From fba7ffd40e6c768cda021444f393e8193daed328 Mon Sep 17 00:00:00 2001
From: Mika Cohen <mjc@kernel.org>
Date: Sat, 30 May 2026 10:42:51 -0600
Subject: [PATCH 1/4] Improve videos page responsiveness and filter behavior

Co-authored-by: Copilot <223556219+Copilot@users.noreply.github.com>
---
 lib/reencodarr/media.ex                       |   1 -
 lib/reencodarr/videos/state.ex                |  15 +-
 lib/reencodarr_web/live/dashboard_live.ex     |  26 +++-
 lib/reencodarr_web/live/videos_live.ex        | 146 +++++++++---------
 nix/package.nix                               |  34 +++-
 test/reencodarr_web/live/videos_live_test.exs |  47 ++++--
 6 files changed, 173 insertions(+), 96 deletions(-)

diff --git a/lib/reencodarr/media.ex b/lib/reencodarr/media.ex
index 182e6a32..20828608 100644
--- a/lib/reencodarr/media.ex
+++ b/lib/reencodarr/media.ex
@@ -2353,7 +2353,6 @@ defmodule Reencodarr.Media do
 
     case Flop.validate_and_run(base_query, flop_params, for: Video) do
       {:ok, {videos, meta}} ->
-        videos = Repo.preload(videos, :chosen_vmaf)
         {videos, meta}
 
       {:error, _meta} ->
diff --git a/lib/reencodarr/videos/state.ex b/lib/reencodarr/videos/state.ex
index b46d4f1f..60fd7838 100644
--- a/lib/reencodarr/videos/state.ex
+++ b/lib/reencodarr/videos/state.ex
@@ -3,8 +3,10 @@ defmodule Reencodarr.Videos.State do
 
   alias Reencodarr.Media
 
-  @spec load(map()) :: map()
-  def load(assigns) do
+  @spec load(map(), keyword()) :: map()
+  def load(assigns, opts \\ []) do
+    include_state_counts? = Keyword.get(opts, :include_state_counts, true)
+
     {videos, meta} =
       Media.list_videos_paginated(
         page: assigns.page,
@@ -17,13 +19,20 @@ defmodule Reencodarr.Videos.State do
         sort_dir: assigns.sort_dir
       )
 
+    state_counts =
+      if include_state_counts? do
+        Media.count_videos_by_state()
+      else
+        Map.get(assigns, :state_counts, %{})
+      end
+
     %{
       videos: videos,
       meta: meta,
       total: meta.total_count || 0,
       page: meta.current_page || assigns.page,
       per_page: meta.page_size || assigns.per_page,
-      state_counts: Media.count_videos_by_state()
+      state_counts: state_counts
     }
   end
 end
diff --git a/lib/reencodarr_web/live/dashboard_live.ex b/lib/reencodarr_web/live/dashboard_live.ex
index 4101f912..2946d500 100644
--- a/lib/reencodarr_web/live/dashboard_live.ex
+++ b/lib/reencodarr_web/live/dashboard_live.ex
@@ -620,13 +620,24 @@ defmodule ReencodarrWeb.DashboardLive do
           <% end %>
         </div>
       <% else %>
-        <!-- Idle: Show compact status -->
+        <!-- Idle/Paused: Show compact status and allow resume when paused -->
         <div class="text-sm text-gray-400">
           <span>Queue: {@queue_count}</span>
           <%= if @status == :idle do %>
             <span class="ml-2">• Idle</span>
           <% end %>
         </div>
+
+        <%= if @status == :paused do %>
+          <div class="mt-2">
+            <.active_job_controls
+              status={@status}
+              suspend_event="suspend_crf_search"
+              resume_event="resume_crf_search"
+              fail_event="fail_crf_search"
+            />
+          </div>
+        <% end %>
       <% end %>
       
     <!-- Always show next-up videos -->
@@ -730,13 +741,24 @@ defmodule ReencodarrWeb.DashboardLive do
           />
         </div>
       <% else %>
-        <!-- Idle: Show compact status -->
+        <!-- Idle/Paused: Show compact status and allow resume when paused -->
         <div class="text-sm text-gray-400">
           <span>Queue: {@queue_count}</span>
           <%= if @status == :idle do %>
             <span class="ml-2">• Idle</span>
           <% end %>
         </div>
+
+        <%= if @status == :paused do %>
+          <div class="mt-2">
+            <.active_job_controls
+              status={@status}
+              suspend_event="suspend_encode"
+              resume_event="resume_encode"
+              fail_event="fail_encode"
+            />
+          </div>
+        <% end %>
       <% end %>
       
     <!-- Always show next-up videos -->
diff --git a/lib/reencodarr_web/live/videos_live.ex b/lib/reencodarr_web/live/videos_live.ex
index e7f39713..fe99d301 100644
--- a/lib/reencodarr_web/live/videos_live.ex
+++ b/lib/reencodarr_web/live/videos_live.ex
@@ -77,7 +77,7 @@ defmodule ReencodarrWeb.VideosLive do
       |> assign(filters)
       |> then(fn s ->
         if connected?(s) and s.assigns.loaded_once and filters_changed?,
-          do: load_data(s),
+          do: load_data(s, include_state_counts: false),
           else: s
       end)
 
@@ -114,33 +114,20 @@ defmodule ReencodarrWeb.VideosLive do
   # ---------------------------------------------------------------------------
 
   @impl true
-  def handle_event("search", %{"search" => q}, socket) do
-    {:noreply, push_patch(socket, to: patch_path(socket.assigns, search: q, page: 1))}
-  end
-
-  @impl true
-  def handle_event("filter_state", %{"state" => state}, socket) do
-    {:noreply,
-     push_patch(socket,
-       to: patch_path(socket.assigns, state: nilify_empty(state), page: 1)
-     )}
-  end
-
-  @impl true
-  def handle_event("filter_service", %{"service" => svc}, socket) do
-    {:noreply,
-     push_patch(socket,
-       to: patch_path(socket.assigns, service: nilify_empty(svc), page: 1)
-     )}
-  end
+  def handle_event("set_filters", params, socket) do
+    search = Map.get(params, "search", socket.assigns.search)
+    state = params |> Map.get("state") |> nilify_empty()
+    service = params |> Map.get("service") |> nilify_empty()
+    hdr = params |> Map.get("hdr") |> nilify_empty() |> parse_hdr_param() |> hdr_to_param()
 
-  @impl true
-  def handle_event("filter_hdr", %{"hdr" => hdr}, socket) do
     {:noreply,
      push_patch(socket,
        to:
          patch_path(socket.assigns,
-           hdr: hdr_to_param(parse_hdr_param(nilify_empty(hdr))),
+           search: search,
+           state: state,
+           service: service,
+           hdr: hdr,
            page: 1
          )
      )}
@@ -281,8 +268,8 @@ defmodule ReencodarrWeb.VideosLive do
   def handle_event("reset_selected", _params, socket) do
     ids = MapSet.to_list(socket.assigns.selected)
     Enum.each(ids, &reset_video_by_id/1)
-
-    socket = socket |> assign(selected: MapSet.new()) |> load_data()
+    videos = apply_video_state_on_page(socket.assigns.videos, ids, :needs_analysis)
+    socket = socket |> assign(selected: MapSet.new(), videos: videos)
     {:noreply, put_flash(socket, :info, "Reset #{length(ids)} video(s) to needs_analysis")}
   end
 
@@ -299,7 +286,7 @@ defmodule ReencodarrWeb.VideosLive do
          put_flash(socket, :error, "No selected videos were eligible for queue prioritization")}
 
       {:ok, count} ->
-        socket = socket |> assign(selected: MapSet.new()) |> load_data()
+        socket = socket |> assign(selected: MapSet.new())
         {:noreply, put_flash(socket, :info, "Prioritized #{count} video(s)")}
 
       {:error, _reason} ->
@@ -316,7 +303,8 @@ defmodule ReencodarrWeb.VideosLive do
     with {:ok, id} <- Parsers.parse_integer_exact(id_str),
          video when not is_nil(video) <- Media.get_video(id),
          {:ok, _} <- Media.mark_as_needs_analysis(video) do
-      {:noreply, socket |> put_flash(:info, "Reset to needs_analysis") |> load_data()}
+      videos = apply_video_state_on_page(socket.assigns.videos, [id], :needs_analysis)
+      {:noreply, socket |> assign(:videos, videos) |> put_flash(:info, "Reset to needs_analysis")}
     else
       nil ->
         {:noreply, put_flash(socket, :error, "Video not found")}
@@ -333,7 +321,10 @@ defmodule ReencodarrWeb.VideosLive do
     case Parsers.parse_integer_exact(id_str) do
       {:ok, id} ->
         Media.force_reanalyze_video(id)
-        {:noreply, socket |> put_flash(:info, "Queued for re-analysis") |> load_data()}
+        videos = apply_video_state_on_page(socket.assigns.videos, [id], :needs_analysis)
+
+        {:noreply,
+         socket |> assign(:videos, videos) |> put_flash(:info, "Queued for re-analysis")}
 
       _ ->
         {:noreply, socket}
@@ -345,7 +336,7 @@ defmodule ReencodarrWeb.VideosLive do
     with {:ok, id} <- Parsers.parse_integer_exact(id_str),
          {:ok, count} <- Media.prioritize_video(id),
          true <- count > 0 do
-      {:noreply, socket |> put_flash(:info, "Prioritized video") |> load_data()}
+      {:noreply, socket |> put_flash(:info, "Prioritized video")}
     else
       {:ok, 0} -> {:noreply, put_flash(socket, :error, "Video is not currently queueable")}
       false -> {:noreply, put_flash(socket, :error, "Video is not currently queueable")}
@@ -356,20 +347,22 @@ defmodule ReencodarrWeb.VideosLive do
 
   @impl true
   def handle_event("fail_video", %{"id" => id_str}, socket) do
-    result =
-      with {:ok, id} <- Parsers.parse_integer_exact(id_str) do
-        fail_video_by_id(id)
-      end
+    case Parsers.parse_integer_exact(id_str) do
+      {:ok, id} ->
+        case fail_video_by_id(id) do
+          :ok ->
+            videos = apply_video_state_on_page(socket.assigns.videos, [id], :failed)
+            {:noreply, socket |> assign(:videos, videos) |> put_flash(:info, "Job stopped")}
 
-    case result do
-      :ok ->
-        {:noreply, socket |> put_flash(:info, "Job stopped") |> load_data()}
+          {:error, :active_mismatch} ->
+            {:noreply, socket |> put_flash(:error, "That video is not the active job")}
 
-      {:error, :active_mismatch} ->
-        {:noreply, socket |> put_flash(:error, "That video is not the active job") |> load_data()}
+          _ ->
+            {:noreply, socket |> put_flash(:error, "Unable to stop job")}
+        end
 
       _ ->
-        {:noreply, socket |> put_flash(:error, "Unable to stop job") |> load_data()}
+        {:noreply, socket |> put_flash(:error, "Unable to stop job")}
     end
   end
 
@@ -398,8 +391,7 @@ defmodule ReencodarrWeb.VideosLive do
            |> put_flash(
              :info,
              "Prioritized #{count} #{Path.basename(season_dir)} video(s)"
-           )
-           |> load_data()}
+           )}
 
         {:error, _reason} ->
           {:noreply, put_flash(socket, :error, "Failed to prioritize season videos")}
@@ -420,7 +412,11 @@ defmodule ReencodarrWeb.VideosLive do
     with {:ok, id} <- Parsers.parse_integer_exact(id_str),
          {:ok, video} <- Media.fetch_video(id),
          {:ok, _} <- Media.delete_video(video) do
-      {:noreply, socket |> put_flash(:info, "Video deleted") |> load_data()}
+      videos = Enum.reject(socket.assigns.videos, &(&1.id == id))
+      total = max(socket.assigns.total - 1, 0)
+
+      {:noreply,
+       socket |> assign(videos: videos, total: total) |> put_flash(:info, "Video deleted")}
     else
       :not_found -> {:noreply, put_flash(socket, :error, "Video not found")}
       {:error, _} -> {:noreply, put_flash(socket, :error, "Delete failed")}
@@ -442,8 +438,7 @@ defmodule ReencodarrWeb.VideosLive do
       {:noreply,
        socket
        |> assign(:expanded_bad_forms, List.delete(socket.assigns.expanded_bad_forms, id))
-       |> put_flash(:info, "Marked as bad")
-       |> load_data()}
+       |> put_flash(:info, "Marked as bad")}
     else
       :not_found -> {:noreply, put_flash(socket, :error, "Video not found")}
       {:error, _} -> {:noreply, put_flash(socket, :error, "Mark bad failed")}
@@ -455,18 +450,22 @@ defmodule ReencodarrWeb.VideosLive do
   # Private helpers
   # ---------------------------------------------------------------------------
 
-  defp load_data(socket) do
+  defp load_data(socket, opts \\ []) do
     page_state =
-      VideosState.load(%{
-        page: socket.assigns.page,
-        per_page: socket.assigns.per_page,
-        state_filter: socket.assigns.state_filter,
-        service_filter: socket.assigns.service_filter,
-        hdr_filter: socket.assigns.hdr_filter,
-        search: socket.assigns.search,
-        sort_by: socket.assigns.sort_by,
-        sort_dir: socket.assigns.sort_dir
-      })
+      VideosState.load(
+        %{
+          state_counts: socket.assigns.state_counts,
+          page: socket.assigns.page,
+          per_page: socket.assigns.per_page,
+          state_filter: socket.assigns.state_filter,
+          service_filter: socket.assigns.service_filter,
+          hdr_filter: socket.assigns.hdr_filter,
+          search: socket.assigns.search,
+          sort_by: socket.assigns.sort_by,
+          sort_dir: socket.assigns.sort_dir
+        },
+        opts
+      )
 
     assign_changed(socket, Map.put(page_state, :loading, false))
   end
@@ -477,6 +476,14 @@ defmodule ReencodarrWeb.VideosLive do
     |> assign(:loaded_once, true)
   end
 
+  defp apply_video_state_on_page(videos, ids, new_state) do
+    ids = MapSet.new(ids)
+
+    Enum.map(videos, fn video ->
+      if MapSet.member?(ids, video.id), do: %{video | state: new_state}, else: video
+    end)
+  end
+
   defp reset_video_by_id(id) do
     case Media.get_video(id) do
       nil -> :ok
@@ -750,18 +757,17 @@ defmodule ReencodarrWeb.VideosLive do
     <!-- Toolbar -->
         <div class="bg-gray-800 rounded-lg border border-gray-700 p-3">
           <div class="flex flex-wrap gap-3 items-center">
-            <form phx-change="search" class="flex-1 min-w-[180px]">
-              <input
-                type="text"
-                name="search"
-                value={@search}
-                placeholder="Search by path..."
-                phx-debounce="300"
-                class="w-full bg-gray-700 border border-gray-600 text-white rounded-lg px-3 py-2 text-sm focus:ring-purple-500 focus:border-purple-500 placeholder-gray-400"
-              />
-            </form>
-
-            <form phx-change="filter_state">
+            <form id="videos-filters" phx-change="set_filters" class="contents">
+              <div class="flex-1 min-w-[180px]">
+                <input
+                  type="text"
+                  name="search"
+                  value={@search}
+                  placeholder="Search by path..."
+                  phx-debounce="300"
+                  class="w-full bg-gray-700 border border-gray-600 text-white rounded-lg px-3 py-2 text-sm focus:ring-purple-500 focus:border-purple-500 placeholder-gray-400"
+                />
+              </div>
               <select
                 name="state"
                 value={@state_filter || ""}
@@ -772,9 +778,6 @@ defmodule ReencodarrWeb.VideosLive do
                   <option value={s}>{s}</option>
                 <% end %>
               </select>
-            </form>
-
-            <form phx-change="filter_service">
               <select
                 name="service"
                 value={@service_filter || ""}
@@ -784,9 +787,6 @@ defmodule ReencodarrWeb.VideosLive do
                 <option value="sonarr">Sonarr (TV)</option>
                 <option value="radarr">Radarr (Movies)</option>
               </select>
-            </form>
-
-            <form phx-change="filter_hdr">
               <select
                 name="hdr"
                 value={hdr_to_param(@hdr_filter) || ""}
diff --git a/nix/package.nix b/nix/package.nix
index 4571e1f4..9cd347d7 100644
--- a/nix/package.nix
+++ b/nix/package.nix
@@ -48,7 +48,39 @@ in
   beamPackages.mixRelease rec {
     pname = "reencodarr";
     version = "0.1.0";
-    src = lib.cleanSource ../.;
+    src = lib.cleanSourceWith {
+      src = ../.;
+
+      filter = path: type:
+        let
+          root = toString ../.;
+          pathStr = toString path;
+          relPath =
+            if pathStr == root
+            then ""
+            else lib.removePrefix "${root}/" pathStr;
+
+          excluded =
+            relPath == "_build"
+            || lib.hasPrefix "_build/" relPath
+            || relPath == "deps"
+            || lib.hasPrefix "deps/" relPath
+            || relPath == "node_modules"
+            || lib.hasPrefix "node_modules/" relPath
+            || relPath == "logs"
+            || lib.hasPrefix "logs/" relPath
+            || relPath == ".elixir_ls"
+            || lib.hasPrefix ".elixir_ls/" relPath
+            || relPath == ".direnv"
+            || lib.hasPrefix ".direnv/" relPath
+            || relPath == ".git"
+            || lib.hasPrefix ".git/" relPath
+            || builtins.match "priv/reencodarr_(dev|prod|test).*\\.db(-shm|-wal)?"
+              relPath
+              != null;
+        in
+          lib.cleanSourceFilter path type && !excluded;
+    };
 
     mixFodDeps = beamPackages.fetchMixDeps {
       pname = "${pname}-mix-deps";
diff --git a/test/reencodarr_web/live/videos_live_test.exs b/test/reencodarr_web/live/videos_live_test.exs
index c4a0e5b4..7284159c 100644
--- a/test/reencodarr_web/live/videos_live_test.exs
+++ b/test/reencodarr_web/live/videos_live_test.exs
@@ -57,7 +57,7 @@ defmodule ReencodarrWeb.VideosLiveTest do
   # Search
   # ---------------------------------------------------------------------------
 
-  describe "search event" do
+  describe "set_filters event" do
     test "filters list to matching videos", %{conn: conn} do
       {:ok, _} = Fixtures.video_fixture(%{path: "/media/unique_alpha_xyz/ep.mkv"})
       {:ok, _} = Fixtures.video_fixture(%{path: "/media/unique_beta_xyz/ep.mkv"})
@@ -66,7 +66,7 @@ defmodule ReencodarrWeb.VideosLiveTest do
 
       html =
         view
-        |> form("form[phx-change='search']", %{search: "unique_alpha_xyz"})
+        |> form("#videos-filters", %{search: "unique_alpha_xyz"})
         |> render_change()
 
       assert html =~ "unique_alpha_xyz"
@@ -78,11 +78,28 @@ defmodule ReencodarrWeb.VideosLiveTest do
 
       html =
         view
-        |> form("form[phx-change='search']", %{search: ""})
+        |> form("#videos-filters", %{search: ""})
         |> render_change()
 
       assert html =~ "show"
     end
+
+    test "applies search and state filters together", %{conn: conn} do
+      {:ok, _} = Fixtures.video_fixture(%{path: "/media/combo_filter_hit.mkv", state: :encoded})
+      {:ok, _} = Fixtures.video_fixture(%{path: "/media/combo_filter_hit_2.mkv", state: :failed})
+      {:ok, _} = Fixtures.video_fixture(%{path: "/media/combo_filter_miss.mkv", state: :encoded})
+
+      {:ok, view, _html} = live(conn, ~p"/videos")
+
+      html =
+        view
+        |> form("#videos-filters", %{search: "/media/combo_filter_hit.mkv", state: "encoded"})
+        |> render_change()
+
+      assert html =~ "combo_filter_hit.mkv"
+      refute html =~ "combo_filter_hit_2.mkv"
+      refute html =~ "combo_filter_miss.mkv"
+    end
   end
 
   # ---------------------------------------------------------------------------
@@ -93,9 +110,7 @@ defmodule ReencodarrWeb.VideosLiveTest do
     test "fires filter_state event and patches URL to include state param", %{conn: conn} do
       {:ok, view, _} = live(conn, ~p"/videos")
 
-      view
-      |> form("form[phx-change='filter_state']", %{state: "encoded"})
-      |> render_change()
+      view |> form("#videos-filters", %{state: "encoded"}) |> render_change()
 
       # The event pushes a patch — after render, the select should keep the chosen value
       html = render(view)
@@ -107,7 +122,7 @@ defmodule ReencodarrWeb.VideosLiveTest do
 
       html =
         view
-        |> form("form[phx-change='filter_state']", %{state: "encoded"})
+        |> form("#videos-filters", %{state: "encoded"})
         |> render_change()
 
       assert html =~ "Videos"
@@ -120,7 +135,7 @@ defmodule ReencodarrWeb.VideosLiveTest do
 
       html =
         view
-        |> form("form[phx-change='filter_state']", %{state: "encoded"})
+        |> form("#videos-filters", %{state: "encoded"})
         |> render_change()
 
       assert html =~ "only_encoded.mkv"
@@ -397,8 +412,8 @@ defmodule ReencodarrWeb.VideosLiveTest do
 
       html =
         view
-        |> element("form[phx-change='filter_service']")
-        |> render_change(%{"service" => "sonarr"})
+        |> form("#videos-filters", %{service: "sonarr"})
+        |> render_change()
 
       assert html =~ "Videos"
     end
@@ -408,13 +423,13 @@ defmodule ReencodarrWeb.VideosLiveTest do
       {:ok, view, _} = live(conn, ~p"/videos")
 
       view
-      |> element("form[phx-change='filter_service']")
-      |> render_change(%{"service" => "sonarr"})
+      |> form("#videos-filters", %{service: "sonarr"})
+      |> render_change()
 
       html =
         view
-        |> element("form[phx-change='filter_service']")
-        |> render_change(%{"service" => ""})
+        |> form("#videos-filters", %{service: ""})
+        |> render_change()
 
       assert html =~ "Videos"
     end
@@ -434,8 +449,8 @@ defmodule ReencodarrWeb.VideosLiveTest do
 
       html =
         view
-        |> element("form[phx-change='filter_hdr']")
-        |> render_change(%{"hdr" => "true"})
+        |> form("#videos-filters", %{hdr: "true"})
+        |> render_change()
 
       assert html =~ "Videos"
     end

From 1c8df811643a66b5a94e32f9df45efca2063235c Mon Sep 17 00:00:00 2001
From: Mika Cohen <mjc@kernel.org>
Date: Sat, 30 May 2026 10:45:55 -0600
Subject: [PATCH 2/4] remove extra script

---
 scripts/find_empty_maxcll_dv.sh | 95 ---------------------------------
 1 file changed, 95 deletions(-)
 delete mode 100755 scripts/find_empty_maxcll_dv.sh

diff --git a/scripts/find_empty_maxcll_dv.sh b/scripts/find_empty_maxcll_dv.sh
deleted file mode 100755
index 3954d990..00000000
--- a/scripts/find_empty_maxcll_dv.sh
+++ /dev/null
@@ -1,95 +0,0 @@
-#!/usr/bin/env bash
-set -euo pipefail
-
-ROOT="${1:-/mnt/tv}"
-PATTERN="${2:-.}"
-
-if ! command -v fd >/dev/null 2>&1; then
-  echo "fd is required" >&2
-  exit 1
-fi
-
-if ! command -v mediainfo >/dev/null 2>&1; then
-  echo "mediainfo is required" >&2
-  exit 1
-fi
-
-if ! command -v jq >/dev/null 2>&1; then
-  echo "jq is required" >&2
-  exit 1
-fi
-
-fd \
-  --type f \
-  --extension mkv \
-  --extension mp4 \
-  --extension m4v \
-  --extension mov \
-  --extension ts \
-  --extension m2ts \
-  "$PATTERN" \
-  "$ROOT" \
-  -X bash -c '
-    for file in "$@"; do
-      base=$(basename "$file")
-      case "$base" in
-        *1080*|*1080p*) ;;
-        *) continue ;;
-      esac
-      case "$base" in
-        *DV*|*dv*) ;;
-        *) continue ;;
-      esac
-
-      mediainfo --Output=JSON "$file" 2>/dev/null \
-        | jq -er --arg file "$file" '"'"'
-            [
-              .media.track[]?
-              | select(."@type" == "Video")
-              | select(
-                  (
-                    ((.HDR_Format // "") | ascii_downcase | contains("dolby vision"))
-                    or ((.HDR_Format_Profile // "") | ascii_downcase | startswith("dvhe."))
-                    or ((.HDR_Format_Profile // "") | ascii_downcase | startswith("dvh1."))
-                  )
-                )
-              | select((.MasteringDisplay_ColorPrimaries // "") == "")
-              | select((.MasteringDisplay_Luminance // "") == "")
-              | select((.MaxCLL // "") == "")
-              | select((.MaxFALL // "") == "")
-              | $file
-            ]
-            | .[]
-            | .
-          '"'"' || true
-    done
-  ' bash \
-  | awk -F/ '
-      {
-        show = $(NF - 2)
-        season = $(NF - 1)
-        key = show "\t" season
-        count[key]++
-      }
-
-      END {
-        for (key in count) {
-          split(key, parts, "\t")
-          printf "%s\t%s\t%d\n", parts[1], parts[2], count[key]
-        }
-      }
-    ' \
-  | sort -t $'\t' -k1,1 -k2,2V \
-  | awk -F'\t' '
-      $1 != current {
-        if (NR > 1) {
-          print ""
-        }
-        current = $1
-        print current
-      }
-
-      {
-        printf "  %s (%s)\n", $2, $3
-      }
-    '

From 6647531231a3f2f74073580b0978cef7c9dd6c26 Mon Sep 17 00:00:00 2001
From: Mika Cohen <mjc@kernel.org>
Date: Sat, 30 May 2026 10:57:05 -0600
Subject: [PATCH 3/4] Address PR feedback for videos and nix filtering

Co-authored-by: Copilot <223556219+Copilot@users.noreply.github.com>
---
 lib/reencodarr_web/live/videos_live.ex        | 29 ++------
 nix/package.nix                               | 29 ++++----
 test/reencodarr_web/live/videos_live_test.exs | 67 +++++++++++++++++++
 3 files changed, 87 insertions(+), 38 deletions(-)

diff --git a/lib/reencodarr_web/live/videos_live.ex b/lib/reencodarr_web/live/videos_live.ex
index fe99d301..648ca33d 100644
--- a/lib/reencodarr_web/live/videos_live.ex
+++ b/lib/reencodarr_web/live/videos_live.ex
@@ -268,8 +268,8 @@ defmodule ReencodarrWeb.VideosLive do
   def handle_event("reset_selected", _params, socket) do
     ids = MapSet.to_list(socket.assigns.selected)
     Enum.each(ids, &reset_video_by_id/1)
-    videos = apply_video_state_on_page(socket.assigns.videos, ids, :needs_analysis)
-    socket = socket |> assign(selected: MapSet.new(), videos: videos)
+    socket = socket |> assign(selected: MapSet.new()) |> load_data()
+
     {:noreply, put_flash(socket, :info, "Reset #{length(ids)} video(s) to needs_analysis")}
   end
 
@@ -303,8 +303,7 @@ defmodule ReencodarrWeb.VideosLive do
     with {:ok, id} <- Parsers.parse_integer_exact(id_str),
          video when not is_nil(video) <- Media.get_video(id),
          {:ok, _} <- Media.mark_as_needs_analysis(video) do
-      videos = apply_video_state_on_page(socket.assigns.videos, [id], :needs_analysis)
-      {:noreply, socket |> assign(:videos, videos) |> put_flash(:info, "Reset to needs_analysis")}
+      {:noreply, socket |> put_flash(:info, "Reset to needs_analysis") |> load_data()}
     else
       nil ->
         {:noreply, put_flash(socket, :error, "Video not found")}
@@ -321,10 +320,7 @@ defmodule ReencodarrWeb.VideosLive do
     case Parsers.parse_integer_exact(id_str) do
       {:ok, id} ->
         Media.force_reanalyze_video(id)
-        videos = apply_video_state_on_page(socket.assigns.videos, [id], :needs_analysis)
-
-        {:noreply,
-         socket |> assign(:videos, videos) |> put_flash(:info, "Queued for re-analysis")}
+        {:noreply, socket |> put_flash(:info, "Queued for re-analysis") |> load_data()}
 
       _ ->
         {:noreply, socket}
@@ -351,8 +347,7 @@ defmodule ReencodarrWeb.VideosLive do
       {:ok, id} ->
         case fail_video_by_id(id) do
           :ok ->
-            videos = apply_video_state_on_page(socket.assigns.videos, [id], :failed)
-            {:noreply, socket |> assign(:videos, videos) |> put_flash(:info, "Job stopped")}
+            {:noreply, socket |> put_flash(:info, "Job stopped") |> load_data()}
 
           {:error, :active_mismatch} ->
             {:noreply, socket |> put_flash(:error, "That video is not the active job")}
@@ -412,11 +407,7 @@ defmodule ReencodarrWeb.VideosLive do
     with {:ok, id} <- Parsers.parse_integer_exact(id_str),
          {:ok, video} <- Media.fetch_video(id),
          {:ok, _} <- Media.delete_video(video) do
-      videos = Enum.reject(socket.assigns.videos, &(&1.id == id))
-      total = max(socket.assigns.total - 1, 0)
-
-      {:noreply,
-       socket |> assign(videos: videos, total: total) |> put_flash(:info, "Video deleted")}
+      {:noreply, socket |> put_flash(:info, "Video deleted") |> load_data()}
     else
       :not_found -> {:noreply, put_flash(socket, :error, "Video not found")}
       {:error, _} -> {:noreply, put_flash(socket, :error, "Delete failed")}
@@ -476,14 +467,6 @@ defmodule ReencodarrWeb.VideosLive do
     |> assign(:loaded_once, true)
   end
 
-  defp apply_video_state_on_page(videos, ids, new_state) do
-    ids = MapSet.new(ids)
-
-    Enum.map(videos, fn video ->
-      if MapSet.member?(ids, video.id), do: %{video | state: new_state}, else: video
-    end)
-  end
-
   defp reset_video_by_id(id) do
     case Media.get_video(id) do
       nil -> :ok
diff --git a/nix/package.nix b/nix/package.nix
index 9cd347d7..29608f73 100644
--- a/nix/package.nix
+++ b/nix/package.nix
@@ -60,22 +60,21 @@ in
             then ""
             else lib.removePrefix "${root}/" pathStr;
 
+          excludedDirs = [
+            "_build"
+            "deps"
+            "node_modules"
+            "logs"
+            ".elixir_ls"
+            ".direnv"
+            ".git"
+          ];
+
+          isExcludedDir = dir: relPath == dir || lib.hasPrefix "${dir}/" relPath;
+
           excluded =
-            relPath == "_build"
-            || lib.hasPrefix "_build/" relPath
-            || relPath == "deps"
-            || lib.hasPrefix "deps/" relPath
-            || relPath == "node_modules"
-            || lib.hasPrefix "node_modules/" relPath
-            || relPath == "logs"
-            || lib.hasPrefix "logs/" relPath
-            || relPath == ".elixir_ls"
-            || lib.hasPrefix ".elixir_ls/" relPath
-            || relPath == ".direnv"
-            || lib.hasPrefix ".direnv/" relPath
-            || relPath == ".git"
-            || lib.hasPrefix ".git/" relPath
-            || builtins.match "priv/reencodarr_(dev|prod|test).*\\.db(-shm|-wal)?"
+            lib.any isExcludedDir excludedDirs
+            || builtins.match "priv/reencodarr_(dev|prod|test).*\\.db(-shm|-wal|-journal)?"
               relPath
               != null;
         in
diff --git a/test/reencodarr_web/live/videos_live_test.exs b/test/reencodarr_web/live/videos_live_test.exs
index 7284159c..7905f9e1 100644
--- a/test/reencodarr_web/live/videos_live_test.exs
+++ b/test/reencodarr_web/live/videos_live_test.exs
@@ -530,6 +530,22 @@ defmodule ReencodarrWeb.VideosLiveTest do
       html = view |> render_click("reset_video", %{"id" => "999999"})
       assert html =~ "Video not found"
     end
+
+    test "removes a row from failed filter and updates badge counts", %{conn: conn} do
+      {:ok, video} = Fixtures.failed_video_fixture(%{path: "/media/failed_filtered_reset.mkv"})
+      {:ok, view, _} = live(conn, ~p"/videos?state=failed")
+
+      html =
+        view
+        |> element("button[phx-click='reset_video'][phx-value-id='#{video.id}']")
+        |> render_click()
+
+      assert html =~ "Reset to needs_analysis"
+      assert html =~ "0 total"
+      refute html =~ "failed_filtered_reset.mkv"
+      assert_state_badge_count(html, "failed", 0)
+      assert_state_badge_count(html, "needs_analysis", 1)
+    end
   end
 
   describe "force_reanalyze event" do
@@ -544,6 +560,21 @@ defmodule ReencodarrWeb.VideosLiveTest do
 
       assert html =~ "Queued for re-analysis"
     end
+
+    test "keeps the row visible until state transition occurs", %{conn: conn} do
+      {:ok, video} =
+        Fixtures.video_fixture(%{path: "/media/reanalyze_filtered.mkv", state: :analyzed})
+
+      {:ok, view, _} = live(conn, ~p"/videos?state=analyzed")
+
+      html =
+        view
+        |> element("button[phx-click='force_reanalyze'][phx-value-id='#{video.id}']")
+        |> render_click()
+
+      assert html =~ "Queued for re-analysis"
+      assert html =~ "reanalyze_filtered.mkv"
+    end
   end
 
   describe "stop job event" do
@@ -594,6 +625,21 @@ defmodule ReencodarrWeb.VideosLiveTest do
       html = view |> render_click("delete_video", %{"id" => "999999"})
       assert html =~ "Video not found"
     end
+
+    test "updates counts after deleting a filtered row", %{conn: conn} do
+      {:ok, video} = Fixtures.failed_video_fixture(%{path: "/media/delete_failed_filtered.mkv"})
+      {:ok, view, _} = live(conn, ~p"/videos?state=failed")
+
+      html =
+        view
+        |> element("button[phx-click='delete_video'][phx-value-id='#{video.id}']")
+        |> render_click()
+
+      assert html =~ "Video deleted"
+      assert html =~ "0 total"
+      refute html =~ "delete_failed_filtered.mkv"
+      assert_state_badge_count(html, "failed", 0)
+    end
   end
 
   # ---------------------------------------------------------------------------
@@ -610,6 +656,20 @@ defmodule ReencodarrWeb.VideosLiveTest do
 
       assert html =~ "Reset 1 video(s) to needs_analysis"
     end
+
+    test "removes selected rows that no longer match the active state filter", %{conn: conn} do
+      {:ok, _} = Fixtures.failed_video_fixture(%{path: "/media/bulk_reset_filtered.mkv"})
+      {:ok, view, _} = live(conn, ~p"/videos?state=failed")
+
+      view |> element("[phx-click='select_all']") |> render_click()
+      html = view |> element("button[phx-click='reset_selected']") |> render_click()
+
+      assert html =~ "Reset 1 video(s) to needs_analysis"
+      assert html =~ "0 total"
+      refute html =~ "bulk_reset_filtered.mkv"
+      assert_state_badge_count(html, "failed", 0)
+      assert_state_badge_count(html, "needs_analysis", 1)
+    end
   end
 
   describe "prioritize actions" do
@@ -702,4 +762,11 @@ defmodule ReencodarrWeb.VideosLiveTest do
       assert html =~ "Videos"
     end
   end
+
+  defp assert_state_badge_count(html, state, count) do
+    assert Regex.match?(
+             ~r/phx-value-state="#{state}".*?font-mono">#{count}<\/span>/s,
+             html
+           )
+  end
 end

From c9a54b2bb32dc42f30d1fca8c8d8de2255314c00 Mon Sep 17 00:00:00 2001
From: Mika Cohen <mjc@kernel.org>
Date: Sat, 30 May 2026 14:11:57 -0600
Subject: [PATCH 4/4] Address new PR comments

Co-authored-by: Copilot <223556219+Copilot@users.noreply.github.com>
---
 nix/package.nix                               |  2 +-
 test/reencodarr_web/live/videos_live_test.exs | 12 ++++++++----
 2 files changed, 9 insertions(+), 5 deletions(-)

diff --git a/nix/package.nix b/nix/package.nix
index 29608f73..481ec7bc 100644
--- a/nix/package.nix
+++ b/nix/package.nix
@@ -70,7 +70,7 @@ in
             ".git"
           ];
 
-          isExcludedDir = dir: relPath == dir || lib.hasPrefix "${dir}/" relPath;
+          isExcludedDir = dir: lib.hasInfix "/${dir}/" "/${relPath}/";
 
           excluded =
             lib.any isExcludedDir excludedDirs
diff --git a/test/reencodarr_web/live/videos_live_test.exs b/test/reencodarr_web/live/videos_live_test.exs
index 7905f9e1..3dc54f69 100644
--- a/test/reencodarr_web/live/videos_live_test.exs
+++ b/test/reencodarr_web/live/videos_live_test.exs
@@ -764,9 +764,13 @@ defmodule ReencodarrWeb.VideosLiveTest do
   end
 
   defp assert_state_badge_count(html, state, count) do
-    assert Regex.match?(
-             ~r/phx-value-state="#{state}".*?font-mono">#{count}<\/span>/s,
-             html
-           )
+    case Regex.run(~r/phx-value-state="#{state}".*?font-mono">(\d+)<\/span>/s, html) do
+      [_, actual] ->
+        assert actual == Integer.to_string(count),
+               "expected #{state} badge count #{count}, got #{actual}"
+
+      nil ->
+        flunk("no #{state} badge found in rendered HTML")
+    end
   end
 end