起動回数のカウンタが、1回の起動で2ずつ進んでいました — 新規ユーザーの広告猶予が早く終わった原因

// kv.ts — AsyncStorage の代役。読み書きが非同期（少し待つ）という性質だけを再現する
export interface KV {
  getItem(key: string): Promise<string | null>;
  setItem(key: string, value: string): Promise<void>;
}
 
export function createMemoryKV(latencyMs = 5): KV & { dump(): Record<string, string> } {
  const data = new Map<string, string>();
  const wait = () => new Promise<void>((r) => setTimeout(r, latencyMs));
  return {
    async getItem(key) {
      await wait();
      return data.has(key) ? (data.get(key) as string) : null;
    },
    async setItem(key, value) {
      await wait();
      data.set(key, value);
    },
    dump: () => Object.fromEntries(data),
  };
}

// counter-buggy.ts — 壊れていた形。呼ぶたびに「読んで、足して、書く」だけ
import type { KV } from "./kv.ts";
 
export function createBuggyCounter(store: KV, key = "launch_count") {
  return {
    async countThisLaunch(): Promise<number> {
      const raw = await store.getItem(key);
      const next = (Number.parseInt(raw ?? "0", 10) || 0) + 1;
      await store.setItem(key, String(next));
      return next;
    },
  };
}

// counter.ts — 直した形。「1回の起動で1だけ進める」ことを、部品の側で保証する
import type { KV } from "./kv.ts";
 
export function createLaunchCounter(store: KV, key = "launch_count") {
  let session: Promise<number> | null = null; // この JS 実行環境（= 1回の起動）で数えた結果
  let queue: Promise<unknown> = Promise.resolve(); // 書き込みを一列に並べる
 
  function bump(): Promise<number> {
    const run = queue.then(async () => {
      const raw = await store.getItem(key);
      const next = (Number.parseInt(raw ?? "0", 10) || 0) + 1;
      await store.setItem(key, String(next));
      return next;
    });
    queue = run.catch(() => undefined); // 一度失敗しても、次の書き込みは止めない
    return run;
  }
 
  return {
    // 何か所から、何度呼ばれても、この起動では一度しか進めない
    countThisLaunch(): Promise<number> {
      if (!session) {
        session = bump().catch((e) => {
          session = null; // 失敗した回だけは、次の呼び出しで数え直せるようにする
          throw e;
        });
      }
      return session;
    },
    async peek(): Promise<number> {
      return Number.parseInt((await store.getItem(key)) ?? "0", 10) || 0;
    },
  };
}
 
// 猶予の判定は、数える部品と分けて、ただの関数にしておく
export function isInAdGrace(launchCount: number, graceLaunches: number): boolean {
  return launchCount <= graceLaunches;
}

// counter-window.ts — 「一定時間内の再呼び出しは飛ばす」形。呼び出し元を一つにできないときの保険
import type { KV } from "./kv.ts";
 
export function createWindowCounter(
  store: KV,
  now: () => number,
  windowMs: number,
  key = "launch_count",
  stampKey = "launch_count_at",
) {
  return {
    async countThisLaunch(): Promise<number> {
      const last = Number.parseInt((await store.getItem(stampKey)) ?? "0", 10) || 0;
      const current = Number.parseInt((await store.getItem(key)) ?? "0", 10) || 0;
      if (last > 0 && now() - last < windowMs) return current; // 直前に数えたばかり: 飛ばす
      const next = current + 1;
      await store.setItem(key, String(next));
      await store.setItem(stampKey, String(now()));
      return next;
    },
  };
}

// launch.ts — アプリで共有する、カウンタの唯一の入口
import AsyncStorage from "@react-native-async-storage/async-storage";
import { createLaunchCounter, isInAdGrace } from "./counter";
 
export const launchCounter = createLaunchCounter(AsyncStorage);
 
const GRACE_LAUNCHES = 3; // 例: 最初の3回の起動は広告を出さない
 
export async function shouldHoldAds(): Promise<boolean> {
  return isInAdGrace(await launchCounter.peek(), GRACE_LAUNCHES);
}

// app/_layout.tsx — 進める呼び出しは、ここだけ
import { useEffect } from "react";
import { Stack } from "expo-router";
import { launchCounter } from "../launch";
 
export default function RootLayout() {
  useEffect(() => {
    launchCounter.countThisLaunch().catch(() => {
      // 数えられなくても、アプリは起動する。猶予が1回延びるだけなので握りつぶしてよい
    });
  }, []);
  return <Stack />;
}