update

cli/src/commands/get-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 = "get-stream";
 module.exports.describe = "Writes localfilename to the SDFS as sdfsfilename.";
 module.exports.builder = (yargs: any) => yargs;
 
@@ -20,23 +20,23 @@ module.exports.builder = (yargs: any) => yargs;
 
 module.exports.handler = handleErrors(async (argv: {}) => {
   const master = await getMaster();
-  getCSVdata();
+//   getCSVdata();
 
   setInterval(function sync() {
     // if (queue.length > 0) {
     //   const body = queue.pop();
       var target = "http://"+ master + ":3000/sink/";
-    //   console.log(target)
+      console.log(target)
     //   console.log(JSON.stringify(body).state)
       fetch(target)
-        .then(res => console.log(res.text()))
-        // .then(json => {
+        .then(res => (res.text()))
+        .then(json => {
         // //   if (json.action !== "END") {
         // //     queue.push(json);
         // //   } else {
-        //     // console.log(json);
+            console.log(json);
         // //   }
-        // });
+        });
     // }
   
   }, 500);

sfds/index.js

@@ -408,7 +408,7 @@ app.post("/spout", function(req, res) {
   res.send("got it");
 });
 
-app.post("/sink", function(req, res) {
+app.get("/sink", function(req, res) {
   // console.log("bolt state: " +req.body.state)
   res.send("IM A SINK");
 });