pezkuwichain/phishing
1
0
Fork 0
mirror of https://github.com/pezkuwichain/phishing.git synced 2026-06-14 05:01:03 +00:00
Code Issues Packages Projects Releases Wiki Activity

Do timeout of fetch

Browse Source
This commit is contained in:
Jaco Greeff
2021-02-12 13:11:07 +01:00
parent 935f8008c6
commit 52bb13d50f
1 changed files with 18 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files
packages/phishing/src/addrcheck.spec.ts
+18 -10
View File
@@ -20,6 +20,16 @@ Missing entries found for ${site}: ${JSON.stringify(missing)}
return null; return null;
} }
async function fetchWithTimeout (url: string, timeout = 2000): Promise<Response> {
const controller = new AbortController();
const id = setTimeout(() => controller.abort(), timeout);
const response = await fetch(url, { signal: controller.signal });
clearTimeout(id);
return response;
}
async function loopSome (ours: Record<string, string[]>, site: string, matcher: () => Promise<string[] | null>): Promise<string | null> { async function loopSome (ours: Record<string, string[]>, site: string, matcher: () => Promise<string[] | null>): Promise<string | null> {
const all = Object.values(ours).reduce((all: string[], addrs: string[]): string[] => { const all = Object.values(ours).reduce((all: string[], addrs: string[]): string[] => {
all.push(...addrs); all.push(...addrs);
@@ -32,13 +42,11 @@ async function loopSome (ours: Record<string, string[]>, site: string, matcher:
try { try {
const addresses = await matcher(); const addresses = await matcher();
if (addresses) { addresses && addresses.forEach((address): void => {
addresses.forEach((address): void => { if (address && !found.includes(address)) {
if (address && !found.includes(address)) { found.push(address);
found.push(address); }
} });
});
}
} catch (error) { } catch (error) {
// ignore // ignore
} }
@@ -54,7 +62,7 @@ async function loopSome (ours: Record<string, string[]>, site: string, matcher:
// shared between polkadot.center & polkadot-event.com (addresses are also the same on first run) // shared between polkadot.center & polkadot-event.com (addresses are also the same on first run)
function checkGetWallet (ours: Record<string, string[]>, site: string): Promise<string | null> { function checkGetWallet (ours: Record<string, string[]>, site: string): Promise<string | null> {
return loopSome(ours, site, async (): Promise<string[] | null> => { return loopSome(ours, site, async (): Promise<string[] | null> => {
const result = await (await fetch(`https://${site}/get_wallet.php`)).json() as Record<string, string>; const result = await (await fetchWithTimeout(`https://${site}/get_wallet.php`)).json() as Record<string, string>;
return (result && result.wallet) return (result && result.wallet)
? [result.wallet.replace('\r', '').trim()] ? [result.wallet.replace('\r', '').trim()]
@@ -67,7 +75,7 @@ function checkTag (ours: Record<string, string[]>, url: string, tag: string, att
const site = url.split('/')[2]; const site = url.split('/')[2];
return loopSome(ours, site, async (): Promise<string[] | null> => { return loopSome(ours, site, async (): Promise<string[] | null> => {
const result = await (await fetch(url)).text(); const result = await (await fetchWithTimeout(url)).text();
// /<p id="trnsctin">(.*?)<\/p>/g // /<p id="trnsctin">(.*?)<\/p>/g
const match = new RegExp(`<${tag}${attr ? ` ${attr}` : ''}>(.*?)</${tag}>`, 'g').exec(result); const match = new RegExp(`<${tag}${attr ? ` ${attr}` : ''}>(.*?)</${tag}>`, 'g').exec(result);
@@ -83,7 +91,7 @@ describe('addrcheck', (): void => {
let ours: Record<string, string[]>; let ours: Record<string, string[]>;
beforeAll(async (): Promise<void> => { beforeAll(async (): Promise<void> => {
jest.setTimeout(10 * 60 * 1000); jest.setTimeout(5 * 60 * 1000);
ours = await retrieveAddrList(); ours = await retrieveAddrList();
}); });