fix: Adjust logging
This commit is contained in:
parent
0a26c2e5ab
commit
e4f2c59b31
@ -13,12 +13,12 @@ const port = 3000;
|
||||
|
||||
io.on('connection', async (socket) => {
|
||||
// Runs on client connection
|
||||
console.log(`\x1b[35m[ws:kit]\x1b[0m client connected (${socket.id})`);
|
||||
console.log(`\x1b[35m[WS]\x1b[0m client connected (${socket.id})`);
|
||||
// Runs on message received
|
||||
socket.on('message', async (msg) => {
|
||||
// If message not empty
|
||||
if (msg.content !== '') {
|
||||
console.log(`\x1b[35m[ws:kit]\x1b[0m message from ${socket.id}: ${msg.content}`);
|
||||
console.log(`\x1b[35m[WS]\x1b[0m message from ${socket.id}: ${msg.content}`);
|
||||
// Store the message in the database
|
||||
const timestamp = new Date();
|
||||
await db.sendMessage(msg.channel, msg.content, msg.id, uuidv4(), timestamp);
|
||||
@ -35,7 +35,7 @@ io.on('connection', async (socket) => {
|
||||
|
||||
// Runs on client disconnect
|
||||
socket.on('disconnect', () => {
|
||||
console.log(`\x1b[35m[ws:kit]\x1b[0m client disconnected (${socket.id})`);
|
||||
console.log(`\x1b[35m[WS]\x1b[0m client disconnected (${socket.id})`);
|
||||
});
|
||||
});
|
||||
|
||||
|
@ -14,7 +14,7 @@ class Websocket {
|
||||
|
||||
connect() {
|
||||
this.socket.on('message', (data: TypeFullMessage) => {
|
||||
console.log('[ws] message received', data);
|
||||
console.log('[WS] message received', data);
|
||||
if (data.channel == this.channel) {
|
||||
this.loadMessage(data);
|
||||
}
|
||||
@ -29,7 +29,6 @@ class Websocket {
|
||||
|
||||
// Add message to local messages array
|
||||
private loadMessage(newMsg: TypeMessage) {
|
||||
console.log(newMsg.timestamp);
|
||||
this.messages = [
|
||||
{
|
||||
message: newMsg.message,
|
||||
|
@ -10,7 +10,7 @@ let io: SocketIOServer | undefined;
|
||||
|
||||
export function startupSocketIOServer(httpServer: HttpServer | null) {
|
||||
if (io) return;
|
||||
console.log('\x1b[35m[ws:kit]\x1b[0m setup');
|
||||
console.log('\x1b[35m[WS]\x1b[0m setup');
|
||||
|
||||
if (!httpServer) {
|
||||
console.error('Error: httpServer is null. Cannot start Socket.IO server.');
|
||||
@ -21,12 +21,12 @@ export function startupSocketIOServer(httpServer: HttpServer | null) {
|
||||
|
||||
io.on('connection', async (socket) => {
|
||||
// Runs on client connection
|
||||
console.log(`\x1b[35m[ws:kit]\x1b[0m client connected (${socket.id})`);
|
||||
console.log(`\x1b[35m[WS]\x1b[0m client connected (${socket.id})`);
|
||||
// Runs on message received
|
||||
socket.on('message', async (msg) => {
|
||||
// If message not empty
|
||||
if (msg.content !== '') {
|
||||
console.log(`\x1b[35m[ws:kit]\x1b[0m message from ${socket.id}: ${msg.content}`);
|
||||
console.log(`\x1b[35m[WS]\x1b[0m message from ${socket.id}: ${msg.content}`);
|
||||
// Store the message in the database
|
||||
const timestamp = new Date();
|
||||
await db.sendMessage(msg.channel, msg.content, msg.id, uuidv4(), timestamp);
|
||||
@ -43,7 +43,7 @@ export function startupSocketIOServer(httpServer: HttpServer | null) {
|
||||
|
||||
// Runs on client disconnect
|
||||
socket.on('disconnect', () => {
|
||||
console.log(`\x1b[35m[ws:kit]\x1b[0m client disconnected (${socket.id})`);
|
||||
console.log(`\x1b[35m[WS]\x1b[0m client disconnected (${socket.id})`);
|
||||
});
|
||||
});
|
||||
}
|
||||
|
Loading…
Reference in New Issue
Block a user