import { node } from "@elysiajs/node";
import { Elysia, t } from "elysia";

new Elysia({ adapter: node() })
  .ws("/ws", {
    open(ws) {
      console.log("Client connected", ws.data.query.token);
      ws.send({
        message: "Hello from Elysia!",
        time: Date.now(),
      });
    },
    close() {
      console.log("Client disconnected");
    },
    message(ws, buffer) {
      console.log("Message from client:", buffer);
      ws.send({
        token: ws.data.query.token,
        buffer,
        time: Date.now(),
      });
    },
    query: t.Object({
      token: t.String({
        minLength: 1,
      }),
    }),
    body: t.Uint8Array(),
  })
  .listen(3000, ({ hostname, port }) => {
    console.log(`🦊 Elysia is running at ${hostname}:${port}`);
  });