カスタマイズされた通知を送信する方法

				
					import crypto from 'crypto';
import { SESClient, SendEmailCommand } from '@aws-sdk/client-ses';

// AWS SESクライアントを初期化
const sesClient = new SESClient({ region: 'ap-northeast-1' });

// Lambdaハンドラー
export const handler = async (event) => {
  try {
    const WEBHOOK_SECRET_TOKEN = process.env.SECRET_KEY;

    // リクエストボディと署名をヘッダーから取得
    const requestBody = event.body ? event.body.toString() : '';
    const komojuSignature = event.headers['X-Komoju-Signature'] || event.headers['x-komoju-signature'];

    // 受信したWebhookペイロードをログに記録
    console.log('Incoming webhook payload:', requestBody);

    if (!komojuSignature) {
      console.error('署名がありません');
      return {
        statusCode: 400,
        body: JSON.stringify({ message: '署名がありません' }),
      };
    }

    // 署名を検証
    const computedSignature = crypto
      .createHmac('sha256', WEBHOOK_SECRET_TOKEN)
      .update(requestBody, 'utf8')
      .digest('hex');

    if (Buffer.byteLength(computedSignature) !== Buffer.byteLength(komojuSignature)) {
      console.error('署名の長さが一致しません');
      return {
        statusCode: 400,
        body: JSON.stringify({ message: '署名の長さが一致しません' }),
      };
    }

    if (!crypto.timingSafeEqual(Buffer.from(computedSignature), Buffer.from(komojuSignature))) {
      console.error('無効な署名です');
      return {
        statusCode: 400,
        body: JSON.stringify({ message: '無効な署名です' }),
      };
    }

    // KOMOJUからのWebhookペイロードを解析し、必要な情報を抽出
    const { data: { id: paymentId, total: totalAmount, payment_details: { email }, created_at: createdAt } } = JSON.parse(requestBody);

    // メール本文の内容
    const body = `こんにちは、

支払いを受け取りました:

支払いID: ${paymentId}
合計金額: ${totalAmount} JPY
支払い日: ${createdAt}`;

    // メール本文をコンソールに記録
    console.log('Email body:', body);

    // AWS SESを使用してメールを送信
    const params = {
      Source: 'sender@example.com', // SESで検証済みのメールアドレスに置き換えてください
      Destination: {
        ToAddresses: ["receiver@example.com"], // 送信先のメールアドレスに置き換えてください
      },
      Message: {
        Subject: {
          Data: `支払い確認 - 支払いID: ${paymentId}`,
        },
        Body: {
          Text: {
            Data: body,
          },
        },
      },
    };

    const command = new SendEmailCommand(params);
    await sesClient.send(command);

    // 成功レスポンスを返す
    return {
      statusCode: 200,
      body: JSON.stringify({ message: 'メールが正常に送信されました。' }),
    };
  } catch (error) {
    console.error('メール送信中のエラー:', error);
    return {
      statusCode: 500,
      body: JSON.stringify({ message: 'メールの送信に失敗しました。' }),
    };
  }
};