Use Seeker API in Request service

services/request/package.json

@@ -12,6 +12,7 @@
     "start:dev": "nodemon"
   },
   "dependencies": {
+    "@autoplex-api/seeker": "^0.0.0",
     "@autoplex/database": "^0.0.0",
     "@autoplex/ipc": "^0.0.0",
     "@autoplex/microservice": "^0.0.0",

services/request/src/server/services/Ipc/SeekerIpcClient.ts

@@ -1,27 +0,0 @@
-import Application from "@server/Application";
-import { IpcClientService } from "@autoplex/ipc";
-import { env } from "@autoplex/utils";
-
-export default class SeekerIpcClient extends IpcClientService<Application>
-{
-    /**
-     * The service name
-     */
-    public readonly NAME = "Seeker IPC";
-
-    /**
-     * The path to the socket file
-     */
-    protected readonly SOCKET_PATH = env("SEEKER_IPC_SOCKET");
-
-    // Methods -------------------------------------------------------------------------------------
-
-    /**
-     * Notify Seeker that a movie was added
-     */
-    public notifyMovieRequested(ticketId: number) {
-        this.request("movie_ticket_added", ticketId).catch((e) => {
-            this.log("No response from seeker notifying added movie", e);
-        });
-    }
-}

services/request/src/server/services/WebServer/routes/api.ts

@@ -1,15 +1,11 @@
+import { IpcClient as SeekerIpc } from "@autoplex-api/seeker";
 import { MovieInfo, MovieTicket } from "@autoplex/database";
-import { handleRequest, RouteRegisterFactory, RouteFactory, MiddlewareMethod } from "@autoplex/webserver";
+import { handleRequest, RouteRegisterFactory, MiddlewareMethod } from "@autoplex/webserver";
 import Application from "@server/Application";
-import SeekerIpc from "@server/services/Ipc/SeekerIpcClient";
 import MovieSearch from "@server/services/MovieSearch";
 import { auth } from "../middleware/auth";
 import { RequestTmdbMovieRequest } from "../requests";
 
-function testFunc<A extends any = number, B extends any = string>(a: A, b: B) {
-
-}
-
 /**
  * Register API routes
  */
@@ -97,7 +93,7 @@ export default function register(factory: RouteRegisterFactory<MiddlewareMethod<
 				ticket.info = info;
 				await ticket.save();
 
-				app.service<SeekerIpc>("Seeker IPC").notifyMovieRequested(ticket.id);
+				app.service<SeekerIpc>("Seeker").notifyMovieRequested(ticket.id);
 				return reply.send({ status: "Success", data: { ticket_id: ticket.id }});
 			}));
 

services/request/src/server/services/index.ts

@@ -1,8 +1,8 @@
+export { IpcClient }       from "@autoplex-api/seeker";
 export { DatabaseService } from "@autoplex/database";
 import DiscordBot          from "./DiscordBot";
 import MovieSearch         from "./MovieSearch";
 import PlexLibrary         from "./PlexLibrary";
-import SeekerIpcClient     from "./Ipc/SeekerIpcClient";
 import TvDb                from "./TvDb";
 import WebServer           from "./WebServer/WebServer";
 
@@ -11,7 +11,6 @@ export {
 	MovieSearch,
 	PlexLibrary,
 	// TorrentIpcClient,
-	SeekerIpcClient,
 	TvDb,
 	WebServer
 }