Webhook APIを使ってメールを処理する（Google Cloud Functions + Node.js）

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

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

今回はGoogle Cloud Functionsで、Node.js/TypeScriptを使ってメールを処理する流れを紹介します。

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

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

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

Google Cloud Functionsの準備

今回はローカルで開発する流れを紹介します。まず、適当なフォルダを作成します。今回はcmcとします。

mkdir cmc
cd cmc

そしてTypeScriptプロジェクト用に準備します。

npm i typescript -D
npx tsc --init
mkdir src

tsconfig.json を編集します。

{
    // 省略
    "rootDir": "./src",                                  /* Specify the root folder within your source files. */
    "outDir": "./dist",                                   /* Specify an output folder for all emitted files. */
    // 省略
}

そしてライブラリをインストールします。

npm i @google-cloud/functions-framework

次に src/index.ts というファイルを作成します。内容は以下の通りです。

import * as functions from '@google-cloud/functions-framework';

functions.http('helloGET', (req, res) => {
    // ここに処理を記述します
  res.send('ok');
});

そして、以下のようにコマンドを実行します。

npx tsc && npx @google-cloud/functions-framework --target=helloGET

これで、 http://localhost:8080 にてサーバーが立ち上がります。

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"
}

TypeScriptのコード

処理は src/index.ts の functions.http 内に記述します。

import * as functions from '@google-cloud/functions-framework';

functions.http('helloGET', (req, res) => {
    // ここに処理を記述します
  res.send('ok');
});

送られてくるデータは req.body で受け取れます。この内容はJSONオブジェクトなので、キーを使ってデータを取得できます。

const { body } = req;

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

console.log(body.filter);  // info@smtps.jp
console.log(body.subject); // Webhookのテスト

Webhookの結果は管理画面で確認

Webhookでデータが送信されたログは管理画面で確認できます。送信時のAPIキー設定など、HTTPヘッダーを編集するといった機能も用意されていますので、運用に応じて細かなカスタマイズが可能です。

まとめ

メールと連携したシステムはよくあります。通常、メールサーバを立てて、その中で処理することが多いのですが、メールサーバが落ちてしまうとシステムが稼働しなくなったり、メール文面の解析が煩雑でした。Customers Mail Cloudを使えばそうした手間なくJSONで処理できて便利です。

受信サーバ | Customers Mail Cloud