Add collector endpoint, host discovery integration event handler and …

…monitoring context (#34)

* Add discovery integration event handler

* Add monitoring context

* Add discovery API controller

* Add /api/collect route

Co-authored-by: Alessio Biancalana <[email protected]>

lib/tronto/monitoring/integration/discovery.ex

@@ -0,0 +1,30 @@
+defmodule Tronto.Monitoring.Integration.Discovery do
+  @moduledoc """
+  This module contains functions to handle integration events
+  from the discovery bounded-context
+  """
+
+  alias Tronto.Monitoring.Domain.Commands.RegisterHost
+
+  @spec handle_discovery_event(map) :: {:error, any} | {:ok, struct}
+  def handle_discovery_event(%{
+        "discovery_type" => "host_discovery",
+        "agent_id" => agent_id,
+        "payload" => %{
+          "hostname" => hostname,
+          "ip_addresses" => ip_addresses,
+          "agent_version" => agent_version
+        }
+      }) do
+    RegisterHost.new(
+      id_host: agent_id,
+      hostname: hostname,
+      ip_addresses: ip_addresses,
+      agent_version: agent_version
+    )
+  end
+
+  def handle_discovery_event(_) do
+    {:error, :invalid_payload}
+  end
+end

lib/tronto/monitoring/monitoring.ex

@@ -0,0 +1,17 @@
+defmodule Tronto.Monitoring do
+  @moduledoc """
+  This module encapuslates the access to the monitoring bounded context
+  """
+
+  alias Tronto.Monitoring.Integration.Discovery
+
+  def handle_discovery_event(event) do
+    case Discovery.handle_discovery_event(event) do
+      {:ok, command} ->
+        Tronto.Commanded.dispatch(command)
+
+      {:error, _} = error ->
+        error
+    end
+  end
+end

lib/tronto_web/controllers/discovery_controller.ex

@@ -0,0 +1,20 @@
+defmodule TrontoWeb.DiscoveryController do
+  use TrontoWeb, :controller
+
+  alias Tronto.Monitoring
+
+  @spec collect(Plug.Conn.t(), map) :: Plug.Conn.t()
+  def collect(conn, event) do
+    case Monitoring.handle_discovery_event(event) do
+      :ok ->
+        conn
+        |> put_status(:accepted)
+        |> json(%{})
+
+      {:error, reason} ->
+        conn
+        |> put_status(:bad_request)
+        |> json(%{error: reason})
+    end
+  end
+end

lib/tronto_web/router.ex

@@ -31,6 +31,11 @@ defmodule TrontoWeb.Router do
     get "/", PageController, :index
   end
 
+  scope "/api", TrontoWeb do
+    pipe_through :api
+    post "/collect", DiscoveryController, :collect
+  end
+
   # Other scopes may use custom stacks.
   # scope "/api", TrontoWeb do
   #   pipe_through :api