anything-llm/server/index.js

94 lines
2.6 KiB
JavaScript
Raw Normal View History

process.env.NODE_ENV === "development"
? require("dotenv").config({ path: `.env.${process.env.NODE_ENV}` })
: require("dotenv").config();
2023-06-08 06:31:35 +02:00
const express = require("express");
const bodyParser = require("body-parser");
const cors = require("cors");
const path = require("path");
2023-06-08 06:31:35 +02:00
const { validatedRequest } = require("./utils/middleware/validatedRequest");
const { reqBody } = require("./utils/http");
const { systemEndpoints } = require("./endpoints/system");
const { workspaceEndpoints } = require("./endpoints/workspaces");
const { chatEndpoints } = require("./endpoints/chat");
const { getVectorDbClass } = require("./utils/helpers");
const { validateTablePragmas } = require("./utils/database");
2023-06-04 04:28:07 +02:00
const app = express();
const apiRouter = express.Router();
2023-06-04 04:28:07 +02:00
app.use(cors({ origin: true }));
app.use(bodyParser.text());
app.use(bodyParser.json());
2023-06-08 06:31:35 +02:00
app.use(
bodyParser.urlencoded({
extended: true,
})
);
2023-06-04 04:28:07 +02:00
apiRouter.use("/system/*", validatedRequest);
systemEndpoints(apiRouter);
apiRouter.use("/workspace/*", validatedRequest);
workspaceEndpoints(apiRouter);
chatEndpoints(apiRouter);
2023-06-04 04:28:07 +02:00
apiRouter.post("/v/:command", async (request, response) => {
2023-06-04 04:28:07 +02:00
try {
const VectorDb = getVectorDbClass();
const { command } = request.params;
if (!Object.getOwnPropertyNames(VectorDb).includes(command)) {
response.status(500).json({
message: "invalid interface command",
commands: Object.getOwnPropertyNames(VectorDb),
});
return;
}
try {
const body = reqBody(request);
const resBody = await VectorDb[command](body);
response.status(200).json({ ...resBody });
} catch (e) {
// console.error(e)
console.error(JSON.stringify(e));
response.status(500).json({ error: e.message });
}
return;
2023-06-04 04:28:07 +02:00
} catch (e) {
console.log(e.message, e);
response.sendStatus(500).end();
2023-06-04 04:28:07 +02:00
}
2023-06-08 06:31:35 +02:00
});
2023-06-04 04:28:07 +02:00
app.use("/api", apiRouter);
if (process.env.NODE_ENV !== "development") {
app.use(
express.static(path.resolve(__dirname, "public"), { extensions: ["js"] })
);
app.use("/", function (_, response) {
response.sendFile(path.join(__dirname, "public", "index.html"));
});
}
2023-06-08 06:31:35 +02:00
app.all("*", function (_, response) {
2023-06-04 04:28:07 +02:00
response.sendStatus(404);
});
2023-06-08 06:31:35 +02:00
app
.listen(process.env.SERVER_PORT || 3001, async () => {
await validateTablePragmas();
2023-06-08 06:31:35 +02:00
console.log(
`Example app listening on port ${process.env.SERVER_PORT || 3001}`
2023-06-08 06:31:35 +02:00
);
})
2023-06-04 04:28:07 +02:00
.on("error", function (err) {
process.once("SIGUSR2", function () {
process.kill(process.pid, "SIGUSR2");
});
process.on("SIGINT", function () {
process.kill(process.pid, "SIGINT");
});
2023-06-08 06:31:35 +02:00
});