fix emit_message mechanism

1 files changed, 7 insertions, 0 deletions

diff --git a/backend/src/localplatform/localsocket.py b/backend/src/localplatform/localsocket.py
index 2ef039ee..93b1ea18 100644
--- a/backend/src/localplatform/localsocket.py
+++ b/backend/src/localplatform/localsocket.py
@@ -18,6 +18,7 @@ class UnixSocket:
         self.socket = None
         self.reader = None
         self.writer = None
+        self.server_writer = None
 
     async def setup_server(self):
         self.socket = await asyncio.start_unix_server(self._listen_for_method_call, path=self.socket_addr, limit=BUFFER_LIMIT)
@@ -90,8 +91,14 @@ class UnixSocket:
 
         writer.write(message.encode("utf-8"))
         await writer.drain()
+    
+    async def write_single_line_server(self, message: str):
+        if self.server_writer is None:
+            return
+        await self._write_single_line(self.server_writer, message)
 
     async def _listen_for_method_call(self, reader: asyncio.StreamReader, writer: asyncio.StreamWriter):
+        self.server_writer = writer
         while True:
 
             def _(task: asyncio.Task[str|None]):