Webhook APIを使ってメールを処理する（AWS Lambda + Java）

Customers Mail Cloudではプログラム側からデータを取得したり、メールを送信するWeb APIの他に、Customers Mail Cloudでメールを受信した時にイベントを伝えてくれるWebhook APIが用意されています。

Webhook APIを使うことで、自前でメールサーバを立てずにメール受信のタイミングでシステムを起動させられるようになります。メールサーバを安定して動作させ続けるのはメンテナンスコストが大きいですが、Customers Mail Cloudを使うことで簡単にメールと連携したシステムが作れるようになるでしょう。

今回はAWS LambdaでJavaを使ってメールを処理する流れを紹介します。

フォーマットはJSONとマルチパートフォームデータ

Webhookの形式として、JSONとマルチパートフォームデータ（multipart/form-data）が選択できます。この二つの違いは、添付ファイルがあるかどうかです。JSONの場合、添付ファイルは送られてきません。メールに添付ファイルがついてくる可能性がある場合は、後者を選択してください。

今回はJSONフォーマットにおけるWebhook処理について紹介します。

AWS Lambdaの準備

AWS Lambdaで新しい関数を作成します。その際、条件として以下を指定します。

ランタイム
Java 21
関数 URL を有効化
チェックを入れる
認証タイプ
NONE

関数の作成が完了したら、関数コードを編集します。ベースになるコードは以下の通りです。

package com.example.lambda;

import com.amazonaws.services.lambda.runtime.Context;
import com.amazonaws.services.lambda.runtime.RequestHandler;
import java.util.Map;

public class HelloLambda implements RequestHandler<Map<String, Object>, String> {
    @Override
    public String handleRequest(Map<String, Object> event, Context context) {
        return "OK";
    }
}

Webhookで受け取るデータについて

Webhookを使ってPOSTされるJSONデータは、次のようになっています。

{
    "filter": "info@smtps.jp",
    "headers": [
      {"name": "Return-Path", "value": "<user@example.com>"},
        :
      {"name": "Date", "value": "Thu, 27 Apr 2023 15:56:26 +0900"}
    ],
    "subject": "Webhookのテスト",
    "envelope-to": "user@smtps.jp",
    "server_composition": "sandbox",
    "html": "<div dir=\\\\\\\\\\\\\\\\"ltr\\\\\\\\\\\\\\\\">Webhookのテスト用メールです。<div>...</div></div>",
    "text": "Webhookのテスト用メールです。\\\\\\\\\\\\\\\\r\\\\\\\\\\\\\\\\n\\\\\\\\\\\\\\\\r\\\\\\\\\\\\\\\\n--\\\\\\\\\\\\\\\\r\\\\\\\\\\\\\\\\n...",
    "envelope-from": "info@smtps.jp"
}

Javaのコード

処理は src/main/java/com/example/lambda/HelloLambda.java に記述します。

package com.example.lambda;

import com.amazonaws.services.lambda.runtime.Context;
import com.amazonaws.services.lambda.runtime.RequestHandler;
import java.util.Map;

public class HelloLambda implements RequestHandler<Map<String, Object>, String> {
    @Override
    public String handleRequest(Map<String, Object> event, Context context) {
        return "OK";
    }
}

まず、受け取る内容をJavaのクラスとして定義します。 Input.java という名前で以下のように定義します。

package com.example.lambda;

import java.util.List;
import com.fasterxml.jackson.annotation.JsonProperty;

public class Input {
    public String filter;
    public List<Header> headers;
    public String subject;

    @JsonProperty("envelope-to")
    public String envelopeTo;

    @JsonProperty("envelope-from")
    public String envelopeFrom;

    @JsonProperty("server_composition")
    public String serverComposition;

    public String html;
    public String text;

    public static class Header {
        public String name;
        public String value;
    }
}

そして、リクエストデータをInputクラスにマッピングします。

ObjectMapper mapper = new ObjectMapper();

// "body" は String として渡されるので、まず取り出してパースする
String bodyJson = (String) event.get("body");
Input input = mapper.readValue(bodyJson, Input.class);

後は、このオブジェクトから必要な情報を取り出して処理を行います。

System.out.println("filter: " + input.filter); // filter: info@smtps.jp
System.out.println("subject: " + input.subject); // subject: Webhookのテスト
System.out.println("envelopeTo: " + input.envelopeTo); // envelopeTo: user@example.com

全体のコードは以下の通りです。

package com.example.lambda;

import com.amazonaws.services.lambda.runtime.Context;
import com.amazonaws.services.lambda.runtime.RequestHandler;
import com.fasterxml.jackson.databind.ObjectMapper;

import java.util.Map;

public class HelloLambda implements RequestHandler<Map<String, Object>, String> {

    @Override
    public String handleRequest(Map<String, Object> event, Context context) {
        try {
            ObjectMapper mapper = new ObjectMapper();

            // "body" は String として渡されるので、まず取り出してパースする
            String bodyJson = (String) event.get("body");
            Input input = mapper.readValue(bodyJson, Input.class);

            // ここでようやく値が正しく取れる
            System.out.println("filter: " + input.filter); // filter: info@smtps.jp
            System.out.println("subject: " + input.subject); // subject: Webhookのテスト
            System.out.println("envelopeTo: " + input.envelopeTo); // envelopeTo: user@example.com

            return "OK";
        } catch (Exception e) {
            e.printStackTrace();
            return "ERROR";
        }
    }
}