1  defmodule EchoShared.Workflow.FlowTest do
 2    use ExUnit.Case, async: false
 3  
 4    defmodule TestFlow do
 5      use EchoShared.Workflow.Flow
 6  
 7      @start
 8      def start_step(state) do
 9        Map.put(state, :started, true)
10      end
11  
12      @router :start_step
13      def route_decision(state) do
14        if Map.get(state, :go_left, false) do
15          "left"
16        else
17          "right"
18        end
19      end
20  
21      @listen "left"
22      def handle_left(state) do
23        Map.put(state, :direction, :left)
24      end
25  
26      @listen "right"
27      def handle_right(state) do
28        Map.put(state, :direction, :right)
29      end
30    end
31  
32    describe "Flow DSL" do
33      test "captures start functions" do
34        starts = TestFlow.get_starts()
35        assert is_list(starts)
36        assert length(starts) > 0
37      end
38  
39      test "captures routers" do
40        metadata = TestFlow.__flow_metadata__()
41        assert is_map(metadata)
42        assert Map.has_key?(metadata, :routers)
43      end
44  
45      test "captures listeners" do
46        listeners = TestFlow.get_listeners("left")
47        assert is_list(listeners)
48      end
49  
50      test "has_router? works" do
51        assert TestFlow.has_router?(:start_step)
52        refute TestFlow.has_router?(:nonexistent)
53      end
54  
55      test "execute_step works" do
56        state = TestFlow.execute_step(:start_step, %{})
57        assert state[:started] == true
58      end
59  
60      test "route_after works" do
61        label = TestFlow.route_after(:start_step, %{go_left: true})
62        assert label == "left"
63  
64        label = TestFlow.route_after(:start_step, %{go_left: false})
65        assert label == "right"
66      end
67    end
68  end