fix(backend): added support of deprecated batch meta message to pre-decoder

This commit is contained in:
Alexander Zavorotynskiy 2023-05-10 13:00:33 +02:00 committed by nick-delirium
parent f1a2874906
commit b121c42f5a

View file

@ -89,13 +89,15 @@ func (m *messageReaderImpl) Parse() (err error) {
if err != nil {
return fmt.Errorf("read message err: %s", err)
}
if m.msgType == MsgBatchMeta || m.msgType == MsgBatchMetadata {
if m.msgType == MsgBatchMeta || m.msgType == MsgBatchMetadata || m.msgType == MsgBatchMetadataDeprecated {
if len(m.list) > 0 {
return fmt.Errorf("batch meta not at the start of batch")
}
switch message := msg.(type) {
case *BatchMetadata:
m.version = int(message.Version)
case *BatchMetadataDeprecated:
m.version = int(message.Version)
case *BatchMeta:
m.version = 0
}