87 lines
2.8 KiB
JavaScript
87 lines
2.8 KiB
JavaScript
require('dotenv').config();
|
|
|
|
var twilio = require('twilio')(process.env.TWILIO_ACCOUNT_SID, process.env.TWILIO_AUTH_TOKEN);
|
|
var express = require('express');
|
|
var app = express();
|
|
var http = require('http').createServer(app);
|
|
var io = require('socket.io')(http);
|
|
var path = require('path');
|
|
var public = path.join(__dirname, 'public');
|
|
|
|
app.use(express.static('public'));
|
|
|
|
app.get('/', function (req, res) {
|
|
res.sendFile(path.join(public, 'chat.html'));
|
|
});
|
|
|
|
app.get('/landing', function (req, res) {
|
|
res.sendFile(path.join(public, 'landing.html'));
|
|
});
|
|
|
|
function log(msg, room) {
|
|
console.log(room + ": " + msg)
|
|
}
|
|
|
|
// When a socket connects, set up the specific listeners we will use.
|
|
io.on('connection', function (socket) {
|
|
// When a client tries to join a room, only allow them if they are first or
|
|
// second in the room. Otherwise it is full.
|
|
socket.on('join', function (room) {
|
|
log('A client joined the room', room);
|
|
var clients = io.sockets.adapter.rooms[room];
|
|
var numClients = typeof clients !== 'undefined' ? clients.length : 0;
|
|
if (numClients === 0) {
|
|
socket.join(room);
|
|
} else if (numClients === 1) {
|
|
socket.join(room);
|
|
// When the client is second to join the room, both clients are ready.
|
|
log('Broadcasting ready message', room);
|
|
socket.broadcast.to(room).emit('willInitiateCall', room);
|
|
socket.emit('ready', room).to(room);
|
|
socket.broadcast.to(room).emit('ready', room);
|
|
} else {
|
|
log("room already full", room);
|
|
socket.emit('full', room);
|
|
}
|
|
});
|
|
|
|
// When receiving the token message, use the Twilio REST API to request an
|
|
// token to get ephemeral credentials to use the TURN server.
|
|
socket.on('token', function (room) {
|
|
log('Received token request', room);
|
|
twilio.tokens.create(function (err, response) {
|
|
if (err) {
|
|
log(err, room);
|
|
} else {
|
|
log('Token generated. Returning it to the browser client', room);
|
|
socket.emit('token', response).to(room);
|
|
}
|
|
});
|
|
});
|
|
|
|
// Relay candidate messages
|
|
socket.on('candidate', function (candidate, room) {
|
|
log('Received candidate. Broadcasting...', room);
|
|
socket.broadcast.to(room).emit('candidate', candidate);
|
|
});
|
|
|
|
// Relay offers
|
|
socket.on('offer', function (offer, room) {
|
|
log('Received offer. Broadcasting...', room);
|
|
socket.broadcast.to(room).emit('offer', offer);
|
|
});
|
|
|
|
// Relay answers
|
|
socket.on('answer', function (answer, room) {
|
|
log('Received answer. Broadcasting...', room);
|
|
socket.broadcast.to(room).emit('answer', answer);
|
|
});
|
|
});
|
|
|
|
|
|
var port = process.env.PORT || 3000;
|
|
http.listen(port, function () {
|
|
console.log("http://localhost:" + port);
|
|
});
|
|
|