Skip to content

Commit

Permalink
Format
Browse files Browse the repository at this point in the history
  • Loading branch information
Matthew committed Aug 1, 2024
1 parent e15a45b commit ce21131
Show file tree
Hide file tree
Showing 2 changed files with 21 additions and 7 deletions.
10 changes: 5 additions & 5 deletions lib/turn_junebug_expressway_web/utils.ex
Original file line number Diff line number Diff line change
Expand Up @@ -64,8 +64,8 @@ defmodule TurnJunebugExpresswayWeb.Utils do
def send_message(message) do
key = Map.get(message, "user_message_id")
value = Map.get(message, "recipient_id")
#IO.puts("#{message}")
#IO.puts("#{inspect(key)}, #{inspect(value)}")
# IO.puts("#{message}")
# IO.puts("#{inspect(key)}, #{inspect(value)}")
TurnJunebugExpressway.TurnAgent.put(key, value)
TurnJunebugExpressway.MessageEngine.publish_message(message)
end
Expand Down Expand Up @@ -118,7 +118,7 @@ defmodule TurnJunebugExpresswayWeb.Utils do
end

def forward_event(event) do
#IO.puts("#{inspect(event)}")
# IO.puts("#{inspect(event)}")
IO.inspect("#{inspect(TurnAgent.get(Map.get(event, "user_message_id")))}")

Check warning on line 122 in lib/turn_junebug_expressway_web/utils.ex

View workflow job for this annotation

GitHub Actions / test (1.17, 26)

There should be no calls to `IO.inspect/1`.

case event |> get_event_status do
Expand All @@ -132,8 +132,8 @@ defmodule TurnJunebugExpresswayWeb.Utils do
"statuses" => [
%{
"id" => Map.get(event, "user_message_id"),
#"recipient_id" => nil,
"recipient_id" => TurnAgent.get(Map.get(event, "user_message_id")),
# "recipient_id" => nil,
"recipient_id" => TurnAgent.get(Map.get(event, "user_message_id")),
"status" => status,
"timestamp" => get_event_timestamp(event, :second)
}
Expand Down
18 changes: 16 additions & 2 deletions test/turn_junebug_expressway_web/utils_test.exs
Original file line number Diff line number Diff line change
Expand Up @@ -99,8 +99,15 @@ defmodule TurnJunebugExpresswayWeb.UtilsTest do
}
]
}
message = %{"content" => "something", "recipient_id"=> "1234","user_message_id" => "f74c4e6108d8418ab53dbcfd628242f3"}

message = %{
"content" => "something",
"recipient_id" => "1234",
"user_message_id" => "f74c4e6108d8418ab53dbcfd628242f3"
}

Utils.send_message(message)

TurnJunebugExpressway.Backends.ClientMock
|> expect(:client, fn -> :client end)
|> expect(:post_event, fn :client, ^body -> :ok end)
Expand Down Expand Up @@ -133,8 +140,15 @@ defmodule TurnJunebugExpresswayWeb.UtilsTest do
}
]
}
message = %{"content" => "something", "recipient_id"=> "1234","user_message_id" => "16e42b66-03b7-4558-8a72-e9db481fdb4c"}

message = %{
"content" => "something",
"recipient_id" => "1234",
"user_message_id" => "16e42b66-03b7-4558-8a72-e9db481fdb4c"
}

Utils.send_message(message)

TurnJunebugExpressway.Backends.ClientMock
|> expect(:client, fn -> :client end)
|> expect(:post_event, fn :client, _new_body ->
Expand Down

0 comments on commit ce21131

Please sign in to comment.