diff --git a/realtime/src/socket.js b/realtime/src/socket.js index cbf639e..e09895d 100644 --- a/realtime/src/socket.js +++ b/realtime/src/socket.js @@ -12,7 +12,7 @@ module.exports = function setupSensorWebSocket(server) { server, path: wsPath, perMessageDeflate: false, - verifyClient: async (info, callback) => { + verifyClient: (info, callback) => { console.log('[WS|verifyClient] URL:', info.req.url); const { query } = url.parse(info.req.url, true); const token = query.token; @@ -22,17 +22,16 @@ module.exports = function setupSensorWebSocket(server) { return callback(false, 401, 'token not passed'); } - try { - const sessionData = await tokenStore.consumeToken(token); + tokenStore.consumeToken(token).then((sessionData) => { if (!sessionData) { return callback(false, 401, 'token not valid or expired'); } info.req.sensorSession = sessionData; callback(true); - } catch (error) { + }).catch((error) => { callback(false, 500, `internal server error: ${error}`); - } + }); } });