From c9895c1a0443b6cf925d59a23f308607716754cc Mon Sep 17 00:00:00 2001
From: alma <alma@governance-labs.org>
Date: Fri, 25 Apr 2025 16:33:03 +0200
Subject: [PATCH] panel 2 courier api

---
 app/api/courrier/[id]/route.ts | 102 +++++++++++++++++++++++----------
 1 file changed, 73 insertions(+), 29 deletions(-)

diff --git a/app/api/courrier/[id]/route.ts b/app/api/courrier/[id]/route.ts
index bd846eb8..49c021b6 100644
--- a/app/api/courrier/[id]/route.ts
+++ b/app/api/courrier/[id]/route.ts
@@ -17,8 +17,8 @@ export async function GET(
   { params }: { params: { id: string } }
 ) {
   try {
-    // 1. Get email ID from params
-    const { id } = params;
+    // 1. Get email ID from params (properly awaited)
+    const { id } = await Promise.resolve(params);
     
     // 2. Authentication check
     const session = await getServerSession(authOptions);
@@ -75,53 +75,97 @@ export async function GET(
       await client.connect();
       
       // 7. Open the folder
-      await client.mailboxOpen(folder);
+      const mailbox = await client.mailboxOpen(folder);
+      console.log(`Mailbox opened: ${folder}, total messages: ${mailbox.exists}`);
       
-      // 8. Fetch the email with UID
-      const options = {
-        uid: true,  // This is crucial - we must specify uid:true to fetch by UID
-        source: true,
-        envelope: true,
-        bodyStructure: true,
-        flags: true
-      };
+      // 8. Download the raw message data using a dynamic fetch approach
+      console.log(`Attempting to fetch message with UID: ${id}`);
       
-      // Fetch by UID
-      const message = await client.fetchOne(id, options);
+      // Create a loop to process all messages until we find the right one
+      let foundMessage = null;
+      const chunkSize = 10;
       
-      if (!message) {
+      for (let i = 1; i <= mailbox.exists; i += chunkSize) {
+        const endIdx = Math.min(i + chunkSize - 1, mailbox.exists);
+        const range = `${i}:${endIdx}`;
+        
+        console.log(`Scanning messages ${range}`);
+        
+        // Fetch messages in chunks with UID
+        const messages = client.fetch(range, {
+          uid: true,
+          envelope: true,
+          flags: true,
+          bodyStructure: true,
+          source: true
+        });
+        
+        for await (const message of messages) {
+          if (message.uid.toString() === id) {
+            console.log(`Found matching message with UID ${id}`);
+            foundMessage = message;
+            break;
+          }
+        }
+        
+        if (foundMessage) {
+          break;
+        }
+      }
+      
+      if (!foundMessage) {
+        console.log(`No message found with UID ${id}`);
         return NextResponse.json(
-          { error: 'Email not found' },
+          { error: `Email not found with UID ${id}` },
           { status: 404 }
         );
       }
 
+      console.log(`Successfully fetched message, parsing content...`);
+      
       // 9. Parse the email content
-      const parsedEmail = await parseEmail(message.source.toString());
+      const parsedEmail = await parseEmail(foundMessage.source.toString());
       
       // 10. Prepare the full email object with all needed data
       const fullEmail = {
-        id: message.uid.toString(),
-        from: message.envelope.from?.[0]?.address || '',
-        fromName: message.envelope.from?.[0]?.name || 
-                 message.envelope.from?.[0]?.address?.split('@')[0] || '',
-        to: message.envelope.to?.map((addr: any) => addr.address).join(', ') || '',
-        subject: message.envelope.subject || '(No subject)',
-        date: message.envelope.date?.toISOString() || new Date().toISOString(),
+        id,
+        from: foundMessage.envelope.from?.[0]?.address || '',
+        fromName: foundMessage.envelope.from?.[0]?.name || 
+                 foundMessage.envelope.from?.[0]?.address?.split('@')[0] || '',
+        to: foundMessage.envelope.to?.map((addr: any) => addr.address).join(', ') || '',
+        subject: foundMessage.envelope.subject || '(No subject)',
+        date: foundMessage.envelope.date?.toISOString() || new Date().toISOString(),
         content: parsedEmail.html || parsedEmail.text || '',
         textContent: parsedEmail.text || '',
-        read: message.flags.has('\\Seen'),
-        starred: message.flags.has('\\Flagged'),
+        read: foundMessage.flags.has('\\Seen'),
+        starred: foundMessage.flags.has('\\Flagged'),
         folder: folder,
-        hasAttachments: message.bodyStructure?.type === 'multipart',
+        hasAttachments: foundMessage.bodyStructure?.type === 'multipart',
         attachments: parsedEmail.attachments || [],
-        flags: Array.from(message.flags),
+        flags: Array.from(foundMessage.flags),
         headers: parsedEmail.headers || {}
       };
 
       // 11. Mark as read if not already
-      if (!message.flags.has('\\Seen')) {
-        await client.messageFlagsAdd(id, ['\\Seen'], { uid: true });
+      if (!foundMessage.flags.has('\\Seen')) {
+        try {
+          // Use the same sequence range to mark message as read
+          for (let i = 1; i <= mailbox.exists; i += chunkSize) {
+            const endIdx = Math.min(i + chunkSize - 1, mailbox.exists);
+            const range = `${i}:${endIdx}`;
+            
+            // Find message and mark as read
+            const messages = client.fetch(range, { uid: true });
+            for await (const message of messages) {
+              if (message.uid.toString() === id) {
+                await client.messageFlagsAdd(i.toString(), ['\\Seen']);
+                break;
+              }
+            }
+          }
+        } catch (error) {
+          console.error('Error marking message as read:', error);
+        }
       }
 
       // 12. Cache the email content