helen

defmodule ReefTest do
  @moduledoc false

  use ExUnit.Case, async: false

  use HelenTest

  setup do
    :ok
  end

  @moduletag :reef
  setup_all do
    switches = [
      "mix_pump",
      "mix_air",
      "mix_rodi",
      "mix_rodi_boost",
      "display tank ato",
      "display_tank_heater",
      "mixtank_heater"
    ]

    need_switches(switches, sw_prefix: "reef_dev", test_group: "reef")

    for dc <- prod_dutycycles(), do: Dutycycle.Server.add(dc)

    sensors = ["display_tank", "mixtank"]

    for sensor <- sensors do
      create_temp_sensor(name: sensor)
    end

    :ok
  end

  # @tag :skip
  test "Reef CLI" do
    rc = Reef.status(clear_screen: false)

    assert :ok == rc
  end

  # @tag :skip
  test "keep_fresh()" do
    Reef.keep_fresh()

    assert true
  end

  # @tag :skip
  test "mix_air()" do
    Reef.air("fast")
    assert true
  end

  test "can invoke water_change_begin" do
    {rc, res} = Reef.water_change_begin(interactive: false)
    assert rc == :failed
    assert tuple_size(res) > 1
  end

  defp base(:msg) do
    import TimeSupport, only: [unix_now: 1, utc_now: 0]

    %{
      host: random_host(),
      name: "reef:display",
      hw: "esp32",
      vsn: "b4edefc",
      mtime: unix_now(:second),
      msg_recv_dt: utc_now(),
      log: false
    }
  end

  defp create_temp_sensor(opts) do
    name = Keyword.get(opts, :name)
    tc = Keyword.get(opts, :tc, random_float())

    sensor = %{type: "temp", device: name, tc: tc}

    Map.merge(base(:msg), sensor)
    |> Msgpax.pack!(iodata: false)
    |> simulate_msg()
  end

  defp profile(:keep_fresh),
    do: %Dutycycle.Profile{name: "keep fresh", run_ms: 60_000, idle_ms: 60_000}

  defp prod_dutycycles,
    do: [
      %Dutycycle{
        name: "mix pump",
        comment: "mix pump",
        device: "mix_pump",
        active: false,
        log: false,
        profiles: [
          %Dutycycle.Profile{name: "fast", run_ms: 3_000, idle_ms: 3_000},
          %Dutycycle.Profile{
            name: "infinity",
            run_ms: 360_000,
            idle_ms: 360_000
          },
          profile(:keep_fresh)
        ],
        state: %Dutycycle.State{}
      },
      %Dutycycle{
        name: "mix air",
        comment: "mix air",
        device: "mix_air",
        active: false,
        log: false,
        profiles: [
          %Dutycycle.Profile{name: "fast", run_ms: 3_000, idle_ms: 3_000},
          %Dutycycle.Profile{
            name: "infinity",
            run_ms: 360_000,
            idle_ms: 360_000
          },
          profile(:keep_fresh)
        ],
        state: %Dutycycle.State{}
      },
      %Dutycycle{
        name: "mix rodi",
        comment: "mix rodi",
        device: "mix_rodi",
        active: false,
        log: false,
        profiles: [
          %Dutycycle.Profile{name: "fast", run_ms: 3_000, idle_ms: 3_000},
          %Dutycycle.Profile{
            name: "infinity",
            run_ms: 360_000,
            idle_ms: 360_000
          },
          profile(:keep_fresh)
        ],
        state: %Dutycycle.State{}
      },
      %Dutycycle{
        name: "mix rodi boost",
        comment: "mix rodi boost",
        device: "mix_rodi_boost",
        active: false,
        log: false,
        profiles: [
          %Dutycycle.Profile{name: "fast", run_ms: 3_000, idle_ms: 3_000},
          %Dutycycle.Profile{
            name: "infinity",
            run_ms: 360_000,
            idle_ms: 360_000
          },
          profile(:keep_fresh)
        ],
        state: %Dutycycle.State{}
      },
      %Dutycycle{
        name: "display tank ato",
        comment: "display tank ato",
        device: "display tank ato",
        active: false,
        log: false,
        profiles: [
          %Dutycycle.Profile{name: "fast", run_ms: 3_000, idle_ms: 3_000},
          %Dutycycle.Profile{
            name: "infinity",
            run_ms: 360_000,
            idle_ms: 360_000
          },
          profile(:keep_fresh)
        ],
        state: %Dutycycle.State{}
      }
    ]
end