pipeline Ecto Multi

pipeline.ex

  @spec pipeline(any) :: (() -> any)
  def pipeline(params) do
    create_operation = fn (multi, params) ->
      Ecto.Multi.run(multi, :create_operation, fn _, _ ->
        Logger.info("create_operation")
        {:ok, nil}
      end)
    end

    verify_condition = fn (multi, params) ->
      Ecto.Multi.run(multi, :verify_condition, fn _, _ ->
        Logger.info("verify_condition")
        {:ok, nil}
      end)
    end

    other_create_operation = fn (multi, params) ->
      Ecto.Multi.run(multi, :other_create_operation, fn _, _ ->
        Logger.info("other_create_operation")
        {:ok, nil}
      end)
    end

    other_verify_condition = fn (multi, params) ->
      Ecto.Multi.run(multi, :other_verify_condition, fn _, _ ->
        Logger.info("other_verify_condition")
        {:ok, nil}
      end)
    end

    fn ->
      Ecto.Multi.new()
      |> create_operation.(params)
      |> verify_condition.(params)
      |> other_create_operation.(params)
      |> other_verify_condition.(params)
      |> Repo.transaction()
      |> Tracing.set_error()
    end
  end