From f483d69552c7de6935ff1c5e05bceef2b476d227 Mon Sep 17 00:00:00 2001
From: Barnabas Jovanovics <barnabas.jovanovics@gmail.com>
Date: Mon, 6 May 2024 09:24:10 +0200
Subject: [PATCH] wip

---
 lib/graphql/resolver.ex                     | 5 +++--
 lib/resource/subscription/default_config.ex | 2 +-
 lib/resource/subscription/notifier.ex       | 3 +--
 3 files changed, 5 insertions(+), 5 deletions(-)

diff --git a/lib/graphql/resolver.ex b/lib/graphql/resolver.ex
index 4a97c7c..1a049e6 100644
--- a/lib/graphql/resolver.ex
+++ b/lib/graphql/resolver.ex
@@ -518,9 +518,10 @@ defmodule AshGraphql.Graphql.Resolver do
         resolution
       )
       # > Ash.Query.filter(id == ^args.id)
-      |> Ash.Query.limit(1)
+      # |> Ash.Query.limit(1)
       |> api.read_one(actor: resolution.context[:current_user])
-      |> dbg()
+
+    dbg(result)
 
     resolution
     |> Absinthe.Resolution.put_result(result)
diff --git a/lib/resource/subscription/default_config.ex b/lib/resource/subscription/default_config.ex
index ed86f9a..52efd05 100644
--- a/lib/resource/subscription/default_config.ex
+++ b/lib/resource/subscription/default_config.ex
@@ -24,7 +24,7 @@ defmodule AshGraphql.Resource.Subscription.DefaultConfig do
                alter_source?: true
              ) do
           {:ok, true} ->
-            {:ok, topic: "*", context_id: "global"}
+            dbg({:ok, topic: "*", context_id: "global"})
 
           {:ok, true, filter} ->
             {:ok, topic: "*", context_id: Base.encode64(:erlang.term_to_binary(filter))}
diff --git a/lib/resource/subscription/notifier.ex b/lib/resource/subscription/notifier.ex
index 2ea844f..c012fe8 100644
--- a/lib/resource/subscription/notifier.ex
+++ b/lib/resource/subscription/notifier.ex
@@ -4,10 +4,9 @@ defmodule AshGraphql.Resource.Subscription.Notifier do
 
   @impl Ash.Notifier
   def notify(notification) do
-    dbg()
     pub_sub = Info.subscription_pubsub(notification.resource)
 
-    for subscription <- AshGraphql.Resource.Info.subscriptions(notification.resource) do
+    for subscription <- dbg(AshGraphql.Resource.Info.subscriptions(notification.resource)) do
       Absinthe.Subscription.publish(pub_sub, notification.data, [{subscription.name, "*"}])
     end
   end