我有一个由GraphQL驱动的应用程序。查询和修改部分运行良好。我尝试添加GraphQL订阅。
服务器GraphQL订阅代码的灵感来自apollographql/subscriptions-transport-ws自述文件中的演示。
请查看代码中的注释以获取更多详细信息。
但是,
服务器GraphQL订阅代码的灵感来自apollographql/subscriptions-transport-ws自述文件中的演示。
请查看代码中的注释以获取更多详细信息。
import Koa from 'koa';
import Router from 'koa-router';
import graphqlHTTP from 'koa-graphql';
import asyncify from 'callback-to-async-iterator';
import { SubscriptionServer } from 'subscriptions-transport-ws';
import firebase from 'firebase-admin';
import { execute, subscribe } from 'graphql';
import { GraphQLObjectType, GraphQLString } from 'graphql';
const MeType = new GraphQLObjectType({
name: 'Me',
fields: () => ({
name: { type: GraphQLString },
// ...
}),
});
const listenMe = async (callback) => {
// Below the firebase API returns real-time data
return firebase
.database()
.ref('/users/123')
.on('value', (snapshot) => {
// snapshot.val() returns an Object including name field.
// Here I tested is correct, it always returns { name: 'Rose', ... }
// when some other fields inside got updated in database.
return callback(snapshot.val());
});
};
const Subscription = new GraphQLObjectType({
name: 'Subscription',
fields: () => ({
meChanged: {
type: MeType,
subscribe: () => asyncify(listenMe),
},
}),
});
const schema = new GraphQLSchema({
query: Query,
mutation: Mutation,
subscription: Subscription,
});
const app = new Koa();
app
.use(new Router()
.post('/graphql', async (ctx) => {
// ...
await graphqlHTTP({
schema,
graphiql: true,
})(ctx);
})
.routes());
const server = app.listen(3009);
SubscriptionServer.create(
{
schema,
execute,
subscribe,
},
{
server,
path: '/subscriptions',
},
);
我正在使用Altair GraphQL Client进行测试,因为它支持GraphQL订阅。
如屏幕截图所示,当数据库中的数据发生更改时,它确实会获取新数据。但是,
meChanged
为null
,并且不会抛出任何错误。有什么想法吗?谢谢