mirror/api
1
0
Fork 0
mirror of https://github.com/unraid/api.git synced 2026-01-15 21:19:53 -06:00
Code Issues Packages Projects Releases Wiki Activity

fix(module:graphql/schema/resolvers): only update when clients connect

Browse Source
This commit is contained in:
Alexis Tyler
2019-11-10 11:14:47 +10:30
parent b5e4ed1ccf
commit 22ff4c14d1
1 changed files with 6 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

11
app/graphql/schema/resolvers.js
View File

@@ -146,14 +146,14 @@ module.exports = function (
// console.log(`CHANNEL: ping DATA: ${JSON.stringify(rest, null, 2)}`);
// });
bus.on('disks', limiter.wrap(async () => {
pubsub.subscribe('disks', limiter.wrap(async () => {
await run('array', 'UPDATED', {
moduleToRun: 'get-array',
context: {}
});
}));
const {withFilter} = $injector.resolve('graphql-subscriptions');
const { withFilter } = $injector.resolve('graphql-subscriptions');
const createBasicSubscription = name => ({
subscribe: async () => {
@@ -167,7 +167,7 @@ module.exports = function (
return;
}
const {json} = await $injector.resolveModule('module:info/get-apps');
const { json } = await $injector.resolveModule('module:info/get-apps');
pubsub.publish('info', {
info: {
mutation: 'UPDATED',
@@ -183,6 +183,7 @@ module.exports = function (
dee.listen();
// Republish bus events to pubsub when clients connect
bus.on('*', (...args) => {
if (!canPublishToClients()) {
return;
@@ -262,7 +263,7 @@ module.exports = function (
},
pluginModule: {
subscribe: async (_, directiveArgs) => {
const {plugin: pluginName, module: pluginModuleName} = directiveArgs;
const { plugin: pluginName, module: pluginModuleName } = directiveArgs;
const name = `${pluginName}/${pluginModuleName}`;
// Verify plugin is installed and active
@@ -294,4 +295,4 @@ module.exports = function (
}
}
};
};
};