From c91cfc3ec2e8424bcb73c23a958490b4583051b7 Mon Sep 17 00:00:00 2001 From: imccyu Date: Thu, 13 Aug 2026 19:44:14 +0800 Subject: [PATCH 1/2] fix: SessionPersistenceCorruptionError --- packages/session-query/session-query/src/corpus.ts | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/packages/session-query/session-query/src/corpus.ts b/packages/session-query/session-query/src/corpus.ts index 717b2b5190..05b4292127 100644 --- a/packages/session-query/session-query/src/corpus.ts +++ b/packages/session-query/session-query/src/corpus.ts @@ -2,7 +2,8 @@ import type { Context, Fiber } from '@deepseek-ai/cordis' import type { Session, SessionEvent, SessionHeader, SessionId } from '@deepseek-ai/dsh-session' -import SessionPersistence, { SessionPersistenceCorruptionError } from '@deepseek-ai/dsh-session-persistence' +import type SessionPersistence from '@deepseek-ai/dsh-session-persistence' +import type { SessionPersistenceCorruptionError } from '@deepseek-ai/dsh-session-persistence' import type { SessionRecord } from './types.ts' import { SessionQueryError } from './config.ts' import { assertSessionHeadersCompatible } from './sources.ts' @@ -274,7 +275,7 @@ async function inspectPersisted( return await persistence.inspect(sessionId, signal) } catch (error: unknown) { if (signal?.aborted) signal.throwIfAborted() - if (error instanceof SessionPersistenceCorruptionError) { + if ((error as SessionPersistenceCorruptionError).name === 'SessionPersistenceCorruptionError') { throw new SessionQueryError( `stored session "${sessionId}" is corrupt: ${errorMessage(error)}`, 'SESSION_QUERY_CORRUPT_SESSION', From c1d26018a4da5c4902eb1f82c51131f0c2e5f1e7 Mon Sep 17 00:00:00 2001 From: imccyu Date: Thu, 13 Aug 2026 19:49:27 +0800 Subject: [PATCH 2/2] fix: lint --- packages/session-query/session-query/src/corpus.ts | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) diff --git a/packages/session-query/session-query/src/corpus.ts b/packages/session-query/session-query/src/corpus.ts index 05b4292127..69fbc8a1a9 100644 --- a/packages/session-query/session-query/src/corpus.ts +++ b/packages/session-query/session-query/src/corpus.ts @@ -3,7 +3,6 @@ import type { Context, Fiber } from '@deepseek-ai/cordis' import type { Session, SessionEvent, SessionHeader, SessionId } from '@deepseek-ai/dsh-session' import type SessionPersistence from '@deepseek-ai/dsh-session-persistence' -import type { SessionPersistenceCorruptionError } from '@deepseek-ai/dsh-session-persistence' import type { SessionRecord } from './types.ts' import { SessionQueryError } from './config.ts' import { assertSessionHeadersCompatible } from './sources.ts' @@ -275,7 +274,7 @@ async function inspectPersisted( return await persistence.inspect(sessionId, signal) } catch (error: unknown) { if (signal?.aborted) signal.throwIfAborted() - if ((error as SessionPersistenceCorruptionError).name === 'SessionPersistenceCorruptionError') { + if (error instanceof Error && error.name === 'SessionPersistenceCorruptionError') { throw new SessionQueryError( `stored session "${sessionId}" is corrupt: ${errorMessage(error)}`, 'SESSION_QUERY_CORRUPT_SESSION',