feat: automatic reversion of repo

Author: AuHau

package.json

@@ -65,7 +65,7 @@
     "err-code": "^1.1.2",
     "interface-datastore": "~0.7.0",
     "ipfs-block": "~0.8.1",
-    "ipfs-repo-migrations": "ipfs/js-ipfs-repo-migrations#master",
+    "ipfs-repo-migrations": "github:ipfs/js-ipfs-repo-migrations#master",
     "just-safe-get": "^1.3.0",
     "just-safe-set": "^2.1.0",
     "lodash.has": "^4.5.2",

src/index.js

@@ -294,11 +294,12 @@ class IpfsRepo {
     const currentRepoVersion = await this.version.get()
 
     if (currentRepoVersion > toVersion) {
-      throw new ERRORS.InvalidRepoVersionError('Your repo\'s version is higher then this version of js-ipfs-repo require! You have to revert it.')
+      log('reverting to version ' + toVersion)
+      return migrator.revert(this.path, toVersion, { ignoreLock: true, repoOptions: this.options })
+    } else {
+      log('migrating to version ' + toVersion)
+      return migrator.migrate(this.path, toVersion, { ignoreLock: true, repoOptions: this.options })
     }
-
-    log('migrating to version ' + toVersion)
-    return migrator.migrate(this.path, { toVersion: toVersion, ignoreLock: true, repoOptions: this.options })
   }
 
   async _storageMaxStat () {

test/migrations-test.js

@@ -17,18 +17,21 @@ module.exports = (createTempRepo) => {
   describe('Migrations tests', () => {
     let repo
     let migrateStub
+    let revertStub
     let repoVersionStub
     let getLatestMigrationVersionStub
 
     before(() => {
       repoVersionStub = sinon.stub(constants, 'repoVersion')
       migrateStub = sinon.stub(migrator, 'migrate')
+      revertStub = sinon.stub(migrator, 'revert')
       getLatestMigrationVersionStub = sinon.stub(migrator, 'getLatestMigrationVersion')
     })
 
     after(() => {
       repoVersionStub.restore()
       migrateStub.restore()
+      revertStub.restore()
       getLatestMigrationVersionStub.restore()
     })
 
@@ -67,9 +70,9 @@ module.exports = (createTempRepo) => {
       expect(migrateStub.called).to.be.false()
       try {
         await newRepo.open()
-        throw Error('Should throw error')
-      } catch (e) {
-        expect(e.code).to.equal(errors.InvalidRepoVersionError.code)
+        expect.fail('should have thrown error')
+      } catch (err) {
+        expect(err.code).to.equal(errors.InvalidRepoVersionError.code)
       }
 
       expect(migrateStub.called).to.be.false()
@@ -87,10 +90,10 @@ module.exports = (createTempRepo) => {
       expect(migrateStub.called).to.be.false()
       try {
         await repo.open()
-        throw Error('Should throw error')
-      } catch (e) {
+        expect.fail('should have thrown error')
+      } catch (err) {
         expect(migrateStub.called).to.be.false()
-        expect(e.code).to.equal(errors.InvalidRepoVersionError.code)
+        expect(err.code).to.equal(errors.InvalidRepoVersionError.code)
       }
     })
 
@@ -108,23 +111,21 @@ module.exports = (createTempRepo) => {
       expect(migrateStub.called).to.be.false()
     })
 
-    it('should not migrate when current repo versions is higher then expected', async () => {
-      migrateStub.resolves()
+    it('should revert when current repo versions is higher then expected', async () => {
+      revertStub.resolves()
       repoVersionStub.value(8)
 
+      expect(revertStub.called).to.be.false()
+
       await repo.version.set(9)
       await repo.close()
 
       expect(migrateStub.called).to.be.false()
+      expect(revertStub.called).to.be.false()
 
-      try {
-        await repo.open()
-        throw Error('Should throw error')
-      } catch (e) {
-        expect(migrateStub.called).to.be.false()
-        expect(e.code).to.equal(errors.InvalidRepoVersionError.code)
-      }
+      await repo.open()
 
+      expect(revertStub.called).to.be.true()
       expect(migrateStub.called).to.be.false()
     })
   })