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

Method onReceive

projects/JavaScript/proto/protoex.js:7949–8008  ·  view source on GitHub ↗

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

7947 * @returns {!boolean} Success flag
7948 */
7949 onReceive (type, buffer, offset, size) {
7950 switch (type) {
7951 case OrderMessageFinalModel.fbeType: {
7952 // Deserialize the value from the FBE stream
7953 this._OrderMessageReceiverModel.attachBuffer(buffer, offset)
7954 console.assert(this._OrderMessageReceiverModel.verify(), 'protoex.OrderMessage validation failed!')
7955 let deserialized = this._OrderMessageReceiverModel.deserialize(this._OrderMessageReceiverValue)
7956 console.assert((deserialized.size > 0), 'protoex.OrderMessage deserialization failed!')
7957
7958 // Log the value
7959 if (this.logging) {
7960 this.onReceiveLog(this._OrderMessageReceiverValue.toString())
7961 }
7962
7963 // Call receive handler with deserialized value
7964 this.onReceive_OrderMessage(this._OrderMessageReceiverValue)
7965 return true
7966 }
7967 case BalanceMessageFinalModel.fbeType: {
7968 // Deserialize the value from the FBE stream
7969 this._BalanceMessageReceiverModel.attachBuffer(buffer, offset)
7970 console.assert(this._BalanceMessageReceiverModel.verify(), 'protoex.BalanceMessage validation failed!')
7971 let deserialized = this._BalanceMessageReceiverModel.deserialize(this._BalanceMessageReceiverValue)
7972 console.assert((deserialized.size > 0), 'protoex.BalanceMessage deserialization failed!')
7973
7974 // Log the value
7975 if (this.logging) {
7976 this.onReceiveLog(this._BalanceMessageReceiverValue.toString())
7977 }
7978
7979 // Call receive handler with deserialized value
7980 this.onReceive_BalanceMessage(this._BalanceMessageReceiverValue)
7981 return true
7982 }
7983 case AccountMessageFinalModel.fbeType: {
7984 // Deserialize the value from the FBE stream
7985 this._AccountMessageReceiverModel.attachBuffer(buffer, offset)
7986 console.assert(this._AccountMessageReceiverModel.verify(), 'protoex.AccountMessage validation failed!')
7987 let deserialized = this._AccountMessageReceiverModel.deserialize(this._AccountMessageReceiverValue)
7988 console.assert((deserialized.size > 0), 'protoex.AccountMessage deserialization failed!')
7989
7990 // Log the value
7991 if (this.logging) {
7992 this.onReceiveLog(this._AccountMessageReceiverValue.toString())
7993 }
7994
7995 // Call receive handler with deserialized value
7996 this.onReceive_AccountMessage(this._AccountMessageReceiverValue)
7997 return true
7998 }
7999 default: break
8000 }
8001
8002 // noinspection RedundantIfStatementJS
8003 if ((this.protoClient != null) && this.protoClient.onReceive(type, buffer, offset, size)) {
8004 return true
8005 }
8006

Callers

nothing calls this directly

Calls 9

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

Tested by

no test coverage detected