From e6416f5725ece424b69a142b70de4a0ca6687869 Mon Sep 17 00:00:00 2001 From: frankpagan Date: Mon, 27 Nov 2023 06:00:01 -0600 Subject: [PATCH] fix: async await upgrade to handle authenticate --- src/index.js | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/src/index.js b/src/index.js index 152eede..da554f5 100644 --- a/src/index.js +++ b/src/index.js @@ -30,7 +30,7 @@ class SocketServer extends EventEmitter { let organization_id = request.url.split('/') organization_id = organization_id[organization_id.length - 1] - this.wss.handleUpgrade(request, socket, head, function (socket) { + this.wss.handleUpgrade(request, socket, head, async function (socket) { if (organization_id) { let organization = self.organizations.get(organization_id) if (organization && organization.status === false) { @@ -87,7 +87,7 @@ class SocketServer extends EventEmitter { self.emit('object.read', data); if (self.authenticate) { - const { user_id, expires } = self.authenticate.decodeToken(options.token) + const { user_id, expires } = await self.authenticate.decodeToken(options.token, organization_id, options.clientId) const userStatus = { socket, method: 'userStatus', user_id: options.user_id, clientId: options.clientId, userStatus: 'off', organization_id } if (user_id) { options.user_id = user_id