downgrade to common js for now

package.json

@@ -1,6 +1,6 @@
 {
   "name": "pg-boss",
-  "version": "8.1.1",
+  "version": "8.2.0",
   "description": "Queueing jobs in Node.js using PostgreSQL like a boss",
   "main": "./src/index.js",
   "engines": {
@@ -10,9 +10,9 @@
     "cron-parser": "^4.0.0",
     "delay": "^5.0.0",
     "lodash.debounce": "^4.0.8",
-    "p-map": "^5.3.0",
+    "p-map": "^4.0.0",
     "pg": "^8.5.1",
-    "serialize-error": "^11.0.0",
+    "serialize-error": "^8.1.0",
     "uuid": "^9.0.0"
   },
   "devDependencies": {

src/index.js

@@ -90,8 +90,6 @@ class PgBoss extends EventEmitter {
   }
 
   async start () {
-    const { serializeError } = await import('serialize-error')
-
     if (!this.stopped) {
       return this
     }
@@ -106,7 +104,7 @@ class PgBoss extends EventEmitter {
 
     this.started = true
 
-    this.manager.start({ stringify: serializeError })
+    this.manager.start()
 
     if (!this.config.noSupervisor) {
       await this.boss.supervise()

src/manager.js

@@ -3,9 +3,10 @@ const EventEmitter = require('events')
 const delay = require('delay')
 const uuid = require('uuid')
 const debounce = require('lodash.debounce')
-
+const { serializeError: stringify } = require('serialize-error')
 const Attorney = require('./attorney')
 const Worker = require('./worker')
+const pMap = require('p-map')
 
 const { QUEUES: BOSS_QUEUES } = require('./boss')
 const { QUEUES: TIMEKEEPER_QUEUES } = require('./timekeeper')
@@ -44,8 +45,6 @@ class Manager extends EventEmitter {
   constructor (db, config) {
     super()
 
-    this.stringify = null
-
     this.config = config
     this.db = db
 
@@ -98,8 +97,7 @@ class Manager extends EventEmitter {
     this.emitWipThrottled = debounce(() => this.emit(events.wip, this.getWipData()), WIP_EVENT_INTERVAL, WIP_DEBOUNCE_OPTIONS)
   }
 
-  start ({ stringify }) {
-    this.stringify = stringify
+  start () {
     this.stopping = false
   }
 
@@ -213,8 +211,6 @@ class Manager extends EventEmitter {
     const fetch = () => this.fetch(name, batchSize || (teamSize - queueSize), { includeMetadata })
 
     const onFetch = async (jobs) => {
-      const { default: pMap } = await import('p-map')
-
       if (this.config.__test__throw_worker) {
         throw new Error('__test__throw_worker')
       }
@@ -524,7 +520,7 @@ class Manager extends EventEmitter {
       ? data
       : { value: data }
 
-    return this.stringify(result)
+    return stringify(result)
   }
 
   mapCompletionResponse (ids, result) {

src/timekeeper.js

@@ -2,6 +2,7 @@ const EventEmitter = require('events')
 const plans = require('./plans')
 const cronParser = require('cron-parser')
 const Attorney = require('./attorney')
+const pMap = require('p-map')
 
 const queues = {
   CRON: '__pgboss__cron',
@@ -125,8 +126,6 @@ class Timekeeper extends EventEmitter {
   async onCron () {
     if (this.stopped) return
 
-    const { default: pMap } = await import('p-map')
-
     try {
       if (this.config.__test__throw_clock_monitoring) {
         throw new Error('clock monitoring error')

test/failureTest.js

@@ -1,6 +1,7 @@
 const delay = require('delay')
 const assert = require('assert')
 const helper = require('./testHelper')
+const pMap = require('p-map')
 
 describe('failure', function () {
   it('should reject missing id argument', async function () {
@@ -60,8 +61,6 @@ describe('failure', function () {
   })
 
   it('should fail a batch of jobs with a data arg', async function () {
-    const { default: pMap } = await import('p-map')
-
     const boss = this.test.boss = await helper.start(this.test.bossConfig)
     const queue = this.test.bossConfig.schema
     const message = 'some error'

test/multiMasterTest.js

@@ -5,11 +5,10 @@ const PgBoss = require('../')
 const Contractor = require('../src/contractor')
 const migrationStore = require('../src/migrationStore')
 const currentSchemaVersion = require('../version.json').schema
+const pMap = require('p-map')
 
 describe('multi-master', function () {
   it('should only allow 1 master to start at a time', async function () {
-    const { default: pMap } = await import('p-map')
-
     const replicaCount = 20
     const config = { ...this.test.bossConfig, noSupervisor: true, max: 2 }
     const instances = []
@@ -28,8 +27,6 @@ describe('multi-master', function () {
   })
 
   it('should only allow 1 master to migrate to latest at a time', async function () {
-    const { default: pMap } = await import('p-map')
-
     const replicaCount = 5
     const config = { ...this.test.bossConfig, noSupervisor: true, max: 2 }
 

test/speedTest.js

@@ -1,4 +1,5 @@
 const helper = require('./testHelper')
+const pMap = require('p-map')
 
 describe('speed', function () {
   const expectedSeconds = 2
@@ -12,8 +13,6 @@ describe('speed', function () {
   let boss
 
   beforeEach(async function () {
-    const { default: pMap } = await import('p-map')
-
     const defaults = { noSupervisor: true, min: 10, max: 10 }
     boss = await helper.start({ ...this.currentTest.bossConfig, ...defaults })
     await pMap(jobs, job => boss.send(job.name, job.data))