2602741271

Build Type

github

Committed by GitHub

Commit Message

Merge 8d6915ddb into 71eebf429

Pull Request Pull Request #123: Add support for Klaytn, SFI

Run Details

25 of 38 branches covered (65.79%)

Branch coverage included in aggregate %.

8 of 121 new or added lines in 8 files covered. (6.61%)

4944 existing lines in 20 files now uncovered.

1431 of 6507 relevant lines covered (21.99%)

0.95 hits per line

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

76.83

/src/internal/rpcconnector.ts

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

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

import {MiniRpcProvider} from "./minirpc";

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

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

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


    constructor(args: RpcConnectorArgs) {
        /* c8 ignore next */
        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
        );
    }
}

1	import type {ChainIdTypeMap} from "@chainid";	2✔
2	import type {StringMap} from "@common/types";	2✔
3		2✔
4	import type {Provider} from "@ethersproject/providers";	2✔
5	import {Web3Provider} from "@ethersproject/providers";	2✔
6		2✔
7	import {MiniRpcProvider} from "./minirpc";	2✔
8		2✔
9	interface RpcConnectorArgs {	2✔
10	urls: StringMap;	2✔
11	batchInterval?: number;	2✔
12	}	2✔
13		2✔
14	export class RpcConnector {	12✔
15	protected _providers: ChainIdTypeMap<MiniRpcProvider>;	12✔
16	protected _web3Providers: ChainIdTypeMap<Web3Provider>	12✔
17		12✔
18	protected _chainEndpoints: {[chainId: number]: string};	12✔
19		12✔
20		12✔
21	constructor(args: RpcConnectorArgs) {	12✔
22	/* c8 ignore next */	2✔
23	const {urls, batchInterval=50} = args;	2✔
24		12✔
25	this._chainEndpoints = urls;	12✔
26		12✔
27	const miniRpcProviders = Object.keys(urls).reduce((acc, chainId) => {	12✔
28	const cid = Number(chainId);	12✔
29	acc[cid] = this._newProvider(cid, urls[cid], batchInterval);	12✔
30	return acc	12✔
31	}, {});	12✔
32		12✔
33	const web3Providers = Object.keys(miniRpcProviders).reduce((acc, chainId) => {	12✔
UNCOV 34	const cid = Number(chainId);	×
UNCOV 35	acc[cid] = new Web3Provider(miniRpcProviders[cid]);	×
UNCOV 36	return acc	×
37	}, {});	12✔
38		12✔
39	this._providers = miniRpcProviders;	12✔
40	this._web3Providers = web3Providers;	12✔
41	}	12✔
42		12✔
43	provider(chainId: number): Provider {	12✔
UNCOV 44	return this._web3Providers[chainId]	×
UNCOV 45	}	×
46		12✔
47	/**	12✔
48	* @internal	12✔
49	*/	12✔
50	setProviderConfig(	12✔
UNCOV 51	chainId: number,	×
UNCOV 52	endpoint: string,	×
UNCOV 53	batchInterval: number = 50,	×
UNCOV 54	) {	×
UNCOV 55	const provider = this._newProvider(chainId, endpoint, batchInterval);	×
UNCOV 56		×
UNCOV 57	delete this._chainEndpoints[chainId];	×
UNCOV 58	delete this._providers[chainId];	×
UNCOV 59	delete this._web3Providers[chainId];	×
UNCOV 60		×
UNCOV 61	this._chainEndpoints[chainId] = endpoint;	×
UNCOV 62	this._providers[chainId] = provider	×
UNCOV 63	this._web3Providers[chainId] = new Web3Provider(provider);	×
UNCOV 64	}	×
65		12✔
66	private _newProvider(	12✔
67	chainId: number,	12✔
68	endpoint: string,	12✔
69	batchInterval: number	12✔
70	): MiniRpcProvider {	12✔
71	return new MiniRpcProvider(	12✔
72	chainId,	12✔
73	endpoint,	12✔
74	batchInterval	12✔
75	);	12✔
76	}	12✔
77	}	12✔

synapsecns / sdk / 2602741271

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