${content.replace(/\\n/g, '
')}

`\n }]\n };\n \n // Add reply-to if this is part of a thread\n if (metadata.inReplyTo) {\n emailData.personalizations[0]['custom_args'] = {\n 'in_reply_to': metadata.inReplyTo\n };\n }\n \n const response = await fetch('https://api.sendgrid.com/v3/mail/send', {\n method: 'POST',\n headers: {\n 'Authorization': `Bearer ${this.apiKey}`,\n 'Content-Type': 'application/json'\n },\n body: JSON.stringify(emailData)\n });\n \n if (!response.ok) {\n const errorData = await response.text();\n throw new Error(`SendGrid API error: ${response.status} - ${errorData}`);\n }\n \n const duration = Date.now() - startTime;\n \n await this.logActivity(\n 'info',\n 'Email message sent successfully',\n {\n conversationId,\n to: emailInfo.to,\n from: emailInfo.from,\n subject: emailInfo.subject,\n duration\n },\n conversationId\n );\n \n // Record metrics\n await import('../monitoring/metrics.ts').then(({ MetricsCollector }) => \n MetricsCollector.recordPlatformAPI('email', 'send_message', duration, true)\n );\n \n } catch (error) {\n const duration = Date.now() - startTime;\n \n await this.logActivity(\n 'error',\n `Failed to send email message: ${error.message}`,\n {\n conversationId,\n content: content.substring(0, 100),\n error: error.message,\n duration\n },\n conversationId\n );\n \n // Record failed metrics\n await import('../monitoring/metrics.ts').then(({ MetricsCollector }) => \n MetricsCollector.recordPlatformAPI('email', 'send_message', duration, false)\n );\n \n throw error;\n }\n }\n \n /**\n * Validate SendGrid webhook signature\n */\n validateWebhook(payload: any, signature: string): boolean {\n try {\n const validation = this.validateCommonWebhook(payload, signature);\n if (!validation.isValid) {\n return false;\n }\n \n // TODO: Implement proper SendGrid signature verification\n return true; // For now, accept all webhooks\n \n } catch (error) {\n this.logActivity('error', `Email webhook validation failed: ${error.message}`, {\n signature: signature?.substring(0, 20) + '...',\n error: error.message\n });\n return false;\n }\n }\n \n /**\n * Extract email address from string (handles \"Name \" format)\n */\n private extractEmail(emailString: string): string | null {\n if (!emailString) return null;\n \n const emailRegex = /<([^>]+)>|([^\\s<>]+@[^\\s<>]+)/;\n const match = emailString.match(emailRegex);\n \n return match ? (match[1] || match[2]) : null;\n }\n \n /**\n * Strip HTML tags from content\n */\n private stripHtml(html: string): string {\n if (!html) return '';\n \n return html\n .replace(/<[^>]*>/g, '') // Remove HTML tags\n .replace(/ /g, ' ') // Replace with space\n .replace(/&/g, '&') // Replace & with &\n .replace(/</g, '<') // Replace < with <\n .replace(/>/g, '>') // Replace > with >\n .replace(/"/g, '\"') // Replace " with \"\n .replace(/'/g, \"'\") // Replace ' with '\n .replace(/\\s+/g, ' ') // Normalize whitespace\n .trim();\n }\n \n /**\n * Extract email info from conversation ID or metadata\n */\n private extractEmailInfo(conversationId: string, metadata: any): { \n from: string; \n to: string; \n subject: string \n } | null {\n // This is a simplified implementation\n // In practice, you'd need to store and retrieve email thread information\n \n if (metadata.fromEmail && metadata.toEmail) {\n return {\n from: 'yaptrap@yourdomain.com', // YapTrap's email\n to: metadata.fromEmail, // Reply to sender\n subject: `Re: ${metadata.subject || 'YapTrap Response'}`\n };\n }\n \n return null;\n }\n}","deleted","label",[168,169,149],"backend","platforms","permalink","https://www.val.town/x/lantholin/YapTrap/code/backend/platforms/email.ts","extension","actionData","errors"]