refactor: replace util.promisify with node promisify

lib/cache.js

@@ -50,7 +50,7 @@ const mkdirp = require('mkdirp');
 
 const { Observable } = require('rx');
 
-const promisify = require('util.promisify');
+const { promisify } = require('util');
 
 const crashRecovery = require('./crash-recovery');
 

lib/dir-content.js

@@ -42,7 +42,7 @@ const extend = require('lodash/extend');
 
 const { Observable } = require('rx');
 
-const promisify = require('util.promisify');
+const { promisify } = require('util');
 
 const { fromPromiseFunction } = require('./promise');
 

lib/file.js

@@ -44,7 +44,7 @@ const partial = require('lodash/partial');
 
 const identity = require('lodash/identity');
 
-const promisify = require('util.promisify');
+const { promisify } = require('util');
 
 const { dirChanges } = require('./dir-content');
 

package.json

@@ -39,8 +39,7 @@
     "deep-freeze": "0.0.1",
     "lodash": "^4.6.1",
     "mkdirp": "^1.0.4",
-    "rx": "^2.3.22",
-    "util.promisify": "^1.0.0"
+    "rx": "^2.3.22"
   },
   "devDependencies": {
     "assertive": "^2.1.0",

test/crash-recovery.test.js

@@ -10,7 +10,7 @@ const _ = require('lodash');
 
 const tmp = require('tmp');
 
-const promisify = require('util.promisify');
+const { promisify } = require('util');
 
 const { timestampName } = require('../lib/cache');
 

test/file-alternatives.test.js

@@ -8,7 +8,7 @@ const path = require('path');
 
 const assert = require('assertive');
 
-const promisify = require('util.promisify');
+const { promisify } = require('util');
 
 const fileAlternativesContent = require('../lib/file-alternatives');
 

test/file.test.js

@@ -10,7 +10,7 @@ const assert = require('assertive');
 
 const CSON = require('cson-parser');
 
-const promisify = require('util.promisify');
+const { promisify } = require('util');
 
 const fileContent = require('../lib/file');
 

test/latest-file.test.js

@@ -12,7 +12,7 @@ const mkdirp = require('mkdirp');
 
 const rimraf = require('rimraf');
 
-const promisify = require('util.promisify');
+const { promisify } = require('util');
 
 const latestFile = require('../lib/latest-file');
 

test/shared-store/with-cache.test.js

@@ -6,11 +6,11 @@ const { Observable } = require('rx');
 
 const tmp = require('tmp');
 
-const promisify = require('util.promisify');
+const { promisify } = require('util');
 
 const SharedStore = require('../../');
 
-const tmpDir = promisify(tmp.dir, tmp);
+const tmpDir = promisify(tmp.dir);
 
 function delay(ms) {
   return new Promise(resolve => setTimeout(resolve, ms));
@@ -20,34 +20,32 @@ describe('SharedStore (with data already in cache)', () => {
   let cacheTmpDir = null;
 
   beforeEach(() =>
-    tmpDir({
-      unsafeCleanup: true,
-    }).then(createdDir => {
-      cacheTmpDir = createdDir;
-      const store = new SharedStore({
-        temp: cacheTmpDir,
-        loader: Observable.just({
-          data: 'some data',
-        }),
-      });
-      return store.init();
-    })
+    tmpDir({ unsafeCleanup: true })
+      .then(createdDir => {
+        cacheTmpDir = createdDir;
+        return new SharedStore({
+          temp: cacheTmpDir,
+          loader: Observable.just({
+            data: 'some data',
+          }),
+        });
+      })
+      .then(store => store.init())
   );
 
   describe('taking a long time to load data', () => {
     let store;
     let notSoCurrent;
 
-    beforeEach(() => {
+    beforeEach(async () => {
       store = new SharedStore({
         temp: cacheTmpDir,
         loader: Observable.just({
           data: 'other data',
         }).delay(500),
       });
-      return store.init().then(current => {
-        notSoCurrent = current;
-      });
+
+      notSoCurrent = await store.init();
     });
 
     beforeEach(() => delay(1000));
@@ -84,27 +82,28 @@ describe('SharedStore (with data already in cache)', () => {
     let thrownError = false;
     let store;
 
-    beforeEach(() => {
-      const loader = () =>
-        Observable.create(observer =>
-          delay(250).then(() => {
-            if (!thrownError) {
-              observer.onError(new Error('kaboom!'));
-              thrownError = true;
-              return;
-            }
-
-            observer.onNext({
-              data: '2nd value',
-            });
-          })
-        );
-
+    const loader = () =>
+      Observable.create(observer =>
+        delay(250).then(() => {
+          if (!thrownError) {
+            observer.onError(new Error('kaboom!'));
+            thrownError = true;
+            return;
+          }
+
+          observer.onNext({
+            data: '2nd value',
+          });
+        })
+      );
+
+    beforeEach(async () => {
       store = new SharedStore({
         temp: cacheTmpDir,
         loader,
       });
-      return store.init();
+
+      await store.init();
     });
 
     it('will throw an error first', done => {