fix test issues

Author: noxify

packages/shared-tests/src/tests/adapter.ts

@@ -111,11 +111,11 @@ export function runTests<TDatabase = unknown>(ctx: SharedTestContext<TDatabase>)
 
         await adapter.updateJobStatus(job.id, "processing")
 
-        const [updated]: [{ progressed_at: number; status: string }?] =
+        const [updated]: [{ processed_at: Date; status: string }?] =
           await internalDbClient`SELECT processed_at, status FROM queue_jobs WHERE id=${job.id}`
 
         expect(updated?.status).toBe("processing")
-        expect(updated?.progressed_at).toBeTruthy()
+        expect(updated?.processed_at).toBeTruthy()
       })
 
       it("should get queue stats", async () => {
@@ -232,7 +232,7 @@ export function runTests<TDatabase = unknown>(ctx: SharedTestContext<TDatabase>)
         const result = { success: true, output: "processed" }
         await adapter.updateJobStatus(job.id, "completed", undefined, result)
 
-        const [updated]: [{ completed_at: number; status: string; result: unknown }?] =
+        const [updated]: [{ completed_at: Date; status: string; result: unknown }?] =
           await internalDbClient`SELECT completed_at, status, result FROM queue_jobs WHERE id=${job.id}`
 
         expect(updated?.status).toBe("completed")
@@ -301,7 +301,9 @@ export function runTests<TDatabase = unknown>(ctx: SharedTestContext<TDatabase>)
         await adapter.updateJobStatus(job.id, "completed")
 
         const [updated]: [{ result: unknown; status: string }?] =
-          await internalDbClient`SELECT result FROM queue_jobs WHERE id=${job.id}`
+          await internalDbClient`SELECT result, status FROM queue_jobs WHERE id=${job.id}`
+
+        console.dir({ updated })
 
         expect(updated?.result).toEqual(result)
         expect(updated?.status).toBe("completed")

packages/shared-tests/src/tests/timezone.ts

@@ -72,21 +72,21 @@ export function runTests<TDatabase = unknown>(ctx: SharedTestContext<TDatabase>)
       })
 
       // Retrieve the job and check the timestamp
-      const [retrieved]: [{ process_at: number }?] =
+      const [retrieved]: [{ process_at: Date }?] =
         await internalDbClient`SELECT process_at FROM queue_jobs WHERE id=${job.id}`
 
       // The processAt should match our input UTC time
-      expect(retrieved?.process_at).toBe(testDate.getTime())
+      expect(retrieved?.process_at.getTime()).toBe(testDate.getTime())
 
       // Update job status and check timestamp consistency
       await adapter.updateJobStatus(job.id, "processing")
 
-      const [updated]: [{ processed_at: number }?] =
+      const [updated]: [{ processed_at: Date }?] =
         await internalDbClient`SELECT processed_at FROM queue_jobs WHERE id=${job.id}`
 
       // processedAt should be a valid UTC timestamp
       expect(updated?.processed_at).toBeTruthy()
-      expect(updated?.processed_at).toBeGreaterThan(testDate.getTime())
+      expect(updated?.processed_at.getTime()).toBeGreaterThan(testDate.getTime())
     })
 
     it("should handle dates with explicit timezone offsets", async () => {