diff --git a/lib/realtime/application.ex b/lib/realtime/application.ex index 77a65f89f..41785401d 100644 --- a/lib/realtime/application.ex +++ b/lib/realtime/application.ex @@ -5,8 +5,9 @@ defmodule Realtime.Application do use Application require Logger - alias DBConnection.App + alias Realtime.Repo.Replica + defmodule JwtSecretError, do: defexception([:message]) defmodule JwtClaimValidatorsError, do: defexception([:message]) diff --git a/test/integration/rt_channel_test.exs b/test/integration/rt_channel_test.exs index 2d3a63a6c..cd07ed27d 100644 --- a/test/integration/rt_channel_test.exs +++ b/test/integration/rt_channel_test.exs @@ -394,8 +394,9 @@ defmodule Realtime.Integration.RtChannelTest do WebsocketClient.send_event(socket, topic, "presence", payload) + assert_receive %Phoenix.Socket.Message{topic: ^topic, event: "phx_reply", payload: %{"status" => "ok"}} assert_receive %Message{event: "presence_diff", payload: %{"joins" => joins, "leaves" => %{}}, topic: ^topic} - refute_receive %Message{topic: ^topic} + join_payload = joins |> Map.values() |> hd() |> get_in(["metas"]) |> hd() assert get_in(join_payload, ["name"]) == payload.payload.name assert get_in(join_payload, ["t"]) == payload.payload.t