refactor: Switch to esm setup

contributes to #546

Author: boredland

.gitignore

@@ -3,4 +3,5 @@ node_modules
 .vscode
 *.tgz
 *.log
-coverage
+coverage
+dist

.nvmrc

@@ -0,0 +1 @@
+22

examples/load/index.js

@@ -5,14 +5,15 @@ const PgBoss = require('../../src')
 const SCHEMA_COUNT = 60
 const QUEUE_COUNT = 200
 
-loadTest()
-  .catch(err => {
-    console.log(err)
-    process.exit(1)
-  })
+loadTest().catch((err) => {
+  console.log(err)
+  process.exit(1)
+})
 
 async function loadTest () {
-  const schemas = new Array(SCHEMA_COUNT).fill(null).map((_, index) => `schema${index}`)
+  const schemas = new Array(SCHEMA_COUNT)
+    .fill(null)
+    .map((_, index) => `schema${index}`)
 
   for (const schema of schemas) {
     setImmediate(() => init(schema))
@@ -21,31 +22,40 @@ async function loadTest () {
 
 async function init (schema) {
   const config = helper.getConfig()
-  const boss = new PgBoss({ ...config, schema, supervise: false, schedule: false })
+  const boss = new PgBoss({
+    ...config,
+    schema,
+    supervise: false,
+    schedule: false
+  })
 
   boss.on('error', console.error)
 
   await boss.start()
 
   console.log('creating queues')
 
-  const queues = new Array(QUEUE_COUNT).fill(null).map((_, index) => `queue${index}`)
+  const queues = new Array(QUEUE_COUNT)
+    .fill(null)
+    .map((_, index) => `queue${index}`)
 
   for (const queue of queues) {
     console.log(`creating queue ${schema}.${queue}`)
     await boss.createQueue(queue)
-    await boss.work(queue, () => {})
+    await boss.work(queue, () => { })
   }
 
   console.log('created queues')
 
   while (true) {
     console.log(`${schema}: sending a job to each one: ${new Date()}`)
 
-    await Promise.all(queues.map(async queue => {
-      await boss.send(queue)
-      await boss.fetch(queue)
-    }))
+    await Promise.all(
+      queues.map(async (queue) => {
+        await boss.send(queue)
+        await boss.fetch(queue)
+      })
+    )
 
     await delay(1000)
   }

examples/readme.js

@@ -1,8 +1,8 @@
-const helper = require('../test/testHelper')
+import { getConnectionString } from '../test/testHelper.js'
+import PgBoss from '../src/index.js'
 
 async function readme () {
-  const PgBoss = require('../src')
-  const boss = new PgBoss(helper.getConnectionString())
+  const boss = new PgBoss(getConnectionString())
 
   boss.on('error', console.error)
 
@@ -21,8 +21,7 @@ async function readme () {
   })
 }
 
-readme()
-  .catch(err => {
-    console.log(err)
-    process.exit(1)
-  })
+readme().catch((err) => {
+  console.log(err)
+  process.exit(1)
+})

examples/schedule.js

@@ -15,12 +15,13 @@ async function schedule () {
   await boss.schedule(queue, '*/2 * * * *', { arg1: 'schedule me' })
 
   await boss.work(queue, async ([job]) => {
-    console.log(`received job ${job.id} with data ${JSON.stringify(job.data)} on ${new Date().toISOString()}`)
+    console.log(
+      `received job ${job.id} with data ${JSON.stringify(job.data)} on ${new Date().toISOString()}`
+    )
   })
 }
 
-schedule()
-  .catch(err => {
-    console.log(err)
-    process.exit(1)
-  })
+schedule().catch((err) => {
+  console.log(err)
+  process.exit(1)
+})