Method processProtoBuf

packages/ibkr/src/decoder/base.ts:71–91

* Dispatch a protobuf-encoded message. * Mirrors: ibapi/decoder.py processProtoBuf()

(protoBuf: Buffer, msgId: number)

   * Mirrors: ibapi/decoder.py processProtoBuf()
   */
  processProtoBuf(protoBuf: Buffer, msgId: number): void {
    if (msgId === 0) return

    const handler = this.msgId2protoHandler.get(msgId)
    if (!handler) {
      console.log(`[ibkr] unhandled protobuf message: msgId=${msgId}, len=${protoBuf.length}`)
      return
    }

    try {
      handler(this, protoBuf)
    } catch (e) {
      if (e instanceof BadMessage) {
        this.wrapper.error(
          NO_VALID_ID, currentTimeMillis(),
          BAD_MESSAGE.code(), BAD_MESSAGE.msg() + `protobuf msgId=${msgId}`, '',
        )
      }
      throw e
    }
  }
}