refactor(runtime): remove unused helper exports

vincentkoc · vincentkoc · commit 2e27a37791c9 · 2026-06-17T20:31:20.000+08:00
diff --git a/src/infra/bonjour-discovery.ts b/src/infra/bonjour-discovery.ts
@@ -62,14 +62,6 @@ export function resolveGatewayDiscoveryEndpoint(
   };
 }
 
-export function pickResolvedGatewayHost(beacon: GatewayBonjourBeacon): string | null {
-  return resolveGatewayDiscoveryEndpoint(beacon)?.host ?? null;
-}
-
-export function pickResolvedGatewayPort(beacon: GatewayBonjourBeacon): number | null {
-  return resolveGatewayDiscoveryEndpoint(beacon)?.port ?? null;
-}
-
 type GatewayBonjourDiscoverOpts = {
   timeoutMs?: number;
   domains?: string[];
diff --git a/src/llm/utils/overflow.ts b/src/llm/utils/overflow.ts
@@ -150,10 +150,3 @@ export function isContextOverflow(message: AssistantMessage, contextWindow?: num
 
   return false;
 }
-
-/**
- * Get the overflow patterns for testing purposes.
- */
-export function getOverflowPatterns(): RegExp[] {
-  return [...OVERFLOW_PATTERNS];
-}
diff --git a/src/shared/chat-message-content.ts b/src/shared/chat-message-content.ts
@@ -54,18 +54,6 @@ export function parseAssistantTextSignature(
   }
 }
 
-/** Encodes versioned assistant text metadata stored alongside streamed text blocks. */
-export function encodeAssistantTextSignature(params: {
-  id: string;
-  phase?: AssistantPhase;
-}): string {
-  return JSON.stringify({
-    v: 1,
-    id: params.id,
-    ...(params.phase ? { phase: params.phase } : {}),
-  });
-}
-
 /** Resolves a message phase only when the top-level phase or all explicit blocks agree. */
 export function resolveAssistantMessagePhase(message: unknown): AssistantPhase | undefined {
   if (!message || typeof message !== "object") {
diff --git a/src/skills/loading/workspace.ts b/src/skills/loading/workspace.ts
@@ -256,10 +256,6 @@ function resolveSkillsLimits(config?: OpenClawConfig, agentId?: string): Resolve
   };
 }
 
-export function resolveSkillRootScanLimit(config?: OpenClawConfig): number {
-  return config?.skills?.limits?.maxCandidatesPerRoot ?? DEFAULT_MAX_CANDIDATES_PER_ROOT;
-}
-
 function listChildDirectories(
   dir: string,
   opts?: {
@@ -1698,13 +1694,6 @@ export async function syncSkillsToWorkspace(params: {
   });
 }
 
-export function filterWorkspaceSkillEntries(
-  entries: SkillEntry[],
-  config?: OpenClawConfig,
-): SkillEntry[] {
-  return filterSkillEntries(entries, config);
-}
-
 export function filterWorkspaceSkillEntriesWithOptions(
   entries: SkillEntry[],
   opts?: {
diff --git a/src/tasks/task-executor.ts b/src/tasks/task-executor.ts
@@ -15,7 +15,6 @@ import {
   isParentFlowLinkError,
   linkTaskToFlowById,
   listTasksForFlowId,
-  markTaskLostById,
   markTaskRunningByRunId,
   finalizeTaskRunByRunId as finalizeTaskRunByRunIdInRegistry,
   recordTaskProgressByRunId,
@@ -207,16 +206,6 @@ export function failTaskRunByRunId(params: {
   });
 }
 
-export function markTaskRunLostById(params: {
-  taskId: string;
-  endedAt: number;
-  lastEventAt?: number;
-  error?: string;
-  cleanupAfter?: number;
-}) {
-  return markTaskLostById(params);
-}
-
 export function setDetachedTaskDeliveryStatusByRunId(params: {
   runId: string;
   runtime?: TaskRuntime;
@@ -362,15 +351,6 @@ export function retryBlockedFlowAsQueuedTaskRun(
   });
 }
 
-export function retryBlockedFlowAsRunningTaskRun(
-  params: Omit<RetryBlockedFlowParams, "status">,
-): RetryBlockedFlowResult {
-  return retryBlockedFlowTask({
-    ...params,
-    status: "running",
-  });
-}
-
 type CancelFlowResult = {
   found: boolean;
   cancelled: boolean;
diff --git a/src/tasks/task-registry.maintenance.ts b/src/tasks/task-registry.maintenance.ts
@@ -1253,8 +1253,3 @@ export function configureTaskRegistryMaintenance(options: {
     configuredRuntimeAuthoritative = options.runtimeAuthoritative;
   }
 }
-
-export function getReconciledTaskById(taskId: string): TaskRecord | undefined {
-  const task = getTaskById(taskId);
-  return task ? reconcileTaskRecordForOperatorInspection(task) : undefined;
-}
diff --git a/src/tasks/task-registry.ts b/src/tasks/task-registry.ts
@@ -2283,11 +2283,6 @@ function listTasksFromIndex(index: Map<string, Set<string>>, key: string): TaskR
     .map(({ insertionIndex: _, ...task }) => task);
 }
 
-export function findLatestTaskForSessionKey(sessionKey: string): TaskRecord | undefined {
-  const task = listTasksForSessionKey(sessionKey)[0];
-  return task ? cloneTaskRecord(task) : undefined;
-}
-
 export function listTasksForSessionKey(sessionKey: string): TaskRecord[] {
   ensureTaskRegistryReady();
   const key = normalizeOptionalString(sessionKey);

Original file line number	Diff line number	Diff line change
`@@ -1253,8 +1253,3 @@ export function configureTaskRegistryMaintenance(options: {`
`1253`	`1253`	`configuredRuntimeAuthoritative = options.runtimeAuthoritative;`
`1254`	`1254`	`}`
`1255`	`1255`	`}`
`1256`		`-`
`1257`		`-export function getReconciledTaskById(taskId: string): TaskRecord \| undefined {`
`1258`		`- const task = getTaskById(taskId);`
`1259`		`- return task ? reconcileTaskRecordForOperatorInspection(task) : undefined;`
`1260`		`-}`