/
server.js
213 lines (180 loc) · 6.84 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
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
// Load environment variables
require("dotenv").config();
const mongoose = require("mongoose");
const express = require("express");
const session = require("express-session");
const MongoStore = require('connect-mongo');
const authRoutes = require("./routes/authRoutes");
const profileRoutes = require('./routes/profileRoutes'); // Added profile routes
const subSphereRoutes = require('./routes/subSphereRoutes'); // Added SubSphere routes
const postRoutes = require('./routes/postRoutes'); // Added post routes
const commentRoutes = require('./routes/commentRoutes'); // Added comment routes
const voteRoutes = require('./routes/voteRoutes'); // Added vote routes
const userRoutes = require('./routes/userRoutes'); // Added user routes
const messageRoutes = require('./routes/messageRoutes'); // Added message routes
const notificationRoutes = require('./routes/notificationRoutes'); // Added notification routes
const searchRoutes = require('./routes/searchRoutes'); // Added search routes
const moderationRoutes = require('./routes/moderationRoutes'); // Added moderation routes
const multer = require('multer'); // For handling multipart/form-data
const path = require('path');
const fs = require('fs');
const http = require('http');
const { Server } = require("socket.io");
const Message = require('./models/Message'); // Import the Message model
const Chat = require('./models/Chat'); // Import the Chat model
const Notification = require('./models/Notification'); // Import the Notification model
const notificationHandler = require('./utils/notificationHandler'); // Import the notificationHandler utility
const passport = require('passport');
require('./config/passport-setup');
if (!process.env.DATABASE_URL || !process.env.SESSION_SECRET) {
console.error("Error: config environment variables not set. Please create/edit .env configuration file.");
process.exit(-1);
}
const app = express();
const port = process.env.PORT || 3000;
// Middleware to parse request bodies
app.use(express.urlencoded({ extended: true }));
app.use(express.json());
// Setting the templating engine to EJS
app.set("view engine", "ejs");
// Serve static files
app.use(express.static("public"));
// Serve uploaded files
app.use('/uploads', express.static(path.join(__dirname, 'public/uploads')));
// Database connection
mongoose
.connect(process.env.DATABASE_URL)
.then(() => {
console.log("Database connected successfully");
})
.catch((err) => {
console.error(`Database connection error: ${err.message}`);
console.error(err.stack);
process.exit(1);
});
// Session configuration with connect-mongo
const sessionMiddleware = session({
secret: process.env.SESSION_SECRET,
resave: false,
saveUninitialized: false,
store: MongoStore.create({ mongoUrl: process.env.DATABASE_URL }),
});
app.use(sessionMiddleware);
// Passport initialization
app.use(passport.initialize());
app.use(passport.session());
// Socket.io setup
const server = http.createServer(app);
const io = new Server(server);
app.set('socketio', io); // Make io available in routes
io.use((socket, next) => {
sessionMiddleware(socket.request, {}, next);
});
io.on('connection', (socket) => {
console.log('a user connected');
if (socket.request.session && socket.request.session.userId) {
const userId = socket.request.session.userId;
socket.join(userId.toString());
console.log(`User ${userId} joined room: ${userId}`);
} else {
console.error("Session or userId not found for socket connection.");
}
socket.on('disconnect', () => {
console.log('user disconnected');
});
socket.on('joinChat', (chatId) => {
console.log(`User joined chat: ${chatId}`);
socket.join(chatId);
});
socket.on('sendMessage', ({chatId, senderId, message}) => {
Chat.findOne({ chatId: chatId }).then(chat => {
if (!chat) {
console.error(`Chat not found for chatId: ${chatId}`);
// Emitting an error message back to the client
io.to(socket.id).emit('error', 'Chat not found');
return;
}
const newMessage = new Message({
sender: senderId,
content: message,
chat: chat._id
});
newMessage.save().then(savedMessage => {
io.to(chatId).emit('receiveMessage', {chatId, senderId, message}); // Adjusted the sequence as per user feedback
console.log(`Message saved and sent from ${senderId} to chat ${chatId}: ${message}`);
// Use notificationHandler to create and emit notifications
notificationHandler.createMessageNotification(savedMessage._id, chatId, io);
}).catch(error => {
console.error(`Error saving message: ${error.message}`);
console.error(error.stack);
});
}).catch(error => {
console.error(`Error finding chat: ${error.message}`);
console.error(error.stack);
});
});
});
app.on("error", (error) => {
console.error(`Server error: ${error.message}`);
console.error(error.stack);
});
// Logging session creation and destruction
app.use((req, res, next) => {
const sess = req.session;
// Make session available to all views
res.locals.session = sess;
if (!sess.views) {
sess.views = 1;
console.log("Session created at: ", new Date().toISOString());
} else {
sess.views++;
console.log(
`Session accessed again at: ${new Date().toISOString()}, Views: ${sess.views}, User ID: ${sess.userId || '(unauthenticated)'}`,
);
}
next();
});
// Authentication Routes
app.use(authRoutes);
// Profile Routes
app.use(profileRoutes); // Use the profile routes
// SubSphere Routes
app.use(subSphereRoutes); // Use the SubSphere routes
// Post Routes
app.use(postRoutes); // Use the post routes
// Comment Routes
app.use(commentRoutes); // Use the comment routes
// Vote Routes
app.use(voteRoutes); // Use the vote routes
// User Routes
app.use(userRoutes); // Use the user routes
// Message Routes
app.use('/messages', messageRoutes); // Use the message routes with '/messages' prefix
// Notification Routes
app.use('/notifications', notificationRoutes); // Use the notification routes
// Search Routes
app.use('/search', searchRoutes); // Use the search routes
// Moderation Routes
app.use('/moderation', moderationRoutes); // Use the moderation routes
// Root path response
app.get("/", (req, res) => {
if (req.session && req.session.userId) {
res.redirect('/users/' + req.session.userId);
} else {
res.render("index");
}
});
// If no routes handled the request, it's a 404
app.use((req, res, next) => {
res.status(404).send("Page not found.");
});
// Error handling
app.use((err, req, res, next) => {
console.error(`Unhandled application error: ${err.message}`);
console.error(err.stack);
res.status(500).send("There was an error serving your request.");
});
// Replace app.listen with server.listen to integrate Socket.io
server.listen(port, () => {
console.log(`Server running with Socket.io at http://localhost:${port}`);
});