c2caeed64d
- new /setup page with three-section onboarding (account, provider, payments) - dashboard launch checklist with progress bar, go-live, dismiss - provider registry on Provider module (single source of truth for metadata) - payments registry for Stripe - setup context made provider-agnostic (provider_connected, theme_customised, etc.) - admin provider pages now fully registry-driven (no hardcoded provider names) - auth flow: fresh installs redirect to /setup, signed_in_path respects setup state - removed old /admin/setup wizard - 840 tests, 0 failures Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com>
108 lines
3.0 KiB
Elixir
108 lines
3.0 KiB
Elixir
defmodule BerrypodWeb.Admin.Providers.Index do
|
|
use BerrypodWeb, :live_view
|
|
|
|
alias Berrypod.Products
|
|
alias Berrypod.Products.ProviderConnection
|
|
alias Berrypod.Providers.Provider
|
|
|
|
@impl true
|
|
def mount(_params, _session, socket) do
|
|
connections = Products.list_provider_connections()
|
|
|
|
{:ok,
|
|
socket
|
|
|> assign(:page_title, "Provider connections")
|
|
|> assign(:available_providers, Provider.available())
|
|
|> stream(:connections, connections)}
|
|
end
|
|
|
|
@impl true
|
|
def handle_event("delete", %{"id" => id}, socket) do
|
|
connection = Products.get_provider_connection!(id)
|
|
{:ok, _} = Products.delete_provider_connection(connection)
|
|
|
|
{:noreply,
|
|
socket
|
|
|> stream_delete(:connections, connection)
|
|
|> put_flash(:info, "Provider connection deleted")}
|
|
end
|
|
|
|
@impl true
|
|
def handle_event("sync", %{"id" => id}, socket) do
|
|
connection = Products.get_provider_connection!(id)
|
|
|
|
case Products.enqueue_sync(connection) do
|
|
{:ok, _job} ->
|
|
# Update the connection status in the stream
|
|
updated = %{connection | sync_status: "syncing"}
|
|
|
|
{:noreply,
|
|
socket
|
|
|> stream_insert(:connections, updated)
|
|
|> put_flash(:info, "Sync started for #{connection.name}")}
|
|
|
|
{:error, _reason} ->
|
|
{:noreply, put_flash(socket, :error, "Failed to start sync")}
|
|
end
|
|
end
|
|
|
|
# Function components for the template
|
|
|
|
attr :status, :string, required: true
|
|
attr :enabled, :boolean, required: true
|
|
|
|
defp status_indicator(assigns) do
|
|
~H"""
|
|
<span class={[
|
|
"inline-flex size-3 rounded-full",
|
|
cond do
|
|
not @enabled -> "bg-base-content/30"
|
|
@status == "syncing" -> "bg-warning animate-pulse"
|
|
@status == "completed" -> "bg-success"
|
|
@status == "failed" -> "bg-error"
|
|
true -> "bg-base-content/30"
|
|
end
|
|
]} />
|
|
"""
|
|
end
|
|
|
|
attr :connection, ProviderConnection, required: true
|
|
|
|
defp connection_info(assigns) do
|
|
product_count = Products.count_products_for_connection(assigns.connection.id)
|
|
assigns = assign(assigns, :product_count, product_count)
|
|
|
|
~H"""
|
|
<span>
|
|
<.icon name="hero-cube" class="size-4 inline" />
|
|
{@product_count} {if @product_count == 1, do: "product", else: "products"}
|
|
</span>
|
|
<span :if={@connection.last_synced_at}>
|
|
<.icon name="hero-clock" class="size-4 inline" />
|
|
Last synced {format_relative_time(@connection.last_synced_at)}
|
|
</span>
|
|
<span :if={!@connection.last_synced_at} class="text-warning">
|
|
<.icon name="hero-exclamation-triangle" class="size-4 inline" /> Never synced
|
|
</span>
|
|
"""
|
|
end
|
|
|
|
defp provider_name(type) do
|
|
case Provider.get(type) do
|
|
%{name: name} -> name
|
|
nil -> String.capitalize(type)
|
|
end
|
|
end
|
|
|
|
defp format_relative_time(datetime) do
|
|
diff = DateTime.diff(DateTime.utc_now(), datetime, :second)
|
|
|
|
cond do
|
|
diff < 60 -> "just now"
|
|
diff < 3600 -> "#{div(diff, 60)} min ago"
|
|
diff < 86400 -> "#{div(diff, 3600)} hours ago"
|
|
true -> "#{div(diff, 86400)} days ago"
|
|
end
|
|
end
|
|
end
|