Skip to content

Commit 9ddc8e2

Browse files
committed
Fix the since processing in GetMessagesSince
1 parent eea64a7 commit 9ddc8e2

File tree

1 file changed

+5
-1
lines changed

1 file changed

+5
-1
lines changed

pkg/chatmessagesstorage/get_messages_since.go

Lines changed: 5 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -30,6 +30,7 @@ func (s *ChatMessagesStorage) getMessagesSinceLocked(
3030
}()
3131

3232
if len(s.Messages) == 0 {
33+
logger.Tracef(ctx, "len(s.Messages) == 0")
3334
return nil, nil
3435
}
3536

@@ -44,7 +45,9 @@ func (s *ChatMessagesStorage) getMessagesSinceLocked(
4445
})
4546

4647
if idx >= len(s.Messages) {
47-
if !since.Before(s.Messages[0].CreatedAt) {
48+
lastMessage := s.Messages[len(s.Messages)-1]
49+
if !since.Before(lastMessage.CreatedAt) {
50+
logger.Tracef(ctx, "all messages are too old: %v < %v", lastMessage, since)
4851
return nil, nil
4952
}
5053
idx = 0
@@ -54,5 +57,6 @@ func (s *ChatMessagesStorage) getMessagesSinceLocked(
5457
idx = len(s.Messages) - int(limit)
5558
}
5659

60+
logger.Tracef(ctx, "s.Messages[%d:%d]", idx, len(s.Messages))
5761
return slices.Clone(s.Messages[idx:]), nil
5862
}

0 commit comments

Comments
 (0)