-
-
Save w0rd-driven/5f79a0c819ec51be3c7611e5ada625a4 to your computer and use it in GitHub Desktop.
Testing module macros
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| defmodule OperationsTest do | |
| use ExUnit.Case, async: true | |
| def make_mod() do | |
| String.to_atom("Elixir.Test#{System.unique_integer([:positive])}") | |
| end | |
| describe "operation/2" do | |
| setup do | |
| mod = make_mod() | |
| {:ok, mod: mod} | |
| end | |
| test "stores the operation", %{mod: mod} do | |
| defmodule :"#{mod}" do | |
| use ChannelSpec.Operations | |
| operation :foo, | |
| payload: %{type: :string}, | |
| replies: %{ok: %{type: :object}} | |
| def foo(_params, _context, socket), do: {:noreply, socket} | |
| end | |
| assert operations = mod.__channel_operations__() | |
| assert %{ | |
| module: ^mod, | |
| schema: %{payload: %{type: :string}} | |
| } = operations.foo | |
| end | |
| test "validates that the replies schemas are maps", %{mod: mod} do | |
| assert %Operations.OperationError{} = | |
| err = | |
| catch_error( | |
| defmodule :"#{mod}" do | |
| use ChannelSpec.Operations | |
| operation :foo, replies: %{ok: :string} | |
| def foo(_params, _context, socket), do: {:noreply, socket} | |
| end | |
| ) | |
| assert err.message == "The schema for replies.ok is not a valid schema map.\n" | |
| end | |
| end | |
| end |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| defmodule OperationsTest do | |
| use ExUnit.Case, async: true | |
| use ChannelSpec.Testing | |
| def make_mod() do | |
| String.to_atom("Elixir.Test#{System.unique_integer([:positive])}") | |
| end | |
| def build_socket(module, id, assigns, endpoint, opts \\ []) do | |
| Phoenix.ChannelTest.__socket__(module, id, assigns, endpoint, opts) | |
| end | |
| describe "push/3 and assert_reply_spec/3" do | |
| setup do | |
| mod = make_mod() | |
| {:ok, mod: mod} | |
| end | |
| test "validates response against the schema", %{mod: mod} do | |
| defmodule :"#{mod}.RoomChannel" do | |
| use Phoenix.Channel | |
| use ChannelHandler.Router | |
| use ChannelSpec.Operations | |
| def join("room:" <> _, _params, socket) do | |
| {:ok, socket} | |
| end | |
| operation "new_msg", | |
| payload: %{type: :object, properties: %{body: %{type: :string}}}, | |
| replies: %{ok: %{type: :string}} | |
| handle "new_msg", fn %{"body" => body}, _, socket -> | |
| {:reply, {:ok, body}, socket} | |
| end | |
| end | |
| defmodule :"#{mod}.UserSocket" do | |
| use ChannelSpec.Socket | |
| channel "room:*", :"#{mod}.RoomChannel" | |
| end | |
| defmodule :"#{mod}.Endpoint" do | |
| use Phoenix.Endpoint, otp_app: :channel_spec | |
| Phoenix.Endpoint.socket("/socket", :"#{mod}.UserSocket") | |
| defoverridable config: 1, config: 2 | |
| def config(:pubsub_server), do: __MODULE__.PubSub | |
| def config(which), do: super(which) | |
| def config(which, default), do: super(which, default) | |
| end | |
| start_supervised({Phoenix.PubSub, name: :"#{mod}.Endpoint.PubSub"}) | |
| {:ok, _endpoint_pid} = start_supervised(:"#{mod}.Endpoint") | |
| {:ok, _, socket} = | |
| :"#{mod}.UserSocket" | |
| |> build_socket("room:123", %{}, :"#{mod}.Endpoint") | |
| |> subscribe_and_join(:"#{mod}.RoomChannel", "room:123") | |
| ref = push(socket, "new_msg", %{"body" => 123}) | |
| error = catch_error(assert_reply_spec ref, :ok, _) | |
| assert error.message =~ "Channel reply doesn't match reply spec for status ok" | |
| end | |
| end | |
| end |
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment