activate skipped tests

Author: noxify

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

@@ -98,7 +98,7 @@ export function runTests<TDatabase = unknown>(ctx: SharedTestContext<TDatabase>)
         expect(job?.name).toBe("job-1") // High priority first
       })
 
-      it.skip("should update job status", async () => {
+      it("should update job status", async () => {
         const job = await adapter.addJob({
           name: "test-job",
           payload: { data: "test" },
@@ -111,12 +111,11 @@ export function runTests<TDatabase = unknown>(ctx: SharedTestContext<TDatabase>)
 
         await adapter.updateJobStatus(job.id, "processing")
 
-        // const [updated] = await db
-        //   .select()
-        //   .from(schema.queueJobs)
-        //   .where(eq(schema.queueJobs.id, job.id))
-        // expect(updated?.status).toBe("processing")
-        // expect(updated?.processedAt).toBeTruthy()
+        const [updated]: [{ progressed_at: number; 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()
       })
 
       it("should get queue stats", async () => {
@@ -218,7 +217,7 @@ export function runTests<TDatabase = unknown>(ctx: SharedTestContext<TDatabase>)
       })
     })
 
-    describe.skip("Result storage", async () => {
+    describe("Result storage", async () => {
       it("should store job result when job completes", async () => {
         const job = await adapter.addJob({
           name: "test-job",
@@ -233,14 +232,12 @@ export function runTests<TDatabase = unknown>(ctx: SharedTestContext<TDatabase>)
         const result = { success: true, output: "processed" }
         await adapter.updateJobStatus(job.id, "completed", undefined, result)
 
-        // const [updated] = await db
-        //   .select()
-        //   .from(schema.queueJobs)
-        //   .where(eq(schema.queueJobs.id, job.id))
+        const [updated]: [{ completed_at: number; status: string; result: unknown }?] =
+          await internalDbClient`SELECT completed_at, status, result FROM queue_jobs WHERE id=${job.id}`
 
-        // expect(updated?.status).toBe("completed")
-        // expect(updated?.result).toEqual(result)
-        // expect(updated?.completedAt).toBeTruthy()
+        expect(updated?.status).toBe("completed")
+        expect(updated?.result).toEqual(result)
+        expect(updated?.completed_at).toBeTruthy()
       })
 
       it("should handle null/undefined results", async () => {
@@ -256,12 +253,10 @@ export function runTests<TDatabase = unknown>(ctx: SharedTestContext<TDatabase>)
 
         await adapter.updateJobStatus(job.id, "completed", undefined, null)
 
-        // const [updated] = await db
-        //   .select()
-        //   .from(schema.queueJobs)
-        //   .where(eq(schema.queueJobs.id, job.id))
+        const [updated]: [{ result: unknown }?] =
+          await internalDbClient`SELECT result FROM queue_jobs WHERE id=${job.id}`
 
-        // expect(updated?.result).toBeNull()
+        expect(updated?.result).toBeNull()
       })
 
       it("should preserve result in transformJob method", async () => {
@@ -281,13 +276,10 @@ export function runTests<TDatabase = unknown>(ctx: SharedTestContext<TDatabase>)
         const nextJob = await adapter.getNextJob()
         expect(nextJob).toBeNull() // No pending jobs
 
-        // Get the completed job directly from database and transform
-        // const [dbJob] = await db
-        //   .select()
-        //   .from(schema.queueJobs)
-        //   .where(eq(schema.queueJobs.id, job.id))
+        const [dbJob]: [{ result: unknown }?] =
+          await internalDbClient`SELECT result FROM queue_jobs WHERE id=${job.id}`
 
-        // expect(dbJob?.result).toEqual(result)
+        expect(dbJob?.result).toEqual(result)
       })
 
       it("should not update result when not provided", async () => {
@@ -308,13 +300,11 @@ export function runTests<TDatabase = unknown>(ctx: SharedTestContext<TDatabase>)
         // Second update without result (should preserve existing result)
         await adapter.updateJobStatus(job.id, "completed")
 
-        // const [updated] = await db
-        //   .select()
-        //   .from(schema.queueJobs)
-        //   .where(eq(schema.queueJobs.id, job.id))
+        const [updated]: [{ result: unknown; status: string }?] =
+          await internalDbClient`SELECT result FROM queue_jobs WHERE id=${job.id}`
 
-        // expect(updated?.result).toEqual(result)
-        // expect(updated?.status).toBe("completed")
+        expect(updated?.result).toEqual(result)
+        expect(updated?.status).toBe("completed")
       })
     })
   })

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

@@ -53,10 +53,12 @@ export function runTests<TDatabase = unknown>(ctx: SharedTestContext<TDatabase>)
       adapter.setQueueName("test-queue")
     })
 
-    it.skip("should handle UTC timestamps correctly regardless of database timezone", async () => {
+    it("should handle UTC timestamps correctly regardless of database timezone", async () => {
       // Set database timezone to something other than UTC
       // await db.execute(sql`SET timezone = 'America/New_York'`)
 
+      await internalDbClient`SET timezone = 'America/New_York`
+
       const testDate = new Date("2025-01-15T12:00:00.000Z") // Explicit UTC time
 
       const job = await adapter.addJob({
@@ -70,26 +72,23 @@ export function runTests<TDatabase = unknown>(ctx: SharedTestContext<TDatabase>)
       })
 
       // Retrieve the job and check the timestamp
-      // const [retrieved] = await db
-      //   .select()
-      //   .from(schema.queueJobs)
-      //   .where(eq(schema.queueJobs.id, job.id))
+      const [retrieved]: [{ process_at: number }?] =
+        await internalDbClient`SELECT process_at FROM queue_jobs WHERE id=${job.id}`
 
-      // // The processAt should match our input UTC time
-      // expect(retrieved?.processAt.getTime()).toBe(testDate.getTime())
+      // The processAt should match our input UTC time
+      expect(retrieved?.process_at).toBe(testDate.getTime())
 
       // Update job status and check timestamp consistency
       await adapter.updateJobStatus(job.id, "processing")
 
-      // const [updated] = await db
-      //   .select()
-      //   .from(schema.queueJobs)
-      //   .where(eq(schema.queueJobs.id, job.id))
+      const [updated]: [{ processed_at: number }?] =
+        await internalDbClient`SELECT processed_at FROM queue_jobs WHERE id=${job.id}`
 
-      // // processedAt should be a valid UTC timestamp
-      // expect(updated?.processedAt).toBeTruthy()
-      // expect(updated?.processedAt?.getTime()).toBeGreaterThan(testDate.getTime())
+      // processedAt should be a valid UTC timestamp
+      expect(updated?.processed_at).toBeTruthy()
+      expect(updated?.processed_at).toBeGreaterThan(testDate.getTime())
     })
+
     it("should handle dates with explicit timezone offsets", async () => {
       // User passes date with timezone offset
       const dateWithOffset = new Date("2024-01-15T14:00:00+02:00") // 2 PM in +2 timezone = 12 PM UTC