Skip to content

Commit 4f2e5c7

Browse files
committed
Fixes for bignum conversion
1 parent 43be176 commit 4f2e5c7

File tree

3 files changed

+12
-3
lines changed

3 files changed

+12
-3
lines changed

CHANGELOG.md

Lines changed: 5 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,9 @@
11

2-
# 0.1.10 -- Bugfixes
2+
# 0.1.12 -- Bugfixes
3+
4+
- Fix for big number conversion on new events
5+
6+
# 0.1.11 -- Bugfixes
37

48
- Fix for `eth-query` dependency mismatch
59
- Fix for big numbers on block numbers on new events

package.json

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,6 @@
11
{
22
"name": "eth-indexer",
3-
"version": "0.1.11",
3+
"version": "0.1.12",
44
"description": "High performance Ethereum smart contract event indexing for fast local retrieval",
55
"author": "Dominiek Ter Heide <[email protected]>",
66
"license": "MIT",

src/index.js

Lines changed: 6 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -9,6 +9,7 @@ import mongodbStore from './stores/mongodb';
99
import elasticsearchStore from './stores/elasticsearch';
1010
import levelStore from './stores/level';
1111
import { serialize, unserialize } from './utils';
12+
import BigNumber from 'bignumber.js';
1213

1314
export const stores = {
1415
memory: memoryStore,
@@ -99,7 +100,11 @@ export class Indexer {
99100
}
100101
this.blockchain.readNewEvents(toBlock, async (event) => {
101102
logger.log('info', `Processing real-time Ethereum ${event.event} event`);
102-
this.store.put([event]);
103+
const normalizeEvent = event;
104+
normalizeEvent.blockNumber = new BigNumber(normalizeEvent.blockNumber);
105+
normalizeEvent.transactionIndex = new BigNumber(normalizeEvent.transactionIndex);
106+
normalizeEvent.logIndex = new BigNumber(normalizeEvent.logIndex);
107+
this.store.put([normalizeEvent]);
103108
});
104109
this.blockchain.readAllEvents(
105110
fromBlock,

0 commit comments

Comments
 (0)