From 433b524c76509cf0e405b80fa3018beb8e55a732 Mon Sep 17 00:00:00 2001
From: Zork <z@z-m13.local>
Date: Tue, 10 May 2016 19:28:15 +0300
Subject: [PATCH] Async calls callback

---
 index.js            | 33 +++++++++++++++++++--------------
 tests/index.test.js |  6 +++---
 2 files changed, 22 insertions(+), 17 deletions(-)

diff --git a/index.js b/index.js
index a48d8be..ef9f2a8 100644
--- a/index.js
+++ b/index.js
@@ -6,6 +6,8 @@ const
     isOSX = (process.platform === 'darwin'),
     isWindows = (process.platform === 'win32');
 
+let unset;
+
 class PackDir {
     constructor() {
         this.params = {
@@ -37,20 +39,23 @@ class PackDir {
         }
     }
 
-    dmg(path) {
-        let fileName = path + this.DMG;
+    dmg(path, callback) {
+        let fileName = path + this.DMG,
+            cmd = `hdiutil create -format ${this.params.dmgFormat} -srcfolder "${path}" "${fileName}"`;
 
         this.cleanFile(fileName);
-        this.exec()(`hdiutil create -format ${this.params.dmgFormat} -srcfolder "${path}" "${fileName}"`);
+        this.exec(cmd, unset, callback || unset);
         this.log(`DMG file created: "${fileName}"`);
 
         return fileName;
     }
 
-    exec() {
-        return this.params.isSync
+    exec(cmd, params, callback) {
+        let execute = this.params.isSync
             ? require('child_process').execSync
             : require('child_process').exec;
+
+        return execute(cmd, params, callback);
     }
 
     extract(path, destination) {
@@ -76,7 +81,7 @@ class PackDir {
         return this.unzip(path, destination);
     }
 
-    path(path) {
+    path(path, callback) {
         try {
             if (!FS.existsSync(path)) {
                 console.error(`Specified path does not exist: "${path}".`);
@@ -84,9 +89,9 @@ class PackDir {
             }
 
             if (this.asDMG(path)) {
-                return this.dmg(path);
+                return this.dmg(path, callback);
             } else {
-                return this.zip(path);
+                return this.zip(path, callback);
             }
         }
         catch (e) {
@@ -96,13 +101,13 @@ class PackDir {
         return false;
     }
 
-    paths(paths) {
+    paths(paths, callback) {
         let packs = false;
 
         if (Array.isArray(paths)) {
             // Recursive packing for Array of paths
             packs = paths.map(path => {
-                return this.path(path);
+                return this.path(path, callback);
             });
         }
 
@@ -138,7 +143,7 @@ class PackDir {
         return this.params[name] = value;
     }
 
-    unzip(path, destination) {
+    unzip(path, destination, callback) {
         let pathInfo = Path.parse(path),
             pathToUnZip = isWindows
                 ? this.getUnZipPath()
@@ -146,12 +151,12 @@ class PackDir {
             extractTo = destination || pathInfo.dir,
             cmd = `${pathToUnZip} -o "${path}" -d "${extractTo}"`;
 
-        this.exec()(cmd);
+        this.exec(cmd, unset, callback || unset);
 
         return extractTo;
     }
 
-    zip(path) {
+    zip(path, callback) {
         let fileName = path + this.ZIP,
             pathInfo = Path.parse(path),
             pathStat = FS.statSync(path),
@@ -169,7 +174,7 @@ class PackDir {
         }
 
         this.cleanFile(fileName);
-        this.exec()(cmd, params);
+        this.exec(cmd, params, callback || unset);
         this.log(`ZIP archive created: "${fileName}"`);
 
         return fileName;
diff --git a/tests/index.test.js b/tests/index.test.js
index 1965007..ae9b41f 100644
--- a/tests/index.test.js
+++ b/tests/index.test.js
@@ -49,13 +49,13 @@ describe('Pack Dir', () => {
     });
 
     it('executed sync/async', () => {
-        let process = require('child_process');
+        let cmd = 'echo test';
 
         Pack.param('isSync', true);
-        expect(Pack.exec()).toBe(process.execSync);
+        expect(Pack.exec(cmd) instanceof Buffer).toBe(true);
 
         Pack.param('isSync', false);
-        expect(Pack.exec()).toBe(process.exec);
+        expect(Pack.exec(cmd) instanceof require('events')).toBe(true);
     });
 
     it('logs are silent when off', () => {