import * as plugins from './plugins.js'; import { FlexFramedTransport } from './classes.flexframedtransport.js'; import { type IFlexServiceStatus, type TFlexChildMessage, type TFlexParentMessage } from './interfaces.flexipc.js'; export declare const flexHarnessTimeoutPolicy: Readonly<{ generationLeaseCleanupTimeoutMs: 30000; reversionMaintenanceTimeoutMs: number; }>; export interface IFlexServiceOptions { transport: FlexFramedTransport; onFatalError?: (errorArg: Error) => void; } export declare const createFlexSubagentDefinitions: () => plugins.flexharness.IFlexSubagentDefinition[]; export declare const createFlexBuiltInTools: () => plugins.flexharness.IFlexBuiltInToolsOptions; export declare class FlexService { private readonly modelRegistry; private readonly transport; private readonly onFatalError?; private status; private initData?; private database?; private store?; private harness?; private unsubscribeHarness?; private openAiAdapter?; private authSwitchLogin?; private providerRegistry?; private secretKernelStore?; private secretStore?; private readonly projects; private readonly pendingProjectRegistrations; private readonly postHarnessMigratedProjects; private readonly pendingProjectRetirements; private readonly pendingProjectRemovals; private readonly projectRegistrationMigrationContext; private readonly loginHandles; private readonly cancelledProviderLoginIds; private readonly catalogCache; private readonly connectionQueues; private secretQueue; private projectRequestTail; private readonly jobs; private readonly intelligenceJobs; private readonly activeIntelligenceJobIdsBySource; private pendingJobAdmissions; private pendingLoginAdmissions; private readonly pendingUploadGrantsBySession; private readonly uploadGrantsByQueueId; private readonly uploadGrantQueueIdsByRunId; private readonly promptRunsByRunKey; private readonly promptMessagesByRunKey; private readonly acknowledgedRunQueueIds; private readonly runAcknowledgementLeasesBySession; private readonly runAcknowledgementLeasesByRun; private readonly runAcknowledgementLeasesByRequestId; private readonly finishedRunKeys; private readonly delegatedRunBindingsByRun; private readonly delegatedRunBindingsBySession; private readonly compactionChoicesBySession; private readonly activeControlRequests; private readonly backgroundTasks; private readonly pendingHostRequests; private readonly lateHostRequestIds; private readonly lateHostCompensationTasks; private readonly browserChannels; private droppedBrowserFrames; private readonly browserChannelAdmissions; private readonly pendingBrowserChannelClosures; private readonly browserFrameTasks; private browserFrameReservationCount; private browserFrameReservationBytes; private readonly sessionChangeQueue; private sessionDeltaTailKeys; private sessionChangeQueueBytes; private sessionChangeQueueTailKey; private sessionChangeFlushRunning; private hostRequestAdmissionOpen; private admissionOpen; private runAcknowledgementTimeoutMs; private runAcknowledgementCancellationRetryMs; private lateHostCompensationDrainTimeoutMs; private failureStatusTimeoutMs; private failureCleanupTimeoutMs; private storeFatalError?; private fatalShutdownPromise?; private initialized; private initializationTask?; private disposing; private disposed; private disposePromise?; constructor(optionsArg: IFlexServiceOptions); start(): Promise; getStatus(): IFlexServiceStatus; closeTransport(): Promise; dispose(): Promise; private handleMessage; private initialize; private handleStoreFatalError; private handleFatalError; private handleRequestMessage; private dispatchRequest; private createIntelligenceJob; private cancelIntelligenceJob; private runIntelligenceJob; private provideIntelligenceTools; private requireIntelligenceJob; private trimIntelligenceJobs; private flexUploadRootForRun; private bindUploadGrantQueue; private bindUploadGrantRun; private deleteUploadGrant; private deleteSessionUploadGrants; private deleteProjectUploadGrants; private provideTools; private createTurnReversionProvider; private handleWorktreeSlashCommand; private requestGitWorktreeCreation; private resolveBrowserResourceToolProviders; private provideBrowserResourceTools; private assertBrowserChannelBinding; private closeBrowserChannel; private applyBrowserChannelClosure; private writeBrowserChannelFrame; private writePassThroughFrame; private cloneProjectManagementSessionContext; private projectDelegatedRunAdmissionContext; private retainDelegatedRunBinding; private releaseDelegatedRunBinding; private closeDelegatedRunAdmission; private acquireDelegatedRunAdmission; private createProjectManagementHost; private requestHost; private retirePendingHostRequest; private handleHostResponse; private resolveModel; private handleHarnessEvent; private promptRunKey; private promptEventRunKey; private promptSessionKey; private reserveRunAcknowledgement; private bindRunAcknowledgementQueue; private bindRunAcknowledgementLease; private bindPendingRunAcknowledgementFromEvent; private bindRunAcknowledgementRequest; private requireRunAcknowledgementLease; private releaseRunAcknowledgementLease; private cancelRunAcknowledgementLease; private scheduleRunAcknowledgementCancellationRetry; private rememberFinishedRun; private rememberAcknowledgedRun; private acknowledgeRun; private settleRunAcknowledgement; private waitForRunAcknowledgementLeaseBinding; private waitForRunAcknowledgement; private setPromptRunCorrelation; private setPromptMessageCorrelation; private emitPromptMessageBinding; private deleteSessionPromptCorrelations; private sessionChangeEventBytes; private getSessionDeltaTailKeys; private deleteSessionChangeQueueEntry; private clearSessionChangeQueue; private setSessionChangeQueueEntry; private collapseSessionChangeQueue; private sessionGenerationEventKey; private queueToolChange; private queueReasoningChange; private queueTextChange; private queuePartDelta; private enqueuePartDeltaFragment; private queueSessionChange; private queuePermissionChange; private startSessionChangeFlush; private flushSessionChanges; private reserveJobAdmission; private finishJob; private beginProviderLogin; private finalizeProviderLogin; private countProviderConnections; private failProviderLogin; private cancelProviderLogin; private listConnections; private listProviderConnectionIdsForCredentialMigration; private getConnection; private transitionConnection; private reconcileProviderConnections; private prepareLogoutConnection; private logoutConnection; private refreshCatalog; private refreshCatalogInConnectionQueue; private validateModelChoice; private validateModelChoiceInQueue; private markConnectionReauthRequired; private getModelChoice; private setModelChoice; private modelChoiceId; private deleteModelChoiceForScope; private deleteModelChoicesForConnection; private getAccountRateLimits; private readCredential; private tryReadCredential; private writeCredential; private deleteCredential; private createCredentialStores; private recreateCredentialStores; private closeCredentialStores; private setCredentialStores; private withSecretQueue; private withConnectionQueue; private withProviderOperationDeadline; private withProjectRequestQueue; private trackBackgroundTask; private trackLateHostCompensationTask; private drainLateHostCompensations; private registerProject; private removeProject; private sendStatus; private sendEvent; private disposeResources; private requireInit; private requireHarness; private requireOpenAiAdapter; private requireProviderRegistry; private requireSecretStore; private requireCredentialStores; }