ゲーム固有データ（戦績・レート）の実装編【CFW P2P心理戦ゲーム開発記】 #5

# node環境なのでnpxをつけて以下を実行すると勝手に連番でsqlファイルを作成してくれます
# migrations/0002_create_buckshot_stats.sql　が作られる。
npx wrangler d1 migrations create DB create_buckshot_stats

CREATE TABLE IF NOT EXISTS buckshot_stats (
    user_id TEXT PRIMARY KEY,
    elo_rating INTEGER NOT NULL DEFAULT 1500,  -- レーティング（初期値1500）
    wins INTEGER NOT NULL DEFAULT 0,          -- 勝ち数
    losses INTEGER NOT NULL DEFAULT 0,        -- 負け数
    winning_streak INTEGER NOT NULL DEFAULT 0, -- 連勝数
    
    FOREIGN KEY (user_id) REFERENCES users(id) ON DELETE CASCADE
);

export interface BuckshotStats {
  user_id: string;
  elo_rating: number;
  wins: number;
  losses: number;
  winning_streak: number;
}

import { D1Database } from '@cloudflare/workers-types';
import { BuckshotStats } from '../types/database';

export class BuckshotRepository {
  constructor(private db: D1Database) {}

  // 戦績を取得する
  async getOrCreateStats(userId: string): Promise<BuckshotStats> {
    // まずデータを検索
    let stats = await this.db
      .prepare('SELECT * FROM buckshot_stats WHERE user_id = ?')
      .bind(userId)
      .first<BuckshotStats>();

    // もし無ければ、初期値でレコードをインサート
    if (!stats) {
      await this.db
        .prepare('INSERT OR IGNORE INTO buckshot_stats (user_id) VALUES (?)')
        .bind(userId)
        .run();

      // インサートした初期データを再取得
      stats = await this.db
        .prepare('SELECT * FROM buckshot_stats WHERE user_id = ?')
        .bind(userId)
        .first<BuckshotStats>();
    }

    return stats!;
  }

  // 試合結果を反映する（勝敗数、連勝数、レートの変動）
  async updateMatchResult(userId: string, isWin: boolean, newRating: number): Promise<void> {
    if (isWin) {
      await this.db
        .prepare(`
          UPDATE buckshot_stats 
          SET elo_rating = ?, wins = wins + 1, winning_streak = winning_streak + 1 
          WHERE user_id = ?
        `)
        .bind(newRating, userId)
        .run();
    } else {
      await this.db
        .prepare(`
          UPDATE buckshot_stats 
          SET elo_rating = ?, losses = losses + 1, winning_streak = 0 
          WHERE user_id = ?
        `)
        .bind(newRating, userId)
        .run();
    }
  }
}

// 必要に応じて追加予定ですが、基本操作はこんな感じでいいと思います

import { BuckshotRepository } from '../repositories/buckshotRepository';

export async function handleGetStats(request: Request, env: any): Promise<Response> {
  const url = new URL(request.url);
  const userId = url.searchParams.get('userId');

  if (!userId) {
    return new Response(JSON.stringify({ success: false, error: 'Missing userId' }), { status: 400 });
  }

  const repo = new BuckshotRepository(env.DB);
  const stats = await repo.getOrCreateStats(userId);

  return new Response(JSON.stringify({ success: true, stats }), {
    headers: { 'Content-Type': 'application/json; charset=utf-8' }
  });
}

// 今回実装分の概要だけ
import { handleGoogleLogin } from "./handlers/authHandler";
// バックショット用ハンドラーをインポート
import { handleGetStats } from "./handlers/buckshotHandler";

export default {
  async fetch(request: Request, env: Env, ctx: ExecutionContext): Promise<Response> {
    const url = new URL(request.url);

    // 認証用エンドポイントとか

    // バックショット戦績取得エンドポイント
    if (url.pathname === "/api/buckshot/stats" && request.method === "GET") {
      try {
        return await handleGetStats(request, env);
      } catch (err: any) {
        console.error("[GetStats Error]:", err);
        return new Response(JSON.stringify({ success: false, error: "Internal Server Error" }), { status: 500 });
      }
    }

    // 確認コードとか
  }
}

// 抜粋：setup.tsで実行するクエリの抜粋(ここまでで紹介したuserとか)
try {
    // 実行したいSQLを配列にまとめておく
    const sqlStatements = [
      `CREATE TABLE IF NOT EXISTS users (
        id TEXT PRIMARY KEY,
        display_name TEXT NOT NULL,
        created_at TEXT DEFAULT (datetime('now', 'localtime'))
      );`,

      `CREATE TABLE IF NOT EXISTS user_auths (
        id INTEGER PRIMARY KEY AUTOINCREMENT,
        user_id TEXT NOT NULL,
        provider TEXT NOT NULL,
        provider_user_id TEXT NOT NULL,
        secret_hash TEXT,
        FOREIGN KEY (user_id) REFERENCES users(id) ON DELETE CASCADE,
        UNIQUE (provider, provider_user_id)
      );`,

      `CREATE TABLE IF NOT EXISTS buckshot_stats (
        user_id TEXT PRIMARY KEY REFERENCES users(id) ON DELETE CASCADE,
        elo_rating INTEGER NOT NULL DEFAULT 1500,
        wins INTEGER NOT NULL DEFAULT 0,
        losses INTEGER NOT NULL DEFAULT 0,
        winning_streak INTEGER NOT NULL DEFAULT 0
      );`
    ];