69 lines
2.4 KiB
JavaScript
69 lines
2.4 KiB
JavaScript
|
const User = require('../../../models/User');
|
||
|
|
const secret = require('../../../secret');
|
||
|
|
const config = require('../../../config');
|
||
|
|
|
||
|
|
const jwt = require('jsonwebtoken');
|
||
|
|
const siolib = require('socket.io')
|
||
|
|
|
||
|
|
class GatewayServer {
|
||
|
|
constructor(httpServer) {
|
||
|
|
this._io = siolib(httpServer);
|
||
|
|
this._gateway = this._io.of('/gateway');
|
||
|
|
this.eventSetup();
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
GatewayServer.prototype.authDisconnect = function(socket, callback) {
|
||
|
|
socket.isConnected = false;
|
||
|
|
socket.disconnect(true);
|
||
|
|
callback(new Error('ERR_GATEWAY_AUTH_FAIL'));
|
||
|
|
};
|
||
|
|
|
||
|
|
GatewayServer.prototype.eventSetup = function() {
|
||
|
|
this._gateway.use((socket, callback) => {
|
||
|
|
console.log('[*] [gateway] User authentication attempt');
|
||
|
|
socket.isConnected = false;
|
||
|
|
|
||
|
|
setTimeout(() => {
|
||
|
|
console.log('[*] [gateway] User still not connected after timeout, removing...');
|
||
|
|
socket.disconnect(true);
|
||
|
|
}, config.gatewayStillNotConnectedTimeoutMS);
|
||
|
|
|
||
|
|
// TODO: Maybe passing the token in the query is not the best idea?
|
||
|
|
const token = socket.handshake.query.token;
|
||
|
|
|
||
|
|
if (!token) return this.authDisconnect(socket, callback);
|
||
|
|
|
||
|
|
jwt.verify(token, secret.jwtPrivateKey, {}, async (err, data) => {
|
||
|
|
if (err) return this.authDisconnect(socket, callback);
|
||
|
|
if (!data) return this.authDisconnect(socket, callback);
|
||
|
|
if (!data.username) return this.authDisconnect(socket, callback);
|
||
|
|
|
||
|
|
const user = await User.findByUsername(data.username);
|
||
|
|
|
||
|
|
if (!user) return this.authDisconnect(socket, callback);
|
||
|
|
|
||
|
|
let permissionLevel = config.roleMap[user.role];
|
||
|
|
if (!permissionLevel) {
|
||
|
|
permissionLevel = 0;
|
||
|
|
}
|
||
|
|
|
||
|
|
if (permissionLevel < config.roleMap.USER) return this.authDisconnect(socket, callback);
|
||
|
|
|
||
|
|
socket.username = data.username;
|
||
|
|
console.log(`[*] [gateway] User ${data.username} has successfully authenticated`);
|
||
|
|
return callback();
|
||
|
|
});
|
||
|
|
});
|
||
|
|
|
||
|
|
this._gateway.on('connection', (socket) => {
|
||
|
|
console.log(`[*] [gateway] User ${socket.username} connected, sending hello and waiting for yoo...`);
|
||
|
|
socket.emit('hello');
|
||
|
|
socket.once('yoo', () => {
|
||
|
|
console.log(`[*] [gateway] Got yoo from ${socket.username}, connection is finally completed!`);
|
||
|
|
socket.isConnected = true;
|
||
|
|
});
|
||
|
|
});
|
||
|
|
};
|
||
|
|
|
||
|
|
module.exports = GatewayServer;
|