我正在使用带有 GraphQL 订阅和订阅-传输-ws 的快速服务器。
我已使用给定频道设置订阅：
...
const subscriptionManager = new SubscriptionManager({
schema: executableSchema,
pubsub: pubsub,
setupFunctions: {
testRunChanged: (options, args) => {
return {
testRunChangedChannel: {
filter: (testRun) => {
return testRun.id === args.testRunId;
}
},
};
},
},
});
...收到突变后，在服务器上启动一个进程，测试运行的数据库条目在完成后更新。现在，当数据库操作的更新承诺通过时，应该通知客户端。
使用来自 pubsub 的发布功能，订阅管理器获取有关更新的测试运行的信息：
...
RunningTestDbService.setToFinished(testRun).then(updatedTestRun => {
pubsub.publish("testRunChangedChannel", updatedTestRun);
})
...订阅管理器根据发布的 testRun 和订阅的 testRunId 过滤订阅后，调用订阅解析器函数。要更新客户端，我必须再次获取更新的测试运行。
如何在订阅解析器函数中获取已发布的测试运行对象？
订阅和解析器如下所示：
...
`testRunChanged(testRunId: ID!): TestRun!`
...
Subscription: {
testRunChanged(_, { testRunId }) {
// need to fetch the test run from database again
return TestRunDbService.getTestRunWith(testRunId);
},
},
...