mirror of
https://github.com/plausible/analytics.git
synced 2024-12-25 02:24:55 +03:00
a10d44a0d7
* Replace Ingestion.Request headers with user_agent * Replace generic Ingestion.Request params with specific fields * Refactor event building function into small functions * Move Plausible.Ingestion to Plausible.Ingestion.Event * Add option to override event fields while building * Rename Ingestion.Request meta to props * Replace UTM-specific fields with generic query_params * Remove Map.from_struct/1 call from ingestion pipeline * Remove stash options from ingestion
93 lines
2.5 KiB
Elixir
93 lines
2.5 KiB
Elixir
defimpl FunWithFlags.Actor, for: BitString do
|
|
def id(str) do
|
|
str
|
|
end
|
|
end
|
|
|
|
defmodule PlausibleWeb.Api.ExternalController do
|
|
use PlausibleWeb, :controller
|
|
require Logger
|
|
|
|
def event(conn, _params) do
|
|
with {:ok, ingestion_request} <- Plausible.Ingestion.Request.build(conn),
|
|
_ <- Sentry.Context.set_extra_context(%{request: ingestion_request}),
|
|
:ok <- Plausible.Ingestion.Event.build_and_buffer(ingestion_request) do
|
|
conn |> put_status(202) |> text("ok")
|
|
else
|
|
:skip ->
|
|
conn |> put_status(202) |> text("ok")
|
|
|
|
{:error, :invalid_json} ->
|
|
conn
|
|
|> put_status(400)
|
|
|> json(%{errors: %{request: "Unable to parse request body as json"}})
|
|
|
|
{:error, %Ecto.Changeset{} = changeset} ->
|
|
errors =
|
|
Ecto.Changeset.traverse_errors(changeset, fn {msg, opts} ->
|
|
Regex.replace(~r"%{(\w+)}", msg, fn _, key ->
|
|
opts |> Keyword.get(String.to_existing_atom(key), key) |> to_string()
|
|
end)
|
|
end)
|
|
|
|
conn |> put_status(400) |> json(%{errors: errors})
|
|
end
|
|
end
|
|
|
|
def error(conn, _params) do
|
|
Sentry.capture_message("JS snippet error")
|
|
send_resp(conn, 200, "")
|
|
end
|
|
|
|
def health(conn, _params) do
|
|
postgres_health =
|
|
case Ecto.Adapters.SQL.query(Plausible.Repo, "SELECT 1", []) do
|
|
{:ok, _} -> "ok"
|
|
e -> "error: #{inspect(e)}"
|
|
end
|
|
|
|
clickhouse_health =
|
|
case Ecto.Adapters.SQL.query(Plausible.ClickhouseRepo, "SELECT 1", []) do
|
|
{:ok, _} -> "ok"
|
|
e -> "error: #{inspect(e)}"
|
|
end
|
|
|
|
status =
|
|
case {postgres_health, clickhouse_health} do
|
|
{"ok", "ok"} -> 200
|
|
_ -> 500
|
|
end
|
|
|
|
put_status(conn, status)
|
|
|> json(%{
|
|
postgres: postgres_health,
|
|
clickhouse: clickhouse_health
|
|
})
|
|
end
|
|
|
|
def info(conn, _params) do
|
|
build_metadata = System.get_env("BUILD_METADATA", "{}") |> Jason.decode!()
|
|
|
|
geo_database =
|
|
case Geolix.metadata(where: :geolocation) do
|
|
%{database_type: type} ->
|
|
type
|
|
|
|
_ ->
|
|
"(not configured)"
|
|
end
|
|
|
|
info = %{
|
|
geo_database: geo_database,
|
|
build: %{
|
|
version: get_in(build_metadata, ["labels", "org.opencontainers.image.version"]),
|
|
commit: get_in(build_metadata, ["labels", "org.opencontainers.image.revision"]),
|
|
created: get_in(build_metadata, ["labels", "org.opencontainers.image.created"]),
|
|
tags: get_in(build_metadata, ["tags"])
|
|
}
|
|
}
|
|
|
|
json(conn, info)
|
|
end
|
|
end
|