diff --git a/src/commands/models/list.probe.ts b/src/commands/models/list.probe.ts index 71d52b9a95e..a458a49e5b9 100644 --- a/src/commands/models/list.probe.ts +++ b/src/commands/models/list.probe.ts @@ -673,17 +673,6 @@ export function formatProbeLatency(latencyMs?: number | null) { return formatMs(latencyMs); } -/** Groups probe results by provider. */ -export function groupProbeResults(results: AuthProbeResult[]): Map { - const map = new Map(); - for (const result of results) { - const list = map.get(result.provider) ?? []; - list.push(result); - map.set(result.provider, list); - } - return map; -} - /** Sorts probe results by provider and display label. */ export function sortProbeResults(results: AuthProbeResult[]): AuthProbeResult[] { return results.slice().toSorted((a, b) => { diff --git a/src/commands/models/shared.ts b/src/commands/models/shared.ts index 04a77a99091..4c927cfe87f 100644 --- a/src/commands/models/shared.ts +++ b/src/commands/models/shared.ts @@ -5,7 +5,6 @@ import { buildModelAliasIndex, legacyModelKey, modelKey, - parseModelRef, resolveModelRefFromString, } from "../../agents/model-selection.js"; import { formatCliCommand } from "../../cli/command-format.js"; @@ -147,20 +146,6 @@ export function resolveModelKeysFromEntries(params: { .map((entry) => modelKey(entry.ref.provider, entry.ref.model)); } -/** Builds the configured model allowlist from agents.defaults.models keys. */ -export function buildAllowlistSet(cfg: OpenClawConfig): Set { - const allowed = new Set(); - const models = cfg.agents?.defaults?.models ?? {}; - for (const raw of Object.keys(models)) { - const parsed = parseModelRef(raw, DEFAULT_PROVIDER); - if (!parsed) { - continue; - } - allowed.add(modelKey(parsed.provider, parsed.model)); - } - return allowed; -} - /** Validates an optional agent id against configured agents. */ export function resolveKnownAgentId(params: { cfg: OpenClawConfig; diff --git a/src/commitments/store-writer.ts b/src/commitments/store-writer.ts index 88247873256..e2fa5525a7a 100644 --- a/src/commitments/store-writer.ts +++ b/src/commitments/store-writer.ts @@ -6,7 +6,6 @@ import fs from "node:fs/promises"; import path from "node:path"; import { type FileLockOptions, withFileLock } from "../plugin-sdk/file-lock.js"; import { - clearStoreWriterQueuesForTest, runQueuedStoreWrite, type StoreWriterQueue, } from "../shared/store-writer-queue.js"; @@ -45,7 +44,3 @@ export async function runExclusiveCommitmentsStoreWrite( }, }); } - -export function clearCommitmentsStoreWriterQueuesForTest(): void { - clearStoreWriterQueuesForTest(WRITER_QUEUES, "commitments store writer queue cleared for test"); -} diff --git a/src/cron/isolated-agent.mocks.ts b/src/cron/isolated-agent.mocks.ts index ac9bac97c05..1388f5458b7 100644 --- a/src/cron/isolated-agent.mocks.ts +++ b/src/cron/isolated-agent.mocks.ts @@ -1,9 +1,5 @@ /** Shared Vitest module mocks for isolated-agent cron tests. */ import { vi } from "vitest"; -import { - makeIsolatedAgentJobFixture, - makeIsolatedAgentParamsFixture, -} from "./isolated-agent/job-fixtures.js"; vi.mock("../agents/embedded-agent.js", () => ({ abortEmbeddedAgentRun: vi.fn().mockReturnValue(false), @@ -36,6 +32,3 @@ vi.mock("../plugins/runtime-plugins.runtime.js", () => ({ vi.mock("../gateway/call.js", () => ({ callGateway: vi.fn(), })); - -export const makeIsolatedAgentJob = makeIsolatedAgentJobFixture; -export const makeIsolatedAgentParams = makeIsolatedAgentParamsFixture; diff --git a/src/gateway/session-reset-service.ts b/src/gateway/session-reset-service.ts index 3c683632e3b..4a057c32e41 100644 --- a/src/gateway/session-reset-service.ts +++ b/src/gateway/session-reset-service.ts @@ -127,17 +127,6 @@ function stripRuntimeModelState(entry?: SessionEntry): SessionEntry | undefined }; } -export function archiveSessionTranscriptsForSession(params: { - sessionId: string | undefined; - storePath: string; - sessionFile?: string; - agentId?: string; - reason: "reset" | "deleted"; - onArchiveError?: (err: unknown, sourcePath: string) => void; -}): string[] { - return archiveSessionTranscriptsForSessionDetailed(params).map((entry) => entry.archivedPath); -} - export function archiveSessionTranscriptsForSessionDetailed(params: { sessionId: string | undefined; storePath: string; diff --git a/src/gateway/talk-session-registry.ts b/src/gateway/talk-session-registry.ts index 964ab55bc0c..a8b5b9f81b0 100644 --- a/src/gateway/talk-session-registry.ts +++ b/src/gateway/talk-session-registry.ts @@ -54,8 +54,3 @@ export function requireUnifiedTalkSessionConn( } return connId; } - -/** Clears process-local Talk session mappings between tests. */ -export function clearUnifiedTalkSessionsForTest(): void { - unifiedTalkSessions.clear(); -} diff --git a/src/infra/json-file.ts b/src/infra/json-file.ts index 839368b6354..dd76dcd843e 100644 --- a/src/infra/json-file.ts +++ b/src/infra/json-file.ts @@ -36,31 +36,6 @@ export function saveJsonFile(pathname: string, data: unknown): void { writeJsonSync(resolveJsonSaveTarget(pathname), data); } -export function repairJsonFilePermissions(pathname: string): void { - const target = resolveJsonSaveTarget(pathname); - let fd: number | undefined; - try { - fd = fs.openSync( - target, - fs.constants.O_RDONLY | - (process.platform !== "win32" && "O_NOFOLLOW" in fs.constants - ? fs.constants.O_NOFOLLOW - : 0), - ); - fs.fchmodSync(fd, 0o600); - } catch { - // Matches fs-safe JSON writes: permission repair is best-effort. - } finally { - if (fd !== undefined) { - try { - fs.closeSync(fd); - } catch { - // best-effort cleanup - } - } - } -} - // oxlint-disable-next-line typescript-eslint/no-unnecessary-type-parameters -- legacy typed JSON loader alias. export function loadJsonFile(pathname: string): T | undefined { const direct = tryReadJsonSync(pathname); diff --git a/src/state/openclaw-agent-db.paths.ts b/src/state/openclaw-agent-db.paths.ts index 638434edb49..6dbe79ba39e 100644 --- a/src/state/openclaw-agent-db.paths.ts +++ b/src/state/openclaw-agent-db.paths.ts @@ -30,8 +30,3 @@ export function resolveOpenClawAgentSqlitePath(options: OpenClawAgentSqlitePathO ), ); } - -/** Resolve the containing directory for one agent's SQLite database. */ -export function resolveOpenClawAgentSqliteDir(options: OpenClawAgentSqlitePathOptions): string { - return path.dirname(resolveOpenClawAgentSqlitePath(options)); -}