legop3/MultiRoombaRover
1
0
Fork 0
mirror of https://github.com/legop3/MultiRoombaRover.git synced 2026-09-16 01:21:20 -04:00
Code Issues Actions Packages Projects Releases Wiki Activity

gah

Browse Source
This commit is contained in:
legop3
2026-05-01 19:35:18 -04:00
parent 76fc1c02d5
commit 6de19c69df
1 changed files with 9 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files
server/src/services/neatoService/lidarRuntime.js
+9 -5
View File
@@ -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() { function teardownProcess() {
const proc = state.process; const proc = state.process;
state.process = null; state.process = null;
@@ -298,15 +305,12 @@ function createLidarRuntime({ logger, host, port = 6053, key, logFile = '', shou
state.stderrBuffer = ''; state.stderrBuffer = '';
proc.stdout.on('data', (chunk) => { proc.stdout.on('data', (chunk) => {
if (!state.connected) { ensureConnected();
state.connected = true;
emitStatus();
triggerPollSoon();
}
handleTextChunk(chunk, 'stdoutBuffer', 'stdout'); handleTextChunk(chunk, 'stdoutBuffer', 'stdout');
}); });
proc.stderr.on('data', (chunk) => { proc.stderr.on('data', (chunk) => {
ensureConnected();
handleTextChunk(chunk, 'stderrBuffer', 'stderr'); handleTextChunk(chunk, 'stderrBuffer', 'stderr');
const message = String(chunk || '').trim(); const message = String(chunk || '').trim();
if (message) logger.warn('Neato lidar log stream stderr', message); if (message) logger.warn('Neato lidar log stream stderr', message);