mirror of
https://github.com/benbusby/farside.git
synced 2025-03-14 19:26:30 -04:00
1be19a8a29
The "throttling" performed by Farside now redirects to the same instance as before, rather than outright blocking the connection.
68 lines
1.3 KiB
Elixir
68 lines
1.3 KiB
Elixir
defmodule Farside.Router do
|
|
@index Application.fetch_env!(:farside, :index)
|
|
@route Application.fetch_env!(:farside, :route)
|
|
|
|
use Plug.Router
|
|
|
|
plug(Farside.Throttle)
|
|
plug(:match)
|
|
plug(:dispatch)
|
|
|
|
get "/" do
|
|
resp =
|
|
EEx.eval_file(
|
|
@index,
|
|
last_updated: Farside.get_last_updated(),
|
|
services: Farside.get_services_map()
|
|
)
|
|
|
|
send_resp(conn, 200, resp)
|
|
end
|
|
|
|
get "/ping" do
|
|
# Useful for app healthcheck
|
|
{:ok, resp} = Redix.command(:redix, ["PING"])
|
|
send_resp(conn, 200, resp)
|
|
end
|
|
|
|
get "/_/:service/*glob" do
|
|
r_path = String.slice(conn.request_path, 2..-1)
|
|
|
|
resp =
|
|
EEx.eval_file(
|
|
@route,
|
|
service: service,
|
|
instance_url: r_path
|
|
)
|
|
|
|
send_resp(conn, 200, resp)
|
|
end
|
|
|
|
get "/:service/*glob" do
|
|
path = Enum.join(glob, "/")
|
|
instance = cond do
|
|
conn.assigns[:throttle] != nil ->
|
|
Farside.last_instance(service)
|
|
true ->
|
|
Farside.pick_instance(service)
|
|
end
|
|
|
|
params =
|
|
cond do
|
|
String.length(conn.query_string) > 0 ->
|
|
"?#{conn.query_string}"
|
|
|
|
true ->
|
|
""
|
|
end
|
|
|
|
# Redirect to the available instance
|
|
conn
|
|
|> Plug.Conn.resp(:found, "")
|
|
|> Plug.Conn.put_resp_header(
|
|
"location",
|
|
"#{instance}/#{path}#{params}"
|
|
)
|
|
end
|
|
end
|