From 322139c84ee9aa4fc191e701873bf8190fb769c2 Mon Sep 17 00:00:00 2001 From: Peter Steinberger Date: Sat, 2 May 2026 01:18:53 +0100 Subject: [PATCH] refactor: trim agent local helper exports --- src/agents/anthropic-payload-log.ts | 2 +- src/agents/anthropic-vertex-stream.ts | 12 ------------ src/agents/compaction-real-conversation.ts | 2 +- src/agents/identity-file.ts | 2 +- src/agents/internal-runtime-context.ts | 2 +- src/agents/provider-request-config.ts | 2 +- src/agents/spawn-requester-origin.ts | 2 +- src/agents/subagent-run-liveness.ts | 2 +- src/agents/tool-description-summary.ts | 2 +- 9 files changed, 8 insertions(+), 20 deletions(-) diff --git a/src/agents/anthropic-payload-log.ts b/src/agents/anthropic-payload-log.ts index ed060e4804a..6a1669598cb 100644 --- a/src/agents/anthropic-payload-log.ts +++ b/src/agents/anthropic-payload-log.ts @@ -89,7 +89,7 @@ function findLastAssistantUsage(messages: AgentMessage[]): Record StreamFn; recordUsage: (messages: AgentMessage[], error?: unknown) => void; diff --git a/src/agents/anthropic-vertex-stream.ts b/src/agents/anthropic-vertex-stream.ts index a9e616c97d8..cd0a1c202fc 100644 --- a/src/agents/anthropic-vertex-stream.ts +++ b/src/agents/anthropic-vertex-stream.ts @@ -20,18 +20,6 @@ function loadAnthropicVertexStreamFacade(): AnthropicVertexStreamFacade { }); } -export function createAnthropicVertexStreamFn( - projectId: string | undefined, - region: string, - baseURL?: string, -): StreamFn { - return loadAnthropicVertexStreamFacade().createAnthropicVertexStreamFn( - projectId, - region, - baseURL, - ); -} - export function createAnthropicVertexStreamFnForModel( model: { baseUrl?: string }, env: NodeJS.ProcessEnv = process.env, diff --git a/src/agents/compaction-real-conversation.ts b/src/agents/compaction-real-conversation.ts index 66d617cd9c8..969c2262042 100644 --- a/src/agents/compaction-real-conversation.ts +++ b/src/agents/compaction-real-conversation.ts @@ -2,7 +2,7 @@ import type { AgentMessage } from "@mariozechner/pi-agent-core"; import { stripHeartbeatToken } from "../auto-reply/heartbeat.js"; import { isSilentReplyText } from "../auto-reply/tokens.js"; -export const TOOL_RESULT_REAL_CONVERSATION_LOOKBACK = 20; +const TOOL_RESULT_REAL_CONVERSATION_LOOKBACK = 20; const NON_CONVERSATION_BLOCK_TYPES = new Set([ "toolCall", "toolUse", diff --git a/src/agents/identity-file.ts b/src/agents/identity-file.ts index f06054f6e04..bcccd12e502 100644 --- a/src/agents/identity-file.ts +++ b/src/agents/identity-file.ts @@ -181,7 +181,7 @@ export function mergeIdentityMarkdownContent( return nextLines.join("\n").replace(/\n*$/, "\n"); } -export function loadIdentityFromFile(identityPath: string): AgentIdentityFile | null { +function loadIdentityFromFile(identityPath: string): AgentIdentityFile | null { try { const content = fs.readFileSync(identityPath, "utf-8"); const parsed = parseIdentityMarkdown(content); diff --git a/src/agents/internal-runtime-context.ts b/src/agents/internal-runtime-context.ts index 52d5e73242c..377de8e79b0 100644 --- a/src/agents/internal-runtime-context.ts +++ b/src/agents/internal-runtime-context.ts @@ -221,7 +221,7 @@ export function hasInternalRuntimeContext(text: string): boolean { ); } -export function isOpenClawRuntimeContextCustomMessage(message: unknown): boolean { +function isOpenClawRuntimeContextCustomMessage(message: unknown): boolean { if (!message || typeof message !== "object") { return false; } diff --git a/src/agents/provider-request-config.ts b/src/agents/provider-request-config.ts index ac9997aa0cd..b8c4371ebda 100644 --- a/src/agents/provider-request-config.ts +++ b/src/agents/provider-request-config.ts @@ -400,7 +400,7 @@ export function normalizeBaseUrl( return raw.replace(/\/+$/, ""); } -export function mergeProviderRequestHeaders( +function mergeProviderRequestHeaders( ...headerSets: Array | undefined> ): Record | undefined { let merged: Record | undefined; diff --git a/src/agents/spawn-requester-origin.ts b/src/agents/spawn-requester-origin.ts index 1fe3dc92824..a8bce9d5809 100644 --- a/src/agents/spawn-requester-origin.ts +++ b/src/agents/spawn-requester-origin.ts @@ -50,7 +50,7 @@ function inferPeerKindFromBareId(value: string): ChatType | undefined { return undefined; } -export function extractRequesterPeer( +function extractRequesterPeer( channelId: string | undefined, requesterTo: string | undefined, ): { peerId?: string; peerKind?: ChatType } { diff --git a/src/agents/subagent-run-liveness.ts b/src/agents/subagent-run-liveness.ts index 2243472eb98..df70d55b0e0 100644 --- a/src/agents/subagent-run-liveness.ts +++ b/src/agents/subagent-run-liveness.ts @@ -54,7 +54,7 @@ export function isLiveUnendedSubagentRun( return !hasSubagentRunEnded(entry) && !isStaleUnendedSubagentRun(entry, now); } -export function isRecentlyEndedSubagentRun( +function isRecentlyEndedSubagentRun( entry: Pick, now = Date.now(), recentMs = RECENT_ENDED_SUBAGENT_CHILD_SESSION_MS, diff --git a/src/agents/tool-description-summary.ts b/src/agents/tool-description-summary.ts index 1c0b6b74a15..5f828743660 100644 --- a/src/agents/tool-description-summary.ts +++ b/src/agents/tool-description-summary.ts @@ -14,7 +14,7 @@ function truncateSummary(value: string, maxLen = 120): string { return `${trimmed}...`; } -export function isToolDocBlockStart(line: string): boolean { +function isToolDocBlockStart(line: string): boolean { const normalized = line.trim().toUpperCase(); if (!normalized) { return false;