move addMessage (ignore ping/pong) (#3)

server/api/chat-ws.ts

@@ -1,5 +1,5 @@
-import type { Peer } from 'crossws';
-import { getQuery } from "ufo"
+import type { Peer } from "crossws";
+import { getQuery } from "ufo";
 
 const users = new Map<string, { online: boolean }>();
 
@@ -11,28 +11,31 @@ export default defineWebSocketHandler({
  users.set(userId, { online: true });
 
  const stats = getStats();
- peer.send({ user: "server", message: `Welcome to the server ${userId}! (Online users: ${stats.online}/${stats.total})` });
+ peer.send({
+ user: "server",
+ message: `Welcome to the server ${userId}! (Online users: ${stats.online}/${stats.total})`,
+ });
 
  peer.subscribe("chat");
  peer.publish("chat", { user: "server", message: `${peer} joined!` });
-
  },
  async message(peer, message) {
  console.log(`[ws] message ${peer} ${message.text()}`);
 
  const userId = getUserId(peer);
-
  if (message.text() === "ping") {
  peer.send({ user: "server", message: "pong" });
- } else {
- const _message = {
- user: userId,
- message: message.text(),
- };
- peer.send(_message); // echo back
- peer.publish("chat", _message);
+ return
  }
 
+ const _message = {
+ user: userId,
+ message: message.text(),
+ };
+ peer.send(_message); // echo back
+ peer.publish("chat", _message);
+
+ // Store message in database
  await addMessage(userId, message.text());
  },
 
@@ -50,7 +53,7 @@ export default defineWebSocketHandler({
  upgrade(req) {
  return {
  headers: {
- "x-powered-by": "cross-ws"
+ "x-powered-by": "cross-ws",
  },
  };
  },