server.js

const express = require("express");
const cors = require("cors");
const bodyParser = require("body-parser");
const morgan = require("morgan");
const getPort = require("get-port");
const nginx = require("./create-nginx-config");
const uuid = require("uuid");
const { registerUrl } = require("./digitalocean");
const app = express();
const fs = require("fs");
require('dotenv').config()

app.use(cors());
app.use(bodyParser.json());
app.use(morgan("dev"));

const PORT = process.env.PORT || 4000;

app.post("/api/tunnels", (req, res) => {
  const { ssh } = req.body;
  if (!fs.existsSync("/home/tunnel/.ssh")) {
    fs.mkdirSync("/home/tunnel/.ssh");
  }
  fs.appendFileSync("/home/tunnel/.ssh/authorized_keys", `${ssh}\n`);
  res.json({ status: "success", message: "ssh key upload" });
});

app.post("/create", async (req, res) => {
  const { id, port } = req.body;
  try {
    await registerUrl(id);
    console.log("registered url")
    await nginx.generateConfig(id, port);
    console.log("generated url config")
    res.json({ status: "success", message: "config created" });
  } catch (error) {
    console.log(error);
    res.status(500).json({ status: "fail", message: "config failed" });
  }
});

app.get("/uuid", async (req, res) => {
  let id = uuid.v4();
  while (!nginx.isDomainAvailable(id)) {
    id = uuid.v4();
  }
  res.json({ status: "success", message: "uuid created", data: { uuid: id } });
});

app.get("/port", async (req, res) => {
  let port = await getPort();
  while (!nginx.isPortAvailable(port)) {
    port = await getPort();
  }
  res.json({ status: "success", message: "port created", data: { port } });
});

app.listen(PORT, () => {
  console.log(`listening on port ${PORT}`);
});