diff options
| author | adamdottv <[email protected]> | 2025-05-13 06:51:28 -0500 |
|---|---|---|
| committer | adamdottv <[email protected]> | 2025-05-13 06:51:28 -0500 |
| commit | 0c21ca531856c2f73da0b27ce215dab8385a9ef5 (patch) | |
| tree | 8e4cd4117ce9c294437872f5170763aa2fb1519f /internal/message | |
| parent | 0117c72a2c3f5a91516d5d8158560637b4a16a4c (diff) | |
| download | opencode-0c21ca531856c2f73da0b27ce215dab8385a9ef5.tar.gz opencode-0c21ca531856c2f73da0b27ce215dab8385a9ef5.zip | |
chore: cleanup
Diffstat (limited to 'internal/message')
| -rw-r--r-- | internal/message/message.go | 6 |
1 files changed, 2 insertions, 4 deletions
diff --git a/internal/message/message.go b/internal/message/message.go index 4c6726ca1..4fa131ea1 100644 --- a/internal/message/message.go +++ b/internal/message/message.go @@ -128,7 +128,7 @@ func (s *service) Update(ctx context.Context, message Message) (Message, error) finishPart := message.FinishPart() if finishPart != nil && finishPart.Time > 0 { dbFinishedAt = sql.NullInt64{ - Int64: finishPart.Time / 1000, // Convert Milliseconds from Go struct to Seconds for DB + Int64: finishPart.Time, Valid: true, } } @@ -193,11 +193,9 @@ func (s *service) ListAfter(ctx context.Context, sessionID string, timestampMill s.mu.RLock() defer s.mu.RUnlock() - timestampSeconds := timestampMillis / 1000 // Convert to seconds for DB query - dbMessages, err := s.db.ListMessagesBySessionAfter(ctx, db.ListMessagesBySessionAfterParams{ SessionID: sessionID, - CreatedAt: timestampSeconds, + CreatedAt: timestampMillis, }) if err != nil { return nil, fmt.Errorf("db.ListMessagesBySessionAfter: %w", err) |