From ddb7338801c7249cf0f8a2fe06793549e0fbc415 Mon Sep 17 00:00:00 2001 From: arnauds5 Date: Tue, 25 Jun 2024 22:02:57 +0200 Subject: [PATCH] Return messages with ascending storedTime order for catchup --- be1-go/internal/database/sqlite/sqlite_const.go | 2 +- be1-go/internal/database/sqlite/sqlite_test.go | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/be1-go/internal/database/sqlite/sqlite_const.go b/be1-go/internal/database/sqlite/sqlite_const.go index f5aa7b5b07..cd638da142 100644 --- a/be1-go/internal/database/sqlite/sqlite_const.go +++ b/be1-go/internal/database/sqlite/sqlite_const.go @@ -161,7 +161,7 @@ const ( FROM message JOIN channelMessage ON message.messageID = channelMessage.messageID WHERE channelMessage.channelPath = ? - ORDER BY message.storedTime DESC` + ORDER BY message.storedTime ASC` selectChannelPath = `SELECT channelPath FROM channel WHERE channelPath = ?` diff --git a/be1-go/internal/database/sqlite/sqlite_test.go b/be1-go/internal/database/sqlite/sqlite_test.go index f0585b7b18..518d97c4b7 100644 --- a/be1-go/internal/database/sqlite/sqlite_test.go +++ b/be1-go/internal/database/sqlite/sqlite_test.go @@ -138,7 +138,7 @@ func Test_SQLite_GetAllMessagesFromChannel(t *testing.T) { require.NoError(t, err) } - expected := []mmessage.Message{testMessages[3].msg, testMessages[0].msg} + expected := []mmessage.Message{testMessages[0].msg, testMessages[3].msg} messages, err := lite.GetAllMessagesFromChannel("channel1") require.NoError(t, err) require.Equal(t, expected, messages)