Merge pull request #2 from snyk/feat/fetch-docker-analyzer-binary

Feat/fetch docker analyzer binary

.gitignore

@@ -1,2 +1,3 @@
 /node_modules/
-.idea/
+.idea/
+dist/

.nvmrc

@@ -1 +1 @@
-8
+4

lib/fetch-snyk-docker-analyzer.js

@@ -0,0 +1,88 @@
+var os = require('os');
+var fs = require('fs');
+var fsExtra = require('fs-extra');
+var path = require('path');
+var request = require('request');
+var ProgressBar = require('progress');
+var pkgInfo = require('../package.json')
+
+module.exports = fetch
+
+const version = pkgInfo['snyk-docker-analyzer']['version'];
+
+function getBinaryName() {
+  var arch = os.arch();  
+  if (arch !== 'x64') {
+    throw new Error(`Unsupported arch ${arch} - only amd64 is supported`);
+  }
+  var suffix = '';
+  var platform = os.platform();
+  if (platform === 'win32') {
+    platform = 'windows';
+    suffix = '.exe';
+  }
+  return `snyk-docker-analyzer-${platform}-amd64${suffix}`;
+}
+
+function getBinaryLocalPath() {
+  var name = getBinaryName();
+  return path.join(__dirname, '../dist/', version, name)
+}
+
+function createBinaryPath(binaryPath) {
+  var binaryDirName = path.dirname(binaryPath);
+  fsExtra.ensureDirSync(binaryDirName);
+}
+
+function fetch(binaryPath) {
+  return new Promise((resolve, reject) => {
+    try {
+      var binaryPath = getBinaryLocalPath()
+      if (fs.existsSync(binaryPath)) {
+        return resolve(binaryPath);
+      }
+      createBinaryPath(binaryPath);
+      const snyk_docker_analyzer_url = `https://s3.amazonaws.com/snyk-docker-analyzer-releases/${version}/${getBinaryName()}`;
+
+      var bar;
+      const LOCAL_SNYK_DOCKER_ANALYZER_EXCEUTION_PERMISSION = 0755
+      const req = request(snyk_docker_analyzer_url);
+      req
+        .on('response', function (res) {
+          if (res.statusCode >= 400) {
+            var err = new Error('Bad HTTP response for snyk-docker-analyzer download');
+            err.statusCode = res.statusCode;
+            reject(err);
+            return;
+          }
+
+          var total = parseInt(res.headers['content-length'], 10);
+
+          bar = new ProgressBar(`  downloading ${getBinaryName()} [:bar] :rate/Kbps :percent :etas remaining`, {
+            complete: '=',
+            incomplete: '.',
+            width: 20,
+            total: total / 1000
+          });
+        })
+        .on('data', function (chunk) {
+          if (bar) {
+            bar.tick(chunk.length / 1000);
+          }
+        })
+        .on('error', function (err) {
+          console.log(err)
+          reject(err)
+        })
+        .on('end', function () {
+          console.log('\n');
+          fs.renameSync(binaryPath + '.part', binaryPath);
+          fs.chmodSync(binaryPath, LOCAL_SNYK_DOCKER_ANALYZER_EXCEUTION_PERMISSION);
+          resolve(binaryPath);
+        })
+        .pipe(fs.createWriteStream(binaryPath + '.part'))
+    } catch (err) {
+      reject(err);
+    }
+  })
+}

lib/index.js

@@ -1,26 +1,33 @@
 var fs = require('fs');
 var path = require('path');
-
 var subProcess = require('./sub-process');
+var fetchSnykDockerAnalyzer = require('./fetch-snyk-docker-analyzer');
 
 module.exports = {
   inspect: inspect,
 };
 
 function inspect(root, targetFile) {
-  return Promise.all([
-    getMetaData(root, targetFile),
-    getDependencies(root, targetFile),
-  ])
-  .then(function (result) {
-    return {
-      plugin: result[0],
-      package: result[1],
-    };
-  });
+  return fetchSnykDockerAnalyzer()
+  .then(function (analyzerBinaryPath) {    
+    return Promise.all([
+      getMetaData(root, targetFile),
+      getDependencies(analyzerBinaryPath, root, targetFile),
+    ])
+    .then(function (result) {
+      return {
+        plugin: result[0],
+        package: result[1],
+      };
+    });
+  })
+  .catch(function (err) {
+    console.log(err);
+  })
 }
 
 function getMetaData(root, targetFile) {
+  console.log(targetFile)
   return subProcess.execute('docker', ['version'], {cwd: root})
   .then(function (output) {
     var runtime;
@@ -39,9 +46,9 @@ function getMetaData(root, targetFile) {
 
 
 
-function getDependencies(command, targetFile) {
+function getDependencies(analyzerBinaryPath, command, targetFile) {
   return subProcess.execute(
-    'snyk-docker-cli',
+    analyzerBinaryPath,
     buildArgs(targetFile)
   )
   .then(function (output) {
@@ -108,4 +115,4 @@ function buildArgs(targetFile) {
 function pathToPosix(fpath) {
   var parts = fpath.split(path.sep);
   return parts.join(path.posix.sep);
-}
+}

package.json

@@ -12,12 +12,21 @@
     "test": "tap test/*.test.js --timeout=300",
     "semantic-release": "semantic-release pre && npm publish && semantic-release post"
   },
+  "snyk-docker-analyzer": {
+    "version": "1.0.2"
+  },
   "author": "snyk.io",
   "license": "Apache-2.0",
   "devDependencies": {
     "jscs": "^3.0.7",
     "semantic-release": "^6.3.6",
     "tap": "^10.7.0",
     "tap-only": "0.0.5"
+  },
+  "dependencies": {
+    "fs-extra": "^5.0.0",
+    "pkginfo": "^0.4.1",
+    "progress": "^2.0.0",
+    "request": "^2.85.0"
   }
 }