sam.hadow/e2ee-messaging-service
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

better logging

Browse Source
This commit is contained in:
Sam Hadow 2025-03-11 13:47:58 +01:00
parent 49f867fd76
commit 544beb534e
1 changed files with 3 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
src/app.js
View File

@ -43,21 +43,20 @@ io.engine.use(sessionMiddleware);
io.on('connection', async (socket) => { io.on('connection', async (socket) => {
const session = socket.request.session; const session = socket.request.session;
socket.join(session.publicKey); socket.join(session.publicKey);
console.log('A user connected'); console.log(`${session.publicKey} connected`);
const peers = await database.getPeers(session.publicKey); const peers = await database.getPeers(session.publicKey);
peers.forEach(peer => { peers.forEach(peer => {
socket.to(peer).emit('key exchange', session.publicKey, null, 0); socket.to(peer).emit('key exchange', session.publicKey, null, 0);
}); });
socket.on('disconnect', () => { socket.on('disconnect', () => {
console.log('User disconnected'); console.log(`${session.publicKey} disconnected`);
}); });
socket.on('chat message', async (msg, room, tag, iv, nonce) => { socket.on('chat message', async (msg, room, tag, iv, nonce) => {
const members = await database.getRoomMembers(room); const members = await database.getRoomMembers(room);
members.forEach(memberRoom => { members.forEach(memberRoom => {
socket.to(memberRoom).emit('chat message', msg, room, tag, iv, nonce, session.publicKey); socket.to(memberRoom).emit('chat message', msg, room, tag, iv, nonce, session.publicKey);
}); });
console.log('message: ' + msg + ', sender: ' + session.id); console.log('message: ' + msg + ', sender: ' + session.publicKey);
console.log(session.publicKey);
}); });
socket.on('key exchange', (user_pubkey, pubkey, part) => { socket.on('key exchange', (user_pubkey, pubkey, part) => {
socket.to(user_pubkey).emit('key exchange', session.publicKey, pubkey, part); socket.to(user_pubkey).emit('key exchange', session.publicKey, pubkey, part);
@ -75,9 +74,6 @@ const server = http.listen(port, () => {
const shutdown = () => { const shutdown = () => {
console.log('Stopping server.'); console.log('Stopping server.');
process.exit(); process.exit();
// server.close(() => {
// console.log('Stopped server.');
// });
}; };
process.on('SIGINT', shutdown); process.on('SIGINT', shutdown);
process.on('SIGTERM', shutdown); process.on('SIGTERM', shutdown);