defmodule Phoenix.LiveDashboard.TableComponent do use Phoenix.LiveDashboard.Web, :live_component alias Phoenix.LiveDashboard.PageBuilder @limit [50, 100, 500, 1000, 5000] @type params() :: %{ limit: pos_integer(), sort_by: :atom, sort_dir: :desc | :asc, search: binary(), hint: binary() | nil } @impl true def mount(socket) do {:ok, socket} end @impl true def update(assigns, socket) do assigns = normalize_update(assigns) apply_update(socket, assigns) end defp normalize_update(assigns) do assigns |> normalize_columns() |> validate_required_one_sortable_column() |> Map.put_new(:search, true) |> Map.put_new(:limit, @limit) |> Map.put_new(:row_attrs, []) |> Map.put_new(:hint, nil) |> Map.put_new(:dom_id, nil) |> Map.update(:default_sort_by, nil, &(&1 && to_string(&1))) |> Map.put_new_lazy(:rows_name, fn -> Phoenix.Naming.humanize(assigns.title) |> String.downcase() end) end defp normalize_columns(%{col: columns} = params) when is_list(columns) do %{params | col: Enum.map(columns, &normalize_column/1)} end defp normalize_column(column) do case Access.fetch(column, :field) do {:ok, nil} -> msg = ":field parameter must not be nil, got: #{inspect(column)}" raise ArgumentError, msg {:ok, field} when is_atom(field) or is_binary(field) -> column |> Map.new() |> Map.put_new_lazy(:header, fn -> Phoenix.Naming.humanize(field) end) |> Map.put_new(:sortable, nil) |> Map.put_new(:text_align, nil) {:ok, _} -> msg = ":field parameter must be an atom or a string, got: " raise ArgumentError, msg <> inspect(column) :error -> msg = "the :field parameter is expected, got: #{inspect(column)}" raise ArgumentError, msg end end defp validate_required_one_sortable_column(%{col: columns} = params) do if sortable_columns(columns) == [] do raise ArgumentError, "must have at least one column with :sortable parameter" else params end end defp apply_update(socket, assigns) do assigns = normalize_table_params(assigns) %{ table_params: table_params, page: page, row_fetcher: row_fetcher } = assigns {rows, total, socket} = fetch_rows(row_fetcher, table_params, page.node, socket) assigns = Map.merge(assigns, %{rows: rows, total: total}) {:ok, assign(socket, assigns)} end defp fetch_rows(row_fetcher, table_params, page_node, socket) when is_function(row_fetcher, 2) do {rows, total} = row_fetcher.(table_params, page_node) {rows, total, socket} end defp fetch_rows({row_fetcher, initial_state}, table_params, page_node, socket) when is_function(row_fetcher, 3) do state = Map.get(socket.assigns, :row_fetcher_state, initial_state) {rows, total, state} = row_fetcher.(table_params, page_node, state) {rows, total, assign(socket, :row_fetcher_state, state)} end defp normalize_table_params(assigns) do %{col: columns, page: %{params: all_params}, default_sort_by: sort_by} = assigns sortable_columns = sortable_columns(columns) sort_by = all_params |> get_in_or_first("sort_by", sort_by, sortable_columns) |> String.to_atom() sort_dir = all_params |> get_in_or_first("sort_dir", sortable_dirs(columns, sort_by)) |> String.to_atom() limit = if assigns.limit do all_params |> get_in_or_first("limit", Enum.map(assigns.limit, &to_string/1)) |> String.to_integer() end search = all_params["search"] search = if search == "", do: nil, else: search table_params = %{sort_by: sort_by, sort_dir: sort_dir, limit: limit, search: search} assigns |> Map.put(:table_params, table_params) |> Map.delete(:col) |> Map.put(:columns, columns) end defp sortable_columns(columns) do for column <- columns, column[:sortable], do: to_string(column.field) end defp sortable_dirs(columns, field) do case Enum.find(columns, &(&1.field == field)) do %{sortable: :desc} -> ~w(desc asc) %{sortable: :asc} -> ~w(asc desc) end end defp get_in_or_first(params, key, default \\ nil, valid) do value = params[key] if value in valid, do: value, else: default || hd(valid) end @impl true def render(assigns) do ~H"""
| <%= if column[:sortable] do %> <.sort_link socket={@socket} page={@page} table_params={@table_params} column={column} /> <% else %> <%= column[:header] || column[:field] %> <% end %> |
|---|
| <%= if column[:inner_block] do %> <%= render_slot(column, row) %> <% else %> <%= row[column.field] |> to_string() %> <% end %> |