diff --git a/src/auto-reply/reply/agent-runner.ts b/src/auto-reply/reply/agent-runner.ts index 7c9a853a0..31c3a434b 100644 --- a/src/auto-reply/reply/agent-runner.ts +++ b/src/auto-reply/reply/agent-runner.ts @@ -318,7 +318,7 @@ export async function runReplyAgent(params: { // Create status update controller for this agent run const agentId = resolveAgentIdFromSessionKey(sessionKey); - log.info(`Setting up status updates for agentId=${agentId}, channel=${replyToChannel}`); + log.debug(`Setting up status updates for agentId=${agentId}, channel=${replyToChannel}`); // Create callbacks using onBlockReply if available // NOTE: Edit mode requires channel-specific edit APIs which aren't available @@ -357,7 +357,7 @@ export async function runReplyAgent(params: { }); const statusUpdateContext = createStatusUpdateRunContext(statusController); - log.info( + log.debug( `Status update context created, controller=${statusController ? "present" : "undefined"}`, ); @@ -588,7 +588,7 @@ export async function runReplyAgent(params: { if (statusUpdateContext && replyPayloads.length > 0) { const lastPayload = replyPayloads[replyPayloads.length - 1]; if (lastPayload?.text) { - log.info(`[agent-runner] Completing status update with final text (fast-path)`); + log.debug(`[agent-runner] Completing status update with final text (fast-path)`); const markedText = await completeStatusUpdate(statusUpdateContext, lastPayload.text); if (markedText) { // Just update the text. The delivery layer handles replacement. @@ -612,7 +612,7 @@ export async function runReplyAgent(params: { removeEventListener(); } if (statusUpdateContext) { - log.info(`Cleaning up status update context`); + log.debug(`Cleaning up status update context`); await cleanupStatusUpdate(statusUpdateContext); } // ===== END STATUS UPDATES ===== diff --git a/src/auto-reply/reply/status-updates-integration.ts b/src/auto-reply/reply/status-updates-integration.ts index b10c8d9bd..34ee4dc73 100644 --- a/src/auto-reply/reply/status-updates-integration.ts +++ b/src/auto-reply/reply/status-updates-integration.ts @@ -59,20 +59,20 @@ export function createAgentStatusController(params: { callbacks: StatusUpdateCallbacks; }): StatusUpdateController | undefined { const { cfg, agentId, callbacks } = params; - log.info(`createAgentStatusController called for agentId=${agentId}`); + log.debug(`createAgentStatusController called for agentId=${agentId}`); const config = resolveStatusUpdateConfigFromConfig(cfg, agentId); if (!config.enabled) { - log.info(`Status updates disabled (enabled=${config.enabled})`); + log.debug(`Status updates disabled (enabled=${config.enabled})`); return undefined; } - log.info( + log.debug( `Creating status update controller with mode=${config.mode}, supportsEdit=${callbacks.supportsEdit?.()}`, ); const controller = createStatusUpdateController(config, callbacks); - log.info(`Status update controller created successfully`); + log.debug(`Status update controller created successfully`); return controller; } @@ -121,7 +121,7 @@ export type StatusUpdateRunContext = { export function createStatusUpdateRunContext( controller?: StatusUpdateController, ): StatusUpdateRunContext { - log.info(`createStatusUpdateRunContext: controller=${controller ? "present" : "undefined"}`); + log.debug(`createStatusUpdateRunContext: controller=${controller ? "present" : "undefined"}`); const ctx = { controller, @@ -130,13 +130,13 @@ export function createStatusUpdateRunContext( }; if (controller) { - log.info(`Status update context created with controller, starting...`); + log.debug(`Status update context created with controller, starting...`); // Start the controller asynchronously controller.start().catch((err) => { log.debug(`Failed to start status controller: ${String(err)}`); }); } else { - log.info(`Status update context created WITHOUT controller (status updates disabled)`); + log.debug(`Status update context created WITHOUT controller (status updates disabled)`); } return ctx; @@ -160,7 +160,7 @@ export async function handleAgentEventForStatus( ); if (phase && phase !== ctx.currentPhase) { - log.info(`Status phase change: ${ctx.currentPhase} -> ${phase}`); + log.debug(`Status phase change: ${ctx.currentPhase} -> ${phase}`); ctx.currentPhase = phase; await ctx.controller.setPhase(phase); } @@ -178,7 +178,7 @@ export async function completeStatusUpdate( return finalText; } - log.info(`completeStatusUpdate: finalizing status update`); + log.debug(`completeStatusUpdate: finalizing status update`); const result = await ctx.controller.complete(finalText); log.debug(`completeStatusUpdate: result=${result?.substring(0, 50)}...`); return result;