PromucFlow_constructor/app/rts/src/server.ts

import http from "http";
import path from "path";
import express from "express";
import { Server } from "socket.io";
import log, { LogLevelDesc } from "loglevel";
import { VERSION as buildVersion } from "./version"; // release version of the api
import { initializeSockets } from "./sockets";

// routes
import ast_routes from "./routes/ast_routes";
import health_check_routes from "./routes/health_check_routes";

const RTS_BASE_PATH = "/rts";
export const RTS_BASE_API_PATH = "/rts-api/v1";

// Setting the logLevel for all log messages
const logLevel: LogLevelDesc = (process.env.APPSMITH_LOG_LEVEL ||
  "debug") as LogLevelDesc;
log.setLevel(logLevel);

// Verifing Environment Variables
const MONGODB_URI = process.env.APPSMITH_MONGODB_URI;
if (
  MONGODB_URI == null ||
  MONGODB_URI === "" ||
  !MONGODB_URI.startsWith("mongodb")
) {
  log.error("Please provide a valid value for `APPSMITH_MONGODB_URI`.");
  process.exit(1);
}

const API_BASE_URL = process.env.APPSMITH_API_BASE_URL;
if (API_BASE_URL == null || API_BASE_URL === "") {
  log.error("Please provide a valid value for `APPSMITH_API_BASE_URL`.");
  process.exit(1);
}

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

//Disable x-powered-by header to prevent information disclosure
const app = express();
app.disable("x-powered-by");
const server = new http.Server(app);
const io = new Server(server, {
  path: RTS_BASE_PATH,
});

// Initializing Sockets
initializeSockets(io);

// parse incoming json requests
app.use(express.json({ limit: "5mb" }));
// Initializing Routes
app.use(express.static(path.join(__dirname, "static")));
app.get("/", (_, res) => {
  res.redirect("/index.html");
});

app.use(`${RTS_BASE_API_PATH}/ast`, ast_routes);
app.use(`${RTS_BASE_API_PATH}`, health_check_routes);

server.headersTimeout = 61000;
server.keepAliveTimeout = 60000;
// Run the server
server.listen(PORT, () => {
  log.info(`RTS version ${buildVersion} running at http://localhost:${PORT}`);
});

export default server;