mirror/api
1
0
Fork 0
mirror of https://github.com/unraid/api.git synced 2026-01-07 09:10:05 -06:00
Code Issues Packages Projects Releases Wiki Activity

fix(module:graphql/index): replace user onConnect/onDisconnect logging

Browse Source 
Remove the old `clients` Map and ws-clients field on $injector and replace with context object
This commit is contained in:
Alexis Tyler
2019-12-09 12:29:22 +10:30
parent 2ee8c731d0
commit 5971fce4e7
1 changed files with 5 additions and 18 deletions
Download Patch File Download Diff File Expand all files Collapse all files

23
app/graphql/index.js
View File

@@ -285,10 +285,6 @@ module.exports = function (
}
};
// Connected ws clients
const clients = new Map();
$injector.registerValue('ws-clients', clients);
const {debug} = config;
return {
introspection: debug,
@@ -297,30 +293,21 @@ module.exports = function (
types,
resolvers,
subscriptions: {
onConnect: (connectionParams, webSocket) => {
onConnect: connectionParams => {
const apiKey = connectionParams['x-api-key'];
ensureApiKey(apiKey);
const user = Users.findOne({apiKey}) || {name: 'guest', apiKey, role: 'guest'};
log.debug(`<ws> ${user.name} connected.`);
clients.set(webSocket, user);
$injector.registerValue('ws-clients', clients);
log.info(`<ws> ${user.name} connected.`);
return {
user
};
},
onDisconnect: webSocket => {
// Const user = clients.get(webSocket);
// log.debug(`<ws> ${user.name} disconnected.`);
//
// // If we don't wait a tick `user` becomes undefined.
process.nextTick(() => {
clients.delete(webSocket);
$injector.registerValue('ws-clients', clients);
});
onDisconnect: async (_, context) => {
const initialContext = await context.initPromise;
log.info(`<ws> ${initialContext.user.name} disconnected.`);
}
},
context: ({req, connection}) => {