diff --git a/server/src/services/roverSnapshotService/index.js b/server/src/services/roverSnapshotService/index.js index 88c89706..f4af4bae 100644 --- a/server/src/services/roverSnapshotService/index.js +++ b/server/src/services/roverSnapshotService/index.js @@ -2,6 +2,7 @@ // Purpose: Composes rover snapshot polling and snapshot socket delivery in one folderized service. // Scope: Preserves existing rover snapshot events/state exports and startup side effects. const roverManager = require('../roverManager'); +const logger = require('../../globals/logger').child('roverSnapshotService'); const { createRoverSnapshotPoller } = require('./poller'); const { registerRoverSnapshotSocketGateway } = require('./socketGateway'); @@ -15,6 +16,8 @@ registerRoverSnapshotSocketGateway({ fetchSnapshotNow: poller.fetchSnapshotNow, }); +logger.warn('Rover snapshot service initialized'); + module.exports = { roverSnapshotEvents: poller.roverSnapshotEvents, getRoverSnapshotState: poller.getRoverSnapshotState, diff --git a/server/src/services/roverSnapshotService/socketGateway.js b/server/src/services/roverSnapshotService/socketGateway.js index b5084832..7e3702eb 100644 --- a/server/src/services/roverSnapshotService/socketGateway.js +++ b/server/src/services/roverSnapshotService/socketGateway.js @@ -104,6 +104,7 @@ function registerRoverSnapshotSocketGateway({ }); io.on('connection', (socket) => { + logger.warn('Rover snapshot gateway saw socket connection', { socketId: socket.id }); socket.on('roverSnapshot:subscribe', (payload = {}, cb = () => {}) => { const visibleRoster = roverManager.getRosterForSocket(socket); const visibleIds = visibleRoster.map((rover) => String(rover.id)); @@ -118,7 +119,7 @@ function registerRoverSnapshotSocketGateway({ if (!passesMode(socket)) throw new Error('Not authorized for rover snapshots'); const rosterIds = new Set(visibleIds); const validIds = uniqueIds.filter((id) => rosterIds.has(String(id))); - logger.info('Rover snapshot subscribe', { + logger.warn('Rover snapshot subscribe', { socketId: socket.id, requestedIds: uniqueIds, visibleIds,