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

fix log spam

Browse Source
This commit is contained in:
legop3
2026-02-25 12:49:33 -05:00
parent b22ba216db
commit 18c0d0fc8d
1 changed files with 24 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files
server/src/services/llmCommentaryService.js
+24 -3
View File
@@ -23,6 +23,8 @@ const ACTIVITY_WINDOW_MS = 30000;
const ACTIVITY_BUCKET_MS = 1000; const ACTIVITY_BUCKET_MS = 1000;
const SELF_TALK_WINDOW_MS = 30 * 60 * 1000; const SELF_TALK_WINDOW_MS = 30 * 60 * 1000;
const MAX_CONTEXT_EVENTS = 100; const MAX_CONTEXT_EVENTS = 100;
const NO_ACTIVE_DRIVER_DELAY_MS = 5000;
const NO_ACTIVE_DRIVER_LOG_COOLDOWN_MS = 30000;
const config = loadConfig(); const config = loadConfig();
const commentaryConfig = config.llmCommentary || {}; const commentaryConfig = config.llmCommentary || {};
@@ -36,6 +38,7 @@ const ollamaClient = ollamaUrl ? new Ollama({ host: ollamaUrl }) : null;
let timer = null; let timer = null;
let inFlight = false; let inFlight = false;
let tickCount = 0; let tickCount = 0;
let lastNoDriverLogAt = 0;
let contextResetAt = Date.now(); let contextResetAt = Date.now();
let clearCount = 0; let clearCount = 0;
const roverActivity = new Map(); // roverId -> { buckets: Map(bucketTs -> { distanceMm, turnDeg, bumps }), bumpLeftActive, bumpRightActive } const roverActivity = new Map(); // roverId -> { buckets: Map(bucketTs -> { distanceMm, turnDeg, bumps }), bumpLeftActive, bumpRightActive }
@@ -505,6 +508,15 @@ function scheduleNextTick(delayMs = defaultTickDelayMs()) {
timer = setTimeout(runTick, safeDelay); timer = setTimeout(runTick, safeDelay);
} }
function wakeForDriverActivity() {
if (inFlight) return;
if (timer) {
clearTimeout(timer);
timer = null;
}
scheduleNextTick(0);
}
async function runTick() { async function runTick() {
let nextDelayMs = defaultTickDelayMs(); let nextDelayMs = defaultTickDelayMs();
tickCount += 1; tickCount += 1;
@@ -529,7 +541,11 @@ async function runTick() {
try { try {
const snapshot = buildSnapshot(); const snapshot = buildSnapshot();
if (!snapshot) { if (!snapshot) {
logger.info('Commentary tick skipped; no active drivers', { tickId }); const nowMs = Date.now();
if (nowMs - lastNoDriverLogAt >= NO_ACTIVE_DRIVER_LOG_COOLDOWN_MS) {
logger.info('Commentary tick skipped; no active drivers', { tickId });
lastNoDriverLogAt = nowMs;
}
updateStatus({ updateStatus({
lastOutcome: 'skipped', lastOutcome: 'skipped',
lastReason: 'no active drivers', lastReason: 'no active drivers',
@@ -540,8 +556,8 @@ async function runTick() {
chatMessages: 0, chatMessages: 0,
}, },
}); });
// Keep delayed cadence when nobody is driving. // Slow polling while no drivers are present to avoid log spam / hot loops.
nextDelayMs = defaultTickDelayMs(); nextDelayMs = NO_ACTIVE_DRIVER_DELAY_MS;
return; return;
} }
const snapshotSummary = { const snapshotSummary = {
@@ -670,5 +686,10 @@ roverManager.managerEvents.on('rover', ({ roverId, action } = {}) => {
roverActivity.delete(String(roverId)); roverActivity.delete(String(roverId));
} }
}); });
roverManager.managerEvents.on('driver', ({ action } = {}) => {
if (action === 'add') {
wakeForDriverActivity();
}
});
start(); start();