PublicMirrors/hydra
1
0
Fork 0
mirror of https://github.com/hydralauncher/hydra.git synced 2025-02-03 00:33:49 +03:00
Code Issues Actions 1 Packages Projects Releases 1 Wiki Activity

feat(webTorrentHealth): update recursive function with a loop

Browse Source
This commit is contained in:
ChristoferMendes 2024-05-16 08:34:42 -03:00
parent 7a2b693397
commit 539f444ab5
1 changed files with 19 additions and 20 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

39
src/main/services/web-torrent-data.ts
View File

@ -1,4 +1,4 @@
import WebTorrentHealth from "webtorrent-health";
import webTorrentHealth from "webtorrent-health";
type WebTorrentHealthData = {
seeds: number;
@ -6,27 +6,26 @@ type WebTorrentHealthData = {
};
export const webTorrentData = {
async getSeedersAndPeers(magnet: string, retry = 0, timeout = 1500) {
return new Promise((resolve, reject) => {
WebTorrentHealth(
magnet,
{ timeout },
(err: Error, data: WebTorrentHealthData) => {
if (err) {
return reject(err);
}
async getSeedersAndPeers(
magnet: string
): Promise<{ seeders: number; peers: number }> {
let peers = 0;
let seeds = 0;
let retry = 0;
const { peers, seeds } = data;
while (retry < 3 && (!peers || !seeds)) {
try {
const data: WebTorrentHealthData = await webTorrentHealth(magnet, {
timeout: 1500 * (retry + 1),
});
if ((!peers || !seeds) && retry < 3) {
return resolve(
webTorrentData.getSeedersAndPeers(magnet, retry + 1, timeout * 2)
);
}
peers = data.peers;
seeds = data.seeds;
} catch (e) {
retry++;
}
}
return resolve({ peers, seeders: seeds });
}
);
});
return { peers, seeders: seeds };
},
};