Notionのデータベースにレコードが追加されたらメールを送信する

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

mkdir notion-app
cd notion-app

npm init -y

npm i @notionhq/client
npm i blastengine
npm i dotenv
npm i typescript -D
npm i ts-node -D

NOTION_SECRET=Notionの内部インテグレーショントークン
MAILDB_ID=NotionのデータベースページのID（URLから取得）

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

# 以下はフィールドの名前
STATUS_PROPERTY=送信状態
STATUS_VALUE=送信待ち
SUBJECTNAME=件名
DELIVERYID_PROPERTY=配信ID

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

// dotenvを読み込む
import * as dotenv from 'dotenv';
import {
	PageObjectResponse,
	UpdatePageResponse
} 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 () => {
  // 処理が重複されないようにするフラグ
	let lock = false;
  setInterval(() => {
    // ここからはこの中に書いていきます
  }, 5000); // 5秒ごとに実行
})();

const ary = await fetchMail(process.env.MAILDB_ID!);

// Notionデータベースから未送信の情報を取得する関数
const fetchMail = async (databaseId: string): Promise<{[key: string]: string}[]> => {
	const res = await notion.databases.query({
    database_id: databaseId,
		filter: {
			and: [{
				property: process.env.STATUS_PROPERTY!,
				status: {
					equals: process.env.STATUS_VALUE!,
				}
			}]
		}
	});
	return (res.results as PageObjectResponse[]).map(row => {
		const properties = row.properties as {[key: string]: any};
		const params: {[key: string]: string} = {
			id: row.id,
		};
		Object.keys(properties).forEach(key => {
			const property = properties[key];
			if (property.type === 'rich_text' && property.rich_text.length > 0) {
				params[key] = property.rich_text[0].plain_text;
			}
			if (property.type === 'title' && property.title.length > 0) {
				params[key] = property.title[0].plain_text;
			}
		});
		return params;
	});
};

// 処理をロック
if (ary.length > 0 && !lock) {
	lock = true;
} else {
	// ロックされていれば処理は中断
	return;
}

for (const row of ary) {
  // ここからはこの中に記述します
}

const body = await getBody(row.id);

// 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");
};

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

await transaction
	.setFrom(
		process.env.FROMADDRESS!,
		process.env.FROMNAME!
	) // 送信元のメールアドレスと名前
	.setSubject(
		row[process.env.SUBJECTNAME!]
	) // 件名
	.setText(body) // 本文
	.setTo(
		row[process.env.EMAIL_PROPERTY!]
	)
	.send();

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

await updatePage(row.id, transaction.delivery_id!);

// Notionデータベースを更新する
const updatePage = async (
	pageId: string,
	deliveryId: number
): Promise<UpdatePageResponse> => {
	return notion.pages.update({
		page_id: pageId,
		properties: {
			[process.env.STATUS_PROPERTY!]: {
				status: {
					name: '送信完了'
				}
			},
			[process.env.DELIVERYID_PROPERTY!]: {
				number: deliveryId
			}
		}
	});
};

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

// dotenvを読み込む
import * as dotenv from 'dotenv';
import {
	PageObjectResponse,
	UpdatePageResponse
} 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 fetchMail = async (databaseId: string): Promise<{[key: string]: string}[]> => {
	const res = await notion.databases.query({
    database_id: databaseId,
		filter: {
			and: [{
				property: process.env.STATUS_PROPERTY!,
				status: {
					equals: process.env.STATUS_VALUE!,
				}
			}]
		}
	});
	return (res.results as PageObjectResponse[]).map(row => {
		const properties = row.properties as {[key: string]: any};
		const params: {[key: string]: string} = {
			id: row.id,
		};
		Object.keys(properties).forEach(key => {
			const property = properties[key];
			if (property.type === 'rich_text' && property.rich_text.length > 0) {
				params[key] = property.rich_text[0].plain_text;
			}
			if (property.type === 'title' && property.title.length > 0) {
				params[key] = property.title[0].plain_text;
			}
		});
		return params;
	});
};

// Notionデータベースを更新する
const updatePage = async (
	pageId: string,
	deliveryId: number
): Promise<UpdatePageResponse> => {
	return notion.pages.update({
		page_id: pageId,
		properties: {
			[process.env.STATUS_PROPERTY!]: {
				status: {
					name: '送信完了'
				}
			},
			[process.env.DELIVERYID_PROPERTY!]: {
				number: deliveryId
			}
		}
	});
};

// 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 () => {
	let lock = false;
	setInterval(async () => {
		const ary = await fetchMail(process.env.MAILDB_ID!);
		// 処理をロック
		if (ary.length > 0 && !lock) {
			lock = true;
		} else {
			// ロックされていれば処理は中断
			return;
		}
		for (const row of ary) {
			const body = await getBody(row.id);
			const transaction = new Transaction();
      await transaction
	      .setFrom(
		      process.env.FROMADDRESS!,
		      process.env.FROMNAME!
	      ) // 送信元のメールアドレスと名前
      	.setSubject(
		      row[process.env.SUBJECTNAME!]
	      ) // 件名
	      .setText(body) // 本文
	      .setTo(
	      	row[process.env.EMAIL_PROPERTY!]
	      )
	      .send();
			console.log(`送信完了${transaction.delivery_id}`);
			await updatePage(row.id, transaction.delivery_id!);
		}
		lock = false;
	}, 5000);
})();

npx ts-node send.ts

送信完了1326
送信完了1327