Update api.js #247
13
src/api.js
13
src/api.js
@ -35,14 +35,19 @@ const Server = require("http").createServer(app);
|
|||||||
const SocketIo = require("socket.io");
|
const SocketIo = require("socket.io");
|
||||||
const io = new SocketIo.Server(Server);
|
const io = new SocketIo.Server(Server);
|
||||||
io.use(function (socket, next) {
|
io.use(function (socket, next) {
|
||||||
if (socket.handshake.query.token) {
|
const { headers, query } = socket.handshake;
|
||||||
if (BdsChecks.token_verify(socket.handshake.query.token)) {
|
const Token = headers["AuthorizationToken"] || query["token"] || query["Token"];
|
||||||
socket.token = socket.handshake.query.token;
|
if (Token) {
|
||||||
next();
|
if (BdsChecks.token_verify(Token)) {
|
||||||
|
socket.token = Token;
|
||||||
|
return next();
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
return next(new Error("Token is not valid"));
|
return next(new Error("Token is not valid"));
|
||||||
});
|
});
|
||||||
|
io.on("connection", socket => {
|
||||||
|
console.log("Socket.io connection ID:", socket.token);
|
||||||
|
});
|
||||||
module.exports.SocketIO = io;
|
module.exports.SocketIO = io;
|
||||||
|
|
||||||
// Routes
|
// Routes
|
||||||
|
Reference in New Issue
Block a user