Adding parameter for options

License: MIT
Signed-off-by: Adam Uhlir <uhlir.a@gmail.com>

Author: AuHau

src/commands.js

@@ -30,12 +30,12 @@ function reportingClosure (action) {
 
 async function migrate ({ repoPath, ver, dry }) {
   repoPath = repoPath || process.env.IPFS_PATH || path.join(os.homedir(), '.jsipfs')
-  await migrator.migrate(repoPath, ver, false, reportingClosure(dry ? 'loaded migration' : 'migrated to version'), dry)
+  await migrator.migrate(repoPath, ver, false, undefined, reportingClosure(dry ? 'loaded migration' : 'migrated to version'), dry)
 }
 
 async function revert ({ repoPath, ver, dry }) {
   repoPath = repoPath || process.env.IPFS_PATH || path.join(os.homedir(), '.jsipfs')
-  await migrator.revert(repoPath, ver, false, reportingClosure(dry ? 'loaded migration' : 'reverted version'), dry)
+  await migrator.revert(repoPath, ver, false, undefined, reportingClosure(dry ? 'loaded migration' : 'reverted version'), dry)
 }
 
 async function status ({ repoPath }) {

src/index.js

@@ -39,12 +39,13 @@ exports.getLatestMigrationVersion = getLatestMigrationVersion
  * @param {string} path - Path to initialized (!) JS-IPFS repo
  * @param {int?} toVersion - Version to which the repo should be migrated, if undefined repo will be migrated to the latest version.
  * @param {boolean?} ignoreLock - Won't lock the repo for applying the migrations. Use with caution.
+ * @param {object?} options - Options that are passed to migrations, that can use them to correctly construct datastore. Options are same like for IPFSRepo.
  * @param {function?} progressCb - Callback which will be called after each executed migration to report progress
  * @param {boolean?} isDryRun - Allows to simulate the execution of the migrations without any effect.
  * @param {array?} migrations - Array of migrations to migrate. If undefined, the bundled migrations are used. Mainly for testing purpose.
  * @returns {Promise<void>}
  */
-async function migrate (path, toVersion, ignoreLock, progressCb, isDryRun, migrations) {
+async function migrate (path, toVersion, ignoreLock, options, progressCb, isDryRun, migrations) {
   migrations = migrations || defaultMigrations
 
   if (!path) {
@@ -89,7 +90,7 @@ async function migrate (path, toVersion, ignoreLock, progressCb, isDryRun, migra
       counter++
       log(`Migrating version ${migration.version}`)
       try {
-        if (!isDryRun) await migration.migrate(path, isBrowser)
+        if (!isDryRun) await migration.migrate(path, options, isBrowser)
       } catch (e) {
         e.message = `During migration to version ${migration.version} exception was raised: ${e.message}`
         throw e
@@ -116,12 +117,13 @@ exports.migrate = migrate
  * @param {string} path - Path to initialized (!) JS-IPFS repo
  * @param {int} toVersion - Version to which the repo will be reverted.
  * @param {function?} progressCb - Callback which will be called after each reverted migration to report progress
+ * @param {object?} options - Options that are passed to migrations, that can use them to correctly construct datastore. Options are same like for IPFSRepo.
  * @param {boolean?} isDryRun - Allows to simulate the execution of the reversion without any effects. Make sense to utilize progressCb with this argument.
  * @param {boolean?} ignoreLock - Won't lock the repo for reverting the migrations. Use with caution.
  * @param {array?} migrations - Array of migrations to migrate. If undefined, the bundled migrations are used. Mainly for testing purpose.
  * @returns {Promise<void>}
  */
-async function revert (path, toVersion, ignoreLock, progressCb, isDryRun, migrations) {
+async function revert (path, toVersion, ignoreLock, options, progressCb, isDryRun, migrations) {
   migrations = migrations || defaultMigrations
 
   if (!path) {
@@ -176,7 +178,7 @@ async function revert (path, toVersion, ignoreLock, progressCb, isDryRun, migrat
       counter++
       log(`Reverting migration version ${migration.version}`)
       try {
-        if (!isDryRun) await migration.revert(path, isBrowser)
+        if (!isDryRun) await migration.revert(path, options, isBrowser)
       } catch (e) {
         e.message = `During reversion to version ${migration.version} exception was raised: ${e.message}`
         throw e

test/index.spec.js

@@ -87,14 +87,14 @@ describe('index.js', () => {
     it('should error with out path argument', () => {
       const migrationsMock = createMigrations()
 
-      return expect(migrator.revert(undefined, undefined, undefined, undefined, undefined, migrationsMock))
+      return expect(migrator.revert(undefined, undefined, undefined, undefined, undefined, undefined, migrationsMock))
         .to.eventually.be.rejectedWith('Path argument is required!')
     })
 
     it('should error with out toVersion argument', () => {
       const migrationsMock = createMigrations()
 
-      return expect(migrator.revert('/some/path', undefined, undefined, undefined, undefined, migrationsMock))
+      return expect(migrator.revert('/some/path', undefined, undefined, undefined, undefined, undefined, migrationsMock))
         .to.eventually.be.rejectedWith('When reverting migrations, you have to specify to which version to revert!')
     })
 
@@ -103,7 +103,7 @@ describe('index.js', () => {
       const migrationsMock = createMigrations()
 
       return Promise.all(
-        invalidValues.map((value) => expect(migrator.revert('/some/path', value, undefined, undefined, undefined, migrationsMock))
+        invalidValues.map((value) => expect(migrator.revert('/some/path', value, undefined, undefined, undefined, undefined, migrationsMock))
           .to.eventually.be.rejectedWith('Version has to be positive integer!'))
       )
     })
@@ -112,7 +112,7 @@ describe('index.js', () => {
       getVersionStub.returns(2)
       const migrationsMock = createMigrations()
 
-      await expect(migrator.revert('/some/path', 2, undefined, undefined, undefined, migrationsMock))
+      await expect(migrator.revert('/some/path', 2, undefined, undefined, undefined, undefined, migrationsMock))
         .to.eventually.be.fulfilled()
 
       expect(lockStub.called).to.be.false()
@@ -122,7 +122,7 @@ describe('index.js', () => {
       getVersionStub.returns(2)
       const migrationsMock = createMigrations()
 
-      await expect(migrator.revert('/some/path', 3, undefined, undefined, undefined, migrationsMock))
+      await expect(migrator.revert('/some/path', 3, undefined, undefined, undefined, undefined, migrationsMock))
         .to.eventually.be.fulfilled()
 
       expect(lockStub.called).to.be.false()
@@ -134,15 +134,15 @@ describe('index.js', () => {
 
       getVersionStub.returns(4)
       return expect(
-        migrator.revert('/some/path', 1, undefined, undefined, undefined, nonReversibleMigrationsMock)
+        migrator.revert('/some/path', 1, undefined, undefined, undefined, undefined, nonReversibleMigrationsMock)
       ).to.eventually.be.rejectedWith('Migration version 3 is not possible to revert! Cancelling reversion.')
     })
 
     it('should revert expected migrations', async () => {
       const migrationsMock = createMigrations()
       getVersionStub.returns(3)
 
-      await expect(migrator.revert('/some/path', 1, undefined, undefined, undefined, migrationsMock))
+      await expect(migrator.revert('/some/path', 1, undefined, undefined, undefined, undefined, migrationsMock))
         .to.eventually.be.fulfilled()
 
       expect(lockCloseStub.calledOnce).to.be.true()
@@ -160,7 +160,7 @@ describe('index.js', () => {
       const migrationsMock = createMigrations()
       getVersionStub.returns(2)
 
-      await expect(migrator.revert('/some/path', 1, undefined, undefined, undefined, migrationsMock))
+      await expect(migrator.revert('/some/path', 1, undefined, undefined, undefined, undefined, migrationsMock))
         .to.eventually.be.fulfilled()
 
       expect(lockCloseStub.calledOnce).to.be.true()
@@ -185,7 +185,7 @@ describe('index.js', () => {
       ]
       getVersionStub.returns(2)
 
-      await expect(migrator.revert('/some/path', 1, undefined, undefined, undefined, migrationsMock))
+      await expect(migrator.revert('/some/path', 1, undefined, undefined, undefined, undefined, migrationsMock))
         .to.eventually.be.fulfilled()
 
       expect(lockCloseStub.calledOnce).to.be.true()
@@ -200,7 +200,7 @@ describe('index.js', () => {
       const migrationsMock = createMigrations()
       getVersionStub.returns(4)
 
-      await expect(migrator.revert('/some/path', 2, undefined, undefined, true, migrationsMock))
+      await expect(migrator.revert('/some/path', 2, undefined, undefined, undefined, true, migrationsMock))
         .to.eventually.be.fulfilled()
 
       expect(lockCloseStub.called).to.be.false()
@@ -214,7 +214,7 @@ describe('index.js', () => {
       const migrationsMock = createMigrations()
       getVersionStub.returns(4)
 
-      await expect(migrator.revert('/some/path', 2, true, undefined, undefined, migrationsMock))
+      await expect(migrator.revert('/some/path', 2, true, undefined, undefined, undefined, migrationsMock))
         .to.eventually.be.fulfilled()
 
       expect(lockCloseStub.called).to.be.false()
@@ -233,7 +233,7 @@ describe('index.js', () => {
       getVersionStub.returns(4)
       const progressCb = sinon.stub()
 
-      await expect(migrator.revert('/some/path', 2, undefined, progressCb, undefined, migrationsMock))
+      await expect(migrator.revert('/some/path', 2, undefined, undefined, progressCb,  undefined, migrationsMock))
         .to.eventually.be.fulfilled()
 
       expect(progressCb.getCall(0).calledWith(sinon.match.any, 1, 2)).to.be.true()
@@ -245,7 +245,7 @@ describe('index.js', () => {
       const migrationsMock = createMigrations()
       migrationsMock[3].revert = sinon.stub().rejects()
 
-      await expect(migrator.revert('/some/path', 2, undefined, undefined, undefined, migrationsMock))
+      await expect(migrator.revert('/some/path', 2, undefined, undefined, undefined, undefined, migrationsMock))
         .to.eventually.be.rejected()
 
       expect(lockCloseStub.calledOnce).to.be.true()
@@ -258,7 +258,7 @@ describe('index.js', () => {
     it('should error with out path argument', () => {
       const migrationsMock = createMigrations()
 
-      return expect(migrator.migrate(undefined, undefined, undefined, undefined, undefined, migrationsMock))
+      return expect(migrator.migrate(undefined, undefined, undefined, undefined, undefined, undefined, migrationsMock))
         .to.eventually.be.rejectedWith('Path argument is required!')
     })
 
@@ -267,7 +267,7 @@ describe('index.js', () => {
       const migrationsMock = createMigrations()
 
       return Promise.all(
-        invalidValues.map((value) => expect(migrator.migrate('/some/path', value, undefined, undefined, undefined, migrationsMock))
+        invalidValues.map((value) => expect(migrator.migrate('/some/path', value, undefined, undefined, undefined, undefined, migrationsMock))
           .to.eventually.be.rejectedWith('Version has to be positive integer!'))
       )
     })
@@ -276,7 +276,7 @@ describe('index.js', () => {
       const migrationsMock = createMigrations()
       getVersionStub.returns(2)
 
-      await expect(migrator.migrate('/some/path', undefined, undefined, undefined, undefined, migrationsMock))
+      await expect(migrator.migrate('/some/path', undefined, undefined, undefined, undefined, undefined, migrationsMock))
         .to.eventually.be.fulfilled()
 
       setVersionStub.calledOnceWithExactly('/some/path', 4) // 4 is the latest migration's version
@@ -286,7 +286,7 @@ describe('index.js', () => {
       getVersionStub.returns(2)
       const migrationsMock = createMigrations()
 
-      await expect(migrator.migrate('/some/path', 2, undefined, undefined, undefined, migrationsMock))
+      await expect(migrator.migrate('/some/path', 2, undefined, undefined, undefined, undefined, migrationsMock))
         .to.eventually.be.fulfilled()
 
       expect(lockStub.called).to.be.false()
@@ -296,7 +296,7 @@ describe('index.js', () => {
       getVersionStub.returns(3)
       const migrationsMock = createMigrations()
 
-      await expect(migrator.migrate('/some/path', 2, undefined, undefined, undefined, migrationsMock))
+      await expect(migrator.migrate('/some/path', 2, undefined, undefined, undefined, undefined, migrationsMock))
         .to.eventually.be.fulfilled()
 
       expect(lockStub.called).to.be.false()
@@ -306,7 +306,7 @@ describe('index.js', () => {
       const migrationsMock = createMigrations()
       getVersionStub.returns(1)
 
-      await expect(migrator.migrate('/some/path', 3, undefined, undefined, undefined, migrationsMock))
+      await expect(migrator.migrate('/some/path', 3, undefined, undefined, undefined, undefined, migrationsMock))
         .to.eventually.be.fulfilled()
 
       expect(lockCloseStub.calledOnce).to.be.true()
@@ -324,7 +324,7 @@ describe('index.js', () => {
       const migrationsMock = createMigrations()
       getVersionStub.returns(2)
 
-      await expect(migrator.migrate('/some/path', 4, undefined, undefined, true, migrationsMock))
+      await expect(migrator.migrate('/some/path', 4, undefined, undefined, undefined, true, migrationsMock))
         .to.eventually.be.fulfilled()
 
       expect(lockCloseStub.called).to.be.false()
@@ -338,7 +338,7 @@ describe('index.js', () => {
       const migrationsMock = createMigrations()
       getVersionStub.returns(2)
 
-      await expect(migrator.migrate('/some/path', 4, true, undefined, undefined, migrationsMock))
+      await expect(migrator.migrate('/some/path', 4, true, undefined, undefined, undefined, migrationsMock))
         .to.eventually.be.fulfilled()
 
       expect(lockCloseStub.called).to.be.false()
@@ -357,7 +357,7 @@ describe('index.js', () => {
       getVersionStub.returns(2)
       const progressCb = sinon.stub()
 
-      await expect(migrator.migrate('/some/path', 4, undefined, progressCb, undefined, migrationsMock))
+      await expect(migrator.migrate('/some/path', 4, undefined, undefined, progressCb, undefined, migrationsMock))
         .to.eventually.be.fulfilled()
 
       expect(progressCb.getCall(0).calledWith(sinon.match.any, 1, 2)).to.be.true()
@@ -369,7 +369,7 @@ describe('index.js', () => {
       const migrationsMock = createMigrations()
       migrationsMock[3].migrate = sinon.stub().rejects()
 
-      await expect(migrator.migrate('/some/path', 4, undefined, undefined, undefined, migrationsMock))
+      await expect(migrator.migrate('/some/path', 4, undefined, undefined, undefined, undefined, migrationsMock))
         .to.eventually.be.rejected()
 
       expect(lockCloseStub.calledOnce).to.be.true()