Fix test

whatyouhide · Oct 20, 2023 · 313d136 · 313d136
1 parent 1d12a9b
commit 313d136
Show file tree

Hide file tree

Showing 2 changed files with 14 additions and 9 deletions.
diff --git a/test/xandra_test.exs b/test/xandra_test.exs
@@ -186,15 +186,6 @@ defmodule XandraTest do
     end
   end
 
-  describe "prepare/3" do
-    test "supports the :timeout option", %{conn: conn} do
-      assert {:error, %ConnectionError{} = error} =
-               Xandra.prepare(conn, "SELECT * FROM system.local", timeout: 0)
-
-      assert error.reason == :timeout
-    end
-  end
-
   describe "failure handling" do
     test "reconnects if the connection drops", %{start_options: start_options} do
       telemetry_ref =

diff --git a/test/xandra_toxiproxy_test.exs b/test/xandra_toxiproxy_test.exs
@@ -31,6 +31,20 @@ defmodule XandraToxiproxyTest do
     end)
   end
 
+  test "prepare/3 supports the :timeout option", %{start_options: opts} do
+    opts = Keyword.merge(opts, nodes: ["127.0.0.1:19052"])
+    conn = start_supervised!({Xandra, opts})
+
+    ToxiproxyEx.get!(:xandra_test_cassandra)
+    |> ToxiproxyEx.toxic(:timeout, timeout: 100)
+    |> ToxiproxyEx.apply!(fn ->
+      assert {:error, %ConnectionError{} = error} =
+               Xandra.prepare(conn, "SELECT * FROM system.local", timeout: 0)
+
+      assert error.reason == :timeout
+    end)
+  end
+
   test "start_link/1 supports the :connect_timeout option", %{start_options: opts} do
     opts =
       Keyword.merge(opts,