Simplify delayed_until check and set default to NOW() if no value is passed

Author: thoven87

Sources/JobsPostgres/Migrations/UpdateJobDelay.swift

@@ -0,0 +1,45 @@
+//
+//  UpdateJobDelay.swift
+//  swift-jobs-postgres
+//
+//  Created by Stevenson Michel on 2/17/25.
+//
+
+//===----------------------------------------------------------------------===//
+//
+// This source file is part of the Hummingbird server framework project
+//
+// Copyright (c) 2024 the Hummingbird authors
+// Licensed under Apache License v2.0
+//
+// See LICENSE.txt for license information
+// See hummingbird/CONTRIBUTORS.txt for the list of Hummingbird authors
+//
+// SPDX-License-Identifier: Apache-2.0
+//
+//===----------------------------------------------------------------------===//
+
+import Logging
+import PostgresMigrations
+import PostgresNIO
+
+struct UpdateJobDelay: DatabaseMigration {
+    func apply(connection: PostgresConnection, logger: Logger) async throws {
+        try await connection.query(
+            """
+            ALTER TABLE _hb_pg_job_queue ALTER COLUMN delayed_until TIMESTAMP WITH TIME ZONE NOT NULL DEFAULT NOW()
+            """,
+            logger: logger
+        )
+    }
+
+    func revert(connection: PostgresConnection, logger: Logger) async throws {
+        try await connection.query(
+            "ALTER TABLE _hb_pg_job_queue ALTER COLUMN delayed_until DROP NOT NULL",
+            logger: logger
+        )
+    }
+
+    var name: String { "_Update_JobQueueDelay_Table_" }
+    var group: DatabaseMigrationGroup { .jobQueue }
+}

Sources/JobsPostgres/PostgresJobsQueue.swift

@@ -112,6 +112,7 @@ public final class PostgresJobQueue: JobQueueDriver {
         await migrations.add(CreateJobQueue())
         await migrations.add(CreateJobQueueMetadata())
         await migrations.add(CreateJobDelay())
+        await migrations.add(UpdateJobDelay())
     }
 
     /// Run on initialization of the job queue
@@ -203,7 +204,7 @@ public final class PostgresJobQueue: JobQueueDriver {
                             SELECT
                                 job_id
                             FROM _hb_pg_job_queue
-                            WHERE (delayed_until IS NULL OR delayed_until <= NOW())
+                            WHERE delayed_until <= NOW()
                             ORDER BY createdAt, delayed_until ASC
                             FOR UPDATE SKIP LOCKED
                             LIMIT 1