grassrootseconomics/openethereum
7
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

reverse caching: pass API into middleware

Browse Source
This commit is contained in:
Jannis R 2017-01-09 16:59:33 +01:00
parent 8c2aa4d87c
commit 61a42cc7e4
No known key found for this signature in database
GPG Key ID: 0FE83946296A88A5
2 changed files with 76 additions and 81 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
js/src/redux/middleware.js
View File

@ -33,7 +33,7 @@ export default function (api, browserHistory) {
const certifications = new CertificationsMiddleware(); const certifications = new CertificationsMiddleware();
const routeMiddleware = routerMiddleware(browserHistory); const routeMiddleware = routerMiddleware(browserHistory);
const chain = new ChainMiddleware(); const chain = new ChainMiddleware();
const registry = new RegistryMiddleware(); const registry = new RegistryMiddleware(api);
const middleware = [ const middleware = [
settings.toMiddleware(), settings.toMiddleware(),
@ -41,7 +41,7 @@ export default function (api, browserHistory) {
errors.toMiddleware(), errors.toMiddleware(),
certifications.toMiddleware(), certifications.toMiddleware(),
chain.toMiddleware(), chain.toMiddleware(),
registry.toMiddleware() registry
]; ];
return middleware.concat(status, routeMiddleware, thunk); return middleware.concat(status, routeMiddleware, thunk);

153
js/src/redux/providers/registry/middleware.js
View File

@ -21,90 +21,85 @@ import registryABI from '~/contracts/abi/registry.json';
import { setReverse, startCachingReverses } from './actions'; import { setReverse, startCachingReverses } from './actions';
export default class RegistryMiddleware { export default (api) => (store) => {
toMiddleware () { let contract, confirmedEvents, removedEvents, timeout, interval;
return (store) => {
const api = Contracts.get()._api;
let contract, confirmedEvents, removedEvents, timeout, interval;
let addressesToCheck = {}; let addressesToCheck = {};
const onLog = (log) => { const onLog = (log) => {
switch (log.event) { switch (log.event) {
case 'ReverseConfirmed': case 'ReverseConfirmed':
addressesToCheck[log.params.reverse.value] = true; addressesToCheck[log.params.reverse.value] = true;
break; break;
case 'ReverseRemoved': case 'ReverseRemoved':
delete addressesToCheck[log.params.reverse.value]; delete addressesToCheck[log.params.reverse.value];
break; break;
} }
}; };
const checkReverses = () => { const checkReverses = () => {
Object Object
.keys(addressesToCheck) .keys(addressesToCheck)
.forEach((address) => { .forEach((address) => {
contract contract
.instance .instance
.reverse .reverse
.call({}, [ address ]) .call({}, [ address ])
.then((reverse) => store.dispatch(setReverse(address, reverse))); .then((reverse) => store.dispatch(setReverse(address, reverse)));
});
addressesToCheck = {};
};
return (next) => (action) => {
switch (action.type) {
case 'initAll':
next(action);
store.dispatch(startCachingReverses());
break;
case 'startCachingReverses':
const { registry } = Contracts.get();
registry.getInstance()
.then((instance) => api.newContract(registryABI, instance.address))
.then((_contract) => {
contract = _contract;
confirmedEvents = subscribeToEvent(_contract, 'ReverseConfirmed');
confirmedEvents.on('log', onLog);
removedEvents = subscribeToEvent(_contract, 'ReverseRemoved');
removedEvents.on('log', onLog);
timeout = setTimeout(checkReverses, 5000);
interval = setInterval(checkReverses, 20000);
})
.catch((err) => {
console.error('Failed to start caching reverses:', err);
throw err;
}); });
addressesToCheck = {}; break;
}; case 'stopCachingReverses':
if (confirmedEvents) {
return (next) => (action) => { confirmedEvents.unsubscribe();
switch (action.type) {
case 'initAll':
next(action);
store.dispatch(startCachingReverses());
break;
case 'startCachingReverses':
const { registry } = Contracts.get();
registry.getInstance()
.then((instance) => api.newContract(registryABI, instance.address))
.then((_contract) => {
contract = _contract;
confirmedEvents = subscribeToEvent(_contract, 'ReverseConfirmed');
confirmedEvents.on('log', onLog);
removedEvents = subscribeToEvent(_contract, 'ReverseRemoved');
removedEvents.on('log', onLog);
timeout = setTimeout(checkReverses, 5000);
interval = setInterval(checkReverses, 20000);
})
.catch((err) => {
console.error('Failed to start caching reverses:', err);
throw err;
});
break;
case 'stopCachingReverses':
if (confirmedEvents) {
confirmedEvents.unsubscribe();
}
if (removedEvents) {
removedEvents.unsubscribe();
}
if (interval) {
clearInterval(interval);
}
if (timeout) {
clearTimeout(timeout);
}
break;
default:
next(action);
} }
}; if (removedEvents) {
}; removedEvents.unsubscribe();
} }
} if (interval) {
clearInterval(interval);
}
if (timeout) {
clearTimeout(timeout);
}
break;
default:
next(action);
}
};
};