import { simpleParser } from 'mailparser'; function cleanHtml(html: string): string { try { // Basic HTML cleaning without DOMPurify return html .replace(/)<[^<]*)*<\/script>/gi, '') // Remove script tags .replace(/)<[^<]*)*<\/style>/gi, '') // Remove style tags .replace(/]*>/gi, '') // Remove meta tags .replace(/]*>[\s\S]*?<\/head>/gi, '') // Remove head .replace(/]*>[\s\S]*?<\/title>/gi, '') // Remove title .replace(/]*>/gi, '') // Remove body opening tag .replace(/<\/body>/gi, '') // Remove body closing tag .replace(/]*>/gi, '') // Remove html opening tag .replace(/<\/html>/gi, '') // Remove html closing tag .replace(/\s+/g, ' ') // Clean up whitespace .trim(); } catch (error) { console.error('Error cleaning HTML:', error); return html; } } function getAddressText(address: any): string | null { if (!address) return null; if (Array.isArray(address)) { return address.map(addr => addr.value?.[0]?.address || '').filter(Boolean).join(', '); } return address.value?.[0]?.address || null; } export async function parseEmail(emailContent: string) { try { const parsed = await simpleParser(emailContent); return { subject: parsed.subject || null, from: getAddressText(parsed.from), to: getAddressText(parsed.to), cc: getAddressText(parsed.cc), bcc: getAddressText(parsed.bcc), date: parsed.date || null, html: parsed.html ? cleanHtml(parsed.html) : null, text: parsed.text || null, attachments: parsed.attachments || [], headers: Object.fromEntries(parsed.headers) }; } catch (error) { console.error('Error parsing email:', error); throw error; } }