update

cli/src/commands/put-stream.js

@@ -12,7 +12,7 @@ const fetch = require("node-fetch");
 const handleErrors = require("../utils/handleErrors");
 const getMaster = require("../utils/getMaster");
 
-module.exports.command = "put-stream";
+module.exports.command = "put-stream [name]";
 module.exports.describe = "Writes localfilename to the SDFS as sdfsfilename.";
 module.exports.builder = (yargs: any) => yargs;
 
@@ -62,7 +62,7 @@ module.exports.handler = handleErrors(async (argv: {}) => {
   setInterval(function sync() {
     if (queue.length > 0) {
       const body = queue.pop();
-      var target = "http://"+ master + ":3000/spout/";
+      var target = "http://"+ master + ":3000/spout/" + argv.name;
       console.log(target)
       console.log(JSON.stringify(body))
       fetch(target, {

sfds/index.js

@@ -406,8 +406,8 @@ app.post("/bolt", function(req, res) {
   res.send(resolver(req.body));
 });
 
-app.post("/spout", function(req, res) {
-  // console.log(req.body);
+app.post("/spout/:name", function(req, res) {
+  console.log(req.params.name);
   queue.push(req.body)
   // console.log(queue.length)
   res.send("got it");