Method _handleMessage

apps/realtime-server/src/sockets.ts:150–166

(message: ArrayBuffer)

  };

  private async _handleMessage(message: ArrayBuffer) {
    if (await this._checkSessionInvalidated()) {
      return;
    }

    const decoder = decoding.createDecoder(new Uint8Array(message));

    const messageType = decoding.readVarUint(decoder);

    switch (messageType) {
      case RealtimeClientMessageType.REQUEST:
        await this._handleRequest(decoder);
        break;
      default:
        throw new Error('Unknown message type');
    }
  }
  private async _handleRequest(decoder: decoding.Decoder) {
    // Gather commands