// Subagent announce delivery tests cover the last-mile routing used when child

// runs report progress or completion back to the requester session.

import { afterEach, describe, expect, it, vi } from "vitest";

import { OutboundDeliveryError } from "../infra/outbound/deliver-types.js";

import {

function createQueueOutcomeSequenceMock(

queuedOutcomes: (boolean | EmbeddedAgentQueueFailureReason)[],

): ReturnType<typeof vi.fn<QueueEmbeddedAgentMessageWithOutcome>> {

// Sequence mocks model retry paths where the embedded run can become

// unavailable between announce attempts.

let index = 0;

return vi.fn((sessionId: string) => {

const outcome = queuedOutcomes[Math.min(index, queuedOutcomes.length - 1)] ?? false;

sourceTool?: string;

requesterAbandoned?: boolean;

}) {

// Slack thread delivery exercises all origins because direct, session, and

// completion routing can differ after a child run outlives its requester.

testing.setDepsForTest({

callGateway: params.callGateway,

getRequesterSessionActivity: () => ({

// Subagent announce dispatch tests lock down direct-vs-steer ordering for

// progress updates and completion messages.

import { describe, expect, it, vi } from "vitest";

import {

mapSteerOutcomeToDeliveryResult,

terminal: true,

}));

// Terminal direct failures can represent partial media delivery; fallback

// steering would risk duplicate or contradictory completion messages.

const result = await runSubagentAnnounceDispatch({

expectsCompletionMessage: true,

steer,

// Subagent announce output tests cover transcript reads, completion extraction,

// compact stats, and wait-outcome text used in announce messages.

import { afterEach, describe, expect, it, vi } from "vitest";

import {

testing,

}

function sessionsYieldTurn(message = "Waiting for subagent completion.") {

// sessions_yield is requester control flow, not child output; fixtures keep

// that wait turn adjacent to later assistant completions.

return [

{

role: "assistant",

],

});

// Private transcript data is fresher for recovered runs and avoids exposing

// stale gateway-visible history after an internal completion is persisted.

await expect(

readSubagentOutput("agent:main:subagent:child", undefined, {

sessionFile: "/tmp/openclaw-internal-run.jsonl",

// Completion-reply capture tests cover the short polling window used to collect

// final child output after an announce waits for the subagent.

import { describe, expect, it, vi } from "vitest";

import { captureSubagentCompletionReplyUsing } from "./subagent-announce-capture.js";

.mockResolvedValueOnce(undefined)

.mockResolvedValueOnce("Late tool result completion");

// Fake timers make the retry contract deterministic without waiting for the

// wall-clock window used by live child sessions.

const pending = captureSubagentCompletionReplyUsing({

sessionKey: "agent:main:subagent:child",

maxWaitMs: 50,