[tasks] fix task pagination race in project view

Author: dudina-ma

frontend/src/lib/components/AssigneeCombobox.svelte

@@ -1,6 +1,7 @@
 <script lang="ts">
   import { searchUsers } from "$lib/api/users";
   import type { UserBrief } from "$lib/types/api";
+  import { createLatestRequestGuard, runLatest } from "$lib/latest-request";
 
   let {
     value = $bindable<number | null>(null),
@@ -20,35 +21,33 @@
   let loading = $state(false);
   let selectedName = $state("");
   let timer: ReturnType<typeof setTimeout> | null = null;
-  let requestSeq = 0;
+  const requestGuard = createLatestRequestGuard();
 
   $effect(() => {
     if (initialName) selectedName = initialName;
   });
 
   function doSearch(q: string) {
-    const seq = ++requestSeq;
     if (!q.trim()) {
+      requestGuard.invalidate();
       results = [];
       open = false;
       loading = false;
       return;
     }
     loading = true;
-    searchUsers(q, 10)
-      .then((r) => {
-        if (seq !== requestSeq) return;
+    runLatest(requestGuard, () => searchUsers(q, 10), {
+      onSuccess: (r) => {
         results = r.items;
         open = true;
-      })
-      .catch(() => {
-        if (seq !== requestSeq) return;
+      },
+      onError: () => {
         results = [];
-      })
-      .finally(() => {
-        if (seq !== requestSeq) return;
+      },
+      onFinally: () => {
         loading = false;
-      });
+      },
+    });
   }
 
   function handleInput(e: Event) {
@@ -59,7 +58,7 @@
   }
 
   function select(user: UserBrief) {
-    requestSeq++;
+    requestGuard.invalidate();
     value = user.id;
     selectedName = user.name;
     query = "";
@@ -68,7 +67,7 @@
   }
 
   function clear() {
-    requestSeq++;
+    requestGuard.invalidate();
     value = null;
     selectedName = "";
     query = "";

frontend/src/lib/components/TaskFilters.svelte

@@ -53,7 +53,11 @@
     if (!mounted) return;
     const value = draft;
     const timer = setTimeout(() => {
-      untrack(() => onSearchChange?.(value));
+      untrack(() => {
+        if (value !== searchQuery) {
+          onSearchChange?.(value);
+        }
+      });
     }, 250);
     return () => clearTimeout(timer);
   });

frontend/src/lib/latest-request.ts

@@ -0,0 +1,44 @@
+export function createLatestRequestGuard() {
+  let version = 0;
+
+  return {
+    next(): number {
+      return ++version;
+    },
+    isLatest(token: number): boolean {
+      return token === version;
+    },
+    invalidate(): void {
+      version++;
+    },
+  };
+}
+
+export type LatestRequestGuard = ReturnType<typeof createLatestRequestGuard>;
+
+type RunLatestHandlers<T> = {
+  onSuccess: (value: T) => void;
+  onError?: (error: unknown) => void;
+  onFinally?: () => void;
+};
+
+export function runLatest<T>(
+  guard: LatestRequestGuard,
+  work: () => Promise<T>,
+  handlers: RunLatestHandlers<T>,
+): void {
+  const token = guard.next();
+  work()
+    .then((value) => {
+      if (!guard.isLatest(token)) return;
+      handlers.onSuccess(value);
+    })
+    .catch((error) => {
+      if (!guard.isLatest(token)) return;
+      handlers.onError?.(error);
+    })
+    .finally(() => {
+      if (!guard.isLatest(token)) return;
+      handlers.onFinally?.();
+    });
+}

frontend/src/lib/pages/admin-projects.svelte

@@ -14,6 +14,7 @@
   import SearchIcon from "@lucide/svelte/icons/search";
   import XIcon from "@lucide/svelte/icons/x";
   import type { Project } from "$lib/types/api";
+  import { createLatestRequestGuard, runLatest } from "$lib/latest-request";
 
   let projects = $state<Project[]>([]);
   let loading = $state(true);
@@ -33,6 +34,8 @@
   let editRepoUrl = $state("");
   let editSaving = $state(false);
 
+  const requestGuard = createLatestRequestGuard();
+
   function handleSearchInput(value: string) {
     searchTerm = value;
     if (searchTimeout) clearTimeout(searchTimeout);
@@ -57,17 +60,24 @@
     return new Date(dateStr).toLocaleDateString();
   }
 
-  async function load() {
+  function load() {
     loading = true;
     error = "";
-    try {
-      const res = await listProjects(100, 0, debouncedSearch || undefined);
-      projects = res.items;
-    } catch (e: any) {
-      error = e?.message || "Failed to load projects";
-    } finally {
-      loading = false;
-    }
+    runLatest(
+      requestGuard,
+      () => listProjects(100, 0, debouncedSearch || undefined),
+      {
+        onSuccess: (res) => {
+          projects = res.items;
+        },
+        onError: (e) => {
+          error = (e as Error)?.message || "Failed to load projects";
+        },
+        onFinally: () => {
+          loading = false;
+        },
+      },
+    );
   }
 
   function openCreate() {

frontend/src/lib/pages/admin-users.svelte

@@ -9,6 +9,7 @@
   import * as Badge from "$lib/components/ui/badge";
   import * as Dialog from "$lib/components/ui/dialog";
   import type { User } from "$lib/types/api";
+  import { createLatestRequestGuard, runLatest } from "$lib/latest-request";
 
   const PAGE_SIZE = 20;
 
@@ -29,6 +30,8 @@
 
   let activatingId = $state<number | null>(null);
 
+  const requestGuard = createLatestRequestGuard();
+
   let totalPages = $derived(Math.max(1, Math.ceil(total / PAGE_SIZE)));
 
   const statusBadgeColors: Record<string, string> = {
@@ -50,24 +53,32 @@
     return new Date(dateStr).toLocaleDateString();
   }
 
-  async function loadUsers() {
+  function loadUsers() {
     loading = true;
     error = "";
-    try {
-      const res = await listUsers({
-        status: filterStatus || undefined,
-        role: filterRole || undefined,
-        limit: PAGE_SIZE,
-        offset: (page - 1) * PAGE_SIZE,
-      });
-      users = res.items;
-      total = res.total;
-    } catch (e: any) {
-      error = e?.message || "Failed to load users";
-      users = [];
-    } finally {
-      loading = false;
-    }
+    runLatest(
+      requestGuard,
+      () =>
+        listUsers({
+          status: filterStatus || undefined,
+          role: filterRole || undefined,
+          limit: PAGE_SIZE,
+          offset: (page - 1) * PAGE_SIZE,
+        }),
+      {
+        onSuccess: (res) => {
+          users = res.items;
+          total = res.total;
+        },
+        onError: (e) => {
+          error = (e as Error)?.message || "Failed to load users";
+          users = [];
+        },
+        onFinally: () => {
+          loading = false;
+        },
+      },
+    );
   }
 
   function onFilterChange() {

frontend/src/lib/pages/dashboard-personal.svelte

@@ -10,6 +10,7 @@
   import type { Task, Project } from "$lib/types/api";
   import { ACTIVE_STATUSES } from "$lib/types/api";
   import { getSnapshot, saveSnapshot } from "$lib/stores/task-filters.svelte";
+  import { createLatestRequestGuard, runLatest } from "$lib/latest-request";
 
   let { params = {} }: { params?: Record<string, string> } = $props();
 
@@ -36,6 +37,8 @@
     sort = saved.sort;
   }
 
+  const requestGuard = createLatestRequestGuard();
+
   function toggleStatus(s: string) {
     if (filterStatuses.includes(s)) {
       filterStatuses = filterStatuses.filter((x) => x !== s);
@@ -94,24 +97,30 @@
       filters.priorities = filterPriorities.join(",");
     if (searchQuery) filters.search = searchQuery;
 
-    Promise.all([
-      listProjects(100, 0).then((r) => {
-        projects = r.items;
-      }),
-      getMyTasks({ limit: 50, ...filters }).then((res) => {
-        const currentUserId = getUser()?.id;
-        createdTasks = res.items.filter((t) => t.author.id === currentUserId);
-        assignedTasks = res.items.filter(
-          (t) => t.assignee?.id === currentUserId,
-        );
-      }),
-    ])
-      .catch((e) => {
-        error = e.message || "Failed to load tasks";
-      })
-      .finally(() => {
-        loading = false;
-      });
+    runLatest(
+      requestGuard,
+      () =>
+        Promise.all([
+          listProjects(100, 0).then((r) => r.items),
+          getMyTasks({ limit: 50, ...filters }).then((res) => res.items),
+        ]),
+      {
+        onSuccess: ([projectItems, taskItems]) => {
+          projects = projectItems;
+          const currentUserId = getUser()?.id;
+          createdTasks = taskItems.filter((t) => t.author.id === currentUserId);
+          assignedTasks = taskItems.filter(
+            (t) => t.assignee?.id === currentUserId,
+          );
+        },
+        onError: (e) => {
+          error = (e as Error).message || "Failed to load tasks";
+        },
+        onFinally: () => {
+          loading = false;
+        },
+      },
+    );
   });
 </script>
 

frontend/src/lib/pages/dashboard-tasks.svelte

@@ -12,6 +12,7 @@
   import type { Project, Task } from "$lib/types/api";
   import { ACTIVE_STATUSES } from "$lib/types/api";
   import { getSnapshot, saveSnapshot } from "$lib/stores/task-filters.svelte";
+  import { createLatestRequestGuard, runLatest } from "$lib/latest-request";
 
   let { params = {} }: { params?: Record<string, string> } = $props();
 
@@ -40,6 +41,8 @@
     offset = saved.offset;
   }
 
+  const requestGuard = createLatestRequestGuard();
+
   function toggleStatus(s: string) {
     if (filterStatuses.includes(s)) {
       filterStatuses = filterStatuses.filter((x) => x !== s);
@@ -83,21 +86,27 @@
       filters.priorities = filterPriorities.join(",");
     if (searchQuery) filters.search = searchQuery;
 
-    Promise.all([
-      listProjects(100, 0).then((r) => {
-        projects = r.items;
-      }),
-      listTasks(filters).then((r) => {
-        tasks = r.items;
-        total = r.total;
-      }),
-    ])
-      .catch((e) => {
-        error = e.message || "Failed to load tasks";
-      })
-      .finally(() => {
-        loading = false;
-      });
+    runLatest(
+      requestGuard,
+      () =>
+        Promise.all([
+          listProjects(100, 0).then((r) => r.items),
+          listTasks(filters).then((r) => ({ items: r.items, total: r.total })),
+        ]),
+      {
+        onSuccess: ([projectItems, taskRes]) => {
+          projects = projectItems;
+          tasks = taskRes.items;
+          total = taskRes.total;
+        },
+        onError: (e) => {
+          error = (e as Error).message || "Failed to load tasks";
+        },
+        onFinally: () => {
+          loading = false;
+        },
+      },
+    );
   }
 
   function resetFilters() {