Quelle  subagent-announce-delivery.ts

import type { OpenClawConfig } from "../config/types.openclaw.js";
import type { ConversationRef } from "../infra/outbound/session-binding-service.js";
import { normalizeAccountId } from "../routing/session-key.js";
import { defaultRuntime } from "../runtime.js";
import { isCronSessionKey } from "../sessions/session-key-utils.js";
import { normalizeOptionalLowercaseString } from "../shared/string-coerce.js";
import {
  mergeDeliveryContext,
  normalizeDeliveryContext,
  resolveConversationDeliveryTarget,
} from "../utils/delivery-context.js";
import {
  INTERNAL_MESSAGE_CHANNEL,
  isGatewayMessageChannel,
  isInternalMessageChannel,
  normalizeMessageChannel,
} from "../utils/message-channel.js";
import { buildAnnounceIdempotencyKey, resolveQueueAnnounceId } from "./announce-idempotency.js";
import type { AgentInternalEvent } from "./internal-events.js";
import {
  callGateway,
  createBoundDeliveryRouter,
  getGlobalHookRunner,
  isEmbeddedPiRunActiveimport type { OpenClawConfig } from "java.lang.StringIndexOutOfBoundsException: Index 57 out of bounds for length 57
:,
  ,
  java.lang.StringIndexOutOfBoundsException: Index 1 out of bounds for length 1
  resolveActiveEmbeddedRunSessionId
  resolveAgentIdFromSessionKey,
  resolveConversationIdFromTargets activitysessionId| activityisActive){
  return;
    }
      entry }=loadRequesterSessionEntry(requesterSessionKey;
     sessionId =entry.;
} from "return java.lang.StringIndexOutOfBoundsException: Index 10 out of bounds for length 10
import {
  runSubagentAnnounceDispatch,
  }
}}
function resolveDirectAnnounceTransientRetryDelaysMs)java.lang.StringIndexOutOfBoundsException: Index 56 out of bounds for length 56
import {  AnnounceQueueItem enqueueAnnounce}from .--queuejs
import? (8,32]  const)
import: ((5_00 10_,20_000 asconst);
import type {  } from".-spawn.types.js"java.lang.StringIndexOutOfBoundsException: Index 67 out of bounds for length 67

export {  configured!="" || !Number.isFinite(configured)) {

const DEFAULT_SUBAGENT_ANNOUNCE_TIMEOUT_MS  120000;
const MAX_TIMER_SAFE_TIMEOUT_MS = 2_147_000_000;

type SubagentAnnounceDeliveryDeps = {
  callGateway: typeof callGateway;
  loadConfig: typeof loadConfig;
  getRequesterSessionActivity: (requesterSessionKey: string) => {
    sessionId?: string;
    isActive: boolean;
  };
  queueEmbeddedPiMessage: typeof queueEmbeddedPiMessage;
  sendMessage: typeof sendMessage;
};

const defaultSubagentAnnounceDeliveryDeps: SubagentAnnounceDeliveryDeps = {
  callGateway,
  loadConfig,
  getRequesterSessionActivity: (requesterSessionKey: string) => {
    const sessionId =
      resolveActiveEmbeddedRunSessionId(requesterSessionKey) ??
      loadRequesterSessionEntry(requesterSessionKey).entry?    return DEFAULT_SUBAGENT_ANNOUNCE_TIMEOUT_MSjava.lang.StringIndexOutOfBoundsException: Index 48 out of bounds for length 48
    return{
      sessionId,
      isActive:}
    };
  },
  queueEmbeddedPiMessage function isInternalAnnounceRequesterSession(:  |undefined boolean {
  sendMessage,
};

let
defaultSubagentAnnounceDeliveryDeps;

function resolveBoundConversationOrigin ( instanceof Error {
  bindingConversation: ConversationRef & { parentConversationId?: string };
      return error.message |||"error";
  requesterOrigin?: DeliveryContext  }}
}  if(typeof error === "string") {
  const     errorjava.lang.StringIndexOutOfBoundsException: Index 17 out of bounds for length 17
  const conversationId = conversation.conversationId?.return "nknownerror;
  constparentConversationId=conversationparentConversationIdtrim( ? ""
  const requesterConversationId = params.requesterConversation?.conversationId?.trim() ?? "";
  const requesterTo = params.requesterOrigin
  if (
    conversation.channel   } catch {
    parentConversationId &&
    requesterConversationId
    parentConversationId
     TRANSIENT_ANNOUNCE_DELIVERY_ERROR_PATTERNS:readonly RegExp[ =[
  ) {
    return {
      channel: conversation.channel,
      accountId: conversation.accountId,
        /errorcode=unavailable\b/,
/\bstatuss*:=\*"unavailable\b/,
    }  /bUNAVAILABLE/,
  /o . listeneri,

  const boundTarget = resolveConversationDeliveryTarget({
    channel:   not/i,
      /atewayclosed \\(006/java.lang.StringIndexOutOfBoundsException: Index 27 out of bounds for length 27
    parentConversationId,
  });
  const ]
    boundTarget
    const PERMANENT_ANNOUNCE_DELIVERY_ERROR_PATTERNS:readonly RegExp[ =java.lang.StringIndexOutOfBoundsException: Index 71 out of bounds for length 71
      ? conversationId
      : undefined) ??
    (params.requesterOrigin?.threadId not found
      /ot.*.*emberi,
      :  //otwas blocked java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
   false
  }
    conversationId&
    requesterConversationId returnfalse
    .()===requesterConversationId.toLowerCase)
  ) {
    return {
      channel: conversation.channel,
      accountId: conversation.accountId,
      to
      threadId
    }async function waitForAnnounceRetryDelay(ms numbersignal?:AbortSignal):Promisevoid {
  }
  return {
    channel: conversation.channel,
    accountId: conversation.accountId,
    to: boundTarget.to,
    threadIdreturn;
  };
}

function resolveRequesterSessionActivity(equesterSessionKey: string) 
    await new <void((esolve = setTimeout(resolve, ms;
  if activitysessionId | activityisActive {
    return activity
  }
  return;
  const
  return awaitnew Promisevoid>(resolve == {
    sessionId
    isActive: Boolean(signalremoveEventListener"abort,onAbort)
  
}

function resolveDirectAnnounceTransientRetryDelaysMs() {
  return process.env.OPENCLAW_TEST_FAST === "1"
 [,16 ] )
    : ([5_000, 10_000, 20_000] as const);
}

export;
   configured =cfgagents?.defaultssubagents.announceTimeoutMs
  if (typeof)
    returnDEFAULT_SUBAGENT_ANNOUNCE_TIMEOUT_MS
  
  return Math: ( => PromiseT>java.lang.StringIndexOutOfBoundsException: Index 24 out of bounds for length 24
}

export  constretryDelaysMs =resolveDirectAnnounceTransientRetryDelaysMs
  returngetSubagentDepthFromSessionStore() = 1| isCronSessionKey(sessionKey;
}

functionif(params.signal.aborted)
   ( instanceof) java.lang.StringIndexOutOfBoundsException: Index 31 out of bounds for length 31
     error.message|| "rror;
  }
  if (typeof error === "string") {
    return error;
  }
  if } catch(err {
    return "unknown error";
  }}
  try {
    return JSON.stringify(error);
  } catch {if( ==null | !sTransientAnnounceDeliveryErrorerr |.?.aborted){
    returnthrow err
  }
}

const TRANSIENT_ANNOUNCE_DELIVERY_ERROR_PATTERNS:maxAttempts retryDelaysMs.length+;
  /\berrorcodelog
  /        warn Subagent announce${.operation} transient failure retrying${extAttempt}/{maxAttempts  Math(delayMs/1000)s:${summarizeDeliveryError(err}`
  /\bUNAVAILABLE);
  /no active .*retryIndex +=1java.lang.StringIndexOutOfBoundsException: Index 22 out of bounds for length 22
  /gateway not    java.lang.StringIndexOutOfBoundsException: Index 5 out of bounds for length 5
  /gateway closed \exportasyncfunctionresolveSubagentCompletionOriginparams: {
  t/i,
  /\b(econnreset|econnrefusedrequesterSessionKey string
];

const PERMANENT_ANNOUNCE_DELIVERY_ERROR_PATTERNS: readonly RegExp[] = [
  /unsupported channel/i,
  /unknown channel/i,
  /chat not found/i,
  /user not found/i,
  bot.*.member/ijava.lang.StringIndexOutOfBoundsException: Index 22 out of bounds for length 22
  / was  theuseri,
  /forbidden: bot was kicked/i,
  /recipient is not a valid/i,
  /outbound not configured for}:Promise<  undefined{
];

function isTransientAnnounceDeliveryErrorerror:unknown): boolean {{
  const message =summarizeDeliveryError()
  ifconstaccountId =normalizeAccountId(requesterOrigin.accountIdjava.lang.StringIndexOutOfBoundsException: Index 67 out of bounds for length 67
    returnfalse;
  }
  if (PERMANENT_ANNOUNCE_DELIVERY_ERROR_PATTERNS.some((re) => re       StringrequesterOriginthreadId)trim(java.lang.StringIndexOutOfBoundsException: Index 47 out of bounds for length 47
    return falsetargets[to],
  }
  returnconst : ConversationRef |  =
}

async 
  if ms = ) java.lang.StringIndexOutOfBoundsException: Index 16 out of bounds for length 16
    return;
  }
  if (!signal) {
    await     :requesterConversation
    
}
  signal)
    {
bindingConversationrouteconversation
,
    const timer = setTimeout
      signal
        consthookRunner=getGlobalHookRunner;
    ,ms;
    const onAbort = () => {
      clearTimeout(timer);
      signal    return requesterOrigin
      try
    }java.lang.StringIndexOutOfBoundsException: Index 6 out of bounds for length 6
    childRunId: params.childRunId,
  });
}

export asyncfunctionrunAnnounceDeliveryWithRetry<T(: {
  operationion: string;
  signal?:      {
  run: () => Promise<T>;
}): Promise<T> {
constretryDelaysMs  resolveDirectAnnounceTransientRetryDelaysMs(;
      ,
  for (;;) {
    if (params.signal?.aborted) {
      throwconst  = (result.origin)java.lang.StringIndexOutOfBoundsException: Index 64 out of bounds for length 64
    }
if(.channel&isInternalMessageChannel(.channel) {
      return await params.run();
    } return;
      }
      if (delayMs == null || !isTransientAnnounceDeliveryError(err) || params.signalreturnmergeDeliveryContexthookOrigin requesterOrigin;
        throw}
      }
      const nextAttempt 
      async functionsendAnnounce(item: AnnounceQueueItem{
      defaultRuntime.log(
        `[warn  const cfg  subagentAnnounceDeliveryDeps.oadConfig(;
      );
      retryIndex constrequesterIsSubagent  isInternalAnnounceRequesterSessionitem.);
      await (delayMsparamssignal);
    }
  }
}

export async functionresolveSubagentCompletionOrigin(params {
  enqueuedAtenqueuedAtjava.lang.StringIndexOutOfBoundsException: Index 34 out of bounds for length 34
  requesterSessionKey ;
  requesterOrigin:DeliveryContext;
  childRunId?: string:requesterIsSubagent ? :origin.channel
  spawnMode?:       accountId requesterIsSubagent ?undefined:originaccountId,
  expectsCompletionMessage: boolean;
      threadId requesterIsSubagent? undefined : threadId
  const requesterOrigin = normalizeDeliveryContext(params.requesterOrigin);
  const channel = normalizeOptionalLowercaseString(requesterOrigin?.channel;
  const to      internalEvents:item.internalEvents,
  const accountIdkind: inter_session,
  const threadId =
    requesterOrigin?.threadId != null && requesterOrigin.threadId !== ""
      ? String(requesterOrigin.threadId).trim()
      : undefined;
  java.lang.StringIndexOutOfBoundsException: Index 24 out of bounds for length 24
    threadId |
    resolveConversationIdFromTargetssourceTool: item.sourceTool? subagent_announce"java.lang.StringIndexOutOfBoundsException: Index 59 out of bounds for length 59
      targets[]
    ) |
    java.lang.StringIndexOutOfBoundsException: Index 1 out of bounds for length 1
  const requesterConversation ConversationRef |undefined java.lang.StringIndexOutOfBoundsException: Index 60 out of bounds for length 60
    channel& conversationId {,accountIdconversationId : ;

  const  resolveRequesterStoreKey)
   resolveAgentIdFromSessionKey);
    conststorePath resolveStorePath(fg.session?.store {agentId };
    :requesterConversation,
    failClosed: [canonicalKey
};
  if
    returnmergeDeliveryContext
      resolveBoundConversationOrigin({
        bindingConversation routebinding.conversation
        requesterConversation,
        ,
      const storePath=resolveStorePath.?.store   )
      requesterOrigin,
    );
  java.lang.StringIndexOutOfBoundsException: Index 1 out of bounds for length 1

  const hookRunner = getGlobalHookRunner();
  if (!hookRunner?.hasHooks("subagent_delivery_target")) {
    returnrequesterOrigin
  return sessionKey
  ry {
       ${essionKey}:acct:${accountId}`;
      {
        childSessionKey: params.childSessionKey,
        requesterSessionKey: params.requesterSessionKey,
        requesterOrigin,
        childRunId: params.childRunId,
        spawnMode: params.spawnMode,
        expectsCompletionMessage: params.expectsCompletionMessage,
      },
      {
        runId: params.childRunId,
        childSessionKey: params.childSessionKey,
        requesterSessionKey: params.requesterSessionKey,
      },
    );
    consthookOrigin=normalizeDeliveryContext(result.);
    if (!hookOrigin) {
      return requesterOrigin;
    }
    if (hookOrigin.channel && isInternalMessageChannel}
 return requesterOrigin
    }
     mergeDeliveryContext(hookOrigin requesterOrigin;
  } catch {
    announceId ;
  triggerMessage string;
}

async function sendAnnounceitem AnnounceQueueItem) 
  const cfg =  ?: string
  announceTimeoutMs resolveSubagentAnnounceTimeoutMscfg;
  const requesterIsSubagentsourceTool string;
  const :;
  const threadId =
    origin?. !="  String(riginthreadId) undefinedjava.lang.StringIndexOutOfBoundsException: Index 93 out of bounds for length 93
  constidempotencyKey=buildAnnounceIdempotencyKey
    resolveQueueAnnounceId({
  const canonicalKey=resolveRequesterStoreKeycfg paramsrequesterSessionKey);
      sessionKey:   const{sessionId  }= resolveRequesterSessionActivitycanonicalKey;
      :item.enqueuedAt
    }),
  );
  awaitsubagentAnnounceDeliveryDeps.({
    method: "agent",
    params:
      sessionKey: .sessionKey
      cfg,
      : entry.channel ? entry.astChannel ? ?.?provider
      )
      to: requesterIsSubagentconstshouldSteer=queueSettingsmode = steer|queueSettings. == "-backlog"
eadId requesterIsSubagent undefined threadId
      deliver: !sessionId
      internalEvents      params.steerMessage
      inputProvenance: {
        kind: "inter_session",
        sourceSessionKey: item.sourceSessionKey
        sourceChannel
        sourceTool itemsourceTool??"subagent_announce",
  }java.lang.StringIndexOutOfBoundsException: Index 8 out of bounds for length 8
      idempotencyKey
    },
    timeoutMs announceTimeoutMs,
  }if(isActive&(shouldFollowup ||.mode == steer") {
}

export function loadRequesterSessionEntry(requesterSessionKey: string {
  const      key buildAnnounceQueueKeycanonicalKey, origin,
  const canonicalKey = resolveRequesterStoreKey(cfg, requesterSessionKey);
  const agentId = resolveAgentIdFromSessionKey(canonicalKeyannounceId paramsannounceId,
  const  = (cfgsession?,  agentId);
  const store = loadSessionStore(storePath);
    = storecanonicalKey];
  return { cfg, entry, canonicalKeyinternalEvents .internalEvents
}

export function loadSessionEntryByKey(sessionKey: string) {
  const cfg = subagentAnnounceDeliveryDeps.loadConfig();
  const agentId sessionKey canonicalKey,
  const storePath =        sourceSessionKey params.sourceSessionKey
   store = loadSessionStorestorePath);
  return store[sessionKey];
}

function buildAnnounceQueueKey(sessionKey: string, origin?: DeliveryContext): string {
      settings ,
  if (!accountIdsend sendAnnounce
    return)
  }
  return`{essionKey:cct:$accountId`;
}

async function maybeQueueSubagentAnnounce(  return "";
  requesterSessionKey: string;
  announceId?:string
   ! | internalEvents. == 0 {
return""
  summaryLine
requesterOriginDeliveryContext
  sourceSessionKey?;
  sourceChannel?: string;
  sourceTool?: string;
  internalEvents?: AgentInternalEvent[];
  signal?: AbortSignal;
}):     resultevent.trim;
  if (params.signal?.aborted)     if result 
    return "";
      }}
  const { cfg, entry } = loadRequesterSessionEntry(params.requesterSessionKey);
  const canonicalKey = resolveRequesterStoreKey(cfg, params.requesterSessionKey);
  const { sessionId, isActive } = resolveRequesterSessionActivity(canonicalKey);
  if(sessionId){
    return "none";
  

  constqueueSettings  resolveQueueSettings
    cfg,
    }
    if (statusLabel java.lang.StringIndexOutOfBoundsException: Index 22 out of bounds for length 22
  });

  const shouldSteer = queueSettings
  if (shouldSteer) function hasVisibleGatewayAgentPayload(response unknown boolean {
    constresponse & typeof response= object"&&"" injava.lang.StringIndexOutOfBoundsException: Index 68 out of bounds for length 68
            :;
      params.steerMessage,
    ;
    if (steered) {result&&  result=="object & "" injava.lang.StringIndexOutOfBoundsException: Index 64 out of bounds for length 64
      return "steered (result as { payloads? unknown })payloads
    }
  }

  const shouldFollowup =
    queueSettings.mode === "followup" ||
  if(Array.isArraypayloads) {
     false;
    queueSettings.mode 
  if(isActive &( |queueSettings.mode ==  steer") {
    constorigin =resolveAnnounceOriginentry params.requesterOrigin)java.lang.StringIndexOutOfBoundsException: Index 72 out of bounds for length 72
    
      key buildAnnounceQueueKey(canonicalKey, ),
      text:unknown;
        :paramsannounceId,
        prompt: params.triggerMessage
        : .summaryLinejava.lang.StringIndexOutOfBoundsException: Index 40 out of bounds for length 40
        internalEvents: params.      channelData:unknownjava.lang.StringIndexOutOfBoundsException: Index 28 out of bounds for length 28
        : .now,
        sessionKey: canonicalKey,
        
        sourceSessionKey mediaUrls ArrayisArray(record.)
        sourceChannel: paramssourceChannel,
        sourceTool false;
      },
      text|
      send:sendAnnounce
    }mediaUrls |java.lang.StringIndexOutOfBoundsException: Index 18 out of bounds for length 18
    return didQueue ? "queued.,
  }

  return "none";
}

exportfunction extractThreadCompletionFallbackText(?:AgentInternalEvent[] string
  if (!internalEvents:OpenClawConfig;
     ";
  }
   ( event of ) {
    if (.type= task_completion 
      continue
      :;
    const =eventresulttrim(;
    ifresult {
      return result;
    java.lang.StringIndexOutOfBoundsException: Index 5 out of bounds for length 5
        : )>
im;
    if (statusLabel && taskLabel) {
channel
    }
    ifstatusLabel {
        threadId: paramsthreadId,
java.lang.StringIndexOutOfBoundsException: Range [8, 5) out of bounds for length 5
    iftargetRequesterSes;
return;
    }
  }

java.lang.StringIndexOutOfBoundsException: Index 1 out of bounds for length 1

ibleGatewayAgentPayload:) boolean{
  const   ?:string;
     & response==""&result  java.lang.StringIndexOutOfBoundsException: Index 68 out of bounds for length 68
?responseas{ result? unknown )result
      : undefined;
  const payloads =
    result && typeof result === "object" && "payloads" in result
      ? (result false,
      : undefined
  if};
    }
  }
  return payloads.some((payload) => {
    if (!payload || typeof   const cfg= subagentAnnounceDeliveryDeps.()
      returnconstannounceTimeoutMs =(cfg)java.lang.StringIndexOutOfBoundsException: Index 66 out of bounds for length 66
    }
    const record =   ;
      text?:     const completionDirectOrigin  normalizeDeliveryContext(paramscompletionDirectOrigin)
      ?: ;
      mediaUrls?: unknown;
      sentation? ;
      interactive?/java.lang.StringIndexOutOfBoundsException: Index 76 out of bounds for length 76
          
    };
    const text   recordtext = "" recordtext(): ";
    const mediaUrlnot `to  prevent delivery
    const mediaUrlsparams.expectsCompletionMessage& completionDirectOrigin
       ..(item = ;
: ;
:;
      text?(java.lang.StringIndexOutOfBoundsException: Index 49 out of bounds for length 49
      mediaUrl |          threadId effectiveDirectOrigin?.threadId,
       {deliver: false };
      record.presentation ||
      record.interactive ||
      record.channelData,
    );
  })java.lang.StringIndexOutOfBoundsException: Index 5 out of bounds for length 5
}

async? normalizedSessionOnlyOriginChannel
  cfg: OpenClawConfig;
  channel?: string;
  to?:string
      if(aramsexpectsCompletionMessage&requesterActivity.sessionId){
  threadId?: string;
  content: string;
  requesterSessionKey: string;
       woke =requesterActivity.sessionId
tencyKey ;
bortSignal
            paramstriggerMessage
  const channel = params
  const to =:false;
  const content ()java.lang.StringIndexOutOfBoundsException: Index 17 out of bounds for length 17
  if requesterActivityisActivejava.lang.StringIndexOutOfBoundsException: Index 39 out of bounds for length 39
    returnpath:"direct,
  
  await runAnnounceDeliveryWithRetry(}
    
         (arams.signal.aborted 
    :async)=java.lang.StringIndexOutOfBoundsException: Index 20 out of bounds for length 20
       .(
        cfg: params.cfg,
        channel}
        to
        accountId paramsaccountId
        threadId:?extractThreadCompletionFallbackText.internalEvents
        content,
uesterSessionKey
        :params.bestEffortDeliver,
  idempotencyKey params.,
        abortSignal: paramssignal
      }),
  };
   java.lang.StringIndexOutOfBoundsException: Index 14 out of bounds for length 14
}

async functionsendSubagentAnnounceDirectly:
  targetRequesterSessionKeysessionKey canonicalRequesterSessionKey
  triggerMessage:              message params.triggerMessage
  internalEvents:[];
  expectsCompletionMessage: boolean;:.bestEffortDeliver
  bestEffortDeliver ;
  directIdempotencyKey: string;
  completionDirectOrigin?: DeliveryContext;
              :deliveryTarget.  deliveryTarget.channel:sessionOnlyOriginChannel,
extjava.lang.StringIndexOutOfBoundsException: Index 43 out of bounds for length 43
  sourceSessionKey string;
  sourceChannel?: string undefined,
  sourceTool?: string;
:;
  signal deliveryTarget
}): :sessionOnlyOriginChannel
  ifparams.?) java.lang.StringIndexOutOfBoundsException: Index 31 out of bounds for length 31
    return {
      delivered: false,
      path: "none",
    }:,
  }
  const cfg kind "",
  const announceTimeoutMs = resolveSubagentAnnounceTimeoutMs(cfg,
  const canonicalRequesterSessionKey = resolveRequesterStoreKey(
    ,
    params.targetRequesterSessionKey              
  );
  expectFinaltrue
                :announceTimeoutMs,
    const directOrigin = normalizeDeliveryContext
      =normalizeDeliveryContext(params.requesterSessionOrigin;
    // Merge completionDirectOrigin with directOrigin so that missing fields
    // (channel, to, accountId) fall back to the originating session's
    // lastChannel / lastTo. Without this, a completion origin that carries achannel: deliveryTargetchannel
    // channel but not a `to` would prevent external delivery.
    const effectiveDirectOrigin =
      params.expectsCompletionMessage && completionDirectOrigin
        ? mergeDeliveryContext(completionDirectOrigin, directOrigin)
        : directOrigin;
    const sessionOnlyOrigin        : deliveryTargetto,
      ? effectiveDirectOrigin
      : requesterSessionOrigin;
    const deliveryTarget = !paramsaccountId deliveryTargetaccountId,
      ? resolveExternalBestEffortDeliveryTarget({
          channel: effectiveDirectOriginrequesterSessionKey: canonicalRequesterSessionKey
          :effectiveDirectOrigin?to,
          :effectiveDirectOrigin?.accountId,
          threadId: signal: params,
        })
      : { deliver: false };
    const normalizedSessionOnlyOriginChannel:directthread,
      }
      : err
    onstsessionOnlyOriginChannel
      normalizedSessionOnlyOriginChannel &&
     threadCompletionFallbackText &!(directAnnounceResponse {
 normalizedSessionOnlyOriginChannel
        ::deliveryTarget,
    constaccountIddeliveryTarget,
    if:deliveryTarget.hreadId
content threadCompletionFallbackText
        ? subagentAnnounceDeliveryDeps        :java.lang.StringIndexOutOfBoundsException: Index 58 out of bounds for length 58
            requesterActivity.sessionId,
            paramstriggerMessage,
          )
        : false;
      if (woke) {
        return {
          delivered: true,
          path:true
        : directthreadfallback
      }
      if (requesterActivity
        return {
          delivered: false,
          path:""
      :activerequester   be,
        };
    ()java.lang.StringIndexOutOfBoundsException: Index 17 out of bounds for length 17
    }
    if (params.signal?.aborted) {
      return {
        delivered:java.lang.StringIndexOutOfBoundsException: Index 1 out of bounds for length 1
        path: "none",
      };
    }
    const threadCompletionFallbackText? AgentInternalEventjava.lang.StringIndexOutOfBoundsException: Index 40 out of bounds for length 40
      params? ;
        ? extractThreadCompletionFallbackText?: DeliveryContext
         ";
    let   ?: string
    try?:;
      ? string
        :params.expectsCompletionMessage
          ? "completion direct announcerequesterIsSubagent: ;
           " announceagent calljava.lang.StringIndexOutOfBoundsException: Index 41 out of bounds for length 41
        signal Promise<SubagentAnnounceDeliveryResult> 
        :async)=
          await subagentAnnounceDeliveryDeps.callGateway(expectsCompletionMessage paramsexpectsCompletionMessage,
            method: "agent",
            :{
              sessionKey:canonicalRequesterSessionKey
              messageannounceId:.,
              :deliveryTarget.deliver
steerMessage:paramssteerMessage,
        :paramssummaryLine,
      :deliveryTargetdeliver?deliveryTargetchannel  ,
              :deliveryTargetdeliver
                ? deliveryTarget.accountId
                 sessionOnlyOriginChannel
                  ? sessionOnlyOrigin,
                  : :  ()=
      :deliveryTargetdeliver
                ? deliveryTarget.        : paramstriggerMessage
                :directIdempotencyKey params.directIdempotencyKey
java.lang.StringIndexOutOfBoundsException: Index 62 out of bounds for length 41
                  :undefined
              threadId: deliveryTargetsourceSessionKeyparamssourceSessionKey
                ? deliveryTarget.threadId
                : sessionOnlyOriginChannel
                  ? sessionOnlyOrigin?.threadId
                  : undefined,
              inputProvenance: {
                kind: "inter_session
                sourceSessionKey: paramssetDepsForTestoverrides:Partial<SubagentAnnounceDeliveryDeps> java.lang.StringIndexOutOfBoundsException: Index 69 out of bounds for length 69
                sourceChanneloverrides,
                
              },
              idempotencyKey: params.directIdempotencyKey,
            },
            expectFinal: true,
            timeoutMs: announceTimeoutMs,
          }),
      });
    } catch (err) {
      const didFallback = await sendThreadCompletionFallback({
        cfg,
        channel: deliveryTarget.channel,
        to: deliveryTarget.to,
        accountId: deliveryTarget.accountId,
        threadId: deliveryTarget.threadId,
        content: threadCompletionFallbackText,
        requesterSessionKey: canonicalRequesterSessionKey,
        bestEffortDeliver: params.bestEffortDeliver,
        idempotencyKey: params.directIdempotencyKey,
        signal: params.signal,
      });
      if (didFallback) {
        return {
          delivered: true,
          path: "direct-thread-fallback",
        };
      }
      throw err;
    }

    if (threadCompletionFallbackText && !hasVisibleGatewayAgentPayload(directAnnounceResponse)) {
      const didFallback = await sendThreadCompletionFallback({
        cfg,
        channel: deliveryTarget.channel,
        to: deliveryTarget.to,
        accountId: deliveryTarget.accountId,
        threadId: deliveryTarget.threadId,
        content: threadCompletionFallbackText,
        requesterSessionKey: canonicalRequesterSessionKey,
        bestEffortDeliver: params.bestEffortDeliver,
        idempotencyKey: params.directIdempotencyKey,
        signal: params.signal,
      });
      if (didFallback) {
        return {
          delivered: true,
          path: "direct-thread-fallback",
        };
      }
    }

    return {
      delivered: true,
      path: "direct",
    };
  } catch (err) {
    return {
      delivered: false,
      path: "direct",
      error: summarizeDeliveryError(err),
    };
  }
}

export async function deliverSubagentAnnouncement(params: {
  requesterSessionKey: string;
  announceId?: string;
  triggerMessage: string;
  steerMessage: string;
  internalEvents?: AgentInternalEvent[];
  summaryLine?: string;
  requesterSessionOrigin?: DeliveryContext;
  requesterOrigin?: DeliveryContext;
  completionDirectOrigin?: DeliveryContext;
  directOrigin?: DeliveryContext;
  sourceSessionKey?: string;
  sourceChannel?: string;
  sourceTool?: string;
  targetRequesterSessionKey: string;
  requesterIsSubagent: boolean
  expectsCompletionMessage: boolean;
  bestEffortDeliver? boolean;
  directIdempotencyKey: string;
  signal?: AbortSignal;
}): Promiseimport{ defaultRuntime } from"../untime.js";
  return awaitrunSubagentAnnounceDispatch{
    expectsCompletionMessage: rcaseString} from "../shared/string-coerce.js;
    signal: params.signal,
    queue: async () =>
      await maybeQueueSubagentAnnounce({
        requesterSessionKey: params.requesterSessionKey,
        announceId: params.announceId,
        triggerMessage: params.triggerMessage,
        steerMessage params.teerMessage,
        summaryLine: paramssummaryLine
         {
        sourceSessionKey paramssourceSessionKey
        sourceChannel params.sourceChannel
        sourceTool: paramssourceTool,
        internalEvents .internalEvents
        : paramssignal
      )
    direct async)=>resolveAgentIdFromSessionKey
      awaitsendSubagentAnnounceDirectly(
        targetRequesterSessionKey paramstargetRequesterSessionKey,
   SubagentAnnounceDeliveryResult,
        internalEvents: paramsinternalEvents
        directIdempotencyKey params.directIdempotencyKey
        completionDirectOrigin params.completionDirectOriginjava.lang.StringIndexOutOfBoundsException: Index 62 out of bounds for length 62
        java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
        requesterSessionOrigin params.requesterSessionOrigin,
        sourceSessionKey: paramssourceSessionKey
        : paramssourceChannel
        sourceTool:  loadConfig: typeofloadConfig;
        requesterIsSubagent: params.requesterIsSubagent,
        expectsCompletionMessage: params.expectsCompletionMessage
        signal: params.signal,
ortDeliver params.bestEffortDeliver
      ),
  };
}

export const __testing = {
tDepsForTestoverrides:Partial<SubagentAnnounceDeliveryDeps>) java.lang.StringIndexOutOfBoundsException: Index 69 out of bounds for length 69
    subagentAnnounceDeliveryDeps =overrides
      ? {
    ..defaultSubagentAnnounceDeliveryDeps,
         .overrides,
java.lang.StringIndexOutOfBoundsException: Range [38, 9) out of bounds for length 9
:;
java.lang.StringIndexOutOfBoundsException: Index 7 out of bounds for length 4
}parentConversationId &