Slack のやりとりから GitHub Issue を自動作成する Bot を作った

chat.onNewMention(async (thread, message) => {
  const userId = message.author?.userId ?? "";
  const mentionText = message.text ?? "";

  // 認可チェック
  if (!isAllowedUser(userId, env.ALLOWED_SLACK_USER_IDS)) {
    await thread.post(
      ":no_entry: このボットを使用する権限がありません。管理者にお問い合わせください。"
    );
    return;
  }

  // 処理中をリアクションで示す
  await thread.adapter.addReaction(thread.id, message.id, "hourglass_flowing_sand");

  // ... Issue 作成処理
});

// チャンネルの直近メッセージを取得
const channelResult = await thread.adapter.fetchChannelMessages?.(
  `slack:${thread.channelId}`,
  { limit: 20 }
);

// スレッドのメッセージを追加（重複を避ける）
for await (const msg of thread.messages) {
  const text = msg.text ?? "";
  const author = msg.author?.displayName ?? "unknown";
  if (text.trim() && !conversationHistory.some((h) => h.text === text)) {
    conversationHistory.push({ author, text });
  }
}

const { text } = await generateText({
  model,
  system:
    "あなたは Slack の会話から GitHub Issue を作成する優秀なアシスタントです。必ず有効な JSON のみを返してください。",
  prompt: `以下は Slack の会話履歴です。この内容を元に GitHub Issue を作成してください。

## 会話履歴
${conversationText || "（会話履歴なし）"}

## ユーザーからの指示
${mentionText}

## 出力ルール
- 会話履歴が少なくてもユーザーからの指示に何か書かれていれば必ず Issue を作成する
- labels は ["bug", "enhancement", "documentation", "question"] の中から最も適切なものを 1〜2 個選ぶ
- 常に以下の JSON 形式で出力する

## 出力形式
{
  "title": "日本語のタイトル",
  "body": "日本語の本文（Markdown 形式）",
  "labels": ["bug"]
}`,
});

export function extractRepoFromText(
  text: string
): { owner: string; repo: string } | null {
  const match = text.match(/([a-zA-Z0-9_.-]+)\/([a-zA-Z0-9_.-]+)/);
  if (!match) return null;
  return { owner: match[1], repo: match[2] };
}

@楠本雑務bot set-repo kusumotoa/myapp

const keywords = title
  .split(/[\s\u3000]+/)
  .filter((w) => w.length >= 2)
  .slice(0, 5)
  .join(" ");

const response = await octokit.search.issuesAndPullRequests({
  q: `repo:${owner}/${repo} is:issue ${keywords}`,
  per_page: 5,
});

if (isCloseRequest(userText)) {
  await closeGitHubIssue(env.GITHUB_TOKEN, {
    owner: state.repo!.owner,
    repo: state.repo!.repo,
    issueNumber: state.issueNumber!,
  });
  await thread.post(`:lock: Issue #${state.issueNumber} をクローズしました。`);
  return;
}

export class ChatStateDO extends DurableObject<Env> {
  async subscribe(threadId: string): Promise<void> {
    await this.ctx.storage.put(`sub:${threadId}`, true);
  }

  async acquireLock(threadId: string, ttlMs: number): Promise<StoredLock | null> {
    const existing = await this.ctx.storage.get<StoredLock>(`lock:${threadId}`);
    if (existing && existing.expiresAt > Date.now()) return null;

    const lock = { threadId, token: crypto.randomUUID(), expiresAt: Date.now() + ttlMs };
    await this.ctx.storage.put(`lock:${threadId}`, lock);
    return lock;
  }

  async getValue(key: string): Promise<string | null> {
    const stored = await this.ctx.storage.get<StoredEntry>(`kv:${key}`);
    if (!stored) return null;
    if (stored.expiresAt !== null && stored.expiresAt <= Date.now()) {
      await this.ctx.storage.delete(`kv:${key}`);
      return null;
    }
    return stored.json;
  }
  // ...
}

class DurableObjectStateAdapter implements StateAdapter {
  private stub: DurableObjectStub<ChatStateDO>;

  constructor(namespace: DurableObjectNamespace<ChatStateDO>) {
    const id = namespace.idFromName("chat-state");
    this.stub = namespace.get(id);
  }

  async get<T = unknown>(key: string): Promise<T | null> {
    const json = await this.stub.getValue(key);
    return json != null ? (JSON.parse(json) as T) : null;
  }

  async set<T = unknown>(key: string, value: T, ttlMs?: number): Promise<void> {
    await this.stub.setValue(key, JSON.stringify(value), ttlMs);
  }
  // ...
}

[[durable_objects.bindings]]
name = "CHAT_STATE"
class_name = "ChatStateDO"

[[migrations]]
tag = "v1"
new_sqlite_classes = ["ChatStateDO"]

const slackLink = await getSlackPermalink(env.SLACK_BOT_TOKEN, thread.id);
const body = slackLink
  ? `${issueContent.body}\n\n---\n[元の Slack スレッド](${slackLink})`
  : issueContent.body;

src/
├── index.ts         - Cloudflare Workers エントリーポイント
├── bot.ts           - Chat SDK 初期化とイベントハンドラー
├── state.ts         - Durable Objects StateAdapter 実装
├── auth.ts          - Slack ユーザー認可チェック
├── github.ts        - GitHub Issue 作成・更新・検索（@octokit/rest）
├── issue-builder.ts - AI による Issue 内容生成
├── slack-utils.ts   - Slack API ユーティリティ（パーマリンク取得など）
└── durable-objects/
    └── chat-state.ts - Durable Objects クラス（状態永続化）

# シークレットを設定
wrangler secret put SLACK_BOT_TOKEN
wrangler secret put SLACK_SIGNING_SECRET
wrangler secret put GITHUB_TOKEN
wrangler secret put ALLOWED_SLACK_USER_IDS

# デプロイ
bun run deploy