defmodule PhoenixKitProjects.Web.TasksLive do @moduledoc "List reusable task templates." use PhoenixKitWeb, :live_view use Gettext, backend: PhoenixKitProjects.Gettext use PhoenixKitProjects.Web.Components alias PhoenixKitProjects.{Activity, L10n, Paths, Projects} alias PhoenixKitProjects.PubSub, as: ProjectsPubSub alias PhoenixKitProjects.Schemas.Task, as: TaskSchema alias PhoenixKitProjects.Web.Helpers, as: WebHelpers require Logger @valid_views ~w(list groups) # Default wrapper class for the standalone admin page. Embedders can # override via `live_render(... session: %{"wrapper_class" => "..."})`. @default_wrapper_class "flex flex-col w-full px-4 py-6 gap-4" @impl true def mount(_params, session, socket) do WebHelpers.maybe_put_locale(session) if connected?(socket), do: ProjectsPubSub.subscribe(ProjectsPubSub.topic_tasks()) wrapper_class = Map.get(session, "wrapper_class", @default_wrapper_class) # `view` is UI state, not a URL param — the standalone admin page # toggles between list and groups via a `phx-click` button. Embedders # can preselect by passing `session["view"]` (defaults to "list"). initial_view = case Map.get(session, "view") do v when v in @valid_views -> v _ -> "list" end socket = socket |> assign( page_title: gettext("Task Library"), wrapper_class: wrapper_class, view: initial_view, tasks: [], deps_by_task: %{}, groups: [], standalone: [] ) |> WebHelpers.assign_embed_state(session) |> WebHelpers.attach_open_embed_hook() # Load on both disconnected + connected mount so the first paint has # real content. `handle_params/3` is intentionally absent — see # dev_docs/embedding_audit.md. {:ok, load_tasks(socket)} end # Loads only what the current view actually renders, so flipping # between modes doesn't pay for the unused query each time. defp load_tasks(socket) do case socket.assigns[:view] || "list" do "groups" -> %{trees: trees, standalone: standalone} = Projects.list_task_groups() # Flatten each tree to a peer-list, root-LAST (execution order: # prerequisites first, the rooted task at the bottom). The # rest of the list is alphabetised inside the tree so within # one card the order stays stable across renders even when # the tree shape changes. groups = Enum.map(trees, fn tree -> [root | rest] = flatten_tree(tree) %{root: root, peers: Enum.sort_by(rest, & &1.title) ++ [root]} end) assign(socket, groups: groups, standalone: standalone, tasks: [], deps_by_task: %{} ) _ -> %{tasks: tasks, deps_by_task: deps_by_task} = Projects.list_tasks_with_deps() assign(socket, tasks: tasks, deps_by_task: deps_by_task, groups: [], standalone: []) end end @impl true def handle_info({:projects, _event, _payload}, socket) do {:noreply, load_tasks(socket)} end def handle_info(msg, socket) do Logger.debug("[TasksLive] unexpected handle_info: #{inspect(msg)}") {:noreply, socket} end @impl true def handle_event("set_view", %{"view" => view}, socket) when view in @valid_views do {:noreply, socket |> assign(view: view) |> load_tasks()} end def handle_event("set_view", _params, socket), do: {:noreply, socket} def handle_event("reorder_tasks", %{"ordered_ids" => ordered_ids} = params, socket) when is_list(ordered_ids) do moved_id = params["moved_id"] actor_uuid = Activity.actor_uuid(socket) case Projects.reorder_tasks(ordered_ids, actor_uuid: actor_uuid) do :ok -> {:noreply, socket |> push_event("sortable:flash", %{uuid: moved_id, status: "ok"}) |> load_tasks()} {:error, :too_many_uuids} -> {:noreply, socket |> put_flash(:error, gettext("Too many tasks to reorder at once.")) |> push_event("sortable:flash", %{uuid: moved_id, status: "error"}) |> load_tasks()} {:error, _reason} -> {:noreply, socket |> put_flash(:error, gettext("Could not reorder tasks.")) |> push_event("sortable:flash", %{uuid: moved_id, status: "error"}) |> load_tasks()} end end def handle_event("delete", %{"uuid" => uuid}, socket) do case Projects.get_task(uuid) do nil -> {:noreply, put_flash(socket, :error, gettext("Task not found."))} task -> case Projects.delete_task(task) do {:ok, _} -> Activity.log("projects.task_deleted", actor_uuid: Activity.actor_uuid(socket), resource_type: "task", resource_uuid: task.uuid, metadata: %{"title" => task.title} ) {:noreply, socket |> WebHelpers.notify_deleted(:task, task.uuid) |> put_flash(:info, gettext("Task deleted.")) |> load_tasks()} {:error, _} -> Activity.log_failed("projects.task_deleted", actor_uuid: Activity.actor_uuid(socket), resource_type: "task", resource_uuid: task.uuid, metadata: %{"title" => task.title} ) {:noreply, put_flash(socket, :error, gettext("Could not delete task."))} end end end defp format_duration(task) do PhoenixKitProjects.Schemas.Task.format_duration( task.estimated_duration, task.estimated_duration_unit ) end # Flattens a closure tree to a unique-by-uuid task list. The root is # always first; everything else is in DFS order. The groups view # renders the result as a flat list of peer tasks (they are full # task templates, not subtasks) — the dep direction is shown by # each row's `→ X` badges, not by indentation. defp flatten_tree(tree), do: tree |> do_flatten_tree(MapSet.new()) |> elem(0) defp do_flatten_tree(%{cycle?: true}, seen), do: {[], seen} defp do_flatten_tree(%{task: task, children: children}, seen) do if MapSet.member?(seen, task.uuid) do {[], seen} else seen = MapSet.put(seen, task.uuid) {kids, seen} = Enum.reduce(children, {[], seen}, fn child, {acc, s} -> {child_tasks, s2} = do_flatten_tree(child, s) {acc ++ child_tasks, s2} end) {[task | kids], seen} end end @impl true def render(assigns) do ~H"""
{gettext("Each group is rooted at a task that nothing else depends on. Tasks reused across multiple groups appear in every one that pulls them in — they're independent task templates, the relationship is just a dependency.")}
{gettext("Tasks with no dependency relationships yet.")}