tech?(api): use batch insert to create jobs

1024pix · Sep 26, 2024 · bc669fd · bc669fd
1 parent 246ce13
commit bc669fd
Showing 1 changed file with 6 additions and 1 deletion.
diff --git a/api/src/shared/infrastructure/repositories/jobs/job-repository.js b/api/src/shared/infrastructure/repositories/jobs/job-repository.js
@@ -59,7 +59,12 @@ export class JobRepository {
   async #send(jobs) {
     const knexConn = DomainTransaction.getConnection();
 
-    return knexConn('pgboss.job').insert(jobs);
+    const results = await knexConn.batchInsert('pgboss.job', jobs);
+
+    // Sum the inserted row counts from the batch insert results
+    const rowCount = results.reduce((total, batchResult) => total + (batchResult.rowCount || 0), 0);
+
+    return { rowCount };
   }
 
   async performAsync(...datas) {