Cloudflare Workers Email Routing POC

index.ts

const PostalMime = require('postal-mime');

export interface EmailMessage {
    readonly from: string;
    readonly to: string;
    readonly headers: Headers;
    readonly raw: ReadableStream;
    readonly rawSize: number;
    setReject(reason: String): void;
    forward(rcptTo: string, headers?: Headers): Promise<void>;
  }

export interface Env {
	MY_BUCKET: R2Bucket;
}

export default {
	async email(message: EmailMessage, env: Env) {
		let rawEmail = new Response(message.raw);
		let arrayBuffer = await rawEmail.arrayBuffer();
		const parser = new PostalMime.default();
		const email = await parser.parse(arrayBuffer);
		const jsonString  = JSON.stringify(email);
		await env.MY_BUCKET.put('email', jsonString);
	},
};