require "test_helper"

class FastTrackTest < Minitest::Spec
  # #success passes fast.
  class Retrieve < Trailblazer::Operation
    pass ->(options, **) { options["x"] = options["dont_fail"] }, pass_fast: true
    fail ->(options, **) { options["b"] = true }
    step ->(options, **) { options["y"] = true }
  end
  it { Retrieve.("dont_fail" => true).inspect("x", "b", "y").must_equal %{<Result:true [true, nil, nil] >} }
  it { Retrieve.("dont_fail" => false).inspect("x", "b", "y").must_equal %{<Result:true [false, nil, nil] >} }

  # #step fails fast if option set and returns false.
  class Update < Trailblazer::Operation
    step ->(options, *) { options["x"] = true }
    step ->(options, *) { options["a"] = options["dont_fail"] }, fail_fast: true # only on false.
    fail ->(options, *) { options["b"] = true }
    step ->(options, *) { options["y"] = true }
  end

  it { Update.("dont_fail" => true).inspect("x", "a", "b", "y").must_equal %{<Result:true [true, true, nil, true] >} }
  it { Update.({}).inspect("x", "a", "b", "y").must_equal %{<Result:false [true, nil, nil, nil] >} }

  # #step passes fast if option set and returns true.
  class Delete < Trailblazer::Operation
    step ->(options, *) { options["x"] = true }
    step ->(options, *) { options["a"] = options["dont_fail"] }, pass_fast: true # only on true.
    fail ->(options, *) { options["b"] = true }
    step ->(options, *) { options["y"] = true }
  end

  it { Delete.("dont_fail" => true).inspect("x", "a", "b", "y").must_equal %{<Result:true [true, true, nil, nil] >} }
  it { Delete.({}).inspect("x", "a", "b", "y").must_equal %{<Result:false [true, nil, true, nil] >} }
end

class FailBangTest < Minitest::Spec
  class Create < Trailblazer::Operation
    step ->(options, *) { options["x"] = true; Railway.fail! }
    step ->(options, *) { options["y"] = true }
    fail ->(options, *) { options["a"] = true }
  end

  it { Create.().inspect("x", "y", "a").must_equal %{<Result:false [true, nil, true] >} }
end

class PassBangTest < Minitest::Spec
  class Create < Trailblazer::Operation
    step ->(options, *) { options["x"] = true; Railway.pass! }
    step ->(options, *) { options["y"] = true }
    fail ->(options, *) { options["a"] = true }
  end

  it { Create.().inspect("x", "y", "a").must_equal %{<Result:true [true, true, nil] >} }
end

class FailFastBangTest < Minitest::Spec
  class Create < Trailblazer::Operation
    step ->(options, *) { options["x"] = true; Railway.fail_fast! }
    step ->(options, *) { options["y"] = true }
    fail ->(options, *) { options["a"] = true }
  end

  # without proper configuration, emitting a FastTrack signal is illegal.
  it { assert_raises(Trailblazer::Activity::Circuit::IllegalSignalError) { Create.().inspect("x", "y", "a").must_equal %{<Result:false [true, nil, nil] >} } }

  class Update < Trailblazer::Operation
    step ->(options, *) { options["x"] = true; Railway.fail_fast! }, fast_track: true
    step ->(options, *) { options["y"] = true }
    fail ->(options, *) { options["a"] = true }
  end

  it { Update.().inspect("x", "y", "a").must_equal %{<Result:false [true, nil, nil] >} }
end

class PassFastBangTest < Minitest::Spec
  class Create < Trailblazer::Operation
    step ->(options, *) { options["x"] = true; Railway.pass_fast! }, fast_track: true
    step ->(options, *) { options["y"] = true }
    fail ->(options, *) { options["a"] = true }
  end

  it { Create.().inspect("x", "y", "a").must_equal %{<Result:true [true, nil, nil] >} }
end

#-
class NestedFastTrackTest < Minitest::Spec
  #- The ::step DSL method automatically connects the nested's End.fail_fast/End.pass_fast to Update's End.fail_fast/End.pass_fast.
  #
  # Edit has fast-tracked steps, so it has outputs :success/:fail/:pass_fast/:fail_fast.
  class Edit < Trailblazer::Operation
    step :a, fast_track: true # task is connected to End.pass_fast and End.fail_fast.

    def a(options, edit_return:, **)
      options["a"] = 1
      edit_return # End.success, End.pass_fast, etc.
    end
  end

  module Steps
    def b(options, a:, **)
      options["b"] = a + 1
    end

    def f(options, **)
      options["f"] = 3
    end
  end

  describe "Nested, fast_track: true and all its outputs given" do
    let(:update) do
      Class.new(Trailblazer::Operation) do
        step Subprocess(Edit), fast_track: true
        step :b
        fail :f

        include Steps
      end
    end

    # Edit returns End.success
    it { update.(edit_return: true).inspect("a", "b", "f").must_equal %{<Result:true [1, 2, nil] >} }
    # Edit returns End.fail
    it { update.(edit_return: false).inspect("a", "b", "f").must_equal %{<Result:false [1, nil, 3] >} }
    # Edit returns End.pass_fast
    it { update.(edit_return: Trailblazer::Operation::Railway.pass_fast!).inspect("a", "b", "f").must_equal %{<Result:true [1, nil, nil] >} }
    # Edit returns End.fail_fast
    it { update.(edit_return: Trailblazer::Operation::Railway.fail_fast!).inspect("a", "b", "f").must_equal %{<Result:false [1, nil, nil] >} }
  end

  describe "Nested, no :fast_track option but all its outputs given" do
    let(:update) do
      Class.new(Trailblazer::Operation) do
        include Steps

        step Subprocess(Edit), Output(:pass_fast) => Track(:pass_fast), Output(:fail_fast) => Track(:fail_fast)
        step :b
        fail :f
      end
    end

    # Edit returns End.success
    it { update.(edit_return: true).inspect("a", "b", "f").must_equal %{<Result:true [1, 2, nil] >} }
    # Edit returns End.fail
    it { update.(edit_return: false).inspect("a", "b", "f").must_equal %{<Result:false [1, nil, 3] >} }
    # Edit returns End.pass_fast
    it { update.(edit_return: Trailblazer::Operation::Railway.pass_fast!).inspect("a", "b", "f").must_equal %{<Result:true [1, nil, nil] >} }
    # Edit returns End.fail_fast
    it { update.(edit_return: Trailblazer::Operation::Railway.fail_fast!).inspect("a", "b", "f").must_equal %{<Result:false [1, nil, nil] >} }
  end

  describe "2.0 behavior: no :fast_track option, all outputs given, but we rewire fast_track" do
    let(:update) do
      Class.new(Trailblazer::Operation) do
        include Steps

        step Subprocess(Edit),
             # manually rewire the fast-track outputs to "conventional" railway ends.
             Output(:pass_fast) => Track(:success),
             Output(:fail_fast) => Track(:failure)

        step :b
        fail :f
      end
    end

    # it { puts Trailblazer::Activity::Introspect.Cct(update.instance_variable_get(:@process)) }
    it { update.to_h }
    # Edit returns End.success
    it { update.(edit_return: true).inspect("a", "b", "f").must_equal %{<Result:true [1, 2, nil] >} }
    # Edit returns End.fail
    it { update.(edit_return: false).inspect("a", "b", "f").must_equal %{<Result:false [1, nil, 3] >} }
    # Edit returns End.pass_fast, but behaves like :success.
    it { update.(edit_return: Trailblazer::Operation::Railway.pass_fast!).inspect("a", "b", "f").must_equal %{<Result:true [1, 2, nil] >} }
    # Edit returns End.fail_fast, but behaves like :fail.
    it { update.(edit_return: Trailblazer::Operation::Railway.fail_fast!).inspect("a", "b", "f").must_equal %{<Result:false [1, nil, 3] >} }
  end
end