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

Method onReceive

projects/JavaScript/proto/protoex.js:7183–7242  ·  view source on GitHub ↗

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

7181 * @returns {!boolean} Success flag
7182 */
7183 onReceive (type, buffer, offset, size) {
7184 switch (type) {
7185 case OrderMessageModel.fbeType: {
7186 // Deserialize the value from the FBE stream
7187 this._OrderMessageReceiverModel.attachBuffer(buffer, offset)
7188 console.assert(this._OrderMessageReceiverModel.verify(), 'protoex.OrderMessage validation failed!')
7189 let deserialized = this._OrderMessageReceiverModel.deserialize(this._OrderMessageReceiverValue)
7190 console.assert((deserialized.size > 0), 'protoex.OrderMessage deserialization failed!')
7191
7192 // Log the value
7193 if (this.logging) {
7194 this.onReceiveLog(this._OrderMessageReceiverValue.toString())
7195 }
7196
7197 // Call receive handler with deserialized value
7198 this.onReceive_OrderMessage(this._OrderMessageReceiverValue)
7199 return true
7200 }
7201 case BalanceMessageModel.fbeType: {
7202 // Deserialize the value from the FBE stream
7203 this._BalanceMessageReceiverModel.attachBuffer(buffer, offset)
7204 console.assert(this._BalanceMessageReceiverModel.verify(), 'protoex.BalanceMessage validation failed!')
7205 let deserialized = this._BalanceMessageReceiverModel.deserialize(this._BalanceMessageReceiverValue)
7206 console.assert((deserialized.size > 0), 'protoex.BalanceMessage deserialization failed!')
7207
7208 // Log the value
7209 if (this.logging) {
7210 this.onReceiveLog(this._BalanceMessageReceiverValue.toString())
7211 }
7212
7213 // Call receive handler with deserialized value
7214 this.onReceive_BalanceMessage(this._BalanceMessageReceiverValue)
7215 return true
7216 }
7217 case AccountMessageModel.fbeType: {
7218 // Deserialize the value from the FBE stream
7219 this._AccountMessageReceiverModel.attachBuffer(buffer, offset)
7220 console.assert(this._AccountMessageReceiverModel.verify(), 'protoex.AccountMessage validation failed!')
7221 let deserialized = this._AccountMessageReceiverModel.deserialize(this._AccountMessageReceiverValue)
7222 console.assert((deserialized.size > 0), 'protoex.AccountMessage deserialization failed!')
7223
7224 // Log the value
7225 if (this.logging) {
7226 this.onReceiveLog(this._AccountMessageReceiverValue.toString())
7227 }
7228
7229 // Call receive handler with deserialized value
7230 this.onReceive_AccountMessage(this._AccountMessageReceiverValue)
7231 return true
7232 }
7233 default: break
7234 }
7235
7236 // noinspection RedundantIfStatementJS
7237 if ((this.protoClient != null) && this.protoClient.onReceive(type, buffer, offset, size)) {
7238 return true
7239 }
7240

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