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

Method onReceive

projects/JavaScript/proto/proto.js:7324–7377  ·  view source on GitHub ↗

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

7322 * @returns {!boolean} Success flag
7323 */
7324 onReceive (type, buffer, offset, size) {
7325 switch (type) {
7326 case OrderMessageFinalModel.fbeType: {
7327 // Deserialize the value from the FBE stream
7328 this._OrderMessageModel.attachBuffer(buffer, offset)
7329 console.assert(this._OrderMessageModel.verify(), 'proto.OrderMessage validation failed!')
7330 let deserialized = this._OrderMessageModel.deserialize(this._OrderMessageValue)
7331 console.assert((deserialized.size > 0), 'proto.OrderMessage deserialization failed!')
7332
7333 // Log the value
7334 if (this.logging) {
7335 this.onReceiveLog(this._OrderMessageValue.toString())
7336 }
7337
7338 // Call receive handler with deserialized value
7339 this.onReceive_OrderMessage(this._OrderMessageValue)
7340 return true
7341 }
7342 case BalanceMessageFinalModel.fbeType: {
7343 // Deserialize the value from the FBE stream
7344 this._BalanceMessageModel.attachBuffer(buffer, offset)
7345 console.assert(this._BalanceMessageModel.verify(), 'proto.BalanceMessage validation failed!')
7346 let deserialized = this._BalanceMessageModel.deserialize(this._BalanceMessageValue)
7347 console.assert((deserialized.size > 0), 'proto.BalanceMessage deserialization failed!')
7348
7349 // Log the value
7350 if (this.logging) {
7351 this.onReceiveLog(this._BalanceMessageValue.toString())
7352 }
7353
7354 // Call receive handler with deserialized value
7355 this.onReceive_BalanceMessage(this._BalanceMessageValue)
7356 return true
7357 }
7358 case AccountMessageFinalModel.fbeType: {
7359 // Deserialize the value from the FBE stream
7360 this._AccountMessageModel.attachBuffer(buffer, offset)
7361 console.assert(this._AccountMessageModel.verify(), 'proto.AccountMessage validation failed!')
7362 let deserialized = this._AccountMessageModel.deserialize(this._AccountMessageValue)
7363 console.assert((deserialized.size > 0), 'proto.AccountMessage deserialization failed!')
7364
7365 // Log the value
7366 if (this.logging) {
7367 this.onReceiveLog(this._AccountMessageValue.toString())
7368 }
7369
7370 // Call receive handler with deserialized value
7371 this.onReceive_AccountMessage(this._AccountMessageValue)
7372 return true
7373 }
7374 default: break
7375 }
7376 return false
7377 }
7378
7379 /**
7380 * 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