DADProject/websockets/classes/BiscaMatch.js

import BiscaGame from "../classes/BiscaGame.js";
import axios from "axios";

const API_URL = process.env.API_URL || "http://localhost:8000/api/v1";

class BiscaMatch {
  constructor(apiData, emitStateCallback, token, autoPlayCallback) {
    this.id = apiData.id;
    this.emitStateCallback = emitStateCallback;
    this.autoPlayCallback = autoPlayCallback;
    this.token = token;
    this.stake = apiData.stake;
    this.type = apiData.type;
    this.status = apiData.status;

    this.player1Id = apiData.player1_user_id;
    this.player2Id = apiData.player2_user_id;
    this.player1 = apiData.player1;
    this.player2 = apiData.player2;

    this.marks = {
      [this.player1Id]: apiData.player1_marks || 0,
      [this.player2Id]: apiData.player2_marks || 0,
    };

    this.points = {
      [this.player1Id]: apiData.player1_points || 0,
      [this.player2Id]: apiData.player2_points || 0,
    };

    this.currentGame = null;
    this.GHOST_ID = 1;

    if (this.status === "Playing" && this.player2Id !== this.GHOST_ID) {
      this.startNewGame();
    }
  }

  async joinPlayer(userId, user) {
    if (this.player2Id !== this.GHOST_ID) return false;
    if (userId === this.player1Id) return false;

    this.player2Id = userId;
    this.player2 = user;
    this.marks[userId] = 0;
    this.points[userId] = 0;
    this.status = "Playing";

    await this.startNewGame();
    return true;
  }

  getAuthHeaders() {
    return {
      headers: {
        Authorization: this.token,
        "Content-Type": "application/json",
        Accept: "application/json",
      },
    };
  }

  async startNewGame() {
    console.log(`[Match ${this.id}] Starting new round...`);
    let newGameDbId = null;
    try {
      const payload = {
        type: this.type,
        player1_user_id: this.player1Id,
        player2_user_id: this.player2Id,
        match_id: this.id,
        status: "Playing",
        began_at: new Date().toISOString(),
      };

      const res = await axios.post(
        `${API_URL}/games`,
        payload,
        this.getAuthHeaders()
      );
      const gameData = res.data.game || res.data.data || res.data;
      newGameDbId = gameData.id;

      const p1Name = this.player1?.nickname || `User ${this.player1Id}`;
      const p2Name = this.player2?.nickname || `User ${this.player2Id}`;

      this.currentGame = new BiscaGame(
        this.id,
        this.type,
        { id: this.player1Id, name: p1Name },
        { id: this.player2Id, name: p2Name },
        newGameDbId,
        (result) => {
          this.handleGameEnd(result);
        }
      );

      this.currentGame.init();

      this.currentGame.startTurnTimer((uid, cid) => {
        if (this.autoPlayCallback) this.autoPlayCallback(uid, cid);
      });

      if (this.emitStateCallback) {
        this.emitStateCallback("match:new-round-start", null);
      }
    } catch (e) {
      console.error(`❌ Start Game Error: ${e.message}`);
    }
  }

  async abortCurrentGame(loserId) {
    if (this.currentGame && this.currentGame.dbId) {
      console.log(`[Match ${this.id}] Aborting Game #${this.currentGame.dbId}`);
      try {
        const winnerId =
          loserId == this.player1Id ? this.player2Id : this.player1Id;

        const payload = {
          status: "Ended",
          winner_user_id: winnerId,
          loser_user_id: loserId,
          is_draw: false,
          ended_at: new Date().toISOString(),
        };
        await axios.put(
          `${API_URL}/games/${this.currentGame.dbId}`,
          payload,
          this.getAuthHeaders()
        );
      } catch (e) {
        console.error("Error aborting game:", e.message);
      }
    }
  }

  async handleGameEnd(result) {
    console.log(`[Match ${this.id}] Round ended. Winner: ${result.winnerId}`);

    if (this.points[result.player1_id] !== undefined)
      this.points[result.player1_id] += result.player1_points;
    if (this.points[result.player2_id] !== undefined)
      this.points[result.player2_id] += result.player2_points;

    if (this.currentGame && this.currentGame.dbId) {
      try {
        const payload = {
          status: "Ended",
          winner_user_id: result.winnerId,
          loser_user_id: result.loserId,
          is_draw: result.isDraw,
          player1_points: result.player1_points,
          player2_points: result.player2_points,
          ended_at: new Date().toISOString(),
        };
        await axios.put(
          `${API_URL}/games/${this.currentGame.dbId}`,
          payload,
          this.getAuthHeaders()
        );
      } catch (e) {
        console.error("DB Game Update Error:", e.message);
      }
    }

    let marksToAdd = 0;
    let roundWinnerId = result.winnerId;

    if (roundWinnerId) {
      const winningScore =
        roundWinnerId == result.player1_id
          ? result.player1_points
          : result.player2_points;
      if (winningScore === 120) marksToAdd = 4;
      else if (winningScore > 90) marksToAdd = 2;
      else if (winningScore >= 60) marksToAdd = 1;

      if (this.marks[roundWinnerId] !== undefined)
        this.marks[roundWinnerId] += marksToAdd;
    }

    if (this.emitStateCallback) {
      this.emitStateCallback("match:round-ended", {
        winnerId: roundWinnerId,
        marksAdded: marksToAdd,
        p1Points: result.player1_points,
        p2Points: result.player2_points,
        p1Marks: this.marks[this.player1Id],
        p2Marks: this.marks[this.player2Id],
        reason: result.reason || "points",
      });
    }

    if (this.marks[this.player1Id] >= 4 || this.marks[this.player2Id] >= 4) {
      await this.finishMatch();
      if (this.emitStateCallback)
        this.emitStateCallback("match:ended-signal", null);
    } else {
      setTimeout(() => {
        this.startNewGame();
      }, 1000);
    }
  }

  async finishMatch() {
    this.status = "Ended";
    const winnerId =
      this.marks[this.player1Id] >= 4 ? this.player1Id : this.player2Id;
    const loserId =
      winnerId == this.player1Id ? this.player2Id : this.player1Id;

    const payload = {
      status: "Ended",
      winner_user_id: winnerId,
      loser_user_id: loserId,
      player1_marks: this.marks[this.player1Id],
      player2_marks: this.marks[this.player2Id],
      player1_points: this.points[this.player1Id],
      player2_points: this.points[this.player2Id],
    };

    try {
      await axios.put(
        `${API_URL}/matches/${this.id}`,
        payload,
        this.getAuthHeaders()
      );
      console.log(`[Match ${this.id}] Match Closed in DB.`);
    } catch (e) {
      console.error(`Match Close Error: ${e.message}`);
    }
  }

  playCard(userId, cardId) {
    if (!this.currentGame || this.status !== "Playing") return;

    const result = this.currentGame.playCard(userId, cardId);

    if (
      result &&
      (result.action === "next_turn" || result.action === "trick_resolved")
    ) {
      this.currentGame.startTurnTimer((uid, cid) => {
        if (this.autoPlayCallback) this.autoPlayCallback(uid, cid);
      });
    }

    return result;
  }

  getGameState(userId) {
    if (!this.currentGame) return null;
    if (this.currentGame.players[userId])
      return this.currentGame.getStateForPlayer(userId);
    return null;
  }

  getPublicState() {
    return {
      matchId: this.id,
      status: this.status,
      marks: this.marks,
      points: this.points,
      player1: this.player1,
      player2: this.player2,
    };
  }
}

export default BiscaMatch;