mirror of
https://github.com/ksyasuda/dotfiles.git
synced 2026-03-20 18:11:27 -07:00
103 lines
2.7 KiB
Markdown
103 lines
2.7 KiB
Markdown
# Email Workers Patterns
|
|
|
|
## Parse Email
|
|
|
|
```typescript
|
|
import PostalMime from 'postal-mime';
|
|
|
|
export default {
|
|
async email(message, env, ctx) {
|
|
const buffer = await new Response(message.raw).arrayBuffer();
|
|
const email = await PostalMime.parse(buffer);
|
|
console.log(email.from, email.subject, email.text, email.attachments.length);
|
|
await message.forward('inbox@example.com');
|
|
}
|
|
};
|
|
```
|
|
|
|
## Filtering
|
|
|
|
```typescript
|
|
// Allowlist from KV
|
|
const allowList = await env.ALLOWED_SENDERS.get('list', 'json') || [];
|
|
if (!allowList.includes(message.from)) {
|
|
message.setReject('Not allowed');
|
|
return;
|
|
}
|
|
|
|
// Size check (avoid parsing large emails)
|
|
if (message.rawSize > 5_000_000) {
|
|
await message.forward('inbox@example.com'); // Forward without parsing
|
|
return;
|
|
}
|
|
```
|
|
|
|
## Auto-Reply with Threading
|
|
|
|
```typescript
|
|
import { EmailMessage } from 'cloudflare:email';
|
|
import { createMimeMessage } from 'mimetext';
|
|
|
|
const msg = createMimeMessage();
|
|
msg.setSender({ addr: 'support@example.com' });
|
|
msg.setRecipient(message.from);
|
|
msg.setSubject(`Re: ${message.headers.get('Subject')}`);
|
|
msg.setHeader('In-Reply-To', message.headers.get('Message-ID') || '');
|
|
msg.addMessage({ contentType: 'text/plain', data: 'Thank you. We will respond.' });
|
|
|
|
await message.reply(new EmailMessage('support@example.com', message.from, msg.asRaw()));
|
|
```
|
|
|
|
## Rate-Limited Auto-Reply
|
|
|
|
```typescript
|
|
const rateKey = `rate:${message.from}`;
|
|
if (!await env.RATE_LIMIT.get(rateKey)) {
|
|
// Send reply...
|
|
ctx.waitUntil(env.RATE_LIMIT.put(rateKey, '1', { expirationTtl: 3600 }));
|
|
}
|
|
```
|
|
|
|
## Subject-Based Routing
|
|
|
|
```typescript
|
|
const subject = (message.headers.get('Subject') || '').toLowerCase();
|
|
if (subject.includes('billing')) await message.forward('billing@example.com');
|
|
else if (subject.includes('support')) await message.forward('support@example.com');
|
|
else await message.forward('general@example.com');
|
|
```
|
|
|
|
## Multi-Tenant Routing
|
|
|
|
```typescript
|
|
// support+tenant123@example.com → tenant123
|
|
const tenantId = message.to.split('@')[0].match(/\+(.+)$/)?.[1] || 'default';
|
|
const config = await env.TENANT_CONFIG.get(tenantId, 'json');
|
|
config?.forwardTo ? await message.forward(config.forwardTo) : message.setReject('Unknown');
|
|
```
|
|
|
|
## Archive & Extract Attachments
|
|
|
|
```typescript
|
|
// Archive to KV
|
|
ctx.waitUntil(env.ARCHIVE.put(`email:${Date.now()}`, JSON.stringify({
|
|
from: message.from, subject: email.subject
|
|
})));
|
|
|
|
// Attachments to R2
|
|
for (const att of email.attachments) {
|
|
ctx.waitUntil(env.R2.put(`${Date.now()}-${att.filename}`, att.content));
|
|
}
|
|
```
|
|
|
|
## Webhook Integration
|
|
|
|
```typescript
|
|
ctx.waitUntil(
|
|
fetch(env.WEBHOOK_URL, {
|
|
method: 'POST',
|
|
body: JSON.stringify({ from: message.from, subject: message.headers.get('Subject') })
|
|
}).catch(err => console.error(err))
|
|
);
|
|
```
|