Initial Commit

Author: YukariChiba

.gitignore

@@ -0,0 +1,107 @@
+# Logs
+logs
+*.log
+npm-debug.log*
+yarn-debug.log*
+yarn-error.log*
+lerna-debug.log*
+
+# Diagnostic reports (https://nodejs.org/api/report.html)
+report.[0-9]*.[0-9]*.[0-9]*.[0-9]*.json
+
+# Runtime data
+pids
+*.pid
+*.seed
+*.pid.lock
+
+# Directory for instrumented libs generated by jscoverage/JSCover
+lib-cov
+
+# Coverage directory used by tools like istanbul
+coverage
+*.lcov
+
+# nyc test coverage
+.nyc_output
+
+# Grunt intermediate storage (https://gruntjs.com/creating-plugins#storing-task-files)
+.grunt
+
+# Bower dependency directory (https://bower.io/)
+bower_components
+
+# node-waf configuration
+.lock-wscript
+
+# Compiled binary addons (https://nodejs.org/api/addons.html)
+build/Release
+
+# Dependency directories
+node_modules/
+jspm_packages/
+
+# Snowpack dependency directory (https://snowpack.dev/)
+web_modules/
+
+# TypeScript cache
+*.tsbuildinfo
+
+# Optional npm cache directory
+.npm
+
+# Optional eslint cache
+.eslintcache
+
+# Microbundle cache
+.rpt2_cache/
+.rts2_cache_cjs/
+.rts2_cache_es/
+.rts2_cache_umd/
+
+# Optional REPL history
+.node_repl_history
+
+# Output of 'npm pack'
+*.tgz
+
+# Yarn Integrity file
+.yarn-integrity
+
+# dotenv environment variables file
+.env
+.env.test
+
+# parcel-bundler cache (https://parceljs.org/)
+.cache
+
+# Next.js build output
+.next
+
+# Nuxt.js build / generate output
+.nuxt
+dist
+
+# Gatsby files
+.cache/
+# Comment in the public line in if your project uses Gatsby and not Next.js
+# https://nextjs.org/blog/next-9-1#public-directory-support
+# public
+
+# vuepress build output
+.vuepress/dist
+
+# Serverless directories
+.serverless/
+
+# FuseBox cache
+.fusebox/
+
+# DynamoDB Local files
+.dynamodb/
+
+# TernJS port file
+.tern-port
+
+# Stores VSCode versions used for testing VSCode extensions
+.vscode-test

index.js

@@ -0,0 +1,104 @@
+const amqplib = require("amqplib");
+
+require("dotenv").config();
+
+let channel = null;
+
+const QUEUE = "maxfield-task";
+
+const express = require("express");
+const bodyParser = require("body-parser");
+const fileUpload = require("express-fileupload");
+
+const app = express();
+
+const { check, validationResult } = require("express-validator");
+
+app.all("*", function(req, res, next) {
+  res.header("Access-Control-Allow-Origin", process.env.ORIGIN);
+  res.header("Access-Control-Allow-Credentials", "true");
+  res.header(
+    "Access-Control-Allow-Headers",
+    "Content-Type, Content-Length, Authorization, Accept, X-Requested-With"
+  );
+  res.header("Access-Control-Allow-Methods", "PUT, POST, GET, DELETE, OPTIONS");
+  if (req.method == "OPTIONS") {
+    res.send(200);
+  } else {
+    next();
+  }
+});
+
+app.use(bodyParser());
+app.use(fileUpload());
+
+app.get("/", (req, res) => res.send("It works!"));
+
+app.get("/queue", [], (req, res) => {
+  channel.assertQueue(QUEUE).then(info => {
+    res.send({
+      error: false,
+      inqueue: info.messageCount,
+      worker: info.consumerCount
+    });
+  });
+});
+
+app.post("/submit", [], (req, res) => {
+  const errors = validationResult(req);
+  if (!errors.isEmpty()) {
+    return res.status(422).json({ error: true, errors: errors.array() });
+  }
+
+  var id = randomid();
+  channel.assertQueue(QUEUE).then(info => {
+    channel.sendToQueue(
+      QUEUE,
+      Buffer.from(
+        JSON.stringify({
+          agents: req.body.agents,
+          googlemap: req.body.googlemap,
+          portal: req.body.portals,
+          faction: req.body.faction
+        })
+      ),
+      {
+        correlationId: id.uuid,
+        replyTo: "amq.rabbitmq.reply-to"
+      }
+    );
+    res.send({ error: false, submitid: id.taskid, inqueue: info.messageCount });
+  });
+});
+
+function init() {
+  return require("amqplib")
+    .connect(process.env.AMQPURL)
+    .then(conn => conn.createChannel())
+    .then(ch => {
+      channel = ch;
+      ch.consume(
+        "amq.rabbitmq.reply-to",
+        msg => eventEmitter.emit(msg.properties.correlationId, msg.content),
+        { noAck: true }
+      );
+    });
+}
+
+function randomid() {
+  var ret1 = new Date().getTime();
+  var ret2 = Math.random();
+  var ret3 = Math.random();
+  return {
+    uuid: ret1.toString() + ret2.toString() + ret3.toString(),
+    taskid: ret1.toString(16) + ret2.toString(16) + ret3.toString(16)
+  };
+}
+
+init()
+  .then(() =>
+    app.listen(process.env.PORT, () =>
+      console.log("MaxField API running on port " + process.env.PORT + " !")
+    )
+  )
+  .catch(err => console.error(err));

package.json

@@ -0,0 +1,18 @@
+{
+  "name": "maxfield-api",
+  "version": "1.0.0",
+  "description": "MaxField NIA-CN API",
+  "main": "index.js",
+  "author": "Yukari Chiba",
+  "license": "GPLv3",
+  "dependencies": {
+    "amqplib": "^0.5.5",
+    "body-parser": "^1.19.0",
+    "dotenv": "^8.2.0",
+    "express": "^4.17.1",
+    "express-fileupload": "^1.1.6",
+    "express-validator": "^6.4.0",
+    "imagemin": "^7.0.1",
+    "imagemin-pngquant": "^8.0.0"
+  }
+}