feat: remove unused data in subscription batcher

lib/graphql/resolver.ex

@@ -550,7 +550,7 @@ defmodule AshGraphql.Graphql.Resolver do
 
           subscription_events =
             notifications
-            |> Enum.group_by(& &1.action.type)
+            |> Enum.group_by(& &1.action_type)
             |> Enum.map(fn {type, notifications} ->
               subscription_field = subcription_field_from_action_type(type)
               key = String.to_existing_atom(subscription_field)
@@ -698,7 +698,7 @@ defmodule AshGraphql.Graphql.Resolver do
           ]
 
           cond do
-            notification.action.type in [:create, :update] ->
+            notification.action_type in [:create, :update] ->
               data = notification.data
               {filter, args} = Map.pop(args, :filter)
 
@@ -725,7 +725,7 @@ defmodule AshGraphql.Graphql.Resolver do
                   domain,
                   resolution,
                   subscription_result_type(name),
-                  [subcription_field_from_action_type(notification.action.type)]
+                  [subcription_field_from_action_type(notification.action_type)]
                 )
 
               result =
@@ -763,7 +763,7 @@ defmodule AshGraphql.Graphql.Resolver do
                     {:ok,
                      %{
                        String.to_existing_atom(
-                         subcription_field_from_action_type(notification.action.type)
+                         subcription_field_from_action_type(notification.action_type)
                        ) => result
                      }}
                   )
@@ -773,13 +773,13 @@ defmodule AshGraphql.Graphql.Resolver do
                   |> Absinthe.Resolution.put_result({:error, to_errors([error], context, domain)})
               end
 
-            notification.action.type in [:destroy] ->
+            notification.action_type in [:destroy] ->
               resolution
               |> Absinthe.Resolution.put_result(
                 {:ok,
                  %{
                    String.to_existing_atom(
-                     subcription_field_from_action_type(notification.action.type)
+                     subcription_field_from_action_type(notification.action_type)
                    ) => AshGraphql.Resource.encode_id(notification.data, false)
                  }}
               )

lib/subscription/batcher.ex

@@ -31,6 +31,12 @@ defmodule AshGraphql.Subscription.Batcher do
     end
   end
 
+  defmodule Notification do
+    @moduledoc false
+
+    defstruct [:action_type, :data]
+  end
+
   def start_link(opts \\ []) do
     GenServer.start_link(__MODULE__, opts, name: opts[:name] || __MODULE__)
   end

lib/subscription/notifier.ex

@@ -2,18 +2,24 @@ defmodule AshGraphql.Subscription.Notifier do
   @moduledoc """
   AshNotifier that triggers absinthe if subscriptions are listening
   """
-  alias AshGraphql.Resource.Info
   use Ash.Notifier
 
+  alias AshGraphql.Resource.Info
+  alias AshGraphql.Subscription.Batcher.Notification
+
   @impl Ash.Notifier
-  def notify(notification) do
+  def notify(%Ash.Notifier.Notification{} = notification) do
     pub_sub = Info.subscription_pubsub(notification.resource)
 
     for subscription <-
           AshGraphql.Resource.Info.subscriptions(notification.resource, notification.domain) do
       if notification.action.name in List.wrap(subscription.actions) or
            notification.action.type in List.wrap(subscription.action_types) do
-        Absinthe.Subscription.publish(pub_sub, notification, [{subscription.name, "*"}])
+        Absinthe.Subscription.publish(
+          pub_sub,
+          %Notification{action_type: notification.action.type, data: notification.data},
+          [{subscription.name, "*"}]
+        )
       end
     end