move resolve logic in existing resolver module

lib/graphql/resolver.ex

@@ -474,6 +474,29 @@ defmodule AshGraphql.Graphql.Resolver do
       end
   end
 
+  def resolve(
+        %{arguments: arguments, context: context} = resolution,
+        {api, resource, %AshGraphql.Resource.Subscription{}, _input?}
+      ) do
+    dbg()
+
+    result =
+      AshGraphql.Subscription.query_for_subscription(
+        resource,
+        api,
+        resolution
+      )
+      # > Ash.Query.filter(id == ^args.id)
+      |> Ash.Query.limit(1)
+      |> api.read_one(actor: resolution.context[:current_user])
+      |> dbg()
+
+    resolution
+    |> Absinthe.Resolution.put_result(result)
+
+    resolution
+  end
+
   defp read_one_query(resource, args) do
     case Map.fetch(args, :filter) do
       {:ok, filter} when filter != %{} ->

lib/resource/resource.ex

@@ -565,7 +565,9 @@ defmodule AshGraphql.Resource do
               raise "No such action #{query.action} on #{resource}"
 
           %Absinthe.Blueprint.Schema.FieldDefinition{
-            arguments: args(query.type, resource, query_action, schema, query.identity),
+            arguments:
+              args(query.type, resource, query_action, schema, query.identity)
+              |> IO.inspect(label: "args"),
             identifier: query.name,
             middleware:
               action_middleware ++
@@ -1010,6 +1012,9 @@ defmodule AshGraphql.Resource do
       dbg(config)
 
       %Absinthe.Blueprint.Schema.FieldDefinition{
+        arguments:
+          args(:subscription, resource, nil, schema, nil)
+          |> IO.inspect(label: "args"),
         identifier: name,
         name: to_string(name),
         config:
@@ -1022,8 +1027,7 @@ defmodule AshGraphql.Resource do
         middleware:
           action_middleware ++
             [
-              {{AshGraphql.Resource.Subscription.DefaultResolve, :resolve},
-               {api, resource, subscription, true}}
+              {{AshGraphql.Graphql.Resolver, :resolve}, {api, resource, subscription, true}}
             ],
         type: AshGraphql.Resource.Info.type(resource),
         __reference__: ref(__ENV__)
@@ -1532,6 +1536,28 @@ defmodule AshGraphql.Resource do
     read_args(resource, action, schema)
   end
 
+  defp args(:subscription, resource, _action, schema, _identity) do
+    if AshGraphql.Resource.Info.derive_filter?(resource) do
+      case resource_filter_fields(resource, schema) do
+        [] ->
+          []
+
+        _ ->
+          [
+            %Absinthe.Blueprint.Schema.InputValueDefinition{
+              name: "filter",
+              identifier: :filter,
+              type: resource_filter_type(resource),
+              description: "A filter to limit the results",
+              __reference__: ref(__ENV__)
+            }
+          ]
+      end
+    else
+      []
+    end
+  end
+
   defp read_args(resource, action, schema) do
     action.arguments
     |> Enum.reject(& &1.private?)

lib/resource/subscription.ex

@@ -2,11 +2,8 @@ defmodule AshGraphql.Resource.Subscription do
   @moduledoc "Represents a configured query on a resource"
   defstruct [
     :name,
-    # :arg = filter,
     :config,
     :read_action
-    # :topic, fn _, _ -> {:ok, topic} | :error,
-    # :trigger fn notification -> {:ok, topics}
   ]
 
   @subscription_schema [