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

Method onReceive

projects/JavaScript/proto/proto.js:6939–6992  ·  view source on GitHub ↗

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

6937 * @returns {!boolean} Success flag
6938 */
6939 onReceive (type, buffer, offset, size) {
6940 switch (type) {
6941 case OrderMessageModel.fbeType: {
6942 // Deserialize the value from the FBE stream
6943 this._OrderMessageReceiverModel.attachBuffer(buffer, offset)
6944 console.assert(this._OrderMessageReceiverModel.verify(), 'proto.OrderMessage validation failed!')
6945 let deserialized = this._OrderMessageReceiverModel.deserialize(this._OrderMessageReceiverValue)
6946 console.assert((deserialized.size > 0), 'proto.OrderMessage deserialization failed!')
6947
6948 // Log the value
6949 if (this.logging) {
6950 this.onReceiveLog(this._OrderMessageReceiverValue.toString())
6951 }
6952
6953 // Call receive handler with deserialized value
6954 this.onReceive_OrderMessage(this._OrderMessageReceiverValue)
6955 return true
6956 }
6957 case BalanceMessageModel.fbeType: {
6958 // Deserialize the value from the FBE stream
6959 this._BalanceMessageReceiverModel.attachBuffer(buffer, offset)
6960 console.assert(this._BalanceMessageReceiverModel.verify(), 'proto.BalanceMessage validation failed!')
6961 let deserialized = this._BalanceMessageReceiverModel.deserialize(this._BalanceMessageReceiverValue)
6962 console.assert((deserialized.size > 0), 'proto.BalanceMessage deserialization failed!')
6963
6964 // Log the value
6965 if (this.logging) {
6966 this.onReceiveLog(this._BalanceMessageReceiverValue.toString())
6967 }
6968
6969 // Call receive handler with deserialized value
6970 this.onReceive_BalanceMessage(this._BalanceMessageReceiverValue)
6971 return true
6972 }
6973 case AccountMessageModel.fbeType: {
6974 // Deserialize the value from the FBE stream
6975 this._AccountMessageReceiverModel.attachBuffer(buffer, offset)
6976 console.assert(this._AccountMessageReceiverModel.verify(), 'proto.AccountMessage validation failed!')
6977 let deserialized = this._AccountMessageReceiverModel.deserialize(this._AccountMessageReceiverValue)
6978 console.assert((deserialized.size > 0), 'proto.AccountMessage deserialization failed!')
6979
6980 // Log the value
6981 if (this.logging) {
6982 this.onReceiveLog(this._AccountMessageReceiverValue.toString())
6983 }
6984
6985 // Call receive handler with deserialized value
6986 this.onReceive_AccountMessage(this._AccountMessageReceiverValue)
6987 return true
6988 }
6989 default: break
6990 }
6991 return false
6992 }
6993
6994 /**
6995 * 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