ewilliams28/openclaw
1
0
Fork 0
mirror of https://github.com/openclaw/openclaw.git synced 2026-08-23 02:45:38 -06:00
Code Issues Packages Projects Releases Wiki Activity

test(auto-reply): align prepared harness proof with SQLite sessions

Browse Source
This commit is contained in:
joshavant
2026-08-10 21:01:23 -05:00
committed by Josh Avant
parent 3d6028da4c
commit eacf6774fa
2 changed files with 10 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/agents/embedded-agent-runner/run.overflow-compaction.harness.ts
+2 -1
View File
@@ -23,6 +23,7 @@ import type { AuthProfileStore } from "../auth-profiles/types.js";
import { extractObservedOverflowTokenCount } from "../embedded-agent-helpers/context-overflow-observation.js";
import type { FailoverReason } from "../failover/signal.js";
import { clearAgentHarnesses, registerAgentHarness } from "../harness/registry.js";
import type { AgentHarnessAttemptParams } from "../harness/types.js";
import type { ResolvedProviderAuth } from "../model-auth-runtime-shared.js";
import type { AgentRuntimePlan } from "../runtime-plan/types.js";
import { makeAttemptResult } from "./run.overflow-compaction.fixture.js";
@@ -257,7 +258,7 @@ const mockedPrepareProviderRuntimeAuth = vi.fn<
(params?: { context?: { apiKey?: string } }) => Promise<{ apiKey: string } | undefined>
>(async () => undefined);
export const mockedRunEmbeddedAttempt =
vi.fn<(params: unknown) => Promise<EmbeddedRunAttemptResult>>();
vi.fn<(params: AgentHarnessAttemptParams) => Promise<EmbeddedRunAttemptResult>>();
export const mockedBuildEmbeddedRunPayloads = vi.fn<
(
...args: Parameters<typeof buildEmbeddedRunPayloads>
src/auto-reply/reply/prepared-harness-source-delivery.integration.test.ts
+8 -4
View File
@@ -174,11 +174,11 @@ describe("prepared harness source delivery", () => {
};
const followupRun = createFollowupRun();
followupRun.run.sessionKey = undefined;
followupRun.run.sessionFile = undefined;
followupRun.run.sessionFile = followupRun.run.sessionId;
followupRun.run.sourceReplyDeliveryMode = runtimeOpts.sourceReplyDeliveryMode;
setSourceReplyDeliveryModeOrigin(followupRun.run, runtimeOpts.sourceReplyDeliveryModeOrigin);
// Dispatch already captured its session snapshot; the embedded fixture has
// no durable transcript row and should therefore skip writer admission.
// Dispatch already captured its session snapshot; the embedded fixture uses
// a SQLite compatibility key and has no durable row for writer admission.
sessionStoreMocks.currentEntry = undefined;
const execution = await executeAgentTurn({
commandBody: "hello",
@@ -211,7 +211,11 @@ describe("prepared harness source delivery", () => {
`expected settled fallback execution: ${embeddedErrorText}; ${JSON.stringify({ execution, failedParams })}`,
);
}
return execution.runResult.payloads[0] satisfies ReplyPayload;
const payload = execution.runResult.payloads?.[0];
if (!payload) {
throw new Error("expected settled fallback payload");
}
return payload satisfies ReplyPayload;
});
const deliver = vi.fn(async () => {});
const onPartialReply = vi.fn(async () => {});