CloudFlare Workers×Slack API×GitHub APIで技術記事ドラフト作成Botをつくってみた #OpenAI

interface Env {
	OPENAI_API_KEY: string;
	GITHUB_TOKEN: string;
	GITHUB_REPO: string;
	GITHUB_BRANCH: string;
}

/**
 * handler
 */
export default {
	async fetch(request: Request, env: Env, ctx: ExecutionContext): PromiseResponse> {
		const url = new URL(request.url);

		if (request.method === 'POST' && url.pathname === '/slack/events') {
			const rawBody = await request.text();
			const params = new URLSearchParams(rawBody);
			const responseUrl = params.get('response_url') ?? '';
			const text = params.get('text') ?? '';

            // 非同期バックグラウンド実行
			ctx.waitUntil(handleSlackEvent(text, responseUrl, env));
            // 即時レスポンス（Slackタイムアウト回避）
			return new Response(`✏️プロンプトを受け取りました。記事生成中です。\nprompt:\n${text}`);
		}

		return new Response('Not Found', { status: 404 });
	},
} satisfies ExportedHandlerEnv>;

/**
 * 非同期処理本体
 */
async function handleSlackEvent(prompt: string, responseUrl: string, env: Env): Promisevoid> {
	try {
		const { title, body } = await generateArticle(prompt, env.OPENAI_API_KEY);
		const resultMessage = await uploadToGitHub(title, body, env);
		if (responseUrl) await notifySlack(responseUrl, resultMessage);
	} catch (err) {
		console.error('処理失敗:', err);
		if (responseUrl) {
			await notifySlack(responseUrl, `❌ エラーが発生しました: ${(err as Error).message}`);
		}
	}
}

/**
 * systemプロンプト
 */
const SYSTEM_PROMPT = `
あなたは技術記事執筆アシスタントです。
以下のルールに従って、Markdown形式で技術記事のドラフトを生成してください：

- 記事の最初に必ず1つだけ H1 見出し（タイトル）を記載してください（例：# Cloudflare WorkersでBotを作ってみた）。
- 以降はH2見出し（##）を使ってセクションを整理してください。
- 挨拶文や前置きは省いて、記事の内容を直接書いてください。
`;

/**
 * 記事を生成する
 * @param prompt 記事の内容
 * @param apiKey OpenAIのAPIキー
 * @returns 記事のタイトルと本文
 */
async function generateArticle(prompt: string, apiKey: string): Promise{ title: string; body: string }> {
	const response = await fetch('https://api.openai.com/v1/chat/completions', {
		method: 'POST',
		headers: {
			Authorization: `Bearer ${apiKey}`,
			'Content-Type': 'application/json',
		},
		body: JSON.stringify({
			model: 'gpt-4o',
			messages: [
				{
					role: 'system',
					content: SYSTEM_PROMPT,
				},
				{
					role: 'user',
					content: `以下の内容の技術記事のドラフトを作成してください。\n${prompt}`,
				},
			],
		}),
	});

	const data = await response.json();
	const content = data.choices?.[0]?.message?.content ?? '';
	const [firstLine, ...rest] = content.split('\n');

	const title = firstLine.replace(/^# /, '').trim();
	const body = rest.join('\n').trim();

	return { title, body };
}

/**
 * GitHubに記事をアップロード
 * @param title 記事のタイトル
 * @param body 記事の本文
 * @param env 環境変数
 * @returns アップロード結果
 */
async function uploadToGitHub(title: string, body: string, env: Env): Promisestring> {
	const filePath = `draft/${title}.md`;
	const [owner, repo] = env.GITHUB_REPO.split('/');

	const res = await fetch(`https://api.github.com/repos/${owner}/${repo}/contents/${filePath}`, {
		method: 'PUT',
		headers: {
			Authorization: `Bearer ${env.GITHUB_TOKEN}`,
			'Content-Type': 'application/json',
			Accept: 'application/vnd.github+json',
			'User-Agent': 'tech-blog-draft-bot',
		},
		body: JSON.stringify({
			message: `Add draft: ${filePath}`,
			content: btoa(String.fromCharCode(...new TextEncoder().encode(body))),
			branch: env.GITHUB_BRANCH,
		}),
	});

	if (!res.ok) {
		const text = await res.text();
		throw new Error(`GitHub投稿失敗: ${text}`);
	}

	return `✅ 記事をGitHubに投稿しました: ${title}`;
}

/**
 * Slackに通知
 * @param responseUrl SlackのWebhook URL
 * @param message 通知メッセージ
 */
async function notifySlack(responseUrl: string, message: string): Promisevoid> {
	const res = await fetch(responseUrl, {
		method: 'POST',
		headers: { 'Content-Type': 'application/json' },
		body: JSON.stringify({ text: message }),
	});

	if (!res.ok) {
		console.warn('Slack通知失敗');
	}
}