Skip to content

Commit 486af3e

Browse files
authored
Merge pull request #163 from pylon-code/fix/prime-background-prompt-admission
fix(server): keep Prime background work out of foreground turns
2 parents 6a31ea8 + 9a4de4c commit 486af3e

9 files changed

Lines changed: 4076 additions & 224 deletions

apps/server/src/provider/prime/PrimeAgentDaemonAdapter.test.ts

Lines changed: 1117 additions & 29 deletions
Large diffs are not rendered by default.

apps/server/src/provider/prime/PrimeAgentDaemonAdapter.ts

Lines changed: 622 additions & 142 deletions
Large diffs are not rendered by default.

apps/server/src/provider/prime/PrimeAgentDaemonBridge.ts

Lines changed: 14 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -48,7 +48,9 @@ export interface PrimeAgentDaemonClient {
4848
timeoutMs?: number,
4949
) => Promise<unknown>;
5050
readonly enableRequestRecovery?: () => void;
51-
readonly supportsServerCapability?: (capability: "queue_message_mutation") => boolean;
51+
readonly supportsServerCapability?: (
52+
capability: "queue_message_mutation" | "correlated_prompt_lifecycle_v1",
53+
) => boolean;
5254
readonly enableAutoReconnect?: (options: {
5355
readonly recoverDaemon: () => Promise<void>;
5456
readonly timeoutMs?: number;
@@ -124,6 +126,17 @@ export interface PrimeAgentDaemonAgentConnection {
124126
message: string,
125127
options?: PrimeAgentDaemonPromptOptions,
126128
) => Promise<unknown>;
129+
readonly submitCorrelatedPrompt?: (
130+
message: string,
131+
options: {
132+
readonly correlationId: string;
133+
readonly images?: ReadonlyArray<PrimeAgentDaemonImage>;
134+
readonly queueIfBusy?: boolean;
135+
readonly signal?: AbortSignal;
136+
},
137+
) => Promise<unknown>;
138+
readonly cancelPromptLifecycle?: (correlationId: string) => Promise<unknown>;
139+
readonly getPromptLifecycles?: () => Promise<unknown>;
127140
readonly waitForHeadlessCompletion?: (options?: {
128141
readonly waitForRlmQuiescence?: boolean;
129142
}) => Promise<unknown>;

0 commit comments

Comments
 (0)