ash-project/ash_graphql
1
0
Fork 0
mirror of https://github.com/ash-project/ash_graphql.git synced 2024-09-20 13:24:14 +12:00
Code Issues Projects Releases Packages Wiki Activity

wip

Browse source
This commit is contained in:
Barnabas Jovanovics 2024-05-06 09:24:10 +02:00
parent c4f08da18a
commit f483d69552
3 changed files with 5 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

5
lib/graphql/resolver.ex
View file

@ -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)

2
lib/resource/subscription/default_config.ex
View file

@ -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))}

3
lib/resource/subscription/notifier.ex
View file

@ -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