diff --git a/gql_graph.go b/gql_graph.go index 43bf721..82e88a3 100644 --- a/gql_graph.go +++ b/gql_graph.go @@ -700,12 +700,16 @@ 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) { 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 }) }