torsten/yourpart3
1
0
Fork 0
Code Issues 1 Pull Requests Actions Packages Projects Releases Wiki Activity

Verbesserung: Aktivierung von Debug-Protokollausgaben in socket.js zur besseren Nachverfolgbarkeit

Browse Source 
Änderungen:
- Eine neue Umgebungsvariable `DEBUG_SOCKETS` wurde eingeführt, um die Protokollierung von Socket-Interaktionen zu steuern.
- Protokollausgaben für Verbindungsherstellung, Benutzer-ID-Setzung, Trennung und Benachrichtigungen wurden aktualisiert, um nur bei aktivem Debugging angezeigt zu werden.

Diese Anpassungen erhöhen die Flexibilität der Protokollierung und verbessern die Fehlerdiagnose in der Socket.io-Integration.
This commit is contained in:
Torsten Schulz (local)
2025-09-11 16:37:54 +02:00
parent 22ed7cb786
commit 1cad671b80
1 changed files with 8 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

15
backend/utils/socket.js
View File

@@ -5,6 +5,7 @@ const baseService = new BaseService();
let io; let io;
const userSockets = {}; const userSockets = {};
const DEBUG_SOCKETS = process.env.DEBUG_SOCKETS === 'true';
export function setupWebSocket(server) { export function setupWebSocket(server) {
io = new Server(server, { io = new Server(server, {
@@ -14,19 +15,19 @@ export function setupWebSocket(server) {
}); });
io.on('connection', (socket) => { io.on('connection', (socket) => {
console.log('[socket.io] connection established:', socket.id, 'from', socket.handshake.address); if (DEBUG_SOCKETS) console.log('[socket.io] connection established:', socket.id, 'from', socket.handshake.address);
socket.on('setUserId', (userId) => { socket.on('setUserId', (userId) => {
if (userId) { if (userId) {
socket.userId = userId; socket.userId = userId;
userSockets[userId] = socket.id; userSockets[userId] = socket.id;
console.log('[socket.io] setUserId received:', userId, '→ socket', socket.id); if (DEBUG_SOCKETS) console.log('[socket.io] setUserId received:', userId, '→ socket', socket.id);
} }
}); });
socket.on('disconnect', () => { socket.on('disconnect', () => {
if (socket.userId) { if (socket.userId) {
delete userSockets[socket.userId]; delete userSockets[socket.userId];
console.log('[socket.io] disconnected:', socket.id, 'for userId', socket.userId); if (DEBUG_SOCKETS) console.log('[socket.io] disconnected:', socket.id, 'for userId', socket.userId);
} }
}); });
}); });
@@ -51,20 +52,20 @@ export async function notifyUser(recipientHashedUserId, event, data) {
if (recipientUser) { if (recipientUser) {
const socketId = userSockets[recipientUser.hashedId]; const socketId = userSockets[recipientUser.hashedId];
if (socketId) { if (socketId) {
console.log('[socket.io] notifyUser → emit:', event, 'to socket', socketId, 'user', recipientUser.hashedId, 'data:', JSON.stringify(data)); if (DEBUG_SOCKETS) console.log('[socket.io] notifyUser → emit:', event, 'to socket', socketId, 'user', recipientUser.hashedId, 'data:', JSON.stringify(data));
setTimeout(() => { setTimeout(() => {
io.to(socketId).emit(event, data); io.to(socketId).emit(event, data);
}, 250); }, 250);
} else { } else {
console.warn('[socket.io] notifyUser: no socket registered for user', recipientUser.hashedId); if (DEBUG_SOCKETS) console.warn('[socket.io] notifyUser: no socket registered for user', recipientUser.hashedId);
} }
} else { } else {
console.log(`Benutzer mit gehashter ID ${recipientHashedUserId} nicht gefunden.`); if (DEBUG_SOCKETS) console.log(`Benutzer mit gehashter ID ${recipientHashedUserId} nicht gefunden.`);
} }
} catch (err) { } catch (err) {
console.error('Fehler beim Senden der Benachrichtigung:', err); console.error('Fehler beim Senden der Benachrichtigung:', err);
} }
console.log('[socket.io] notifyUser done'); if (DEBUG_SOCKETS) console.log('[socket.io] notifyUser done');
} }
export async function notifyAllUsers(event, data) { export async function notifyAllUsers(event, data) {