estoy implementando subscripciones en graphql, estoy utilizando type-graphql para los resolvers, la aplicacion funciona bien, cuando creo una publicacion, antes de responder al usuario creo un pulisher
para activar la subscripcion, pero cuando la recibo en el cliente me aparece el siguiente error
Error: Cannot read property 'plugin' of undefined
at new ApolloError (index.ts:49)
at QueryManager.ts:708
at Object.next (Observable.js:322)
at notifySubscription (Observable.js:135)
at onNotify (Observable.js:179)
at SubscriptionObserver.next (Observable.js:235)
at iteration.ts:13
at Array.forEach (<anonymous>)
at iterateObserversSafely (iteration.ts:13)
at Object.next (Concast.ts:171)
at Object.handler (client.ts:218)
at SubscriptionClient.processReceivedData (client.ts:651)
at WebSocket.client.onmessage (client.ts:593)
este error me aparece por consola, este es el metodo con el que actualizo mi hook que contiene las publicaciones
const { loading: loadingSubPub, error: errorSubPub, data: dataSubPub } = useSubscription(get_subscription_publications);
useEffect(() => {
console.log(errorSubPub) // es el error que aparece en consola
if (dataSubPub) {
const { publications } = dataSubPub;
return setPublicaciones((prev) => {
return [...prev, publications];
});
}
}, [dataSubPub, errorSubPub]);
de esta manera guardo la publicacion del usuario y llamo a publisher
:
@Authorized()
@Mutation((returns) => PublicationResponse)
async post(
@Arg("data") data: IPublicacionInput,
@Ctx() { Models, user }: any,
@PubSub("PUBLICACIONES") publish: any
) {
try {
const usr: any = await Models.Usuarios.findById(user._id)
const publicacion = new Models.Publicaciones(data)
publicacion.usuario = usr._id
usr?.publicaciones.addToSet(publicacion._id)
await usr.save()
const new_publicacion = await publicacion.save()
const np = await Models.Publicaciones.findById(new_publicacion._id).populate("usuario")
publish(np)
return {success: true, message: "Publicacion creada con exito"}
} catch (error) {
console.error(error)
return {error: true, message: "Intentalo mas tarde." };
}
}
y de esta menera manejo la subscripcion
@Subscription((returns) => IPublicacion,{topics: "PUBLICACIONES"})
async publications(
@Root() publicacion: IPublicacion,
) {
return publicacion
}
sencillo, pero no me devuelve la nueva publicación, me sorprende por que estaba funcionando bien, me llama mucho la atención el Cannot read property 'plugin' of undefined
por que no estoy utilizando plugins.