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

Method onReceive

projects/JavaScript/proto/protoex.js:6726–6785  ·  view source on GitHub ↗

* protoex 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

6724 * @returns {!boolean} Success flag
6725 */
6726 onReceive (type, buffer, offset, size) {
6727 switch (type) {
6728 case OrderMessageModel.fbeType: {
6729 // Deserialize the value from the FBE stream
6730 this._OrderMessageModel.attachBuffer(buffer, offset)
6731 console.assert(this._OrderMessageModel.verify(), 'protoex.OrderMessage validation failed!')
6732 let deserialized = this._OrderMessageModel.deserialize(this._OrderMessageValue)
6733 console.assert((deserialized.size > 0), 'protoex.OrderMessage deserialization failed!')
6734
6735 // Log the value
6736 if (this.logging) {
6737 this.onReceiveLog(this._OrderMessageValue.toString())
6738 }
6739
6740 // Call receive handler with deserialized value
6741 this.onReceive_OrderMessage(this._OrderMessageValue)
6742 return true
6743 }
6744 case BalanceMessageModel.fbeType: {
6745 // Deserialize the value from the FBE stream
6746 this._BalanceMessageModel.attachBuffer(buffer, offset)
6747 console.assert(this._BalanceMessageModel.verify(), 'protoex.BalanceMessage validation failed!')
6748 let deserialized = this._BalanceMessageModel.deserialize(this._BalanceMessageValue)
6749 console.assert((deserialized.size > 0), 'protoex.BalanceMessage deserialization failed!')
6750
6751 // Log the value
6752 if (this.logging) {
6753 this.onReceiveLog(this._BalanceMessageValue.toString())
6754 }
6755
6756 // Call receive handler with deserialized value
6757 this.onReceive_BalanceMessage(this._BalanceMessageValue)
6758 return true
6759 }
6760 case AccountMessageModel.fbeType: {
6761 // Deserialize the value from the FBE stream
6762 this._AccountMessageModel.attachBuffer(buffer, offset)
6763 console.assert(this._AccountMessageModel.verify(), 'protoex.AccountMessage validation failed!')
6764 let deserialized = this._AccountMessageModel.deserialize(this._AccountMessageValue)
6765 console.assert((deserialized.size > 0), 'protoex.AccountMessage deserialization failed!')
6766
6767 // Log the value
6768 if (this.logging) {
6769 this.onReceiveLog(this._AccountMessageValue.toString())
6770 }
6771
6772 // Call receive handler with deserialized value
6773 this.onReceive_AccountMessage(this._AccountMessageValue)
6774 return true
6775 }
6776 default: break
6777 }
6778
6779 // noinspection RedundantIfStatementJS
6780 if ((this.protoReceiver != null) && this.protoReceiver.onReceive(type, buffer, offset, size)) {
6781 return true
6782 }
6783

Callers

nothing calls this directly

Calls 9

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

Tested by

no test coverage detected