App Store Connect・RevenueCat・AdMob の朝の指標を Cloudflare Workers で1本化する — 6アプリ運用の日次集約アーキテクチャ

// src/asc.ts
const ASC_KEY_ID = "XXXXXXXXXX";
const ASC_ISSUER_ID = "00000000-0000-0000-0000-000000000000";
 
export async function signAscJwt(env: Env): Promise<string> {
  const pem = atob(env.ASC_PRIVATE_KEY_B64);
  const key = await crypto.subtle.importKey(
    "pkcs8",
    pemToBinary(pem),
    { name: "ECDSA", namedCurve: "P-256" },
    false,
    ["sign"],
  );
 
  const header = { alg: "ES256", kid: ASC_KEY_ID, typ: "JWT" };
  const payload = {
    iss: ASC_ISSUER_ID,
    iat: Math.floor(Date.now() / 1000),
    exp: Math.floor(Date.now() / 1000) + 1200, // 20 min
    aud: "appstoreconnect-v1",
  };
 
  const headerB64 = base64UrlEncode(JSON.stringify(header));
  const payloadB64 = base64UrlEncode(JSON.stringify(payload));
  const signingInput = `${headerB64}.${payloadB64}`;
 
  const signature = await crypto.subtle.sign(
    { name: "ECDSA", hash: { name: "SHA-256" } },
    key,
    new TextEncoder().encode(signingInput),
  );
 
  return `${signingInput}.${base64UrlEncode(signature)}`;
}

export async function fetchAscSalesReport(env: Env, dateYmd: string) {
  const jwt = await signAscJwt(env);
  const url = new URL("https://api.appstoreconnect.apple.com/v1/salesReports");
  url.searchParams.set("filter[frequency]", "DAILY");
  url.searchParams.set("filter[reportType]", "SALES");
  url.searchParams.set("filter[reportSubType]", "SUMMARY");
  url.searchParams.set("filter[vendorNumber]", env.ASC_VENDOR_NUMBER);
  url.searchParams.set("filter[reportDate]", dateYmd);
 
  const res = await fetch(url, {
    headers: { Authorization: `Bearer ${jwt}`, Accept: "application/a-gzip" },
  });
  if (res.status === 404) return null; // 当該日のレポート未確定
  if (!res.ok) throw new Error(`ASC ${res.status}`);
 
  const ds = new DecompressionStream("gzip");
  const decompressed = res.body!.pipeThrough(ds);
  const text = await new Response(decompressed).text();
  return parseTsv(text); // TSV を行・列のオブジェクトに
}

export async function fetchRevenueCatOverview(env: Env) {
  const res = await fetch(
    `https://api.revenuecat.com/v1/projects/${env.RC_PROJECT_ID}/overview`,
    { headers: { Authorization: `Bearer ${env.RC_SECRET_KEY}` } },
  );
  if (!res.ok) throw new Error(`RC ${res.status}`);
  return res.json();
}

export async function fetchAdMobReport(env: Env, dateYmd: string) {
  const access = await refreshAdMobAccessToken(env);
  const body = {
    reportSpec: {
      dateRange: { startDate: ymdToObj(dateYmd), endDate: ymdToObj(dateYmd) },
      dimensions: ["APP", "COUNTRY"],
      metrics: ["ESTIMATED_EARNINGS", "IMPRESSIONS", "CLICKS", "IMPRESSION_RPM"],
    },
  };
  const res = await fetch(
    `https://admob.googleapis.com/v1beta/accounts/${env.ADMOB_PUBLISHER_ID}/networkReport:generate`,
    { method: "POST", headers: { Authorization: `Bearer ${access}` }, body: JSON.stringify(body) },
  );
  if (!res.ok) throw new Error(`AdMob ${res.status}`);
  // 1 行目 header, 中間 rows, 最終行 footer の streaming JSON
  return parseAdMobReport(await res.json());
}

// src/config.ts
export const APP_REGISTRY = [
  { slug: "shooting-stars", asc: "123456789", rc: "app_abc", admob: "ca-app-pub-.../9999" },
  { slug: "moon-phases", asc: "234567890", rc: "app_def", admob: "ca-app-pub-.../8888" },
  // ... 6 apps
] as const;

function buildSlackBlocks(report: DailyReport) {
  const anomalies = report.apps.flatMap(detectAnomalies);
  const blocks: any[] = [
    { type: "header", text: { type: "plain_text", text: `Daily Metrics — ${report.date}` } },
  ];
  if (anomalies.length > 0) {
    blocks.push({
      type: "section",
      text: {
        type: "mrkdwn",
        text: `:rotating_light: *Anomalies (${anomalies.length})*\n` +
          anomalies.map(a => `• \`${a.app}\` ${a.metric}: ${a.delta} (${a.severity})`).join("\n"),
      },
    });
    blocks.push({ type: "divider" });
  }
  for (const app of report.apps) {
    blocks.push({
      type: "section",
      text: { type: "mrkdwn", text: formatAppLine(app) },
    });
  }
  return blocks;
}

# wrangler.toml
name = "rork-multiapp-metrics"
main = "src/index.ts"
compatibility_date = "2026-05-15"
 
[triggers]
crons = ["0 23 * * *"]
 
[[kv_namespaces]]
binding = "METRICS_KV"
id = "..."
 
[[d1_databases]]
binding = "METRICS_D1"
database_name = "metrics-history"
database_id = "..."
 
# Secrets を wrangler secret put で投入
# - ASC_PRIVATE_KEY_B64
# - ASC_VENDOR_NUMBER
# - RC_SECRET_KEY
# - RC_PROJECT_ID
# - ADMOB_PUBLISHER_ID
# - ADMOB_REFRESH_TOKEN
# - SLACK_WEBHOOK_URL