-
Notifications
You must be signed in to change notification settings - Fork 2
/
server.js
89 lines (76 loc) · 2.12 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
require("dotenv").config();
const express = require("express");
const app = express();
const path = require("path");
const expressLayout = require("express-ejs-layouts");
const PORT = process.env.PORT || 3000;
const mongoose = require("mongoose");
const session = require("express-session");
const flash = require("express-flash");
const MongoStore = require("connect-mongo");
const dbURI = process.env.MONGODB_URI;
const passport = require("passport");
const passportInit = require("./app/config/passport");
const cors = require("cors");
const routesInit = require("./routes/index.js");
const Emitter = require("events");
// Database connection
mongoose
.connect(`${process.env.MONGODB_URI}`, {
useNewUrlParser: true,
useUnifiedTopology: true,
})
.catch((err) => console.log(err));
// Event emitter
const eventEmitter = new Emitter();
app.set("eventEmitter", eventEmitter);
// Session config
app.use(
session({
secret: process.env.SESSION_SECRET,
resave: false,
saveUninitialized: false,
store: new MongoStore({
mongoUrl: dbURI,
}),
cookie: { maxAge: 1000 * 60 * 60 * 24 }, // 24 hour
})
);
app.use(cors());
app.use(flash());
// Assets
app.use(express.static("public"));
app.use(express.urlencoded({ extended: false }));
app.use(express.json());
// Passport config
passportInit(passport);
app.use(passport.initialize());
app.use(passport.session());
// Global middleware
app.use((req, res, next) => {
res.locals.session = req.session;
res.locals.user = req.user;
next();
});
// Set Template engine
app.use(expressLayout);
app.set("views", path.join(__dirname, "/src/views"));
app.set("view engine", "ejs");
routesInit(app);
const server = app.listen(PORT, () => {
console.log(`Listening on port http://localhost:${PORT}`);
});
// Socket
const io = require("socket.io")(server);
io.on("connection", (socket) => {
// Join socket
socket.on("join", (orderId) => {
socket.join(orderId);
});
});
eventEmitter.on("orderUpdated", (data) => {
io.to(`order_${data.id}`).emit("orderUpdated", data);
});
eventEmitter.on("orderPlaced", (data) => {
io.to("adminRoom").emit("orderPlaced", data);
});