basant307/AI_Governance_Project
048
1/**2 * @license3 * Copyright 2026 Qwen Team4 * SPDX-License-Identifier: Apache-2.05 */6import type { Application, Request, RequestHandler, Response } from 'express';7import type { AcpSessionBridge, BridgeWorkspaceMemoryDreamResult, BridgeWorkspaceMemoryForgetResult, BridgeWorkspaceMemoryRememberContextMode, BridgeWorkspaceMemoryRememberResult } from './acp-session-bridge.js';8export type WorkspaceMemoryTaskStatus = 'queued' | 'running' | 'completed' | 'failed';9/** @deprecated Use WorkspaceMemoryTaskStatus. */10export type WorkspaceMemoryRememberTaskStatus = WorkspaceMemoryTaskStatus;11export type WorkspaceMemoryTaskKind = 'remember' | 'forget' | 'dream';12interface WorkspaceMemoryTaskBaseSnapshot {13 taskId: string;14 status: WorkspaceMemoryTaskStatus;15 createdAt: string;16 updatedAt: string;17 error?: {18 code: string;19 message: string;20 };21}22export interface WorkspaceMemoryRememberTaskSnapshot extends WorkspaceMemoryTaskBaseSnapshot {23 contextMode: BridgeWorkspaceMemoryRememberContextMode;24 result?: BridgeWorkspaceMemoryRememberResult;25}26export interface WorkspaceMemoryForgetTaskSnapshot extends WorkspaceMemoryTaskBaseSnapshot {27 result?: BridgeWorkspaceMemoryForgetResult;28}29export interface WorkspaceMemoryDreamTaskSnapshot extends WorkspaceMemoryTaskBaseSnapshot {30 result?: BridgeWorkspaceMemoryDreamResult;31}32type WorkspaceMemoryTaskRecord = (({33 kind: 'remember';34} & WorkspaceMemoryRememberTaskSnapshot) | ({35 kind: 'forget';36} & WorkspaceMemoryForgetTaskSnapshot) | ({37 kind: 'dream';38} & WorkspaceMemoryDreamTaskSnapshot)) & {39 originatorClientId?: string;40};41export interface WorkspaceRememberRouteDeps {42 bridge: AcpSessionBridge;43 lane: WorkspaceRememberTaskLane;44 mutate: (opts?: {45 strict?: boolean;46 }) => RequestHandler;47 parseClientId: (req: Request, res: Response) => string | undefined | null;48 safeBody: (req: Request) => Record<string, unknown>;49}50export declare function publicErrorMessage(code: string, kind: WorkspaceMemoryTaskKind): string;51export declare function publicErrorStatus(code: string): number;52export declare class WorkspaceRememberTaskLane {53 private readonly bridge;54 private static readonly MAX_TASKS;55 private static readonly TERMINAL_TASK_TTL_MS;56 private static readonly MAX_PENDING;57 private static readonly MAX_NON_REMEMBER_PENDING;58 private static readonly NON_REMEMBER_KINDS;59 private readonly tasks;60 private tail;61 constructor(bridge: AcpSessionBridge);62 private pendingCounts;63 private evictTerminalTasks;64 private assertCapacity;65 private queue;66 private publishManagedMemoryChanged;67 enqueue(params: {68 content: string;69 contextMode: BridgeWorkspaceMemoryRememberContextMode;70 originatorClientId?: string;71 }): WorkspaceMemoryRememberTaskSnapshot;72 enqueueForget(params: {73 query: string;74 originatorClientId?: string;75 }): WorkspaceMemoryForgetTaskSnapshot;76 enqueueDream(params: {77 originatorClientId?: string;78 }): WorkspaceMemoryDreamTaskSnapshot;79 get(taskId: string, requesterClientId?: string, kind?: WorkspaceMemoryTaskRecord['kind']): WorkspaceMemoryRememberTaskSnapshot | WorkspaceMemoryForgetTaskSnapshot | WorkspaceMemoryDreamTaskSnapshot | undefined;80}81export declare function mountWorkspaceMemoryRememberRoutes(app: Application, deps: WorkspaceRememberRouteDeps): void;82export {};83 