74 lines
2.2 KiB
TypeScript
74 lines
2.2 KiB
TypeScript
import net from "net";
|
|
import {OpenAPIHono} from "@hono/zod-openapi";
|
|
import {createLog} from "../logger/logger.js";
|
|
|
|
import startTCP from "./route/startServer.js";
|
|
import stopTCP from "./route/stopServer.js";
|
|
import restartTCP from "./route/restartServer.js";
|
|
import {db} from "../../../database/dbclient.js";
|
|
import {settings} from "../../../database/schema/settings.js";
|
|
import {eq} from "drizzle-orm";
|
|
|
|
let tcpServer: net.Server;
|
|
let tcpSockets: Set<net.Socket> = new Set();
|
|
let isServerRunning = false;
|
|
|
|
const tcpPort = await db.select().from(settings).where(eq(settings.name, "tcpPort"));
|
|
const app = new OpenAPIHono();
|
|
|
|
export const startTCPServer = () => {
|
|
if (isServerRunning) return {success: false, message: "Server is already running"};
|
|
|
|
tcpServer = net.createServer((socket) => {
|
|
console.log("Client connected");
|
|
|
|
tcpSockets.add(socket);
|
|
socket.on("data", (data: Buffer) => {
|
|
console.log("Received:", data.toString());
|
|
socket.write("Message received");
|
|
});
|
|
|
|
socket.on("end", () => {
|
|
console.log("Client disconnected");
|
|
tcpSockets.delete(socket);
|
|
});
|
|
|
|
socket.on("error", (err: Error) => {
|
|
console.error("Socket error:", err);
|
|
tcpSockets.delete(socket);
|
|
});
|
|
});
|
|
|
|
tcpServer.listen(tcpPort[0]?.value ?? 2222, () => {
|
|
createLog("info", "lst", "tcp", `TCP Server listening on port ${tcpPort[0]?.value ?? 2222}`);
|
|
});
|
|
|
|
isServerRunning = true;
|
|
return {success: true, message: "TCP Server started"};
|
|
};
|
|
|
|
// Function to stop the TCP server
|
|
export const stopTCPServer = () => {
|
|
if (!isServerRunning) return {success: false, message: "Server is not running"};
|
|
for (const socket of tcpSockets) {
|
|
socket.destroy();
|
|
}
|
|
tcpSockets.clear();
|
|
tcpServer.close(() => {
|
|
console.log("TCP Server stopped");
|
|
});
|
|
isServerRunning = false;
|
|
return {success: true, message: "TCP Server stopped"};
|
|
};
|
|
|
|
app.route("/tcpserver/start", startTCP);
|
|
app.route("/tcpserver/stop", stopTCP);
|
|
app.route("/tcpserver/restart", restartTCP);
|
|
|
|
// start the server after on system start up
|
|
setTimeout(() => {
|
|
startTCPServer();
|
|
}, 5000);
|
|
|
|
export default app;
|