Quiqup.DispatchOrderStagePipeline

quiqup.dispatch_order_stage_pipeline.ex

defmodule Quiqup.DispatchOrderStagePipeline do
  def call(%{order_id: order_id}) do
    with {:ok, %{courier: courier} = order} <- validate_order(order),
         {:ok, true} <- courier_available?(courier),
         {:ok, next_stage_slug} <- next_stage_slug_by(order),
         {:persist_stage, {:ok, %Stage{} = stage}}
             <- {:persist_stage, %{order: order} |> create_stage(next_stage_slug)},
         {:push_notification, :ok}
             <- {:push_notification, push_notification(%{courier: courier, stage: stage})},
         {:emit_event, :ok}
             <- {:emit_event, emit_event(%{courier: courier, stage: stage})} do
        {:ok, stage}
    else
        e -> {:error, e}
    end
  end
end