Asserts the channel has broadcast a message within timeout.

Before asserting anything was broadcast, we must first subscribe to the topic of the channel in the test process:

@endpoint.subscribe("foo:ok")

Now we can match on event and payload as patterns:

assert_broadcast "some_event", %{"data" => _}

In the assertion above, we don't particularly care about the data being sent, as long as something was sent.

The timeout is in milliseconds and defaults to the :assert_receive_timeout set on the :ex_unit application (which defaults to 100ms).

Asserts the channel has pushed a message back to the client with the given event and payload within timeout.

Notice event and payload are patterns. This means one can write:

assert_push "some_event", %{"data" => _}

In the assertion above, we don't particularly care about the data being sent, as long as something was sent.

The timeout is in milliseconds and defaults to the :assert_receive_timeout set on the :ex_unit application (which defaults to 100ms).

NOTE: Because event and payload are patterns, they will be matched. This means that if you wish to assert that the received payload is equivalent to an existing variable, you need to pin the variable in the assertion expression.

Good:

expected_payload = %{foo: "bar"}
assert_push "some_event", ^expected_payload

Bad:

expected_payload = %{foo: "bar"}
assert_push "some_event", expected_payload
# The code above does not assert the payload matches the described map.

Asserts the channel has replied to the given message within timeout.

Notice status and payload are patterns. This means one can write:

ref = push(channel, "some_event")
assert_reply ref, :ok, %{"data" => _}

In the assertion above, we don't particularly care about the data being sent, as long as something was replied.

The timeout is in milliseconds and defaults to the :assert_receive_timeout set on the :ex_unit application (which defaults to 100ms).

Broadcast event from pid to all subscribers of the socket topic.

The test process will not receive the published message. This triggers the handle_out/3 callback in the channel.

Examples

iex> broadcast_from(socket, "new_message", %{id: 1, content: "hello"})
:ok

Same as broadcast_from/3, but raises if broadcast fails.

Emulates the client closing the socket.

Closing socket is synchronous and has a default timeout of 5000 milliseconds.

Initiates a transport connection for the socket handler.

Useful for testing UserSocket authentication. Returns the result of the handler's connect/3 callback.

See join/4.

See join/4.

Joins the channel under the given topic and payload.

The given channel is joined in a separate process which is linked to the test process.

It returns {:ok, reply, socket} or {:error, reply}.

@spec leave(Phoenix.Socket.t()) :: reference()

Emulates the client leaving the channel.

@spec push(Phoenix.Socket.t(), String.t(), map()) :: reference()

Pushes a message into the channel.

The triggers the handle_in/3 callback in the channel.

Examples

iex> push(socket, "new_message", %{id: 1, content: "hello"})
reference

Asserts the channel has not broadcast a message within timeout.

Like assert_broadcast, the event and payload are patterns.

The timeout is in milliseconds and defaults to the :refute_receive_timeout set on the :ex_unit application (which defaults to 100ms). Keep in mind this macro will block the test by the timeout value, so use it only when necessary as overuse will certainly slow down your test suite.

Asserts the channel has not pushed a message to the client matching the given event and payload within timeout.

Like assert_push, the event and payload are patterns.

The timeout is in milliseconds and defaults to the :refute_receive_timeout set on the :ex_unit application (which defaults to 100ms). Keep in mind this macro will block the test by the timeout value, so use it only when necessary as overuse will certainly slow down your test suite.

Asserts the channel has not replied with a matching payload within timeout.

Like assert_reply, the event and payload are patterns.

The timeout is in milliseconds and defaults to the :refute_receive_timeout set on the :ex_unit application (which defaults to 100ms). Keep in mind this macro will block the test by the timeout value, so use it only when necessary as overuse will certainly slow down your test suite.

Builds a socket for the given socket_module.

The socket is then used to subscribe and join channels. Use this function when you want to create a blank socket to pass to functions like UserSocket.connect/3.

Otherwise, use socket/4 if you want to build a socket with existing id and assigns.

Examples

socket(MyApp.UserSocket)

Builds a socket for the given socket_module with given id and assigns.

Examples

socket(MyApp.UserSocket, "user_id", %{some: :assign})

If you need to access the socket in another process than the test process, you can give the pid of the test process in the 4th argument.

Examples

test "connect in a task" do
  pid = self()
  task = Task.async(fn -> 
    socket = socket(MyApp.UserSocket, "user_id", %{some: :assign}, test_process: pid)
    broadcast_from!(socket, "default", %{"foo" => "bar"})
    assert_push "default", %{"foo" => "bar"}
  end)
  Task.await(task)
end

See subscribe_and_join/4.

See subscribe_and_join/4.

Subscribes to the given topic and joins the channel under the given topic and payload.

By subscribing to the topic, we can use assert_broadcast/3 to verify a message has been sent through the pubsub layer.

By joining the channel, we can interact with it directly. The given channel is joined in a separate process which is linked to the test process.

If no channel module is provided, the socket's handler is used to lookup the matching channel for the given topic.

It returns {:ok, reply, socket} or {:error, reply}.

See subscribe_and_join!/4.

See subscribe_and_join!/4.

Same as subscribe_and_join/4, but returns either the socket or throws an error.

This is helpful when you are not testing joining the channel and just need the socket.