aboutsummaryrefslogtreecommitdiff
path: root/static/src/main.ts
blob: fc04b728291b6773043207485cafa169d392cf04 (plain) (blame)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
import $ from "jquery";
import { Vec2 } from "./vector";
import { EventType, type SetControllableEvent, type Event } from "./event";
import { MouseController } from "./mouse_controller";

$(document).ready(async () => {
  const session_id = await fetch("/assign", {
    credentials: "include",
  })
    .then((res) => res.json())
    .then(({ session }) => session);

  const controllable_entities = new Set<string>();
  const control_callback = (movement: Vec2) => {
    for (const id of controllable_entities) {
      const message = JSON.stringify({
        event_type: EventType.ENTITY_POSITION_UPDATE,
        data: { id, position: movement },
      });
      ws.send(message);
    }
  };
  const mouse_controller = new MouseController(control_callback);
  $(document).on("mousemove", (event) => {
    mouse_controller.move(event.clientX, event.clientY);
  });
  mouse_controller.start();

  const ws = new WebSocket("/ws");
  await new Promise<void>((resolve) => {
    ws.onopen = () => {
      console.log("connected");
      resolve();
    };
  });
  ws.onmessage = ({ data }) => {
    const [event_type, event_data] = JSON.parse(data);
    const message = { event_type, data: event_data } as Event;

    console.log("Received message", message);
    if (message.event_type === EventType.SET_CONTROLLABLE) {
      const event = message as SetControllableEvent;
      if (event.data.client_id === session_id) {
        controllable_entities.add(event.data.id);
      }
    }
  };
  ws.onclose = () => {
    controllable_entities.clear();
  };
});