bkinnightskytw
/
agent-orchestrator
mirror of https://github.com/ComposioHQ/agent-orchestrator.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

fix: reset dashboard state on page load failures 

Keep the SSR dashboard page using unified project filtering while clearing orchestrator links and pause state whenever enrichment fails, so error paths cannot render stale state beside an empty session list.
This commit is contained in:
Harsh 2026-03-12 02:15:03 +05:30
parent 1d1c4533a2
commit 3968bb0dc8
1 changed files with 35 additions and 23 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

58
packages/web/src/app/page.tsx
View File

@ -37,27 +37,33 @@ export async function generateMetadata(props: {
export default async function Home(props: { searchParams: Promise<{ project?: string }> }) {
const searchParams = await props.searchParams;
let sessions: DashboardSession[] = [];
let globalPause: GlobalPauseState | null = null;
let orchestrators: Array<{ id: string; projectId: string; projectName: string }> = [];
const projectFilter = searchParams.project ?? getPrimaryProjectId();
const pageData: {
sessions: DashboardSession[];
globalPause: GlobalPauseState | null;
orchestrators: Array<{ id: string; projectId: string; projectName: string }>;
} = {
sessions: [],
globalPause: null,
orchestrators: [],
};
try {
const { config, registry, sessionManager } = await getServices();
const allSessions = await sessionManager.list();
globalPause = resolveGlobalPause(allSessions);
pageData.globalPause = resolveGlobalPause(allSessions);
const visibleSessions = filterProjectSessions(allSessions, projectFilter, config.projects);
orchestrators = listDashboardOrchestrators(visibleSessions, config.projects);
pageData.orchestrators = listDashboardOrchestrators(visibleSessions, config.projects);
const coreSessions = filterWorkerSessions(allSessions, projectFilter, config.projects);
sessions = coreSessions.map(sessionToDashboard);
pageData.sessions = coreSessions.map(sessionToDashboard);
const metaTimeout = new Promise<void>((resolve) => setTimeout(resolve, 3_000));
await Promise.race([
enrichSessionsMetadata(coreSessions, sessions, config, registry),
enrichSessionsMetadata(coreSessions, pageData.sessions, config, registry),
metaTimeout,
]);
@ -69,25 +75,29 @@ export default async function Home(props: { searchParams: Promise<{ project?: st
const cached = prCache.get(cacheKey);
if (cached) {
if (sessions[i].pr) {
sessions[i].pr.state = cached.state;
sessions[i].pr.title = cached.title;
sessions[i].pr.additions = cached.additions;
sessions[i].pr.deletions = cached.deletions;
sessions[i].pr.ciStatus = cached.ciStatus as "none" | "pending" | "passing" | "failing";
sessions[i].pr.reviewDecision = cached.reviewDecision as
if (pageData.sessions[i].pr) {
pageData.sessions[i].pr.state = cached.state;
pageData.sessions[i].pr.title = cached.title;
pageData.sessions[i].pr.additions = cached.additions;
pageData.sessions[i].pr.deletions = cached.deletions;
pageData.sessions[i].pr.ciStatus = cached.ciStatus as
| "none"
| "pending"
| "passing"
| "failing";
pageData.sessions[i].pr.reviewDecision = cached.reviewDecision as
| "none"
| "pending"
| "approved"
| "changes_requested";
sessions[i].pr.ciChecks = cached.ciChecks.map((c) => ({
pageData.sessions[i].pr.ciChecks = cached.ciChecks.map((c) => ({
name: c.name,
status: c.status as "pending" | "running" | "passed" | "failed" | "skipped",
url: c.url,
}));
sessions[i].pr.mergeability = cached.mergeability;
sessions[i].pr.unresolvedThreads = cached.unresolvedThreads;
sessions[i].pr.unresolvedComments = cached.unresolvedComments;
pageData.sessions[i].pr.mergeability = cached.mergeability;
pageData.sessions[i].pr.unresolvedThreads = cached.unresolvedThreads;
pageData.sessions[i].pr.unresolvedComments = cached.unresolvedComments;
}
if (
@ -102,12 +112,14 @@ export default async function Home(props: { searchParams: Promise<{ project?: st
const project = resolveProject(core, config.projects);
const scm = getSCM(registry, project);
if (!scm) return Promise.resolve();
return enrichSessionPR(sessions[i], scm, core.pr);
return enrichSessionPR(pageData.sessions[i], scm, core.pr);
});
const enrichTimeout = new Promise<void>((resolve) => setTimeout(resolve, 4_000));
await Promise.race([Promise.allSettled(enrichPromises), enrichTimeout]);
} catch {
sessions = [];
pageData.sessions = [];
pageData.globalPause = null;
pageData.orchestrators = [];
}
const projectName = getSelectedProjectName(projectFilter);
@ -116,12 +128,12 @@ export default async function Home(props: { searchParams: Promise<{ project?: st
return (
<Dashboard
initialSessions={sessions}
initialSessions={pageData.sessions}
projectId={selectedProjectId}
projectName={projectName}
projects={projects}
initialGlobalPause={globalPause}
orchestrators={orchestrators}
initialGlobalPause={pageData.globalPause}
orchestrators={pageData.orchestrators}
/>
);
}