fix(api): simplify date comparison in getDueCronTriggers using lte for improved clarity

Author: bchapuis

apps/api/src/db/queries.ts

@@ -6,7 +6,7 @@ import {
   WorkflowExecutionStatus,
 } from "@dafthunk/types";
 import * as crypto from "crypto";
-import { and, desc, eq, inArray, SQL, sql } from "drizzle-orm";
+import { and, desc, eq, inArray, lte, SQL, sql } from "drizzle-orm";
 import { alias } from "drizzle-orm/sqlite-core";
 import { v7 as uuidv7 } from "uuid";
 
@@ -1207,31 +1207,24 @@ export async function getDueCronTriggers(
       selectedDeployment: selectedDeployment,
     })
     .from(cronTriggers)
-    .where(
-      and(
-        eq(cronTriggers.active, true),
-        sql`${cronTriggers.nextRunAt} <= ${Math.floor(now.getTime() / 1000)}`
-      )
-    )
+    .where(and(eq(cronTriggers.active, true), lte(cronTriggers.nextRunAt, now)))
     .innerJoin(workflows, eq(workflows.id, cronTriggers.workflowId))
-    .innerJoin(latestByWorkflow, eq(latestByWorkflow.workflowId, workflows.id))
-    .innerJoin(
+    .leftJoin(latestByWorkflow, eq(latestByWorkflow.workflowId, workflows.id))
+    .leftJoin(
       latestDeployment,
       and(
         eq(latestDeployment.workflowId, latestByWorkflow.workflowId),
         eq(latestDeployment.version, latestByWorkflow.latestVersion)
       )
     )
-    .leftJoin(
-      selectedDeployment,
-      and(
-        eq(selectedDeployment.workflowId, workflows.id),
-        eq(selectedDeployment.version, cronTriggers.versionNumber)
-      )
-    )
     .all();
 
-  return rows.map((r) => ({
+  return rows
+  .filter(r =>
+    r.cronTrigger.versionAlias === 'dev' ||
+    (r.cronTrigger.versionAlias === 'latest'  && r.latestDeployment) ||
+    (r.cronTrigger.versionAlias === 'version' && r.selectedDeployment)
+  ).map((r) => ({
     cronTrigger: r.cronTrigger,
     workflow: r.workflow,
     deployment: