Notionからblastengine経由で送信したメールのエラーステータスを更新する

更新日：2024年11月11日 Notion

Notionは最近注目度の高い情報共有サービスです。Wikiのように自由テキストを保存したり、データベースのように構造化されたデータを保存もできます。

今回はそんなNotion内にあるメールアドレスを使って、blastengineと組み合わせてみました。前回はNotionデータベース上のメールアドレスを使ってメール送信を行いましたので、今回はエラーステータスをデータベースに反映します。

機能について

データベースにある顧客リストのメールアドレス宛にメールを一括送信
エラーリストを使って次回以降送信しないようにNotionのデータを更新

後半となるこの記事ではblastengineから取得できるエラーリストを使って、データベースにある顧客リストのメールアドレスのステータスを更新します。

ベースとなるアプリやライブラリは前回のものを使います。

ファイルの作成

今回は update.ts というファイルを作成します。

ライブラリ読み込み

update.ts への記述です。まず最初に必要なライブラリを読み込みます。

// dotenvを読み込み、環境変数を設定する
require('dotenv').config();

// Notionのクライアントを読み込む
import { Client } from '@notionhq/client';

// Notionから返されるページオブジェクトの型を読み込む
import { PageObjectResponse } from '@notionhq/client/build/src/api-endpoints';

// blastEngineとErrorReportを読み込む
import { BlastEngine, ErrorReport } from 'blastengine'

Notionクライアントの初期化への接続情報を作成する

.env ファイルに定義したシークレットを使って、Notionクライアントを作成します。

// Notion APIの認証を設定
const notion = new Client({ auth: process.env.NOTION_SECRET });

blastengineの初期化

blastengine SDKを初期化します。こちらも .env ファイルの内容を使います。

// blastEngineを初期化する
new BlastEngine(process.env.BLASTENGINE_USERID, process.env.BLASTENGINE_APIKEY);

無名関数の定義

ここからはネットワーク処理があるので、非同期処理用にasync/awaitを定義します。

// メイン処理をasync関数で囲む
(async () => {
  // ここからはこの中に書いていきます
})();

blastengineのエラーレポートをダウンロード

blastengineのエラーレポートをダウンロードします。これは、2回以上配信エラーがあったメールアドレスが記録されています。

// blastEngineのエラーレポートを管理するオブジェクトを作成する
const report = new ErrorReport;
// ダウンロードができるようになるまで待つ
while (await report.finished() === false) {
	// 1秒待つ
	await new Promise(res => setTimeout(res, 1000));
}
// エラーレポートをダウンロードする
const results = await report.download();

エラーレポートは管理画面でも確認できます。

Notionからレコードを取得

エラーレポートに含まれているメールアドレスを使って、Notionのデータベースを検索します。

// ダウンロードしたエラーレポートからメールアドレスを取り出し、
// それらのメールが含まれるページのIDを取得する
const ary = await fetchAll(
	process.env.DB_ID!,
	results.map((r: any) => r.email)
);

fetchAll関数は以下のようになります。関数は (async () => { 外で問題ありません。

// Notionデータベースから未送信の情報を取得する関数
const fetchAll = async (databaseId: string, emails: string[]): Promise<string[]> => {
	// データベースをクエリして、結果を取得する
	const res = await notion.databases.query({
    database_id: databaseId,
		filter: {
			// フィルタ条件は指定されたメールアドレスが含まれているエントリ
			or: emails.map(email => ({
				property: process.env.EMAIL_PROPERTY!,
				rich_text: {
					contains: email,
				}
			}))
		}
	});
	// 返された結果からIDのみを取り出す
	return (res.results as PageObjectResponse[]).map(row => row.id);
};

Notionデータベースのプロパティを更新する

取得できたページIDを使って、Notionデータベースを更新します。

// 取得したページのIDに対してプロパティを更新する
await updateAll(ary);

updateAll 関数は以下のようになります。これも (async () => { 外で問題ありません。

// 全ての指定されたページのプロパティを更新する関数
const updateAll = async (ary: string[]): Promise<boolean> => {
	// 指定されたページIDすべてを非同期で更新する
	const res = await Promise.all(ary.map(id => {
		return notion.pages.update({
			page_id: id,
			properties: {
				// 更新するプロパティはCHECKBOX_IDの値
				[process.env.CHECKBOX_ID!]: {
					checkbox: true,
				}
			}
		});
	}));
	return true;
};

スクリプトの全体像

update.ｔs の内容は以下の通りです。

// dotenvを読み込み、環境変数を設定する
require('dotenv').config();

// Notionのクライアントを読み込む
import { Client } from '@notionhq/client';

// Notionから返されるページオブジェクトの型を読み込む
import { PageObjectResponse } from '@notionhq/client/build/src/api-endpoints';

// Notion APIの認証を設定する
const notion = new Client({ auth: process.env.NOTION_SECRET });

// blastEngineとErrorReportを読み込む
import { BlastEngine, ErrorReport } from 'blastengine';

// BlastEngineのユーザIDとAPIキーを使ってblastEngineを初期化する
new BlastEngine(process.env.BLASTENGINE_USERID, process.env.BLASTENGINE_APIKEY);

// Notionデータベースから未送信の情報を取得する関数
const fetchAll = async (databaseId: string, emails: string[]): Promise<string[]> => {
	// データベースをクエリして、結果を取得する
	const res = await notion.databases.query({
    database_id: databaseId,
		filter: {
			// フィルタ条件は指定されたメールアドレスが含まれているエントリ
			or: emails.map(email => ({
				property: process.env.EMAIL_PROPERTY!,
				rich_text: {
					contains: email,
				}
			}))
		}
	});
	// 返された結果からIDのみを取り出す
	return (res.results as PageObjectResponse[]).map(row => row.id);
};

// 全ての指定されたページのプロパティを更新する関数
const updateAll = async (ary: string[]): Promise<boolean> => {
	// 指定されたページIDすべてを非同期で更新する
	const res = await Promise.all(ary.map(id => {
		return notion.pages.update({
			page_id: id,
			properties: {
				// 更新するプロパティはCHECKBOX_IDの値
				[process.env.CHECKBOX_ID!]: {
					checkbox: true,
				}
			}
		});
	}));
	return true;
};

// メイン処理をasync関数で囲む
(async () => {
	// blastEngineのエラーレポートを管理するオブジェクトを作成する
	const report = new ErrorReport;
	// ダウンロードができるようになるまで待つ
	while (await report.finished() === false) {
		// 1秒待つ
		await new Promise(res => setTimeout(res, 1000));
	}
	// エラーレポートをダウンロードする
	const results = await report.download();
  // ダウンロードしたエラーレポートからメールアドレスを取り出し、
  // それらのメールが含まれるページのIDを取得する
  const ary = await fetchAll(
  	process.env.DB_ID!,
  	results.map((r: any) => r.email)
  );
	// 取得したページのIDに対してプロパティを更新する
	await updateAll(ary);
	// 完了メッセージをログに表示する
	console.log('更新完了しました');
})();