refactor: Update filter function to include additional cursor values (#…

…1508)
retracedhq · Jul 17, 2024 · 57cf12b · 57cf12b
1 parent 0eff18f
commit 57cf12b
Showing 1 changed file with 1 addition and 2 deletions.
diff --git a/src/models/event/filter.ts b/src/models/event/filter.ts
@@ -43,13 +43,12 @@ export default async function filter(opts: Options): Promise<Result> {
       wheres.push(
         `(((doc -> 'canonical_time')::text::bigint < ${nextParam()}) OR ((doc -> 'canonical_time')::text::bigint = ${nextParam()} AND id < ${nextParam()}))`
       );
-      vals.push(opts.cursor[0], opts.cursor[0], opts.cursor[1]);
     } else {
       wheres.push(
         `(((doc -> 'canonical_time')::text::bigint > ${nextParam()}) OR ((doc -> 'canonical_time')::text::bigint = ${nextParam()} AND id > ${nextParam()}))`
       );
-      vals.push(opts.cursor[0]);
     }
+    vals.push(opts.cursor[0], opts.cursor[0], opts.cursor[1]);
   }
 
   const q = `