move nodesfc to agent service

Author: joseconstela

agent.js

@@ -70,12 +70,11 @@ module.exports.exec = (program) => {
     q.push(services.agent.execute(socket, 'tf.agent.execute', req))
   })
 
-  // Execute code
-  socket.on('tf.agent.code', function () {
+  socket.on('tf.agent.code_nodesfc', function(req) {
     if (!agent.authenticated) return
-    q.push(services.agent.code(socket, 'tf.agent.code', req))
+    q.push(services.agent.codeNodeSfc(socket, 'tf.agent.code_nodesfc', req))
   })
-
+  
   // Authorize agent
   socket.on('tf.authz', function (auth) {
     agent = Object.assign({authenticated: true}, agent, auth)

helpers/report.js

@@ -41,23 +41,49 @@ module.exports.parseStd = parseStd
  * @param {String} stdout Command's stdout output
  * @param {String} stderr Command's stderr output
  */
-const progress = (socket, originalMessage, stdout, stderr) => {
+const progress = async (socket, originalMessage, stdout, stderr, date) => {
   console.log(' || STDOUT/ERR. Reporting...'.yellow)
 
   const res = Object.assign(originalMessage, {
     stdout: parseStd(stdout),
-    stderr: parseStd(stderr)
+    stderr: parseStd(stderr),
+    date: date || null
   })
 
   // Make sure the agent doesn't make a report to the server, unless there's
   // an actual std output to be reported.
   if (!res.stdout && !res.stderr) { return }
 
-  socket.emit('tf.notify.progress', res)
+  await socket.emit('tf.notify.progress', res)
 }
 
 module.exports.progress = progress
 
+/**
+ * Reports the final result of an execution, with
+ * all stds as an array
+ * 
+ * @param {Object} socket Socket's io socket that requested the execution
+ * @param {Object} originalMessage Message that originally requested the execution
+ * @param {object} result Command's stds and exit code output:
+ * 
+ *  {
+ *    stdLines: [{
+ *      output: string,
+ *      err: boolean,
+ *      date: date
+ *    }],
+ *    code: number
+ *  }
+ */
+const bulkResult = async (socket, originalMessage, result) => {
+  console.log(' || BULK STDOUT/ERR. Reporting...'.yellow)
+  const res = Object.assign(originalMessage, result)
+  await socket.emit('tf.notify.finishBulk', res)
+}
+
+module.exports.bulkResult = bulkResult
+
 /**
  * Reports the final result of an execution.
  *