cloud/music_library
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Move error tracker notifier files to correct namespace

Browse Source
This commit is contained in:
Claudio Ortolina
2026-03-04 19:39:36 +00:00
parent 25fd355d1c
commit c831b20317
6 changed files with 11 additions and 11 deletions
Download Patch File Download Diff File Expand all files Collapse all files
lib/error_tracker/error_notifier.ex
+135
View File
@@ -0,0 +1,135 @@
defmodule ErrorTracker.ErrorNotifier do
@moduledoc false
use GenServer
require Logger
alias ErrorTracker.ErrorNotifier.Email
@cleanup_interval :timer.minutes(5)
def start_link(opts \\ []) do
GenServer.start_link(__MODULE__, opts, name: __MODULE__)
end
@impl true
def init(_opts) do
if has_valid_config?() do
attach_telemetry()
schedule_cleanup()
{:ok, %{errors: %{}}}
else
:ignore
end
end
@impl true
def handle_info({:telemetry_event, event_name, _measurements, metadata}, state) do
case event_name do
[:error_tracker, :error, :new] ->
reason = truncate_reason(metadata.occurrence.reason)
{_result, new_state} = maybe_notify(metadata.occurrence, "New Error! (#{reason})", state)
{:noreply, new_state}
[:error_tracker, :occurrence, :new] ->
reason = truncate_reason(metadata.occurrence.reason)
{_result, new_state} = maybe_notify(metadata.occurrence, "Error: #{reason}", state)
{:noreply, new_state}
_ ->
{:noreply, state}
end
end
def handle_info(:cleanup, state) do
schedule_cleanup()
{:noreply, cleanup_old_records(state)}
end
def handle_info(_msg, state), do: {:noreply, state}
@doc false
def handle_telemetry_event(event_name, measurements, metadata, _config) do
case Process.whereis(__MODULE__) do
nil -> :ok
pid -> send(pid, {:telemetry_event, event_name, measurements, metadata})
end
end
# -- Private --
defp attach_telemetry do
events = [
[:error_tracker, :error, :new],
[:error_tracker, :occurrence, :new]
]
:telemetry.detach("error-tracker-notifications")
:telemetry.attach_many(
"error-tracker-notifications",
events,
&__MODULE__.handle_telemetry_event/4,
nil
)
end
defp maybe_notify(occurrence, header, state) do
error_id = occurrence.error_id
now = System.system_time(:second)
throttle_seconds = config()[:throttle_seconds] || 10
error_state = Map.get(state.errors, error_id, %{count: 0, last_time: 0})
time_since_last = now - error_state.last_time
if error_state.last_time == 0 || time_since_last >= throttle_seconds do
header_with_count = format_header_with_count(header, error_state.count)
result = Email.send(occurrence, header_with_count)
updated_errors = Map.put(state.errors, error_id, %{count: 0, last_time: now})
{result, %{state | errors: updated_errors}}
else
updated_error = %{count: error_state.count + 1, last_time: error_state.last_time}
updated_errors = Map.put(state.errors, error_id, updated_error)
Logger.debug("Throttled notification for error #{error_id}. Count: #{updated_error.count}")
{:throttled, %{state | errors: updated_errors}}
end
end
defp cleanup_old_records(state) do
now = System.system_time(:second)
one_hour_ago = now - 3600
cleaned_errors =
state.errors
|> Enum.filter(fn {_error_id, %{last_time: last_time}} -> last_time >= one_hour_ago end)
|> Map.new()
%{state | errors: cleaned_errors}
end
defp format_header_with_count(header, count) when count > 1,
do: "#{header} (#{count} occurrences)"
defp format_header_with_count(header, _count), do: header
defp schedule_cleanup do
Process.send_after(self(), :cleanup, @cleanup_interval)
end
defp truncate_reason(reason) when is_binary(reason) do
if String.length(reason) > 80, do: String.slice(reason, 0, 77) <> "...", else: reason
end
defp truncate_reason(reason), do: reason |> inspect() |> truncate_reason()
defp has_valid_config? do
conf = config()
not is_nil(conf[:from_email]) and not is_nil(conf[:to_email]) and not is_nil(conf[:mailer])
end
defp config do
Application.get_env(:music_library, __MODULE__, [])
end
end
lib/error_tracker/error_notifier/email.ex
+139
View File
@@ -0,0 +1,139 @@
defmodule ErrorTracker.ErrorNotifier.Email do
@moduledoc false
import Swoosh.Email
require Logger
def send(occurrence, header) do
conf = config()
from_email = Keyword.fetch!(conf, :from_email)
to_email = Keyword.fetch!(conf, :to_email)
mailer = Keyword.fetch!(conf, :mailer)
first_line = first_stack_line(occurrence)
file = if first_line, do: first_line.file, else: "unknown"
line = if first_line, do: first_line.line, else: "?"
error_name = String.slice(occurrence.reason, 0, 80)
email =
new()
|> to(to_email)
|> from({"MusicLibrary", from_email})
|> subject("[MusicLibrary] Error: #{error_name} - #{file}:#{line}")
|> html_body(build_html(occurrence, header))
case mailer.deliver(email) do
{:ok, _} ->
Logger.info("Error notification email sent")
{:ok, :sent}
{:error, reason} ->
Logger.error("Failed to send error notification: #{inspect(reason)}")
{:error, reason}
end
end
# -- Private --
defp build_html(occurrence, header) do
first_line = first_stack_line(occurrence)
location =
if first_line do
"#{first_line.module}.#{first_line.function} (#{first_line.file}:#{first_line.line})"
else
"Unknown location"
end
view = occurrence.context["live_view.view"] || "N/A"
path = occurrence.context["request.path"] || "N/A"
error_url = error_url(occurrence.error_id)
escaped_header = html_escape(header)
escaped_error_id = html_escape(occurrence.error_id)
escaped_reason = occurrence.reason |> String.slice(0..199) |> html_escape()
escaped_location = html_escape(location)
escaped_view = html_escape(view)
escaped_path = html_escape(path)
escaped_url = html_escape(error_url)
stack_trace_html = format_stack_trace(occurrence)
"""
<div style="max-width: 600px; margin: 0 auto; padding: 20px; font-family: system-ui, -apple-system, sans-serif;">
<div style="background-color: white; border-radius: 8px; padding: 24px; box-shadow: 0 1px 3px 0 rgb(0 0 0 / 0.1);">
<h1 style="color: #dc2626; font-size: 24px; font-weight: bold; margin-bottom: 16px;">
#{escaped_header}
</h1>
<p style="color: #374151; font-size: 16px; line-height: 24px; margin-bottom: 24px;">
ErrorTracker has detected an error:
</p>
<div style="background-color: #f9fafb; border-radius: 6px; padding: 16px; margin-bottom: 24px;">
<p><strong>Error ID:</strong> #{escaped_error_id}</p>
<p><strong>Reason:</strong> #{escaped_reason}</p>
<p><strong>Location:</strong> #{escaped_location}</p>
#{stack_trace_html}
<p><strong>View:</strong> #{escaped_view}</p>
<p><strong>Request Path:</strong> #{escaped_path}</p>
<p><strong>Time:</strong> #{DateTime.utc_now()}</p>
</div>
<p style="margin-bottom: 24px;">
<a href="#{escaped_url}"
style="display: inline-block; background-color: #dc2626; color: white; font-weight: 500;
padding: 8px 16px; border-radius: 4px; text-decoration: none;">
View Error Details
</a>
</p>
</div>
</div>
"""
end
defp format_stack_trace(occurrence) do
case occurrence.stacktrace do
%{lines: lines} when is_list(lines) and lines != [] ->
formatted =
lines
|> Enum.take(10)
|> Enum.map_join("\n", fn line ->
"#{line.module}.#{line.function} (#{line.file}:#{line.line})"
end)
|> html_escape()
"""
<p style="margin: 8px 0 4px 0;"><strong>Stack Trace:</strong></p>
<pre style="font-family: 'Courier New', monospace; font-size: 12px; margin: 0; white-space: pre-wrap;">#{formatted}</pre>
"""
_ ->
""
end
end
defp error_url(error_id) do
conf = config()
base_url = Keyword.get(conf, :base_url, "")
error_path = Keyword.get(conf, :error_tracker_path, "/dev/errors")
error_path = error_path |> String.trim_trailing("/")
base_url = base_url |> String.trim_trailing("/")
"#{base_url}#{error_path}/#{error_id}"
end
defp first_stack_line(occurrence) do
case occurrence.stacktrace do
%{lines: [first | _]} -> first
_ -> nil
end
end
defp html_escape(value) do
value |> Phoenix.HTML.html_escape() |> Phoenix.HTML.safe_to_string()
end
defp config do
Application.get_env(:music_library, ErrorTracker.ErrorNotifier, [])
end
end