server.js 1.4 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566
  1. var app = require('express')();
  2. var server = require('http').createServer(app);
  3. var webRTC = require('webrtc.io').listen(server);
  4. server.listen(8000);
  5. app.get('/', function(req, res) {
  6. res.sendfile(__dirname + '/index.html');
  7. });
  8. app.get('/style.css', function(req, res) {
  9. res.sendfile(__dirname + '/style.css');
  10. });
  11. app.get('/fullscrean.png', function(req, res) {
  12. res.sendfile(__dirname + '/fullscrean.png');
  13. });
  14. app.get('/script.js', function(req, res) {
  15. res.sendfile(__dirname + '/script.js');
  16. });
  17. app.get('/webrtc.io.js', function(req, res) {
  18. res.sendfile(__dirname + '/webrtc.io.js');
  19. });
  20. webRTC.rtc.on('connect', function(rtc) {
  21. //Client connected
  22. });
  23. webRTC.rtc.on('send answer', function(rtc) {
  24. //answer sent
  25. });
  26. webRTC.rtc.on('disconnect', function(rtc) {
  27. //Client disconnect
  28. });
  29. webRTC.rtc.on('chat_msg', function(data, socket) {
  30. var roomList = webRTC.rtc.rooms[data.room] || [];
  31. for (var i = 0; i < roomList.length; i++) {
  32. var socketId = roomList[i];
  33. if (socketId !== socket.id) {
  34. var soc = webRTC.rtc.getSocket(socketId);
  35. if (soc) {
  36. soc.send(JSON.stringify({
  37. "eventName": "receive_chat_msg",
  38. "data": {
  39. "messages": data.messages,
  40. "color": data.color
  41. }
  42. }), function(error) {
  43. if (error) {
  44. console.log(error);
  45. }
  46. });
  47. }
  48. }
  49. }
  50. });