-
Notifications
You must be signed in to change notification settings - Fork 0
/
testHelpers.ts
49 lines (43 loc) · 1.53 KB
/
testHelpers.ts
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
import { rpc } from "./packages/neon-core/src";
export const TESTNET_URLS = [
"http://seed1t4.neo.org:20332",
"http://seed2t4.neo.org:20332",
"http://seed3t4.neo.org:20332",
"http://seed4t4.neo.org:20332",
"http://seed5t4.neo.org:20332",
];
//Node17+ defaults to resolving IPv6 by default so localhost does not work anymore.
export const LOCALNET_URLS = ["http://127.0.0.1:20332"];
export async function getIntegrationEnvUrl(): Promise<string> {
const urls = isTestNet() ? TESTNET_URLS : LOCALNET_URLS;
return await getBestUrl(urls);
}
export function isTestNet(): boolean {
return (global["__TARGETNET__"] as string).toLowerCase() === "testnet";
}
export async function sleep(ms: number): Promise<void> {
return new Promise((resolve) => setTimeout(resolve, ms));
}
export async function getBestUrl(urls: string[]): Promise<string> {
const data = await Promise.all(urls.map((url) => safelyCheckHeight(url)));
const heights = data.map((h, i) => ({ height: h, url: urls[i] }));
const best = heights.reduce(
(bestSoFar, h) => (bestSoFar.height >= h.height ? bestSoFar : h),
{ height: -1, url: "" }
);
if (!best.url) {
throw new Error("No good endpoint found");
}
return best.url;
}
async function safelyCheckHeight(url: string): Promise<number> {
try {
const res = await rpc.sendQuery(url, rpc.Query.getBlockCount(), {
timeout: 10000,
});
return res.result;
} catch (_e) {
console.log("Error while checking RPC height:" + _e);
return -1;
}
}