9236674667
Refactor real-time sync from per-event precise mutations to WS-as-invalidation-signal + debounced refetch. Backend: - Add SubscribeAll to Event Bus — auto-broadcasts ALL events, eliminates manual 25-item allEvents list - Add skill event constants to protocol, fix skill handler string literals - Add title_changed activity tracking Frontend: - WSClient: add onAny() method for wildcard event subscription - useRealtimeSync: rewrite to refreshMap + prefix routing + 100ms debounce - Precise handlers only for side effects: workspace:deleted, member:removed, member:added (self-check) - Reconnect now refetches all stores (fixes missing members/skills/workspace refresh) - Stale-while-revalidate: fetch() only shows loading spinner on initial load, not on refetch - Remove redundant useWSEvent in agents/page.tsx and skills-page.tsx - WSClient.disconnect() now clears all handler registrations Inbox bugfixes: - Unify sidebar badge count with page count via dedupedItems + unreadCount in store - Sort by time DESC (removed severity-first ordering) - Ellipsis on truncated detail labels UI: - Status/Priority pickers: replace RadioGroup with MenuItem for auto-close on selection Co-Authored-By: Claude Opus 4.6 (1M context) <noreply@anthropic.com>
55 lines
1.6 KiB
TypeScript
55 lines
1.6 KiB
TypeScript
"use client";
|
|
|
|
import { create } from "zustand";
|
|
import type { Issue } from "@/shared/types";
|
|
import { api } from "@/shared/api";
|
|
import { createLogger } from "@/shared/logger";
|
|
|
|
const logger = createLogger("issue-store");
|
|
|
|
interface IssueState {
|
|
issues: Issue[];
|
|
loading: boolean;
|
|
activeIssueId: string | null;
|
|
fetch: () => Promise<void>;
|
|
setIssues: (issues: Issue[]) => void;
|
|
addIssue: (issue: Issue) => void;
|
|
updateIssue: (id: string, updates: Partial<Issue>) => void;
|
|
removeIssue: (id: string) => void;
|
|
setActiveIssue: (id: string | null) => void;
|
|
}
|
|
|
|
export const useIssueStore = create<IssueState>((set, get) => ({
|
|
issues: [],
|
|
loading: true,
|
|
activeIssueId: null,
|
|
|
|
fetch: async () => {
|
|
logger.debug("fetch start");
|
|
const isInitialLoad = get().issues.length === 0;
|
|
if (isInitialLoad) set({ loading: true });
|
|
try {
|
|
const res = await api.listIssues({ limit: 200 });
|
|
logger.info("fetched", res.issues.length, "issues");
|
|
set({ issues: res.issues, loading: false });
|
|
} catch (err) {
|
|
logger.error("fetch failed", err);
|
|
if (isInitialLoad) set({ loading: false });
|
|
}
|
|
},
|
|
|
|
setIssues: (issues) => set({ issues }),
|
|
addIssue: (issue) =>
|
|
set((s) => ({
|
|
issues: s.issues.some((i) => i.id === issue.id)
|
|
? s.issues
|
|
: [...s.issues, issue],
|
|
})),
|
|
updateIssue: (id, updates) =>
|
|
set((s) => ({
|
|
issues: s.issues.map((i) => (i.id === id ? { ...i, ...updates } : i)),
|
|
})),
|
|
removeIssue: (id) =>
|
|
set((s) => ({ issues: s.issues.filter((i) => i.id !== id) })),
|
|
setActiveIssue: (id) => set({ activeIssueId: id }),
|
|
}));
|