backend: better socket handling

src/MediaPlayer.ts

@@ -17,20 +17,24 @@ export class MediaPlayer {
     private dataBuffer: string = '';
 
     constructor() {
+        // Create a random string of length 5
+        const socketFilename = Math.random().toString(36).substring(2, 10);
+        const socketPath = `/tmp/mpv-${socketFilename}`;
+
         console.log("Starting player process");
         this.playerProcess = spawn("mpv", [
             "--no-video", 
             "--no-terminal",
             "--idle=yes",
-            "--input-ipc-server=/tmp/mpv-socket"
+            "--input-ipc-server=" + socketPath
         ]);
 
         this.socket = new Socket();
 
         this.playerProcess.on("spawn", () => {
-            console.log("Player process spawned, opening socket");
+            console.log(`Player process spawned, opening socket @ ${socketPath}`);
             setTimeout(() => {
-                this.connectToSocket();
+                this.connectToSocket(socketPath);
             }, 200);
         });
     }
@@ -123,13 +127,13 @@ export class MediaPlayer {
         });
     }
 
-    private connectToSocket() {
+    private connectToSocket(path: string) {
-        this.socket.connect("/tmp/mpv-socket");
+        this.socket.connect(path);
         this.socket.on("data", data => this.receiveData(data.toString()));
     }
 
     private handleEvent(event: string, data: any) {
-        console.log("Event [" + event + "]: " + JSON.stringify(data, null, 2));
+        console.log("MPV Event [" + event + "]: " + JSON.stringify(data, null, 2));
 
         // Notify all subscribers
         this.eventSubscribers.forEach(subscriber => {
@@ -156,7 +160,7 @@ export class MediaPlayer {
                             this.pendingCommands.delete(response.request_id);
                         }
                     } else if (response.event) {
-                        this.handleEvent(response.event, response.data);
+                        this.handleEvent(response.event, response);
                     } else {
                         console.log(response);
                     }

src/server.ts

@@ -78,10 +78,11 @@ apiRouter.post("/volume", async (req, res) => {
 });
 
 apiRouter.ws("/events", (ws, req) => {
-    console.log(req.query);
+    console.log("Events client connected");
     mediaPlayer.subscribe(ws);
 
     ws.on("close", () => {
+        console.log("Events client disconnected");
         mediaPlayer.unsubscribe(ws);
     });
 });