1961328472

Build # 1961328472

Build Type

github

Committed by GitHub

Commit Message

<a href="https://github.com/synapsecns/sdk/commit/<a class=hub.com/synapsecns/sdk/commit/5d020df1f4431bd9228e4eb5dd524b81986be7d4">5d020df1f<a href="https://github.com/synapsecns/sdk/commit/5d020df1f4431bd9228e4eb5dd524b81986be7d4">">Merge </a><a class="double-link" href="https://github.com/synapsecns/sdk/commit/<a class="double-link" href="https://github.com/synapsecns/sdk/commit/7e50572fd2a6422a902b640d28cb165c31cf6813">7e50572fd</a>">7e50572fd</a><a href="https://github.com/synapsecns/sdk/commit/5d020df1f4431bd9228e4eb5dd524b81986be7d4"> into 04d4facb5">04d4facb5</a>

Pull Request Pull Request #74: Terra integration

Run Details

561 of 583 branches covered (96.23%)

Branch coverage included in aggregate %.

1126 of 1133 new or added lines in 22 files covered. (99.38%)

1 existing line in 1 file now uncovered.

13484 of 13530 relevant lines covered (99.66%)

39.58 hits per line

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

98.82

/src/internal/rpcproviders.ts

import {fromPairs} from "lodash-es";

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

import {
    ChainId,
    supportedChainIds,
    isTerraChainId
} from "@chainid";
import type {StringMap} from "@common/types";

import {
    EvmRpcConnector,
    TerraRpcConnector
} from "./rpcconnector";

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

enum UriMapKind {
    evm,
    nonEvm,
}

const ENV_KEY_MAP: StringMap = {
    [ChainId.ETH]:       "ETH_RPC_URI",
    [ChainId.OPTIMISM]:  "OPTIMISM_RPC_URI",
    [ChainId.CRONOS]:    "CRONOS_RPC_URI",
    [ChainId.BSC]:       "BSC_RPC_URI",
    [ChainId.POLYGON]:   "POLYGON_RPC_URI",
    [ChainId.FANTOM]:    "FANTOM_RPC_URI",
    [ChainId.BOBA]:      "BOBA_RPC_URI",
    [ChainId.METIS]:     "METIS_RPC_URI",
    [ChainId.MOONBEAM]:  "MOONBEAM_RPC_URI",
    [ChainId.MOONRIVER]: "MOONRIVER_RPC_URI",
    [ChainId.ARBITRUM]:  "ARBITRUM_RPC_URI",
    [ChainId.AVALANCHE]: "AVALANCHE_RPC_URI",
    [ChainId.TERRA]:     "TERRA_RPC_URI",
    [ChainId.AURORA]:    "AURORA_RPC_URI",
    [ChainId.HARMONY]:   "HARMONY_RPC_URI",
}

const CHAIN_RPC_URIS: StringMap = {
    [ChainId.ETH]:       "https://mainnet.infura.io/v3/9aa3d95b3bc440fa88ea12eaa4456161",
    [ChainId.OPTIMISM]:  "https://mainnet.optimism.io",
    [ChainId.CRONOS]:    "https://evm-cronos.crypto.org",
    [ChainId.BSC]:       "https://bsc-dataseed.binance.org/",
    [ChainId.POLYGON]:   "https://polygon-rpc.com/",
    [ChainId.FANTOM]:    "https://rpc.ftm.tools/",
    [ChainId.BOBA]:      "https://replica-oolong.boba.network/",
    [ChainId.METIS]:     "https://andromeda.metis.io/?owner=1088",
    [ChainId.MOONBEAM]:  "https://rpc.api.moonbeam.network",
    [ChainId.MOONRIVER]: "https://rpc.api.moonriver.moonbeam.network",
    [ChainId.ARBITRUM]:  "https://arb1.arbitrum.io/rpc",
    [ChainId.AVALANCHE]: "https://api.avax.network/ext/bc/C/rpc",
    [ChainId.TERRA]:     "https://lcd.terra.dev/",
    [ChainId.AURORA]:    "https://mainnet.aurora.dev",
    [ChainId.HARMONY]:   "https://api.harmony.one/",
}

const
    EVM_CHAINS_URI_MAP:    StringMap = _makeChainIdMap(UriMapKind.evm),
    NONEVM_CHAINS_URI_MAP: StringMap = _makeChainIdMap(UriMapKind.nonEvm);


const RPC_BATCH_INTERVAL = Number(process.env["RPC_BATCH_INTERVAL"]) || 60;

const EVM_RPC_CONNECTOR = new EvmRpcConnector({
    urls:          EVM_CHAINS_URI_MAP,
    batchInterval: RPC_BATCH_INTERVAL
});

const TERRA_RPC_CONNECTOR = new TerraRpcConnector({
    urls: NONEVM_CHAINS_URI_MAP
});

function _makeChainIdMap(mapKind: UriMapKind): StringMap {
    let allChainIds = supportedChainIds();

    let filterFn: (cid: number) => boolean;

    switch (mapKind) {
        case UriMapKind.evm:
            filterFn = cid => !isTerraChainId(cid)
            break;
        case UriMapKind.nonEvm:
            filterFn = cid => isTerraChainId(cid)
            break;
    }

    return fromPairs(
        allChainIds
            .filter(filterFn)
            .map(cid => [cid, _getChainRpcUri(cid)])
    );
}

function _getChainRpcUri(chainId: number): string {
    const
        rpcEnvKey: string           = ENV_KEY_MAP[chainId],
        rpcEnvVal: string|undefined = rpcEnvKey in process.env ? process.env[rpcEnvKey] : undefined;

    return rpcEnvVal ?? CHAIN_RPC_URIS[chainId]
}

/**
 * @param chainId chain id of the network for which to return a provider
 */
export function rpcProviderForChain(chainId: number): Provider {
    if (isTerraChainId(chainId)) {
        console.error("call `terraRpcProvider(chainId)` for a Terra-compatible RPC provider");
        return null
    }

    return EVM_RPC_CONNECTOR.provider(chainId)
}

export function terraRpcProvider(chainId: number = ChainId.TERRA): LCDClient {
    /* c8 ignore next 3 */
    if (!isTerraChainId(chainId)) {
        console.error("call `rpcProviderForChain(chainId)` for an EVM-compatible RPC provider");
        return null
    }

    return TERRA_RPC_CONNECTOR.provider(chainId)
}

export interface RPCEndpointsConfig {
    [chainId: number]: {
        endpoint:       string,
        batchInterval?: number,
    }
}

export function configureRPCEndpoints(config: RPCEndpointsConfig) {
    for (const chainId of supportedChainIds()) {
        if (config[chainId]) {
            let {endpoint, batchInterval} = config[chainId];
            isTerraChainId(chainId)
                ? TERRA_RPC_CONNECTOR.setProviderConfig(chainId, endpoint, batchInterval)
                : EVM_RPC_CONNECTOR.setProviderConfig(chainId, endpoint, batchInterval);
        }
    }
}
/**
 * Used solely for tests, initRpcConnectors() basically just makes sure on-import initialization
 * of Rpc connections occurs before tests run.
 * @internal
 */
export function initRpcConnectors() {}

1	import {fromPairs} from "lodash-es";	2✔
2		2✔
3	import type {Provider} from "@ethersproject/providers";	2✔
4		2✔
5	import {	2✔
6	ChainId,	2✔
7	supportedChainIds,	2✔
8	isTerraChainId	2✔
9	} from "@chainid";	2✔
10	import type {StringMap} from "@common/types";	2✔
11		2✔
12	import {	2✔
13	EvmRpcConnector,	2✔
14	TerraRpcConnector	2✔
15	} from "./rpcconnector";	2✔
16		2✔
17	import {LCDClient} from "@terra-money/terra.js";	2✔
18		2✔
19	enum UriMapKind {	12✔
20	evm,	12✔
21	nonEvm,	12✔
22	}	12✔
23		2✔
24	const ENV_KEY_MAP: StringMap = {	2✔
25	[ChainId.ETH]: "ETH_RPC_URI",	2✔
26	[ChainId.OPTIMISM]: "OPTIMISM_RPC_URI",	2✔
27	[ChainId.CRONOS]: "CRONOS_RPC_URI",	2✔
28	[ChainId.BSC]: "BSC_RPC_URI",	2✔
29	[ChainId.POLYGON]: "POLYGON_RPC_URI",	2✔
30	[ChainId.FANTOM]: "FANTOM_RPC_URI",	2✔
31	[ChainId.BOBA]: "BOBA_RPC_URI",	2✔
32	[ChainId.METIS]: "METIS_RPC_URI",	2✔
33	[ChainId.MOONBEAM]: "MOONBEAM_RPC_URI",	2✔
34	[ChainId.MOONRIVER]: "MOONRIVER_RPC_URI",	2✔
35	[ChainId.ARBITRUM]: "ARBITRUM_RPC_URI",	2✔
36	[ChainId.AVALANCHE]: "AVALANCHE_RPC_URI",	2✔
37	[ChainId.TERRA]: "TERRA_RPC_URI",	2✔
38	[ChainId.AURORA]: "AURORA_RPC_URI",	2✔
39	[ChainId.HARMONY]: "HARMONY_RPC_URI",	2✔
40	}	2✔
41		2✔
42	const CHAIN_RPC_URIS: StringMap = {	2✔
43	[ChainId.ETH]: "https://mainnet.infura.io/v3/9aa3d95b3bc440fa88ea12eaa4456161",	2✔
44	[ChainId.OPTIMISM]: "https://mainnet.optimism.io",	2✔
45	[ChainId.CRONOS]: "https://evm-cronos.crypto.org",	2✔
46	[ChainId.BSC]: "https://bsc-dataseed.binance.org/",	2✔
47	[ChainId.POLYGON]: "https://polygon-rpc.com/",	2✔
48	[ChainId.FANTOM]: "https://rpc.ftm.tools/",	2✔
49	[ChainId.BOBA]: "https://replica-oolong.boba.network/",	2✔
50	[ChainId.METIS]: "https://andromeda.metis.io/?owner=1088",	2✔
51	[ChainId.MOONBEAM]: "https://rpc.api.moonbeam.network",	2✔
52	[ChainId.MOONRIVER]: "https://rpc.api.moonriver.moonbeam.network",	2✔
53	[ChainId.ARBITRUM]: "https://arb1.arbitrum.io/rpc",	2✔
54	[ChainId.AVALANCHE]: "https://api.avax.network/ext/bc/C/rpc",	2✔
55	[ChainId.TERRA]: "https://lcd.terra.dev/",	2✔
56	[ChainId.AURORA]: "https://mainnet.aurora.dev",	2✔
57	[ChainId.HARMONY]: "https://api.harmony.one/",	2✔
58	}	2✔
59		2✔
60	const	2✔
61	EVM_CHAINS_URI_MAP: StringMap = _makeChainIdMap(UriMapKind.evm),	2✔
62	NONEVM_CHAINS_URI_MAP: StringMap = _makeChainIdMap(UriMapKind.nonEvm);	2✔
63		2✔
64		2✔
65	const RPC_BATCH_INTERVAL = Number(process.env["RPC_BATCH_INTERVAL"]) \|\| 60;	2✔
66		2✔
67	const EVM_RPC_CONNECTOR = new EvmRpcConnector({	2✔
68	urls: EVM_CHAINS_URI_MAP,	2✔
69	batchInterval: RPC_BATCH_INTERVAL	2✔
70	});	2✔
71		2✔
72	const TERRA_RPC_CONNECTOR = new TerraRpcConnector({	2✔
73	urls: NONEVM_CHAINS_URI_MAP	2✔
74	});	2✔
75		2✔
76	function _makeChainIdMap(mapKind: UriMapKind): StringMap {	24✔
77	let allChainIds = supportedChainIds();	24✔
78		24✔
79	let filterFn: (cid: number) => boolean;	24✔
80		24✔
81	switch (mapKind) {	24✔
82	case UriMapKind.evm:	24✔
83	filterFn = cid => !isTerraChainId(cid)	12✔
84	break;	12✔
85	case UriMapKind.nonEvm:	24✔
86	filterFn = cid => isTerraChainId(cid)	12✔
87	break;	12✔
88	}	24✔
89		24✔
90	return fromPairs(	24✔
91	allChainIds	24✔
92	.filter(filterFn)	24✔
93	.map(cid => [cid, _getChainRpcUri(cid)])	24✔
94	);	24✔
95	}	24✔
96		2✔
97	function _getChainRpcUri(chainId: number): string {	180✔
98	const	180✔
99	rpcEnvKey: string = ENV_KEY_MAP[chainId],	180✔
100	rpcEnvVal: string\|undefined = rpcEnvKey in process.env ? process.env[rpcEnvKey] : undefined;	180✔
101		180✔
102	return rpcEnvVal ?? CHAIN_RPC_URIS[chainId]	180✔
103	}	180✔
104		2✔
105	/**	2✔
106	* @param chainId chain id of the network for which to return a provider	2✔
107	*/	2✔
108	export function rpcProviderForChain(chainId: number): Provider {	2✔
109	if (isTerraChainId(chainId)) {	2,680✔
110	console.error("call `terraRpcProvider(chainId)` for a Terra-compatible RPC provider");	10✔
111	return null	10✔
112	}	10✔
113		2,670✔
114	return EVM_RPC_CONNECTOR.provider(chainId)	2,670✔
115	}	2,670✔
116		2✔
117	export function terraRpcProvider(chainId: number = ChainId.TERRA): LCDClient {	2✔
118	/* c8 ignore next 3 */	2✔
119	if (!isTerraChainId(chainId)) {	2✔
120	console.error("call `rpcProviderForChain(chainId)` for an EVM-compatible RPC provider");	2✔
121	return null	2✔
NEW 122	}	×
123		48✔
124	return TERRA_RPC_CONNECTOR.provider(chainId)	48✔
125	}	48✔
126		2✔
127	export interface RPCEndpointsConfig {	2✔
128	[chainId: number]: {	2✔
129	endpoint: string,	2✔
130	batchInterval?: number,	2✔
131	}	2✔
132	}	2✔
133		2✔
134	export function configureRPCEndpoints(config: RPCEndpointsConfig) {	2✔
135	for (const chainId of supportedChainIds()) {	2✔
136	if (config[chainId]) {	30✔
137	let {endpoint, batchInterval} = config[chainId];	4✔
138	isTerraChainId(chainId)	4✔
139	? TERRA_RPC_CONNECTOR.setProviderConfig(chainId, endpoint, batchInterval)	4!
140	: EVM_RPC_CONNECTOR.setProviderConfig(chainId, endpoint, batchInterval);	4✔
141	}	4✔
142	}	30✔
143	}	2✔
144	/**	2✔
145	* Used solely for tests, initRpcConnectors() basically just makes sure on-import initialization	2✔
146	* of Rpc connections occurs before tests run.	2✔
147	* @internal	2✔
148	*/	2✔
149	export function initRpcConnectors() {}	2✔

synapsecns / sdk / 1961328472

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