WIP injecting component names

lib/trento/activity_logging/parser/activity_parser.ex

@@ -4,7 +4,7 @@ defmodule Trento.ActivityLog.Parser.ActivityParser do
   """
 
   alias Trento.ActivityLog.ActivityCatalog
-  alias Trento.ActivityLog.Logger.Parser.{EventParser, PhoenixConnParser}
+  alias Trento.ActivityLog.Logger.Parser.{EventParser, MetadataEnricher, PhoenixConnParser}
 
   @type activity_log :: %{
           type: String.t(),
@@ -17,12 +17,15 @@ defmodule Trento.ActivityLog.Parser.ActivityParser do
   def to_activity_log(activity, activity_context) do
     with true <- activity in ActivityCatalog.supported_activities(),
          {:ok, actor} <- get_activity_info(:actor, activity, activity_context),
-         {:ok, metadata} <- get_activity_info(:metadata, activity, activity_context) do
+         {:ok, metadata} <-
+           get_activity_info(:metadata, activity, activity_context)
+           |> IO.inspect(label: "metadata"),
+         {:ok, enriched_metadata} <- MetadataEnricher.enrich(metadata, activity, activity_context) do
       {:ok,
        %{
          type: Atom.to_string(activity),
          actor: actor,
-         metadata: metadata
+         metadata: enriched_metadata
        }}
     else
       _ -> {:error, :cannot_parse_activity}

lib/trento/activity_logging/parser/metadata_enricher.ex

@@ -0,0 +1,67 @@
+defmodule Trento.ActivityLog.Logger.Parser.MetadataEnricher do
+  @moduledoc """
+  Metadata enricher enriches metadata extracted by activity parser.
+  """
+  alias Trento.Databases
+  alias Trento.Clusters.Projections.ClusterReadModel
+  alias Trento.Clusters
+  alias Trento.Hosts.Projections.HostReadModel
+  alias Trento.Hosts
+
+  def enrich(
+        %{
+          resource_id: resource_id,
+          resource_type: resource_type
+        } = metadata,
+        activity,
+        activity_context
+      )
+      when activity in [:resource_tagging, :resource_untagging] do
+    IO.inspect(activity, label: "activity")
+
+    resource_name =
+      case resource_type do
+        :host -> get_hostname(resource_id)
+        :cluster -> get_cluster_name(resource_id)
+        _ -> nil
+      end
+
+    IO.inspect(resource_name, label: "resource_name")
+
+    {:ok,
+     case resource_name do
+       nil -> metadata
+       _ -> Map.put(metadata, :resource_name, resource_name)
+     end}
+  end
+
+  def enrich(metadata, activity, activity_context) do
+    metadata
+  end
+
+  defp get_hostname(id) do
+    case Hosts.by_host_id(id) do
+      {:ok, %HostReadModel{hostname: hostname}} -> hostname
+      {:error, :not_found} -> nil
+    end
+  end
+
+  defp get_cluster_name(id) do
+    case Clusters.by_cluster_id(id) do
+      {:ok, %ClusterReadModel{name: cluster_name}} -> cluster_name
+      {:error, :not_found} -> nil
+    end
+  end
+
+  defp get_database_sid(id) do
+  end
+
+  defp get_sap_system_sid(id) do
+  end
+
+  defp get_application_instance_number(id) do
+  end
+
+  defp get_database_instance_number(id) do
+  end
+end

lib/trento/clusters.ex

@@ -27,6 +27,15 @@ defmodule Trento.Clusters do
 
   alias Trento.Repo
 
+  def by_cluster_id(cluster_id) do
+    case ClusterReadModel
+         |> where([c], c.id == ^cluster_id and is_nil(c.deregistered_at))
+         |> Repo.one() do
+      nil -> {:error, :not_found}
+      cluster -> {:ok, cluster}
+    end
+  end
+
   @spec select_checks(String.t(), [String.t()]) :: :ok | {:error, any}
   def select_checks(cluster_id, checks) do
     Logger.debug("Selecting checks, cluster: #{cluster_id}")

lib/trento/databases.ex

@@ -16,6 +16,15 @@ defmodule Trento.Databases do
 
   alias Trento.Repo
 
+  def by_database_id(id) do
+    case DatabaseReadModel
+         |> where([d], d.id == ^id and is_nil(d.deregistered_at))
+         |> Repo.one() do
+      nil -> {:error, :not_found}
+      database -> {:ok, database}
+    end
+  end
+
   @spec get_all_databases :: [DatabaseReadModel.t()]
   def get_all_databases do
     DatabaseReadModel