deps = Registry.select(Client.dependent_registry_name(name), [{{:"$1", :_, :_}, [], [:"$1"]}])
Enum.each(deps, fn pid ->
- Logger.info("Send connected to: #{inspect(pid)}")
send(pid, {:connected, name})
end)
_,
%SL{data: %Sess{message: msg, requests: requests, roles: roles}} = data
) do
- Logger.debug("Handling Message #{inspect(msg)}")
+ debug("Handling Message #{inspect(msg)}")
case handle_message(msg, roles) do
{actions, id, response} ->
{%SL{data: sess} = data, response} = maybe_update_response(data, response)
{requests, actions} = resp = handle_response(id, actions, requests, response)
- Logger.debug("Response: #{inspect(resp)}")
+ debug("Response: #{inspect(resp)}")
{:ok, %SL{data | data: %Sess{sess | requests: requests}}, actions}
nil ->
@event,
%SL{data: %Sess{name: name, event: %Event{subscription_id: sub_id} = event}} = sl
) do
- Logger.debug("Received Event #{inspect(event)}")
+ debug("Received Event #{inspect(event)}")
sub = Client.subscriber_registry_name(name)
res = r.handle(msg)
{:halt, res}
rescue
- FunctionClauseError -> {:cont, nil}
+ FunctionClauseError ->
+ {:cont, nil}
end
end)
end
@impl true
def handle_connect(
- %Conn{host: h, port: p, path: pa, query: q} = _conn,
+ _conn,
%{name: name, session_data: sd} = state
) do
- Logger.info("Connected to #{h}:#{p}#{pa}?#{q}")
Process.send_after(self(), :ping, @ping_interval)
{:ok, sess} =
@impl true
def handle_cast({:send_request, data}, %{serializer: s} = state) do
- Logger.debug("Sending Request #{inspect(data)}")
+ Logger.debug("#{__MODULE__} Sending Request #{inspect(data)}")
{:reply, {s.data_type(), s.serialize!(data)}, state}
end
elixirc_paths: elixirc_paths(Mix.env()),
aliases: aliases(),
deps: deps(),
- preferred_cli_env: [
- coveralls: :test,
- "coveralls.detail": :test,
- "coveralls.post": :test,
- "coveralls.html": :test,
- all_tests: :test
- ],
- test_coverage: [tool: ExCoveralls],
docs: [
main: "readme",
extras: ["README.md"],
defp deps do
[
- {:credo, "~> 1.2", only: [:dev, :test], runtime: false},
- {:dialyxir, "~> 0.5.1", only: [:dev, :test], runtime: false},
+ {:credo, "~> 1.2", only: [:test], runtime: false},
+ {:dialyxir, "~> 0.5.1", only: [:test], runtime: false},
{:ex_doc, "~> 0.21", only: :dev, runtime: false},
- {:excoveralls, "~> 0.12.2", only: [:dev, :test], runtime: false},
- {:jason, "~> 1.1"},
- {:msgpack, "~> 0.7.0"},
- {:pbkdf2, "~> 2.0"},
{:states_language, "~> 0.2"},
{:wampex,
git: "https://gitlab.com/entropealabs/wampex.git",
"compile --force --warnings-as-errors",
"credo --strict",
"format --check-formatted",
- "coveralls",
"dialyzer --halt-exit-status"
]
]