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

Method onReceive

projects/JavaScript/proto/proto.js:6535–6588  ·  view source on GitHub ↗

* proto receive message handler * @this {!Receiver} * @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

6533 * @returns {!boolean} Success flag
6534 */
6535 onReceive (type, buffer, offset, size) {
6536 switch (type) {
6537 case OrderMessageModel.fbeType: {
6538 // Deserialize the value from the FBE stream
6539 this._OrderMessageModel.attachBuffer(buffer, offset)
6540 console.assert(this._OrderMessageModel.verify(), 'proto.OrderMessage validation failed!')
6541 let deserialized = this._OrderMessageModel.deserialize(this._OrderMessageValue)
6542 console.assert((deserialized.size > 0), 'proto.OrderMessage deserialization failed!')
6543
6544 // Log the value
6545 if (this.logging) {
6546 this.onReceiveLog(this._OrderMessageValue.toString())
6547 }
6548
6549 // Call receive handler with deserialized value
6550 this.onReceive_OrderMessage(this._OrderMessageValue)
6551 return true
6552 }
6553 case BalanceMessageModel.fbeType: {
6554 // Deserialize the value from the FBE stream
6555 this._BalanceMessageModel.attachBuffer(buffer, offset)
6556 console.assert(this._BalanceMessageModel.verify(), 'proto.BalanceMessage validation failed!')
6557 let deserialized = this._BalanceMessageModel.deserialize(this._BalanceMessageValue)
6558 console.assert((deserialized.size > 0), 'proto.BalanceMessage deserialization failed!')
6559
6560 // Log the value
6561 if (this.logging) {
6562 this.onReceiveLog(this._BalanceMessageValue.toString())
6563 }
6564
6565 // Call receive handler with deserialized value
6566 this.onReceive_BalanceMessage(this._BalanceMessageValue)
6567 return true
6568 }
6569 case AccountMessageModel.fbeType: {
6570 // Deserialize the value from the FBE stream
6571 this._AccountMessageModel.attachBuffer(buffer, offset)
6572 console.assert(this._AccountMessageModel.verify(), 'proto.AccountMessage validation failed!')
6573 let deserialized = this._AccountMessageModel.deserialize(this._AccountMessageValue)
6574 console.assert((deserialized.size > 0), 'proto.AccountMessage deserialization failed!')
6575
6576 // Log the value
6577 if (this.logging) {
6578 this.onReceiveLog(this._AccountMessageValue.toString())
6579 }
6580
6581 // Call receive handler with deserialized value
6582 this.onReceive_AccountMessage(this._AccountMessageValue)
6583 return true
6584 }
6585 default: break
6586 }
6587 return false
6588 }
6589
6590 /**
6591 * Setup receive log message handler

Callers

nothing calls this directly

Calls 8

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

Tested by

no test coverage detected