-
Notifications
You must be signed in to change notification settings - Fork 0
/
server.js
79 lines (65 loc) · 2.25 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
import express from 'express';
import mongoose from 'mongoose';
import Messages from './dbMessages.js';
import Pusher from 'pusher';
import cors from 'cors';
// App configuration
const app = express();
const port = process.env.PORT || 9000;
const pusher = new Pusher({
appId: "0",
key: "0",
secret: "0",
cluster: "0",
useTLS: true
}); // add own API Data
// Middleware
app.use(express.json()); // Middleware to parse JSON bodies
app.use(cors());
// DB configuration
const connection_url = 'mongodb+srv://@cluster1.erv7d.mongodb.net/?retryWrites=true&w=majority&appName=Cluster1'; // add own db configuration
// Connect to MongoDB
mongoose.connect(connection_url, {
})
.then(() => console.log('MongoDB connected successfully'))
.catch(error => console.error('MongoDB connection error:', error));
const db = mongoose.connection;
db.once("open", () => {
console.log("Db Connected")
const msgCollection = db.collection("messagecontents");
const changeStream = msgCollection.watch();
changeStream.on("change", (change) => {
console.log("A change is occured:", change);
if (change.operationType === "insert") {
const messageDetails = change.fullDocument;
pusher.trigger("messages", "inserted", {
name: messageDetails.name,
message: messageDetails.message,
})
console.log("Message is updating")
} else {
console.log("Error triggering Pusher")
}
})
})
// API routes
app.get('/', (req, res) => res.status(200).send("Hello Worlds"));
app.get('/messages/sync', async (req, res) => {
try {
const newMessage = await Messages.find();
res.status(200).send(newMessage);
} catch {
res.status(500).send(err.message)
}
})
app.post('/messages/new', async (req, res) => {
try {
const dbMessage = req.body;
const newMessage = await Messages.create(dbMessage);
res.status(201).send(`New message created: \n ${newMessage}`);
} catch (err) {
res.status(500).send(err.message);
}
});
// Start the server
app.listen(port, () => console.log(`Listening on localhost:${port}`));