// Copyright 2015-2017 Parity Technologies (UK) Ltd.
// This file is part of Parity.
// Parity is free software: you can redistribute it and/or modify
// it under the terms of the GNU General Public License as published by
// the Free Software Foundation, either version 3 of the License, or
// (at your option) any later version.
// Parity is distributed in the hope that it will be useful,
// but WITHOUT ANY WARRANTY; without even the implied warranty of
// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
// GNU General Public License for more details.
// You should have received a copy of the GNU General Public License
// along with Parity. If not, see .
import React, { Component } from 'react';
import PropTypes from 'prop-types';
import { api } from '../../parity';
import Container from '../../Container';
import Event from '../Event';
import styles from './events.css';
export default class Events extends Component {
static contextTypes = {
managerInstance: PropTypes.object.isRequired
}
state = {
blocks: {},
loading: true,
events: [],
minedEvents: [],
pendingEvents: []
}
componentDidMount () {
const { managerInstance } = this.context;
const options = {
fromBlock: 0,
toBlock: 'pending',
limit: 50
};
managerInstance.Created
.subscribe(options, this.receiveCreatedEvents)
.then((subscriptionIdCreated) => {
this.setState({ subscriptionIdCreated });
});
}
componentWillUnmount () {
const { managerInstance } = this.context;
const { subscriptionIdCreated } = this.state;
managerInstance.Created.unsubscribe(subscriptionIdCreated);
}
render () {
const { loading } = this.state;
return (
{ loading ? this.renderLoading() : this.renderEvents() }
);
}
renderEvents () {
const { events } = this.state;
return events.length
? this.renderEventsList()
: this.renderEventsNone();
}
renderEventsNone () {
return (
There are currently no events available
);
}
renderEventsList () {
const { events } = this.state;
const rows = events.map((event) => {
return (
);
});
return (
);
}
renderLoading () {
return (
Loading events
);
}
logToEvent = (log) => {
log.key = api.util.sha3(JSON.stringify(log));
log.params = Object.keys(log.params).reduce((params, name) => {
params[name] = log.params[name].value;
return params;
}, {});
return log;
}
receiveCreatedEvents = (error, logs) => {
if (error) {
console.error('receiveLogs', error);
return;
}
const { minedEvents, pendingEvents } = this.state;
const minedNew = logs
.filter((log) => log.type === 'mined')
.map(this.logToEvent)
.filter((log) => !minedEvents.find((event) => event.transactionHash === log.transactionHash))
.reverse()
.concat(minedEvents);
const pendingNew = logs
.filter((log) => log.type === 'pending')
.map(this.logToEvent)
.filter((log) => !pendingEvents.find((event) => event.transactionHash === log.transactionHash))
.reverse()
.concat(pendingEvents)
.filter((log) => !minedNew.find((event) => event.transactionHash === log.transactionHash));
const events = [].concat(pendingNew).concat(minedNew);
this.setState({ loading: false, events, minedEvents: minedNew, pendingEvents: pendingNew });
}
}