aqib
06/30/2021, 10:35 AMconst buildMutationResolvers = (methods) =>
Object.entries(methods).reduce(
(resolvers, [queryName, queryFunc]) => ({
...resolvers,
[queryName]: async (parent, args, context, info) => {
const label = getPublishLabel(queryName)
// const data = await queryFunc(args, info)
if(label) {
pubsub.publish(label[0], { [label[1]]: args});
}
return queryFunc(args, info)
},
}),
{}
);