diff --git a/src/main/services/repack-tracker/1337x.ts b/src/main/services/repack-tracker/1337x.ts index 8573079b..4f328d09 100644 --- a/src/main/services/repack-tracker/1337x.ts +++ b/src/main/services/repack-tracker/1337x.ts @@ -3,7 +3,7 @@ import { JSDOM } from "jsdom"; import { formatUploadDate } from "@main/helpers"; import { Repack } from "@main/entity"; -import { requestWebPage, savePage } from "./helpers"; +import { requestWebPage, saveRepacks } from "./helpers"; export const request1337x = async (path: string) => requestWebPage(`https://1337xx.to${path}`); @@ -128,7 +128,7 @@ export const getNewRepacksFromUser = async ( if (!newRepacks.length) return; - await savePage(newRepacks); + await saveRepacks(newRepacks); return getNewRepacksFromUser(user, existingRepacks, page + 1); }; diff --git a/src/main/services/repack-tracker/cpg-repacks.ts b/src/main/services/repack-tracker/cpg-repacks.ts index 2b939d08..0c6399a6 100644 --- a/src/main/services/repack-tracker/cpg-repacks.ts +++ b/src/main/services/repack-tracker/cpg-repacks.ts @@ -2,7 +2,7 @@ import { JSDOM } from "jsdom"; import { Repack } from "@main/entity"; -import { requestWebPage, savePage } from "./helpers"; +import { requestWebPage, saveRepacks } from "./helpers"; import { logger } from "../logger"; export const getNewRepacksFromCPG = async ( @@ -58,7 +58,7 @@ export const getNewRepacksFromCPG = async ( if (!newRepacks.length) return; - await savePage(newRepacks); + await saveRepacks(newRepacks); return getNewRepacksFromCPG(existingRepacks, page + 1); }; diff --git a/src/main/services/repack-tracker/gog.ts b/src/main/services/repack-tracker/gog.ts index 00c78e36..a23ff956 100644 --- a/src/main/services/repack-tracker/gog.ts +++ b/src/main/services/repack-tracker/gog.ts @@ -1,5 +1,5 @@ import { JSDOM, VirtualConsole } from "jsdom"; -import { requestWebPage, savePage } from "./helpers"; +import { requestWebPage, saveRepacks } from "./helpers"; import { Repack } from "@main/entity"; import { QueryDeepPartialEntity } from "typeorm/query-builder/QueryPartialEntity"; @@ -66,6 +66,6 @@ export const getNewGOGGames = async (existingRepacks: Repack[] = []) => { } } - if (repacks.length) await savePage(repacks); + if (repacks.length) await saveRepacks(repacks); } }; diff --git a/src/main/services/repack-tracker/helpers.ts b/src/main/services/repack-tracker/helpers.ts index ef2f4945..250b2c2d 100644 --- a/src/main/services/repack-tracker/helpers.ts +++ b/src/main/services/repack-tracker/helpers.ts @@ -5,7 +5,7 @@ import { repackRepository } from "@main/repository"; import { QueryDeepPartialEntity } from "typeorm/query-builder/QueryPartialEntity"; -export const savePage = async (repacks: QueryDeepPartialEntity[]) => +export const saveRepacks = async (repacks: QueryDeepPartialEntity[]) => Promise.all( repacks.map((repack) => repackRepository.insert(repack).catch(() => {})) ); diff --git a/src/main/services/repack-tracker/online-fix.ts b/src/main/services/repack-tracker/online-fix.ts index a473679f..c8fb75b7 100644 --- a/src/main/services/repack-tracker/online-fix.ts +++ b/src/main/services/repack-tracker/online-fix.ts @@ -1,5 +1,5 @@ import { Repack } from "@main/entity"; -import { decodeNonUtf8Response, savePage } from "./helpers"; +import { decodeNonUtf8Response, saveRepacks } from "./helpers"; import { logger } from "../logger"; import parseTorrent, { toMagnetURI, @@ -181,7 +181,7 @@ export const getNewRepacksFromOnlineFix = async ( if (!newRepacks.length) return; if (page === totalPages) return; - await savePage(newRepacks); + await saveRepacks(newRepacks); return getNewRepacksFromOnlineFix(existingRepacks, page + 1, cookieJar); }; diff --git a/src/main/services/repack-tracker/xatab.ts b/src/main/services/repack-tracker/xatab.ts index df075e88..ba44bca5 100644 --- a/src/main/services/repack-tracker/xatab.ts +++ b/src/main/services/repack-tracker/xatab.ts @@ -2,7 +2,7 @@ import { JSDOM } from "jsdom"; import { Repack } from "@main/entity"; import { logger } from "../logger"; -import { requestWebPage, savePage } from "./helpers"; +import { requestWebPage, saveRepacks } from "./helpers"; import createWorker from "@main/workers/torrent-parser.worker?nodeWorker"; import { toMagnetURI } from "parse-torrent"; @@ -95,7 +95,7 @@ export const getNewRepacksFromXatab = async ( if (!newRepacks.length) return; - await savePage(newRepacks); + await saveRepacks(newRepacks); return getNewRepacksFromXatab(existingRepacks, page + 1); };