-
Notifications
You must be signed in to change notification settings - Fork 0
/
index.js
115 lines (96 loc) · 2.78 KB
/
index.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
require("dotenv").config();
const express = require("express");
const cors = require("cors");
const app = express();
const socket = require("socket.io");
const client = require("./configs/db");
const port = process.env.PORT || 8000;
const authRoutes = require("./routes/auth");
const postRoutes = require("./routes/post");
const detailsRoutes = require("./routes/details");
const roomsRoutes = require("./routes/rooms");
const feedBackRoutes = require("./routes/feedback");
const passportSetup = require("./configs/passport-setup");
const passport = require("passport");
const fileUploader = require("express-fileupload");
app.use(fileUploader());
app.use(express.json());
app.use(cors());
var server = app.listen(port, () => {
console.log("On port 8000!");
});
app.use(express.static("public"));
app.get("/", (req, res) => {
res.redirect("/pages");
});
app.use(passport.initialize());
app.use(passport.session());
app.use("/auth", authRoutes);
app.use("/posts", postRoutes);
app.use("/details", detailsRoutes);
app.use("/rooms", roomsRoutes);
app.use("/feedback", feedBackRoutes);
app.get("*", (req, res) => {
res.redirect("/pages/404Page/");
// res.send("page not found");
}); //default 404 response
//socket setup
const formatMessage = require("./utils/messageFormat");
const {
userJoin,
getCurrentUser,
userLeave,
getRoomUsers,
} = require("./utils/users");
var io = socket(server);
io.on("connection", function (socket) {
socket.on("joinRoom", ({ username, room }) => {
const user = userJoin(socket.id, username, room);
socket.join(user.room);
socket.emit("message", formatMessage("Bot", "Welcome to the chat"));
socket.broadcast
.to(user.room)
.emit(
"chat",
formatMessage("Linkize", `${user.username} has joined the chat!`)
);
io.to(user.room).emit("roomUsers", {
room: user.room,
users: getRoomUsers(user.room),
});
socket.on("chat", (data) => {
const user = getCurrentUser(socket.id);
if (data.message !== "") {
io.to(user.room).emit(
"chat",
formatMessage(user.username, data.message)
);
}
});
//disconnects
socket.on("disconnect", () => {
const user = userLeave(socket.id);
if (user) {
io.to(user.room).emit(
"message",
formatMessage("Bot", `${user.username} has left the chat`)
);
io.to(user.room).emit("roomUsers", {
room: user.room,
users: getRoomUsers(user.room),
});
}
});
socket.on("typing", (data) => {
const user = getCurrentUser(socket.id);
socket.broadcast.to(user.room).emit("typing", user.username);
});
});
});
client.connect((err) => {
if (err) {
console.log(err);
} else {
console.log("Connected to database!");
}
});