10967725754

Committed 20 Sep 2024 11:43PM UTC coverage: 99.294%. Remained the same

Build # 10967725754

Build Type

Pull #49

github

Committed by

web-flow

Commit Message

Merge e6cbf7991 into 59affc166

Pull Request Pull Request #49: chore(deps): bump body-parser and express

Run Details

76 of 80 branches covered (95.0%)

Branch coverage included in aggregate %.

627 of 628 relevant lines covered (99.84%)

5.77 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

95.65

/src/processor.ts

import {
    BlockData as BlockDataEvm,
    BlockHeader,
    DataHandlerContext,
    EvmBatchProcessor,
    EvmBatchProcessorFields,
    Log as _Log,
    Transaction as _Transaction,
} from '@subsquid/evm-processor';
import { events as CartesiDApp } from './abi/CartesiDApp';
import { events as CartesiDAppFactory } from './abi/CartesiDAppFactory';
import { events as InputBox } from './abi/InputBox';
import {
    CartesiDAppFactoryAddress,
    InputBoxAddress,
    getConfig,
} from './config';
import { loadApplications } from './utils';

export type NetworkConfig = {
    archive: string;
    rpcUrl: string;
};

export const createProcessor = (chainId: number) => {
    const applicationMetadata = loadApplications(chainId);
    const config = getConfig(chainId);
    let processor = new EvmBatchProcessor()
        .setFinalityConfirmation(config.finalityConfirmation ?? 10)
        .setFields({
            transaction: {
                chainId: true,
                from: true,
                value: true,
                hash: true,
            },
        })
        .setBlockRange({
            from: config.from,
        })
        .addLog({
            address: [CartesiDAppFactoryAddress],
            topic0: [CartesiDAppFactory.ApplicationCreated.topic],
        })
        .addLog({
            address: [InputBoxAddress],
            topic0: [InputBox.InputAdded.topic],
            transaction: true,
        });

    processor = config.dataSource.archive
        ? processor.setGateway(config.dataSource.archive)
        : processor;

    processor = config.dataSource.rpcEndpoint
        ? processor.setRpcEndpoint(config.dataSource.rpcEndpoint)
        : processor;

    if (applicationMetadata !== null) {
        processor = processor
            .addLog({
                address:
                    applicationMetadata.addresses[CartesiDAppFactoryAddress],
                topic0: [CartesiDApp.OwnershipTransferred.topic],
                range: { from: config.from, to: applicationMetadata.height },
                transaction: true,
            })
            .addLog({
                topic0: [CartesiDApp.OwnershipTransferred.topic],
                range: { from: applicationMetadata.height + 1 },
                transaction: true,
            });
    } else {
        processor = processor.addLog({
            topic0: [CartesiDApp.OwnershipTransferred.topic],
            transaction: true,
        });
    }

    return processor;
};

export type Fields = EvmBatchProcessorFields<typeof createProcessor>;
export type Block = BlockHeader<Fields>;
export type BlockData = BlockDataEvm<Fields>;
export type Log = _Log<Fields>;
export type Transaction = _Transaction<Fields>;
export type ProcessorContext<Store> = DataHandlerContext<Store, Fields>;

1	import {	1✔
2	BlockData as BlockDataEvm,
3	BlockHeader,
4	DataHandlerContext,
5	EvmBatchProcessor,
6	EvmBatchProcessorFields,
7	Log as _Log,
8	Transaction as _Transaction,
9	} from '@subsquid/evm-processor';	1✔
10	import { events as CartesiDApp } from './abi/CartesiDApp';	1✔
11	import { events as CartesiDAppFactory } from './abi/CartesiDAppFactory';	1✔
12	import { events as InputBox } from './abi/InputBox';	1✔
13	import {
14	CartesiDAppFactoryAddress,
15	InputBoxAddress,
16	getConfig,
17	} from './config';	1✔
18	import { loadApplications } from './utils';	1✔
19
20	export type NetworkConfig = {
21	archive: string;
22	rpcUrl: string;
23	};
24
25	export const createProcessor = (chainId: number) => {	1✔
26	const applicationMetadata = loadApplications(chainId);	19✔
27	const config = getConfig(chainId);	19✔
28	let processor = new EvmBatchProcessor()	19✔
29	.setFinalityConfirmation(config.finalityConfirmation ?? 10)	19!
30	.setFields({	19✔
31	transaction: {	19✔
32	chainId: true,	19✔
33	from: true,	19✔
34	value: true,	19✔
35	hash: true,	19✔
36	},	19✔
37	})	19✔
38	.setBlockRange({	19✔
39	from: config.from,	19✔
40	})	19✔
41	.addLog({	19✔
42	address: [CartesiDAppFactoryAddress],	19✔
43	topic0: [CartesiDAppFactory.ApplicationCreated.topic],	19✔
44	})	19✔
45	.addLog({	19✔
46	address: [InputBoxAddress],	19✔
47	topic0: [InputBox.InputAdded.topic],	19✔
48	transaction: true,	19✔
49	});	19✔
50
51	processor = config.dataSource.archive	19✔
52	? processor.setGateway(config.dataSource.archive)	16✔
53	: processor;	2✔
54
55	processor = config.dataSource.rpcEndpoint	19✔
56	? processor.setRpcEndpoint(config.dataSource.rpcEndpoint)	18!
57	: processor;	×
58
59	if (applicationMetadata !== null) {	19✔
60	processor = processor	4✔
61	.addLog({	4✔
62	address:	4✔
63	applicationMetadata.addresses[CartesiDAppFactoryAddress],	4✔
64	topic0: [CartesiDApp.OwnershipTransferred.topic],	4✔
65	range: { from: config.from, to: applicationMetadata.height },	4✔
66	transaction: true,	4✔
67	})	4✔
68	.addLog({	4✔
69	topic0: [CartesiDApp.OwnershipTransferred.topic],	4✔
70	range: { from: applicationMetadata.height + 1 },	4✔
71	transaction: true,	4✔
72	});	4✔
73	} else {	19✔
74	processor = processor.addLog({	14✔
75	topic0: [CartesiDApp.OwnershipTransferred.topic],	14✔
76	transaction: true,	14✔
77	});	14✔
78	}	14✔
79
80	return processor;	18✔
81	};	18✔
82
83	export type Fields = EvmBatchProcessorFields<typeof createProcessor>;
84	export type Block = BlockHeader<Fields>;
85	export type BlockData = BlockDataEvm<Fields>;
86	export type Log = _Log<Fields>;
87	export type Transaction = _Transaction<Fields>;
88	export type ProcessorContext<Store> = DataHandlerContext<Store, Fields>;

cartesi / rollups-explorer-api / 10967725754

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous