-
Notifications
You must be signed in to change notification settings - Fork 3
/
Copy pathserver.js
147 lines (132 loc) · 3.7 KB
/
server.js
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
const express = require("express");
const app = express();
const fs = require("fs");
const cors = require("cors");
const server = require("http").createServer(app);
const { spawn } = require("child_process");
const io = require("socket.io")(server, {
cors: {
origin: "*",
methods: ["GET", "POST"],
},
});
const PORT = process.env.PORT || 5000;
app.use(express.json());
app.use(express.urlencoded({ extended: true }));
const path = require("path");
const broadcast = require("nodemon");
app.use(express.static(path.join(__dirname, "client/build")));
app.post("/py", async (req, res, next) => {
let val = req.body.message;
let ans = "";
var childpython = null;
await new Promise((resolve, reject) => {
childpython = spawn("python", ["HospitalModel.py", val[0], val[2], val[4]]);
childpython.stdout.on("data", (data) => {
ans = "";
console.log(val[0]);
console.log(val[2]);
console.log(val[4]);
ans += data;
console.log(`${data}`);
resolve(true);
});
childpython.stderr.on("data", (data) => {
console.error(`stderr: ${data}`);
resolve(true);
});
}).then(() => {
res.json({ value: ans, val: val });
res.end();
});
});
let ansss = [];
let str1 = "";
app.post("/predict", async (req, res, next) => {
let val = req.body.dat;
let finalString = "";
finalString += val[0];
for (var i = 1; i < val.length; i++) {
finalString += `,${val[i]}`;
}
var childpython = null;
await new Promise((resolve, reject) => {
childpython = spawn("python", ["diseasePrediction.py", finalString]);
childpython.stdout.on("data", (data) => {
str1 = "";
ansss = [];
ansss.push(data);
str1 += ansss[0];
console.log(`${ansss[0]}`);
resolve(true);
});
// childpython.stderr.on("data", (data) => {
// console.error(`stderr: ${data}`);
// resolve(true);
// });
}).then(() => {
res.json({ key: str1 });
res.end();
});
});
app.post("/append", (req, res) => {
const val = req.body.message;
fs.appendFile("./appointment.txt", `\n${val}`, (err) => {
if (err) {
console.log(err);
}
console.log("file was saved");
});
res.end();
});
const user = {};
const activated = {};
io.on("connection", (socket) => {
console.log("ready to use");
socket.on("join-room", (roomId, userId) => {
console.log("joined room", roomId, "-", userId);
socket.join(roomId);
console.log(user[roomId]);
if (!user[roomId]) {
user[roomId] = 1;
} else {
user[roomId]++;
}
console.log(user[roomId]);
socket.broadcast.to(roomId).emit("user-connected", userId, user);
socket.on("disconnect", () => {
// console.log("user left", userId);
// user[roomId]--;
socket.broadcast.to(roomId).emit("user-disconnected", userId);
});
});
socket.on("room-full", (roomId, userId) => {
user[roomId]--;
console.log("removed from room", userId);
io.to(roomId).emit("removed", userId);
console.log(user[roomId]);
});
socket.on("room-check", (roomId) => {
console.log(user[roomId]);
socket.emit("check", user);
});
socket.on("leave-room", (roomId, userId) => {
console.log("left the room", roomId, userId);
socket.leave(roomId);
user[roomId]--;
socket.emit("room-left", userId);
io.to(roomId).emit("empty-chat", userId);
});
socket.on("chat", (roomId, payload) => {
io.to(roomId).emit("chat", payload);
});
});
app.get("/*", (req, res) => {
res.sendFile(path.join(__dirname, "client/build", "index.html"));
});
if (process.env.NODE_ENV === "production") {
app.use(express.static("client/build"));
}
server.listen(PORT, () => {
console.log(`Server running at http://127.0.0.1:${PORT}`);
});