'use client'; import { useEffect, useState, useMemo, useCallback } from 'react'; import { useRouter } from 'next/navigation'; import { Card, CardContent, CardDescription, CardHeader, CardTitle } from '@/components/ui/card'; import { Input } from '@/components/ui/input'; import { Button } from '@/components/ui/button'; import { Label } from '@/components/ui/label'; import { Textarea } from '@/components/ui/textarea'; import { Checkbox } from '@/components/ui/checkbox'; import { AlertDialog, AlertDialogAction, AlertDialogCancel, AlertDialogContent, AlertDialogDescription, AlertDialogFooter, AlertDialogHeader, AlertDialogTitle, } from "@/components/ui/alert-dialog"; import { Avatar, AvatarFallback } from '@/components/ui/avatar'; import { MoreVertical, Settings, Plus as PlusIcon, Trash2, Edit, Mail, Inbox, Send, Star, Trash, Plus, ChevronLeft, ChevronRight, Search, ChevronDown, Folder, ChevronUp, Reply, Forward, ReplyAll, MoreHorizontal, FolderOpen, X, Paperclip, MessageSquare, Copy, EyeOff, AlertOctagon, Archive, RefreshCw } from 'lucide-react'; import { ScrollArea } from '@/components/ui/scroll-area'; import { useSession } from 'next-auth/react'; import { decodeQuotedPrintable, decodeBase64, convertCharset, cleanHtml, parseEmailHeaders, extractBoundary, extractFilename, extractHeader } from '@/lib/infomaniak-mime-decoder'; interface Account { id: number; name: string; email: string; color: string; folders?: string[]; } interface Email { id: number; accountId: number; from: string; fromName: string; to: string; subject: string; body: string; date: string; read: boolean; starred: boolean; folder: string; cc?: string; bcc?: string; flags?: string[]; } interface Attachment { name: string; type: string; content: string; encoding: string; } interface ParsedEmailContent { headers: string; body: string; html?: string; text?: string; attachments?: Array<{ filename: string; content: string; contentType: string; }>; } interface ParsedEmailMetadata { subject: string; from: string; to: string; date: string; contentType: string; text: string | null; html: string | null; raw: { headers: string; body: string; }; } function parseFullEmail(emailContent: string): ParsedEmailContent { if (!emailContent) return { headers: '', body: '' }; // Split headers and body const headerEnd = emailContent.indexOf('\r\n\r\n'); if (headerEnd === -1) return { headers: '', body: emailContent }; const headers = emailContent.substring(0, headerEnd); const body = emailContent.substring(headerEnd + 4); // Parse headers const headerInfo = parseEmailHeaders(headers); const boundary = extractBoundary(headers); // Initialize result object const result: ParsedEmailContent = { headers, body: '', html: undefined, text: undefined, attachments: [] }; // Handle multipart content if (boundary && headerInfo.contentType.startsWith('multipart/')) { const parts = body.split(`--${boundary}`); parts .filter(part => part.trim() && !part.includes('--')) .forEach(part => { const partHeaderEnd = part.indexOf('\r\n\r\n'); if (partHeaderEnd === -1) return; const partHeaders = part.substring(0, partHeaderEnd); const partBody = part.substring(partHeaderEnd + 4); const partInfo = parseEmailHeaders(partHeaders); let decodedContent = partBody; if (partInfo.encoding === 'quoted-printable') { decodedContent = decodeQuotedPrintable(partBody, partInfo.charset); } else if (partInfo.encoding === 'base64') { decodedContent = decodeBase64(partBody, partInfo.charset); } // Handle different content types if (partInfo.contentType.includes('text/html')) { result.html = cleanHtml(decodedContent); } else if (partInfo.contentType.includes('text/plain')) { result.text = decodedContent; } else if (partInfo.contentType.includes('application/') || partInfo.contentType.includes('image/')) { // Handle attachments const filename = extractFilename(partHeaders) || `attachment-${Date.now()}`; result.attachments?.push({ filename, content: decodedContent, contentType: partInfo.contentType }); } }); // Set the body to the text content if available, otherwise use HTML result.body = result.text || result.html || ''; } else { // Handle single part content let decodedBody = body; if (headerInfo.encoding === 'quoted-printable') { decodedBody = decodeQuotedPrintable(body, headerInfo.charset); } else if (headerInfo.encoding === 'base64') { decodedBody = decodeBase64(body, headerInfo.charset); } if (headerInfo.contentType.includes('text/html')) { result.html = cleanHtml(decodedBody); result.body = result.html; } else if (headerInfo.contentType.includes('text/plain')) { result.text = decodedBody; result.body = result.text; } else { result.body = decodedBody; } } return result; } function extractTextFromHtml(html: string): string { // Remove scripts and style tags html = html.replace(/]*>[\s\S]*?<\/script>/gi, '') .replace(/]*>[\s\S]*?<\/style>/gi, ''); // Convert
and

to newlines html = html.replace(/]*>/gi, '\n') .replace(/]*>/gi, '\n') .replace(/<\/p>/gi, '\n'); // Remove all other HTML tags html = html.replace(/<[^>]+>/g, ''); // Decode HTML entities html = html.replace(/ /g, ' ') .replace(/&/g, '&') .replace(/</g, '<') .replace(/>/g, '>') .replace(/"/g, '"'); // Clean up whitespace return html.replace(/\n\s*\n/g, '\n\n').trim(); } function decodeMIME(text: string, encoding?: string, charset: string = 'utf-8'): string { if (!text) return ''; // Normalize encoding and charset encoding = (encoding || '').toLowerCase(); charset = (charset || 'utf-8').toLowerCase(); try { // Handle different encoding types if (encoding === 'quoted-printable') { return decodeQuotedPrintable(text, charset); } else if (encoding === 'base64') { return decodeBase64(text, charset); } else if (encoding === '7bit' || encoding === '8bit' || encoding === 'binary') { // For these encodings, we still need to handle the character set return convertCharset(text, charset); } else { // Unknown encoding, return as is but still handle charset return convertCharset(text, charset); } } catch (error) { console.error('Error decoding MIME:', error); return text; } } function extractHtmlBody(html: string): string { const bodyMatch = html.match(/]*>([\s\S]*?)<\/body>/i); return bodyMatch ? bodyMatch[1] : html; } function decodeMimeContent(content: string): string { if (!content) return ''; // Check if this is a multipart message if (content.includes('Content-Type: multipart/')) { const boundary = content.match(/boundary="([^"]+)"/)?.[1]; if (boundary) { const parts = content.split('--' + boundary); let htmlContent = ''; let textContent = ''; parts.forEach(part => { if (part.includes('Content-Type: text/html')) { const match = part.match(/\r?\n\r?\n([\s\S]+?)(?=\r?\n--)/); if (match) { htmlContent = cleanHtml(match[1]); } } else if (part.includes('Content-Type: text/plain')) { const match = part.match(/\r?\n\r?\n([\s\S]+?)(?=\r?\n--)/); if (match) { textContent = cleanHtml(match[1]); } } }); // Prefer HTML content if available return htmlContent || textContent; } } // If not multipart or no boundary found, clean the content directly return cleanHtml(content); } function renderEmailContent(email: Email) { if (!email.body) return null; try { // Parse the email content using our MIME decoder const parsed = parseFullEmail(email.body); // If we have HTML content, render it if (parsed.html) { return (

{parsed.attachments && parsed.attachments.length > 0 && (

Attachments:

    {parsed.attachments.map((attachment, index) => (
  • {attachment.filename}
  • ))}
)}
); } // If we have text content, render it if (parsed.text) { return (
{parsed.text.split('\n').map((line, i) => (

{line}

))}
{parsed.attachments && parsed.attachments.length > 0 && (

Attachments:

    {parsed.attachments.map((attachment, index) => (
  • {attachment.filename}
  • ))}
)}
); } // If we couldn't parse the content, try to decode and clean the raw body const decodedBody = decodeMIME(email.body, 'quoted-printable', 'utf-8'); const cleanedContent = cleanHtml(decodedBody); return (
{cleanedContent.split('\n').map((line, i) => (

{line}

))}
); } catch (error) { console.error('Error rendering email content:', error); return (
{email.body}
); } } // Define the exact folder names from IMAP type MailFolder = string; // Map IMAP folders to sidebar items with icons const getFolderIcon = (folder: string) => { switch (folder.toLowerCase()) { case 'inbox': return Inbox; case 'sent': return Send; case 'drafts': return Edit; case 'trash': return Trash; case 'spam': return AlertOctagon; case 'archive': case 'archives': return Archive; default: return Folder; } }; // Initial sidebar items - only INBOX const initialSidebarItems = [ { view: 'INBOX' as MailFolder, label: 'Inbox', icon: Inbox, folder: 'INBOX' } ]; export default function CourrierPage() { const router = useRouter(); const { data: session } = useSession(); const [loading, setLoading] = useState(true); const [accounts, setAccounts] = useState([ { id: 0, name: 'All', email: '', color: 'bg-gray-500' }, { id: 1, name: 'Mail', email: 'alma@governance-labs.org', color: 'bg-blue-500' } ]); const [selectedAccount, setSelectedAccount] = useState(null); const [currentView, setCurrentView] = useState('INBOX'); const [showCompose, setShowCompose] = useState(false); const [showDeleteConfirm, setShowDeleteConfirm] = useState(false); const [selectedEmails, setSelectedEmails] = useState([]); const [showBulkActions, setShowBulkActions] = useState(false); const [showBcc, setShowBcc] = useState(false); const [emails, setEmails] = useState([]); const [error, setError] = useState(null); const [composeSubject, setComposeSubject] = useState(''); const [composeTo, setComposeTo] = useState(''); const [composeCc, setComposeCc] = useState(''); const [composeBcc, setComposeBcc] = useState(''); const [composeBody, setComposeBody] = useState(''); const [selectedEmail, setSelectedEmail] = useState(null); const [sidebarOpen, setSidebarOpen] = useState(true); const [foldersOpen, setFoldersOpen] = useState(true); const [showSettings, setShowSettings] = useState(false); const [searchQuery, setSearchQuery] = useState(''); const [mobileSidebarOpen, setMobileSidebarOpen] = useState(false); const [composeOpen, setComposeOpen] = useState(false); const [accountsDropdownOpen, setAccountsDropdownOpen] = useState(false); const [foldersDropdownOpen, setFoldersDropdownOpen] = useState(false); const [showAccountActions, setShowAccountActions] = useState(null); const [showEmailActions, setShowEmailActions] = useState(false); const [deleteType, setDeleteType] = useState<'email' | 'emails' | 'account'>('email'); const [itemToDelete, setItemToDelete] = useState(null); const [showCc, setShowCc] = useState(false); const [contentLoading, setContentLoading] = useState(false); const [attachments, setAttachments] = useState([]); const [folders, setFolders] = useState([]); const [unreadCount, setUnreadCount] = useState(0); const [availableFolders, setAvailableFolders] = useState([]); const [sidebarItems, setSidebarItems] = useState(initialSidebarItems); const [page, setPage] = useState(1); const [hasMore, setHasMore] = useState(true); const [isLoadingMore, setIsLoadingMore] = useState(false); const [isLoadingInitial, setIsLoadingInitial] = useState(true); const [isLoadingSearch, setIsLoadingSearch] = useState(false); const [isLoadingCompose, setIsLoadingCompose] = useState(false); const [isLoadingReply, setIsLoadingReply] = useState(false); const [isLoadingForward, setIsLoadingForward] = useState(false); const [isLoadingDelete, setIsLoadingDelete] = useState(false); const [isLoadingMove, setIsLoadingMove] = useState(false); const [isLoadingStar, setIsLoadingStar] = useState(false); const [isLoadingUnstar, setIsLoadingUnstar] = useState(false); const [isLoadingMarkRead, setIsLoadingMarkRead] = useState(false); const [isLoadingMarkUnread, setIsLoadingMarkUnread] = useState(false); const [isLoadingRefresh, setIsLoadingRefresh] = useState(false); const emailsPerPage = 20; const [isSearching, setIsSearching] = useState(false); const [searchResults, setSearchResults] = useState([]); const [showSearchResults, setShowSearchResults] = useState(false); const [isComposing, setIsComposing] = useState(false); const [composeEmail, setComposeEmail] = useState({ to: '', subject: '', body: '', }); const [isSending, setIsSending] = useState(false); const [isReplying, setIsReplying] = useState(false); const [isForwarding, setIsForwarding] = useState(false); const [replyToEmail, setReplyToEmail] = useState(null); const [forwardEmail, setForwardEmail] = useState(null); const [replyBody, setReplyBody] = useState(''); const [forwardBody, setForwardBody] = useState(''); const [replyAttachments, setReplyAttachments] = useState([]); const [forwardAttachments, setForwardAttachments] = useState([]); const [isSendingReply, setIsSendingReply] = useState(false); const [isSendingForward, setIsSendingForward] = useState(false); const [isDeleting, setIsDeleting] = useState(false); const [isMoving, setIsMoving] = useState(false); const [isStarring, setIsStarring] = useState(false); const [isUnstarring, setIsUnstarring] = useState(false); const [isMarkingRead, setIsMarkingRead] = useState(false); const [isMarkingUnread, setIsMarkingUnread] = useState(false); const [isRefreshing, setIsRefreshing] = useState(false); // Debug logging for email distribution useEffect(() => { const emailsByFolder = emails.reduce((acc, email) => { acc[email.folder] = (acc[email.folder] || 0) + 1; return acc; }, {} as Record); console.log('Emails by folder:', emailsByFolder); console.log('Current view:', currentView); }, [emails, currentView]); // Move getSelectedEmail inside the component const getSelectedEmail = () => { return emails.find(email => email.id === selectedEmail?.id); }; // Check for stored credentials useEffect(() => { const checkCredentials = async () => { try { console.log('Checking for stored credentials...'); const response = await fetch('/api/mail'); if (!response.ok) { const errorData = await response.json(); console.log('API response error:', errorData); if (errorData.error === 'No stored credentials found') { console.log('No credentials found, redirecting to login...'); router.push('/mail/login'); return; } throw new Error(errorData.error || 'Failed to check credentials'); } console.log('Credentials verified, loading emails...'); setLoading(false); loadEmails(); } catch (err) { console.error('Error checking credentials:', err); setError(err instanceof Error ? err.message : 'Failed to check credentials'); setLoading(false); } }; checkCredentials(); }, [router]); // Update the loadEmails function const loadEmails = async (isLoadMore = false) => { try { if (isLoadMore) { setIsLoadingMore(true); } else { setLoading(true); } setError(null); const response = await fetch(`/api/mail?folder=${currentView}&page=${page}&limit=${emailsPerPage}`); if (!response.ok) { throw new Error('Failed to load emails'); } const data = await response.json(); // Get available folders from the API response if (data.folders) { setAvailableFolders(data.folders); } // Process emails keeping exact folder names const processedEmails = (data.emails || []).map((email: any) => ({ id: Number(email.id), accountId: 1, from: email.from || '', fromName: email.from?.split('@')[0] || '', to: email.to || '', subject: email.subject || '(No subject)', body: email.body || '', date: email.date || new Date().toISOString(), read: email.read || false, starred: email.starred || false, folder: email.folder || 'INBOX', cc: email.cc, bcc: email.bcc, flags: email.flags || [] })); // Only update unread count if we're in the Inbox folder if (currentView === 'INBOX') { const unreadInboxEmails = processedEmails.filter( (email: Email) => !email.read && email.folder === 'INBOX' ).length; setUnreadCount(unreadInboxEmails); } // Update emails state based on whether we're loading more if (isLoadMore) { setEmails(prev => [...prev, ...processedEmails]); } else { setEmails(processedEmails); } // Update hasMore state based on the number of emails received setHasMore(processedEmails.length === emailsPerPage); } catch (err) { console.error('Error loading emails:', err); setError(err instanceof Error ? err.message : 'Failed to load emails'); } finally { setLoading(false); setIsLoadingMore(false); } }; // Add an effect to reload emails when the view changes useEffect(() => { setPage(1); // Reset page when view changes setHasMore(true); loadEmails(); }, [currentView]); // Format date for display const formatDate = (dateString: string) => { const date = new Date(dateString); const now = new Date(); if (date.toDateString() === now.toDateString()) { return date.toLocaleTimeString([], { hour: '2-digit', minute: '2-digit' }); } else { return date.toLocaleDateString([], { month: 'short', day: 'numeric' }); } }; // Get account color const getAccountColor = (accountId: number) => { const account = accounts.find(acc => acc.id === accountId); return account ? account.color : 'bg-gray-500'; }; // Update handleEmailSelect to set selectedEmail correctly const handleEmailSelect = async (emailId: number) => { const email = emails.find(e => e.id === emailId); if (!email) { console.error('Email not found in list'); return; } // Set the selected email first to show preview immediately setSelectedEmail(email); // Fetch the full email content const response = await fetch(`/api/mail/${emailId}`); if (!response.ok) { throw new Error('Failed to fetch full email content'); } const fullEmail = await response.json(); // Update the email in the list and selected email with full content setEmails(prevEmails => prevEmails.map(email => email.id === emailId ? { ...email, body: fullEmail.body } : email )); setSelectedEmail(prev => prev ? { ...prev, body: fullEmail.body } : prev); // Try to mark as read in the background try { const markReadResponse = await fetch(`/api/mail/mark-read`, { method: 'POST', headers: { 'Content-Type': 'application/json', 'Authorization': `Bearer ${session?.user?.id}` // Add session token }, body: JSON.stringify({ emailId, isRead: true, }), }); if (markReadResponse.ok) { // Only update the emails list if the API call was successful setEmails((prevEmails: Email[]) => prevEmails.map((email: Email): Email => email.id === emailId ? { ...email, read: true } : email ) ); } else { console.error('Failed to mark email as read:', await markReadResponse.text()); } } catch (error) { console.error('Error marking email as read:', error); } }; // Add these improved handlers const handleEmailCheckbox = (e: React.ChangeEvent, emailId: number) => { e.stopPropagation(); if (e.target.checked) { setSelectedEmails([...selectedEmails, emailId.toString()]); } else { setSelectedEmails(selectedEmails.filter(id => id !== emailId.toString())); } }; // Handles marking an individual email as read/unread const handleMarkAsRead = (emailId: string, isRead: boolean) => { setEmails(emails.map(email => email.id.toString() === emailId ? { ...email, read: isRead } : email )); }; // Handles bulk actions for selected emails const handleBulkAction = async (action: 'delete' | 'mark-read' | 'mark-unread' | 'archive') => { if (action === 'delete') { setDeleteType('emails'); setShowDeleteConfirm(true); return; } try { const response = await fetch('/api/mail/bulk-actions', { method: 'POST', headers: { 'Content-Type': 'application/json', }, body: JSON.stringify({ emailIds: selectedEmails, action: action }), }); if (!response.ok) { throw new Error('Failed to perform bulk action'); } // Update local state based on the action setEmails(emails.map(email => { if (selectedEmails.includes(email.id.toString())) { switch (action) { case 'mark-read': return { ...email, read: true }; case 'mark-unread': return { ...email, read: false }; case 'archive': return { ...email, folder: 'Archive' }; default: return email; } } return email; })); // Clear selection after successful action setSelectedEmails([]); } catch (error) { console.error('Error performing bulk action:', error); alert('Failed to perform bulk action. Please try again.'); } }; // Add handleDeleteConfirm function const handleDeleteConfirm = async () => { try { const response = await fetch('/api/mail/bulk-actions', { method: 'POST', headers: { 'Content-Type': 'application/json', }, body: JSON.stringify({ emailIds: selectedEmails, action: 'delete' }), }); if (!response.ok) { throw new Error('Failed to delete emails'); } // Remove deleted emails from state setEmails(emails.filter(email => !selectedEmails.includes(email.id.toString()))); setSelectedEmails([]); } catch (error) { console.error('Error deleting emails:', error); alert('Failed to delete emails. Please try again.'); } finally { setShowDeleteConfirm(false); } }; // Add infinite scroll handler const handleScroll = useCallback((e: React.UIEvent) => { const target = e.currentTarget; if ( target.scrollHeight - target.scrollTop === target.clientHeight && !isLoadingMore && hasMore ) { setPage(prev => prev + 1); loadEmails(true); } }, [isLoadingMore, hasMore]); // Sort emails by date (most recent first) const sortedEmails = useMemo(() => { return [...emails].sort((a, b) => { return new Date(b.date).getTime() - new Date(a.date).getTime(); }); }, [emails]); const toggleSelectAll = () => { if (selectedEmails.length === emails.length) { setSelectedEmails([]); } else { setSelectedEmails(emails.map(email => email.id.toString())); } }; // Add filtered emails based on search query const filteredEmails = useMemo(() => { if (!searchQuery) return emails; const query = searchQuery.toLowerCase(); return emails.filter(email => email.subject.toLowerCase().includes(query) || email.from.toLowerCase().includes(query) || email.to.toLowerCase().includes(query) || email.body.toLowerCase().includes(query) ); }, [emails, searchQuery]); // Update the email list to use filtered emails const renderEmailList = () => (
{renderEmailListHeader()} {renderBulkActionsToolbar()}
{loading ? (
) : filteredEmails.length === 0 ? (

{searchQuery ? 'No emails match your search' : 'No emails in this folder'}

) : (
{filteredEmails.map((email) => renderEmailListItem(email))} {isLoadingMore && (
)}
)}
); // Update the email count in the header to show filtered count const renderEmailListHeader = () => (
setSearchQuery(e.target.value)} />
0 && selectedEmails.length === filteredEmails.length} onCheckedChange={toggleSelectAll} className="mt-0.5" />

Inbox

{searchQuery ? `${filteredEmails.length} of ${emails.length} emails` : `${emails.length} emails`}
); // Update the bulk actions toolbar to include confirmation dialog const renderBulkActionsToolbar = () => { if (selectedEmails.length === 0) return null; return (
{selectedEmails.length} selected
); }; // Keep only one renderEmailListWrapper function that includes both panels const renderEmailListWrapper = () => (
{/* Email list panel */} {renderEmailList()} {/* Preview panel - will automatically take remaining space */}
{selectedEmail ? ( <> {/* Email actions header */}

{selectedEmail.subject}

{/* Scrollable content area */}
{selectedEmail.fromName?.charAt(0) || selectedEmail.from.charAt(0)}

{selectedEmail.fromName || selectedEmail.from}

to {selectedEmail.to}

{formatDate(selectedEmail.date)}
{renderEmailContent(selectedEmail)}
) : (

Select an email to view its contents

)}
); // Update sidebar items when available folders change useEffect(() => { if (availableFolders.length > 0) { const newItems = [ ...initialSidebarItems, ...availableFolders .filter(folder => !['INBOX'].includes(folder)) // Exclude folders already in initial items .map(folder => ({ view: folder as MailFolder, label: folder.charAt(0).toUpperCase() + folder.slice(1).toLowerCase(), icon: getFolderIcon(folder), folder: folder })) ]; setSidebarItems(newItems); } }, [availableFolders]); // Update the email list item to match header checkbox alignment const renderEmailListItem = (email: Email) => { console.log('=== Email List Item Debug ==='); console.log('Email ID:', email.id); console.log('Subject:', email.subject); console.log('Body length:', email.body.length); console.log('First 100 chars of body:', email.body.substring(0, 100)); const preview = generateEmailPreview(email); console.log('Generated preview:', preview); return (
handleEmailSelect(email.id)} > { const e = { target: { checked }, stopPropagation: () => {} } as React.ChangeEvent; handleEmailCheckbox(e, email.id); }} onClick={(e) => e.stopPropagation()} className="mt-0.5" />
{currentView === 'Sent' ? email.to : ( (() => { const fromMatch = email.from.match(/^([^<]+)\s*<([^>]+)>$/); return fromMatch ? fromMatch[1].trim() : email.from; })() )}
{formatDate(email.date)}

{email.subject || '(No subject)'}

{preview}
); }; const generateEmailPreview = (email: Email): string => { console.log('=== generateEmailPreview Debug ==='); console.log('Email ID:', email.id); console.log('Subject:', email.subject); console.log('Body length:', email.body.length); console.log('First 200 chars of body:', email.body.substring(0, 200)); try { const parsed = parseFullEmail(email.body); console.log('Parsed content:', { hasText: !!parsed.body, hasHtml: !!parsed.headers, textPreview: parsed.body?.substring(0, 100) || 'No text', htmlPreview: parsed.headers?.substring(0, 100) || 'No HTML' }); let preview = ''; if (parsed.body) { preview = parsed.body; console.log('Using text content for preview'); } else if (parsed.headers) { preview = parsed.headers .replace(/]*>[\s\S]*?<\/style>/gi, '') .replace(/]*>[\s\S]*?<\/script>/gi, '') .replace(/<[^>]+>/g, ' ') .replace(/\s+/g, ' ') .trim(); console.log('Using HTML content for preview'); } if (!preview) { console.log('No preview from parsed content, using raw body'); preview = email.body .replace(/<[^>]+>/g, ' ') .replace(/ |‌|»|«|>/g, ' ') .replace(/\s+/g, ' ') .trim(); } console.log('Final preview before cleaning:', preview.substring(0, 100) + '...'); // Clean up the preview preview = preview .replace(/^>+/gm, '') .replace(/Content-Type:[^\n]+/g, '') .replace(/Content-Transfer-Encoding:[^\n]+/g, '') .replace(/--[a-zA-Z0-9]+(-[a-zA-Z0-9]+)?/g, '') .replace(/boundary=[^\n]+/g, '') .replace(/charset=[^\n]+/g, '') .replace(/[\r\n]+/g, ' ') .trim(); // Take first 100 characters preview = preview.substring(0, 100); // Try to end at a complete word if (preview.length === 100) { const lastSpace = preview.lastIndexOf(' '); if (lastSpace > 80) { preview = preview.substring(0, lastSpace); } preview += '...'; } console.log('Final preview:', preview); return preview; } catch (e) { console.error('Error generating preview:', e); return 'No preview available'; } }; // Render the sidebar navigation const renderSidebarNav = () => ( ); // Add attachment handling functions const handleFileAttachment = async (e: React.ChangeEvent) => { if (!e.target.files) return; const newAttachments: Attachment[] = []; const MAX_FILE_SIZE = 10 * 1024 * 1024; // 10MB in bytes const oversizedFiles: string[] = []; for (const file of e.target.files) { if (file.size > MAX_FILE_SIZE) { oversizedFiles.push(file.name); continue; } try { // Read file as base64 const base64Content = await new Promise((resolve) => { const reader = new FileReader(); reader.onloadend = () => { const base64 = reader.result as string; resolve(base64.split(',')[1]); // Remove data URL prefix }; reader.readAsDataURL(file); }); newAttachments.push({ name: file.name, type: file.type, content: base64Content, encoding: 'base64' }); } catch (error) { console.error('Error processing attachment:', error); } } if (oversizedFiles.length > 0) { alert(`The following files exceed the 10MB size limit and were not attached:\n${oversizedFiles.join('\n')}`); } if (newAttachments.length > 0) { setAttachments([...attachments, ...newAttachments]); } }; // Add handleSend function for email composition const handleSend = async () => { if (!composeTo) { alert('Please specify at least one recipient'); return; } try { const response = await fetch('/api/mail/send', { method: 'POST', headers: { 'Content-Type': 'application/json', }, body: JSON.stringify({ to: composeTo, cc: composeCc, bcc: composeBcc, subject: composeSubject, body: composeBody, attachments: attachments, }), }); const data = await response.json(); if (!response.ok) { if (data.error === 'Attachment size limit exceeded') { alert(`Error: ${data.error}\nThe following files are too large:\n${data.details.oversizedFiles.join('\n')}`); } else { alert(`Error sending email: ${data.error}`); } return; } // Clear compose form and close modal setComposeTo(''); setComposeCc(''); setComposeBcc(''); setComposeSubject(''); setComposeBody(''); setAttachments([]); setShowCompose(false); } catch (error) { console.error('Error sending email:', error); alert('Failed to send email. Please try again.'); } }; // Add toggleStarred function const toggleStarred = async (emailId: number, e?: React.MouseEvent) => { if (e) { e.stopPropagation(); } const email = emails.find(e => e.id === emailId); if (!email) return; try { const response = await fetch('/api/mail/toggle-star', { method: 'POST', headers: { 'Content-Type': 'application/json', }, body: JSON.stringify({ emailId, starred: !email.starred }), }); if (!response.ok) { throw new Error('Failed to toggle star'); } // Update email in state setEmails(emails.map(e => e.id === emailId ? { ...e, starred: !e.starred } : e )); } catch (error) { console.error('Error toggling star:', error); } }; // Add handleReply function const handleReply = async (type: 'reply' | 'replyAll' | 'forward') => { // First, ensure we have the full email content if (!selectedEmail) { setError('No email selected'); return; } if (!selectedEmail.body) { try { // Fetch the full email content const response = await fetch(`/api/mail/${selectedEmail.id}`); if (!response.ok) { throw new Error('Failed to fetch email content'); } const emailData = await response.json(); // Update the selected email with the full content setSelectedEmail(prev => { if (!prev) return null; return { ...prev, body: emailData.body, to: emailData.to, cc: emailData.cc, bcc: emailData.bcc }; }); } catch (error) { console.error('Error fetching email content:', error); setError('Failed to load email content. Please try again.'); return; } } // Helper functions for reply composition const getReplySubject = (): string => { if (!selectedEmail) return ''; const prefix = type === 'forward' ? 'Fwd:' : 'Re:'; return `${prefix} ${selectedEmail.subject}`; }; const getReplyTo = (): string => { if (!selectedEmail) return ''; if (type === 'forward') return ''; return selectedEmail.from; }; const getReplyCc = (): string => { if (!selectedEmail) return ''; if (type === 'forward' || type === 'reply') return ''; return selectedEmail.cc || ''; }; const getReplyBody = () => { if (!selectedEmail?.body) return ''; const parsed = parseFullEmail(selectedEmail.body); if (!parsed) return ''; const body = parsed.body; // Convert HTML to plain text if needed const plainText = body .replace(//gi, '\n') .replace(/]*>/gi, '\n') .replace(/<\/div>/gi, '') .replace(/]*>/gi, '\n') .replace(/<\/p>/gi, '') .replace(/ /g, ' ') .replace(/>/g, '>') .replace(/</g, '<') .replace(/&/g, '&') .replace(/"/g, '"') .replace(/<[^>]+>/g, '') .replace(/^\s+$/gm, '') .replace(/\n{3,}/g, '\n\n') .trim(); // Add reply prefix to each line return plainText .split('\n') .map(line => `> ${line}`) .join('\n'); }; // Prepare the reply email const replyEmail = { to: getReplyTo(), cc: getReplyCc(), subject: getReplySubject(), body: getReplyBody() }; // Update the compose form with the reply content setComposeTo(replyEmail.to); setComposeCc(replyEmail.cc); setComposeSubject(replyEmail.subject); setComposeBody(replyEmail.body); setComposeBcc(''); // Show the compose form and CC field for Reply All setShowCompose(true); setShowCc(type === 'replyAll'); setShowBcc(false); setAttachments([]); }; // Add the confirmation dialog component const renderDeleteConfirmDialog = () => ( Delete Emails Are you sure you want to delete {selectedEmails.length} selected email{selectedEmails.length > 1 ? 's' : ''}? This action cannot be undone. Cancel Delete ); const handleMailboxChange = async (newMailbox: string) => { setCurrentView(newMailbox); setSelectedEmails([]); setSearchQuery(''); setEmails([]); setLoading(true); setError(null); setHasMore(true); setPage(1); try { // Optimize the request by adding a timeout const controller = new AbortController(); const timeoutId = setTimeout(() => controller.abort(), 10000); // 10 second timeout const response = await fetch(`/api/mail?folder=${encodeURIComponent(newMailbox)}&page=1&limit=${emailsPerPage}`, { signal: controller.signal }); clearTimeout(timeoutId); if (!response.ok) { throw new Error('Failed to fetch emails'); } const data = await response.json(); // Process emails more efficiently const processedEmails = data.emails.map((email: any) => ({ id: Number(email.id), accountId: 1, from: email.from || '', fromName: email.from?.split('@')[0] || '', to: email.to || '', subject: email.subject || '(No subject)', body: email.body || '', date: email.date || new Date().toISOString(), read: email.read || false, starred: email.starred || false, folder: email.folder || newMailbox, cc: email.cc, bcc: email.bcc, flags: email.flags || [] })); setEmails(processedEmails); setHasMore(processedEmails.length === emailsPerPage); // Only update unread count if we're in the Inbox folder if (newMailbox === 'INBOX') { const unreadInboxEmails = processedEmails.filter( (email: Email) => !email.read && email.folder === 'INBOX' ).length; setUnreadCount(unreadInboxEmails); } } catch (err) { if (err instanceof Error) { if (err.name === 'AbortError') { setError('Request timed out. Please try again.'); } else { setError(err.message); } } else { setError('Failed to fetch emails'); } } finally { setLoading(false); } }; if (error) { return (

{error}

); } return ( <> {/* Main layout */}
{/* Sidebar */}
{/* Courrier Title */}
COURRIER
{/* Compose button and refresh button */}
{/* Accounts Section */}
{accountsDropdownOpen && (
{accounts.map(account => (
))}
)}
{/* Navigation */} {renderSidebarNav()}
{/* Main content area */}
{/* Email list panel */} {renderEmailListWrapper()}
{/* Compose Email Modal */} {showCompose && (
{/* Modal Header */}

{composeSubject.startsWith('Re:') ? 'Reply' : composeSubject.startsWith('Fwd:') ? 'Forward' : 'New Message'}

{/* Modal Body */}
{/* To Field */}
setComposeTo(e.target.value)} placeholder="recipient@example.com" className="w-full mt-1 bg-white border-gray-300 text-gray-900" />
{/* CC/BCC Toggle Buttons */}
{/* CC Field */} {showCc && (
setComposeCc(e.target.value)} placeholder="cc@example.com" className="w-full mt-1 bg-white border-gray-300 text-gray-900" />
)} {/* BCC Field */} {showBcc && (
setComposeBcc(e.target.value)} placeholder="bcc@example.com" className="w-full mt-1 bg-white border-gray-300 text-gray-900" />
)} {/* Subject Field */}
setComposeSubject(e.target.value)} placeholder="Enter subject" className="w-full mt-1 bg-white border-gray-300 text-gray-900" />
{/* Message Body */}