File size: 5,627 Bytes
e249c6d | 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 126 127 128 129 130 131 132 133 134 135 | import type { CliDeps } from "../../cli/deps.types.js";
import { createLazyImportLoader } from "../../shared/lazy-promise.js";
import type { getRemoteSkillEligibility } from "../../skills/runtime/remote.js";
import type { resolveReusableWorkspaceSkillSnapshot } from "../../skills/runtime/session-snapshot.js";
type AttemptExecutionRuntime = typeof import("./attempt-execution.runtime.js");
export type AgentAttemptResult = Awaited<ReturnType<AttemptExecutionRuntime["runAgentAttempt"]>>;
type AcpManagerRuntime = typeof import("../../acp/control-plane/manager.js");
type AcpPolicyRuntime = typeof import("../../acp/policy.js");
type AcpRuntimeErrorsRuntime = typeof import("../../acp/runtime/errors.js");
type AcpSessionIdentifiersRuntime = typeof import("@openclaw/acp-core/runtime/session-identifiers");
type DeliveryRuntime = typeof import("./delivery.runtime.js");
type SessionStoreRuntime = typeof import("./session-store.runtime.js");
type CliCompactionRuntime = typeof import("./cli-compaction.js");
type AgentRunnerMemoryRuntime = typeof import("../../auto-reply/reply/agent-runner-memory.js");
type TranscriptResolveRuntime =
typeof import("../../config/sessions/transcript-resolve.runtime.js");
type TranscriptAppendRuntime = typeof import("../../config/sessions/transcript.runtime.js");
type CliDepsRuntime = typeof import("../../cli/deps.js");
type ExecDefaultsRuntime = typeof import("../exec-defaults.js");
type SkillsRuntime = {
getRemoteSkillEligibility: typeof getRemoteSkillEligibility;
resolveReusableWorkspaceSkillSnapshot: typeof resolveReusableWorkspaceSkillSnapshot;
};
const attemptExecutionRuntimeLoader = createLazyImportLoader<AttemptExecutionRuntime>(
() => import("./attempt-execution.runtime.js"),
);
const acpManagerRuntimeLoader = createLazyImportLoader<AcpManagerRuntime>(
() => import("../../acp/control-plane/manager.js"),
);
const acpPolicyRuntimeLoader = createLazyImportLoader<AcpPolicyRuntime>(
() => import("../../acp/policy.js"),
);
const acpRuntimeErrorsRuntimeLoader = createLazyImportLoader<AcpRuntimeErrorsRuntime>(
() => import("../../acp/runtime/errors.js"),
);
const acpSessionIdentifiersRuntimeLoader = createLazyImportLoader<AcpSessionIdentifiersRuntime>(
() => import("@openclaw/acp-core/runtime/session-identifiers"),
);
const deliveryRuntimeLoader = createLazyImportLoader<DeliveryRuntime>(
() => import("./delivery.runtime.js"),
);
const sessionStoreRuntimeLoader = createLazyImportLoader<SessionStoreRuntime>(
() => import("./session-store.runtime.js"),
);
const cliCompactionRuntimeLoader = createLazyImportLoader<CliCompactionRuntime>(
() => import("./cli-compaction.js"),
);
const agentRunnerMemoryRuntimeLoader = createLazyImportLoader<AgentRunnerMemoryRuntime>(
() => import("../../auto-reply/reply/agent-runner-memory.js"),
);
const transcriptResolveRuntimeLoader = createLazyImportLoader<TranscriptResolveRuntime>(
() => import("../../config/sessions/transcript-resolve.runtime.js"),
);
const transcriptAppendRuntimeLoader = createLazyImportLoader<TranscriptAppendRuntime>(
() => import("../../config/sessions/transcript.runtime.js"),
);
const cliDepsRuntimeLoader = createLazyImportLoader<CliDepsRuntime>(
() => import("../../cli/deps.js"),
);
const execDefaultsRuntimeLoader = createLazyImportLoader<ExecDefaultsRuntime>(
() => import("../exec-defaults.js"),
);
const skillsRuntimeLoader = createLazyImportLoader<SkillsRuntime>(async () => {
const [remote, sessionSnapshot] = await Promise.all([
import("../../skills/runtime/remote.js"),
import("../../skills/runtime/session-snapshot.js"),
]);
return {
getRemoteSkillEligibility: remote.getRemoteSkillEligibility,
resolveReusableWorkspaceSkillSnapshot: sessionSnapshot.resolveReusableWorkspaceSkillSnapshot,
};
});
export function loadAttemptExecutionRuntime(): Promise<AttemptExecutionRuntime> {
return attemptExecutionRuntimeLoader.load();
}
export function loadAcpManagerRuntime(): Promise<AcpManagerRuntime> {
return acpManagerRuntimeLoader.load();
}
export function loadAcpPolicyRuntime(): Promise<AcpPolicyRuntime> {
return acpPolicyRuntimeLoader.load();
}
export function loadAcpRuntimeErrorsRuntime(): Promise<AcpRuntimeErrorsRuntime> {
return acpRuntimeErrorsRuntimeLoader.load();
}
export function loadAcpSessionIdentifiersRuntime(): Promise<AcpSessionIdentifiersRuntime> {
return acpSessionIdentifiersRuntimeLoader.load();
}
export function loadDeliveryRuntime(): Promise<DeliveryRuntime> {
return deliveryRuntimeLoader.load();
}
export function loadSessionStoreRuntime(): Promise<SessionStoreRuntime> {
return sessionStoreRuntimeLoader.load();
}
export function loadCliCompactionRuntime(): Promise<CliCompactionRuntime> {
return cliCompactionRuntimeLoader.load();
}
export function loadAgentRunnerMemoryRuntime(): Promise<AgentRunnerMemoryRuntime> {
return agentRunnerMemoryRuntimeLoader.load();
}
export function loadTranscriptResolveRuntime(): Promise<TranscriptResolveRuntime> {
return transcriptResolveRuntimeLoader.load();
}
export function loadTranscriptAppendRuntime(): Promise<TranscriptAppendRuntime> {
return transcriptAppendRuntimeLoader.load();
}
export function loadExecDefaultsRuntime(): Promise<ExecDefaultsRuntime> {
return execDefaultsRuntimeLoader.load();
}
export function loadSkillsRuntime(): Promise<SkillsRuntime> {
return skillsRuntimeLoader.load();
}
export async function resolveAgentCommandDeps(deps: CliDeps | undefined): Promise<CliDeps> {
if (deps) {
return deps;
}
const { createDefaultDeps } = await cliDepsRuntimeLoader.load();
return createDefaultDeps();
}
|