server.js 1.0 KB

123456789101112131415161718192021222324252627282930313233343536373839404142
  1. var app = require('express')();
  2. var server = require('http').createServer(app);
  3. var webRTC = require('webrtc.io').listen(server);
  4. var port = process.env.PORT || 8881;
  5. server.listen(port);
  6. app.get('/', function(req, res) {
  7. res.sendFile(__dirname + '/index.html');
  8. });
  9. app.get('/style.css', function(req, res) {
  10. res.sendFile(__dirname + '/style.css');
  11. });
  12. app.get('/script.js', function(req, res) {
  13. res.sendFile(__dirname + '/script.js');
  14. });
  15. app.get('/webrtc.io.js', function(req, res) {
  16. res.sendFile(__dirname + '/webrtc.io.js');
  17. });
  18. webRTC.rtc.on('chat_msg', function(data, socket) {
  19. var roomList = webRTC.rtc.rooms[data.room] || [];
  20. for (var i = 0; i < roomList.length; i++) {
  21. var socketId = roomList[i];
  22. if (socketId !== socket.id) {
  23. var soc = webRTC.rtc.getSocket(socketId);
  24. if (soc) {
  25. soc.send(JSON.stringify({
  26. "eventName": "receive_chat_msg",
  27. "data": {
  28. "messages": data.messages,
  29. "color": data.color
  30. }
  31. }), function(error) {
  32. if (error) {
  33. console.log(error);
  34. }
  35. });
  36. }
  37. }
  38. }
  39. });