-
Notifications
You must be signed in to change notification settings - Fork 0
Expand file tree
/
Copy pathindex.js
More file actions
73 lines (59 loc) · 1.92 KB
/
index.js
File metadata and controls
73 lines (59 loc) · 1.92 KB
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
const express = require("express");
const mongoose = require("mongoose");
const cors = require("cors");
const errorMiddleWare = require("./middlewares/error");
const http = require("http");
const socket = require("socket.io");
const documentModel = require("./models/document.model");
require("dotenv").config();
const app = express();
var server = http.createServer(app);
const routes = require("./routes/routes");
var io = socket(server);
app.use(cors());
app.use(express.json());
const PORT = process.env.PORT || 3000;
var d = new Date();
console.log(d.toLocaleTimeString());
app.use("/api", routes);
mongoose
.connect(process.env.DB_URL, {
useNewUrlParser: true,
useUnifiedTopology: true,
})
.then(() => console.log("MongoDb Connected!"))
.catch((error) => console.log(error));
io.on("connection", (socket) => {
console.log("client is connected to socked id :", socket.id);
socket.on("join", (documentId) => {
console.log(`Document id is ${documentId}`);
socket.join(documentId);
});
socket.on("disconnect", (documentId) => {
console.log("client disconnect...on ", documentId, "and", socket.id);
});
socket.on("typing", (data) => {
socket.broadcast.to(data.room).emit("changes", data);
});
socket.on("save", (data) => {
// console.log(data);
saveData(data);
});
});
const saveData = async (data) => {
try {
// console.log('I am databaes room ' + data.room);
let document = await documentModel.findOne({ documentId: data.room });
document.content = data.delta;
document.updatedAt = Date.now();
document = await document.save();
// console.log('I am doc content' + document.content);
} catch (error) {
console.log(error);
}
};
//middleware
app.use(errorMiddleWare.errorHandler);
server.listen(PORT, "0.0.0.0", () =>
console.log(`Server is running on ${PORT}`)
);