2024-08-16 15:04:52 -04:00
|
|
|
import fs from "fs";
|
|
|
|
import http from "http";
|
|
|
|
import dotenv from "dotenv";
|
|
|
|
import { Review, reviewSchema } from "./types";
|
2024-08-18 17:11:15 -04:00
|
|
|
import { checkFile, emp, Logger, Responder } from "./utils";
|
2024-08-16 15:04:52 -04:00
|
|
|
dotenv.config();
|
|
|
|
|
2024-08-18 17:17:59 -04:00
|
|
|
const logger = new Logger("Simple Review Server");
|
2024-08-18 17:11:15 -04:00
|
|
|
const response = new Responder();
|
|
|
|
// @ts-ignore
|
2024-08-16 15:04:52 -04:00
|
|
|
const port = +process.env.PORT ?? 8080;
|
2024-08-18 17:11:15 -04:00
|
|
|
const host = emp(`http://localhost:${port}`);
|
2024-08-16 15:04:52 -04:00
|
|
|
const contentType = { "Content-Type": "application/json" };
|
|
|
|
|
|
|
|
http
|
|
|
|
.createServer((req, res) => {
|
|
|
|
const isPost = req.method === "POST";
|
|
|
|
|
|
|
|
req.on("data", async (chunk) => {
|
2024-08-18 17:11:15 -04:00
|
|
|
const sender = req.headers["user-agent"];
|
2024-08-16 15:04:52 -04:00
|
|
|
let data: Review[] = checkFile("data.json", "utf8");
|
|
|
|
let temp: any;
|
|
|
|
|
|
|
|
try {
|
|
|
|
temp = JSON.parse(chunk);
|
|
|
|
} catch (err) {
|
|
|
|
console.error(origin + "Chunk is not valid JSON");
|
|
|
|
return;
|
|
|
|
}
|
|
|
|
|
|
|
|
await reviewSchema
|
|
|
|
.validate(temp)
|
|
|
|
.then((valid) => {
|
|
|
|
req.on("end", () => {
|
2024-08-18 17:11:15 -04:00
|
|
|
logger.log(`${emp(sender)} sent: ${valid}`);
|
2024-08-16 15:04:52 -04:00
|
|
|
|
|
|
|
data.push(valid);
|
2024-08-17 12:56:35 -04:00
|
|
|
fs.writeFileSync(
|
|
|
|
"./persist/data.json",
|
|
|
|
JSON.stringify(data, null, 2),
|
|
|
|
);
|
2024-08-16 15:04:52 -04:00
|
|
|
|
2024-08-18 17:11:15 -04:00
|
|
|
res.writeHead(201, contentType);
|
|
|
|
res.write(response.success("Review was sent"));
|
2024-08-16 15:04:52 -04:00
|
|
|
res.end();
|
|
|
|
});
|
|
|
|
})
|
2024-08-18 17:11:15 -04:00
|
|
|
.catch((err) => {
|
|
|
|
logger.error(err);
|
2024-08-16 15:04:52 -04:00
|
|
|
|
|
|
|
res.writeHead(415, contentType);
|
2024-08-18 17:11:15 -04:00
|
|
|
res.write(JSON.stringify({ response: "error", message: "Invalid content-type." }));
|
2024-08-16 15:04:52 -04:00
|
|
|
res.end();
|
|
|
|
});
|
|
|
|
});
|
|
|
|
|
|
|
|
req.on("end", () => {
|
2024-08-18 17:11:15 -04:00
|
|
|
const sender = req.headers["user-agent"];
|
2024-08-16 15:04:52 -04:00
|
|
|
if (!isPost) {
|
2024-08-18 17:11:15 -04:00
|
|
|
logger.warn(`${emp(sender)} sent no data.`)
|
|
|
|
|
|
|
|
res.writeHead(400, contentType);
|
|
|
|
res.write(response.error("Invalid content-type"));
|
2024-08-16 15:04:52 -04:00
|
|
|
res.end();
|
|
|
|
}
|
|
|
|
});
|
|
|
|
})
|
|
|
|
.listen(port || 8080);
|
|
|
|
|
2024-08-18 17:11:15 -04:00
|
|
|
logger.log(`Server started on ${host}`);
|