Kano001 commited on
Commit
5750188
·
verified ·
1 Parent(s): d8ee76f

Update server.js

Browse files
Files changed (1) hide show
  1. server.js +22 -50
server.js CHANGED
@@ -1,50 +1,22 @@
1
- const colyseus = require("colyseus");
2
- const http = require("http");
3
- const express = require("express"); // optional
4
- const monitor = require("@colyseus/monitor").monitor;
5
-
6
- // Initialize the Express app (optional)
7
- const app = express();
8
-
9
- // Create HTTP & WebSocket servers
10
- const server = http.createServer(app);
11
- const gameServer = new colyseus.Server({
12
- server: server,
13
- });
14
-
15
- // Define a room handler
16
- class MyRoom extends colyseus.Room {
17
- onCreate(options) {
18
- console.log("Room created!", options);
19
- }
20
-
21
- onJoin(client, options) {
22
- console.log(client.sessionId, "joined!");
23
- }
24
-
25
- onLeave(client, consented) {
26
- console.log(client.sessionId, "left!");
27
- }
28
-
29
- onMessage(client, message) {
30
- console.log(client.sessionId, "sent message", message);
31
- this.broadcast("messages", message);
32
- }
33
-
34
- onDispose() {
35
- console.log("Room disposed!");
36
- }
37
- }
38
-
39
- // Register the room handler
40
- gameServer.define("my_room", MyRoom);
41
-
42
- // Serve static files (optional)
43
- app.use(express.static("public"));
44
- app.use("/colyseus", monitor());
45
-
46
- // Start the server
47
- const port = process.env.PORT || 7860;
48
- server.listen(port, () => {
49
- console.log(`Listening on ws://localhost:${port}`);
50
- });
 
1
+ const express = require('express')
2
+ const webserver = express()
3
+ .use((req, res) =>
4
+ res.sendFile('/websocket-client.html', { root: __dirname })
5
+ )
6
+ .listen(7860, () => console.log(`Listening on ${7860}`))
7
+ const { WebSocketServer } = require('ws')
8
+ const sockserver = new WebSocketServer({ port: 443 })
9
+ sockserver.on('connection', ws => {
10
+ console.log('New client connected!')
11
+ ws.send('connection established')
12
+ ws.on('close', () => console.log('Client has disconnected!'))
13
+ ws.on('message', data => {
14
+ sockserver.clients.forEach(client => {
15
+ console.log(`distributing message: ${data}`)
16
+ client.send(`${data}`)
17
+ })
18
+ })
19
+ ws.onerror = function () {
20
+ console.log('websocket error')
21
+ }
22
+ })