Merge pull request #1270 from absinthe-graphql/initial-phases-mfa

Initial phases mfa
absinthe-graphql · Aug 16, 2023 · 4c1d692 · 4c1d692
2 parents 8a5c293 + 173d6d1
commit 4c1d692
Show file tree

Hide file tree

Showing 2 changed files with 11 additions and 2 deletions.
diff --git a/lib/absinthe/blueprint.ex b/lib/absinthe/blueprint.ex
@@ -43,7 +43,7 @@ defmodule Absinthe.Blueprint do
           source: nil | String.t() | Absinthe.Language.Source.t(),
           execution: Blueprint.Execution.t(),
           result: result_t,
-          initial_phases: [Absinthe.Phase.t()]
+          initial_phases: [Absinthe.Phase.t()] | {module(), atom, list()}
         }
 
   @type result_t :: %{

diff --git a/lib/absinthe/subscription/pipeline_serializer.ex b/lib/absinthe/subscription/pipeline_serializer.ex
@@ -18,7 +18,12 @@ defmodule Absinthe.Subscription.PipelineSerializer do
 
   @type packed_pipeline :: {:packed, [packed_phase_config()], options_map()}
 
-  @spec pack(Pipeline.t()) :: packed_pipeline()
+  @spec pack(Pipeline.t() | {module(), atom, list()}) :: packed_pipeline()
+  def pack({module, function, args})
+      when is_atom(module) and is_atom(function) and is_list(args) do
+    {module, function, args}
+  end
+
   def pack(pipeline) do
     {packed_pipeline, reverse_map} =
       pipeline
@@ -41,6 +46,10 @@ defmodule Absinthe.Subscription.PipelineSerializer do
     end)
   end
 
+  def unpack({module, function, args}) do
+    apply(module, function, args)
+  end
+
   def unpack([_ | _] = pipeline) do
     pipeline
   end