defmodule PrymnWeb.ServerLive.Show do use PrymnWeb, :live_view require Logger alias Prymn.{Agents, Servers} @impl true def mount(_params, _session, socket) do # TODO: A more lightweight call instead of listing all data? servers = Servers.list_servers() {:ok, assign(socket, :servers, servers)} end @impl true def render(assigns) do ~H"""
<.dropdown title="Select a different server"> <:button>Server <%= @server.name %> <:item :for={server <- Enum.filter(@servers, fn s -> s.id != @server.id end)}> <.link patch={~p"/servers/#{server}"} class="block text-sm text-gray-700" role="menuitem" > <%= server.name %> <.indicator message={@health.message} />
New App <.dropdown> <:button> Quick actions <:item> Test
<%= @server.public_ip %>

Background task in progress: <%= name %>

<%= task.progress %> complete

Connect to your server using root credentials and execute the following command:

# <%= @registration_command %>
<.live_component id={"system_info-#{@server.name}"} module={PrymnWeb.SystemInfo} ip={@server.public_ip} />
<.input type="checkbox" name="dry_run" value={@dry_run} label="Enable dry-run operations" />

System

Updates: <%= 0 %> pending updates. Update now

<%= output %>

Backups

<.table id="backups" rows={[%{date: "2023-10-11"}, %{date: "2023-10-10"}]}> <:col :let={backup} label="Date"><%= backup.date %> <:action> Restore

Manage Services

<.table id="services" rows={[%{name: "mariadb", status: "Active"}, %{name: "php8.0", status: "Disabled"}]} > <:col :let={service} label="Service"><%= service.name %> <:col :let={service} label="Status"><%= service.status %> <:action> Activate Deactivate
<.back navigate={~p"/servers"}>Back to servers
""" end @impl true def handle_params(%{"id" => id}, _, socket) do server = Servers.get_server!(id) if connected?(socket) and server.status == :registered do Agents.subscribe_to_health(server.public_ip) Agents.start_connection(server.public_ip) end health = Agents.get_health(server.public_ip) {:noreply, socket |> assign(:page_title, server.name) |> assign(:health, health || %{message: "Connecting...", tasks: []}) |> assign(:server, server) |> assign(:dry_run, false) |> assign(:update_output, []) # TODO: Do not assign this to the socket - instead generate it in the HTML |> assign(:registration_command, Servers.create_setup_command(server))} end @impl true def handle_info(%PrymnProto.Prymn.SysUpdateResponse{} = response, socket) do output = String.split(response.output, "\n") socket = assign(socket, :update_output, output) {:noreply, socket} end def handle_info(%Agents.Health{host: host} = health, socket) do socket = if host == socket.assigns.server.public_ip, do: assign(socket, :health, health), else: socket {:noreply, socket} end @impl true def handle_event("system_update", _params, socket) do host_address = get_in(socket.assigns, [:server, Access.key(:public_ip)]) server_name = get_in(socket.assigns, [:server, Access.key(:name)]) socket = if host_address do Agents.sys_update(host_address, socket.assigns.dry_run) put_flash(socket, :info, "Started a system update on server #{server_name}.") else put_flash( socket, :error, "Could not perform the update. Your server does not seem to have an address" ) end {:noreply, socket} end def handle_event("edit_server_name", %{"name" => name}, socket) do server = socket.assigns.server |> Servers.update_server(%{"name" => name}) |> case do {:ok, server} -> server {:error, _} -> raise "Oops" end {:noreply, assign(socket, :server, server)} end def handle_event("change_dry_run", %{"dry_run" => enabled}, socket) do enabled = (enabled == "true" && true) || false {:noreply, assign(socket, :dry_run, enabled)} end defp show_edit_server_name() do JS.hide(to: "#server-name") |> JS.show(to: "#server-name-edit") |> JS.focus_first(to: "#server-name-edit") end defp submit_edit_server_name() do JS.push("edit_server_name") |> JS.hide() |> JS.show(to: "#server-name", display: "flex") end defp indicator(assigns) do ~H""" <%= case @message do %> <% "Connected" -> %> <% "Disconnected" -> %> <% _ -> %> <% end %> """ end end