diff --git a/cmd/streamcli/commands/commands.go b/cmd/streamcli/commands/commands.go index e3adfb8..ee61658 100644 --- a/cmd/streamcli/commands/commands.go +++ b/cmd/streamcli/commands/commands.go @@ -319,7 +319,7 @@ func chatListen(cmd *cobra.Command, args []string) { assertNoError(ctx, err) fmt.Println("subscribing...") - ch, err := streamD.SubscribeToChatMessages(ctx, time.Now().Add(-time.Minute), 1000) + ch, err := streamD.SubscribeToChatMessages(ctx, time.Now().Add(-time.Hour*24*3), 1000) assertNoError(ctx, err) fmt.Println("started listening...") diff --git a/pkg/chatmessagesstorage/get_messages_since.go b/pkg/chatmessagesstorage/get_messages_since.go index d86f0a6..832e1aa 100644 --- a/pkg/chatmessagesstorage/get_messages_since.go +++ b/pkg/chatmessagesstorage/get_messages_since.go @@ -24,9 +24,9 @@ func (s *ChatMessagesStorage) getMessagesSinceLocked( since time.Time, limit uint, ) (_ret []api.ChatMessage, _err error) { - logger.Tracef(ctx, "getMessagesSinceLocked(ctx, %v, %d)", since, limit) + logger.Debugf(ctx, "getMessagesSinceLocked(ctx, %v, %d)", since, limit) defer func() { - logger.Tracef(ctx, "/getMessagesSinceLocked(ctx, %v, %d): len:%d, %v", since, limit, len(_ret), _err) + logger.Debugf(ctx, "/getMessagesSinceLocked(ctx, %v, %d): len:%d, %v", since, limit, len(_ret), _err) }() if len(s.Messages) == 0 { @@ -48,7 +48,7 @@ func (s *ChatMessagesStorage) getMessagesSinceLocked( if idx >= len(s.Messages) { lastMessage := s.Messages[len(s.Messages)-1] if !since.Before(lastMessage.CreatedAt) { - logger.Tracef(ctx, "all messages are too old: %v < %v", lastMessage, since) + logger.Tracef(ctx, "all messages (%d) are too old: %v < %v; meanwhile the first message: %v", len(s.Messages), lastMessage, since, s.Messages[0]) return nil, nil } idx = 0 diff --git a/pkg/streamcontrol/text_format_type.go b/pkg/streamcontrol/text_format_type.go index e2db2a9..dd8aac7 100644 --- a/pkg/streamcontrol/text_format_type.go +++ b/pkg/streamcontrol/text_format_type.go @@ -12,6 +12,7 @@ const ( TextFormatTypePlain TextFormatTypeMarkdown TextFormatTypeHTML + EndOfTextFormatType ) func (t TextFormatType) String() string { @@ -34,7 +35,7 @@ func (t TextFormatType) MarshalJSON() ([]byte, error) { } func TextFormatTypeFromString(s string) (TextFormatType, error) { - for i := TextFormatTypeUndefined + 1; i < TextFormatTypeHTML; i++ { + for i := range EndOfTextFormatType { if s == i.String() { return i, nil }