index.js 1.0 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647
  1. 'use strict';
  2. const http = require('http');
  3. const socket = require('socket.io');
  4. const server = http.createServer();
  5. const port = 11100;
  6. var io = socket(server, {
  7. pingInterval: 10000,
  8. pingTimeout: 5000
  9. });
  10. io.use((socket, next) => {
  11. if (socket.handshake.query.token === "UNITY") {
  12. next();
  13. } else {
  14. next(new Error("Authentication error"));
  15. }
  16. });
  17. io.on('connection', socket => {
  18. console.log('connection');
  19. setTimeout(() => {
  20. socket.emit('connection', {date: new Date().getTime(), data: "Hello Unity"})
  21. }, 1000);
  22. socket.on('hello', (data) => {
  23. console.log('hello', data);
  24. socket.emit('hello', {date: new Date().getTime(), data: data});
  25. });
  26. socket.on('spin', (data) => {
  27. console.log('spin');
  28. socket.emit('spin', {date: new Date().getTime(), data: data});
  29. });
  30. socket.on('class', (data) => {
  31. console.log('class', data);
  32. socket.emit('class', {date: new Date().getTime(), data: data});
  33. });
  34. });
  35. server.listen(port, () => {
  36. console.log('listening on *:' + port);
  37. });