diff options
Diffstat (limited to 'packages/pipeline/src/data_types/events/event_utils.ts')
-rw-r--r-- | packages/pipeline/src/data_types/events/event_utils.ts | 35 |
1 files changed, 35 insertions, 0 deletions
diff --git a/packages/pipeline/src/data_types/events/event_utils.ts b/packages/pipeline/src/data_types/events/event_utils.ts new file mode 100644 index 000000000..6be964807 --- /dev/null +++ b/packages/pipeline/src/data_types/events/event_utils.ts @@ -0,0 +1,35 @@ +import { AbiDecoder } from '@0xproject/utils'; +import { AbiDefinition, LogEntry, LogWithDecodedArgs } from 'ethereum-types'; + +import { EventsResponseResult } from '../../data_sources/etherscan'; + +const hexRadix = 16; + +function hexToInt(hex: string): number { + return parseInt(hex.replace('0x', ''), hexRadix); +} + +// Converts a raw event response to a LogEntry +export function convertResponseToLogEntry(result: EventsResponseResult): LogEntry { + return { + logIndex: hexToInt(result.logIndex), + transactionIndex: hexToInt(result.transactionIndex), + transactionHash: result.transactionHash, + blockHash: '', + blockNumber: hexToInt(result.blockNumber), + address: result.address, + data: result.data, + topics: result.topics, + }; +} + +// Decodes a LogEntry into a LogWithDecodedArgs +export function decodeLogEntry<EventArgsType>( + contractAbi: AbiDefinition[], + log: LogEntry, +): LogWithDecodedArgs<EventArgsType> { + const abiDecoder = new AbiDecoder([contractAbi]); + const logWithDecodedArgs = abiDecoder.tryToDecodeLogOrNoop<EventArgsType>(log); + // tslint:disable-next-line:no-unnecessary-type-assertion + return logWithDecodedArgs as LogWithDecodedArgs<EventArgsType>; +} |