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

feat: removing publishers

Browse Source
This commit is contained in:
Chubby Granny Chaser 2024-12-23 01:14:50 +00:00
parent 618d6f8337
commit 3a1fa9ab00
No known key found for this signature in database
2 changed files with 47 additions and 51 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
src/renderer/src/app.tsx
View File

@ -37,8 +37,6 @@ export function App() {
const { t } = useTranslation("app");
const downloadSourceMigrationLock = useRef(false);
const { updateRepacks } = useRepacks();
const { clearDownload, setLastPacket } = useDownload();
@ -198,10 +196,6 @@ export function App() {
}, [dispatch, draggingDisabled]);
useEffect(() => {
if (downloadSourceMigrationLock.current) return;
downloadSourceMigrationLock.current = true;
updateRepacks();
const id = crypto.randomUUID();

92
src/renderer/src/workers/download-sources.worker.ts
View File

@ -155,60 +155,62 @@ self.onmessage = async (event: MessageEvent<Payload>) => {
const downloadSources = await downloadSourcesTable.toArray();
const existingRepacks = await repacksTable.toArray();
for (const downloadSource of downloadSources) {
console.log(downloadSource);
if (!downloadSource.fingerprint) {
await deleteDownloadSource(downloadSource.id);
await importDownloadSource(downloadSource.url);
continue;
}
if (downloadSources.some((source) => !source.fingerprint)) {
await Promise.all(
downloadSources.map(async (source) => {
await deleteDownloadSource(source.id);
await importDownloadSource(source.url);
})
);
} else {
for (const downloadSource of downloadSources) {
const headers = new AxiosHeaders();
const headers = new AxiosHeaders();
if (downloadSource.etag) {
headers.set("If-None-Match", downloadSource.etag);
}
if (downloadSource.etag) {
headers.set("If-None-Match", downloadSource.etag);
}
try {
const response = await axios.get(downloadSource.url, {
headers,
});
try {
const response = await axios.get(downloadSource.url, {
headers,
});
const source = downloadSourceSchema.parse(response.data);
const source = downloadSourceSchema.parse(response.data);
const steamGames = await getSteamGames();
const steamGames = await getSteamGames();
await db.transaction(
"rw",
repacksTable,
downloadSourcesTable,
async () => {
await downloadSourcesTable.update(downloadSource.id, {
etag: response.headers["etag"],
downloadCount: source.downloads.length,
status: DownloadSourceStatus.UpToDate,
});
await db.transaction(
"rw",
repacksTable,
downloadSourcesTable,
async () => {
await downloadSourcesTable.update(downloadSource.id, {
etag: response.headers["etag"],
downloadCount: source.downloads.length,
status: DownloadSourceStatus.UpToDate,
});
const repacks = source.downloads.filter(
(download) =>
!existingRepacks.some(
(repack) => repack.title === download.title
)
);
const repacks = source.downloads.filter(
(download) =>
!existingRepacks.some(
(repack) => repack.title === download.title
)
);
await addNewDownloads(downloadSource, repacks, steamGames);
await addNewDownloads(downloadSource, repacks, steamGames);
newRepacksCount += repacks.length;
}
);
} catch (err: unknown) {
const isNotModified = (err as AxiosError).response?.status === 304;
newRepacksCount += repacks.length;
}
);
} catch (err: unknown) {
const isNotModified = (err as AxiosError).response?.status === 304;
await downloadSourcesTable.update(downloadSource.id, {
status: isNotModified
? DownloadSourceStatus.UpToDate
: DownloadSourceStatus.Errored,
});
await downloadSourcesTable.update(downloadSource.id, {
status: isNotModified
? DownloadSourceStatus.UpToDate
: DownloadSourceStatus.Errored,
});
}
}
}