From 8393a29b7dbcaed6a76992b851fa35ef59fe16ce Mon Sep 17 00:00:00 2001
From: Rory& <root@rory.gay>
Date: Thu, 16 Jul 2026 09:47:32 +0200
Subject: [PATCH] Clean up supposedly orphaned unix sockets

---
 src/util/util/ipc/writer/UnixSocketWriter.ts | 10 +++++++---
 1 file changed, 7 insertions(+), 3 deletions(-)

diff --git a/src/util/util/ipc/writer/UnixSocketWriter.ts b/src/util/util/ipc/writer/UnixSocketWriter.ts
index c24656869..e9ee4d94d 100644
--- a/src/util/util/ipc/writer/UnixSocketWriter.ts
+++ b/src/util/util/ipc/writer/UnixSocketWriter.ts
@@ -101,16 +101,20 @@ export class UnixSocketWriter extends BaseEventWriter {
                 });
 
                 this.clients[fullPath].on("error", (err) => {
-                    console.error("[UnixSocketWriter] Unix socket client error on", fullPath, ":", err);
                     // clean up after error
                     if (this.clients[fullPath]) {
                         delete this.clients[fullPath];
                     }
+
+                    if ("code" in err && err.code == "ECONNREFUSED") {
+                        console.error("[UnixSocketWriter] Got ECONNREFUSED for socket", fullPath, " - assuming it is orphaned...");
+                        fs.unlinkSync(fullPath);
+                    } else console.error("[UnixSocketWriter] Unix socket client error on", fullPath, ":", err);
                 });
 
                 // handle clean socket closure
-                this.clients[fullPath].on("close", () => {
-                    console.log("[UnixSocketWriter] Unix socket client closed:", fullPath);
+                this.clients[fullPath].on("close", (hadError) => {
+                    console.log("[UnixSocketWriter] Unix socket client closed:", fullPath, "- hadError:", hadError);
                     delete this.clients[fullPath];
                     this.openConnectionsMetric.set(Object.entries(this.clients).length);
                 });