analytics/lib/plausible_web/controllers/api/external_controller.ex
2020-02-27 11:46:48 +02:00

162 lines
5.2 KiB
Elixir

defmodule PlausibleWeb.Api.ExternalController do
use PlausibleWeb, :controller
require Logger
def event(conn, _params) do
params = parse_body(conn)
case create_event(conn, params) do
{:ok, nil} ->
conn |> send_resp(202, "")
{:ok, event} ->
Plausible.Ingest.Session.on_event(event)
Plausible.Ingest.FingerprintSession.on_event(event)
update_fingerprint(event)
conn |> send_resp(202, "")
{:error, changeset} ->
request = Sentry.Plug.build_request_interface_data(conn, [])
Sentry.capture_message("Error processing event", extra: %{errors: inspect(changeset.errors), params: params, request: request})
Logger.info("Error processing event: #{inspect(changeset)}")
conn |> send_resp(400, "")
end
end
def unload(conn, _params) do
params = parse_body(conn)
Plausible.Ingest.Session.on_unload(params["uid"], Timex.now())
fingerprint = calculate_fingerprint(conn, params)
Plausible.Ingest.FingerprintSession.on_unload(params["uid"], Timex.now())
conn |> send_resp(202, "")
end
def error(conn, _params) do
request = Sentry.Plug.build_request_interface_data(conn, [])
Sentry.capture_message("JS snippet error", request: request)
send_resp(conn, 200, "")
end
defp update_fingerprint(%Plausible.Event{new_visitor: true}), do: nil
defp update_fingerprint(event) do
use Plausible.Repo
q = from(e in Plausible.Event, where: e.user_id == ^event.user_id and is_nil(e.fingerprint))
Repo.update_all(q, set: [fingerprint: event.fingerprint])
end
defp create_event(conn, params) do
uri = URI.parse(params["url"])
country_code = Plug.Conn.get_req_header(conn, "cf-ipcountry") |> List.first
user_agent = Plug.Conn.get_req_header(conn, "user-agent") |> List.first
if UAInspector.bot?(user_agent) do
{:ok, nil}
else
ua = if user_agent do
UAInspector.Parser.parse(user_agent)
end
ref = parse_referrer(uri, params["referrer"])
initial_ref = parse_referrer(uri, params["initial_referrer"])
event_attrs = %{
name: params["name"],
hostname: strip_www(uri.host),
domain: strip_www(params["domain"]) || strip_www(uri.host),
pathname: uri.path,
new_visitor: params["new_visitor"],
country_code: country_code,
user_id: params["uid"],
fingerprint: calculate_fingerprint(conn, params),
operating_system: ua && os_name(ua),
browser: ua && browser_name(ua),
referrer_source: params["source"] || referrer_source(ref),
referrer: clean_referrer(ref),
initial_referrer_source: params["initial_source"] || referrer_source(initial_ref),
initial_referrer: clean_referrer(initial_ref),
screen_size: calculate_screen_size(params["screen_width"])
}
Plausible.Event.changeset(%Plausible.Event{}, event_attrs)
|> Plausible.Repo.insert
end
end
defp parse_referrer(_, nil), do: nil
defp parse_referrer(uri, referrer_str) do
referrer_uri = URI.parse(referrer_str)
if strip_www(referrer_uri.host) !== strip_www(uri.host) && referrer_uri.host !== "localhost" do
RefInspector.parse(referrer_str)
end
end
defp calculate_fingerprint(conn, params) do
user_agent = List.first(Plug.Conn.get_req_header(conn, "user-agent")) || ""
ip_address = List.first(Plug.Conn.get_req_header(conn, "cf-connecting-ip")) || ""
domain = strip_www(params["domain"]) || ""
:crypto.hash(:sha256, [user_agent, ip_address, domain])
|> Base.encode16
|> String.downcase
end
defp calculate_screen_size(nil) , do: nil
defp calculate_screen_size(width) when width < 576, do: "Mobile"
defp calculate_screen_size(width) when width < 992, do: "Tablet"
defp calculate_screen_size(width) when width < 1440, do: "Laptop"
defp calculate_screen_size(width) when width >= 1440, do: "Desktop"
defp clean_referrer(nil), do: nil
defp clean_referrer(ref) do
uri = URI.parse(String.trim_trailing(ref.referer, "/"))
if uri && uri.scheme in ["http", "https"] do
host = String.replace_prefix(uri.host, "www.", "")
host <> (uri.path || "")
end
end
defp parse_body(conn) do
{:ok, body, _conn} = Plug.Conn.read_body(conn)
Jason.decode!(body)
end
defp strip_www(nil), do: nil
defp strip_www(hostname) do
String.replace_prefix(hostname, "www.", "")
end
defp browser_name(ua) do
case ua.client do
%UAInspector.Result.Client{name: "Mobile Safari"} -> "Safari"
%UAInspector.Result.Client{name: "Chrome Mobile"} -> "Chrome"
%UAInspector.Result.Client{name: "Chrome Mobile iOS"} -> "Chrome"
%UAInspector.Result.Client{type: "mobile app"} -> "Mobile App"
:unknown -> nil
client -> client.name
end
end
defp os_name(ua) do
case ua.os do
:unknown -> nil
os -> os.name
end
end
defp referrer_source(nil), do: nil
defp referrer_source(ref) do
case ref.source do
:unknown ->
clean_uri(ref.referer)
source ->
source
end
end
defp clean_uri(uri) do
uri = URI.parse(String.trim(uri))
if uri.scheme in ["http", "https"] do
String.replace_leading(uri.host, "www.", "")
end
end
end