【第2回】受信メールを解析して自動応答！Cloudflare Email Routing ＋ postal-mime で文字化けのない自動返信システムを作ろう

npm install postal-mime

import { Resend } from 'resend';
import PostalMime from 'postal-mime';

// 環境変数の型定義（前回のキーを引き続き使用します）
export interface Env {
  RESEND_API_KEY: string;
}

export default {
  // ■ 1. Web（API）からのリクエストを受け付ける関数（第1回で実装したもの）
  async fetch(request: Request, env: Env, ctx: ExecutionContext): Promise<Response> {
    const url = new URL(request.url);
    if (request.method !== 'POST' || url.pathname !== '/send') {
      return new Response('Not Found', { status: 404 });
    }
    // (中略：前回の送信ロジックがそのまま動きます)
    return new Response('Fetch endpoint active', { status: 200 });
  },

  // ■ 2. 【今回新規追加】独自ドメイン宛てにメールが届いたときに自動実行される関数
  async email(message: ForwardableEmailMessage, env: Env, ctx: ExecutionContext): Promise<void> {
    try {
      // ① Cloudflareから届いたメールの「生データ（Raw Email）」をストリームとして取得
      const rawEmailStream = message.raw;
      
      // ② postal-mime を使って、生データを解析（パース）する
      const parser = new PostalMime();
      const parsedEmail = await parser.parse(rawEmailStream);

      // ③ 解析データから「送信元」「件名」「本文」を抽出
      const fromAddress = message.from; // 送信元のメールアドレス
      const subject = parsedEmail.subject || 'No Subject'; // メールの件名
      const bodyText = parsedEmail.text || '本文なし'; // メールの本文（テキスト）

      // 日本語の文字化け（MIMEエンコード）を防ぐための「デコード（復元）」処理
      // ※件名や本文が `=?UTF-8?B?...=` のような謎の文字列になっているのを日本語に戻します
      const decodedSubject = decodeMimeHeader(subject);

      // ④ 自動応答のメール本文を作成（相手の本文を引用）
      const replyText = `メールを受け付けました。

件名: ${decodedSubject}

本文:
------------------------------------------
${bodyText}
------------------------------------------

※このメールはシステムより自動送信されています。`;

      // ⑤ Resendを使って、メールを送ってきた相手に自動返信を送信！
      const resend = new Resend(env.RESEND_API_KEY);
      await resend.emails.send({
        from: 'info@go-pro-world.net', // あなたの独自ドメインアドレス
        to: [fromAddress],             // メールの差出人（相手のアドレス）
        subject: `【自動応答】${decodedSubject}`,
        text: replyText,
      });

    } catch (error: any) {
      console.error('メール処理中にエラーが発生しました:', error.message);
      // 注意: ここでエラーを throw するとCloudflare側でメールが「一時不達」となり再送され続けます。
      // ログを出力して処理を正常に終了させるのが安全です。
    }
  }
};

/**
 * 【文字化け対策ヘルパー関数】
 * メールヘッダー（件名など）のMIMEエンコードを検知し、正しい日本語（UTF-8）にデコードします。
 */
function decodeMimeHeader(header: string): string {
  // =?UTF-8?B?BASE64文字列?= のパターンを検出する正規表現
  const mimeRegex = /=\?UTF-8\?B\?([^\?]+)\?=/gi;
  
  return header.replace(mimeRegex, (_, base64Str) => {
    try {
      // Base64をバイナリデータに変換し、TextDecoderで日本語文字列に戻す
      const binaryString = atob(base64Str);
      const len = binaryString.length;
      const bytes = new Uint8Array(len);
      for (let i = 0; i < len; i++) {
        bytes[i] = binaryString.charCodeAt(i);
      }
      return new TextDecoder('utf-8').decode(bytes);
    } catch (e) {
      return header; // デコードに失敗した場合は元の文字列をそのまま返す
    }
  });
}

npx wrangler secret put RESEND_API_KEY

npm run deploy

https://mail-serverless.<あなたのユーザー名>.workers.dev