refactor: split delivery target runtime seams

shakkernerd · steipete · commit 24edb82eced9 · 2026-04-04T01:07:28.000+09:00
diff --git a/src/cron/isolated-agent/delivery-target.ts b/src/cron/isolated-agent/delivery-target.ts
@@ -41,6 +41,17 @@ async function loadTargetsRuntime() {
   return await targetsRuntimePromise;
 }
 
+async function resolveOutboundTargetWithRuntime(
+  params: Parameters<typeof tryResolveLoadedOutboundTarget>[0],
+) {
+  const loaded = tryResolveLoadedOutboundTarget(params);
+  if (loaded) {
+    return loaded;
+  }
+  const { resolveOutboundTarget } = await loadTargetsRuntime();
+  return resolveOutboundTarget(params);
+}
+
 let channelSelectionRuntimePromise:
   | Promise<typeof import("../../infra/outbound/channel-selection.runtime.js")>
   | undefined;
@@ -49,7 +60,6 @@ async function loadChannelSelectionRuntime() {
   channelSelectionRuntimePromise ??= import("../../infra/outbound/channel-selection.runtime.js");
   return await channelSelectionRuntimePromise;
 }
-
 export async function resolveDeliveryTarget(
   cfg: OpenClawConfig,
   agentId: string,
@@ -182,49 +192,27 @@ export async function resolveDeliveryTarget(
   const effectiveAllowFrom = mode === "implicit" ? allowFromOverride : undefined;
 
   if (toCandidate && mode === "implicit" && allowFromOverride.length > 0) {
-    let currentTargetResolution = tryResolveLoadedOutboundTarget({
+    const currentTargetResolution = await resolveOutboundTargetWithRuntime({
       channel,
       to: toCandidate,
       cfg,
       accountId,
       mode,
       allowFrom: effectiveAllowFrom,
     });
-    if (!currentTargetResolution) {
-      const { resolveOutboundTarget } = await loadTargetsRuntime();
-      currentTargetResolution = resolveOutboundTarget({
-        channel,
-        to: toCandidate,
-        cfg,
-        accountId,
-        mode,
-        allowFrom: effectiveAllowFrom,
-      });
-    }
     if (!currentTargetResolution.ok) {
       toCandidate = allowFromOverride[0];
     }
   }
 
-  let docked = tryResolveLoadedOutboundTarget({
+  const docked = await resolveOutboundTargetWithRuntime({
     channel,
     to: toCandidate,
     cfg,
     accountId,
     mode,
     allowFrom: effectiveAllowFrom,
   });
-  if (!docked) {
-    const { resolveOutboundTarget } = await loadTargetsRuntime();
-    docked = resolveOutboundTarget({
-      channel,
-      to: toCandidate,
-      cfg,
-      accountId,
-      mode,
-      allowFrom: effectiveAllowFrom,
-    });
-  }
   if (!docked.ok) {
     return {
       ok: false,
