「広告を見たら壁紙を解放」をエージェントがクライアント側だけで付与していた — リワード報酬をSSVで検証し直した記録

// 解放リクエストはサーバーが発行した不透明ID。端末で生成しない。
val options = ServerSideVerificationOptions.Builder()
    .setCustomData(grantRequestId)   // 例: "g_8f3c...d21" サーバー発行・使い捨て
    .setUserId(stableUserId)         // 端末横断で安定したID（メアド等の生値は載せない）
    .build()
rewardedAd.setServerSideVerificationOptions(options)
 
rewardedAd.show(activity) { _ ->
    // 楽観的UXのみ。ここでは「解放した」を永続化しない。
    showOptimisticUnlock(wallpaperId)
    // 真の解放状態はサーバーから取得する
    viewModel.refreshEntitlement(grantRequestId)
}

const VERIFIER_KEYS_URL = "https://www.gstatic.com/admob/reward/verifier-keys.json";
let keyCache = { at: 0, keys: null };
 
// 鍵は24時間以上キャッシュしない（鍵はローテートされる）
async function getKeys() {
  const now = Date.now();
  if (keyCache.keys && now - keyCache.at < 24 * 60 * 60 * 1000) return keyCache.keys;
  const res = await fetch(VERIFIER_KEYS_URL, { cf: { cacheTtl: 3600 } });
  const json = await res.json();
  const map = new Map();
  for (const k of json.keys) map.set(String(k.keyId), k.base64); // base64 は DER SPKI
  keyCache = { at: now, keys: map };
  return map;
}
 
function b64urlToBytes(s) {
  s = s.replace(/-/g, "+").replace(/_/g, "/");
  while (s.length % 4) s += "=";
  const bin = atob(s);
  return Uint8Array.from(bin, (c) => c.charCodeAt(0));
}
function b64ToBytes(s) {
  const bin = atob(s);
  return Uint8Array.from(bin, (c) => c.charCodeAt(0));
}
 
// DER(ECDSA) -> 生の r‖s 64バイト（P-256）。Web Crypto はこちらを要求する。
function derToRaw(der) {
  let o = 0;
  if (der[o++] !== 0x30) throw new Error("bad DER");
  if (der[o] & 0x80) o += (der[o] & 0x7f) + 1; else o++;
  const readInt = () => {
    if (der[o++] !== 0x02) throw new Error("bad DER int");
    let len = der[o++];
    let v = der.slice(o, o + len); o += len;
    while (v.length > 1 && v[0] === 0x00) v = v.slice(1);   // 先頭0x00を除去
    return v;
  };
  const r = readInt(), s = readInt();
  const out = new Uint8Array(64);
  out.set(r, 32 - r.length);
  out.set(s, 64 - s.length);
  return out;
}
 
async function verifySsv(rawQuery) {
  // 署名対象 = "&signature=" の直前まで。順序もエンコードも一切変えない。
  const sigMarker = "&signature=";
  const i = rawQuery.indexOf(sigMarker);
  if (i === -1) return false;
  const signedContent = rawQuery.slice(0, i);
 
  const params = new URLSearchParams(rawQuery);
  const keyId = params.get("key_id");
  const sigB64url = params.get("signature");
  if (!keyId || !sigB64url) return false;
 
  const keys = await getKeys();
  const spki = keys.get(String(keyId));
  if (!spki) return false; // 鍵が見つからない=キャッシュ更新が必要かもしれない
 
  const pub = await crypto.subtle.importKey(
    "spki", b64ToBytes(spki),
    { name: "ECDSA", namedCurve: "P-256" }, false, ["verify"]
  );
  const rawSig = derToRaw(b64urlToBytes(sigB64url));
  return crypto.subtle.verify(
    { name: "ECDSA", hash: "SHA-256" },
    pub, rawSig, new TextEncoder().encode(signedContent)
  );
}

export default {
  async fetch(req, env) {
    const url = new URL(req.url);
    const rawQuery = url.search.slice(1); // 先頭の "?" を除く生クエリ
    const ok = await verifySsv(rawQuery);
    if (!ok) return new Response("invalid signature", { status: 403 });
 
    const p = new URLSearchParams(rawQuery);
    const txId = p.get("transaction_id");
    const grantRequestId = decodeURIComponent(p.get("custom_data") || "");
    const ts = Number(p.get("timestamp") || 0);
 
    // 鮮度チェック（任意）: 古すぎるコールバックは捨てる
    if (ts && Date.now() * 1000 - ts > 10 * 60 * 1_000_000) {
      return new Response("stale", { status: 200 }); // 200 を返し再送は止める
    }
 
    // 冪等化: transaction_id 初出のときだけ付与
    const seenKey = `ssv:txn:${txId}`;
    if (await env.GRANTS.get(seenKey)) {
      return new Response("dup", { status: 200 }); // 既処理。200で再送を止める
    }
    await env.GRANTS.put(seenKey, "1", { expirationTtl: 60 * 60 * 24 * 30 });
 
    // 対応する解放リクエストを確定（保留→解放済み）
    await env.GRANTS.put(`grant:${grantRequestId}`, "unlocked", { expirationTtl: 60 * 60 * 24 * 365 });
 
    return new Response("ok", { status: 200 }); // Google は 200 を期待する
  },
};