From b121c42f5a6c5c5817bcbd1b770cedffc5b38cd8 Mon Sep 17 00:00:00 2001 From: Alexander Zavorotynskiy Date: Wed, 10 May 2023 13:00:33 +0200 Subject: [PATCH] fix(backend): added support of deprecated batch meta message to pre-decoder --- backend/pkg/messages/reader.go | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/backend/pkg/messages/reader.go b/backend/pkg/messages/reader.go index 436876e55..62eaf5bcd 100644 --- a/backend/pkg/messages/reader.go +++ b/backend/pkg/messages/reader.go @@ -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 }