"""
end
# ===========================================
# LIST VIEW
# ===========================================
defp connections_list(assigns) do
~H"""
<%!-- Actions Bar --%>
<%!-- Sender Connections --%>
<%= if @direction_filter != "receiver" do %>
"""
end
defp connection_actions(assigns) do
# Default sender_status to nil if not provided
assigns = assign_new(assigns, :sender_status, fn -> nil end)
~H"""
<%!-- Sync button only for receivers when sender status is active --%>
<%= if @connection.direction == "receiver" and @sender_status == "active" do %>
<% end %>
<%!-- Edit button only for senders (receivers get info from sender) --%>
<%= if @connection.direction == "sender" do %>
<% end %>
<%!-- Delete/Sever connection button --%>
<%!-- Status controls only for sender connections (receivers sync from sender) --%>
<%= if @connection.direction == "sender" do %>
<%= if @connection.status == "active" do %>
<% end %>
<%= if @connection.status == "suspended" do %>
<% end %>
<% end %>
"""
end
# ===========================================
# FORM VIEW
# ===========================================
defp connection_form(assigns) do
assigns = assign_new(assigns, :connection, fn -> nil end)
~H"""
<%= if @action == :new do %>
New Connection
<% else %>
Edit Connection
<% end %>
<.form
for={@changeset}
phx-submit="save"
class="space-y-6"
>
<%!-- Name Field --%>
<%= if @changeset.action && @changeset.errors[:name] do %>
{elem(@changeset.errors[:name], 0)}
<% end %>
<%!-- Direction Field --%>
<%= if @action == :new do %>
Sender
Allow remote site to pull data from here
Receiver connections are created automatically when remote sites connect
<%= if @connection.last_connected_at do %>
{format_time_ago(@connection.last_connected_at)}
<% else %>
Never
<% end %>
<%= if @connection.last_transfer_at do %>
{format_time_ago(@connection.last_transfer_at)}
<% else %>
Never
<% end %>
<%!-- Actions --%>
Actions
<%!-- Status controls only for sender connections (receivers sync status from sender) --%>
<%= if @connection.direction == "sender" do %>
<%= if @connection.status == "active" do %>
<% end %>
<%= if @connection.status == "suspended" do %>
<% end %>
<% end %>
<%= if @connection.status not in ["revoked"] do %>
<% end %>
<%!-- Back Button --%>
"""
end
# ===========================================
# SYNC VIEW
# ===========================================
defp sync_view(assigns) do
~H"""
<.icon name="hero-arrow-path" class="w-6 h-6" /> Sync Data
<% end %>
<% end %>
<% end %>
<% else %>
<%!-- ========== PRECISE TRANSFER TAB ========== --%>
<%= if @progress && Map.get(@progress, :status) == :completed do %>
Select a table above to view details and transfer options
<% end %>
<% end %>
<% end %>
<% end %>
"""
end
# ===========================================
# HELPER COMPONENTS
# ===========================================
defp status_badge(assigns) do
{color, label} =
case assigns.status do
"pending" -> {"badge-warning", "Pending"}
"active" -> {"badge-success", "Active"}
"suspended" -> {"badge-error", "Suspended"}
"revoked" -> {"badge-ghost", "Revoked"}
"expired" -> {"badge-ghost", "Expired"}
"loading" -> {"badge-ghost animate-pulse", "Loading..."}
"offline" -> {"badge-warning", "Sender Offline"}
"not_found" -> {"badge-error", "Not Found"}
"error" -> {"badge-error", "Error"}
_ -> {"badge-ghost", String.capitalize(to_string(assigns.status))}
end
assigns = assigns |> assign(:color, color) |> assign(:label, label)
~H"""
{@label}
"""
end
# ===========================================
# HELPER FUNCTIONS
# ===========================================
defp format_time_ago(datetime) do
now = DateTime.utc_now()
diff = DateTime.diff(now, datetime, :second)
cond do
diff < 60 -> "just now"
diff < 3600 -> "#{div(diff, 60)}m ago"
diff < 86_400 -> "#{div(diff, 3600)}h ago"
diff < 604_800 -> "#{div(diff, 86_400)}d ago"
true -> Calendar.strftime(datetime, "%b %d")
end
end
defp format_bytes(bytes) when is_nil(bytes) or bytes == 0, do: "0 B"
defp format_bytes(bytes) do
cond do
bytes >= 1_073_741_824 -> "#{Float.round(bytes / 1_073_741_824, 1)} GB"
bytes >= 1_048_576 -> "#{Float.round(bytes / 1_048_576, 1)} MB"
bytes >= 1024 -> "#{Float.round(bytes / 1024, 1)} KB"
true -> "#{bytes} B"
end
end
defp path_with_params(base_path, params) when map_size(params) == 0 do
Routes.path(base_path)
end
defp path_with_params(base_path, params) do
query_string = URI.encode_query(params)
"#{Routes.path(base_path)}?#{query_string}"
end
defp format_number(num) when is_integer(num) do
num
|> Integer.to_string()
|> String.reverse()
|> String.replace(~r/.{3}(?=.)/, "\\0,")
|> String.reverse()
end
defp format_number(num), do: "#{num}"
defp parse_id_list(ids_string) when is_binary(ids_string) do
ids_string
|> String.split(",")
|> Enum.map(&String.trim/1)
|> Enum.filter(&(&1 != ""))
|> Enum.map(fn id ->
case Integer.parse(id) do
{int, _} -> int
:error -> nil
end
end)
|> Enum.filter(&(&1 != nil))
end
defp parse_id_list(_), do: []
defp parse_int(val) when is_binary(val) do
case Integer.parse(val) do
{int, _} -> int
:error -> nil
end
end
defp parse_int(val) when is_integer(val), do: val
defp parse_int(_), do: nil
# Get schema columns, handling both atom and string keys
defp get_schema_columns(nil), do: []
defp get_schema_columns(schema) when is_map(schema) do
Map.get(schema, :columns) || Map.get(schema, "columns") || []
end
defp get_schema_columns(_), do: []
# Table summary stat component
defp table_summary_stat(assigns) do
~H"""
{@count}{@label}
"""
end
# Count tables that don't exist locally
defp count_new_tables(tables, local_counts) do
Enum.count(tables, fn table ->
name = table.name || table["name"]
not Map.has_key?(local_counts, name)
end)
end
# Count tables with different counts
defp count_different_tables(tables, local_counts) do
Enum.count(tables, fn table ->
name = table.name || table["name"]
local_count = Map.get(local_counts, name)
sender_count = table.row_count || table["row_count"] || 0
not is_nil(local_count) and local_count != sender_count
end)
end
# Count tables that match (same count)
defp count_same_tables(tables, local_counts) do
Enum.count(tables, fn table ->
name = table.name || table["name"]
local_count = Map.get(local_counts, name)
sender_count = table.row_count || table["row_count"] || 0
not is_nil(local_count) and local_count == sender_count
end)
end
end