IO-1685 Task Scheduler.

package.json

@@ -35,6 +35,7 @@
     "graylog2": "^0.2.1",
     "inline-css": "^3.0.0",
     "intuit-oauth": "^4.0.0",
+    "json-2-csv": "^3.17.0",
     "lodash": "^4.17.21",
     "moment": "^2.29.1",
     "moment-timezone": "^0.5.34",

server.js

@@ -177,12 +177,18 @@ var data = require("./server/data/data");
 app.post("/data/ah", data.autohouse);
 app.post("/data/arms", data.arms);
 
+var taskHandler = require("./server/tasks/tasks");
+app.post("/taskHandler", taskHandler.taskHandler);
+
+
 var ioevent = require("./server/ioevent/ioevent");
 app.post("/ioevent", ioevent.default);
 app.post("/newlog", (req, res) => {
   const { message, type, user, record, object } = req.body;
   logger.log(message, type, user, record, object);
 });
+
+
 var cdkGetMake = require("./server/cdk/cdk-get-makes");
 app.post("/cdk/getvehicles", fb.validateFirebaseIdToken, cdkGetMake.default);
 

server/tasks/tasks.js

@@ -0,0 +1,38 @@
+const path = require("path");
+require("dotenv").config({
+  path: path.resolve(
+    process.cwd(),
+    `.env.${process.env.NODE_ENV || "development"}`
+  ),
+});
+const axios = require("axios");
+const client = require("../graphql-client/graphql-client").client;
+const emailer = require("../email/sendemail");
+const logger = require("../utils/logger");
+
+exports.taskHandler = async (req, res) => {
+  try {
+    const { bodyshopid, query, variables, text, to, subject } = req.body;
+    //Run the query
+    const response = await client.request(query, variables);
+    //Massage the data
+    //Send the email
+    const rootElement = response[Object.keys(response)[0]]; //This element shoudl always be an array.
+    let converter = require("json-2-csv");
+    converter.json2csv(rootElement, (err, csv) => {
+      if (err) {
+        res.status(500).json(err);
+      }
+
+      emailer.sendTaskEmail({
+        to,
+        subject,
+        text,
+        attachments: [{ filename: "query.csv", content: csv }],
+      });
+      res.status(200).send(csv);
+    });
+  } catch (error) {
+    res.status(500).json({ error });
+  }
+};