MCPcopy Create free account
hub / github.com/chronoxor/FastBinaryEncoding / onReceive

Method onReceive

projects/JavaScript/proto/proto.js:7616–7669  ·  view source on GitHub ↗

* proto receive message handler * @this {!FinalClient} * @param {!number} type Message type * @param {!Uint8Array} buffer Buffer to send * @param {!number} offset Buffer offset * @param {!number} size Buffer size * @returns {!boolean} Success flag

(type, buffer, offset, size)

Source from the content-addressed store, hash-verified

7614 * @returns {!boolean} Success flag
7615 */
7616 onReceive (type, buffer, offset, size) {
7617 switch (type) {
7618 case OrderMessageFinalModel.fbeType: {
7619 // Deserialize the value from the FBE stream
7620 this._OrderMessageReceiverModel.attachBuffer(buffer, offset)
7621 console.assert(this._OrderMessageReceiverModel.verify(), 'proto.OrderMessage validation failed!')
7622 let deserialized = this._OrderMessageReceiverModel.deserialize(this._OrderMessageReceiverValue)
7623 console.assert((deserialized.size > 0), 'proto.OrderMessage deserialization failed!')
7624
7625 // Log the value
7626 if (this.logging) {
7627 this.onReceiveLog(this._OrderMessageReceiverValue.toString())
7628 }
7629
7630 // Call receive handler with deserialized value
7631 this.onReceive_OrderMessage(this._OrderMessageReceiverValue)
7632 return true
7633 }
7634 case BalanceMessageFinalModel.fbeType: {
7635 // Deserialize the value from the FBE stream
7636 this._BalanceMessageReceiverModel.attachBuffer(buffer, offset)
7637 console.assert(this._BalanceMessageReceiverModel.verify(), 'proto.BalanceMessage validation failed!')
7638 let deserialized = this._BalanceMessageReceiverModel.deserialize(this._BalanceMessageReceiverValue)
7639 console.assert((deserialized.size > 0), 'proto.BalanceMessage deserialization failed!')
7640
7641 // Log the value
7642 if (this.logging) {
7643 this.onReceiveLog(this._BalanceMessageReceiverValue.toString())
7644 }
7645
7646 // Call receive handler with deserialized value
7647 this.onReceive_BalanceMessage(this._BalanceMessageReceiverValue)
7648 return true
7649 }
7650 case AccountMessageFinalModel.fbeType: {
7651 // Deserialize the value from the FBE stream
7652 this._AccountMessageReceiverModel.attachBuffer(buffer, offset)
7653 console.assert(this._AccountMessageReceiverModel.verify(), 'proto.AccountMessage validation failed!')
7654 let deserialized = this._AccountMessageReceiverModel.deserialize(this._AccountMessageReceiverValue)
7655 console.assert((deserialized.size > 0), 'proto.AccountMessage deserialization failed!')
7656
7657 // Log the value
7658 if (this.logging) {
7659 this.onReceiveLog(this._AccountMessageReceiverValue.toString())
7660 }
7661
7662 // Call receive handler with deserialized value
7663 this.onReceive_AccountMessage(this._AccountMessageReceiverValue)
7664 return true
7665 }
7666 default: break
7667 }
7668 return false
7669 }
7670
7671 /**
7672 * Setup receive log message handler

Callers

nothing calls this directly

Calls 8

attachBufferMethod · 0.45
verifyMethod · 0.45
deserializeMethod · 0.45
onReceiveLogMethod · 0.45
toStringMethod · 0.45

Tested by

no test coverage detected