github/peerjs-server
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

fix

Browse Source
This commit is contained in:
afrokick 2019-04-01 15:14:24 +03:00
parent 0aa52c488a
commit 9a89394c11
3 changed files with 5 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/index.js
View File

@ -9,7 +9,7 @@ const logger = require('./services/logger');
const api = require('./api'); const api = require('./api');
const messageHandler = require('./messageHandler'); const messageHandler = require('./messageHandler');
const realm = require('./services/realm'); const realm = require('./services/realm');
const MessageType = require('./enums'); const { MessageType } = require('./enums');
// parse config // parse config
let path = config.get('path'); let path = config.get('path');

2
src/messageHandler/handlers/transmission/index.js
View File

@ -1,6 +1,6 @@
const realm = require('../../../services/realm'); const realm = require('../../../services/realm');
const logger = require('../../../services/logger'); const logger = require('../../../services/logger');
const MessageType = require('../../../enums'); const { MessageType } = require('../../../enums');
const handler = (client, message) => { const handler = (client, message) => {
const type = message.type; const type = message.type;

5
src/messageHandler/index.js
View File

@ -1,10 +1,11 @@
const logger = require('../services/logger'); const logger = require('../services/logger');
const MessageType = require('../enums'); const { MessageType } = require('../enums');
const transmissionHandler = require('./handlers/transmission'); const transmissionHandler = require('./handlers/transmission');
const handlers = {}; const handlers = {};
const registerHandler = (messageType, handler) => { const registerHandler = (messageType, handler) => {
logger.info(`[MSGHANDLER] register handler for ${messageType}`);
handlers[messageType] = handler; handlers[messageType] = handler;
}; };
@ -14,7 +15,7 @@ module.exports = (client, message) => {
const handler = handlers[type]; const handler = handlers[type];
if (!handler) { if (!handler) {
return logger.error(`Message unrecognized:${type}`); return logger.error(`[MSGHANDLER] Message unrecognized:${type}`);
} }
handler(client, message); handler(client, message);