clean logs

Author: ctate

app/api/tasks/[taskId]/files/route.ts

@@ -104,7 +104,7 @@ export async function GET(request: NextRequest, { params }: { params: Promise<{
       } catch (branchError: unknown) {
         if (branchError && typeof branchError === 'object' && 'status' in branchError && branchError.status === 404) {
           // Branch doesn't exist yet (task is still processing)
-          console.log(`Branch ${task.branchName} doesn't exist yet, returning empty file list`)
+          console.log('Branch does not exist yet, returning empty file list')
           return NextResponse.json({
             success: true,
             files: [],
@@ -144,7 +144,7 @@ export async function GET(request: NextRequest, { params }: { params: Promise<{
               masterError.status === 404
             ) {
               // Neither main nor master exists, or head branch doesn't exist
-              console.log(`Could not compare branches for ${task.branchName}`)
+              console.log('Could not compare branches')
               return NextResponse.json({
                 success: true,
                 files: [],
@@ -171,7 +171,7 @@ export async function GET(request: NextRequest, { params }: { params: Promise<{
           changes: file.changes || 0,
         })) || []
 
-      console.log(`Found ${files.length} changed files in branch ${task.branchName}`)
+      console.log('Found changed files in branch')
     } catch (error: unknown) {
       console.error('Error fetching file changes from GitHub:', error)
 

app/api/tasks/[taskId]/route.ts

@@ -89,7 +89,7 @@ export async function PATCH(request: NextRequest, { params }: RouteParams) {
           if (killResult.success) {
             await logger.success('Sandbox killed successfully')
           } else {
-            await logger.error(`Failed to kill sandbox: ${killResult.error}`)
+            await logger.error('Failed to kill sandbox')
           }
         } catch (killError) {
           console.error('Failed to kill sandbox during stop:', killError)

app/api/tasks/route.ts

@@ -122,7 +122,7 @@ export async function POST(request: NextRequest) {
           })
           .where(eq(tasks.id, taskId))
 
-        await logger.success(`Generated AI branch name: ${aiBranchName}`)
+        await logger.success('Generated AI branch name')
       } catch (error) {
         console.error('Error generating AI branch name:', error)
 
@@ -139,7 +139,7 @@ export async function POST(request: NextRequest) {
             .where(eq(tasks.id, taskId))
 
           const logger = createTaskLogger(taskId)
-          await logger.info(`Using fallback branch name: ${fallbackBranchName}`)
+          await logger.info('Using fallback branch name')
         } catch (dbError) {
           console.error('Error updating task with fallback branch name:', dbError)
         }
@@ -278,7 +278,7 @@ async function processTask(
   const taskStartTime = Date.now()
 
   try {
-    console.log(`[TASK ${taskId}] Starting task processing at ${new Date().toISOString()}`)
+    console.log('Starting task processing')
 
     // Update task status to processing with real-time logging
     await logger.updateStatus('processing', 'Task created, preparing to start...')
@@ -310,13 +310,13 @@ async function processTask(
     }
 
     if (aiBranchName) {
-      await logger.info(`Using AI-generated branch name: ${aiBranchName}`)
+      await logger.info('Using AI-generated branch name')
     } else {
       await logger.info('AI branch name not ready, will use fallback during sandbox creation')
     }
 
-    await logger.updateProgress(15, 'Creating sandbox environment...')
-    console.log(`[TASK ${taskId}] Creating sandbox at ${new Date().toISOString()}`)
+    await logger.updateProgress(15, 'Creating sandbox environment')
+    console.log('Creating sandbox')
 
     // Create sandbox with progress callback and 5-minute timeout
     const sandboxResult = await createSandbox(
@@ -371,7 +371,7 @@ async function processTask(
 
     const { sandbox: createdSandbox, domain, branchName } = sandboxResult
     sandbox = createdSandbox || null
-    console.log(`[TASK ${taskId}] Sandbox created successfully at ${new Date().toISOString()}`)
+    console.log('Sandbox created successfully')
 
     // Update sandbox URL and branch name (only update branch name if not already set by AI)
     const updateData: { sandboxUrl?: string; updatedAt: Date; branchName?: string } = {
@@ -393,8 +393,8 @@ async function processTask(
     }
 
     // Log agent execution start
-    await logger.updateProgress(50, `Installing and executing ${selectedAgent} agent...`)
-    console.log(`[TASK ${taskId}] Starting ${selectedAgent} agent execution at ${new Date().toISOString()}`)
+    await logger.updateProgress(50, 'Installing and executing agent')
+    console.log('Starting agent execution')
 
     // Execute selected agent with timeout (different timeouts per agent)
     const getAgentTimeout = (agent: string) => {
@@ -447,9 +447,7 @@ async function processTask(
         })
 
         if (mcpServers.length > 0) {
-          await logger.info(
-            `Found ${mcpServers.length} connected MCP servers: ${mcpServers.map((s) => s.name).join(', ')}`,
-          )
+          await logger.info('Found connected MCP servers')
 
           // Store MCP server IDs in the task
           await db
@@ -484,15 +482,15 @@ async function processTask(
       agentTimeoutPromise,
     ])
 
-    console.log(`[TASK ${taskId}] Agent execution completed at ${new Date().toISOString()}`)
+    console.log('Agent execution completed')
 
     if (agentResult.success) {
       // Log agent completion
-      await logger.success(`${selectedAgent} agent execution completed`)
-      await logger.info(agentResult.output || 'Code changes applied successfully')
+      await logger.success('Agent execution completed')
+      await logger.info('Code changes applied successfully')
 
       if (agentResult.agentResponse) {
-        await logger.info(`Agent Response: ${agentResult.agentResponse}`)
+        await logger.info('Agent response received')
       }
 
       // Agent execution logs are already logged in real-time by the agent
@@ -508,7 +506,7 @@ async function processTask(
       if (shutdownResult.success) {
         await logger.success('Sandbox shutdown completed')
       } else {
-        await logger.error(`Sandbox shutdown failed: ${shutdownResult.error}`)
+        await logger.error('Sandbox shutdown failed')
       }
 
       // Check if push failed and handle accordingly
@@ -521,14 +519,11 @@ async function processTask(
         await logger.updateStatus('completed')
         await logger.updateProgress(100, 'Task completed successfully')
 
-        const totalTaskTime = ((Date.now() - taskStartTime) / 1000).toFixed(2)
-        console.log(
-          `[TASK ${taskId}] Task completed successfully at ${new Date().toISOString()} (total time: ${totalTaskTime}s)`,
-        )
+        console.log('Task completed successfully')
       }
     } else {
       // Agent failed, but we still want to capture its logs
-      await logger.error(`${selectedAgent} agent execution failed`)
+      await logger.error('Agent execution failed')
 
       // Agent execution logs are already logged in real-time by the agent
       // No need to log them again here
@@ -546,7 +541,7 @@ async function processTask(
         if (shutdownResult.success) {
           await logger.info('Sandbox shutdown completed after error')
         } else {
-          await logger.error(`Sandbox shutdown failed: ${shutdownResult.error}`)
+          await logger.error('Sandbox shutdown failed')
         }
       } catch (shutdownError) {
         console.error('Failed to shutdown sandbox after error:', shutdownError)
@@ -557,7 +552,7 @@ async function processTask(
     const errorMessage = error instanceof Error ? error.message : 'Unknown error occurred'
 
     // Log the error and update task status
-    await logger.error(`Error: ${errorMessage}`)
+    await logger.error('Error occurred during task processing')
     await logger.updateStatus('error', errorMessage)
   }
 }

components/task-details.tsx

@@ -306,7 +306,7 @@ export function TaskDetails({ task }: TaskDetailsProps) {
             newDiffsCache[filename] = result.data
           }
         } catch (err) {
-          console.error(`Error fetching diff for ${filename}:`, err)
+          console.error('Error fetching diff for file:', err)
         }
       })
 

components/task-form.tsx

@@ -239,7 +239,7 @@ export function TaskForm({
             setLoadingRepos(false)
             return
           } catch {
-            console.warn(`Failed to parse cached repos for ${selectedOwner}, fetching fresh data`)
+            console.warn('Failed to parse cached repos, fetching fresh data')
             sessionStorage.removeItem(cacheKey)
           }
         }

lib/api-keys/user-keys.ts

@@ -97,7 +97,7 @@ export async function getUserApiKey(provider: Provider): Promise<string | undefi
       return decrypt(userKey[0].value)
     }
   } catch (error) {
-    console.error(`Error fetching user API key for ${provider}:`, error)
+    console.error('Error fetching user API key:', error)
   }
 
   return systemKeys[provider]

lib/sandbox/agents/claude.ts

@@ -83,7 +83,7 @@ export async function installClaudeCLI(
       // Use selectedModel if provided, otherwise fall back to default
 
       if (mcpServers && mcpServers.length > 0) {
-        await logger.info(`Adding ${mcpServers.length} MCP servers: ${mcpServers.map((s) => s.name).join(', ')}`)
+        await logger.info('Adding MCP servers')
 
         for (const server of mcpServers) {
           const serverName = server.name.toLowerCase().replace(/[^a-z0-9]/g, '-')
@@ -103,10 +103,10 @@ export async function installClaudeCLI(
             const addResult = await runCommandInSandbox(sandbox, 'sh', ['-c', addMcpCmd])
 
             if (addResult.success) {
-              await logger.info(`Successfully added local MCP server: ${server.name}`)
+              await logger.info('Successfully added local MCP server')
             } else {
               const redactedError = redactSensitiveInfo(addResult.error || 'Unknown error')
-              await logger.info(`Failed to add MCP server ${server.name}: ${redactedError}`)
+              await logger.info('Failed to add MCP server')
             }
           } else {
             // Remote HTTP/SSE server
@@ -123,10 +123,10 @@ export async function installClaudeCLI(
             const addResult = await runCommandInSandbox(sandbox, 'sh', ['-c', addMcpCmd])
 
             if (addResult.success) {
-              await logger.info(`Successfully added remote MCP server: ${server.name}`)
+              await logger.info('Successfully added remote MCP server')
             } else {
               const redactedError = redactSensitiveInfo(addResult.error || 'Unknown error')
-              await logger.info(`Failed to add MCP server ${server.name}: ${redactedError}`)
+              await logger.info('Failed to add MCP server')
             }
           }
         }
@@ -235,9 +235,9 @@ export async function executeClaudeInSandbox(
 
     // Check MCP configuration status
     const mcpList = await runCommandInSandbox(sandbox, 'sh', ['-c', `${envPrefix} claude mcp list`])
-    await logger.info(`MCP servers list: ${JSON.stringify(mcpList.output)}`)
+    await logger.info('MCP servers list retrieved')
     if (mcpList.error) {
-      await logger.info(`MCP list error: ${JSON.stringify(mcpList.error)}`)
+      await logger.info('MCP list error occurred')
     }
 
     // Try multiple command formats to see what works
@@ -274,7 +274,7 @@ export async function executeClaudeInSandbox(
 
     // Log the output
     if (result.output && result.output.trim()) {
-      await logger.info(`everything: ${JSON.stringify(result.output)}`)
+      await logger.info('Claude CLI execution output available')
 
       const redactedOutput = redactSensitiveInfo(result.output.trim())
       await logger.info(redactedOutput)
@@ -295,12 +295,12 @@ export async function executeClaudeInSandbox(
 
     // Log more details for debugging
     if (logger) {
-      await logger.info(`Claude CLI exit code: ${result.exitCode}`)
+      await logger.info('Claude CLI execution completed')
       if (result.output) {
-        await logger.info(`Claude CLI output length: ${result.output.length} characters`)
+        await logger.info('Claude CLI output available')
       }
       if (result.error) {
-        await logger.error(`Claude CLI error: ${result.error}`)
+        await logger.error('Claude CLI error occurred')
       }
     }
 

lib/sandbox/agents/codex.ts

@@ -93,7 +93,7 @@ export async function executeCodexInSandbox(
 
     if (logger) {
       const keyType = isVercelKey ? 'Vercel AI Gateway' : 'OpenAI'
-      await logger.info(`Using ${keyType} API key: ${apiKey.substring(0, 10)}...${apiKey.substring(apiKey.length - 4)}`)
+      await logger.info('Using API key for authentication')
     }
 
     // According to the official Codex CLI docs, we should use 'exec' for non-interactive execution
@@ -128,7 +128,7 @@ export async function executeCodexInSandbox(
     })
 
     if (logger) {
-      await logger.info(`Codex CLI version test: ${versionTestResult.exitCode === 0 ? 'SUCCESS' : 'FAILED'}`)
+      await logger.info('Codex CLI version test completed')
     }
 
     // Create configuration file based on API key type
@@ -170,7 +170,7 @@ log_requests = true
 
     // Add MCP servers configuration if provided
     if (mcpServers && mcpServers.length > 0) {
-      await logger.info(`Configuring ${mcpServers.length} MCP servers: ${mcpServers.map((s) => s.name).join(', ')}`)
+      await logger.info('Configuring MCP servers')
 
       // Check if we need experimental RMCP client (for remote servers)
       const hasRemoteServers = mcpServers.some((s) => s.type === 'remote')
@@ -203,7 +203,7 @@ command = "${executable}"
               .join(', ')} }\n`
           }
 
-          await logger.info(`Added local MCP server: ${server.name} (${server.command})`)
+          await logger.info('Added local MCP server')
         } else {
           // Remote HTTP/SSE server
           configToml += `
@@ -215,7 +215,7 @@ url = "${server.baseUrl}"
             configToml += `bearer_token = "${server.oauthClientSecret}"\n`
           }
 
-          await logger.info(`Added remote MCP server: ${server.name} (${server.baseUrl})`)
+          await logger.info('Added remote MCP server')
         }
       }
     }
@@ -232,7 +232,7 @@ url = "${server.baseUrl}"
     })
 
     if (logger) {
-      await logger.info(`Codex config setup: ${configSetupResult.exitCode === 0 ? 'SUCCESS' : 'FAILED'}`)
+      await logger.info('Codex config setup completed')
     }
 
     // Debug: Check if the config file was created correctly (without logging sensitive contents)
@@ -250,13 +250,13 @@ url = "${server.baseUrl}"
     // Debug: List files in the current directory before running Codex
     const lsDebugResult = await runCommandInSandbox(sandbox, 'ls', ['-la'])
     if (logger) {
-      await logger.info(`Current directory contents:\n${lsDebugResult.output || 'No output from ls -la'}`)
+      await logger.info('Current directory contents retrieved')
     }
 
     // Debug: Show current working directory
     const pwdResult = await runCommandInSandbox(sandbox, 'pwd', [])
     if (logger) {
-      await logger.info(`Current working directory: ${pwdResult.output || 'Unknown'}`)
+      await logger.info('Current working directory retrieved')
     }
 
     // Use exec command with Vercel AI Gateway configuration