diff --git a/src/shared/compaction-marker.ts b/src/shared/compaction-marker.ts index 6af43e774..795ddae61 100644 --- a/src/shared/compaction-marker.ts +++ b/src/shared/compaction-marker.ts @@ -30,12 +30,16 @@ export function isCompactionMessage(message: CompactionMessageLike): boolean { return isCompactionAgent(message.info?.agent ?? message.agent) || hasCompactionPart(message.parts) } +export function getCompactionPartStorageDir(messageID: string): string { + return join(PART_STORAGE, messageID) +} + export function hasCompactionPartInStorage(messageID: string | undefined): boolean { if (!messageID) { return false } - const partDir = join(PART_STORAGE, messageID) + const partDir = getCompactionPartStorageDir(messageID) if (!existsSync(partDir)) { return false } diff --git a/src/shared/tmux/tmux-utils/server-health.ts b/src/shared/tmux/tmux-utils/server-health.ts index 043c9048d..a4c5c6806 100644 --- a/src/shared/tmux/tmux-utils/server-health.ts +++ b/src/shared/tmux/tmux-utils/server-health.ts @@ -58,4 +58,5 @@ export async function isServerRunning(serverUrl: string): Promise { export function resetServerCheck(): void { serverAvailable = null serverCheckUrl = null + delete (globalThis as Record)[SERVER_RUNNING_KEY] }