diff --git a/packages/core/src/agents/a2aUtils.ts b/packages/core/src/agents/a2aUtils.ts index 311658118b..f1e66309d6 100644 --- a/packages/core/src/agents/a2aUtils.ts +++ b/packages/core/src/agents/a2aUtils.ts @@ -28,7 +28,7 @@ export function extractMessageText(message: Message | undefined): string { /** * Extracts text from a single Part. */ -export function extractPartText(part: Part): string { +function extractPartText(part: Part): string { if (isTextPart(part)) { return part.text; } diff --git a/packages/core/src/config/storage.ts b/packages/core/src/config/storage.ts index bd0fec1c8e..2d7f5d8c2a 100644 --- a/packages/core/src/config/storage.ts +++ b/packages/core/src/config/storage.ts @@ -8,11 +8,14 @@ import * as path from 'node:path'; import * as os from 'node:os'; import * as crypto from 'node:crypto'; import * as fs from 'node:fs'; -import { GEMINI_DIR, homedir } from '../utils/paths.js'; +import { + GEMINI_DIR, + homedir, + GOOGLE_ACCOUNTS_FILENAME, +} from '../utils/paths.js'; import { ProjectRegistry } from './projectRegistry.js'; import { StorageMigration } from './storageMigration.js'; -export const GOOGLE_ACCOUNTS_FILENAME = 'google_accounts.json'; export const OAUTH_FILE = 'oauth_creds.json'; const TMP_DIR_NAME = 'tmp'; const BIN_DIR_NAME = 'bin'; diff --git a/packages/core/src/ide/detect-ide.ts b/packages/core/src/ide/detect-ide.ts index 40aae11b7f..c07ef8254c 100644 --- a/packages/core/src/ide/detect-ide.ts +++ b/packages/core/src/ide/detect-ide.ts @@ -38,7 +38,7 @@ export function isCloudShell(): boolean { return !!(process.env['EDITOR_IN_CLOUD_SHELL'] || process.env['CLOUD_SHELL']); } -export function isJetBrains(): boolean { +function isJetBrains(): boolean { return !!process.env['TERMINAL_EMULATOR'] ?.toLowerCase() .includes('jetbrains'); diff --git a/packages/core/src/mcp/oauth-provider.ts b/packages/core/src/mcp/oauth-provider.ts index d0c8987d4a..95cec40f50 100644 --- a/packages/core/src/mcp/oauth-provider.ts +++ b/packages/core/src/mcp/oauth-provider.ts @@ -17,8 +17,6 @@ import { coreEvents } from '../utils/events.js'; import { debugLogger } from '../utils/debugLogger.js'; import { getConsentForOauth } from '../utils/authConsent.js'; -export const OAUTH_DISPLAY_MESSAGE_EVENT = 'oauth-display-message' as const; - /** * OAuth configuration for an MCP server. */ diff --git a/packages/core/src/scheduler/confirmation.ts b/packages/core/src/scheduler/confirmation.ts index 5d98dd526e..67ae26d2eb 100644 --- a/packages/core/src/scheduler/confirmation.ts +++ b/packages/core/src/scheduler/confirmation.ts @@ -59,7 +59,7 @@ export interface ResolutionResult { * @param correlationId The correlationId to match. * @param signal An AbortSignal to cancel the wait and cleanup listeners. */ -export async function awaitConfirmation( +async function awaitConfirmation( messageBus: MessageBus, correlationId: string, signal: AbortSignal, diff --git a/packages/core/src/services/chatCompressionService.ts b/packages/core/src/services/chatCompressionService.ts index 9878358966..44ffe90cf2 100644 --- a/packages/core/src/services/chatCompressionService.ts +++ b/packages/core/src/services/chatCompressionService.ts @@ -37,18 +37,18 @@ import { LlmRole } from '../telemetry/types.js'; * Default threshold for compression token count as a fraction of the model's * token limit. If the chat history exceeds this threshold, it will be compressed. */ -export const DEFAULT_COMPRESSION_TOKEN_THRESHOLD = 0.5; +const DEFAULT_COMPRESSION_TOKEN_THRESHOLD = 0.5; /** * The fraction of the latest chat history to keep. A value of 0.3 * means that only the last 30% of the chat history will be kept after compression. */ -export const COMPRESSION_PRESERVE_THRESHOLD = 0.3; +const COMPRESSION_PRESERVE_THRESHOLD = 0.3; /** * The budget for function response tokens in the preserved history. */ -export const COMPRESSION_FUNCTION_RESPONSE_TOKEN_BUDGET = 50_000; +const COMPRESSION_FUNCTION_RESPONSE_TOKEN_BUDGET = 50_000; /** * Returns the index of the oldest item to keep when compressing. May return diff --git a/packages/core/src/telemetry/loggers.ts b/packages/core/src/telemetry/loggers.ts index bbc47cfac8..54bec22a65 100644 --- a/packages/core/src/telemetry/loggers.ts +++ b/packages/core/src/telemetry/loggers.ts @@ -32,7 +32,6 @@ import type { ConversationFinishedEvent, ChatCompressionEvent, MalformedJsonResponseEvent, - InvalidChunkEvent, ContentRetryEvent, ContentRetryFailureEvent, RipgrepFallbackEvent, @@ -65,7 +64,6 @@ import { recordToolCallMetrics, recordChatCompressionMetrics, recordFileOperationMetric, - recordInvalidChunk, recordContentRetry, recordContentRetryFailure, recordModelRoutingMetrics, @@ -470,22 +468,6 @@ export function logMalformedJsonResponse( }); } -export function logInvalidChunk( - config: Config, - event: InvalidChunkEvent, -): void { - ClearcutLogger.getInstance(config)?.logInvalidChunkEvent(event); - bufferTelemetryEvent(() => { - const logger = logs.getLogger(SERVICE_NAME); - const logRecord: LogRecord = { - body: event.toLogBody(), - attributes: event.toOpenTelemetryAttributes(config), - }; - logger.emit(logRecord); - recordInvalidChunk(config); - }); -} - export function logContentRetry( config: Config, event: ContentRetryEvent, diff --git a/packages/core/src/telemetry/metrics.ts b/packages/core/src/telemetry/metrics.ts index 5d8dd90bd1..f7869cb980 100644 --- a/packages/core/src/telemetry/metrics.ts +++ b/packages/core/src/telemetry/metrics.ts @@ -617,7 +617,7 @@ let baselineComparisonHistogram: Histogram | undefined; let isMetricsInitialized = false; let isPerformanceMonitoringEnabled = false; -export function getMeter(): Meter | undefined { +function getMeter(): Meter | undefined { if (!cliMeter) { cliMeter = metrics.getMeter(SERVICE_NAME); } @@ -1019,7 +1019,7 @@ function getGenAiOperationName(): GenAiOperationName { // Performance Monitoring Functions -export function initializePerformanceMonitoring(config: Config): void { +function initializePerformanceMonitoring(config: Config): void { const meter = getMeter(); if (!meter) return; diff --git a/packages/core/src/telemetry/semantic.ts b/packages/core/src/telemetry/semantic.ts index 23623b5b3e..c05d110e9f 100644 --- a/packages/core/src/telemetry/semantic.ts +++ b/packages/core/src/telemetry/semantic.ts @@ -240,7 +240,7 @@ export function toChatMessage(content?: Content): ChatMessage { return message; } -export function toOTelPart(part: Part): AnyPart { +function toOTelPart(part: Part): AnyPart { if (part.thought) { if (part.text) { return new ReasoningPart(part.text); @@ -287,7 +287,7 @@ export enum OTelRole { TOOL = 'tool', } -export function toOTelRole(role?: string): OTelRole { +function toOTelRole(role?: string): OTelRole { switch (role?.toLowerCase()) { case 'system': return OTelRole.SYSTEM; @@ -322,7 +322,7 @@ export enum OTelFinishReason { ERROR = 'error', } -export function toOTelFinishReason(finishReason?: string): OTelFinishReason { +function toOTelFinishReason(finishReason?: string): OTelFinishReason { switch (finishReason) { // we have significantly more finish reasons than the spec case FinishReason.FINISH_REASON_UNSPECIFIED: @@ -376,7 +376,7 @@ export interface ChatMessage { parts: AnyPart[]; } -export class TextPart { +class TextPart { readonly type = 'text'; content: string; @@ -385,7 +385,7 @@ export class TextPart { } } -export class ToolCallRequestPart { +class ToolCallRequestPart { readonly type = 'tool_call'; name?: string; id?: string; @@ -398,7 +398,7 @@ export class ToolCallRequestPart { } } -export class ToolCallResponsePart { +class ToolCallResponsePart { readonly type = 'tool_call_response'; response?: string; id?: string; @@ -409,7 +409,7 @@ export class ToolCallResponsePart { } } -export class ReasoningPart { +class ReasoningPart { readonly type = 'reasoning'; content: string; @@ -418,7 +418,7 @@ export class ReasoningPart { } } -export class GenericPart { +class GenericPart { type: string; [key: string]: unknown; diff --git a/packages/core/src/utils/toolCallContext.ts b/packages/core/src/utils/toolCallContext.ts index c371d23783..e89d20ddef 100644 --- a/packages/core/src/utils/toolCallContext.ts +++ b/packages/core/src/utils/toolCallContext.ts @@ -21,7 +21,7 @@ export interface ToolCallContext { /** * AsyncLocalStorage instance for tool call context. */ -export const toolCallContext = new AsyncLocalStorage(); +const toolCallContext = new AsyncLocalStorage(); /** * Runs a function within a tool call context.