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

logging

Browse Source
This commit is contained in:
legop3
2026-04-29 14:16:38 -04:00
parent 9b80b0d248
commit b716e40f53
2 changed files with 5 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files
server/src/services/roverSnapshotService/index.js
+3
View File
@@ -2,6 +2,7 @@
// Purpose: Composes rover snapshot polling and snapshot socket delivery in one folderized service. // 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. // Scope: Preserves existing rover snapshot events/state exports and startup side effects.
const roverManager = require('../roverManager'); const roverManager = require('../roverManager');
const logger = require('../../globals/logger').child('roverSnapshotService');
const { createRoverSnapshotPoller } = require('./poller'); const { createRoverSnapshotPoller } = require('./poller');
const { registerRoverSnapshotSocketGateway } = require('./socketGateway'); const { registerRoverSnapshotSocketGateway } = require('./socketGateway');
@@ -15,6 +16,8 @@ registerRoverSnapshotSocketGateway({
fetchSnapshotNow: poller.fetchSnapshotNow, fetchSnapshotNow: poller.fetchSnapshotNow,
}); });
logger.warn('Rover snapshot service initialized');
module.exports = { module.exports = {
roverSnapshotEvents: poller.roverSnapshotEvents, roverSnapshotEvents: poller.roverSnapshotEvents,
getRoverSnapshotState: poller.getRoverSnapshotState, getRoverSnapshotState: poller.getRoverSnapshotState,
server/src/services/roverSnapshotService/socketGateway.js
+2 -1
View File
@@ -104,6 +104,7 @@ function registerRoverSnapshotSocketGateway({
}); });
io.on('connection', (socket) => { io.on('connection', (socket) => {
logger.warn('Rover snapshot gateway saw socket connection', { socketId: socket.id });
socket.on('roverSnapshot:subscribe', (payload = {}, cb = () => {}) => { socket.on('roverSnapshot:subscribe', (payload = {}, cb = () => {}) => {
const visibleRoster = roverManager.getRosterForSocket(socket); const visibleRoster = roverManager.getRosterForSocket(socket);
const visibleIds = visibleRoster.map((rover) => String(rover.id)); 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'); if (!passesMode(socket)) throw new Error('Not authorized for rover snapshots');
const rosterIds = new Set(visibleIds); const rosterIds = new Set(visibleIds);
const validIds = uniqueIds.filter((id) => rosterIds.has(String(id))); const validIds = uniqueIds.filter((id) => rosterIds.has(String(id)));
logger.info('Rover snapshot subscribe', { logger.warn('Rover snapshot subscribe', {
socketId: socket.id, socketId: socket.id,
requestedIds: uniqueIds, requestedIds: uniqueIds,
visibleIds, visibleIds,