app.js

import createBareServer from "@tomphttp/bare-server-node"
import http from "http"
import { fileURLToPath } from "url"
import { dirname, join } from "path"
import serveStatic from "serve-static"
import { createRequire } from "module"
const require = createRequire(import.meta.url)
const config = require("./deployment.config.json")
import fs from "fs"
var base64data
import sgTransport from "nodemailer-sendgrid-transport"
import nodemailer from "nodemailer"
const options = {
  auth: {
    api_key: config.api_key,
  },
}
const mailerAgent = nodemailer.createTransport(sgTransport(options))
function sendVerificationEmail(UUID, mailTo, OTP) {
  const email = {
    to: mailTo,
    from: `${config.sendFromEmail}`,
    subject: `NebulaWEB personal access code ${OTP}`,
    text: `
 ####### ACCESS CODE (OTP) ${OTP} #######
 ####### DO NOT SHARE THIS CODE!  ####### 
  (this message is automated)`,
    html: `
    ####### ACCESS CODE (OTP) ${OTP} #######
 ####### DO NOT SHARE THIS CODE!  ####### 
  (this message is automated)
  `,
  }
  if (config.verification == true) {
    mailerAgent.sendMail(email, (err, res) => {
      if (err) {
        console.log(err)
      }
      console.log(res)
    })
  }
}

function getNewCode() {
  var seq = (Math.floor(Math.random() * 10000) + 10000).toString().substring(1)
  if (seq == "0") {
    getNewCode()
  }
  return seq
}

const PORT = process.env.PORT || 3000
const bareServer = createBareServer("/bare/", {
  logErrors: false,
  localAddress: undefined,
})

const serve = serveStatic(
  join(dirname(fileURLToPath(import.meta.url)), "static/"),
  {
    fallthrough: false,
    maxAge: 5 * 60 * 1000,
  }
)

const server = http.createServer()

server.on("request", (request, response) => {
  try {
    if (bareServer.shouldRoute(request)) {
      bareServer.routeRequest(request, response)
    } else {
      let base64data
      const url = request.url
      if (url.startsWith("/sendNewCode")) {
        const OTP = getNewCode()
        fs.writeFile("./memory.txt", OTP, function (err) {
          if (err) return console.log(err)
          console.log(`Wrote OTP code to temp file`)
        })

        fs.readFile("./memory.txt", "utf8", (err, data) => {
          if (err) {
            console.error(err)
            return
          }
          console.log(data)

          sendVerificationEmail("10", config.email, data)
          let buff = new Buffer(data)
          base64data = buff.toString("base64")
          console.log("302")
          response.writeHead(302, {
            location: "/unv.html?c=" + base64data,
          })
          response.end()
        })
      } else if (url.startsWith("/verification")) {
        var body
        if (config.verification == true) {
          const body = "true"
          response.writeHead(200, {
            "Content-Length": Buffer.byteLength(body),
            "Content-Type": "text/plain",
          })
          response.end(body)
        } else {
          const body = "false"
          response.writeHead(200, {
            "Content-Length": Buffer.byteLength(body),
            "Content-Type": "text/plain",
          })
          response.end(body)
        }
      } else {
        serve(request, response, (err) => {
          response.writeHead(err?.statusCode || 500, null, {
            "Content-Type": "text/plain",
          })
          response.end(err?.stack)
        })
      }
    }
  } catch (e) {
    response.writeHead(500, "Internal Server Error", {
      "Content-Type": "text/plain",
    })
    response.end(e.stack)
  }
})
server.on("upgrade", (req, socket, head) => {
  if (bareServer.shouldRoute(req)) {
    bareServer.routeUpgrade(req, socket, head)
  } else {
    socket.end()
  }
})

server.listen(PORT)

if (process.env.UNSAFE_CONTINUE)
  process.on("uncaughtException", (err, origin) => {
    console.error(`Critical error (${origin}):`)
    console.error(err)
    console.error("UNSAFELY CONTINUING EXECUTION")
    console.error()
  })

console.log(`Server running at http://localhost:${PORT}/.`)