implementation.js

const express = require("express");
const router = express.Router();
const logger = require("../config/winston");
const models = require("../models");
const sanitizeHtml = require("sanitize-html");
const jwt = require("express-jwt");
const fs = require("fs").promises;
const config = require("config");
const Workflow = require("../util/workflow");

router.post("/:stepId/:language", jwt({secret:config.get("jwt.RSA_PRIVATE_KEY"), algorithms:["RS256"]}), async function(req, res, next) {

  if(!req.files || Object.keys(req.files).length === 0 || !req.user.sub) return res.status(400).send("No files were uploaded.");

  let uploadedFile = req.files.implementation;
  let step;
  try {
    step = await models.step.findOne({where:{id: req.params.stepId}});
    if (!step) return res.status(500).send("No step found with supplied id.");
    var workflow = await models.workflow.findOne({where:{id:step.workflowId}});
    if (!workflow) return res.status(500).send("No workflow linked to step.");
    if(!(workflow.userName==req.user.sub)) return res.sendStatus(500);
  } catch(error) {
    error = "Error getting workflowId for implementation: " + error;
    logger.debug(error);
    res.status(500).send(error);
  }

  uploadedFile.mv("uploads/" + step.workflowId + "/" + req.params.language + "/" + uploadedFile.name, async function(error) {

    if(error) return res.status(500).send(error);
    try {
      await models.implementation.upsert({fileName:uploadedFile.name, language:req.params.language, stepId:req.params.stepId});
      await Workflow.workflowComplete(workflow.id);
      res.sendStatus(200);
    } catch(error) {
      error = "Error adding implementation: " + (error&&error.errors&&error.errors[0]&&error.errors[0].message?error.errors[0].message:error);
      logger.debug(error);
      res.status(500).send(error);
    }

  });

});

router.get("/:workflowId/:position/:language", async function(req, res, next) {

  let step, implementation, file;
  try {
    step = await models.step.findOne({where:{workflowId: req.params.workflowId, position: req.params.position}});
  } catch(error) {
    error = "Error getting step for implementation: " + error;
    logger.debug(error);
    return res.status(500).send(error);
  }
  if (!step) return res.sendStatus(404);
  try {
    implementation = await models.implementation.findOne({where:{language:req.params.language,stepId:step.id}});
  } catch(error) {
    error = "Error getting implementation details: " + error;
    logger.debug(error);
    return res.status(500).send(error);
  }
  if (!implementation) return res.sendStatus(404);
  try {
    file = await fs.readFile("uploads/" + step.workflowId + "/" + req.params.language + "/" + implementation.fileName, "utf8");
  } catch(error) {
    error = "Error reading implementation: " + error;
    logger.debug(error);
    return res.status(500).send(error);
  }
  if (!file) return res.sendStatus(500);
  res.render("code",{title:"Phenoflow", implementation:file, language:implementation.language})

});

module.exports = router;