ai/byre
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases 7 Wiki Activity

Audit of 9af1463

Browse Source
This commit is contained in:
Ian Gulliver
2026-10-20 22:48:47 -07:00
parent ee73b93a30
commit 4f7d05021a
1 changed files with 6 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files
internal/store/store.go
+6 -8
View File
@@ -1021,8 +1021,8 @@ func (s *Store) TaskEvents(ctx context.Context, taskID string, after int64, limi
}
func (s *Store) TranscriptEvents(ctx context.Context, taskID string, after int64, limit int) ([]api.Event, error) {
where := "task_id = ?"
args := []any{taskID}
query := "SELECT " + eventColumns + " FROM events WHERE task_id = ? AND seq > ?"
args := []any{taskID, after}
for id := taskID; ; {
from := ""
at := 0
@@ -1041,14 +1041,12 @@ func (s *Store) TranscriptEvents(ctx context.Context, taskID string, after int64
if err != nil {
return nil, err
}
where += " OR (task_id = ? AND seq <= ?)"
args = append(args, from, cut)
query += " UNION ALL SELECT " + eventColumns + " FROM events WHERE task_id = ? AND seq <= ? AND seq > ?"
args = append(args, from, cut, after)
id = from
}
rows, err := s.db.QueryContext(ctx, `
SELECT `+eventColumns+`
FROM events WHERE (`+where+`) AND seq > ? ORDER BY seq LIMIT ?
`, append(args, after, limit)...)
// Merge the indexed ranges in sequence order instead of sorting the remaining history for every page.
rows, err := s.db.QueryContext(ctx, query+" ORDER BY seq LIMIT ?", append(args, limit)...)
if err != nil {
return nil, err
}