Update endpoint_test.exs

doctolib · Jul 24, 2024 · 1c5fff7 · 1c5fff7
1 parent ab60521
commit 1c5fff7
Showing 1 changed file with 8 additions and 5 deletions.
diff --git a/neurow/test/neurow/internal_api/endpoint_test.exs b/neurow/test/neurow/internal_api/endpoint_test.exs
@@ -1,5 +1,5 @@
 defmodule Neurow.InternalApi.EndpointTest do
-  use ExUnit.Case, async: true
+  use ExUnit.Case
   use Plug.Test
 
   alias Neurow.InternalApi.Message
@@ -99,9 +99,10 @@ defmodule Neurow.InternalApi.EndpointTest do
         conn(:post, "/v1/publish", body) |> put_jwt_token_in_req_header_internal_api()
 
       call = Neurow.InternalApi.Endpoint.call(conn, [])
-
       assert call.status == 200
 
+      Process.sleep(20)
+
       assert_received {:pubsub_message,
                        %Message{
                          type: "type_foo",
@@ -124,9 +125,10 @@ defmodule Neurow.InternalApi.EndpointTest do
         conn(:post, "/v1/publish", body) |> put_jwt_token_in_req_header_internal_api()
 
       call = Neurow.InternalApi.Endpoint.call(conn, [])
-
       assert call.status == 200
 
+      Process.sleep(20)
+
       assert_received {:pubsub_message,
                        %Message{
                          type: "type_foo",
@@ -158,6 +160,9 @@ defmodule Neurow.InternalApi.EndpointTest do
         conn(:post, "/v1/publish", body) |> put_jwt_token_in_req_header_internal_api()
 
       call = Neurow.InternalApi.Endpoint.call(conn, [])
+      assert call.status == 200
+
+      Process.sleep(20)
 
       assert_received(
         {:pubsub_message,
@@ -176,8 +181,6 @@ defmodule Neurow.InternalApi.EndpointTest do
            timestamp: 123_458
          }}
       )
-
-      assert call.status == 200
     end
 
     test "provides a timestamp if the message timestamp is not provided in the request payload" do