Linting

License: MIT
Signed-off-by: Adam Uhlir <[email protected]>

Author: AuHau

src/cli.js

@@ -9,8 +9,7 @@ const log = require('debug')('js-ipfs-repo-migrations:cli')
 
 const commands = require('./commands')
 
-
-function print(msg, newline) {
+function print (msg, newline) {
   if (newline === undefined) {
     newline = true
   }
@@ -22,11 +21,11 @@ function print(msg, newline) {
   process.stdout.write(msg)
 }
 
-async function main(args) {
+async function main (args) {
   const cli = yargs()
     .option('repo-path', {
       desc: 'Path to the IPFS repo',
-      type: 'string',
+      type: 'string'
     })
     .command(commands.migrate)
     .command(commands.revert)
@@ -49,7 +48,7 @@ async function main(args) {
   let exitCode = 0
 
   try {
-    const {data} = await new YargsPromise(cli).parse(args)
+    const { data } = await new YargsPromise(cli).parse(args)
     if (data) print(data)
   } catch (err) {
     log(err)

src/commands.js

@@ -4,11 +4,11 @@ const os = require('os')
 const path = require('path')
 const fs = require('fs')
 const process = require('process')
-const util = require('util');
+const util = require('util')
 
 const writeFile = util.promisify(fs.writeFile)
 const mkdir = util.promisify(fs.mkdir)
-const exec = util.promisify(require('child_process').exec);
+const exec = util.promisify(require('child_process').exec)
 
 const chalk = require('chalk')
 
@@ -17,28 +17,28 @@ const migrator = require('./index')
 const templates = require('./migration-templates')
 const migrations = require('../migrations')
 
-function asyncClosure(fnc) {
-  return function asyncWrapper({resolve, ...options}) {
+function asyncClosure (fnc) {
+  return function asyncWrapper ({ resolve, ...options }) {
     resolve(fnc(options))
   }
 }
 
-function reportingClosure(action) {
+function reportingClosure (action) {
   return (migration, currentlyMigrated, totalToMigrate) =>
     process.stdout.write(`${chalk.green(`[${currentlyMigrated}/${totalToMigrate}]`)} Successfully ${action} ${chalk.bold(migration.version)}: ${migration.description}\n`)
 }
 
-async function migrate({repoPath, ver, dry}) {
+async function migrate ({ repoPath, ver, dry }) {
   repoPath = repoPath || process.env.IPFS_PATH || path.join(os.homedir(), '.jsipfs')
   await migrator.migrate(repoPath, ver, reportingClosure(dry ? 'loaded migration' : 'migrated to version'), dry)
 }
 
-async function revert({repoPath, ver, dry}) {
+async function revert ({ repoPath, ver, dry }) {
   repoPath = repoPath || process.env.IPFS_PATH || path.join(os.homedir(), '.jsipfs')
   await migrator.revert(repoPath, ver, reportingClosure(dry ? 'loaded migration' : 'reverted to version'), dry)
 }
 
-async function status({repoPath}) {
+async function status ({ repoPath }) {
   repoPath = repoPath || process.env.IPFS_PATH || path.join(os.homedir(), '.jsipfs')
 
   const version = await repoVersion.getVersion(repoPath)
@@ -49,17 +49,17 @@ async function status({repoPath}) {
   return `${statusString}\nCurrent repo version: ${version}\nLast migration's version: ${lastMigrationVersion}`
 }
 
-async function getAuthor() {
+async function getAuthor () {
   try {
-    const name = (await exec('git config --get user.name'))['stdout']
-    const email = (await exec('git config --get user.email'))['stdout']
+    const name = (await exec('git config --get user.name')).stdout
+    const email = (await exec('git config --get user.email')).stdout
     return `${name.replace('\n', '')} <${email.replace('\n', '')}>`
   } catch (e) {
     return ''
   }
 }
 
-async function add({repoPath, empty}) {
+async function add ({ repoPath, empty }) {
   const newMigrationVersion = migrator.getLatestMigrationVersion() + 1
   const newMigrationFolder = path.join(__dirname, '..', 'migrations', 'migration-' + newMigrationVersion)
 
@@ -71,7 +71,7 @@ async function add({repoPath, empty}) {
   }
   const migrationsIndexJsContent = templates.migrationsIndexJs
     .replace('{{imports}}', migrationsImport.join('\n'))
-  ;await writeFile(path.join(newMigrationFolder, '..', 'index.js'), migrationsIndexJsContent)
+  await writeFile(path.join(newMigrationFolder, '..', 'index.js'), migrationsIndexJsContent)
 
   if (empty) return
 
@@ -80,11 +80,11 @@ async function add({repoPath, empty}) {
   const packageJsonContent = templates.packageJson
     .replace(/{{version}}/gi, newMigrationVersion)
     .replace(/{{author}}/gi, await getAuthor())
-  ;await writeFile(path.join(newMigrationFolder, 'package.json'), packageJsonContent)
+  await writeFile(path.join(newMigrationFolder, 'package.json'), packageJsonContent)
 
   const indexJsContent = templates.indexJs
     .replace(/{{version}}/gi, newMigrationVersion)
-  ;await writeFile(path.join(newMigrationFolder, 'index.js'), indexJsContent)
+  await writeFile(path.join(newMigrationFolder, 'index.js'), indexJsContent)
 }
 
 module.exports = {
@@ -114,12 +114,12 @@ module.exports = {
       .positional('ver', {
         describe: 'version to revert to (inclusive)',
         type: 'number'
-      }),
+      })
   },
   status: {
     command: 'status',
     describe: 'Display status of IPFS repo',
-    handler: asyncClosure(status),
+    handler: asyncClosure(status)
   },
   add: {
     command: 'add',
@@ -130,5 +130,5 @@ module.exports = {
         describe: 'Creates empty migration',
         type: 'boolean'
       })
-  },
+  }
 }

src/index.js

@@ -9,15 +9,15 @@ const debug = require('debug')
 
 const log = debug('js-ipfs-repo-migrations:migrator')
 
-
 /**
  * Returns the version of latest migration.
  *
  * @returns {int}
  */
-function getLatestMigrationVersion() {
+function getLatestMigrationVersion () {
   return migrations[migrations.length - 1].version
 }
+
 exports.getLatestMigrationVersion = getLatestMigrationVersion
 
 /**
@@ -32,7 +32,7 @@ exports.getLatestMigrationVersion = getLatestMigrationVersion
  * @param {boolean|undefined} isDryRun - Allows to simulate the execution of the migrations without any effect.
  * @returns {Promise<void>}
  */
-async function migrate(path, toVersion, progressCb, isDryRun) {
+async function migrate (path, toVersion, progressCb, isDryRun) {
   if (toVersion && (!Number.isInteger(toVersion) || toVersion <= 0)) {
     throw new Error('Version has to be positive integer!')
   }
@@ -47,7 +47,8 @@ async function migrate(path, toVersion, progressCb, isDryRun) {
     log('Nothing to migrate, skipping migrations.')
     return
   }
-  let counter = 0, totalMigrations = toVersion - currentVersion
+  let counter = 0
+  let totalMigrations = toVersion - currentVersion
   for (let migration of migrations) {
     if (toVersion !== undefined && migration.version > toVersion) {
       break
@@ -74,6 +75,7 @@ async function migrate(path, toVersion, progressCb, isDryRun) {
 
   if (!isDryRun) await lock.close()
 }
+
 exports.migrate = migrate
 
 /**
@@ -88,7 +90,7 @@ exports.migrate = migrate
  * @param {boolean|undefined} isDryRun - Allows to simulate the execution of the reversion without any effect.
  * @returns {Promise<void>}
  */
-async function revert(path, toVersion, progressCb, isDryRun) {
+async function revert (path, toVersion, progressCb, isDryRun) {
   if (!toVersion) {
     throw new Error('When reverting migrations, you have to specify to which version to revert!')
   }
@@ -103,14 +105,15 @@ async function revert(path, toVersion, progressCb, isDryRun) {
     return
   }
 
-  let {reversible, problematicMigration} = verifyReversibility(currentVersion, toVersion)
+  let { reversible, problematicMigration } = verifyReversibility(currentVersion, toVersion)
   if (!reversible) {
     throw new errors.NonReversibleMigration(`Migration version ${problematicMigration} is not possible to revert! Cancelling reversion.`)
   }
 
   let lock
   if (!isDryRun) lock = await repoLock.lock(currentVersion, path)
-  let counter = 0, totalMigrations = currentVersion - toVersion
+  let counter = 0
+  let totalMigrations = currentVersion - toVersion
   const reversedMigrationArray = migrations.reverse()
   for (let migration of reversedMigrationArray) {
     if (migration.version <= toVersion) {
@@ -138,6 +141,7 @@ async function revert(path, toVersion, progressCb, isDryRun) {
 
   if (!isDryRun) await lock.close()
 }
+
 exports.revert = revert
 
 /**
@@ -147,17 +151,17 @@ exports.revert = revert
  * @param {int} toVersion
  * @returns {object}
  */
-function verifyReversibility(fromVersion, toVersion) {
+function verifyReversibility (fromVersion, toVersion) {
   const reversedMigrationArray = migrations.reverse()
   for (let migration of reversedMigrationArray) {
     if (migration.version <= toVersion) {
       break
     }
 
     if (migration.version <= fromVersion && !migration.reversible) {
-      return {reversible: false, version: migration.version}
+      return { reversible: false, version: migration.version }
     }
   }
 
-  return {reversible: true, version: undefined}
+  return { reversible: true, version: undefined }
 }

src/option-browser.js

@@ -1,2 +1,2 @@
 'use strict'
-exports = true
+module.exports = true

src/option-node.js

@@ -1,2 +1,2 @@
 'use strict'
-exports = false
+module.exports = false

src/repo/lock-memory.js

@@ -14,7 +14,7 @@ const LOCKS = {}
  * @param {string} dir
  * @returns {Promise<Object>}
  */
-exports.lock = async function lock(version, dir) {
+exports.lock = async function lock (version, dir) {
   const file = dir + '/' + lockFile
   log('locking %s', file)
 
@@ -24,7 +24,7 @@ exports.lock = async function lock(version, dir) {
 
   LOCKS[file] = true
   return {
-    close() {
+    close () {
       if (LOCKS[file]) {
         log('releasing lock %s', file)
         delete LOCKS[file]

src/repo/lock.js

@@ -26,7 +26,6 @@ const STALE_TIME = 20000
  * @returns {Promise<Object>}
  */
 exports.lock = async (version, dir) => {
-
   const file = path.join(dir, lockFile)
   log('locking %s', file)
   const release = await lock(dir, { lockfilePath: file, stale: STALE_TIME })

src/repo/version.js

@@ -17,8 +17,8 @@ exports.getVersion = getVersion
  * @param {string} path
  * @returns {Promise<int>}
  */
-async function getVersion(path) {
-  const store = new Datastore(path, {extension: '', createIfMissing: false})
+async function getVersion (path) {
+  const store = new Datastore(path, { extension: '', createIfMissing: false })
   await store.open()
 
   if (!await store.has(versionKey)) {
@@ -38,8 +38,8 @@ async function getVersion(path) {
  * @param {int} version
  * @returns {Promise<void>}
  */
-async function setVersion(path, version) {
-  const store = new Datastore(path, {extension: '', createIfMissing: false})
+async function setVersion (path, version) {
+  const store = new Datastore(path, { extension: '', createIfMissing: false })
   await store.open()
   await store.put(versionKey, Buffer.from(String(version)))
   await store.close()