in src/message/messageparser.go [36:89]
func (clientMessage *ClientMessage) DeserializeClientMessage(log log.T, input []byte) (err error) {
clientMessage.MessageType, err = getString(log, input, ClientMessage_MessageTypeOffset, ClientMessage_MessageTypeLength)
if err != nil {
log.Errorf("Could not deserialize field MessageType with error: %v", err)
return err
}
clientMessage.SchemaVersion, err = getUInteger(log, input, ClientMessage_SchemaVersionOffset)
if err != nil {
log.Errorf("Could not deserialize field SchemaVersion with error: %v", err)
return err
}
clientMessage.CreatedDate, err = getULong(log, input, ClientMessage_CreatedDateOffset)
if err != nil {
log.Errorf("Could not deserialize field CreatedDate with error: %v", err)
return err
}
clientMessage.SequenceNumber, err = getLong(log, input, ClientMessage_SequenceNumberOffset)
if err != nil {
log.Errorf("Could not deserialize field SequenceNumber with error: %v", err)
return err
}
clientMessage.Flags, err = getULong(log, input, ClientMessage_FlagsOffset)
if err != nil {
log.Errorf("Could not deserialize field Flags with error: %v", err)
return err
}
clientMessage.MessageId, err = getUuid(log, input, ClientMessage_MessageIdOffset)
if err != nil {
log.Errorf("Could not deserialize field MessageId with error: %v", err)
return err
}
clientMessage.PayloadDigest, err = getBytes(log, input, ClientMessage_PayloadDigestOffset, ClientMessage_PayloadDigestLength)
if err != nil {
log.Errorf("Could not deserialize field PayloadDigest with error: %v", err)
return err
}
clientMessage.PayloadType, err = getUInteger(log, input, ClientMessage_PayloadTypeOffset)
if err != nil {
log.Errorf("Could not deserialize field PayloadType with error: %v", err)
return err
}
clientMessage.PayloadLength, err = getUInteger(log, input, ClientMessage_PayloadLengthOffset)
headerLength, herr := getUInteger(log, input, ClientMessage_HLOffset)
if herr != nil {
log.Errorf("Could not deserialize field HeaderLength with error: %v", err)
return err
}
clientMessage.HeaderLength = headerLength
clientMessage.Payload = input[headerLength+ClientMessage_PayloadLengthLength:]
return err
}