Notionのデータベースから一斉メール配信する

txt @ v=spf1 include:spf.besender.jp ~all

mkdir notion-app
cd notion-app

npm init -y

npm i @kintone/kintone-js-sdk
npm i blastengine
npm i dotenv
npm i typescript -D
npm i ts-node -D

NOTION_SECRET=Notionの内部インテグレーショントークン
DB_ID=NotionのデータベースページのID（URLから取得）
CHECKBOX_ID=送信不可フラグのID
EMAIL_PROPERTY=メールアドレスの入っているフィールドの名前
NAME_PROPERTY=名前が入っているフィールドの名前
PAGE_ID=NotionのメールテンプレートページのID（URLから取得）

BLASTENGINE_USERID=blastengineのユーザー名
BLASTENGINE_APIKEY=blastengineのAPIキー
FROMNAME=送信元の名前
FROMADDRESS=送信元のメールアドレス

// blastEngine SDKとBulkを読み込む
import { BlastEngine, Bulk } from 'blastengine';
import { Client } from '@notionhq/client';

// dotenvを読み込む
import * as dotenv from 'dotenv';
import { PageObjectResponse } from '@notionhq/client/build/src/api-endpoints';
dotenv.config();

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

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

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

const ary = await fetchAll(process.env.DB_ID!);

// Notionデータベースから未送信の情報を取得する関数
const fetchAll = async (databaseId: string): Promise<{email: string, name: string}[]> => {
	const res = await notion.databases.query({
    database_id: databaseId,
		filter: {
			and: [{
				property: process.env.CHECKBOX_ID!,
				checkbox: {
					equals: false,
				}
			}]
		}
	});
	return (res.results as PageObjectResponse[]).map(row => {
		const properties = row.properties as {[key: string]: any};
		const name = (properties[process.env.NAME_PROPERTY!].title[0].plain_text);
		const email = properties[process.env.EMAIL_PROPERTY!].email;
		return {
			name, email,
		}
	});
};

const { title, body } = await getTemplate(process.env.PAGE_ID!);

// Notionページからテンプレートのタイトルと本文を取得する関数
const getTemplate = async (pageId: string): Promise<{title: string, body: string}> => {
	const title = await getTitle(pageId);
	const body = await getBody(pageId);
	return { title, body };
}

// Notionページからタイトルを取得する関数
const getTitle = async (pageId: string): Promise<string> => {
	const res = await notion.pages.retrieve({ page_id: pageId }) as any;
	return res.properties.title.title[0].plain_text;
};

// Notionページから本文を取得する関数
const getBody = async (pageId: string): Promise<string> => {
	const { results } = await notion.blocks.children.list({
		block_id: pageId,
		page_size: 200,
	});
	const ary = (results as any[])
		.map(row => 
			row.paragraph.rich_text && row.paragraph.rich_text[0]
				? row.paragraph.rich_text[0].plain_text
				: ''
		);
	return ary.join("\n");
};

// Bulkオブジェクトを作成する
const bulk = new Bulk();

// Bulkオブジェクトにメールの情報を設定する
await bulk
	.setFrom(process.env.FROMADDRESS, process.env.FROMNAME)   // 送信元のメールアドレスと名前
	.setSubject(process.env.SUBJECT)   // 件名
	.setText(text)   // 本文
	.register();   // 送信するメールの情報をblastEngineに登録する

// レコードを処理し、Bulkオブジェクトに宛先を追加する
ary.map(({email, name }) => {
	bulk.addTo(email, { name });
});

// blastEngineに登録したメールの情報を更新する
await bulk.update();

// blastEngineを使ってメールを送信する
await bulk.send();

// 送信が完了したことをログに出力する
console.log(`送信しました ${bulk.delivery_id}`);

// blastEngine SDKとBulkを読み込む
import { BlastEngine, Bulk } from 'blastengine';
import { Client } from '@notionhq/client';

// dotenvを読み込む
import * as dotenv from 'dotenv';
import { PageObjectResponse } from '@notionhq/client/build/src/api-endpoints';
dotenv.config();

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

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

// Notionデータベースから未送信の情報を取得する関数
const fetchAll = async (databaseId: string): Promise<{email: string, name: string}[]> => {
	const res = await notion.databases.query({
    database_id: databaseId,
		filter: {
			and: [{
				property: process.env.CHECKBOX_ID!,
				checkbox: {
					equals: false,
				}
			}]
		}
	});
	return (res.results as PageObjectResponse[]).map(row => {
		const properties = row.properties as {[key: string]: any};
		const name = (properties[process.env.NAME_PROPERTY!].title[0].plain_text);
		const email = properties[process.env.EMAIL_PROPERTY!].email;
		return {
			name, email,
		}
	});
};

// Notionページからテンプレートのタイトルと本文を取得する関数
const getTemplate = async (pageId: string): Promise<{title: string, body: string}> => {
	const title = await getTitle(pageId);
	const body = await getBody(pageId);
	return { title, body };
}

// Notionページからタイトルを取得する関数
const getTitle = async (pageId: string): Promise<string> => {
	const res = await notion.pages.retrieve({ page_id: pageId }) as any;
	return res.properties.title.title[0].plain_text;
};

// Notionページから本文を取得する関数
const getBody = async (pageId: string): Promise<string> => {
	const { results } = await notion.blocks.children.list({
		block_id: pageId,
		page_size: 200,
	});
	const ary = (results as any[])
		.map(row => 
			row.paragraph.rich_text && row.paragraph.rich_text[0]
				? row.paragraph.rich_text[0].plain_text
				: ''
		);
	return ary.join("\n");
};

(async () => {
	const ary = await fetchAll(process.env.DB_ID!);
	const { title, body } = await getTemplate(process.env.PAGE_ID!);
	const bulk = new Bulk();

	// Bulkオブジェクトにメールの情報を設定する
	await bulk
		.setFrom(process.env.FROMADDRESS!, process.env.FROMNAME) // 送信元のメールアドレスと名前
		.setSubject(title)   // 件名
		.setText(body)   // 本文
		.register();   // 送信するメールの情報をblastEngineに登録する
	// レコードを処理し、Bulkオブジェクトに宛先を追加する
	ary.map(({email, name }) => {
		bulk.addTo(email, { name });
	});
	
	// Bulkオブジェクトを更新する
	await bulk.update();
	
	// Bulkオブジェクトでメールを送信する
	await bulk.send();
	
	// 送信完了メッセージを表示する
	console.log(`送信しました ${bulk.delivery_id}`);
})();

npx ts-node mail.ts

送信しました 105