mirror of
https://github.com/xtr-dev/payload-mailing.git
synced 2025-12-10 08:13:23 +00:00
Compare commits
22 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
5905f732de | ||
| 4c495a72b0 | |||
| 8518c716e8 | |||
| 570190be01 | |||
|
|
685875d1b9 | ||
| 79044b7bc3 | |||
| e7304fe1a2 | |||
| 790eedfee7 | |||
| 9520ec5ed1 | |||
|
|
768b70a003 | ||
| e91ab7e54e | |||
| 06f9c2cb5b | |||
|
|
21b22a033a | ||
| 6ad90874cf | |||
|
|
03f1f62fbf | ||
| e55e4197d3 | |||
| 2e6feccf54 | |||
|
|
e38b63d814 | ||
| 31721dc110 | |||
| 6e4f754306 | |||
| 45559804b0 | |||
| 934b7c2de7 |
88
CUSTOM-TYPES.md
Normal file
88
CUSTOM-TYPES.md
Normal file
@@ -0,0 +1,88 @@
|
|||||||
|
# Using Custom ID Types
|
||||||
|
|
||||||
|
The mailing plugin now supports both `string` and `number` ID types. By default, it works with the generic `BaseEmailDocument` interface, but you can provide your own types for full type safety.
|
||||||
|
|
||||||
|
## Usage with Your Generated Types
|
||||||
|
|
||||||
|
When you have your own generated Payload types (e.g., from `payload generate:types`), you can use them with the mailing plugin:
|
||||||
|
|
||||||
|
```typescript
|
||||||
|
import { sendEmail, BaseEmailDocument } from '@xtr-dev/payload-mailing'
|
||||||
|
import { Email } from './payload-types' // Your generated types
|
||||||
|
|
||||||
|
// Option 1: Use your specific Email type
|
||||||
|
const email = await sendEmail<Email>(payload, {
|
||||||
|
template: {
|
||||||
|
slug: 'welcome',
|
||||||
|
variables: { name: 'John' }
|
||||||
|
},
|
||||||
|
data: {
|
||||||
|
to: 'user@example.com',
|
||||||
|
// All your custom fields are now type-safe
|
||||||
|
}
|
||||||
|
})
|
||||||
|
|
||||||
|
// Option 2: Extend BaseEmailDocument for custom fields
|
||||||
|
interface MyEmail extends BaseEmailDocument {
|
||||||
|
customField: string
|
||||||
|
anotherField?: number
|
||||||
|
}
|
||||||
|
|
||||||
|
const customEmail = await sendEmail<MyEmail>(payload, {
|
||||||
|
data: {
|
||||||
|
to: 'user@example.com',
|
||||||
|
subject: 'Hello',
|
||||||
|
html: '<p>Hello World</p>',
|
||||||
|
customField: 'my value', // Type-safe!
|
||||||
|
}
|
||||||
|
})
|
||||||
|
```
|
||||||
|
|
||||||
|
## ID Type Compatibility
|
||||||
|
|
||||||
|
The plugin works with both:
|
||||||
|
- **String IDs**: `id: string`
|
||||||
|
- **Number IDs**: `id: number`
|
||||||
|
|
||||||
|
Your Payload configuration determines which type is used. The plugin automatically adapts to your setup.
|
||||||
|
|
||||||
|
## Type Definitions
|
||||||
|
|
||||||
|
The base interfaces provided by the plugin:
|
||||||
|
|
||||||
|
```typescript
|
||||||
|
interface BaseEmailDocument {
|
||||||
|
id: string | number
|
||||||
|
template?: any
|
||||||
|
to: string[]
|
||||||
|
cc?: string[]
|
||||||
|
bcc?: string[]
|
||||||
|
from?: string
|
||||||
|
replyTo?: string
|
||||||
|
subject: string
|
||||||
|
html: string
|
||||||
|
text?: string
|
||||||
|
variables?: Record<string, any>
|
||||||
|
scheduledAt?: string
|
||||||
|
sentAt?: string
|
||||||
|
status?: 'pending' | 'processing' | 'sent' | 'failed'
|
||||||
|
attempts?: number
|
||||||
|
lastAttemptAt?: string
|
||||||
|
error?: string
|
||||||
|
priority?: number
|
||||||
|
createdAt?: string
|
||||||
|
updatedAt?: string
|
||||||
|
}
|
||||||
|
|
||||||
|
interface BaseEmailTemplateDocument {
|
||||||
|
id: string | number
|
||||||
|
name: string
|
||||||
|
slug: string
|
||||||
|
subject?: string
|
||||||
|
content?: any
|
||||||
|
createdAt?: string
|
||||||
|
updatedAt?: string
|
||||||
|
}
|
||||||
|
```
|
||||||
|
|
||||||
|
These provide a foundation that works with any ID type while maintaining type safety for the core email functionality.
|
||||||
282
README.md
282
README.md
@@ -139,10 +139,6 @@ mailingPlugin({
|
|||||||
retryDelay: 300000, // 5 minutes (default)
|
retryDelay: 300000, // 5 minutes (default)
|
||||||
|
|
||||||
// Advanced options
|
// Advanced options
|
||||||
emailWrapper: (email) => ({ // optional layout wrapper
|
|
||||||
...email,
|
|
||||||
html: `<html><body>${email.html}</body></html>`
|
|
||||||
}),
|
|
||||||
richTextEditor: lexicalEditor(), // optional custom editor
|
richTextEditor: lexicalEditor(), // optional custom editor
|
||||||
onReady: async (payload) => { // optional initialization hook
|
onReady: async (payload) => { // optional initialization hook
|
||||||
console.log('Mailing plugin ready!')
|
console.log('Mailing plugin ready!')
|
||||||
@@ -227,7 +223,7 @@ Thanks for joining {{siteName}}. We're excited to have you!
|
|||||||
|
|
||||||
**What you can do:**
|
**What you can do:**
|
||||||
• Create beautiful emails with rich text formatting
|
• Create beautiful emails with rich text formatting
|
||||||
• Use the emailWrapper hook to add custom layouts
|
|
||||||
• Queue and schedule emails effortlessly
|
• Queue and schedule emails effortlessly
|
||||||
|
|
||||||
Your account was created on {{formatDate createdAt "long"}}.
|
Your account was created on {{formatDate createdAt "long"}}.
|
||||||
@@ -238,282 +234,6 @@ The {{siteName}} Team
|
|||||||
|
|
||||||
## Advanced Features
|
## Advanced Features
|
||||||
|
|
||||||
### Custom HTML Layouts with Email Wrapper Hook
|
|
||||||
|
|
||||||
The `emailWrapper` hook allows you to apply consistent HTML layouts and styling to all emails sent through the plugin. This is perfect for adding company branding, headers, footers, and responsive styling.
|
|
||||||
|
|
||||||
#### Basic Email Wrapper
|
|
||||||
|
|
||||||
```typescript
|
|
||||||
mailingPlugin({
|
|
||||||
// ... other config
|
|
||||||
emailWrapper: (email) => {
|
|
||||||
const wrappedHtml = `
|
|
||||||
<!DOCTYPE html>
|
|
||||||
<html>
|
|
||||||
<head>
|
|
||||||
<meta charset="utf-8">
|
|
||||||
<meta name="viewport" content="width=device-width, initial-scale=1">
|
|
||||||
<title>${email.subject}</title>
|
|
||||||
<style>
|
|
||||||
body { font-family: Arial, sans-serif; margin: 0; padding: 20px; background-color: #f4f4f4; }
|
|
||||||
.container { max-width: 600px; margin: 0 auto; background: white; border-radius: 8px; overflow: hidden; }
|
|
||||||
.header { background: #007bff; color: white; padding: 20px; text-align: center; }
|
|
||||||
.content { padding: 30px; line-height: 1.6; }
|
|
||||||
.footer { background: #f8f9fa; padding: 15px; text-align: center; color: #6c757d; font-size: 14px; }
|
|
||||||
|
|
||||||
/* Responsive styles */
|
|
||||||
@media only screen and (max-width: 600px) {
|
|
||||||
.container { margin: 0 10px; }
|
|
||||||
.content { padding: 20px; }
|
|
||||||
}
|
|
||||||
</style>
|
|
||||||
</head>
|
|
||||||
<body>
|
|
||||||
<div class="container">
|
|
||||||
<div class="header">
|
|
||||||
<h1>My Company</h1>
|
|
||||||
</div>
|
|
||||||
<div class="content">
|
|
||||||
${email.html}
|
|
||||||
</div>
|
|
||||||
<div class="footer">
|
|
||||||
© 2024 My Company. All rights reserved.<br>
|
|
||||||
<a href="#" style="color: #007bff;">Unsubscribe</a> |
|
|
||||||
<a href="#" style="color: #007bff;">Contact Support</a>
|
|
||||||
</div>
|
|
||||||
</div>
|
|
||||||
</body>
|
|
||||||
</html>
|
|
||||||
`
|
|
||||||
|
|
||||||
return {
|
|
||||||
...email,
|
|
||||||
html: wrappedHtml,
|
|
||||||
text: `MY COMPANY\n\n${email.text}\n\n© 2024 My Company\nUnsubscribe: [link] | Contact Support: [link]`
|
|
||||||
}
|
|
||||||
}
|
|
||||||
})
|
|
||||||
```
|
|
||||||
|
|
||||||
#### Advanced Email Wrapper with Dynamic Content
|
|
||||||
|
|
||||||
```typescript
|
|
||||||
mailingPlugin({
|
|
||||||
// ... other config
|
|
||||||
emailWrapper: (email) => {
|
|
||||||
// You can access email properties and customize based on content
|
|
||||||
const isTransactional = email.subject?.includes('Receipt') || email.subject?.includes('Confirmation');
|
|
||||||
const headerColor = isTransactional ? '#28a745' : '#007bff';
|
|
||||||
const headerText = isTransactional ? 'Order Confirmation' : 'My Company';
|
|
||||||
|
|
||||||
const wrappedHtml = `
|
|
||||||
<!DOCTYPE html>
|
|
||||||
<html lang="en">
|
|
||||||
<head>
|
|
||||||
<meta charset="utf-8">
|
|
||||||
<meta name="viewport" content="width=device-width, initial-scale=1">
|
|
||||||
<meta http-equiv="X-UA-Compatible" content="IE=edge">
|
|
||||||
<title>${email.subject}</title>
|
|
||||||
<!--[if mso]>
|
|
||||||
<noscript>
|
|
||||||
<xml>
|
|
||||||
<o:OfficeDocumentSettings>
|
|
||||||
<o:PixelsPerInch>96</o:PixelsPerInch>
|
|
||||||
</o:OfficeDocumentSettings>
|
|
||||||
</xml>
|
|
||||||
</noscript>
|
|
||||||
<![endif]-->
|
|
||||||
<style>
|
|
||||||
/* Reset styles */
|
|
||||||
body, table, td, a { -webkit-text-size-adjust: 100%; -ms-text-size-adjust: 100%; }
|
|
||||||
table, td { mso-table-lspace: 0pt; mso-table-rspace: 0pt; }
|
|
||||||
img { -ms-interpolation-mode: bicubic; border: 0; outline: none; text-decoration: none; }
|
|
||||||
|
|
||||||
/* Base styles */
|
|
||||||
body {
|
|
||||||
margin: 0 !important;
|
|
||||||
padding: 0 !important;
|
|
||||||
background-color: #f4f4f4;
|
|
||||||
font-family: 'Segoe UI', Tahoma, Geneva, Verdana, sans-serif;
|
|
||||||
}
|
|
||||||
|
|
||||||
.email-container {
|
|
||||||
max-width: 600px;
|
|
||||||
margin: 0 auto;
|
|
||||||
background-color: #ffffff;
|
|
||||||
border-radius: 8px;
|
|
||||||
overflow: hidden;
|
|
||||||
box-shadow: 0 2px 10px rgba(0,0,0,0.1);
|
|
||||||
}
|
|
||||||
|
|
||||||
.email-header {
|
|
||||||
background: linear-gradient(135deg, ${headerColor}, ${headerColor}dd);
|
|
||||||
color: white;
|
|
||||||
padding: 30px 20px;
|
|
||||||
text-align: center;
|
|
||||||
}
|
|
||||||
|
|
||||||
.email-content {
|
|
||||||
padding: 30px;
|
|
||||||
color: #333333;
|
|
||||||
line-height: 1.6;
|
|
||||||
}
|
|
||||||
|
|
||||||
.email-footer {
|
|
||||||
background-color: #f8f9fa;
|
|
||||||
padding: 20px;
|
|
||||||
text-align: center;
|
|
||||||
color: #6c757d;
|
|
||||||
font-size: 14px;
|
|
||||||
border-top: 1px solid #e9ecef;
|
|
||||||
}
|
|
||||||
|
|
||||||
.email-footer a {
|
|
||||||
color: ${headerColor};
|
|
||||||
text-decoration: none;
|
|
||||||
}
|
|
||||||
|
|
||||||
/* Responsive */
|
|
||||||
@media only screen and (max-width: 600px) {
|
|
||||||
.email-container {
|
|
||||||
margin: 0 10px !important;
|
|
||||||
}
|
|
||||||
.email-header, .email-content {
|
|
||||||
padding: 20px !important;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
</style>
|
|
||||||
</head>
|
|
||||||
<body>
|
|
||||||
<div class="email-container">
|
|
||||||
<div class="email-header">
|
|
||||||
<h1 style="margin: 0; font-size: 24px;">${headerText}</h1>
|
|
||||||
</div>
|
|
||||||
<div class="email-content">
|
|
||||||
${email.html}
|
|
||||||
</div>
|
|
||||||
<div class="email-footer">
|
|
||||||
<p style="margin: 0 0 10px;">© ${new Date().getFullYear()} My Company. All rights reserved.</p>
|
|
||||||
<p style="margin: 0;">
|
|
||||||
<a href="mailto:support@mycompany.com">Contact Support</a> |
|
|
||||||
<a href="#">Privacy Policy</a> |
|
|
||||||
<a href="#">Unsubscribe</a>
|
|
||||||
</p>
|
|
||||||
</div>
|
|
||||||
</div>
|
|
||||||
</body>
|
|
||||||
</html>
|
|
||||||
`
|
|
||||||
|
|
||||||
// Also enhance the plain text version
|
|
||||||
const wrappedText = `
|
|
||||||
${headerText.toUpperCase()}
|
|
||||||
${'='.repeat(headerText.length)}
|
|
||||||
|
|
||||||
${email.text || email.html?.replace(/<[^>]*>/g, '')}
|
|
||||||
|
|
||||||
---
|
|
||||||
© ${new Date().getFullYear()} My Company. All rights reserved.
|
|
||||||
Contact Support: support@mycompany.com
|
|
||||||
Privacy Policy: [link]
|
|
||||||
Unsubscribe: [link]
|
|
||||||
`.trim();
|
|
||||||
|
|
||||||
return {
|
|
||||||
...email,
|
|
||||||
html: wrappedHtml,
|
|
||||||
text: wrappedText
|
|
||||||
}
|
|
||||||
}
|
|
||||||
})
|
|
||||||
```
|
|
||||||
|
|
||||||
#### External CSS and Assets
|
|
||||||
|
|
||||||
You can also reference external stylesheets and assets:
|
|
||||||
|
|
||||||
```typescript
|
|
||||||
mailingPlugin({
|
|
||||||
emailWrapper: (email) => {
|
|
||||||
const wrappedHtml = `
|
|
||||||
<!DOCTYPE html>
|
|
||||||
<html>
|
|
||||||
<head>
|
|
||||||
<meta charset="utf-8">
|
|
||||||
<meta name="viewport" content="width=device-width, initial-scale=1">
|
|
||||||
<title>${email.subject}</title>
|
|
||||||
<!-- External CSS -->
|
|
||||||
<link href="https://fonts.googleapis.com/css2?family=Inter:wght@400;600&display=swap" rel="stylesheet">
|
|
||||||
<style>
|
|
||||||
body { font-family: 'Inter', sans-serif; }
|
|
||||||
/* Your custom styles here */
|
|
||||||
</style>
|
|
||||||
</head>
|
|
||||||
<body>
|
|
||||||
<div style="max-width: 600px; margin: 0 auto;">
|
|
||||||
<img src="https://mycompany.com/email-header.png" alt="My Company" style="width: 100%; height: auto;">
|
|
||||||
<div style="padding: 20px;">
|
|
||||||
${email.html}
|
|
||||||
</div>
|
|
||||||
<img src="https://mycompany.com/email-footer.png" alt="Footer" style="width: 100%; height: auto;">
|
|
||||||
</div>
|
|
||||||
</body>
|
|
||||||
</html>
|
|
||||||
`;
|
|
||||||
|
|
||||||
return { ...email, html: wrappedHtml };
|
|
||||||
}
|
|
||||||
})
|
|
||||||
```
|
|
||||||
|
|
||||||
#### Template-Specific Layouts
|
|
||||||
|
|
||||||
You can customize layouts based on email templates:
|
|
||||||
|
|
||||||
```typescript
|
|
||||||
mailingPlugin({
|
|
||||||
emailWrapper: (email, context) => {
|
|
||||||
// Access template information if available
|
|
||||||
const templateSlug = context?.templateSlug;
|
|
||||||
|
|
||||||
let layoutClass = 'default-layout';
|
|
||||||
let headerColor = '#007bff';
|
|
||||||
|
|
||||||
if (templateSlug === 'welcome-email') {
|
|
||||||
layoutClass = 'welcome-layout';
|
|
||||||
headerColor = '#28a745';
|
|
||||||
} else if (templateSlug === 'invoice-email') {
|
|
||||||
layoutClass = 'invoice-layout';
|
|
||||||
headerColor = '#dc3545';
|
|
||||||
}
|
|
||||||
|
|
||||||
const wrappedHtml = `
|
|
||||||
<!DOCTYPE html>
|
|
||||||
<html>
|
|
||||||
<head>
|
|
||||||
<meta charset="utf-8">
|
|
||||||
<title>${email.subject}</title>
|
|
||||||
<style>
|
|
||||||
.${layoutClass} { /* template-specific styles */ }
|
|
||||||
.header { background-color: ${headerColor}; }
|
|
||||||
</style>
|
|
||||||
</head>
|
|
||||||
<body>
|
|
||||||
<div class="${layoutClass}">
|
|
||||||
${email.html}
|
|
||||||
</div>
|
|
||||||
</body>
|
|
||||||
</html>
|
|
||||||
`;
|
|
||||||
|
|
||||||
return { ...email, html: wrappedHtml };
|
|
||||||
}
|
|
||||||
})
|
|
||||||
```
|
|
||||||
|
|
||||||
The `emailWrapper` hook receives the email object with `html`, `text`, and `subject` properties, and should return the modified email object with your custom layout applied.
|
|
||||||
|
|
||||||
### Custom Rich Text Editor
|
### Custom Rich Text Editor
|
||||||
|
|
||||||
Override the rich text editor used for templates:
|
Override the rich text editor used for templates:
|
||||||
|
|||||||
@@ -100,7 +100,8 @@ export interface Config {
|
|||||||
};
|
};
|
||||||
jobs: {
|
jobs: {
|
||||||
tasks: {
|
tasks: {
|
||||||
'process-email-queue': ProcessEmailQueueJob;
|
processEmails: ProcessEmailsJob;
|
||||||
|
'send-email': TaskSendEmail;
|
||||||
inline: {
|
inline: {
|
||||||
input: unknown;
|
input: unknown;
|
||||||
output: unknown;
|
output: unknown;
|
||||||
@@ -232,21 +233,17 @@ export interface Email {
|
|||||||
*/
|
*/
|
||||||
template?: (string | null) | EmailTemplate;
|
template?: (string | null) | EmailTemplate;
|
||||||
/**
|
/**
|
||||||
* Template slug used for this email
|
* Recipient email addresses
|
||||||
*/
|
*/
|
||||||
templateSlug?: string | null;
|
to: string[];
|
||||||
/**
|
/**
|
||||||
* Recipient email address(es), comma-separated
|
* CC email addresses
|
||||||
*/
|
*/
|
||||||
to: string;
|
cc?: string[] | null;
|
||||||
/**
|
/**
|
||||||
* CC email address(es), comma-separated
|
* BCC email addresses
|
||||||
*/
|
*/
|
||||||
cc?: string | null;
|
bcc?: string[] | null;
|
||||||
/**
|
|
||||||
* BCC email address(es), comma-separated
|
|
||||||
*/
|
|
||||||
bcc?: string | null;
|
|
||||||
/**
|
/**
|
||||||
* Sender email address (optional, uses default if not provided)
|
* Sender email address (optional, uses default if not provided)
|
||||||
*/
|
*/
|
||||||
@@ -362,7 +359,7 @@ export interface PayloadJob {
|
|||||||
| {
|
| {
|
||||||
executedAt: string;
|
executedAt: string;
|
||||||
completedAt: string;
|
completedAt: string;
|
||||||
taskSlug: 'inline' | 'process-email-queue';
|
taskSlug: 'inline' | 'processEmails' | 'send-email';
|
||||||
taskID: string;
|
taskID: string;
|
||||||
input?:
|
input?:
|
||||||
| {
|
| {
|
||||||
@@ -395,7 +392,7 @@ export interface PayloadJob {
|
|||||||
id?: string | null;
|
id?: string | null;
|
||||||
}[]
|
}[]
|
||||||
| null;
|
| null;
|
||||||
taskSlug?: ('inline' | 'process-email-queue') | null;
|
taskSlug?: ('inline' | 'processEmails' | 'send-email') | null;
|
||||||
queue?: string | null;
|
queue?: string | null;
|
||||||
waitUntil?: string | null;
|
waitUntil?: string | null;
|
||||||
processing?: boolean | null;
|
processing?: boolean | null;
|
||||||
@@ -542,7 +539,6 @@ export interface EmailTemplatesSelect<T extends boolean = true> {
|
|||||||
*/
|
*/
|
||||||
export interface EmailsSelect<T extends boolean = true> {
|
export interface EmailsSelect<T extends boolean = true> {
|
||||||
template?: T;
|
template?: T;
|
||||||
templateSlug?: T;
|
|
||||||
to?: T;
|
to?: T;
|
||||||
cc?: T;
|
cc?: T;
|
||||||
bcc?: T;
|
bcc?: T;
|
||||||
@@ -627,12 +623,69 @@ export interface PayloadMigrationsSelect<T extends boolean = true> {
|
|||||||
}
|
}
|
||||||
/**
|
/**
|
||||||
* This interface was referenced by `Config`'s JSON-Schema
|
* This interface was referenced by `Config`'s JSON-Schema
|
||||||
* via the `definition` "ProcessEmailQueueJob".
|
* via the `definition` "ProcessEmailsJob".
|
||||||
*/
|
*/
|
||||||
export interface ProcessEmailQueueJob {
|
export interface ProcessEmailsJob {
|
||||||
input?: unknown;
|
input?: unknown;
|
||||||
output?: unknown;
|
output?: unknown;
|
||||||
}
|
}
|
||||||
|
/**
|
||||||
|
* This interface was referenced by `Config`'s JSON-Schema
|
||||||
|
* via the `definition` "TaskSend-email".
|
||||||
|
*/
|
||||||
|
export interface TaskSendEmail {
|
||||||
|
input: {
|
||||||
|
/**
|
||||||
|
* Use a template (leave empty for direct email)
|
||||||
|
*/
|
||||||
|
templateSlug?: string | null;
|
||||||
|
/**
|
||||||
|
* JSON object with variables for template rendering
|
||||||
|
*/
|
||||||
|
variables?:
|
||||||
|
| {
|
||||||
|
[k: string]: unknown;
|
||||||
|
}
|
||||||
|
| unknown[]
|
||||||
|
| string
|
||||||
|
| number
|
||||||
|
| boolean
|
||||||
|
| null;
|
||||||
|
/**
|
||||||
|
* Email subject (required if not using template)
|
||||||
|
*/
|
||||||
|
subject?: string | null;
|
||||||
|
/**
|
||||||
|
* HTML email content (required if not using template)
|
||||||
|
*/
|
||||||
|
html?: string | null;
|
||||||
|
/**
|
||||||
|
* Plain text email content (optional)
|
||||||
|
*/
|
||||||
|
text?: string | null;
|
||||||
|
/**
|
||||||
|
* Comma-separated list of email addresses
|
||||||
|
*/
|
||||||
|
to: string;
|
||||||
|
/**
|
||||||
|
* Optional comma-separated list of CC email addresses
|
||||||
|
*/
|
||||||
|
cc?: string | null;
|
||||||
|
/**
|
||||||
|
* Optional comma-separated list of BCC email addresses
|
||||||
|
*/
|
||||||
|
bcc?: string | null;
|
||||||
|
/**
|
||||||
|
* Optional date/time to schedule email for future delivery
|
||||||
|
*/
|
||||||
|
scheduledAt?: string | null;
|
||||||
|
/**
|
||||||
|
* Email priority (1 = highest, 10 = lowest)
|
||||||
|
*/
|
||||||
|
priority?: number | null;
|
||||||
|
};
|
||||||
|
output?: unknown;
|
||||||
|
}
|
||||||
/**
|
/**
|
||||||
* This interface was referenced by `Config`'s JSON-Schema
|
* This interface was referenced by `Config`'s JSON-Schema
|
||||||
* via the `definition` "auth".
|
* via the `definition` "auth".
|
||||||
|
|||||||
@@ -1,12 +1,10 @@
|
|||||||
import { mongooseAdapter } from '@payloadcms/db-mongodb'
|
import { mongooseAdapter } from '@payloadcms/db-mongodb'
|
||||||
import { lexicalEditor } from '@payloadcms/richtext-lexical'
|
import { lexicalEditor } from '@payloadcms/richtext-lexical'
|
||||||
import {
|
import {
|
||||||
BlocksFeature,
|
|
||||||
FixedToolbarFeature,
|
FixedToolbarFeature,
|
||||||
HeadingFeature,
|
HeadingFeature,
|
||||||
HorizontalRuleFeature,
|
HorizontalRuleFeature,
|
||||||
InlineToolbarFeature,
|
InlineToolbarFeature,
|
||||||
lexicalHTML,
|
|
||||||
} from '@payloadcms/richtext-lexical'
|
} from '@payloadcms/richtext-lexical'
|
||||||
import { MongoMemoryReplSet } from 'mongodb-memory-server'
|
import { MongoMemoryReplSet } from 'mongodb-memory-server'
|
||||||
import path from 'path'
|
import path from 'path'
|
||||||
@@ -17,7 +15,7 @@ import { fileURLToPath } from 'url'
|
|||||||
import { testEmailAdapter } from './helpers/testEmailAdapter.js'
|
import { testEmailAdapter } from './helpers/testEmailAdapter.js'
|
||||||
import { seed, seedUser } from './seed.js'
|
import { seed, seedUser } from './seed.js'
|
||||||
import mailingPlugin from "../src/plugin.js"
|
import mailingPlugin from "../src/plugin.js"
|
||||||
import { sendEmail } from "../src/utils/helpers.js"
|
import {sendEmail} from "@xtr-dev/payload-mailing"
|
||||||
|
|
||||||
const filename = fileURLToPath(import.meta.url)
|
const filename = fileURLToPath(import.meta.url)
|
||||||
const dirname = path.dirname(filename)
|
const dirname = path.dirname(filename)
|
||||||
@@ -85,15 +83,19 @@ const buildConfigWithMemoryDB = async () => {
|
|||||||
|
|
||||||
// Queue the welcome email using template slug
|
// Queue the welcome email using template slug
|
||||||
const emailId = await sendEmail(req.payload, {
|
const emailId = await sendEmail(req.payload, {
|
||||||
templateSlug: 'welcome-email',
|
template: {
|
||||||
to: doc.email,
|
slug: 'welcome-email',
|
||||||
variables: {
|
variables: {
|
||||||
firstName: doc.firstName || doc.email?.split('@')?.[0],
|
firstName: doc.firstName || doc.email?.split('@')?.[0],
|
||||||
siteName: 'PayloadCMS Mailing Demo',
|
siteName: 'PayloadCMS Mailing Demo',
|
||||||
createdAt: new Date().toISOString(),
|
createdAt: new Date().toISOString(),
|
||||||
isPremium: false,
|
isPremium: false,
|
||||||
dashboardUrl: 'http://localhost:3000/admin',
|
dashboardUrl: 'http://localhost:3000/admin',
|
||||||
|
},
|
||||||
},
|
},
|
||||||
|
data: {
|
||||||
|
to: doc.email,
|
||||||
|
}
|
||||||
})
|
})
|
||||||
|
|
||||||
console.log('✅ Welcome email queued successfully. Email ID:', emailId)
|
console.log('✅ Welcome email queued successfully. Email ID:', emailId)
|
||||||
@@ -280,56 +282,6 @@ const buildConfigWithMemoryDB = async () => {
|
|||||||
],
|
],
|
||||||
}),
|
}),
|
||||||
|
|
||||||
emailWrapper: (email) => {
|
|
||||||
// Example: wrap email content in a custom layout
|
|
||||||
const wrappedHtml = `
|
|
||||||
<!DOCTYPE html>
|
|
||||||
<html>
|
|
||||||
<head>
|
|
||||||
<meta charset="utf-8">
|
|
||||||
<meta name="viewport" content="width=device-width, initial-scale=1">
|
|
||||||
<title>${email.subject}</title>
|
|
||||||
<style>
|
|
||||||
body { font-family: Arial, sans-serif; margin: 0; padding: 20px; background-color: #f5f5f5; }
|
|
||||||
.container { max-width: 600px; margin: 0 auto; background: white; border-radius: 8px; overflow: hidden; }
|
|
||||||
.header { background: #007bff; color: white; padding: 20px; text-align: center; }
|
|
||||||
.content { padding: 30px; }
|
|
||||||
.footer { background: #f8f9fa; padding: 15px; text-align: center; font-size: 12px; color: #6c757d; }
|
|
||||||
</style>
|
|
||||||
</head>
|
|
||||||
<body>
|
|
||||||
<div class="container">
|
|
||||||
<div class="header">
|
|
||||||
<h1>My Company</h1>
|
|
||||||
</div>
|
|
||||||
<div class="content">
|
|
||||||
${email.html}
|
|
||||||
</div>
|
|
||||||
<div class="footer">
|
|
||||||
This email was sent from My Company. If you have questions, contact support@mycompany.com
|
|
||||||
</div>
|
|
||||||
</div>
|
|
||||||
</body>
|
|
||||||
</html>
|
|
||||||
`
|
|
||||||
|
|
||||||
const wrappedText = `
|
|
||||||
MY COMPANY
|
|
||||||
==========
|
|
||||||
|
|
||||||
${email.text || email.html?.replace(/<[^>]*>/g, '')}
|
|
||||||
|
|
||||||
---
|
|
||||||
This email was sent from My Company.
|
|
||||||
If you have questions, contact support@mycompany.com
|
|
||||||
`
|
|
||||||
|
|
||||||
return {
|
|
||||||
...email,
|
|
||||||
html: wrappedHtml,
|
|
||||||
text: wrappedText.trim(),
|
|
||||||
}
|
|
||||||
},
|
|
||||||
|
|
||||||
// Called after mailing plugin is fully initialized
|
// Called after mailing plugin is fully initialized
|
||||||
onReady: async (payload) => {
|
onReady: async (payload) => {
|
||||||
|
|||||||
@@ -102,7 +102,7 @@ export const seed = async (payload: Payload) => {
|
|||||||
format: 0,
|
format: 0,
|
||||||
mode: 'normal',
|
mode: 'normal',
|
||||||
style: '',
|
style: '',
|
||||||
text: 'Use the emailWrapper hook to add custom layouts',
|
text: 'Create beautiful emails with rich text formatting',
|
||||||
type: 'text',
|
type: 'text',
|
||||||
version: 1,
|
version: 1,
|
||||||
},
|
},
|
||||||
|
|||||||
@@ -19,13 +19,13 @@
|
|||||||
"@payload-config": [
|
"@payload-config": [
|
||||||
"./payload.config.ts"
|
"./payload.config.ts"
|
||||||
],
|
],
|
||||||
"temp-project": [
|
"@xtr-dev/payload-mailing": [
|
||||||
"../src/index.ts"
|
"../src/index.ts"
|
||||||
],
|
],
|
||||||
"temp-project/client": [
|
"@xtr-dev/payload-mailing/client": [
|
||||||
"../src/exports/client.ts"
|
"../src/exports/client.ts"
|
||||||
],
|
],
|
||||||
"temp-project/rsc": [
|
"@xtr-dev/payload-mailing/rsc": [
|
||||||
"../src/exports/rsc.ts"
|
"../src/exports/rsc.ts"
|
||||||
]
|
]
|
||||||
},
|
},
|
||||||
|
|||||||
@@ -1,6 +1,6 @@
|
|||||||
{
|
{
|
||||||
"name": "@xtr-dev/payload-mailing",
|
"name": "@xtr-dev/payload-mailing",
|
||||||
"version": "0.1.7",
|
"version": "0.1.13",
|
||||||
"description": "Template-based email system with scheduling and job processing for PayloadCMS",
|
"description": "Template-based email system with scheduling and job processing for PayloadCMS",
|
||||||
"type": "module",
|
"type": "module",
|
||||||
"main": "dist/index.js",
|
"main": "dist/index.js",
|
||||||
@@ -23,8 +23,9 @@
|
|||||||
"dev:generate-importmap": "npm run dev:payload generate:importmap",
|
"dev:generate-importmap": "npm run dev:payload generate:importmap",
|
||||||
"dev:generate-types": "npm run dev:payload generate:types",
|
"dev:generate-types": "npm run dev:payload generate:types",
|
||||||
"dev:payload": "cross-env PAYLOAD_CONFIG_PATH=./dev/payload.config.ts payload",
|
"dev:payload": "cross-env PAYLOAD_CONFIG_PATH=./dev/payload.config.ts payload",
|
||||||
"generate:importmap": "npm run dev:generate-importmap",
|
"payload": "cross-env NODE_OPTIONS=--no-deprecation payload",
|
||||||
"generate:types": "npm run dev:generate-types",
|
"generate:importmap": "npm run payload generate:importmap",
|
||||||
|
"generate:types": "npm run payload generate:types",
|
||||||
"lint": "eslint",
|
"lint": "eslint",
|
||||||
"lint:fix": "eslint ./src --fix",
|
"lint:fix": "eslint ./src --fix",
|
||||||
"prepublishOnly": "npm run clean && npm run build",
|
"prepublishOnly": "npm run clean && npm run build",
|
||||||
|
|||||||
31
payload.config.ts
Normal file
31
payload.config.ts
Normal file
@@ -0,0 +1,31 @@
|
|||||||
|
/**
|
||||||
|
* This config is only used to generate types.
|
||||||
|
*/
|
||||||
|
|
||||||
|
import { BaseDatabaseAdapter, buildConfig, Payload} from 'payload'
|
||||||
|
import Emails from "./src/collections/Emails.js"
|
||||||
|
import {createEmailTemplatesCollection} from "./src/collections/EmailTemplates.js"
|
||||||
|
import path from "path"
|
||||||
|
import { fileURLToPath } from 'url'
|
||||||
|
|
||||||
|
const __filename = fileURLToPath(import.meta.url)
|
||||||
|
const __dirname = path.dirname(__filename)
|
||||||
|
|
||||||
|
export default buildConfig({
|
||||||
|
collections: [
|
||||||
|
Emails,
|
||||||
|
createEmailTemplatesCollection()
|
||||||
|
],
|
||||||
|
db: {
|
||||||
|
allowIDOnCreate: undefined,
|
||||||
|
defaultIDType: 'number',
|
||||||
|
init: function (args: { payload: Payload; }): BaseDatabaseAdapter {
|
||||||
|
throw new Error('Function not implemented.');
|
||||||
|
},
|
||||||
|
name: undefined
|
||||||
|
},
|
||||||
|
secret: '',
|
||||||
|
typescript: {
|
||||||
|
outputFile: path.resolve(__dirname, 'src/payload-types.ts'),
|
||||||
|
}
|
||||||
|
});
|
||||||
@@ -16,7 +16,7 @@ export { mailingJobs, sendEmailJob } from './jobs/index.js'
|
|||||||
export type { SendEmailTaskInput } from './jobs/sendEmailTask.js'
|
export type { SendEmailTaskInput } from './jobs/sendEmailTask.js'
|
||||||
|
|
||||||
// Main email sending function
|
// Main email sending function
|
||||||
export { sendEmail, type BaseEmailData, type SendEmailOptions } from './sendEmail.js'
|
export { sendEmail, type SendEmailOptions } from './sendEmail.js'
|
||||||
export { default as sendEmailDefault } from './sendEmail.js'
|
export { default as sendEmailDefault } from './sendEmail.js'
|
||||||
|
|
||||||
// Utility functions for developers
|
// Utility functions for developers
|
||||||
|
|||||||
@@ -1,4 +1,5 @@
|
|||||||
import { sendEmail, type BaseEmailData } from '../sendEmail.js'
|
import { sendEmail } from '../sendEmail.js'
|
||||||
|
import { BaseEmailDocument } from '../types/index.js'
|
||||||
|
|
||||||
export interface SendEmailTaskInput {
|
export interface SendEmailTaskInput {
|
||||||
// Template mode fields
|
// Template mode fields
|
||||||
@@ -21,6 +22,45 @@ export interface SendEmailTaskInput {
|
|||||||
[key: string]: any
|
[key: string]: any
|
||||||
}
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Transforms task input into sendEmail options by separating template and data fields
|
||||||
|
*/
|
||||||
|
function transformTaskInputToSendEmailOptions(taskInput: SendEmailTaskInput) {
|
||||||
|
const sendEmailOptions: any = {
|
||||||
|
data: {}
|
||||||
|
}
|
||||||
|
|
||||||
|
// If using template mode, set template options
|
||||||
|
if (taskInput.templateSlug) {
|
||||||
|
sendEmailOptions.template = {
|
||||||
|
slug: taskInput.templateSlug,
|
||||||
|
variables: taskInput.variables || {}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
// Standard email fields that should be copied to data
|
||||||
|
const standardFields = ['to', 'cc', 'bcc', 'subject', 'html', 'text', 'scheduledAt', 'priority']
|
||||||
|
|
||||||
|
// Template-specific fields that should not be copied to data
|
||||||
|
const templateFields = ['templateSlug', 'variables']
|
||||||
|
|
||||||
|
// Copy standard fields to data
|
||||||
|
standardFields.forEach(field => {
|
||||||
|
if (taskInput[field] !== undefined) {
|
||||||
|
sendEmailOptions.data[field] = taskInput[field]
|
||||||
|
}
|
||||||
|
})
|
||||||
|
|
||||||
|
// Copy any additional custom fields that aren't template or standard fields
|
||||||
|
Object.keys(taskInput).forEach(key => {
|
||||||
|
if (!templateFields.includes(key) && !standardFields.includes(key)) {
|
||||||
|
sendEmailOptions.data[key] = taskInput[key]
|
||||||
|
}
|
||||||
|
})
|
||||||
|
|
||||||
|
return sendEmailOptions
|
||||||
|
}
|
||||||
|
|
||||||
export const sendEmailJob = {
|
export const sendEmailJob = {
|
||||||
slug: 'send-email',
|
slug: 'send-email',
|
||||||
label: 'Send Email',
|
label: 'Send Email',
|
||||||
@@ -115,64 +155,42 @@ export const sendEmailJob = {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
],
|
],
|
||||||
|
outputSchema: [
|
||||||
|
{
|
||||||
|
name: 'id',
|
||||||
|
type: 'text' as const
|
||||||
|
}
|
||||||
|
],
|
||||||
handler: async ({ input, payload }: any) => {
|
handler: async ({ input, payload }: any) => {
|
||||||
// Cast input to our expected type
|
// Cast input to our expected type
|
||||||
const taskInput = input as SendEmailTaskInput
|
const taskInput = input as SendEmailTaskInput
|
||||||
|
|
||||||
try {
|
try {
|
||||||
// Prepare options for sendEmail based on task input
|
// Transform task input into sendEmail options using helper function
|
||||||
const sendEmailOptions: any = {
|
const sendEmailOptions = transformTaskInputToSendEmailOptions(taskInput)
|
||||||
data: {}
|
|
||||||
}
|
|
||||||
|
|
||||||
// If using template mode
|
|
||||||
if (taskInput.templateSlug) {
|
|
||||||
sendEmailOptions.template = {
|
|
||||||
slug: taskInput.templateSlug,
|
|
||||||
variables: taskInput.variables || {}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
// Build data object from task input
|
|
||||||
const dataFields = ['to', 'cc', 'bcc', 'subject', 'html', 'text', 'scheduledAt', 'priority']
|
|
||||||
const additionalFields: string[] = []
|
|
||||||
|
|
||||||
// Copy standard fields
|
|
||||||
dataFields.forEach(field => {
|
|
||||||
if (taskInput[field] !== undefined) {
|
|
||||||
sendEmailOptions.data[field] = taskInput[field]
|
|
||||||
}
|
|
||||||
})
|
|
||||||
|
|
||||||
// Copy any additional custom fields
|
|
||||||
Object.keys(taskInput).forEach(key => {
|
|
||||||
if (!['templateSlug', 'variables', ...dataFields].includes(key)) {
|
|
||||||
sendEmailOptions.data[key] = taskInput[key]
|
|
||||||
additionalFields.push(key)
|
|
||||||
}
|
|
||||||
})
|
|
||||||
|
|
||||||
// Use the sendEmail helper to create the email
|
// Use the sendEmail helper to create the email
|
||||||
const email = await sendEmail<BaseEmailData>(payload, sendEmailOptions)
|
const email = await sendEmail<BaseEmailDocument>(payload, sendEmailOptions)
|
||||||
|
|
||||||
return {
|
return {
|
||||||
output: {
|
output: {
|
||||||
success: true,
|
success: true,
|
||||||
emailId: email.id,
|
id: email.id,
|
||||||
message: `Email queued successfully with ID: ${email.id}`,
|
|
||||||
mode: taskInput.templateSlug ? 'template' : 'direct',
|
|
||||||
templateSlug: taskInput.templateSlug || null,
|
|
||||||
subject: email.subject,
|
|
||||||
recipients: Array.isArray(email.to) ? email.to.length : 1,
|
|
||||||
scheduledAt: email.scheduledAt || null
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
} catch (error) {
|
} catch (error) {
|
||||||
const errorMessage = error instanceof Error ? error.message : 'Unknown error'
|
if (error instanceof Error) {
|
||||||
throw new Error(`Failed to queue email: ${errorMessage}`)
|
// Preserve original error and stack trace
|
||||||
|
const wrappedError = new Error(`Failed to queue email: ${error.message}`)
|
||||||
|
wrappedError.stack = error.stack
|
||||||
|
wrappedError.cause = error
|
||||||
|
throw wrappedError
|
||||||
|
} else {
|
||||||
|
throw new Error(`Failed to queue email: ${String(error)}`)
|
||||||
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
export default sendEmailJob
|
export default sendEmailJob
|
||||||
|
|||||||
431
src/payload-types.ts
Normal file
431
src/payload-types.ts
Normal file
@@ -0,0 +1,431 @@
|
|||||||
|
/* tslint:disable */
|
||||||
|
/* eslint-disable */
|
||||||
|
/**
|
||||||
|
* This file was automatically generated by Payload.
|
||||||
|
* DO NOT MODIFY IT BY HAND. Instead, modify your source Payload config,
|
||||||
|
* and re-run `payload generate:types` to regenerate this file.
|
||||||
|
*/
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Supported timezones in IANA format.
|
||||||
|
*
|
||||||
|
* This interface was referenced by `Config`'s JSON-Schema
|
||||||
|
* via the `definition` "supportedTimezones".
|
||||||
|
*/
|
||||||
|
export type SupportedTimezones =
|
||||||
|
| 'Pacific/Midway'
|
||||||
|
| 'Pacific/Niue'
|
||||||
|
| 'Pacific/Honolulu'
|
||||||
|
| 'Pacific/Rarotonga'
|
||||||
|
| 'America/Anchorage'
|
||||||
|
| 'Pacific/Gambier'
|
||||||
|
| 'America/Los_Angeles'
|
||||||
|
| 'America/Tijuana'
|
||||||
|
| 'America/Denver'
|
||||||
|
| 'America/Phoenix'
|
||||||
|
| 'America/Chicago'
|
||||||
|
| 'America/Guatemala'
|
||||||
|
| 'America/New_York'
|
||||||
|
| 'America/Bogota'
|
||||||
|
| 'America/Caracas'
|
||||||
|
| 'America/Santiago'
|
||||||
|
| 'America/Buenos_Aires'
|
||||||
|
| 'America/Sao_Paulo'
|
||||||
|
| 'Atlantic/South_Georgia'
|
||||||
|
| 'Atlantic/Azores'
|
||||||
|
| 'Atlantic/Cape_Verde'
|
||||||
|
| 'Europe/London'
|
||||||
|
| 'Europe/Berlin'
|
||||||
|
| 'Africa/Lagos'
|
||||||
|
| 'Europe/Athens'
|
||||||
|
| 'Africa/Cairo'
|
||||||
|
| 'Europe/Moscow'
|
||||||
|
| 'Asia/Riyadh'
|
||||||
|
| 'Asia/Dubai'
|
||||||
|
| 'Asia/Baku'
|
||||||
|
| 'Asia/Karachi'
|
||||||
|
| 'Asia/Tashkent'
|
||||||
|
| 'Asia/Calcutta'
|
||||||
|
| 'Asia/Dhaka'
|
||||||
|
| 'Asia/Almaty'
|
||||||
|
| 'Asia/Jakarta'
|
||||||
|
| 'Asia/Bangkok'
|
||||||
|
| 'Asia/Shanghai'
|
||||||
|
| 'Asia/Singapore'
|
||||||
|
| 'Asia/Tokyo'
|
||||||
|
| 'Asia/Seoul'
|
||||||
|
| 'Australia/Brisbane'
|
||||||
|
| 'Australia/Sydney'
|
||||||
|
| 'Pacific/Guam'
|
||||||
|
| 'Pacific/Noumea'
|
||||||
|
| 'Pacific/Auckland'
|
||||||
|
| 'Pacific/Fiji';
|
||||||
|
|
||||||
|
export interface Config {
|
||||||
|
auth: {
|
||||||
|
users: UserAuthOperations;
|
||||||
|
};
|
||||||
|
blocks: {};
|
||||||
|
collections: {
|
||||||
|
emails: Email;
|
||||||
|
'email-templates': EmailTemplate;
|
||||||
|
users: User;
|
||||||
|
'payload-locked-documents': PayloadLockedDocument;
|
||||||
|
'payload-preferences': PayloadPreference;
|
||||||
|
'payload-migrations': PayloadMigration;
|
||||||
|
};
|
||||||
|
collectionsJoins: {};
|
||||||
|
collectionsSelect: {
|
||||||
|
emails: EmailsSelect<false> | EmailsSelect<true>;
|
||||||
|
'email-templates': EmailTemplatesSelect<false> | EmailTemplatesSelect<true>;
|
||||||
|
users: UsersSelect<false> | UsersSelect<true>;
|
||||||
|
'payload-locked-documents': PayloadLockedDocumentsSelect<false> | PayloadLockedDocumentsSelect<true>;
|
||||||
|
'payload-preferences': PayloadPreferencesSelect<false> | PayloadPreferencesSelect<true>;
|
||||||
|
'payload-migrations': PayloadMigrationsSelect<false> | PayloadMigrationsSelect<true>;
|
||||||
|
};
|
||||||
|
db: {
|
||||||
|
defaultIDType: number;
|
||||||
|
};
|
||||||
|
globals: {};
|
||||||
|
globalsSelect: {};
|
||||||
|
locale: null;
|
||||||
|
user: User & {
|
||||||
|
collection: 'users';
|
||||||
|
};
|
||||||
|
jobs: {
|
||||||
|
tasks: unknown;
|
||||||
|
workflows: unknown;
|
||||||
|
};
|
||||||
|
}
|
||||||
|
export interface UserAuthOperations {
|
||||||
|
forgotPassword: {
|
||||||
|
email: string;
|
||||||
|
password: string;
|
||||||
|
};
|
||||||
|
login: {
|
||||||
|
email: string;
|
||||||
|
password: string;
|
||||||
|
};
|
||||||
|
registerFirstUser: {
|
||||||
|
email: string;
|
||||||
|
password: string;
|
||||||
|
};
|
||||||
|
unlock: {
|
||||||
|
email: string;
|
||||||
|
password: string;
|
||||||
|
};
|
||||||
|
}
|
||||||
|
/**
|
||||||
|
* Email delivery and status tracking
|
||||||
|
*
|
||||||
|
* This interface was referenced by `Config`'s JSON-Schema
|
||||||
|
* via the `definition` "emails".
|
||||||
|
*/
|
||||||
|
export interface Email {
|
||||||
|
id: number;
|
||||||
|
/**
|
||||||
|
* Email template used (optional if custom content provided)
|
||||||
|
*/
|
||||||
|
template?: (number | null) | EmailTemplate;
|
||||||
|
/**
|
||||||
|
* Recipient email addresses
|
||||||
|
*/
|
||||||
|
to: string[];
|
||||||
|
/**
|
||||||
|
* CC email addresses
|
||||||
|
*/
|
||||||
|
cc?: string[] | null;
|
||||||
|
/**
|
||||||
|
* BCC email addresses
|
||||||
|
*/
|
||||||
|
bcc?: string[] | null;
|
||||||
|
/**
|
||||||
|
* Sender email address (optional, uses default if not provided)
|
||||||
|
*/
|
||||||
|
from?: string | null;
|
||||||
|
/**
|
||||||
|
* Reply-to email address
|
||||||
|
*/
|
||||||
|
replyTo?: string | null;
|
||||||
|
/**
|
||||||
|
* Email subject line
|
||||||
|
*/
|
||||||
|
subject: string;
|
||||||
|
/**
|
||||||
|
* Rendered HTML content of the email
|
||||||
|
*/
|
||||||
|
html: string;
|
||||||
|
/**
|
||||||
|
* Plain text version of the email
|
||||||
|
*/
|
||||||
|
text?: string | null;
|
||||||
|
/**
|
||||||
|
* Template variables used to render this email
|
||||||
|
*/
|
||||||
|
variables?:
|
||||||
|
| {
|
||||||
|
[k: string]: unknown;
|
||||||
|
}
|
||||||
|
| unknown[]
|
||||||
|
| string
|
||||||
|
| number
|
||||||
|
| boolean
|
||||||
|
| null;
|
||||||
|
/**
|
||||||
|
* When this email should be sent (leave empty for immediate)
|
||||||
|
*/
|
||||||
|
scheduledAt?: string | null;
|
||||||
|
/**
|
||||||
|
* When this email was actually sent
|
||||||
|
*/
|
||||||
|
sentAt?: string | null;
|
||||||
|
/**
|
||||||
|
* Current status of this email
|
||||||
|
*/
|
||||||
|
status: 'pending' | 'processing' | 'sent' | 'failed';
|
||||||
|
/**
|
||||||
|
* Number of send attempts made
|
||||||
|
*/
|
||||||
|
attempts?: number | null;
|
||||||
|
/**
|
||||||
|
* When the last send attempt was made
|
||||||
|
*/
|
||||||
|
lastAttemptAt?: string | null;
|
||||||
|
/**
|
||||||
|
* Last error message if send failed
|
||||||
|
*/
|
||||||
|
error?: string | null;
|
||||||
|
/**
|
||||||
|
* Email priority (1=highest, 10=lowest)
|
||||||
|
*/
|
||||||
|
priority?: number | null;
|
||||||
|
updatedAt: string;
|
||||||
|
createdAt: string;
|
||||||
|
}
|
||||||
|
/**
|
||||||
|
* This interface was referenced by `Config`'s JSON-Schema
|
||||||
|
* via the `definition` "email-templates".
|
||||||
|
*/
|
||||||
|
export interface EmailTemplate {
|
||||||
|
id: number;
|
||||||
|
/**
|
||||||
|
* A descriptive name for this email template
|
||||||
|
*/
|
||||||
|
name: string;
|
||||||
|
/**
|
||||||
|
* Unique identifier for this template (e.g., "welcome-email", "password-reset")
|
||||||
|
*/
|
||||||
|
slug: string;
|
||||||
|
/**
|
||||||
|
* Email subject line. You can use Handlebars variables like {{firstName}} or {{siteName}}.
|
||||||
|
*/
|
||||||
|
subject: string;
|
||||||
|
/**
|
||||||
|
* Email content with rich text formatting. Supports Handlebars variables like {{firstName}} and helpers like {{formatDate createdAt "long"}}. Content is converted to HTML and plain text automatically.
|
||||||
|
*/
|
||||||
|
content: {
|
||||||
|
root: {
|
||||||
|
type: string;
|
||||||
|
children: {
|
||||||
|
type: string;
|
||||||
|
version: number;
|
||||||
|
[k: string]: unknown;
|
||||||
|
}[];
|
||||||
|
direction: ('ltr' | 'rtl') | null;
|
||||||
|
format: 'left' | 'start' | 'center' | 'right' | 'end' | 'justify' | '';
|
||||||
|
indent: number;
|
||||||
|
version: number;
|
||||||
|
};
|
||||||
|
[k: string]: unknown;
|
||||||
|
};
|
||||||
|
updatedAt: string;
|
||||||
|
createdAt: string;
|
||||||
|
}
|
||||||
|
/**
|
||||||
|
* This interface was referenced by `Config`'s JSON-Schema
|
||||||
|
* via the `definition` "users".
|
||||||
|
*/
|
||||||
|
export interface User {
|
||||||
|
id: number;
|
||||||
|
updatedAt: string;
|
||||||
|
createdAt: string;
|
||||||
|
email: string;
|
||||||
|
resetPasswordToken?: string | null;
|
||||||
|
resetPasswordExpiration?: string | null;
|
||||||
|
salt?: string | null;
|
||||||
|
hash?: string | null;
|
||||||
|
loginAttempts?: number | null;
|
||||||
|
lockUntil?: string | null;
|
||||||
|
sessions?:
|
||||||
|
| {
|
||||||
|
id: string;
|
||||||
|
createdAt?: string | null;
|
||||||
|
expiresAt: string;
|
||||||
|
}[]
|
||||||
|
| null;
|
||||||
|
password?: string | null;
|
||||||
|
}
|
||||||
|
/**
|
||||||
|
* This interface was referenced by `Config`'s JSON-Schema
|
||||||
|
* via the `definition` "payload-locked-documents".
|
||||||
|
*/
|
||||||
|
export interface PayloadLockedDocument {
|
||||||
|
id: number;
|
||||||
|
document?:
|
||||||
|
| ({
|
||||||
|
relationTo: 'emails';
|
||||||
|
value: number | Email;
|
||||||
|
} | null)
|
||||||
|
| ({
|
||||||
|
relationTo: 'email-templates';
|
||||||
|
value: number | EmailTemplate;
|
||||||
|
} | null)
|
||||||
|
| ({
|
||||||
|
relationTo: 'users';
|
||||||
|
value: number | User;
|
||||||
|
} | null);
|
||||||
|
globalSlug?: string | null;
|
||||||
|
user: {
|
||||||
|
relationTo: 'users';
|
||||||
|
value: number | User;
|
||||||
|
};
|
||||||
|
updatedAt: string;
|
||||||
|
createdAt: string;
|
||||||
|
}
|
||||||
|
/**
|
||||||
|
* This interface was referenced by `Config`'s JSON-Schema
|
||||||
|
* via the `definition` "payload-preferences".
|
||||||
|
*/
|
||||||
|
export interface PayloadPreference {
|
||||||
|
id: number;
|
||||||
|
user: {
|
||||||
|
relationTo: 'users';
|
||||||
|
value: number | User;
|
||||||
|
};
|
||||||
|
key?: string | null;
|
||||||
|
value?:
|
||||||
|
| {
|
||||||
|
[k: string]: unknown;
|
||||||
|
}
|
||||||
|
| unknown[]
|
||||||
|
| string
|
||||||
|
| number
|
||||||
|
| boolean
|
||||||
|
| null;
|
||||||
|
updatedAt: string;
|
||||||
|
createdAt: string;
|
||||||
|
}
|
||||||
|
/**
|
||||||
|
* This interface was referenced by `Config`'s JSON-Schema
|
||||||
|
* via the `definition` "payload-migrations".
|
||||||
|
*/
|
||||||
|
export interface PayloadMigration {
|
||||||
|
id: number;
|
||||||
|
name?: string | null;
|
||||||
|
batch?: number | null;
|
||||||
|
updatedAt: string;
|
||||||
|
createdAt: string;
|
||||||
|
}
|
||||||
|
/**
|
||||||
|
* This interface was referenced by `Config`'s JSON-Schema
|
||||||
|
* via the `definition` "emails_select".
|
||||||
|
*/
|
||||||
|
export interface EmailsSelect<T extends boolean = true> {
|
||||||
|
template?: T;
|
||||||
|
to?: T;
|
||||||
|
cc?: T;
|
||||||
|
bcc?: T;
|
||||||
|
from?: T;
|
||||||
|
replyTo?: T;
|
||||||
|
subject?: T;
|
||||||
|
html?: T;
|
||||||
|
text?: T;
|
||||||
|
variables?: T;
|
||||||
|
scheduledAt?: T;
|
||||||
|
sentAt?: T;
|
||||||
|
status?: T;
|
||||||
|
attempts?: T;
|
||||||
|
lastAttemptAt?: T;
|
||||||
|
error?: T;
|
||||||
|
priority?: T;
|
||||||
|
updatedAt?: T;
|
||||||
|
createdAt?: T;
|
||||||
|
}
|
||||||
|
/**
|
||||||
|
* This interface was referenced by `Config`'s JSON-Schema
|
||||||
|
* via the `definition` "email-templates_select".
|
||||||
|
*/
|
||||||
|
export interface EmailTemplatesSelect<T extends boolean = true> {
|
||||||
|
name?: T;
|
||||||
|
slug?: T;
|
||||||
|
subject?: T;
|
||||||
|
content?: T;
|
||||||
|
updatedAt?: T;
|
||||||
|
createdAt?: T;
|
||||||
|
}
|
||||||
|
/**
|
||||||
|
* This interface was referenced by `Config`'s JSON-Schema
|
||||||
|
* via the `definition` "users_select".
|
||||||
|
*/
|
||||||
|
export interface UsersSelect<T extends boolean = true> {
|
||||||
|
updatedAt?: T;
|
||||||
|
createdAt?: T;
|
||||||
|
email?: T;
|
||||||
|
resetPasswordToken?: T;
|
||||||
|
resetPasswordExpiration?: T;
|
||||||
|
salt?: T;
|
||||||
|
hash?: T;
|
||||||
|
loginAttempts?: T;
|
||||||
|
lockUntil?: T;
|
||||||
|
sessions?:
|
||||||
|
| T
|
||||||
|
| {
|
||||||
|
id?: T;
|
||||||
|
createdAt?: T;
|
||||||
|
expiresAt?: T;
|
||||||
|
};
|
||||||
|
}
|
||||||
|
/**
|
||||||
|
* This interface was referenced by `Config`'s JSON-Schema
|
||||||
|
* via the `definition` "payload-locked-documents_select".
|
||||||
|
*/
|
||||||
|
export interface PayloadLockedDocumentsSelect<T extends boolean = true> {
|
||||||
|
document?: T;
|
||||||
|
globalSlug?: T;
|
||||||
|
user?: T;
|
||||||
|
updatedAt?: T;
|
||||||
|
createdAt?: T;
|
||||||
|
}
|
||||||
|
/**
|
||||||
|
* This interface was referenced by `Config`'s JSON-Schema
|
||||||
|
* via the `definition` "payload-preferences_select".
|
||||||
|
*/
|
||||||
|
export interface PayloadPreferencesSelect<T extends boolean = true> {
|
||||||
|
user?: T;
|
||||||
|
key?: T;
|
||||||
|
value?: T;
|
||||||
|
updatedAt?: T;
|
||||||
|
createdAt?: T;
|
||||||
|
}
|
||||||
|
/**
|
||||||
|
* This interface was referenced by `Config`'s JSON-Schema
|
||||||
|
* via the `definition` "payload-migrations_select".
|
||||||
|
*/
|
||||||
|
export interface PayloadMigrationsSelect<T extends boolean = true> {
|
||||||
|
name?: T;
|
||||||
|
batch?: T;
|
||||||
|
updatedAt?: T;
|
||||||
|
createdAt?: T;
|
||||||
|
}
|
||||||
|
/**
|
||||||
|
* This interface was referenced by `Config`'s JSON-Schema
|
||||||
|
* via the `definition` "auth".
|
||||||
|
*/
|
||||||
|
export interface Auth {
|
||||||
|
[k: string]: unknown;
|
||||||
|
}
|
||||||
|
|
||||||
|
|
||||||
|
declare module 'payload' {
|
||||||
|
export interface GeneratedTypes extends Config {}
|
||||||
|
}
|
||||||
@@ -1,22 +1,9 @@
|
|||||||
import { Payload } from 'payload'
|
import { Payload } from 'payload'
|
||||||
import { getMailing, renderTemplate, parseAndValidateEmails } from './utils/helpers.js'
|
import { getMailing, renderTemplate, parseAndValidateEmails } from './utils/helpers.js'
|
||||||
|
import { BaseEmailDocument } from './types/index.js'
|
||||||
// Base type for email data that all emails must have
|
|
||||||
// Compatible with PayloadCMS generated types that include null
|
|
||||||
export interface BaseEmailData {
|
|
||||||
to: string | string[]
|
|
||||||
cc?: string | string[] | null
|
|
||||||
bcc?: string | string[] | null
|
|
||||||
subject?: string | null
|
|
||||||
html?: string | null
|
|
||||||
text?: string | null
|
|
||||||
scheduledAt?: string | Date | null
|
|
||||||
priority?: number | null
|
|
||||||
[key: string]: any
|
|
||||||
}
|
|
||||||
|
|
||||||
// Options for sending emails
|
// Options for sending emails
|
||||||
export interface SendEmailOptions<T extends BaseEmailData = BaseEmailData> {
|
export interface SendEmailOptions<T extends BaseEmailDocument = BaseEmailDocument> {
|
||||||
// Template-based email
|
// Template-based email
|
||||||
template?: {
|
template?: {
|
||||||
slug: string
|
slug: string
|
||||||
@@ -48,14 +35,14 @@ export interface SendEmailOptions<T extends BaseEmailData = BaseEmailData> {
|
|||||||
* })
|
* })
|
||||||
* ```
|
* ```
|
||||||
*/
|
*/
|
||||||
export const sendEmail = async <T extends BaseEmailData = BaseEmailData>(
|
export const sendEmail = async <TEmail extends BaseEmailDocument = BaseEmailDocument>(
|
||||||
payload: Payload,
|
payload: Payload,
|
||||||
options: SendEmailOptions<T>
|
options: SendEmailOptions<TEmail>
|
||||||
): Promise<T> => {
|
): Promise<TEmail> => {
|
||||||
const mailing = getMailing(payload)
|
const mailing = getMailing(payload)
|
||||||
const collectionSlug = options.collectionSlug || mailing.collections.emails || 'emails'
|
const collectionSlug = options.collectionSlug || mailing.collections.emails || 'emails'
|
||||||
|
|
||||||
let emailData: Partial<T> = { ...options.data } as Partial<T>
|
let emailData: Partial<TEmail> = { ...options.data } as Partial<TEmail>
|
||||||
|
|
||||||
// If using a template, render it first
|
// If using a template, render it first
|
||||||
if (options.template) {
|
if (options.template) {
|
||||||
@@ -71,7 +58,7 @@ export const sendEmail = async <T extends BaseEmailData = BaseEmailData>(
|
|||||||
subject,
|
subject,
|
||||||
html,
|
html,
|
||||||
text,
|
text,
|
||||||
} as Partial<T>
|
} as Partial<TEmail>
|
||||||
}
|
}
|
||||||
|
|
||||||
// Validate required fields
|
// Validate required fields
|
||||||
@@ -79,8 +66,17 @@ export const sendEmail = async <T extends BaseEmailData = BaseEmailData>(
|
|||||||
throw new Error('Field "to" is required for sending emails')
|
throw new Error('Field "to" is required for sending emails')
|
||||||
}
|
}
|
||||||
|
|
||||||
if (!emailData.subject || !emailData.html) {
|
// Validate required fields based on whether template was used
|
||||||
throw new Error('Fields "subject" and "html" are required when not using a template')
|
if (options.template) {
|
||||||
|
// When using template, subject and html should have been set by renderTemplate
|
||||||
|
if (!emailData.subject || !emailData.html) {
|
||||||
|
throw new Error(`Template rendering failed: template "${options.template.slug}" did not provide required subject and html content`)
|
||||||
|
}
|
||||||
|
} else {
|
||||||
|
// When not using template, user must provide subject and html directly
|
||||||
|
if (!emailData.subject || !emailData.html) {
|
||||||
|
throw new Error('Fields "subject" and "html" are required when sending direct emails without a template')
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
// Process email addresses using shared validation (handle null values)
|
// Process email addresses using shared validation (handle null values)
|
||||||
@@ -94,18 +90,18 @@ export const sendEmail = async <T extends BaseEmailData = BaseEmailData>(
|
|||||||
emailData.bcc = parseAndValidateEmails(emailData.bcc as string | string[])
|
emailData.bcc = parseAndValidateEmails(emailData.bcc as string | string[])
|
||||||
}
|
}
|
||||||
|
|
||||||
// Convert scheduledAt to ISO string if it's a Date
|
// Create the email in the collection with proper typing
|
||||||
if (emailData.scheduledAt instanceof Date) {
|
|
||||||
emailData.scheduledAt = emailData.scheduledAt.toISOString()
|
|
||||||
}
|
|
||||||
|
|
||||||
// Create the email in the collection
|
|
||||||
const email = await payload.create({
|
const email = await payload.create({
|
||||||
collection: collectionSlug as any,
|
collection: collectionSlug,
|
||||||
data: emailData as any
|
data: emailData
|
||||||
})
|
})
|
||||||
|
|
||||||
return email as unknown as T
|
// Validate that the created email has the expected structure
|
||||||
|
if (!email || typeof email !== 'object' || !email.id) {
|
||||||
|
throw new Error('Failed to create email: invalid response from database')
|
||||||
|
}
|
||||||
|
|
||||||
|
return email as TEmail
|
||||||
}
|
}
|
||||||
|
|
||||||
export default sendEmail
|
export default sendEmail
|
||||||
|
|||||||
@@ -5,10 +5,8 @@ import {
|
|||||||
MailingPluginConfig,
|
MailingPluginConfig,
|
||||||
TemplateVariables,
|
TemplateVariables,
|
||||||
MailingService as IMailingService,
|
MailingService as IMailingService,
|
||||||
EmailTemplate,
|
|
||||||
QueuedEmail,
|
|
||||||
MailingTransportConfig,
|
MailingTransportConfig,
|
||||||
EmailObject
|
BaseEmail, BaseEmailTemplate, BaseEmailDocument, BaseEmailTemplateDocument
|
||||||
} from '../types/index.js'
|
} from '../types/index.js'
|
||||||
import { serializeRichTextToHTML, serializeRichTextToText } from '../utils/richTextSerializer.js'
|
import { serializeRichTextToHTML, serializeRichTextToText } from '../utils/richTextSerializer.js'
|
||||||
|
|
||||||
@@ -133,7 +131,7 @@ export class MailingService implements IMailingService {
|
|||||||
}
|
}
|
||||||
|
|
||||||
const emailContent = await this.renderEmailTemplate(template, variables)
|
const emailContent = await this.renderEmailTemplate(template, variables)
|
||||||
const subject = await this.renderTemplateString(template.subject, variables)
|
const subject = await this.renderTemplateString(template.subject || '', variables)
|
||||||
|
|
||||||
return {
|
return {
|
||||||
html: emailContent.html,
|
html: emailContent.html,
|
||||||
@@ -238,10 +236,10 @@ export class MailingService implements IMailingService {
|
|||||||
const email = await this.payload.findByID({
|
const email = await this.payload.findByID({
|
||||||
collection: this.emailsCollection as any,
|
collection: this.emailsCollection as any,
|
||||||
id: emailId,
|
id: emailId,
|
||||||
}) as QueuedEmail
|
}) as BaseEmailDocument
|
||||||
|
|
||||||
let emailObject: EmailObject = {
|
const mailOptions = {
|
||||||
from: email.from || this.getDefaultFrom(),
|
from: email.from,
|
||||||
to: email.to,
|
to: email.to,
|
||||||
cc: email.cc || undefined,
|
cc: email.cc || undefined,
|
||||||
bcc: email.bcc || undefined,
|
bcc: email.bcc || undefined,
|
||||||
@@ -249,23 +247,6 @@ export class MailingService implements IMailingService {
|
|||||||
subject: email.subject,
|
subject: email.subject,
|
||||||
html: email.html,
|
html: email.html,
|
||||||
text: email.text || undefined,
|
text: email.text || undefined,
|
||||||
variables: email.variables,
|
|
||||||
}
|
|
||||||
|
|
||||||
// Apply emailWrapper hook if configured
|
|
||||||
if (this.config.emailWrapper) {
|
|
||||||
emailObject = await this.config.emailWrapper(emailObject)
|
|
||||||
}
|
|
||||||
|
|
||||||
const mailOptions = {
|
|
||||||
from: emailObject.from,
|
|
||||||
to: emailObject.to,
|
|
||||||
cc: emailObject.cc || undefined,
|
|
||||||
bcc: emailObject.bcc || undefined,
|
|
||||||
replyTo: emailObject.replyTo || undefined,
|
|
||||||
subject: emailObject.subject,
|
|
||||||
html: emailObject.html,
|
|
||||||
text: emailObject.text || undefined,
|
|
||||||
}
|
}
|
||||||
|
|
||||||
await this.transporter.sendMail(mailOptions)
|
await this.transporter.sendMail(mailOptions)
|
||||||
@@ -304,7 +285,7 @@ export class MailingService implements IMailingService {
|
|||||||
const email = await this.payload.findByID({
|
const email = await this.payload.findByID({
|
||||||
collection: this.emailsCollection as any,
|
collection: this.emailsCollection as any,
|
||||||
id: emailId,
|
id: emailId,
|
||||||
}) as QueuedEmail
|
}) as BaseEmail
|
||||||
|
|
||||||
const newAttempts = (email.attempts || 0) + 1
|
const newAttempts = (email.attempts || 0) + 1
|
||||||
|
|
||||||
@@ -319,7 +300,7 @@ export class MailingService implements IMailingService {
|
|||||||
return newAttempts
|
return newAttempts
|
||||||
}
|
}
|
||||||
|
|
||||||
private async getTemplateBySlug(templateSlug: string): Promise<EmailTemplate | null> {
|
private async getTemplateBySlug(templateSlug: string): Promise<BaseEmailTemplateDocument | null> {
|
||||||
try {
|
try {
|
||||||
const { docs } = await this.payload.find({
|
const { docs } = await this.payload.find({
|
||||||
collection: this.templatesCollection as any,
|
collection: this.templatesCollection as any,
|
||||||
@@ -331,7 +312,7 @@ export class MailingService implements IMailingService {
|
|||||||
limit: 1,
|
limit: 1,
|
||||||
})
|
})
|
||||||
|
|
||||||
return docs.length > 0 ? docs[0] as EmailTemplate : null
|
return docs.length > 0 ? docs[0] as BaseEmailTemplateDocument : null
|
||||||
} catch (error) {
|
} catch (error) {
|
||||||
console.error(`Template with slug '${templateSlug}' not found:`, error)
|
console.error(`Template with slug '${templateSlug}' not found:`, error)
|
||||||
return null
|
return null
|
||||||
@@ -396,7 +377,7 @@ export class MailingService implements IMailingService {
|
|||||||
})
|
})
|
||||||
}
|
}
|
||||||
|
|
||||||
private async renderEmailTemplate(template: EmailTemplate, variables: Record<string, any> = {}): Promise<{ html: string; text: string }> {
|
private async renderEmailTemplate(template: BaseEmailTemplateDocument, variables: Record<string, any> = {}): Promise<{ html: string; text: string }> {
|
||||||
if (!template.content) {
|
if (!template.content) {
|
||||||
return { html: '', text: '' }
|
return { html: '', text: '' }
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -1,20 +1,44 @@
|
|||||||
import { Payload } from 'payload'
|
import { Payload } from 'payload'
|
||||||
import type { CollectionConfig, RichTextField, TypedCollection } from 'payload'
|
import type { CollectionConfig, RichTextField } from 'payload'
|
||||||
import { Transporter } from 'nodemailer'
|
import { Transporter } from 'nodemailer'
|
||||||
|
|
||||||
export interface EmailObject {
|
// Generic base interfaces that work with any ID type
|
||||||
to: string | string[]
|
export interface BaseEmailDocument {
|
||||||
cc?: string | string[]
|
id: string | number
|
||||||
bcc?: string | string[]
|
template?: any
|
||||||
|
to: string[]
|
||||||
|
cc?: string[]
|
||||||
|
bcc?: string[]
|
||||||
from?: string
|
from?: string
|
||||||
replyTo?: string
|
replyTo?: string
|
||||||
subject: string
|
subject: string
|
||||||
html: string
|
html: string
|
||||||
text?: string
|
text?: string
|
||||||
variables?: Record<string, any>
|
variables?: Record<string, any>
|
||||||
|
scheduledAt?: string
|
||||||
|
sentAt?: string
|
||||||
|
status?: 'pending' | 'processing' | 'sent' | 'failed'
|
||||||
|
attempts?: number
|
||||||
|
lastAttemptAt?: string
|
||||||
|
error?: string
|
||||||
|
priority?: number
|
||||||
|
createdAt?: string
|
||||||
|
updatedAt?: string
|
||||||
}
|
}
|
||||||
|
|
||||||
export type EmailWrapperHook = (email: EmailObject) => EmailObject | Promise<EmailObject>
|
export interface BaseEmailTemplateDocument {
|
||||||
|
id: string | number
|
||||||
|
name: string
|
||||||
|
slug: string
|
||||||
|
subject?: string
|
||||||
|
content?: any
|
||||||
|
createdAt?: string
|
||||||
|
updatedAt?: string
|
||||||
|
}
|
||||||
|
|
||||||
|
export type BaseEmail<TEmail extends BaseEmailDocument = BaseEmailDocument, TEmailTemplate extends BaseEmailTemplateDocument = BaseEmailTemplateDocument> = Omit<TEmail, 'id' | 'template'> & {template: Omit<TEmailTemplate, 'id'> | TEmailTemplate['id'] | undefined | null}
|
||||||
|
|
||||||
|
export type BaseEmailTemplate<TEmailTemplate extends BaseEmailTemplateDocument = BaseEmailTemplateDocument> = Omit<TEmailTemplate, 'id'>
|
||||||
|
|
||||||
export type TemplateRendererHook = (template: string, variables: Record<string, any>) => string | Promise<string>
|
export type TemplateRendererHook = (template: string, variables: Record<string, any>) => string | Promise<string>
|
||||||
|
|
||||||
@@ -31,7 +55,6 @@ export interface MailingPluginConfig {
|
|||||||
queue?: string
|
queue?: string
|
||||||
retryAttempts?: number
|
retryAttempts?: number
|
||||||
retryDelay?: number
|
retryDelay?: number
|
||||||
emailWrapper?: EmailWrapperHook
|
|
||||||
templateRenderer?: TemplateRendererHook
|
templateRenderer?: TemplateRendererHook
|
||||||
templateEngine?: TemplateEngine
|
templateEngine?: TemplateEngine
|
||||||
richTextEditor?: RichTextField['editor']
|
richTextEditor?: RichTextField['editor']
|
||||||
@@ -49,16 +72,6 @@ export interface MailingTransportConfig {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
export interface EmailTemplate {
|
|
||||||
id: string
|
|
||||||
name: string
|
|
||||||
slug: string
|
|
||||||
subject: string
|
|
||||||
content: any // Lexical editor state
|
|
||||||
createdAt: string
|
|
||||||
updatedAt: string
|
|
||||||
}
|
|
||||||
|
|
||||||
|
|
||||||
export interface QueuedEmail {
|
export interface QueuedEmail {
|
||||||
id: string
|
id: string
|
||||||
|
|||||||
@@ -15,9 +15,20 @@ export const parseAndValidateEmails = (emails: string | string[] | null | undefi
|
|||||||
emailList = emails.split(',').map(email => email.trim()).filter(Boolean)
|
emailList = emails.split(',').map(email => email.trim()).filter(Boolean)
|
||||||
}
|
}
|
||||||
|
|
||||||
// Basic email validation
|
// RFC 5322 compliant email validation
|
||||||
const emailRegex = /^[^\s@]+@[^\s@]+\.[^\s@]+$/
|
const emailRegex = /^[a-zA-Z0-9.!#$%&'*+/=?^_`{|}~-]+@[a-zA-Z0-9](?:[a-zA-Z0-9-]{0,61}[a-zA-Z0-9])?(?:\.[a-zA-Z0-9](?:[a-zA-Z0-9-]{0,61}[a-zA-Z0-9])?)*$/
|
||||||
const invalidEmails = emailList.filter(email => !emailRegex.test(email))
|
const invalidEmails = emailList.filter(email => {
|
||||||
|
// Check basic format
|
||||||
|
if (!emailRegex.test(email)) return true
|
||||||
|
// Check for common invalid patterns
|
||||||
|
if (email.includes('..') || email.startsWith('.') || email.endsWith('.')) return true
|
||||||
|
if (email.includes('@.') || email.includes('.@')) return true
|
||||||
|
// Check domain has at least one dot
|
||||||
|
const parts = email.split('@')
|
||||||
|
if (parts.length !== 2 || !parts[1].includes('.')) return true
|
||||||
|
return false
|
||||||
|
})
|
||||||
|
|
||||||
if (invalidEmails.length > 0) {
|
if (invalidEmails.length > 0) {
|
||||||
throw new Error(`Invalid email addresses: ${invalidEmails.join(', ')}`)
|
throw new Error(`Invalid email addresses: ${invalidEmails.join(', ')}`)
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user