t2_server_query_elixir/test/t2_server_query_test.exs

defmodule T2ServerQueryTest do
  use ExUnit.Case, async: true

  # doctest T2ServerQuery


  test "Gracefully handle timeouts and unreachable servers" do
    # We know this query is going to timeout, so lets not wait around :)
    timeout = 250

    port = Enum.random(28_000..28_999)
    {:error, result} = T2ServerQuery.query("127.0.0.1", port, timeout)
      |> T2ServerQuery.log

    assert result.server_status      == :offline
    assert result.server_description == "Host unreachable, timed out."
    assert result.server_name        == "127.0.0.1:#{port}"
  end


  test "Live test a number of Tribes 2 servers" do
    tasks = [
      Task.async(T2ServerQuery, :query, ["35.239.88.241", 28_000]),
      Task.async(T2ServerQuery, :query, ["148.170.171.67"])
    ]

    Task.yield_many(tasks)
      |> Enum.each(fn {_task, result} ->
        case result do
          {:ok, _ }   -> assert true
          {:error, _} -> assert false
          _         -> assert false
        end
      end)
  end


  test "Invalid IP" do
    {:error, result} = T2ServerQuery.query("fake.ip")
      |> T2ServerQuery.log

    assert result.server_status      == :offline
    assert result.server_name        == "fake.ip - Invalid IP"
  end


end





#qry_test = T2ServerQuery.query("127.0.0.1")
#IO.inspect qry_test

#qry_test2 = T2ServerQuery.query("35.239.88.241")
#IO.inspect qry_test2


# tasks = [
#   Task.async(T2ServerQuery, :query, ["127.0.0.1"]),
#   Task.async(T2ServerQuery, :query, ["35.239.88.241"]),
#   Task.async(T2ServerQuery, :query, ["97.99.172.12", 28001]),
#   Task.async(T2ServerQuery, :query, ["67.222.138.13"]),
#   Task.async(T2ServerQuery, :query, ["91.55.51.94"]),
# ]

# IO.inspect Task.yield_many(tasks)

# task0 = Task.async(T2ServerQuery, :query, ["127.0.0.1"])
# task1 = Task.async(T2ServerQuery, :query, ["35.239.88.241"])
# task2 = Task.async(T2ServerQuery, :query, ["97.99.172.12", 28001])
# task3 = Task.async(T2ServerQuery, :query, ["67.222.138.13"])
# task4 = Task.async(T2ServerQuery, :query, ["91.55.51.94"])
# # res4 = Task.await(task4)
# # IO.inspect res4.server_name

# res0 = Task.await(task0)
# res1 = Task.await(task1)
# res2 = Task.await(task2)
# res3 = Task.await(task3)
# res4 = Task.await(task4)


# IO.inspect res1.server_name
# IO.inspect res2.server_name
# IO.inspect res3.server_name
# IO.inspect res4.server_name

# T2ServerQuery.query("35.239.88.241")
# T2ServerQuery.query("97.99.172.12", 28001)
# T2ServerQuery.query("67.222.138.13")
# T2ServerQuery.query("91.55.51.94")