defmodule DalaDev.Server.ObserverLive.Applications do @moduledoc "LiveView for applications list display." use Phoenix.LiveView, layout: {DalaDev.Server.Layouts, :app} alias DalaDev.Observer @refresh_interval 5_000 def mount(_params, _session, socket) do if connected?(socket), do: :timer.send_interval(@refresh_interval, self(), :refresh) socket = socket |> assign(:node, Node.self()) |> assign(:available_nodes, [Node.self() | Node.list()]) |> assign(:applications, []) |> assign(:error, nil) |> assign(:loading, false) {:ok, fetch_applications(socket)} end def handle_params(%{"node" => node_str}, _uri, socket) do try do node = String.to_existing_atom(":#{node_str}") {:noreply, assign(socket, :node, node) |> fetch_applications()} rescue _ -> {:noreply, assign(socket, :error, "Invalid node name: #{node_str}")} end end def handle_params(_params, _uri, socket), do: {:noreply, socket} def handle_info(:refresh, socket), do: {:noreply, fetch_applications(socket)} def handle_event("refresh", _params, socket), do: {:noreply, fetch_applications(socket)} def handle_event("select_node", %{"node" => node_str}, socket) do try do node = String.to_existing_atom(node_str) {:noreply, assign(socket, :node, node) |> fetch_applications()} rescue _ -> {:noreply, assign(socket, :error, "Invalid node: #{node_str}")} end end def render(assigns) do ~H"""
← Back

Applications: <%= @node %>

<%= if @error do %>

<%= @error %>

<% end %>
<%= for app <- @applications do %>

<%= app.name %>

<%= app.description %>

Version: <%= app.version %>

<% end %>
""" end defp fetch_applications(socket) do node = socket.assigns[:node] socket = socket |> assign(:loading, true) |> assign(:available_nodes, [Node.self() | Node.list()]) case Observer.observe(node) do {:ok, data} -> apps = data[:applications] || [] assign(socket, :applications, apps) |> assign(:error, nil) |> assign(:loading, false) {:error, reason} -> assign(socket, :error, "Failed: #{reason}") |> assign(:loading, false) end end end