aboutsummaryrefslogtreecommitdiffstats
path: root/src/utils/abi_decoder.ts
blob: 05389a05f67465e0730e5edfdd1bcea56c7ef407 (plain) (blame)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
import * as Web3 from 'web3';
import * as _ from 'lodash';
import {AbiType, DecodedLogArgs, DecodedArgs} from '../types';
import * as SolidityCoder from 'web3/lib/solidity/coder';

export class AbiDecoder {
    private savedABIs: Web3.AbiDefinition[] = [];
    private methodIds: {[signatureHash: string]: Web3.EventAbi} = {};
    constructor(abiArrays: Web3.AbiDefinition[][]) {
        _.map(abiArrays, this.addABI.bind(this));
    }
    public decodeLog(logItem: Web3.LogEntry): DecodedArgs|undefined {
        const methodId = logItem.topics[0];
        const event = this.methodIds[methodId];
        if (!_.isUndefined(event)) {
            const logData = logItem.data;
            const decodedParams: DecodedLogArgs = {};
            let dataIndex = 0;
            let topicsIndex = 1;

            const nonIndexedInputs = _.filter(event.inputs, input => !input.indexed);
            const dataTypes = _.map(nonIndexedInputs, input => input.type);
            const decodedData = SolidityCoder.decodeParams(dataTypes, logData.slice(2));
            _.map(event.inputs, (param: Web3.EventParameter) => {
                let value;
                if (param.indexed) {
                    value = logItem.topics[topicsIndex];
                    topicsIndex++;
                } else {
                    value = decodedData[dataIndex];
                    dataIndex++;
                }
                if (param.type === 'address') {
                    value = this.padZeros(new Web3().toBigNumber(value).toString(16));
                } else if (param.type === 'uint256' || param.type === 'uint8' || param.type === 'int' ) {
                    value = new Web3().toBigNumber(value).toString(10);
                }
                decodedParams[param.name] = value;
            });

            return {
                event: event.name,
                args: decodedParams,
            };
        }
    }
    private addABI(abiArray: Web3.AbiDefinition[]): void {
        _.map(abiArray, (abi: Web3.AbiDefinition) => {
            if (abi.type === AbiType.Event) {
                const signature = `${abi.name}(${_.map(abi.inputs, input => input.type).join(',')})`;
                const signatureHash = new Web3().sha3(signature);
                this.methodIds[signatureHash] = abi;
            }
        });
        this.savedABIs = this.savedABIs.concat(abiArray);
    }
    private padZeros(address: string) {
        let formatted = address;
        if (!_.includes(formatted, '0x')) {
            formatted = formatted.slice(2);
        }

        formatted = _.padStart(formatted, 40, '0');
        return '0x' + formatted;
    }
}