neptune/ghost-portal
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Check all endpoints for wss:// (#5493)

Browse Source 
* Check all endpoints for wss://

* Remove useless (ignored) padding

* cleanup

* value check

* Expectation

* drop space

* Check all endpoints
This commit is contained in:
Jaco 2021-06-08 08:48:34 +03:00 committed by GitHub
parent f1f559f136
commit 29adf4cfe3
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
2 changed files with 80 additions and 70 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

122
packages/apps-config/src/ciChainTypes.spec.ts
View File

@ -28,74 +28,80 @@ const FAILURES: string[] = [
const TICK = '`';
const endpoints = createWsEndpoints((k: string, v?: string) => v || k, true)
.filter(({ isDisabled, isUnreachable, value }) =>
!isDisabled && !isUnreachable && value && isString(value) && !value.startsWith('ws://')
)
.map((o): Partial<Endpoint> => ({ name: o.text as string, ws: o.value as string }))
.filter((v): v is Endpoint => !!v.ws);
describe('--SLOW--: check configured chain connections', (): void => {
endpoints.forEach(({ name, ws }) =>
it(`${name} @ ${ws}`, async (): Promise<void> => {
const [,, hostWithPort] = ws.split('/');
const [host] = hostWithPort.split(':');
createWsEndpoints((k: string, v?: string) => v || k)
.filter(({ isDisabled, isUnreachable, value }) =>
!isDisabled &&
!isUnreachable &&
value &&
isString(value) &&
!value.includes('127.0.0.1')
)
.map(({ text, value }): Partial<Endpoint> => ({
name: text as string,
ws: value as string
}))
.filter((v): v is Endpoint => !!v.ws)
.forEach(({ name, ws }) =>
it(`${name} @ ${ws}`, async (): Promise<void> => {
const [,, hostWithPort] = ws.split('/');
const [host] = hostWithPort.split(':');
const response = await fetch(`https://dns.google/resolve?name=${host}`);
const json = await response.json() as DnsResponse;
const response = await fetch(`https://dns.google/resolve?name=${host}`);
const json = await response.json() as DnsResponse;
let provider: WsProvider | null = null;
let api: ApiPromise | null = null;
let timerId: NodeJS.Timeout | null = null;
let provider: WsProvider | null = null;
let api: ApiPromise | null = null;
let timerId: NodeJS.Timeout | null = null;
try {
assert(json.Answer, `No DNS entry for ${host}`);
try {
assert(json.Answer, `No DNS entry for ${host}`);
provider = new WsProvider(ws, false);
api = new ApiPromise({
provider,
throwOnConnect: true,
typesBundle,
typesChain
});
provider = new WsProvider(ws, false);
api = new ApiPromise({
provider,
throwOnConnect: true,
typesBundle,
typesChain
});
setTimeout((): void => {
provider && provider.connect().catch(() => undefined);
}, 1000);
setTimeout((): void => {
provider && provider.connect().catch(() => undefined);
}, 1000);
await Promise.race([
// eslint-disable-next-line promise/param-names
new Promise((_, reject): void => {
timerId = setTimeout((): void => {
timerId = null;
reject(new Error(`Timeout connecting to ${ws}`));
}, 60_000);
}),
api.isReadyOrError
]);
} catch (error) {
if (isError(error) && FAILURES.some((f) => (error as Error).message.includes(f))) {
process.env.CI_LOG && fs.appendFileSync('./.github/chain-types.md', `\n${TICK}${ws.padStart(52, ' ')}: ${error.message}${TICK}`);
await Promise.race([
// eslint-disable-next-line promise/param-names
new Promise((_, reject): void => {
timerId = setTimeout((): void => {
timerId = null;
reject(new Error(`Timeout connecting to ${ws}`));
}, 60_000);
}),
api.isReadyOrError
]);
} catch (error) {
if (isError(error) && FAILURES.some((f) => (error as Error).message.includes(f))) {
process.env.CI_LOG && fs.appendFileSync('./.github/chain-types.md', `\n${TICK}${name} @ ${ws} ${error.message}${TICK}`);
throw error;
}
} finally {
if (timerId) {
clearTimeout(timerId);
}
throw error;
}
} finally {
if (timerId) {
clearTimeout(timerId);
}
if (provider) {
try {
if (api) {
await api.disconnect();
} else {
await provider.disconnect();
if (provider) {
try {
if (api) {
await api.disconnect();
} else {
await provider.disconnect();
}
} catch {
// ignore
}
} catch {
// ignore
}
}
}
})
);
})
);
});

28
packages/apps-config/src/endpoints/index.spec.ts
View File

@ -10,17 +10,21 @@ interface Endpoint {
ws: string;
}
const endpoints = createWsEndpoints((k: string, v?: string) => v || k, true)
.filter(({ value }) =>
value && isString(value) && !value.includes('127.0.0.1')
)
.map((o): Partial<Endpoint> => ({ name: o.text as string, ws: o.value as string }))
.filter((v): v is Endpoint => !!v.ws);
describe('urls are all valid', (): void => {
endpoints.forEach(({ name, ws }) =>
it(`${name} @ ${ws}`, (): void => {
assert(ws.startsWith('wss://'), `Expected ${ws} endpoint to start with wss:// `);
})
);
createWsEndpoints((k: string, v?: string) => v || k)
.filter(({ value }) =>
value &&
isString(value) &&
!value.includes('127.0.0.1')
)
.map(({ text, value }): Partial<Endpoint> => ({
name: text as string,
ws: value as string
}))
.filter((v): v is Endpoint => !!v.ws)
.forEach(({ name, ws }) =>
it(`${name} @ ${ws}`, (): void => {
assert(ws.startsWith('wss://'), `${name} @ ${ws} should start with wss://`);
})
);
});