feat: migrate to pgboss 10

lib/handler-scanner.service.ts

@@ -75,7 +75,7 @@ export class HandlerScannerService {
             await this.pgBossService.registerJob(
               jobName,
               boundHandler,
-              jobOptions as PgBoss.BatchWorkOptions,
+              jobOptions,
             );
             this.logger.log(`Registered job: ${jobName}`);
           }

lib/pgboss.service.ts

@@ -42,20 +42,33 @@ export class PgBossService {
     await this.pgBoss.schedule(name, cron, data ?? {}, options ?? {});
     await this.pgBoss.work<TData>(
       name,
-      { ...options, includeMetadata: true },
+      { ...this.transformOptions(options), includeMetadata: true },
       handler,
     );
   }
 
   async registerJob<TData extends object>(
     name: string,
     handler: WorkWithMetadataHandler<TData>,
-    options?: PgBoss.BatchWorkOptions,
+    options?: PgBoss.WorkOptions,
   ) {
     await this.pgBoss.work<TData>(
       name,
       { ...options, includeMetadata: true },
       handler,
     );
   }
+  private transformOptions(
+    options?: PgBoss.WorkOptions | PgBoss.ScheduleOptions,
+  ) {
+    if (!options) return {};
+
+    const transformedOptions: any = { ...options };
+
+    if (typeof options.priority === "number") {
+      transformedOptions.priority = options.priority > 0;
+    }
+
+    return transformedOptions;
+  }
 }

lib/utils/conversion-helper.ts

@@ -1,10 +1,15 @@
-import { JobOptions, BatchWorkOptions } from "pg-boss";
-
-export function convertToBatchWorkOptions(
-  jobOptions: JobOptions = {},
-): BatchWorkOptions {
-  return {
-    ...jobOptions,
-    batchSize: 1,
-  };
+import PgBoss from "pg-boss";
+
+export function transformOptions(
+  options?: PgBoss.WorkOptions | PgBoss.ScheduleOptions,
+) {
+  if (!options) return {};
+
+  const transformedOptions: any = { ...options };
+
+  if (typeof options.priority === "number") {
+    transformedOptions.priority = options.priority > 0;
+  }
+
+  return transformedOptions;
 }

package.json

@@ -23,7 +23,7 @@
   "peerDependencies": {
     "@nestjs/common": "^9 || ^10",
     "@nestjs/core": "^9 || ^10",
-    "pg-boss": "^9",
+    "pg-boss": "^10",
     "reflect-metadata": "^0.1.13 || ^0.2.0",
     "rxjs": "^7.2.0"
   },

test/pgboss.service.spec.ts

@@ -32,13 +32,13 @@ describe("PgBossService", () => {
   describe("registerJob", () => {
     it("should call PgBoss work with correct parameters", async () => {
       const handler = jest.fn();
-      const options = { batchSize: 5 };
+      const options = {};
 
       await service.registerJob("test-job", handler, options);
 
       expect(mockPgBoss.work).toHaveBeenCalledWith(
         "test-job",
-        { batchSize: 5, includeMetadata: true },
+        { includeMetadata: true },
         handler,
       );
     });