Merge branch 'swarm' into develop

Author: iurimatias

lib/cmd.js

@@ -14,7 +14,7 @@ Cmd.prototype.process = function(args) {
   this.blockchain();
   this.simulator();
   this.test();
-  this.ipfs();
+  this.upload();
   this.otherCommands();
   program.parse(args);
 };
@@ -137,13 +137,17 @@ Cmd.prototype.test = function() {
   });
 };
 
-Cmd.prototype.ipfs = function() {
+Cmd.prototype.upload = function() {
   var self = this;
   program
-  .command('ipfs')
-  .description('deploy to IPFS')
-  .action(function() {
-    self.Embark.ipfs();
+  .command('upload [platform]')
+  .description('upload your dapp to a decentralized storage. possible options: ipfs, swarm (e.g embark upload swarm)')
+  .action(function(platform ,options) {
+    // TODO: get env in cmd line as well
+    self.Embark.initConfig('development', {
+        embarkConfig: 'embark.json'
+    });
+    self.Embark.upload(platform);
   });
 };
 

lib/index.js

@@ -23,6 +23,7 @@ var Monitor = require('./monitor.js');
 var ServicesMonitor = require('./services.js');
 var Console = require('./console.js');
 var IPFS = require('./ipfs.js');
+var Swarm = require('./swarm.js');
 
 var Embark = {
 
@@ -301,10 +302,18 @@ var Embark = {
   },
 
   // TODO: should deploy if it hasn't already
-  ipfs: function() {
-    var ipfs = new IPFS({buildDir: 'dist/'});
-    ipfs.deploy();
-  }
+  upload: function(platform) {
+    if (platform === 'ipfs') {
+      var ipfs = new IPFS({buildDir: 'dist/'});
+      ipfs.deploy();
+    } else if (platform === 'swarm') {
+      var swarm = new Swarm({buildDir: 'dist/'});
+      swarm.deploy();
+    } else {
+      console.log(("unknown platform: " + platform).red);
+      console.log('try "embark upload ipfs" or "embark upload swarm"'.green);
+    }
+  },
 
 };
 

lib/ipfs.js

@@ -1,28 +1,51 @@
 var colors = require('colors');
+var async = require('async');
 
 var IPFS = function(options) {
   this.options = options;
   this.buildDir = options.buildDir || 'dist/';
 };
 
 IPFS.prototype.deploy = function() {
-  var ipfs_bin = exec('which ipfs').output.split("\n")[0];
-
-  if (ipfs_bin==='ipfs not found'){
-    console.log('=== WARNING: IPFS not in an executable path. Guessing ~/go/bin/ipfs for path'.yellow);
-    ipfs_bin = "~/go/bin/ipfs";
-  }
-
-  var cmd = ipfs_bin + " add -r " + build_dir;
-  console.log(("=== adding " + cmd + " to ipfs").green);
-
-  var result = exec(cmd);
-  var rows = result.output.split("\n");
-  var dir_row = rows[rows.length - 2];
-  var dir_hash = dir_row.split(" ")[1];
-
-  console.log(("=== DApp available at http://localhost:8080/ipfs/" + dir_hash + "/").green);
-  console.log(("=== DApp available at http://gateway.ipfs.io/ipfs/" + dir_hash + "/").green);
+  var self = this;
+  async.waterfall([
+    function findBinary(callback) {
+      var ipfs_bin = exec('which ipfs').output.split("\n")[0];
+
+      if (ipfs_bin==='ipfs not found'){
+        console.log('=== WARNING: IPFS not in an executable path. Guessing ~/go/bin/ipfs for path'.yellow);
+        ipfs_bin = "~/go/bin/ipfs";
+      }
+
+      return callback(null, ipfs_bin);
+    },
+    function runCommand(ipfs_bin, callback) {
+      var cmd = ipfs_bin + " add -r " + self.buildDir;
+      console.log(("=== adding " + self.buildDir + " to ipfs").green);
+      console.log(cmd.green);
+      var result = exec(cmd);
+
+      return callback(null, result);
+    },
+    function getHashFromOutput(result, callback) {
+      var rows = result.output.split("\n");
+      var dir_row = rows[rows.length - 2];
+      var dir_hash = dir_row.split(" ")[1];
+
+      return callback(null, dir_hash);
+    },
+    function printUrls(dir_hash, callback) {
+      console.log(("=== DApp available at http://localhost:8080/ipfs/" + dir_hash + "/").green);
+      console.log(("=== DApp available at http://gateway.ipfs.io/ipfs/" + dir_hash + "/").green);
+
+      return callback();
+    }
+  ], function(err, result) {
+      if (err) {
+        console.log("error uploading to ipfs".red);
+        console.log(err);
+      }
+  });
 };
 
 module.exports = IPFS;

lib/swarm.js

@@ -0,0 +1,54 @@
+var colors = require('colors');
+var async = require('async');
+
+var Swarm = function(options) {
+  this.options = options;
+  this.buildDir = options.buildDir || 'dist/';
+};
+
+Swarm.prototype.deploy = function() {
+  var self = this;
+  async.waterfall([
+    function findBinary(callback) {
+      var swarm_bin = exec('which swarm').output.split("\n")[0];
+
+      if (swarm_bin==='swarm not found' || swarm_bin === ''){
+        console.log('=== WARNING: Swarm not in an executable path. Guessing ~/go/bin/swarm for path'.yellow);
+        swarm_bin = "~/go/bin/swarm";
+      }
+
+      return callback(null, swarm_bin);
+    },
+    function runCommand(swarm_bin, callback) {
+      var cmd = swarm_bin + " --defaultpath " + self.buildDir + "index.html --recursive up " + self.buildDir;
+      console.log(("=== adding " + self.buildDir + " to swarm").green);
+      console.log(cmd.green);
+      var result = exec(cmd);
+
+      return callback(null, result);
+    },
+    function getHashFromOutput(result, callback) {
+      if (result.code !== 0) {
+        return callback("couldn't upload, is the swarm daemon running?");
+      }
+
+      var rows = result.output.split("\n");
+      var dir_hash = rows.reverse()[1];
+
+      return callback(null, dir_hash);
+    },
+    function printUrls(dir_hash, callback) {
+      console.log(("=== DApp available at http://localhost:8500/bzz:/" + dir_hash + "/").green);
+
+      return callback();
+    }
+  ], function(err, result) {
+      if (err) {
+        console.log("error uploading to swarm".red);
+        console.log(err);
+      }
+  });
+};
+
+module.exports = Swarm;
+

package.json

@@ -32,7 +32,7 @@
     "serve-static": "^1.11.1",
     "shelljs": "^0.5.0",
     "toposort": "^0.2.10",
-    "web3": "^0.15.0",
+    "web3": "^0.18.0",
     "wrench": "^1.5.8"
   },
   "author": "Iuri Matias <[email protected]>",