Added custom logger package, switched to tsc in back building, added pnpm lifecycle scripts
This commit is contained in:
@@ -7,6 +7,7 @@ import {
|
||||
isUpdateMessage,
|
||||
ListMessage,
|
||||
} from "@roomruler/messages";
|
||||
import { logger as log } from "@roomruler/logger";
|
||||
|
||||
const main = async () => {
|
||||
const connection = await connect();
|
||||
@@ -15,11 +16,11 @@ const main = async () => {
|
||||
{
|
||||
port: Number.parseInt(process.env.PORT || "") || 8081,
|
||||
},
|
||||
() => console.log(`Started server on ${process.env.PORT || 8081}`)
|
||||
() => log(`Started server on ${process.env.PORT || 8081}`)
|
||||
);
|
||||
|
||||
wss.on("connection", async (wsc, req) => {
|
||||
console.log("New user connected from " + req.socket.remoteAddress);
|
||||
log("New user connected from " + req.socket.remoteAddress);
|
||||
wsc.send(
|
||||
JSON.stringify(
|
||||
composeMessage<ListMessage>("list", await getRoomList(connection))
|
||||
@@ -27,14 +28,15 @@ const main = async () => {
|
||||
);
|
||||
|
||||
wsc.on("message", async (data) => {
|
||||
console.log("Got message from " + req.socket.remoteAddress);
|
||||
log("Got message from " + req.socket.remoteAddress);
|
||||
try {
|
||||
const message: unknown = JSON.parse(data.toString());
|
||||
if (!isMessage(message)) throw new Error("Message corrupted");
|
||||
|
||||
if (isUpdateMessage(message)) {
|
||||
console.log(
|
||||
`Processing message of \"${message.type}\" type from ${req.socket.remoteAddress}`
|
||||
log(
|
||||
`\nProcessing message of \"${message.type}\" type from ${req.socket.remoteAddress}\n`,
|
||||
message.args
|
||||
);
|
||||
|
||||
const { id, value } = message.args;
|
||||
@@ -46,7 +48,7 @@ const main = async () => {
|
||||
});
|
||||
}
|
||||
} catch (err) {
|
||||
console.log("Error processing message", err);
|
||||
log("Error processing message", err);
|
||||
}
|
||||
});
|
||||
});
|
||||
|
Reference in New Issue
Block a user