Improve logger

apps/web/app/api/google/webhook/route.ts

@@ -53,6 +53,7 @@ async function processWebhookAsync(
   } catch (error) {
     await handleWebhookError(error, {
       email: decodedData.emailAddress,
+      emailAccountId: "unknown", // TODO: add emailAccountId
       url: "/api/google/webhook",
       logger,
     });

apps/web/app/api/outlook/webhook/route.ts

@@ -104,6 +104,7 @@ async function processNotificationsAsync(
       if (emailAccount?.email) {
         await handleWebhookError(error, {
           email: emailAccount.email,
+          emailAccountId: emailAccount.id,
           url: "/api/outlook/webhook",
           logger,
         });

apps/web/utils/ai/assistant/process-user-request.ts

@@ -157,7 +157,7 @@ ${stringifyEmailSimple(getEmailForLLM(originalEmail))}
   const modelOptions = getModel(emailAccount.user, "chat");
 
   const generateText = createGenerateText({
-    userEmail: emailAccount.email,
+    emailAccount,
     label: "Process user request",
     modelOptions,
   });

apps/web/utils/ai/calendar/availability.ts

@@ -90,7 +90,7 @@ ${threadContent}
   const modelOptions = getModel(emailAccount.user);
 
   const generateText = createGenerateText({
-    userEmail: emailAccount.email,
+    emailAccount,
     label: "Calendar availability analysis",
     modelOptions,
   });

apps/web/utils/ai/categorize-sender/ai-categorize-senders.ts

@@ -89,7 +89,7 @@ ${formatCategoriesForPrompt(categories)}
   const modelOptions = getModel(emailAccount.user, "economy");
 
   const generateObject = createGenerateObject({
-    userEmail: emailAccount.email,
+    emailAccount,
     label: "Categorize senders bulk",
     modelOptions,
   });

apps/web/utils/ai/categorize-sender/ai-categorize-single-sender.ts

@@ -49,7 +49,7 @@ ${formatCategoriesForPrompt(categories)}
   const modelOptions = getModel(emailAccount.user);
 
   const generateObject = createGenerateObject({
-    userEmail: emailAccount.email,
+    emailAccount,
     label: "Categorize sender",
     modelOptions,
   });

apps/web/utils/ai/choose-rule/ai-choose-args.ts

@@ -85,7 +85,7 @@ export async function aiGenerateArgs({
 
   const generateObject = createGenerateObject({
     label: "Args for rule",
-    userEmail: emailAccount.email,
+    emailAccount,
     modelOptions,
   });
 

apps/web/utils/ai/choose-rule/ai-choose-rule.ts

@@ -73,7 +73,7 @@ async function getAiResponse(options: GetAiResponseOptions): Promise<{
   const modelOptions = getModel(emailAccount.user, modelType);
 
   const generateObject = createGenerateObject({
-    userEmail: emailAccount.email,
+    emailAccount,
     label: "Choose rule",
     modelOptions,
   });

apps/web/utils/ai/choose-rule/ai-detect-recurring-pattern.ts

@@ -97,7 +97,7 @@ ${getEmailListPrompt({ messages: emails, messageMaxLength: 500 })}
     const modelOptions = getModel(emailAccount.user, "chat");
 
     const generateObject = createGenerateObject({
-      userEmail: emailAccount.email,
+      emailAccount,
       label: "Detect recurring pattern",
       modelOptions,
     });

apps/web/utils/ai/clean/ai-clean-select-labels.ts

@@ -30,7 +30,7 @@ ${instructions}
   const modelOptions = getModel(emailAccount.user);
 
   const generateObject = createGenerateObject({
-    userEmail: emailAccount.email,
+    emailAccount,
     label: "Clean - Select Labels",
     modelOptions,
   });

apps/web/utils/ai/clean/ai-clean.ts

@@ -93,7 +93,7 @@ The current date is ${currentDate}.
   const modelOptions = getModel(emailAccount.user);
 
   const generateObject = createGenerateObject({
-    userEmail: emailAccount.email,
+    emailAccount,
     label: "Clean",
     modelOptions,
   });

apps/web/utils/ai/digest/summarize-email-for-digest.ts

@@ -81,7 +81,7 @@ ${getUserInfoPrompt({ emailAccount })}`;
     const modelOptions = getModel(emailAccount.user);
 
     const generateObject = createGenerateObject({
-      userEmail: emailAccount.email,
+      emailAccount,
       label: "Summarize email",
       modelOptions,
     });

apps/web/utils/ai/group/create-group.ts

@@ -84,7 +84,7 @@ Key guidelines:
   const modelOptions = getModel(emailAccount.user);
 
   const generateText = createGenerateText({
-    userEmail: emailAccount.email,
+    emailAccount,
     label: "Create group",
     modelOptions,
   });
@@ -154,7 +154,7 @@ Guidelines:
   const modelOptions = getModel(emailAccount.user);
 
   const generateText = createGenerateText({
-    userEmail: emailAccount.email,
+    emailAccount,
     label: "Verify group criteria",
     modelOptions,
   });

apps/web/utils/ai/knowledge/extract-from-email-history.ts

@@ -90,7 +90,7 @@ export async function aiExtractFromEmailHistory({
     const modelOptions = getModel(emailAccount.user, "economy");
 
     const generateObject = createGenerateObject({
-      userEmail: emailAccount.email,
+      emailAccount,
       label: "Email history extraction",
       modelOptions,
     });

apps/web/utils/ai/knowledge/extract.ts

@@ -91,7 +91,7 @@ export async function aiExtractRelevantKnowledge({
     const modelOptions = getModel(emailAccount.user, "economy");
 
     const generateObject = createGenerateObject({
-      userEmail: emailAccount.email,
+      emailAccount,
       label: "Knowledge extraction",
       modelOptions,
     });

apps/web/utils/ai/knowledge/persona.ts

@@ -96,7 +96,7 @@ ${getEmailListPrompt({ messages: emails, messageMaxLength: 1000 })}
   const modelOptions = getModel(emailAccount.user, "economy");
 
   const generateObject = createGenerateObject({
-    userEmail: emailAccount.email,
+    emailAccount,
     label: "Persona Analysis",
     modelOptions,
   });

apps/web/utils/ai/knowledge/writing-style.ts

@@ -68,7 +68,7 @@ ${getUserInfoPrompt({ emailAccount })}`;
   const modelOptions = getModel(emailAccount.user);
 
   const generateObject = createGenerateObject({
-    userEmail: emailAccount.email,
+    emailAccount,
     label: "Writing Style Analysis",
     modelOptions,
   });

apps/web/utils/ai/mcp/mcp-agent.ts

@@ -58,7 +58,7 @@ ${getEmailListPrompt({ messages, messageMaxLength: 1000, maxMessages: 5 })}
   const modelOptions = getModel(emailAccount.user, "economy");
 
   const generateText = createGenerateText({
-    userEmail: emailAccount.email,
+    emailAccount,
     label: "MCP Agent",
     modelOptions,
   });

apps/web/utils/ai/reply/check-if-needs-reply.ts

@@ -55,7 +55,7 @@ Decide if the message we are sending needs a reply. Respond with a JSON object w
   const modelOptions = getModel(emailAccount.user);
 
   const generateObject = createGenerateObject({
-    userEmail: emailAccount.email,
+    emailAccount,
     label: "Check if needs reply",
     modelOptions,
   });

apps/web/utils/ai/reply/determine-thread-status.ts

@@ -107,7 +107,7 @@ Based on the full thread context above, determine the current status of this thr
   const modelOptions = getModel(emailAccount.user, modelType);
 
   const generateObject = createGenerateObject({
-    userEmail: emailAccount.email,
+    emailAccount,
     label: "Determine thread status",
     modelOptions,
   });

apps/web/utils/ai/reply/draft-with-knowledge.ts

@@ -187,7 +187,7 @@ export async function aiDraftWithKnowledge({
     const modelOptions = getModel(emailAccount.user);
 
     const generateObject = createGenerateObject({
-      userEmail: emailAccount.email,
+      emailAccount,
       label: "Email draft with knowledge",
       modelOptions,
     });

apps/web/utils/ai/reply/generate-nudge.ts

@@ -32,7 +32,7 @@ IMPORTANT: The person you're writing an email for is: ${messages.at(-1)?.from}.`
 
   const generateText = createGenerateText({
     label: "Reply",
-    userEmail: emailAccount.email,
+    emailAccount,
     modelOptions,
   });
 

apps/web/utils/ai/reply/reply-context-collector.ts

@@ -87,7 +87,7 @@ ${getTodayForLLM()}`;
     const modelOptions = getModel(emailAccount.user, "economy");
 
     const generateText = createGenerateText({
-      userEmail: emailAccount.email,
+      emailAccount,
       label: "Reply context collector",
       modelOptions,
     });

apps/web/utils/ai/report/analyze-email-behavior.ts

@@ -60,7 +60,7 @@ Analyze the email patterns and identify:
   const modelOptions = getModel(emailAccount.user, "economy");
 
   const generateObject = createGenerateObject({
-    userEmail: emailAccount.email,
+    emailAccount,
     label: "email-report-email-behavior",
     modelOptions,
   });

apps/web/utils/ai/report/analyze-label-optimization.ts

@@ -55,7 +55,7 @@ Each suggestion should include the reason and expected impact.`;
   const modelOptions = getModel(emailAccount.user, "economy");
 
   const generateObject = createGenerateObject({
-    userEmail: emailAccount.email,
+    emailAccount,
     label: "email-report-label-analysis",
     modelOptions,
   });

apps/web/utils/ai/report/build-user-persona.ts

@@ -67,7 +67,7 @@ Analyze the data and identify:
   const modelOptions = getModel(emailAccount.user);
 
   const generateObject = createGenerateObject({
-    userEmail: emailAccount.email,
+    emailAccount,
     label: "email-report-user-persona",
     modelOptions,
   });

apps/web/utils/ai/report/generate-actionable-recommendations.ts

@@ -62,7 +62,7 @@ Focus on practical, implementable solutions that improve email organization and
   const modelOptions = getModel(emailAccount.user);
 
   const generateObject = createGenerateObject({
-    userEmail: emailAccount.email,
+    emailAccount,
     label: "email-report-actionable-recommendations",
     modelOptions,
   });