defmodule ComponentsElixirWeb.ComponentsLive do use ComponentsElixirWeb, :live_view alias ComponentsElixir.{Inventory, Auth} alias ComponentsElixir.Inventory.{Component, StorageLocation, Hierarchical} @items_per_page 20 @impl true def mount(_params, session, socket) do # Check authentication if Auth.authenticated?(session) do categories = Inventory.list_categories() storage_locations = Inventory.list_storage_locations() stats = Inventory.component_stats() {:ok, socket |> assign(:session, session) |> assign(:categories, categories) |> assign(:storage_locations, storage_locations) |> assign(:stats, stats) |> assign(:search, "") |> assign(:sort_criteria, "name_asc") |> assign(:selected_category, nil) |> assign(:selected_storage_location, nil) |> assign(:show_advanced_filters, false) |> assign(:offset, 0) |> assign(:components, []) |> assign(:has_more, false) |> assign(:loading, false) |> assign(:sort_freeze_until, nil) |> assign(:interacting_with, nil) |> assign(:sort_freeze_timer, nil) |> assign(:sort_frozen, false) |> assign(:show_add_form, false) |> assign(:show_edit_form, false) |> assign(:editing_component, nil) |> assign(:form, nil) |> assign(:show_image_modal, false) |> assign(:modal_image_url, nil) |> assign(:focused_component_id, nil) |> allow_upload(:image, accept: ~w(.jpg .jpeg .png .gif), max_entries: 1, max_file_size: 5_000_000 ) |> allow_upload(:datasheet, accept: ~w(.pdf), max_entries: 1, max_file_size: 10_000_000 ) |> load_components()} else {:ok, socket |> push_navigate(to: ~p"/login")} end end @impl true def handle_params(params, _uri, socket) do search = Map.get(params, "search", "") criteria = Map.get(params, "criteria", "name_asc") category_id = parse_filter_id(Map.get(params, "category_id")) storage_location_id = parse_filter_id(Map.get(params, "storage_location_id")) # Show advanced filters if storage location is being used show_advanced = not is_nil(storage_location_id) {:noreply, socket |> assign(:search, search) |> assign(:sort_criteria, criteria) |> assign(:selected_category, category_id) |> assign(:selected_storage_location, storage_location_id) |> assign(:show_advanced_filters, show_advanced) |> assign(:offset, 0) |> load_components()} end @impl true def handle_event("search", %{"search" => search}, socket) do query_string = build_query_params(socket, %{search: search}) path = if query_string == "", do: "/", else: "/?" <> query_string {:noreply, socket |> assign(:search, search) |> assign(:offset, 0) |> load_components() |> push_patch(to: path)} end def handle_event("sort_change", %{"sort_criteria" => criteria}, socket) do query_string = build_query_params(socket, %{criteria: criteria}) path = if query_string == "", do: "/", else: "/?" <> query_string {:noreply, socket |> assign(:sort_criteria, criteria) |> assign(:offset, 0) |> load_components() |> push_patch(to: path)} end def handle_event("category_filter", %{"category_id" => ""}, socket) do query_string = build_query_params_without_category(socket) path = if query_string == "", do: "/", else: "/?" <> query_string {:noreply, socket |> assign(:selected_category, nil) |> assign(:offset, 0) |> load_components() |> push_patch(to: path)} end def handle_event("category_filter", %{"category_id" => category_id}, socket) do category_id = String.to_integer(category_id) query_string = build_query_params_with_category(socket, category_id) path = if query_string == "", do: "/", else: "/?" <> query_string {:noreply, socket |> assign(:selected_category, category_id) |> assign(:offset, 0) |> load_components() |> push_patch(to: path)} end def handle_event("storage_location_filter", %{"storage_location_id" => ""}, socket) do query_string = build_query_params_with_storage_location(socket, nil) path = if query_string == "", do: "/", else: "/?" <> query_string {:noreply, socket |> assign(:selected_storage_location, nil) |> assign(:offset, 0) |> load_components() |> push_patch(to: path)} end def handle_event("storage_location_filter", %{"storage_location_id" => storage_location_id}, socket) do storage_location_id = String.to_integer(storage_location_id) query_string = build_query_params_with_storage_location(socket, storage_location_id) path = if query_string == "", do: "/", else: "/?" <> query_string {:noreply, socket |> assign(:selected_storage_location, storage_location_id) |> assign(:offset, 0) |> load_components() |> push_patch(to: path)} end def handle_event("toggle_advanced_filters", _params, socket) do {:noreply, assign(socket, :show_advanced_filters, !socket.assigns.show_advanced_filters)} end def handle_event("load_more", _params, socket) do new_offset = socket.assigns.offset + @items_per_page {:noreply, socket |> assign(:offset, new_offset) |> load_components(append: true)} end def handle_event("increment_count", %{"id" => id}, socket) do component = Inventory.get_component!(id) case Inventory.increment_component_count(component) do {:ok, _updated_component} -> # Only apply sort freeze for dynamic sorting criteria should_freeze = socket.assigns.sort_criteria in [ "count_asc", "count_desc", "updated_at_asc", "updated_at_desc" ] if should_freeze do # Cancel any existing timer if socket.assigns.sort_freeze_timer do Process.cancel_timer(socket.assigns.sort_freeze_timer) end # Set sort freeze for 3 seconds and mark component as interacting freeze_until = DateTime.add(DateTime.utc_now(), 3, :second) # Set new timer to clear interaction state timer_ref = Process.send_after(self(), {:clear_interaction, id}, 3000) {:noreply, socket |> put_flash(:info, "Count updated") |> assign(:sort_freeze_until, freeze_until) |> assign(:interacting_with, id) |> assign(:sort_freeze_timer, timer_ref) |> assign(:sort_frozen, true) |> load_components()} else # Normal behavior for stable sorts {:noreply, socket |> put_flash(:info, "Count updated") |> load_components()} end {:error, _changeset} -> {:noreply, put_flash(socket, :error, "Failed to update count")} end end def handle_event("decrement_count", %{"id" => id}, socket) do component = Inventory.get_component!(id) case Inventory.decrement_component_count(component) do {:ok, _updated_component} -> # Only apply sort freeze for dynamic sorting criteria should_freeze = socket.assigns.sort_criteria in [ "count_asc", "count_desc", "updated_at_asc", "updated_at_desc" ] if should_freeze do # Cancel any existing timer if socket.assigns.sort_freeze_timer do Process.cancel_timer(socket.assigns.sort_freeze_timer) end # Set sort freeze for 3 seconds and mark component as interacting freeze_until = DateTime.add(DateTime.utc_now(), 3, :second) # Set new timer to clear interaction state timer_ref = Process.send_after(self(), {:clear_interaction, id}, 3000) {:noreply, socket |> put_flash(:info, "Count updated") |> assign(:sort_freeze_until, freeze_until) |> assign(:interacting_with, id) |> assign(:sort_freeze_timer, timer_ref) |> assign(:sort_frozen, true) |> load_components()} else # Normal behavior for stable sorts {:noreply, socket |> put_flash(:info, "Count updated") |> load_components()} end {:error, _changeset} -> {:noreply, put_flash(socket, :error, "Failed to update count")} end end def handle_event("delete_component", %{"id" => id}, socket) do component = Inventory.get_component!(id) case Inventory.delete_component(component) do {:ok, _deleted_component} -> # Clean up the image file if it exists delete_image_file(component.image_filename) {:noreply, socket |> put_flash(:info, "Component deleted") |> load_components()} {:error, _changeset} -> {:noreply, put_flash(socket, :error, "Failed to delete component")} end end def handle_event("show_add_form", _params, socket) do changeset = Inventory.change_component(%Component{}) form = to_form(changeset) {:noreply, socket |> assign(:show_add_form, true) |> assign(:form, form)} end def handle_event("hide_add_form", _params, socket) do {:noreply, socket |> assign(:show_add_form, false) |> assign(:form, nil)} end def handle_event("show_edit_form", %{"id" => id}, socket) do component = Inventory.get_component!(id) changeset = Inventory.change_component(component) form = to_form(changeset) {:noreply, socket |> assign(:show_edit_form, true) |> assign(:editing_component, component) |> assign(:form, form)} end def handle_event("hide_edit_form", _params, socket) do {:noreply, socket |> assign(:show_edit_form, false) |> assign(:editing_component, nil) |> assign(:form, nil)} end def handle_event("show_image", %{"url" => url}, socket) do {:noreply, socket |> assign(:show_image_modal, true) |> assign(:modal_image_url, url)} end def handle_event("close_image_modal", _params, socket) do {:noreply, socket |> assign(:show_image_modal, false) |> assign(:modal_image_url, nil)} end def handle_event("toggle_focus", %{"id" => id}, socket) do component_id = String.to_integer(id) new_focused_id = if socket.assigns.focused_component_id == component_id do # Unfocus if clicking on the same component nil else # Focus on the new component component_id end {:noreply, assign(socket, :focused_component_id, new_focused_id)} end def handle_event("prevent_close", _params, socket) do {:noreply, socket} end def handle_event("validate", _params, socket) do {:noreply, socket} end def handle_event("cancel-upload", %{"ref" => ref}, socket) do {:noreply, cancel_upload(socket, :image, ref)} end def handle_event("cancel-datasheet-upload", %{"ref" => ref}, socket) do {:noreply, cancel_upload(socket, :datasheet, ref)} end def handle_event("save_component", %{"component" => component_params}, socket) do # Handle any uploaded files updated_params = socket |> save_uploaded_image(component_params) |> save_uploaded_datasheet(socket) case Inventory.create_component_with_datasheet(updated_params) do {:ok, _component} -> {:noreply, socket |> put_flash(:info, "Component created successfully") |> assign(:show_add_form, false) |> assign(:form, nil) |> load_components()} {:error, changeset} -> {:noreply, assign(socket, :form, to_form(changeset))} end end def handle_event("save_edit", %{"component" => component_params}, socket) do # Handle any uploaded files updated_params = socket |> save_uploaded_image(component_params) |> save_uploaded_datasheet(socket) case Inventory.update_component_with_datasheet(socket.assigns.editing_component, updated_params) do {:ok, _component} -> {:noreply, socket |> put_flash(:info, "Component updated successfully") |> assign(:show_edit_form, false) |> assign(:editing_component, nil) |> assign(:form, nil) |> load_components()} {:error, changeset} -> {:noreply, assign(socket, :form, to_form(changeset))} end end @impl true def handle_info({:clear_interaction, component_id}, socket) do # Only clear if this timer is for the currently interacting component if socket.assigns.interacting_with == component_id do # Clear interaction state and allow sorting to resume {:noreply, socket |> assign(:sort_freeze_until, nil) |> assign(:interacting_with, nil) |> assign(:sort_freeze_timer, nil) |> assign(:sort_frozen, false) |> load_components()} else # Ignore stale timer messages {:noreply, socket} end end defp load_components(socket, opts \\ []) do append = Keyword.get(opts, :append, false) # Check if sorting should be frozen now = DateTime.utc_now() should_reload = is_nil(socket.assigns.sort_freeze_until) || DateTime.compare(now, socket.assigns.sort_freeze_until) != :lt if should_reload do load_components_from_db(socket, append) else update_frozen_components(socket) end end defp load_components_from_db(socket, append) do filters = build_component_filters(socket) %{components: new_components, has_more: has_more} = Inventory.paginate_components(filters) components = if append do socket.assigns.components ++ new_components else new_components end socket |> assign(:components, components) |> assign(:has_more, has_more) end defp update_frozen_components(socket) do if socket.assigns.interacting_with do updated_components = update_interacting_component(socket) assign(socket, :components, updated_components) else socket end end defp update_interacting_component(socket) do interacting_id = socket.assigns.interacting_with Enum.map(socket.assigns.components, fn component -> if to_string(component.id) == interacting_id do # Reload this specific component to get updated count Inventory.get_component!(component.id) else component end end) end defp build_component_filters(socket) do [ search: socket.assigns.search, sort_criteria: socket.assigns.sort_criteria, category_id: socket.assigns.selected_category, storage_location_id: socket.assigns.selected_storage_location, limit: @items_per_page, offset: socket.assigns.offset ] |> Enum.reject(fn {_, v} when is_nil(v) -> true {:search, v} when v == "" -> true {_, _} -> false end) end defp build_query_params(socket, overrides) do params = %{ search: Map.get(overrides, :search, socket.assigns.search), criteria: Map.get(overrides, :criteria, socket.assigns.sort_criteria), category_id: Map.get(overrides, :category_id, socket.assigns.selected_category), storage_location_id: Map.get(overrides, :storage_location_id, socket.assigns.selected_storage_location) } params |> Enum.reject(fn {_k, v} -> is_nil(v) or v == "" end) |> URI.encode_query() end defp parse_filter_id(nil), do: nil defp parse_filter_id(""), do: nil defp parse_filter_id(id) when is_binary(id) do case Integer.parse(id) do {int_id, ""} -> int_id _ -> nil end end defp parse_filter_id(id) when is_integer(id), do: id defp build_query_params_with_category(socket, category_id) do params = %{ search: socket.assigns.search, criteria: socket.assigns.sort_criteria, category_id: category_id, storage_location_id: socket.assigns.selected_storage_location } params |> Enum.reject(fn {_k, v} -> is_nil(v) or v == "" end) |> URI.encode_query() end defp build_query_params_with_storage_location(socket, storage_location_id) do params = %{ search: socket.assigns.search, criteria: socket.assigns.sort_criteria, category_id: socket.assigns.selected_category, storage_location_id: storage_location_id } params |> Enum.reject(fn {_k, v} -> is_nil(v) or v == "" end) |> URI.encode_query() end defp build_query_params_without_category(socket) do params = %{ search: socket.assigns.search, criteria: socket.assigns.sort_criteria, storage_location_id: socket.assigns.selected_storage_location } params |> Enum.reject(fn {_k, v} -> is_nil(v) or v == "" end) |> URI.encode_query() end defp category_options(categories) do Hierarchical.select_options(categories, &(&1.parent), "Select a category") end defp storage_location_display_name(location) do StorageLocation.full_path(location) end defp storage_location_options(storage_locations) do Hierarchical.select_options(storage_locations, &(&1.parent), "No storage location") end @impl true def render(assigns) do ~H"""
JPG, PNG, GIF up to 5MB
<%= for err <- upload_errors(@uploads.image) do %>{Phoenix.Naming.humanize(err)}
<% end %> <%= for entry <- @uploads.image.entries do %>{entry.client_name}
{entry.progress}%
{upload_error_to_string(err)}
<% end %>PDF files up to 10MB (or enter URL above to auto-download)
<%= for err <- upload_errors(@uploads.datasheet) do %>{Phoenix.Naming.humanize(err)}
<% end %> <%= for entry <- @uploads.datasheet.entries do %>{entry.client_name}
{entry.progress}%
{upload_error_to_string(err)}
<% end %>Current image:
JPG, PNG, GIF up to 5MB (leave empty to keep current image)
<%= for err <- upload_errors(@uploads.image) do %>{Phoenix.Naming.humanize(err)}
<% end %> <%= for entry <- @uploads.image.entries do %>{entry.client_name}
{entry.progress}%
{upload_error_to_string(err)}
<% end %>Current datasheet:
<.icon name="hero-document-text" class="w-4 h-4 mr-1" /> View PDFPDF files up to 10MB (leave empty to keep current, or enter URL above to auto-download)
<%= for err <- upload_errors(@uploads.datasheet) do %>{Phoenix.Naming.humanize(err)}
<% end %> <%= for entry <- @uploads.datasheet.entries do %>{entry.client_name}
{entry.progress}%
{upload_error_to_string(err)}
<% end %>{component.description}
<%= cond do %> <% component.datasheet_filename -> %> {component.name} <% component.datasheet_url -> %> {component.name} <% true -> %> {component.name} <% end %>
<%= if component.datasheet_url || component.datasheet_filename do %> 📄 <% end %>{component.description}
Keywords: {component.keywords}
<%= if @search != "" do %> Try adjusting your search terms. <% else %> Get started by adding your first component. <% end %>
No image available
<% end %>