AdMob と AppLovin MAX を並走させて、Antigravity サブエージェントで日次比較する仕組み

// agents/collector-admob/index.ts
import { GoogleAuth } from "google-auth-library";
 
const SCOPES = ["https://www.googleapis.com/auth/admob.readonly"];
 
interface AdMobRow {
  date: string;        // YYYY-MM-DD
  country: string;     // ISO-3166 alpha-2
  adUnit: string;
  impressions: number;
  estimatedEarnings: number; // micro-units, 6桁デノミ
  matchRate: number;   // 0..1
}
 
export async function fetchAdMobDaily(
  publisherId: string,
  dateRange: { start: string; end: string }
): Promise<AdMobRow[]> {
  const auth = new GoogleAuth({ scopes: SCOPES });
  const client = await auth.getClient();
  const url = `https://admob.googleapis.com/v1/accounts/${publisherId}/networkReport:generate`;
 
  const body = {
    reportSpec: {
      dateRange: { startDate: parseDate(dateRange.start), endDate: parseDate(dateRange.end) },
      dimensions: ["DATE", "COUNTRY", "AD_UNIT"],
      metrics: ["IMPRESSIONS", "ESTIMATED_EARNINGS", "MATCH_RATE"],
      localizationSettings: { currencyCode: "USD", languageCode: "en-US" },
    },
  };
 
  const res = await client.request<unknown>({ url, method: "POST", data: body });
  return normalizeAdMobResponse(res.data);
}
 
function parseDate(iso: string) {
  const [year, month, day] = iso.split("-").map(Number);
  return { year, month, day };
}

// agents/collector-applovin/index.ts
import { parse } from "csv-parse/sync";
 
interface MaxRow {
  date: string;
  country: string;
  adUnit: string;
  impressions: number;
  estimatedEarnings: number; // USD float
  fillRate: number;          // 0..1
}
 
export async function fetchMaxDaily(
  apiKey: string,
  dateRange: { start: string; end: string }
): Promise<MaxRow[]> {
  const url = new URL("https://r.applovin.com/maxReport");
  url.searchParams.set("api_key", apiKey);
  url.searchParams.set("start", dateRange.start);
  url.searchParams.set("end", dateRange.end);
  url.searchParams.set("columns", "day,country,ad_unit_name,impressions,estimated_revenue,fill_rate");
  url.searchParams.set("format", "csv");
 
  const res = await fetch(url.toString());
  if (!res.ok) throw new Error(`MAX report failed: ${res.status}`);
  const csv = await res.text();
  const rows = parse(csv, { columns: true, skip_empty_lines: true });
  return rows.map((r: Record<string, string>) => ({
    date: r.day,
    country: r.country,
    adUnit: r.ad_unit_name,
    impressions: Number(r.impressions),
    estimatedEarnings: Number(r.estimated_revenue),
    fillRate: Number(r.fill_rate) / 100,
  }));
}

// agents/normalizer/aliases.ts
export const AD_UNIT_ALIASES: Record<string, string> = {
  "Wallpaper_App_iOS_Native_Home": "ios_home_native",
  "home_native_ios": "ios_home_native",
  "Wallpaper_App_iOS_Interstitial_Detail": "ios_detail_interstitial",
  "detail_interstitial_ios": "ios_detail_interstitial",
};
 
export function canonicalAdUnit(raw: string): string {
  return AD_UNIT_ALIASES[raw] ?? raw.toLowerCase().replace(/\s+/g, "_");
}

// agents/comparator/index.ts
interface MergedRow {
  country: string;
  adUnit: string;
  admob: { ecpm: number; fillRate: number; arpdau: number };
  max: { ecpm: number; fillRate: number; arpdau: number };
}
 
export function classify(row: MergedRow): "max-superior" | "admob-superior" | "tie" {
  const ecpmDelta = (row.max.ecpm - row.admob.ecpm) / row.admob.ecpm;
  const fillDelta = row.max.fillRate - row.admob.fillRate;
  const arpdauDelta = (row.max.arpdau - row.admob.arpdau) / row.admob.arpdau;
 
  // Fill Rate ガードレール
  if (fillDelta < -0.05) return "admob-superior";
 
  if (ecpmDelta >= 0.10 && arpdauDelta >= 0.05) return "max-superior";
  if (ecpmDelta <= -0.10 && arpdauDelta <= -0.05) return "admob-superior";
  return "tie";
}