66 lines
1.4 KiB
JavaScript
66 lines
1.4 KiB
JavaScript
|
const express = require("express");
|
||
|
|
const app = express();
|
||
|
|
const http = require("http");
|
||
|
|
const server = http.createServer(app);
|
||
|
|
const { Server } = require("socket.io");
|
||
|
|
const io = new Server(server, {
|
||
|
|
maxHttpBufferSize: 50000000,
|
||
|
|
});
|
||
|
|
const readline = require("readline");
|
||
|
|
const { randomBytes } = require("crypto");
|
||
|
|
|
||
|
|
app.get("/", (req, res) => {
|
||
|
|
res.sendFile(__dirname + "/index.html");
|
||
|
|
});
|
||
|
|
|
||
|
|
io.on("connection", (socket) => {
|
||
|
|
console.log("a user connected");
|
||
|
|
let isRunning = true;
|
||
|
|
const rl = readline.createInterface({
|
||
|
|
input: process.stdin,
|
||
|
|
output: process.stdout,
|
||
|
|
});
|
||
|
|
|
||
|
|
socket.on("disconnect", (reason) => {
|
||
|
|
isRunning = false;
|
||
|
|
rl.close();
|
||
|
|
console.log("Client disconnected: ", reason);
|
||
|
|
});
|
||
|
|
socket.on("chat_message", (msg) => {
|
||
|
|
console.log("Received: ", msg);
|
||
|
|
});
|
||
|
|
|
||
|
|
async function readLine() {
|
||
|
|
return new Promise((resolve) => {
|
||
|
|
rl.question("Input: ", (answer) => {
|
||
|
|
resolve(answer);
|
||
|
|
});
|
||
|
|
});
|
||
|
|
}
|
||
|
|
|
||
|
|
async function readLoop() {
|
||
|
|
while (isRunning) {
|
||
|
|
let input = await readLine();
|
||
|
|
socket.emit("chat_message", {
|
||
|
|
user: {
|
||
|
|
id: "user_id",
|
||
|
|
},
|
||
|
|
chat: {
|
||
|
|
id: "session_id",
|
||
|
|
},
|
||
|
|
message: {
|
||
|
|
type: "text",
|
||
|
|
content: input,
|
||
|
|
id: `${Math.random() * 1000}`,
|
||
|
|
},
|
||
|
|
});
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
readLoop();
|
||
|
|
});
|
||
|
|
|
||
|
|
server.listen(3000, () => {
|
||
|
|
console.log("listening on *:3000");
|
||
|
|
});
|