fix: fix lock for node 11

Author: hugomrdias

package.json

@@ -59,11 +59,11 @@
     "debug": "^4.1.0",
     "interface-datastore": "~0.6.0",
     "ipfs-block": "~0.7.1",
-    "lock-me": "^1.0.4",
     "lodash.get": "^4.4.2",
     "lodash.has": "^4.5.2",
     "lodash.set": "^4.3.2",
     "multiaddr": "^5.0.0",
+    "proper-lockfile": "^3.2.0",
     "pull-stream": "^3.6.9",
     "sort-keys": "^2.0.0"
   },

src/lock.js

@@ -1,14 +1,13 @@
 'use strict'
 
-const Lock = require('lock-me')
 const path = require('path')
 const debug = require('debug')
 const fs = require('fs')
+const { lock, check } = require('proper-lockfile')
 
 const log = debug('repo:lock')
 
 const lockFile = 'repo.lock'
-const lock = new Lock()
 
 /**
  * Lock the repo in the given dir.
@@ -20,7 +19,16 @@ const lock = new Lock()
 exports.lock = (dir, callback) => {
   const file = path.join(dir, lockFile)
   log('locking %s', file)
-  lock(file, callback)
+
+  lock(dir, {lockfilePath: file})
+    .then(release => {
+      callback(null, {close: (cb) => {
+        release()
+          .then(() => cb())
+          .catch(err => cb(err))
+      }})
+    })
+    .catch(err => callback(err))
 }
 
 /**
@@ -38,18 +46,12 @@ exports.locked = (dir, callback) => {
     log('file does not exist: %s', file)
   }
 
-  lock(file, (err, lck) => {
-    if (err) {
-      log('already locked: %s', err.message)
-      return callback(null, true)
-    }
-
-    log('no one has a lock')
-    lck.close((err) => {
-      if (err) {
-        return callback(err)
+  check(dir, { lockfilePath: file })
+    .then(islocked => {
+      if (islocked) {
+        return callback(null, true)
       }
       callback(null, false)
     })
-  })
+    .catch(err => callback(err))
 }

test/lock-test.js

@@ -32,7 +32,7 @@ module.exports = (repo) => {
       const mochaExceptionHandler = process.listeners('uncaughtException').pop()
       process.removeListener('uncaughtException', mochaExceptionHandler)
       process.once('uncaughtException', function (err) {
-        expect(err.message).to.match(/already held|IO error/)
+        expect(err.message).to.match(/already held|IO error|already being hold/)
       })
 
       series([
@@ -49,7 +49,7 @@ module.exports = (repo) => {
       ], function (err) {
         // There will be no listeners if the uncaughtException was triggered
         if (process.listeners('uncaughtException').length > 0) {
-          expect(err.message).to.match(/already locked|already held|ENOENT/)
+          expect(err.message).to.match(/already locked|already held|already being hold|ELOCKED/)
         }
 
         // Reset listeners to maintain test integrity

test/node.js

@@ -43,29 +43,34 @@ describe('IPFS Repo Tests onNode.js', () => {
     }
   }
 
-  const repos = [{
-    name: 'default inited',
-    opts: undefined,
-    init: true
-  }, {
-    name: 'memory',
-    opts: {
-      fs: require('interface-datastore').MemoryDatastore,
-      level: require('memdown'),
-      lock: 'memory'
+  const repos = [
+    {
+      name: 'default inited',
+      opts: undefined,
+      init: true
     },
-    init: true
-  }, {
-    name: 'custom locker',
-    opts: {
-      lock: customLock
+    {
+      name: 'memory',
+      opts: {
+        fs: require('interface-datastore').MemoryDatastore,
+        level: require('memdown'),
+        lock: 'memory'
+      },
+      init: true
     },
-    init: true
-  }, {
-    name: 'default existing',
-    opts: undefined,
-    init: false
-  }]
+    {
+      name: 'custom locker',
+      opts: {
+        lock: customLock
+      },
+      init: true
+    },
+    {
+      name: 'default existing',
+      opts: undefined,
+      init: false
+    }
+  ]
   repos.forEach((r) => describe(r.name, () => {
     const testRepoPath = path.join(__dirname, 'test-repo')
     const date = Date.now().toString()