project skeleton

Author: siloenix

app.js

@@ -1,17 +1,22 @@
-const createError = require('http-errors');
 const express = require('express');
+const fileUpload = require('express-fileupload');
+const createError = require('http-errors');
 const logger = require('morgan');
-const errorHandler = require('./errors/handler');
+const requestLogger = require('./middleware/requestLogger');
+const errorHandler = require('./middleware/errorHandler');
 
 const rootRouter = require('./routes/root');
+const dockerRouter = require('./routes/docker');
 
 const app = express();
 
-
-app.use(logger('dev'));
+// app.use(logger('dev'));
 app.use(express.json());
+app.use(fileUpload());
+app.use(requestLogger);
 
 app.use('/', rootRouter);
+app.use('/docker', dockerRouter);
 
 // catch 404 and forward to error handler
 app.use(function (req, res, next) {

controllers/DockerController.js

@@ -0,0 +1,31 @@
+const log = require('../logger');
+const ValidationError = require('../errors/ValidationError');
+const DockerService = require('../services/DockerService');
+
+module.exports = class DockerController {
+  static async applyYaml(req, res, next) {
+    try {
+      const file = extractYaml(req.files);
+      if (!file) {
+        next(new ValidationError('no file provided'));
+        return;
+      }
+
+      const result = await DockerService.applyYaml(file.data.toString());
+      res.json(result);
+    } catch (e) {
+      next(e);
+    }
+  }
+};
+
+const mimetype = 'text/yaml';
+function extractYaml(files) {
+  for (const name in files) {
+    if (files.hasOwnProperty(name) && files[name].mimetype === mimetype) {
+      log.info(`file found: ${name}`);
+      return files[name];
+    }
+  }
+  return null;
+}

errors/handler.js

@@ -0,0 +1,6 @@
+const {format} = require('winston');
+
+module.exports = format.combine(
+  format.colorize(),
+  format.printf(info => `${new Date().toLocaleString()} -- ${info.level} : ${info.message}`)
+);

logger/format.js

@@ -0,0 +1,9 @@
+const {createLogger, transports} = require('winston');
+const format = require('./format');
+
+module.exports = createLogger({
+  format: format,
+  transports: [
+    new transports.Console()
+  ]
+});

logger/index.js

@@ -0,0 +1,8 @@
+const log = require('../logger');
+
+module.exports = function (err, req, res, next) {
+  res.status(err.status || 500);
+  const message = err.message || err.constructor.name;
+  log.error(message);
+  res.json({message: message});
+};

middleware/errorHandler.js

@@ -0,0 +1,6 @@
+const log = require('../logger');
+
+module.exports = function (req, res, next) {
+  log.info(`${req.method} ${req.url}`);
+  next()
+};

middleware/requestLogger.js

@@ -9,9 +9,16 @@
   },
   "dependencies": {
     "debug": "~2.6.9",
+    "docker-client": "^1.38.1",
     "express": "~4.16.0",
+    "express-fileupload": "^1.0.0",
     "http-errors": "~1.6.2",
     "morgan": "~1.9.0",
-    "nconf": "latest"
+    "nconf": "^0.10.0",
+    "winston": "^3.1.0",
+    "yaml": "^1.0.0"
+  },
+  "devDependencies": {
+    "@types/node": "^10.12.0"
   }
 }

package.json

@@ -0,0 +1,6 @@
+const router = require('express').Router();
+const DockerController = require('../controllers/DockerController');
+
+router.post('/compose/yaml', DockerController.applyYaml);
+
+module.exports = router;

routes/docker.js

@@ -0,0 +1,29 @@
+const log = require('../logger');
+const yaml = require('yaml');
+
+module.exports = class DockerService {
+  static applyYaml(fileContent) {
+    const directives = yaml.parse(fileContent);
+    return this.applyDirectives(directives);
+  }
+
+  static async applyDirectives(directives) {
+    const all = {
+      ...directives.services,
+      ...directives.volumes,
+      ...directives.networks
+    };
+
+    for (const name in directives.services) {
+      log.info(`service: ${name}`);
+    }
+    for (const name in directives.volumes) {
+      log.info(`volume: ${name}`);
+    }
+    for (const name in directives.networks) {
+      log.info(`network: ${name}`);
+    }
+
+    return {ok: true}
+  }
+};