1951450229

Build # 1951450229

Build Type

github

Committed by GitHub

Commit Message

Merge 7ede126db into f78bf8f99

Pull Request Pull Request #74: Terra integration

Run Details

513 of 538 branches covered (95.35%)

Branch coverage included in aggregate %.

298 of 350 new or added lines in 11 files covered. (85.14%)

8 existing lines in 2 files now uncovered.

13236 of 13332 relevant lines covered (99.28%)

39.0 hits per line

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

91.49

/src/internal/rpcconnector.ts

import type {ChainIdTypeMap, StringMap} from "@common/types";

import {terraChainIdName} from "@common/chainid";

import {
    type Provider,
    Web3Provider
}  from "@ethersproject/providers";

import {LCDClient} from "@terra-money/terra.js";

import {MiniRpcProvider} from "./minirpc";

interface RpcConnectorArgs {
    urls:           StringMap,
    batchInterval?: number,
}

export class EvmRpcConnector {
    protected _providers:     ChainIdTypeMap<MiniRpcProvider>;
    protected _web3Providers: ChainIdTypeMap<Web3Provider>

    protected _chainEndpoints: {[chainId: number]: string};


    constructor(args: RpcConnectorArgs) {
        const {urls, batchInterval=50} = args;

        this._chainEndpoints = urls;

        const miniRpcProviders = Object.keys(urls).reduce((acc, chainId) => {
            const cid = Number(chainId);
            acc[cid]  = this._newProvider(cid, urls[cid], batchInterval);
            return acc
        }, {});

        const web3Providers = Object.keys(miniRpcProviders).reduce((acc, chainId) => {
            const cid = Number(chainId);
            acc[cid]  = new Web3Provider(miniRpcProviders[cid]);
            return acc
        }, {});

        this._providers     = miniRpcProviders;
        this._web3Providers = web3Providers;
    }

    provider(chainId: number): Provider {
        return this._web3Providers[chainId]
    }

    /**
     * @internal
     */
    setProviderConfig(
        chainId:       number,
        endpoint:      string,
        batchInterval: number = 50,
    ) {
        const provider = this._newProvider(chainId, endpoint, batchInterval);

        delete this._chainEndpoints[chainId];
        delete this._providers[chainId];
        delete this._web3Providers[chainId];

        this._chainEndpoints[chainId] = endpoint;
        this._providers[chainId]      = provider
        this._web3Providers[chainId]  = new Web3Provider(provider);
    }

    private _newProvider(
        chainId:       number,
        endpoint:      string,
        batchInterval: number
    ): MiniRpcProvider {
        return new MiniRpcProvider(
            chainId,
            endpoint,
            batchInterval
        );
    }
}

export class TerraRpcConnector {
    protected _providers:      ChainIdTypeMap<LCDClient>;
    protected _chainEndpoints: {[chainId: number]: string};

    constructor(args: Omit<RpcConnectorArgs, "batchInterval">) {
        const {urls} = args;

        this._chainEndpoints = urls;

        this._providers = Object.keys(urls).reduce((acc, chainId) => {
            const cid = Number(chainId);
            acc[cid]  = this._newProvider(cid, urls[cid]);
            return acc
        }, {});
    }

    provider(chainId: number): LCDClient {
        return this._providers[chainId]
    }

    /**
     * @internal
     */
    setProviderConfig(
        chainId:       number,
        endpoint:      string,
        batchInterval: number = 50,
    ) {
        const provider = this._newProvider(chainId, endpoint);

        delete this._chainEndpoints[chainId];
        delete this._providers[chainId];

        this._chainEndpoints[chainId] = endpoint;
        this._providers[chainId]      = provider
    }

    private _newProvider(
        chainId:       number,
        endpoint:      string,
    ): LCDClient {
        return new LCDClient({
          URL:     endpoint,
          chainID: terraChainIdName(chainId),
        })
    }
}

1	import type {ChainIdTypeMap, StringMap} from "@common/types";	2✔
2		2✔
3	import {terraChainIdName} from "@common/chainid";	2✔
4		2✔
5	import {	2✔
6	type Provider,	2✔
7	Web3Provider	2✔
8	} from "@ethersproject/providers";	2✔
9		2✔
10	import {LCDClient} from "@terra-money/terra.js";	2✔
11		2✔
12	import {MiniRpcProvider} from "./minirpc";	2✔
13		2✔
14	interface RpcConnectorArgs {	2✔
15	urls: StringMap,	2✔
16	batchInterval?: number,	2✔
17	}	2✔
18		2✔
19	export class EvmRpcConnector {	2✔
20	protected _providers: ChainIdTypeMap<MiniRpcProvider>;	2✔
21	protected _web3Providers: ChainIdTypeMap<Web3Provider>	12✔
22		12✔
23	protected _chainEndpoints: {[chainId: number]: string};	2✔
24		2✔
25		2✔
26	constructor(args: RpcConnectorArgs) {	2✔
27	const {urls, batchInterval=50} = args;	12✔
28		12✔
29	this._chainEndpoints = urls;	12✔
30		12✔
31	const miniRpcProviders = Object.keys(urls).reduce((acc, chainId) => {	12✔
32	const cid = Number(chainId);	168✔
33	acc[cid] = this._newProvider(cid, urls[cid], batchInterval);	168✔
34	return acc	168✔
35	}, {});	12✔
36		12✔
37	const web3Providers = Object.keys(miniRpcProviders).reduce((acc, chainId) => {	12✔
38	const cid = Number(chainId);	168✔
39	acc[cid] = new Web3Provider(miniRpcProviders[cid]);	168✔
40	return acc	168✔
41	}, {});	12✔
42		12✔
43	this._providers = miniRpcProviders;	12✔
44	this._web3Providers = web3Providers;	12✔
45	}	12✔
46		2✔
47	provider(chainId: number): Provider {	2✔
48	return this._web3Providers[chainId]	2,568✔
49	}	2,568✔
50		2✔
51	/**	2✔
52	* @internal	2✔
53	*/	2✔
54	setProviderConfig(	2✔
55	chainId: number,	4✔
56	endpoint: string,	4✔
57	batchInterval: number = 50,	4✔
58	) {	4✔
59	const provider = this._newProvider(chainId, endpoint, batchInterval);	4✔
60		4✔
61	delete this._chainEndpoints[chainId];	4✔
62	delete this._providers[chainId];	4✔
63	delete this._web3Providers[chainId];	4✔
64		4✔
65	this._chainEndpoints[chainId] = endpoint;	4✔
66	this._providers[chainId] = provider	4✔
67	this._web3Providers[chainId] = new Web3Provider(provider);	4✔
68	}	4✔
69		2✔
70	private _newProvider(	2✔
71	chainId: number,	172✔
72	endpoint: string,	172✔
73	batchInterval: number	172✔
74	): MiniRpcProvider {	172✔
75	return new MiniRpcProvider(	172✔
76	chainId,	172✔
77	endpoint,	172✔
78	batchInterval	172✔
79	);	172✔
80	}	172✔
81	}	2✔
82		2✔
83	export class TerraRpcConnector {	2✔
84	protected _providers: ChainIdTypeMap<LCDClient>;	2✔
85	protected _chainEndpoints: {[chainId: number]: string};	2✔
86		2✔
87	constructor(args: Omit<RpcConnectorArgs, "batchInterval">) {	2✔
88	const {urls} = args;	12✔
89		12✔
90	this._chainEndpoints = urls;	12✔
91		12✔
92	this._providers = Object.keys(urls).reduce((acc, chainId) => {	12✔
93	const cid = Number(chainId);	12✔
94	acc[cid] = this._newProvider(cid, urls[cid]);	12✔
95	return acc	12✔
96	}, {});	12✔
97	}	12✔
98		2✔
99	provider(chainId: number): LCDClient {	2✔
100	return this._providers[chainId]	6✔
101	}	6✔
102		2✔
103	/**	2✔
104	* @internal	2✔
105	*/	2✔
106	setProviderConfig(	2✔
NEW 107	chainId: number,	×
NEW 108	endpoint: string,	×
NEW 109	batchInterval: number = 50,	×
NEW 110	) {	×
NEW 111	const provider = this._newProvider(chainId, endpoint);	×
NEW 112		×
NEW 113	delete this._chainEndpoints[chainId];	×
NEW 114	delete this._providers[chainId];	×
NEW 115		×
NEW 116	this._chainEndpoints[chainId] = endpoint;	×
NEW 117	this._providers[chainId] = provider	×
NEW 118	}	×
119		2✔
120	private _newProvider(	2✔
121	chainId: number,	12✔
122	endpoint: string,	12✔
123	): LCDClient {	12✔
124	return new LCDClient({	12✔
125	URL: endpoint,	12✔
126	chainID: terraChainIdName(chainId),	12✔
127	})	12✔
128	}	12✔
129	}	2✔

synapsecns / sdk / 1951450229

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