Method onMessage

src/utils/mediaConnection.ts:79–123

(msg: Data)

  }

  onMessage(msg: Data) {
    if (!(msg instanceof Buffer)) return;
    const op = msg.readUint8(0);
    logger.debug(`Received message from media server ${this.host} with opcode ${op}`);
    if (op === Rinit) {
      this.formats = JSON.parse(msg.toString("utf8", 7));
      this.funcs = {
        image: this.formats.image ? Object.keys(this.formats.image) : [],
      };
      this.types = {};
      for (const [type, cmdList] of Object.entries(this.formats)) {
        const cmds = Object.keys(cmdList);
        for (const cmd of cmds) {
          if (!this.types[cmd]) this.types[cmd] = [];
          this.types[cmd].push(type as MediaTypes);
        }
      }
      return;
    }
    if (op === Rclose) {
      this.reconnect = true;
      this.close();
      return;
    }
    const tag = msg.readUint16LE(1);
    const promise = this.requests.get(tag);
    if (!promise) {
      logger.error(`Received response for unknown request ${tag}`);
      return;
    }
    this.requests.delete(tag);
    if (op === Rerror) {
      promise.reject(new Error(msg.subarray(3, msg.length).toString()));
      return;
    }
    if (op === Rsent) {
      promise.resolve({ sent: true, data: msg.subarray(3, msg.length) });
      return;
    }
    if (op === Rwait) {
      promise.resolve({ sent: false });
      return;
    }
    promise.resolve();
  }

  onError(e: Error | ErrorEvent) {
    logger.error(e);