orchid

defmodule Orchid.Executor.Serial do
  @moduledoc """
  Serial Executor, implementing the behaviour of `Orchid.Executor`.

  It executes the steps within a Recipe sequentially, performing only
  one step at a time and waiting for its completion before proceeding
  to the next step.
  """
  @behaviour Orchid.Executor
  alias Orchid.Scheduler

  @impl true
  def execute(ctx, executor_opts \\ []), do: loop(ctx, executor_opts)

  defp loop(ctx, opts) do
    case Orchid.Executor.execute_next_step(ctx) do
      {:done, final_ctx} ->
        {:ok, Scheduler.get_results(final_ctx)}

      {:stuck, stuck_ctx} ->
        {:error, %Orchid.Error{reason: :stuck, context: stuck_ctx, kind: :exception}}

      {:cont, new_ctx} ->
        loop(new_ctx, opts)

      error ->
        error
    end
  end
end