Customers Mail CloudのWebhookは2種類あります。
- メール受信時
- メール送信時
メール受信時のWebhookはその名の通り、メールを受け取った際に任意のURLをコールするものです。この記事では添付ファイル付きメールを受け取った際のWebhook処理について解説します。
フォーマットはマルチパートフォームデータ
Webhookの形式として、JSONとマルチパートフォームデータ(multipart/form-data)が選択できます。この二つの違いは、添付ファイルがあるかどうかです。JSONの場合、添付ファイルは送られてきません。今回のようにメールに添付ファイルがついてくる場合は、後者を選択してください。
送信されてくるデータについて
メールを受信すると、以下のようなWebhookが送られてきます(データは一部マスキングしています)。JSONにしていますが、実際にはmultipart/form-data
です。
{ "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", "attachments": 1, "attachment1": "...." }
Deno Deployの準備
今回はローカルで開発する流れを紹介します。Denoのインストールは行っている前提とします。その上で、任意のフォルダを作成します。
mkdir cmc_demo cd cmc_demo
そして、 main.ts
というファイルを作成します。
import { serve } from "https://deno.land/std@0.140.0/http/server.ts"; serve(async (_req) => { try { return new Response("ok", { status: 200 }); } catch (error) { return new Response("Invalid request", { status: 400 }); } });
実行する際には、下記コマンドを実行します。
deno run --watch --allow-net main.ts
これで、 http://localhost:8000
にてサーバーが立ち上がります。
TypeScriptのコード
処理は main.ts
に記述します。
import { serve } from "https://deno.land/std@0.140.0/http/server.ts"; serve(async (_req) => { try { // ここに処理を記述します return new Response("ok", { status: 200 }); } catch (error) { return new Response("Invalid request", { status: 400 }); } });
マルチパートフォームデータを取得する
multipart/form-data
で送られてくるデータは _req.formData()
にて受け取れます。たとえば、添付ファイルの数を取得する場合は以下のようにします。この数が1以上の場合、添付ファイルがあるということです。
const params = await _req.formData(); const attachments = parseInt(params.get('attachments') as string || '0'); if (attachments > 0) { // 添付ファイルあり }
その他のフィールドも同じように get
メソッドで取得できます。
console.log(params.get('filter')); console.log(params.get('subject'));
ファイルは params.get('attachment1')
にて取得します。末尾の数字は添付ファイルの数に合わせて変化します。
const file = params.get('attachment1'); console.log(file); // Fileオブジェクト
ファイルを保存する場合には、ArrayBufferでデータを取得します。なお、実行する際に --allow-write
オプションが必要になります。
const arrayBuffer = await file.arrayBuffer(); const uint8Array = new Uint8Array(arrayBuffer); await Deno.writeFile(`./upload/${file.name}`, uint8Array);
Webhookの結果は管理画面で確認
Webhookでデータが送信されたログは管理画面で確認できます。送信時のAPIキー設定など、HTTPヘッダーを編集するといった機能も用意されていますので、運用に応じて細かなカスタマイズが可能です。
まとめ
メールと連携したシステムはよくあります。通常、メールサーバを立てて、その中で処理することが多いのですが、メールサーバが落ちてしまうとシステムが稼働しなくなったり、メール文面の解析が煩雑でした。Customers Mail Cloudを使えばそうした手間なくJSONで処理できて便利です。
添付ファイルまで処理対象にしたい時には、この方法を利用してください。