From dd6b0de41479a1082bf7486014a9258c1ca2b526 Mon Sep 17 00:00:00 2001 From: Noah Metz Date: Mon, 3 Jul 2023 19:37:04 -0600 Subject: [PATCH] fix --- gql_graph.go | 7 ++----- 1 file changed, 2 insertions(+), 5 deletions(-) diff --git a/gql_graph.go b/gql_graph.go index bd3e68e..8461cc4 100644 --- a/gql_graph.go +++ b/gql_graph.go @@ -700,17 +700,14 @@ func GQLTypeSignalInput() *graphql.InputObject { func GQLSubscribeSignal(p graphql.ResolveParams) (interface{}, error) { return GQLSubscribeFn(p, func(signal GraphSignal, p graphql.ResolveParams)(interface{}, error) { - ctx := p.Context.Value("graph_context").(*GraphContext) - ctx.Log.Logf("gql", "SUBSCRIBE_SIGNAL: %+v", p.Source) return signal, nil }) } func GQLSubscribeSelf(p graphql.ResolveParams) (interface{}, error) { + server := p.Context.Value("gql_server").(*GQLThread) return GQLSubscribeFn(p, func(signal GraphSignal, p graphql.ResolveParams)(interface{}, error) { - ctx := p.Context.Value("graph_context").(*GraphContext) - ctx.Log.Logf("gql", "SUBSCRIBE_SELF: %+v", p.Source) - return p.Source, nil + return server, nil }) }