Commit: a011f1c95d48cfb8aeebeb2ee7e72908dd5900ef - dogrun-ci (git)

docker based ci tool

Commit MetaInfo

• Revisión: a011f1c95d48cfb8aeebeb2ee7e72908dd5900ef (tree)
• Tiempo: 2019-06-03 23:16:40
• Autor: hylom <hylom@user...>
• Commiter: hylom

Log Message

add frontend server basic codes

Cambiar Resumen

• add: frontend/config.js
• add: frontend/index.js
• add: frontend/package.json

Diferencia incremental

--- /dev/null
+++ b/frontend/config.js
@@ -0,0 +1,9 @@
+exports.config = {
+  port: 5678,
+  tasks: {
+    newslash: {
+      token: "ASEgbfsREAsea",
+    },
+  },
+};
+

--- /dev/null
+++ b/frontend/index.js
@@ -0,0 +1,96 @@
+const http = require('http');
+const url = require('url');
+
+const connect = require('connect');
+const morgan = require('morgan');
+const config = require('./config').config;
+const bodyParser = require('body-parser');
+const Busboy = require('busboy');
+
+const app = connect();
+
+// use morgan logger
+app.use(morgan('combined'));
+
+// use bodyParser for Content-Disposition: form-data
+//app.use(bodyParser.urlencoded({ extended: false }));
+//app.use(bodyParser.json());
+
+function _sendJson(res, statusCode, data) {
+  const json = JSON.stringify(data);
+  res.writeHead(statusCode, {
+    'Content-Type': 'application/json',
+    'Content-Length': json.length,
+  });
+  res.end(json);
+};
+
+function _run_task(payload, task) {
+  console.log(payload);
+  return true;
+};
+
+// public routes - webhook receiver
+app.use('/pub', (req, res, next) => {
+  if (req.method != 'POST') {
+    _sendJson(res, 400, { error: { code: 400, message: "bad request" } });
+    return;
+  }
+
+  const req_url = url.parse(req.url, true);
+  m = req_url.pathname.match(/^\/([^/]*)\/([^/]*)/);
+  if (!m) {
+    next();
+    return;
+  }
+  const task = m[1];
+  const action = m[2];
+
+  const task_config = config.tasks[task];
+  if (!task_config) {
+    next();
+    return;
+  }
+
+  if (action == 'run') {
+    // check token
+    if (!task_config.token || task_config.token != req_url.query.token) {
+      _sendJson(res, 400, { error: { code: 400, message: "invalid token" } });
+      return;
+    }
+
+    // check header
+    const contentType = req.headers['content-type'];
+    if (contentType.match(/^multipart\/form-data;/)) {
+      // parse and extract multipart/form-data
+      const body = {};
+      bb = new Busboy({ headers: req.headers });
+      bb.on('field', (fieldname, val, fieldnameTruncated, valTruncated, encoding, mimetype) => {
+	body[fieldname] = val;
+      });
+      bb.on('finish', () => {
+	const result = _run_task(body, task);
+	if (result) {
+	  _sendJson(res, 200, { result: { message: "ok" } });
+	} else {
+	  _sendJson(res, 400, { error: { code: 500, message: "execute error" } });
+	}
+      });
+      req.pipe(bb);
+      return;
+    }
+
+    _sendJson(res, 400, { error: { code: 500, message: "invalid body" } });
+    return;
+  }
+
+  next();
+});
+
+// 404: Not Found
+app.use((req, res) => {
+  _sendJson(res, 404, { error: { code: 404, message: "not found" } });
+});
+
+//create node.js http server and listen on port
+http.createServer(app).listen(config.port);

--- /dev/null
+++ b/frontend/package.json
@@ -0,0 +1,17 @@
+{
+  "name": "dogrun-frontend",
+  "version": "1.0.0",
+  "description": "dogrun-ci web frontend",
+  "main": "index.js",
+  "scripts": {
+    "test": "echo \"Error: no test specified\" && exit 1"
+  },
+  "author": "hylom <[e-mail]>",
+  "license": "ISC",
+  "dependencies": {
+    "body-parser": "^1.19.0",
+    "busboy": "^0.3.1",
+    "connect": "^3.7.0",
+    "morgan": "^1.9.1"
+  }
+}