Initial data model and error reporting

Author: crbelaus

.formatter.exs

@@ -1,4 +1,5 @@
 # Used by "mix format"
 [
-  inputs: ["{mix,.formatter}.exs", "{config,lib,test}/**/*.{ex,exs}"]
+  inputs: ["{mix,.formatter}.exs", "{config,lib,test}/**/*.{ex,exs}"],
+  import_deps: [:ecto, :ecto_sql]
 ]

config/config.exs

@@ -0,0 +1,11 @@
+import Config
+
+config :error_tracker, ErrorTracker.Repo,
+  name: ErrorTracker.Repo,
+  priv: "test/support/repo",
+  stacktrace: true,
+  url:
+    System.get_env("DATABASE_URL") ||
+      "postgres://postgres:postgres@localhost:5432/error_tracker_test"
+
+config :error_tracker, ecto_repos: [ErrorTracker.Repo]

lib/error_tracker.ex

@@ -1,18 +1,24 @@
 defmodule ErrorTracker do
-  @moduledoc """
-  Documentation for `ErrorTracker`.
-  """
+  alias ErrorTracker.Repo
 
-  @doc """
-  Hello world.
+  def report(exception, stacktrace, context \\ %{}) do
+    {:ok, stacktrace} = ErrorTracker.Stacktrace.new(stacktrace)
+    {:ok, error} = ErrorTracker.Error.new(exception, stacktrace)
 
-  ## Examples
+    error =
+      Repo.insert!(error,
+        on_conflict: [set: [status: :unresolved]],
+        conflict_target: :fingerprint
+      )
 
-      iex> ErrorTracker.hello()
-      :world
+    error
+    |> Ecto.build_assoc(:occurrences, stacktrace: stacktrace, context: context)
+    |> Repo.insert!()
+  end
 
-  """
-  def hello do
-    :world
+  def raise do
+    raise "PROBANDO PROBANDO"
+  rescue
+    e -> report(e, __STACKTRACE__)
   end
 end

lib/error_tracker/application.ex

@@ -0,0 +1,9 @@
+defmodule ErrorTracker.Application do
+  use Application
+
+  def start(_type, _args) do
+    children = [ErrorTracker.Repo]
+
+    Supervisor.start_link(children, strategy: :one_for_one, name: __MODULE__)
+  end
+end

lib/error_tracker/models/error.ex

@@ -0,0 +1,32 @@
+defmodule ErrorTracker.Error do
+  use Ecto.Schema
+
+  schema "error_tracker_errors" do
+    field :kind, :string
+    field :reason, :string
+    field :source, :string
+    field :status, Ecto.Enum, values: [:resolved, :unresolved], default: :unresolved
+    field :fingerprint, :binary
+
+    has_many :occurrences, ErrorTracker.Occurrence
+
+    timestamps()
+  end
+
+  def new(exception, stacktrace = %ErrorTracker.Stacktrace{}) do
+    source = ErrorTracker.Stacktrace.source(stacktrace)
+
+    params = [
+      kind: "error",
+      reason: Exception.message(exception),
+      source: to_string(source)
+    ]
+
+    fingerprint = :crypto.hash(:sha256, params |> Keyword.values() |> Enum.join())
+
+    %__MODULE__{}
+    |> Ecto.Changeset.change(params)
+    |> Ecto.Changeset.put_change(:fingerprint, Base.encode16(fingerprint))
+    |> Ecto.Changeset.apply_action(:new)
+  end
+end

lib/error_tracker/models/occurrence.ex

@@ -0,0 +1,12 @@
+defmodule ErrorTracker.Occurrence do
+  use Ecto.Schema
+
+  schema "error_tracker_occurrences" do
+    field :context, :map
+
+    embeds_one :stacktrace, ErrorTracker.Stacktrace
+    belongs_to :error, ErrorTracker.Error
+
+    timestamps(updated_at: false)
+  end
+end

lib/error_tracker/models/stacktrace.ex

@@ -0,0 +1,56 @@
+defmodule ErrorTracker.Stacktrace do
+  use Ecto.Schema
+
+  @primary_key false
+  embedded_schema do
+    embeds_many :lines, Line, primary_key: false do
+      field :application, :string
+      field :module, :string
+      field :function, :string
+      field :arity, :integer
+      field :file, :string
+      field :line, :integer
+    end
+  end
+
+  def new(stack) do
+    lines_params =
+      for {module, function, arity, opts} <- stack do
+        application = Application.get_application(module)
+
+        %{
+          application: to_string(application),
+          module: to_string(module),
+          function: to_string(function),
+          arity: arity,
+          file: to_string(opts[:file]),
+          line: opts[:line]
+        }
+      end
+
+    %__MODULE__{}
+    |> Ecto.Changeset.cast(%{lines: lines_params}, [])
+    |> Ecto.Changeset.cast_embed(:lines, with: &line_changeset/2)
+    |> Ecto.Changeset.apply_action(:new)
+  end
+
+  defp line_changeset(line = %__MODULE__.Line{}, params) do
+    Ecto.Changeset.cast(line, params, ~w[application module function arity file line]a)
+  end
+
+  def source(stack = %__MODULE__{}) do
+    List.first(stack.lines)
+  end
+end
+
+defimpl String.Chars, for: ErrorTracker.Stacktrace do
+  def to_string(stack = %ErrorTracker.Stacktrace{}) do
+    Enum.join(stack.lines, "\n")
+  end
+end
+
+defimpl String.Chars, for: ErrorTracker.Stacktrace.Line do
+  def to_string(stack_line = %ErrorTracker.Stacktrace.Line{}) do
+    "#{stack_line.module}.#{stack_line.function}/#{stack_line.arity} in #{stack_line.file}:#{stack_line.line}"
+  end
+end

lib/error_tracker/plug.ex

@@ -0,0 +1,18 @@
+defmodule ErrorTracker.Plug do
+  defmacro __using__(_opts) do
+    quote do
+      use Plug.ErrorHandler
+
+      @impl Plug.ErrorHandler
+      def handle_errors(conn, %{kind: kind, reason: reason, stack: stack}) do
+
+
+        dbg kind
+        dbg reason
+        dbg stack
+
+        :ok
+      end
+    end
+  end
+end

lib/error_tracker/repo.ex

@@ -0,0 +1,5 @@
+defmodule ErrorTracker.Repo do
+  use Ecto.Repo,
+    otp_app: :error_tracker,
+    adapter: Ecto.Adapters.Postgres
+end

mix.exs

@@ -6,6 +6,7 @@ defmodule ErrorTracker.MixProject do
       app: :error_tracker,
       version: "0.0.1",
       elixir: "~> 1.15",
+      elixirc_paths: elixirc_paths(Mix.env()),
       start_permanent: Mix.env() == :prod,
       deps: deps(),
       package: package(),
@@ -16,9 +17,15 @@ defmodule ErrorTracker.MixProject do
 
   # Run "mix help compile.app" to learn about applications.
   def application do
-    []
+    [
+      mod: {ErrorTracker.Application, []},
+      extra_applications: [:logger]
+    ]
   end
 
+  defp elixirc_paths(:test), do: ["lib", "test/support"]
+  defp elixirc_paths(_env), do: ["lib"]
+
   def package do
     [
       licenses: ["Apache-2.0"],
@@ -35,7 +42,11 @@ defmodule ErrorTracker.MixProject do
   # Run "mix help deps" to learn about dependencies.
   defp deps do
     [
-      {:ex_doc, "~> 0.33", only: :dev, runtime: false}
+      {:ecto_sql, "~> 3.0"},
+      {:ecto, "~> 3.11"},
+      {:ex_doc, "~> 0.33", only: :dev, runtime: false},
+      {:jason, "~> 1.1"},
+      {:postgrex, ">= 0.0.0"}
     ]
   end
 end