Function timeCursorPredicate

apps/sim/lib/data-drains/sources/cursor.ts:41–48

(
  timestampCol: PgColumn,
  idCol: PgColumn,
  cursor: TimeCursor | null
)

 * lexicographically earlier id than the cursor row would be skipped forever.
 */
export function timeCursorPredicate(
  timestampCol: PgColumn,
  idCol: PgColumn,
  cursor: TimeCursor | null
): SQL | undefined {
  if (!cursor) return undefined
  return sql`(date_trunc('milliseconds', ${timestampCol}), ${idCol}) > (${new Date(cursor.ts)}, ${cursor.id})`
}

/**
 * ORDER BY fragments paired with `timeCursorPredicate`. Both must agree on