refactor: clean up code

.gitignore

@@ -1,6 +1,5 @@
 .vscode/
 node_modules/
-fastlist.exe
 __pycache__
 dist
 out

src/main/events/auth/sign-out.ts

@@ -2,6 +2,7 @@ import { registerEvent } from "../register-event";
 import { DownloadManager, HydraApi, gamesPlaytime } from "@main/services";
 import { dataSource } from "@main/data-source";
 import { DownloadQueue, Game, UserAuth, UserSubscription } from "@main/entity";
+import { PythonRPC } from "@main/services/python-rpc";
 
 const signOut = async (_event: Electron.IpcMainInvokeEvent) => {
   const databaseOperations = dataSource
@@ -27,8 +28,7 @@ const signOut = async (_event: Electron.IpcMainInvokeEvent) => {
   DownloadManager.cancelDownload();
 
   /* Disconnects libtorrent */
-  // TODO
+  PythonRPC.kill();
-  // TorrentDownloader.killTorrent();
 
   HydraApi.handleSignOut();
 

src/main/events/profile/process-profile-image.ts

@@ -1,11 +1,14 @@
 import { registerEvent } from "../register-event";
+import { PythonRPC } from "@main/services/python-rpc";
 
 const processProfileImage = async (
   _event: Electron.IpcMainInvokeEvent,
   path: string
 ) => {
-  return path;
+  return PythonRPC.rpc.post<{ imagePath: string; mimeType: string }>(
-  // return PythonInstance.processProfileImage(path);
+    "/profile_image_processor/process_image",
+    { path },
+  );
 };
 
 registerEvent("processProfileImage", processProfileImage);

src/main/events/torrenting/pause-game-seed.ts

@@ -8,11 +8,9 @@ const pauseGameSeed = async (
   _event: Electron.IpcMainInvokeEvent,
   gameId: number
 ) => {
-  await dataSource.transaction(async (transactionalEntityManager) => {
+  await dataSource
-    await transactionalEntityManager
+    .getRepository(Game)
-      .getRepository(Game)
+    .update({ id: gameId }, { status: "complete", shouldSeed: false });
-      .update({ id: gameId }, { status: "complete", shouldSeed: false });
-  });
 
   await DownloadManager.cancelDownload(gameId);
 };

src/main/events/torrenting/resume-game-seed.ts

@@ -20,11 +20,9 @@ const resumeGameSeed = async (
 
   if (!game) return;
 
-  await dataSource.transaction(async (transactionalEntityManager) => {
+  await dataSource
-    await transactionalEntityManager
+    .getRepository(Game)
-      .getRepository(Game)
+    .update({ id: gameId }, { status: "seeding", shouldSeed: true });
-      .update({ id: gameId }, { status: "seeding", shouldSeed: true });
-  });
 
   await DownloadManager.startDownload(game);
 };

src/main/main.ts

@@ -1,8 +1,5 @@
 import { Ludusavi, startMainLoop } from "./services";
-import {
+import { userPreferencesRepository } from "./repository";
-  // downloadQueueRepository,
-  userPreferencesRepository,
-} from "./repository";
 import { UserPreferences } from "./entity";
 import { RealDebridClient } from "./services/download/real-debrid";
 import { HydraApi } from "./services/hydra-api";
@@ -25,24 +22,7 @@ const loadState = async (userPreferences: UserPreferences | null) => {
     uploadGamesBatch();
   });
 
-  // const [nextQueueItem] = await downloadQueueRepository.find({
-  //   order: {
-  //     id: "DESC",
-  //   },
-  //   relations: {
-  //     game: true,
-  //   },
-  // });
-
   PythonRPC.spawn();
-  // start download
-
-  // if (nextQueueItem?.game.status === "active") {
-  //   DownloadManager.startDownload(nextQueueItem.game);
-  // } else {
-  //   PythonInstance.spawn();
-  // }
-
   startMainLoop();
 };
 

src/main/services/hydra-api.ts

@@ -30,7 +30,7 @@ export class HydraApi {
   private static instance: AxiosInstance;
 
   private static readonly EXPIRATION_OFFSET_IN_MS = 1000 * 60 * 5; // 5 minutes
-  private static readonly ADD_LOG_INTERCEPTOR = false;
+  private static readonly ADD_LOG_INTERCEPTOR = true;
 
   private static secondsToMilliseconds = (seconds: number) => seconds * 1000;