simple echo server for sake of testing connection-ability
This commit is contained in:
parent
27c0af5b8d
commit
455f6ed6b3
4
rtc-server/.gitignore
vendored
4
rtc-server/.gitignore
vendored
@ -1 +1,3 @@
|
|||||||
node_modules/
|
node_modules/
|
||||||
|
cert.pem
|
||||||
|
key.pem
|
||||||
|
@ -1,22 +1,40 @@
|
|||||||
const express = require('express')
|
'use strict';
|
||||||
const socketio = require('socket.io')({
|
|
||||||
serveClient: false
|
const https = require('https')
|
||||||
|
const WebSocket = require('ws')
|
||||||
|
const WebSocketServer = require('wss')
|
||||||
|
const fs = require('fs')
|
||||||
|
|
||||||
|
const serverConfig = {
|
||||||
|
key: fs.readFileSync('key.pem'),
|
||||||
|
cert: fs.readFileSync('cert.pem')
|
||||||
|
}
|
||||||
|
|
||||||
|
const httpServer = https.createServer(serverConfig, (req, res) => {
|
||||||
|
res.writeHead(200)
|
||||||
|
res.end()
|
||||||
})
|
})
|
||||||
|
|
||||||
const app = express()
|
httpServer.listen(3535, '0.0.0.0')
|
||||||
|
|
||||||
var http = require('http').Server(app);
|
// Now for the websockets server
|
||||||
var io = require('socket.io')(http)
|
|
||||||
|
|
||||||
const port = process.env.PORT || 3000
|
const wss = new WebSocketServer({server: httpServer})
|
||||||
|
|
||||||
|
wss.on('connection', function(socket) {
|
||||||
|
socket.on('message', function(message) {
|
||||||
|
console.log('Socket received message: ', message)
|
||||||
|
wss.broadcast(message)
|
||||||
|
})
|
||||||
|
})
|
||||||
|
|
||||||
// Signals and shit yo
|
wss.broadcast = function(data) {
|
||||||
io.on('connection', function(socket) {
|
console.log('Cuurent clients list: ', this.clients)
|
||||||
// do some kind of header auth checking here
|
this.clients.forEach(client => {
|
||||||
console.log('New connection')
|
if(client.readyState == WebSocket.OPEN) {
|
||||||
|
client.send(data)
|
||||||
|
}
|
||||||
|
})
|
||||||
|
}
|
||||||
|
|
||||||
socket.on('create or join', function(room_id) {
|
console.log('serving on https://localhost:3535')
|
||||||
let room = io.sockets.adapter.rooms
|
|
||||||
})
|
|
||||||
})
|
|
Loading…
Reference in New Issue
Block a user