From 6de19c69df17f169263660f6e71d4f255d4b7330 Mon Sep 17 00:00:00 2001
From: legop3 <minecratfd8@gmail.com>
Date: Fri, 1 May 2026 19:35:18 -0400
Subject: [PATCH] gah

---
 server/src/services/neatoService/lidarRuntime.js | 14 +++++++++-----
 1 file changed, 9 insertions(+), 5 deletions(-)

diff --git a/server/src/services/neatoService/lidarRuntime.js b/server/src/services/neatoService/lidarRuntime.js
index 38dfd3ee..c55897b7 100644
--- a/server/src/services/neatoService/lidarRuntime.js
+++ b/server/src/services/neatoService/lidarRuntime.js
@@ -221,6 +221,13 @@ function createLidarRuntime({ logger, host, port = 6053, key, logFile = '', shou
     }
   }
 
+  function ensureConnected() {
+    if (state.connected) return;
+    state.connected = true;
+    emitStatus();
+    triggerPollSoon();
+  }
+
   function teardownProcess() {
     const proc = state.process;
     state.process = null;
@@ -298,15 +305,12 @@ function createLidarRuntime({ logger, host, port = 6053, key, logFile = '', shou
     state.stderrBuffer = '';
 
     proc.stdout.on('data', (chunk) => {
-      if (!state.connected) {
-        state.connected = true;
-        emitStatus();
-        triggerPollSoon();
-      }
+      ensureConnected();
       handleTextChunk(chunk, 'stdoutBuffer', 'stdout');
     });
 
     proc.stderr.on('data', (chunk) => {
+      ensureConnected();
       handleTextChunk(chunk, 'stderrBuffer', 'stderr');
       const message = String(chunk || '').trim();
       if (message) logger.warn('Neato lidar log stream stderr', message);