2b94d2493f33c1abe4748e6ac5a76b88bdcb56b0-PR-29

defmodule OffBroadwayPulsar.Test.Support.System do
  @moduledoc """
  Helper functions for managing the test environment (i.e. Pulsar).
  """

  def start_pulsar do
    IO.puts("Starting Pulsar...")
    {_output, 0} = System.cmd("docker", ["compose", "up", "-d"])

    IO.puts("Waiting for Pulsar to become healthy...")
    wait_for_pulsar()
  end

  def stop_pulsar do
    IO.puts("Stopping Pulsar...")
    {_output, 0} = System.cmd("docker", ["compose", "down", "-v"])
  end

  defp wait_for_pulsar(retries \\ 30) do
    if retries == 0 do
      raise "Pulsar failed to become healthy"
    end

    case System.cmd("curl", ["-f", "http://localhost:8080/metrics/health"], stderr_to_stdout: true) do
      {_output, 0} ->
        IO.puts("Pulsar is healthy!")
        :ok

      {_output, _code} ->
        Process.sleep(1000)
        wait_for_pulsar(retries - 1)
    end
  end
end

1	defmodule OffBroadwayPulsar.Test.Support.System do
2	@moduledoc """
3	Helper functions for managing the test environment (i.e. Pulsar).
4	"""
5
6	def start_pulsar do
7	IO.puts("Starting Pulsar...")	1✔
8	{_output, 0} = System.cmd("docker", ["compose", "up", "-d"])	1✔
9
10	IO.puts("Waiting for Pulsar to become healthy...")	1✔
11	wait_for_pulsar()	1✔
12	end
13
14	def stop_pulsar do
15	IO.puts("Stopping Pulsar...")	1✔
16	{_output, 0} = System.cmd("docker", ["compose", "down", "-v"])	1✔
17	end
18
19	defp wait_for_pulsar(retries \\ 30) do
20	if retries == 0 do	7✔
NEW 21	raise "Pulsar failed to become healthy"	×
22	end
23
24	case System.cmd("curl", ["-f", "http://localhost:8080/metrics/health"], stderr_to_stdout: true) do	7✔
25	{_output, 0} ->
26	IO.puts("Pulsar is healthy!")	1✔
27	:ok
28
29	{_output, _code} ->
30	Process.sleep(1000)	6✔
31	wait_for_pulsar(retries - 1)	6✔
32	end
33	end
34	end

efcasado / off_broadway_pulsar / 2b94d2493f33c1abe4748e6ac5a76b88bdcb56b0-PR-29

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous