Packages

tidewave

0.1.7
0.8.0 0.6.1 0.6.0 0.5.6 0.5.5 0.5.4 0.5.3 0.5.2 0.5.1 0.5.0 0.4.2 0.4.1 0.4.0 0.3.2 0.3.1 0.3.0 0.2.0 0.1.10 0.1.9 0.1.8 0.1.7 0.1.6 0.1.5 0.1.4 0.1.3 0.1.2 0.1.1 0.1.0

Tidewave for Phoenix

HexDocs

Current section

Files

Jump to
Readme
28 Versions
5 Dependencies
Dependants
Files
Activity
tidewave lib tidewave.ex
Raw

lib/tidewave.ex 

defmodule Tidewave do

  @moduledoc false

  @behaviour Plug



  @impl true

  def init(opts) do

    %{

      allowed_origins: Keyword.get(opts, :allowed_origins, nil),

      sse_keepalive_timeout: Keyword.get(opts, :sse_keepalive_timeout, 15_000),

      allow_remote_access: Keyword.get(opts, :allow_remote_access, false),

      phoenix_endpoint: nil,

      inspect_opts:

        Keyword.get(opts, :inspect_opts, charlists: :as_lists, limit: 50, pretty: true),

      exclude_tools: Enum.map(opts[:tools][:exclude] || [], &to_string/1),

      include_tools: opts[:tools][:include] && Enum.map(opts[:tools][:include], &to_string/1)

    }

  end



  @impl true

  def call(%Plug.Conn{path_info: ["tidewave" | rest]} = conn, config) do

    config = %{config | phoenix_endpoint: conn.private[:phoenix_endpoint]}



    conn

    |> Plug.Conn.put_private(:tidewave_config, config)

    |> Plug.forward(rest, Tidewave.Router, [])

    |> Plug.Conn.halt()

  end



  def call(conn, _opts), do: conn

end