websocket client

web/src/ws.js

@@ -1,7 +1,7 @@
 import { getToken } from './api.js';
 
-const AUDIO_TYPE = 0x01;
-const HDR = 9; // [1B type][4B groupId][4B memberId]
+const HDR = 9;      // type(1) + groupId(4) + memberId(4)
+const AUDIO = 0x01;
 
 export class DispatchSocket {
   constructor(handlers) {
@@ -15,29 +15,27 @@ export class DispatchSocket {
     const proto = location.protocol === 'https:' ? 'wss' : 'ws';
     this.ws = new WebSocket(`${proto}://${location.host}/ws`);
     this.ws.binaryType = 'arraybuffer';
-
     this.ws.onopen = () => {
       this.retries = 0;
       this.ws.send(JSON.stringify({ type: 'auth', token: getToken() }));
       this.handlers.onStatus?.(true);
     };
-
     this.ws.onmessage = (ev) => {
       if (typeof ev.data === 'string') {
         let msg;
         try { msg = JSON.parse(ev.data); } catch { return; }
         switch (msg.type) {
-          case 'welcome':    this.handlers.onWelcome?.(msg); break;
-          case 'members':    this.handlers.onMembers?.(msg.members); break;
-          case 'groups':     this.handlers.onGroups?.(msg.groups); break;
-          case 'sos_new':    this.handlers.onSosNew?.(msg.alert); break;
+          case 'welcome': this.handlers.onWelcome?.(msg); break;
+          case 'members': this.handlers.onMembers?.(msg.members); break;
+          case 'groups': this.handlers.onGroups?.(msg.groups); break;
+          case 'sos_new': this.handlers.onSosNew?.(msg.alert); break;
           case 'sos_update': this.handlers.onSosUpdate?.(msg.alert); break;
-          case 'floor':      this.handlers.onFloor?.(msg); break;
-          case 'error':      console.warn('[ws]', msg.message); break;
+          case 'floor': this.handlers.onFloor?.(msg); break;
+          case 'error': console.warn('[ws]', msg.message); break;
         }
       } else if (ev.data instanceof ArrayBuffer && ev.data.byteLength > HDR) {
         const dv = new DataView(ev.data);
-        if (dv.getUint8(0) !== AUDIO_TYPE) return;
+        if (dv.getUint8(0) !== AUDIO) return;
         this.handlers.onAudio?.({
           groupId: dv.getUint32(1),
           memberId: dv.getUint32(5),
@@ -45,7 +43,6 @@ export class DispatchSocket {
         });
       }
     };
-
     this.ws.onclose = () => {
       this.handlers.onStatus?.(false);
       if (this.closed) return;
@@ -59,14 +56,14 @@ export class DispatchSocket {
     if (this.ws?.readyState === WebSocket.OPEN) this.ws.send(JSON.stringify(obj));
   }
 
-  sendAudio(groupId, memberId, int16Buffer) {
+  sendAudio(groupId, memberId, int16buffer) {
     if (this.ws?.readyState !== WebSocket.OPEN) return;
     const head = new Uint8Array(HDR);
     const dv = new DataView(head.buffer);
-    dv.setUint8(0, AUDIO_TYPE);
+    dv.setUint8(0, AUDIO);
     dv.setUint32(1, groupId);
     dv.setUint32(5, memberId);
-    const body = new Uint8Array(int16Buffer);
+    const body = new Uint8Array(int16buffer);
     const out = new Uint8Array(HDR + body.byteLength);
     out.set(head);
     out.set(body, HDR);