client updated

Author: ackava

package-lock.json

@@ -37,8 +37,8 @@
   "devDependencies": {
     "@types/mssql": "^8.1.2",
     "@types/node": "^20.3.2",
-    "@types/pg": "^8.10.2",
-    "@types/pg-cursor": "^2.7.0",
+    "@types/pg": "^8.15.6",
+    "@types/pg-cursor": "^2.7.2",
     "@typescript-eslint/eslint-plugin": "^6.7.3",
     "@typescript-eslint/parser": "^6.7.3",
     "pg": "^8.11.1",

package.json

@@ -45,6 +45,9 @@ pg.types.setTypeParser(pg.types.builtins.DATE, (n) =>
 pg.types.setTypeParser(pg.types.builtins.TIMETZ, (n) =>
     new DateTime(n)
 );
+
+pg.defaults.parseInputDatesAsUTC = true;
+
 // pg.types.setTypeParser(pg.types.builtins.NUMERIC, (n) => n ? Number(n) : 0);
 
 class DbReader implements IDbReader {

src/drivers/postgres/PostgreSqlDriver.ts

@@ -76,20 +76,21 @@ export default async function (this: TestConfig) {
 
     await storage.seed();
 
+
     const id = await c.queue(SendWorkflow, "a", {
         throttle: {
-            group: "a",
-            deferSeconds: 15
-        }
+            group: "a1",
+            deferSeconds: 60,
+        },
     });
 
     const result = await storage.getWorkflow(id);
 
     const next = await c.queue(SendWorkflow, "b", {
         throttle: {
-            group: "a",
-            deferSeconds: 15
-        }
+            group: "a1",
+            deferSeconds: 60
+        },
     });
 
     const resultNext = await storage.getWorkflow(next);

src/tests/eternity/throttle/throttle-defer.test.ts

@@ -63,6 +63,7 @@ export default class WorkflowStorage {
                 && x.eta >= Sql.cast.asDateTime(p.now)
             )
             .orderByDescending(void 0, (p) => (x) => x.queued)
+            .trace(console.log)
             .first();
         if (w) {
             w.eta = DateTime.from(w.eta).addSeconds(deferSeconds);