neuron-technologies/neuron
2
0
Fork 0
Code Issues 44 Pull Requests Actions Packages Projects Releases Wiki Activity

fix(app): hydrate v1 session progress (#38606)

Browse Source
This commit is contained in:
Brendan Allan
2026-07-24 11:39:40 +08:00
committed by GitHub
parent a46c9aee07
commit e39576a1ac
2 changed files with 5 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files
packages/app/src/context/server-sync.test.ts
+2 -1
View File
@@ -64,7 +64,7 @@ describe("MCP queries", () => {
}) })
describe("active session query", () => { describe("active session query", () => {
test("loads active sessions once per server cache", async () => { test("loads active sessions immediately and once per server cache", async () => {
let calls = 0 let calls = 0
const queryClient = new QueryClient() const queryClient = new QueryClient()
const options = loadActiveSessionsQuery(ServerScope.local, { const options = loadActiveSessionsQuery(ServerScope.local, {
@@ -77,6 +77,7 @@ describe("active session query", () => {
expect(await queryClient.fetchQuery(options)).toEqual({ ses_running: { type: "running" } }) expect(await queryClient.fetchQuery(options)).toEqual({ ses_running: { type: "running" } })
expect(await queryClient.fetchQuery(options)).toEqual({ ses_running: { type: "running" } }) expect(await queryClient.fetchQuery(options)).toEqual({ ses_running: { type: "running" } })
expect(calls).toBe(1) expect(calls).toBe(1)
expect(options.enabled).toBe(true)
expect([...options.queryKey]).toEqual([ServerScope.local, "activeSessions"]) expect([...options.queryKey]).toEqual([ServerScope.local, "activeSessions"])
}) })
packages/app/src/context/server-sync.tsx
+3 -3
View File
@@ -157,7 +157,7 @@ export const loadActiveSessionsQuery = (
queryOptions<SessionActiveOutput, Error, SessionActiveOutput, readonly [ServerScope, "activeSessions"]>({ queryOptions<SessionActiveOutput, Error, SessionActiveOutput, readonly [ServerScope, "activeSessions"]>({
queryKey: [scope, "activeSessions"] as const, queryKey: [scope, "activeSessions"] as const,
queryFn: () => api.active(), queryFn: () => api.active(),
enabled: false, enabled: true,
staleTime: Number.POSITIVE_INFINITY, staleTime: Number.POSITIVE_INFINITY,
gcTime: Number.POSITIVE_INFINITY, gcTime: Number.POSITIVE_INFINITY,
refetchOnMount: false, refetchOnMount: false,
@@ -242,8 +242,8 @@ export function createServerSyncContextInner(serverSDK: ServerSDK) {
active: async () => { active: async () => {
if ((await serverSDK.protocol) === "v1") { if ((await serverSDK.protocol) === "v1") {
const statuses = (await serverSDK.client.session.status()).data ?? {} const statuses = (await serverSDK.client.session.status()).data ?? {}
for (const [sessionID, status] of Object.entries(statuses)) { seedActiveSessionStatuses(session, statuses)
session.set("session_status", sessionID, reconcile(status)) for (const sessionID of Object.keys(statuses)) {
void session.resolve(sessionID).catch(() => undefined) void session.resolve(sessionID).catch(() => undefined)
} }
return Object.fromEntries( return Object.fromEntries(