Merge pull request #741 from zackproser/codex/enhance-vectordatabases-tool-with-lead-tracking-and-ui-impro

Improve lead detection and comparison UI

Author: zackproser

src/app/api/vectordatabases/chat/route.ts

@@ -6,6 +6,7 @@ import { z } from 'zod';
 import { LeadAnalysis } from '@/types';
 import { prisma } from '@/lib/prisma';
 import { auth } from '../../../../../auth';
+import { sendLeadNotificationEmail } from '@/lib/postmark';
 
 // Allow this serverless function to run for up to 5 minutes
 export const maxDuration = 300;
@@ -95,6 +96,14 @@ Respond with a JSON object containing:
               nextSteps: result.nextSteps
             }
           });
+
+          if (result.confidence > 0.7) {
+            await sendLeadNotificationEmail({
+              messages,
+              analysis: result,
+              email,
+            });
+          }
         } catch (error) {
           console.error('Failed to process lead:', error);
         }

src/app/vectordatabases/compare/ComparePageClient.tsx

@@ -264,9 +264,9 @@ export default function ComparePageClient({
                     const categoryObj = db[category] as { [feature: string]: any } || {};
                     const value = categoryObj[feature];
                     return (
-                      <TableCell key={db.name}>
+                      <TableCell key={db.name} className="text-center">
                         {typeof value === 'boolean' ? (
-                          <span className={value ? 'text-green-600' : 'text-red-600'}>
+                          <span className={value ? 'text-green-600 text-xl' : 'text-red-600 text-xl'}>
                             {getEmoji(value.toString())}
                           </span>
                         ) : (

src/components/VectorDBComparison.jsx

@@ -158,9 +158,9 @@ const renderComparison = (category, selectedDatabases, categories, features) =>
                 {selectedDatabases.map((db) => {
                   const value = db[category][feature];
                   return (
-                    <TableCell key={db.name}>
+                    <TableCell key={db.name} className="text-center">
                       {typeof value === 'boolean' ? (
-                        <span className={value ? 'text-green-600' : 'text-red-600'}>
+                        <span className={value ? 'text-green-600 text-xl' : 'text-red-600 text-xl'}>
                           {getEmoji(value.toString())}
                         </span>
                       ) : (

src/lib/postmark.ts

@@ -1,7 +1,7 @@
 import { ServerClient } from 'postmark'
 // import { renderPaywalledContent, loadContent } from "./content-handlers"; // Note: loadContent might be deprecated, check content-handlers
 import { getContentWithComponentByDirectorySlug } from "./content-handlers"; // Use this instead of loadContent
-import { ExtendedMetadata } from '@/types'
+import { ExtendedMetadata, LeadAnalysis } from '@/types'
 import { emailLogger as logger } from '@/utils/logger' // Import centralized email logger
 import { getContentUrlFromObject } from './content-url'
 
@@ -178,7 +178,7 @@ async function extractPreviewContent(productSlug: string): Promise<PreviewConten
  * @returns Postmark response
  */
 const sendFreeChaptersEmail = async (
-	input: SendFreeChaptersEmailInput
+        input: SendFreeChaptersEmailInput
 ): Promise<MessageSendingResponse | null> => {
 	logger.info(`[START] Sending free chapters email to: ${input.To}`);
 	logger.debug(`[CONFIG] Postmark API Key configured: ${!!process.env.POSTMARK_API_KEY}`);
@@ -268,7 +268,55 @@ You're receiving this email because you requested a preview from Zachary Proser.
 		// Handle specific Postmark errors if needed
 		// e.g., if (error.code === 406) { ... }
 		return null;
-	}
+        }
+};
+
+interface SendLeadNotificationInput {
+  messages: { role: string; content: string }[];
+  analysis: LeadAnalysis;
+  email?: string | null;
+}
+
+const sendLeadNotificationEmail = async (
+  input: SendLeadNotificationInput
+): Promise<MessageSendingResponse | null> => {
+  const adminEmail = process.env.ADMIN_EMAIL || '[email protected]';
+
+  const conversationText = input.messages
+    .map((m) => `${m.role}: ${m.content}`)
+    .join('\n');
+
+  const emailData = {
+    From: '[email protected]',
+    To: adminEmail,
+    Subject: 'New Potential Lead from Chatbot',
+    HtmlBody: `
+      <h1>New Potential Lead Detected</h1>
+      <p><strong>Email:</strong> ${input.email || 'unknown'}</p>
+      <p><strong>Confidence:</strong> ${input.analysis.confidence}</p>
+      <p><strong>Reasons:</strong> ${input.analysis.reasons.join(', ')}</p>
+      <p><strong>Topics:</strong> ${input.analysis.topics.join(', ')}</p>
+      <p><strong>Next Steps:</strong> ${input.analysis.nextSteps.join(', ')}</p>
+      <pre style="white-space:pre-wrap">${conversationText}</pre>
+    `,
+    TextBody: `New Potential Lead\nEmail: ${input.email || 'unknown'}\nConfidence: ${input.analysis.confidence}\nReasons: ${input.analysis.reasons.join(', ')}\nTopics: ${input.analysis.topics.join(', ')}\nNext Steps: ${input.analysis.nextSteps.join(', ')}\nConversation:\n${conversationText}`,
+    MessageStream: 'outbound',
+  };
+
+  try {
+    const response = await client.sendEmail(emailData);
+    logger.info('[SUCCESS] Lead notification sent:', response);
+    return response;
+  } catch (error) {
+    logger.error('[FAIL] Failed to send lead notification:', error);
+    return null;
+  }
 };
 
-export { sendReceiptEmail, sendFreeChaptersEmail, type SendReceiptEmailInput, type SendFreeChaptersEmailInput };
+export {
+  sendReceiptEmail,
+  sendFreeChaptersEmail,
+  sendLeadNotificationEmail,
+  type SendReceiptEmailInput,
+  type SendFreeChaptersEmailInput,
+};