Merge pull request #11 from tideflow-io/github_ci_service

GitHub ci service

Author: Jose Constela

.vscode/settings.json

@@ -0,0 +1,3 @@
+{
+  "workbench.colorCustomizations": {}
+}

agent.js

@@ -3,7 +3,7 @@ const io = require('socket.io-client')
 const colors = require('colors')
 const url = require('url')
 const pretty = require('./helpers/pretty')
-const runner = require('./runner')
+const services = require('./services')
 const os = require('os')
 
 /**
@@ -34,18 +34,47 @@ module.exports.exec = (program) => {
 
   const socket = io(`${URL}?token=${program.token}`)
 
-  // Execute command
-  socket.on('tf.command', function (req) {
+  socket.on('tf.githubCi.pullRequest', (req) => {
+    if (!agent.authenticated) return
+    q.push(services.githubCi.pullRequest(socket, 'tf.githubCi.pullRequest', req))
+  })
+
+  socket.on('tf.githubCi.pullRequest.execution.finished', (req) => {
+    if (!agent.authenticated) return
+    q.push(services.githubCi.executionFinished(socket, 'tf.githubCi.pullRequest.execution.finished', req))
+  })
+  
+  socket.on('tf.githubCi.push', (req) => {
+    if (!agent.authenticated) return
+    q.push(services.githubCi.push(socket, 'tf.githubCi.push', req))
+  })
+
+  socket.on('tf.githubCi.push.execution.finished', (req) => {
     if (!agent.authenticated) return
-    q.push(runner.cmd(socket, 'tf.command', req))
+    q.push(services.githubCi.executionFinished(socket, 'tf.githubCi.push.execution.finished', req))
   })
 
-  // Execute code
-  socket.on('tf.code', function () {
+  socket.on('tf.githubCi.test_cmd', (req) => {
     if (!agent.authenticated) return
-    q.push(runner.code(socket, 'tf.code', req))
+    q.push(services.githubCi.test_cmd(socket, 'tf.githubCi.test_cmd', req))
   })
 
+  socket.on('tf.githubCi.run_cmd', (req) => {
+    if (!agent.authenticated) return
+    q.push(services.githubCi.run_cmd(socket, 'tf.githubCi.run_cmd', req))
+  })
+
+  // Execute command
+  socket.on('tf.agent.execute', function (req) {
+    if (!agent.authenticated) return
+    q.push(services.agent.execute(socket, 'tf.agent.execute', req))
+  })
+
+  socket.on('tf.agent.code_nodesfc', function(req) {
+    if (!agent.authenticated) return
+    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

@@ -37,28 +37,53 @@ module.exports.parseStd = parseStd
  * Reports stds outputed by the in-execution command.
  * 
  * @param {Object} socket Socket's io socket that requested the execution
- * @param {String} topic Original message's topic
  * @param {Object} originalMessage Message that originally requested the execution
  * @param {String} stdout Command's stdout output
  * @param {String} stderr Command's stderr output
  */
-const progress = (socket, topic, 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(`${topic}.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.
  * 
@@ -67,15 +92,13 @@ module.exports.progress = progress
  * @param {Object} originalMessage Message that originally requested the execution
  * @param {Object} res Object containing both stds
  */
-const result = (socket, topic, originalMessage, res) => {
+const result = (socket, originalMessage, res) => {
   console.log(' || Command executed. Reporting...'.yellow)
 
-  const message = Object.assign(originalMessage, {
+  socket.emit('tf.notify.finish', Object.assign(originalMessage, {
     stdout: parseStd(res.stdout),
     stderr: parseStd(res.stderr)
-  })
-
-  socket.emit(`${topic}.res`, message)
+  }))
 }
 
 module.exports.result = result
@@ -87,10 +110,10 @@ module.exports.result = result
  * @param {Object} originalMessage Message that originally requested the execution
  * @param {Object} executionResult Catched exception
  */
-const exception = (socket, topic, originalMessage, ex) => {
+const exception = (socket, originalMessage, ex) => {
   console.log(' || Command returned error'.red)
 
-  socket.emit(`${topic}.exception`, Object.assign(originalMessage, {ex}))
+  socket.emit('tf.notify.exception', Object.assign(originalMessage, {ex}))
 }
 
 module.exports.exception = exception