mirror of
https://github.com/outbackdingo/firezone.git
synced 2026-03-21 19:41:58 +00:00
d9eb2d18df
TODO: - [x] Cluster formation for all API and web nodes - [x] Injest Docker logs to Stackdriver - [x] Fix assets building for prod To finish later: - [ ] Structured logging: https://issuetracker.google.com/issues/285950891 - [ ] Better networking policy (eg. use public postmark ranges and deny all unwanted egress) - [ ] OpenTelemetry collector for Google Stackdriver - [ ] LoggerJSON.Plug integration --------- Signed-off-by: Andrew Dryga <andrew@dryga.com> Co-authored-by: Jamil <jamilbk@users.noreply.github.com>
50 lines
1.4 KiB
Elixir
50 lines
1.4 KiB
Elixir
defmodule API.Sockets do
|
|
@moduledoc """
|
|
This module provides a set of helper function for Phoenix sockets and
|
|
error handling around them.
|
|
"""
|
|
|
|
def options do
|
|
[
|
|
websocket: [
|
|
transport_log: :debug,
|
|
check_origin: :conn,
|
|
connect_info: [:trace_context_headers, :user_agent, :peer_data, :x_headers],
|
|
error_handler: {__MODULE__, :handle_error, []}
|
|
],
|
|
longpoll: false
|
|
]
|
|
end
|
|
|
|
def handle_error(conn, :unauthenticated),
|
|
do: Plug.Conn.send_resp(conn, 403, "Forbidden")
|
|
|
|
def handle_error(conn, :invalid_token),
|
|
do: Plug.Conn.send_resp(conn, 422, "Unprocessable Entity")
|
|
|
|
def handle_error(conn, :rate_limit),
|
|
do: Plug.Conn.send_resp(conn, 429, "Too many requests")
|
|
|
|
def handle_error(conn, %Ecto.Changeset{}),
|
|
do: Plug.Conn.send_resp(conn, 422, "Invalid or missing connection parameters")
|
|
|
|
# if Mix.env() == :test do
|
|
# defp maybe_allow_sandbox_access(%{user_agent: user_agent}) do
|
|
# %{owner: owner_pid, repo: repos} =
|
|
# metadata = Phoenix.Ecto.SQL.Sandbox.decode_metadata(user_agent)
|
|
|
|
# repos
|
|
# |> List.wrap()
|
|
# |> Enum.each(fn repo ->
|
|
# Ecto.Adapters.SQL.Sandbox.allow(repo, owner_pid, self())
|
|
# end)
|
|
|
|
# {:ok, metadata}
|
|
# end
|
|
|
|
# defp maybe_allow_sandbox_access(_), do: {:ok, %{}}
|
|
# else
|
|
# defp maybe_allow_sandbox_access(_), do: {:ok, %{}}
|
|
# end
|
|
end
|