Merge branch 'master' of github.com:timgit/pg-boss

package.json

@@ -1,6 +1,6 @@
 {
   "name": "pg-boss",
-  "version": "10.0.5",
+  "version": "10.0.6",
   "description": "Queueing jobs in Postgres from Node.js like a boss",
   "main": "./src/index.js",
   "engines": {

src/contractor.js

@@ -46,8 +46,7 @@ class Contractor {
       const version = await this.schemaVersion()
 
       if (schemaVersion > version) {
-        throw new Error('Migrations are not supported to v10')
-        // await this.migrate(version)
+        await this.migrate(version)
       }
     } else {
       await this.create()
@@ -86,15 +85,15 @@ class Contractor {
     }
   }
 
-  // async next (version) {
-  //   const commands = migrationStore.next(this.config.schema, version, this.migrations)
-  //   await this.db.executeSql(commands)
-  // }
+  async next (version) {
+    const commands = migrationStore.next(this.config.schema, version, this.migrations)
+    await this.db.executeSql(commands)
+  }
 
-  // async rollback (version) {
-  //   const commands = migrationStore.rollback(this.config.schema, version, this.migrations)
-  //   await this.db.executeSql(commands)
-  // }
+  async rollback (version) {
+    const commands = migrationStore.rollback(this.config.schema, version, this.migrations)
+    await this.db.executeSql(commands)
+  }
 }
 
 module.exports = Contractor

src/migrationStore.js

@@ -64,5 +64,16 @@ function migrate (value, version, migrations) {
 
 function getAll (schema) {
   return [
+    {
+      release: '10.0.6',
+      version: 22,
+      previous: 21,
+      install: [
+        `ALTER TABLE ${schema}.job ALTER COLUMN retry_limit SET DEFAULT 2`
+      ],
+      uninstall: [
+        `ALTER TABLE ${schema}.job ALTER COLUMN retry_limit SET DEFAULT 0`
+      ]
+    }
   ]
 }

src/plans.js

@@ -179,7 +179,7 @@ function createTableJob (schema) {
       priority integer not null default(0),
       data jsonb,
       state ${schema}.job_state not null default('${JOB_STATES.created}'),
-      retry_limit integer not null default(0),
+      retry_limit integer not null default(2),
       retry_count integer not null default(0),
       retry_delay integer not null default(0),
       retry_backoff boolean not null default false,

test/migrationTest.js

@@ -32,23 +32,39 @@ describe('migration', function () {
     }
   })
 
-  it.skip('should migrate to previous version and back again', async function () {
+  it('should migrate to previous version and back again', async function () {
     const { contractor } = this.test
 
     await contractor.create()
 
     await contractor.rollback(currentSchemaVersion)
-    const oldVersion = await contractor.version()
+    const oldVersion = await contractor.schemaVersion()
 
     assert.notStrictEqual(oldVersion, currentSchemaVersion)
 
     await contractor.migrate(oldVersion)
-    const newVersion = await contractor.version()
+    const newVersion = await contractor.schemaVersion()
 
     assert.strictEqual(newVersion, currentSchemaVersion)
   })
 
-  it.skip('should migrate to latest during start if on previous schema version', async function () {
+  it('should install next version via contractor', async function () {
+    const { contractor } = this.test
+
+    await contractor.create()
+
+    await contractor.rollback(currentSchemaVersion)
+
+    const oneVersionAgo = await contractor.schemaVersion()
+
+    await contractor.next(oneVersionAgo)
+
+    const version = await contractor.schemaVersion()
+
+    assert.strictEqual(version, currentSchemaVersion)
+  })
+
+  it('should migrate to latest during start if on previous schema version', async function () {
     const { contractor } = this.test
 
     await contractor.create()
@@ -61,7 +77,7 @@ describe('migration', function () {
 
     await boss.start()
 
-    const version = await contractor.version()
+    const version = await contractor.schemaVersion()
 
     assert.strictEqual(version, currentSchemaVersion)
   })
@@ -88,22 +104,22 @@ describe('migration', function () {
     await boss.send(queue)
 
     await contractor.rollback(currentSchemaVersion)
-    const oneVersionAgo = await contractor.version()
+    const oneVersionAgo = await contractor.schemaVersion()
 
     assert.notStrictEqual(oneVersionAgo, currentSchemaVersion)
 
     await contractor.rollback(oneVersionAgo)
-    const twoVersionsAgo = await contractor.version()
+    const twoVersionsAgo = await contractor.schemaVersion()
 
     assert.notStrictEqual(twoVersionsAgo, oneVersionAgo)
 
     await contractor.next(twoVersionsAgo)
-    const oneVersionAgoPart2 = await contractor.version()
+    const oneVersionAgoPart2 = await contractor.schemaVersion()
 
     assert.strictEqual(oneVersionAgo, oneVersionAgoPart2)
 
     await contractor.next(oneVersionAgo)
-    const version = await contractor.version()
+    const version = await contractor.schemaVersion()
 
     assert.strictEqual(version, currentSchemaVersion)
 
@@ -118,18 +134,18 @@ describe('migration', function () {
     await contractor.create()
 
     await contractor.rollback(currentSchemaVersion)
-    const oneVersionAgo = await contractor.version()
+    const oneVersionAgo = await contractor.schemaVersion()
     assert.strictEqual(oneVersionAgo, currentSchemaVersion - 1)
 
     await contractor.rollback(oneVersionAgo)
-    const twoVersionsAgo = await contractor.version()
+    const twoVersionsAgo = await contractor.schemaVersion()
     assert.strictEqual(twoVersionsAgo, currentSchemaVersion - 2)
 
     const config = { ...this.test.bossConfig }
     const boss = this.test.boss = new PgBoss(config)
     await boss.start()
 
-    const version = await contractor.version()
+    const version = await contractor.schemaVersion()
 
     assert.strictEqual(version, currentSchemaVersion)
   })
@@ -146,7 +162,7 @@ describe('migration', function () {
     }
   })
 
-  it.skip('should roll back an error during a migration', async function () {
+  it('should roll back an error during a migration', async function () {
     const { contractor } = this.test
 
     const config = { ...this.test.bossConfig }
@@ -158,7 +174,7 @@ describe('migration', function () {
 
     await contractor.create()
     await contractor.rollback(currentSchemaVersion)
-    const oneVersionAgo = await contractor.version()
+    const oneVersionAgo = await contractor.schemaVersion()
 
     const boss1 = new PgBoss(config)
 
@@ -170,7 +186,7 @@ describe('migration', function () {
       await boss1.stop({ graceful: false, wait: false })
     }
 
-    const version1 = await contractor.version()
+    const version1 = await contractor.schemaVersion()
 
     assert.strictEqual(version1, oneVersionAgo)
 
@@ -181,7 +197,7 @@ describe('migration', function () {
 
     await boss2.start()
 
-    const version2 = await contractor.version()
+    const version2 = await contractor.schemaVersion()
 
     assert.strictEqual(version2, currentSchemaVersion)
 
@@ -199,7 +215,7 @@ describe('migration', function () {
     }
   })
 
-  it.skip('should not migrate if migrate option is false', async function () {
+  it('should not migrate if migrate option is false', async function () {
     const { contractor } = this.test
 
     await contractor.create()

test/multiMasterTest.js

@@ -39,7 +39,7 @@ describe('multi-master', function () {
 
     await contractor.rollback(currentSchemaVersion)
 
-    const oldVersion = await contractor.version()
+    const oldVersion = await contractor.schemaVersion()
 
     assert.notStrictEqual(oldVersion, currentSchemaVersion)
 

version.json

@@ -1,3 +1,3 @@
 {
-  "schema": 21
+  "schema": 22
 }