iOS Crashlytics の障害トリアージを Claude Code で自動化する — dSYM シンボリケーションから修正候補生成までの本番運用設計

// functions/src/crashlytics-ingest.ts
import { onMessagePublished } from "firebase-functions/v2/pubsub";
import { Firestore, FieldValue } from "@google-cloud/firestore";
 
const db = new Firestore();
const DEDUP_WINDOW_MIN = 30; // 同一 Issue ID は30分以内なら再処理しない
 
export const ingestCrashlyticsIssue = onMessagePublished(
  { topic: "crashlytics-issues", region: "asia-northeast1", memory: "512MiB" },
  async (event) => {
    const payload = event.data.message.json as CrashlyticsPayload;
    const issueKey = `${payload.app.bundleId}:${payload.issue.id}`;
 
    const ref = db.collection("crash_triage").doc(issueKey);
    const snap = await ref.get();
    if (snap.exists) {
      const last = snap.data()?.lastSeenAt?.toDate();
      const minutesSince = last ? (Date.now() - last.getTime()) / 60000 : Infinity;
      if (minutesSince < DEDUP_WINDOW_MIN) {
        await ref.update({
          recurrenceCount: FieldValue.increment(1),
          lastSeenAt: FieldValue.serverTimestamp(),
        });
        return; // Claude 呼び出しは行わない
      }
    }
 
    await ref.set({
      bundleId: payload.app.bundleId,
      version: payload.app.version,
      issueId: payload.issue.id,
      title: payload.issue.title,
      stackTraceRaw: payload.issue.exception.stack_trace,
      affectedUsers: payload.issue.distinct_counts.users,
      crashCount: payload.issue.distinct_counts.events,
      firstSeenAt: FieldValue.serverTimestamp(),
      lastSeenAt: FieldValue.serverTimestamp(),
      recurrenceCount: 1,
      status: "queued",
    }, { merge: true });
 
    await db.collection("triage_queue").add({
      issueKey,
      enqueuedAt: FieldValue.serverTimestamp(),
    });
  }
);

#!/usr/bin/env bash
# scripts/symbolicate.sh
set -euo pipefail
 
ISSUE_KEY="$1"          # 例: com.dolice.wallpapers:abc123
DSYM_BUCKET="gs://wallpaper-crash-pipeline/dsyms"
 
# Firestore から必要情報を取得（gcloud firestore は1コマンドに収まる範囲のみ使用）
BUNDLE_ID=$(echo "$ISSUE_KEY" | cut -d: -f1)
VERSION=$(gcloud firestore documents describe "crash_triage/${ISSUE_KEY}" \
  --format="value(fields.version.stringValue)")
 
# 該当 dSYM をローカルに展開
WORKDIR=$(mktemp -d)
gsutil -m cp -r "${DSYM_BUCKET}/${BUNDLE_ID}/${VERSION}/" "${WORKDIR}/dsym/"
unzip -q "${WORKDIR}/dsym/"*.zip -d "${WORKDIR}/dsym_expanded"
 
# atos でアドレスをシンボル名に変換し、Firestore に書き戻し
python3 scripts/atos_resolve.py \
  --issue-key "${ISSUE_KEY}" \
  --dsym-dir "${WORKDIR}/dsym_expanded" \
  --output "${WORKDIR}/symbolicated.json"
 
gcloud firestore documents update "crash_triage/${ISSUE_KEY}" \
  --update-fields-file="${WORKDIR}/symbolicated.json"
 
rm -rf "${WORKDIR}"

# .github/workflows/crash-triage.yml の中核
- name: Run Claude Code RCA
  env:
    CLAUDE_API_KEY: ${{ secrets.CLAUDE_API_KEY }}
    ISSUE_KEY: ${{ inputs.issue_key }}
  run: |
    npx -y @anthropic-ai/claude-code@latest \
      --headless \
      --allowedTools "Read,Grep,Bash(git log:*),Bash(git diff:*)" \
      --output-format markdown \
      --output-file ./out/rca_${{ inputs.issue_key }}.md \
      --prompt-file ./prompts/rca_triage.md \
      --context-file ./context/${{ inputs.issue_key }}.json

// scripts/open-draft-pr.js（抜粋）
import { Octokit } from "@octokit/rest";
 
const issueKey = process.env.ISSUE_KEY;
const rcaBody = await fs.readFile(`./out/rca_${issueKey}.md`, "utf-8");
 
const branch = `crashtriage/${issueKey.replace(/[:.]/g, "-")}-${Date.now()}`;
await octokit.git.createRef({ owner, repo, ref: `refs/heads/${branch}`, sha: mainSha });
 
const pr = await octokit.pulls.create({
  owner, repo,
  head: branch,
  base: "main",
  title: `[crash-triage] ${title} — auto draft`,
  body: rcaBody,
  draft: true,
});
 
await slack.chat.postMessage({
  channel: "#crashlytics-triage",
  text: `🩹 Draft PR opened: <${pr.data.html_url}|#${pr.data.number}> for *${issueKey}*`,
});