// ============================================================ // Texas Hold'em Poker Manager // Server-authoritative game logic. Invisible entity. // Listens for 'poker-action' events from player behaviors. // ============================================================ var poker = require('lib/poker-logic.js'); var NUM_SEATS = 6; var SMALL_BLIND = 10; var BIG_BLIND = 20; var STARTING_CHIPS = 1000; var COUNTDOWN_SECONDS = 5; var SHOWDOWN_DELAY = 4; // ---- Helpers ---- function emptySeats() { var seats = []; for (var i = 0; i < NUM_SEATS; i++) { seats.push({ playerId: null, username: null, chips: 0, currentBet: 0, totalBet: 0, folded: false, allIn: false, active: false, actedThisRound: false, ready: false }); } return seats; } function countReadyPlayers(seats) { var n = 0; for (var i = 0; i < seats.length; i++) { if (seats[i].active && seats[i].playerId && seats[i].ready) n++; } return n; } function allPlayersReady(seats) { var active = countActivePlayers(seats); if (active < 2) return false; for (var i = 0; i < seats.length; i++) { if (seats[i].active && seats[i].playerId && !seats[i].ready) return false; } return true; } function countActivePlayers(seats) { var n = 0; for (var i = 0; i < seats.length; i++) { if (seats[i].active && seats[i].playerId) n++; } return n; } function countUnfolded(seats) { var n = 0; for (var i = 0; i < seats.length; i++) { if (seats[i].active && seats[i].playerId && !seats[i].folded) n++; } return n; } function countCanAct(seats) { var n = 0; for (var i = 0; i < seats.length; i++) { if (seats[i].active && seats[i].playerId && !seats[i].folded && !seats[i].allIn) n++; } return n; } function nextOccupiedSeat(seats, fromIndex) { for (var i = 1; i <= seats.length; i++) { var idx = (fromIndex + i) % seats.length; if (seats[idx].active && seats[idx].playerId && !seats[idx].folded) { return idx; } } return -1; } function nextCanActSeat(seats, fromIndex) { for (var i = 1; i <= seats.length; i++) { var idx = (fromIndex + i) % seats.length; if (seats[idx].active && seats[idx].playerId && !seats[idx].folded && !seats[idx].allIn) { return idx; } } return -1; } function dealCard(state) { if (state.deck.length === 0) return null; var card = state.deck[state.deck.length - 1]; state.deck = state.deck.slice(0, state.deck.length - 1); return card; } function isRoundComplete(seats, currentBet) { for (var i = 0; i < seats.length; i++) { var s = seats[i]; if (!s.active || !s.playerId || s.folded || s.allIn) continue; if (!s.actedThisRound) return false; if (s.currentBet !== currentBet) return false; } return true; } // ---- Lifecycle ---- export function onSpawn(api) { var s = api.getState(); // Initialize only if not already set api.patchState({ phase: s.phase || 'waiting', deck: s.deck || [], communityCards: s.communityCards || [], pot: s.pot || 0, currentBet: s.currentBet || 0, dealerSeatIndex: s.dealerSeatIndex != null ? s.dealerSeatIndex : 0, currentTurnSeatIndex: s.currentTurnSeatIndex != null ? s.currentTurnSeatIndex : -1, seats: s.seats || emptySeats(), minRaise: s.minRaise || BIG_BLIND, smallBlind: s.smallBlind || SMALL_BLIND, bigBlind: s.bigBlind || BIG_BLIND, startingChips: STARTING_CHIPS, winners: s.winners || [], handInProgress: s.handInProgress || false, countdownActive: false, countdownEnd: 0, handNumber: s.handNumber || 0, lastAction: s.lastAction || null, showdownReveal: s.showdownReveal || [] }); // Listen for player actions api.on('poker-action', function (evt) { handlePokerAction(api, evt); }); api.log('Poker manager spawned and listening for actions.'); } // ---- Main Update ---- export function update(dt, api) { var s = api.getState(); // Check for disconnected players during waiting (clear ready) if (s.phase === 'waiting') { checkWaitingDisconnects(api); } // Check for disconnected players during active hand if (s.phase !== 'waiting') { checkDisconnects(api); } } // ---- Check Waiting Disconnects ---- function checkWaitingDisconnects(api) { var s = api.getState(); var seats = deepCopySeats(s.seats); var changed = false; for (var i = 0; i < seats.length; i++) { if (!seats[i].active || !seats[i].playerId) continue; var obj = api.getObject(seats[i].playerId); if (!obj) { api.log('Player disconnected from seat ' + i + ' during waiting'); seats[i].playerId = null; seats[i].username = null; seats[i].active = false; seats[i].ready = false; changed = true; } } if (changed) { api.patchState({ seats: seats }); } } // ---- Check Disconnects ---- function checkDisconnects(api) { var s = api.getState(); var seats = deepCopySeats(s.seats); var changed = false; for (var i = 0; i < seats.length; i++) { if (!seats[i].active || !seats[i].playerId) continue; var obj = api.getObject(seats[i].playerId); if (!obj) { // Player disconnected api.log('Player disconnected from seat ' + i); if (s.handInProgress && !seats[i].folded) { seats[i].folded = true; changed = true; } // Remove from seat seats[i].playerId = null; seats[i].username = null; seats[i].active = false; changed = true; } } if (changed) { api.patchState({ seats: seats }); // Check if hand can continue if (s.handInProgress) { var unfolded = countUnfolded(seats); if (unfolded <= 1) { awardPotToLastPlayer(api); return; } // If current turn player left, advance if (s.currentTurnSeatIndex >= 0 && (!seats[s.currentTurnSeatIndex].active || seats[s.currentTurnSeatIndex].folded)) { advanceTurn(api); } } } } // ---- Handle Poker Actions ---- function handlePokerAction(api, evt) { if (!evt || !evt.action || !evt.playerId) return; var action = evt.action; var playerId = evt.playerId; if (action === 'joinGame') { handleJoinGame(api, playerId); } else if (action === 'leaveGame') { handleLeaveGame(api, playerId); } else if (action === 'ready') { handleReady(api, playerId); } else if (action === 'fold') { handleFold(api, playerId); } else if (action === 'check') { handleCheck(api, playerId); } else if (action === 'call') { handleCall(api, playerId); } else if (action === 'raise') { handleRaise(api, playerId, evt.amount); } } // ---- Join / Leave ---- function handleJoinGame(api, playerId) { var s = api.getState(); var seats = deepCopySeats(s.seats); // Already seated? for (var i = 0; i < seats.length; i++) { if (seats[i].playerId === playerId) { api.toast('You are already seated.', { audience: { kind: 'player', id: playerId } }); return; } } // Find empty seat var seatIdx = -1; for (var j = 0; j < seats.length; j++) { if (!seats[j].active || !seats[j].playerId) { seatIdx = j; break; } } if (seatIdx === -1) { api.toast('Table is full!', { audience: { kind: 'player', id: playerId } }); return; } // Get username var playerObj = api.getObject(playerId); var username = 'Player'; if (playerObj && playerObj.state && playerObj.state.username) { username = playerObj.state.username; } seats[seatIdx] = { playerId: playerId, username: username, chips: STARTING_CHIPS, currentBet: 0, totalBet: 0, folded: false, allIn: false, active: true, actedThisRound: false, ready: false }; api.patchState({ seats: seats }); api.patchObjectState(playerId, { seatIndex: seatIdx, inGame: true, holeCards: [] }); api.toast('Seated at position ' + (seatIdx + 1) + ' with ' + STARTING_CHIPS + ' chips.', { audience: { kind: 'player', id: playerId } }); api.announce('🪑 ' + username + ' joined!', { style: 'info', duration: 2, audience: { kind: 'place' } }); } function handleLeaveGame(api, playerId) { var s = api.getState(); var seats = deepCopySeats(s.seats); var seatIdx = findPlayerSeat(seats, playerId); if (seatIdx === -1) return; var username = seats[seatIdx].username || 'Player'; // If hand in progress, fold first if (s.handInProgress && !seats[seatIdx].folded) { seats[seatIdx].folded = true; } seats[seatIdx].playerId = null; seats[seatIdx].username = null; seats[seatIdx].active = false; seats[seatIdx].chips = 0; seats[seatIdx].ready = false; api.patchState({ seats: seats }); api.patchObjectState(playerId, { seatIndex: -1, inGame: false, holeCards: [] }); api.toast('You left the table.', { audience: { kind: 'player', id: playerId } }); api.announce('👋 ' + username + ' left', { style: 'info', duration: 2, audience: { kind: 'place' } }); // If hand in progress, check if it should end if (s.handInProgress) { var unfolded = countUnfolded(seats); if (unfolded <= 1) { awardPotToLastPlayer(api); return; } // If it was their turn, advance if (s.currentTurnSeatIndex === seatIdx) { advanceTurn(api); } } } // ---- Ready Up ---- function handleReady(api, playerId) { var s = api.getState(); // Only allow readying during waiting phase if (s.handInProgress) return; if (s.phase !== 'waiting') return; var seats = deepCopySeats(s.seats); var seatIdx = findPlayerSeat(seats, playerId); if (seatIdx === -1) return; // Already ready? if (seats[seatIdx].ready) return; seats[seatIdx].ready = true; api.patchState({ seats: seats }); var username = seats[seatIdx].username || 'Player'; api.playSound('cdn/sfx-tap-soft.mp3', { audience: { kind: 'place' } }); // Check if all players are ready if (allPlayersReady(seats)) { api.announce('🃏 All players ready — dealing!', { style: 'info', duration: 2, audience: { kind: 'place' } }); // Small delay for dramatic effect api.runInSeconds(0.8, function () { startHand(api); }); } } // ---- Betting Actions ---- function handleFold(api, playerId) { var s = api.getState(); if (!s.handInProgress) return; var seats = deepCopySeats(s.seats); var seatIdx = findPlayerSeat(seats, playerId); if (seatIdx === -1 || seatIdx !== s.currentTurnSeatIndex) return; if (seats[seatIdx].folded || seats[seatIdx].allIn) return; seats[seatIdx].folded = true; seats[seatIdx].actedThisRound = true; api.patchState({ seats: seats, lastAction: { seat: seatIdx, action: 'fold', username: seats[seatIdx].username } }); // Clear hole cards from player state api.patchObjectState(playerId, { holeCards: [] }); api.playSound('cdn/sfx-card-flip.mp3', { audience: { kind: 'place' } }); // Check if only one player left if (countUnfolded(seats) <= 1) { awardPotToLastPlayer(api); return; } advanceTurn(api); } function handleCheck(api, playerId) { var s = api.getState(); if (!s.handInProgress) return; var seats = deepCopySeats(s.seats); var seatIdx = findPlayerSeat(seats, playerId); if (seatIdx === -1 || seatIdx !== s.currentTurnSeatIndex) return; if (seats[seatIdx].folded || seats[seatIdx].allIn) return; // Can only check if current bet matches if (seats[seatIdx].currentBet !== s.currentBet) { api.toast('You must call or raise — cannot check.', { audience: { kind: 'player', id: playerId } }); return; } seats[seatIdx].actedThisRound = true; api.patchState({ seats: seats, lastAction: { seat: seatIdx, action: 'check', username: seats[seatIdx].username } }); api.playSound('cdn/sfx-tap-soft.mp3', { audience: { kind: 'place' } }); advanceTurn(api); } function handleCall(api, playerId) { var s = api.getState(); if (!s.handInProgress) return; var seats = deepCopySeats(s.seats); var seatIdx = findPlayerSeat(seats, playerId); if (seatIdx === -1 || seatIdx !== s.currentTurnSeatIndex) return; if (seats[seatIdx].folded || seats[seatIdx].allIn) return; var toCall = s.currentBet - seats[seatIdx].currentBet; if (toCall <= 0) { // Nothing to call — treat as check handleCheck(api, playerId); return; } var seat = seats[seatIdx]; var actualCall = Math.min(toCall, seat.chips); seat.chips -= actualCall; seat.currentBet += actualCall; seat.totalBet += actualCall; seat.actedThisRound = true; if (seat.chips === 0) { seat.allIn = true; } var newPot = s.pot + actualCall; api.patchState({ seats: seats, pot: newPot, lastAction: { seat: seatIdx, action: seat.allIn ? 'all-in (call)' : 'call', amount: actualCall, username: seat.username } }); api.playSound('cdn/sfx-coin-drop.mp3', { audience: { kind: 'place' } }); if (seat.allIn) { api.announce('💰 ' + (seat.username || 'Player') + ' is ALL IN!', { style: 'warning', duration: 2, audience: { kind: 'place' } }); } advanceTurn(api); } function handleRaise(api, playerId, amount) { var s = api.getState(); if (!s.handInProgress) return; var seats = deepCopySeats(s.seats); var seatIdx = findPlayerSeat(seats, playerId); if (seatIdx === -1 || seatIdx !== s.currentTurnSeatIndex) return; if (seats[seatIdx].folded || seats[seatIdx].allIn) return; var seat = seats[seatIdx]; var totalAmount = parseInt(amount) || 0; // totalAmount is the TOTAL bet this player wants to have for the round // (not the raise increment) if (totalAmount <= 0) totalAmount = s.currentBet + s.minRaise; // Clamp to player's maximum var maxBet = seat.currentBet + seat.chips; if (totalAmount > maxBet) totalAmount = maxBet; // Must be at least currentBet + minRaise (or all-in) var minTotal = s.currentBet + s.minRaise; if (totalAmount < minTotal && totalAmount < maxBet) { api.toast('Minimum raise is ' + s.minRaise + ' (total bet: ' + minTotal + ')', { audience: { kind: 'player', id: playerId } }); return; } var raiseIncrement = totalAmount - s.currentBet; var chipsCost = totalAmount - seat.currentBet; seat.chips -= chipsCost; seat.currentBet = totalAmount; seat.totalBet += chipsCost; seat.actedThisRound = true; if (seat.chips === 0) { seat.allIn = true; } var newPot = s.pot + chipsCost; var newMinRaise = Math.max(raiseIncrement, s.bigBlind || BIG_BLIND); // Reset acted for other active players (they need to respond to the raise) for (var i = 0; i < seats.length; i++) { if (i !== seatIdx && seats[i].active && seats[i].playerId && !seats[i].folded && !seats[i].allIn) { seats[i].actedThisRound = false; } } api.patchState({ seats: seats, pot: newPot, currentBet: totalAmount, minRaise: newMinRaise, lastAction: { seat: seatIdx, action: seat.allIn ? 'all-in (raise)' : 'raise', amount: totalAmount, username: seat.username } }); api.playSound('cdn/sfx-coin-collect-chime-pickup.mp3', { audience: { kind: 'place' } }); if (seat.allIn) { api.announce('💰 ' + (seat.username || 'Player') + ' is ALL IN!', { style: 'warning', duration: 2, audience: { kind: 'place' } }); } advanceTurn(api); } // ---- Game Flow ---- function startHand(api) { var s = api.getState(); var seats = deepCopySeats(s.seats); // Check we still have enough players if (countActivePlayers(seats) < 2) { api.patchState({ countdownActive: false }); api.announce('Not enough players to start.', { style: 'warning', duration: 2, audience: { kind: 'place' } }); return; } // Reset seats for new hand for (var i = 0; i < seats.length; i++) { if (seats[i].active && seats[i].playerId) { // Remove players with 0 chips if (seats[i].chips <= 0) { api.patchObjectState(seats[i].playerId, { seatIndex: -1, inGame: false, holeCards: [] }); api.toast('You ran out of chips!', { audience: { kind: 'player', id: seats[i].playerId } }); seats[i].playerId = null; seats[i].username = null; seats[i].active = false; continue; } seats[i].currentBet = 0; seats[i].totalBet = 0; seats[i].folded = false; seats[i].allIn = false; seats[i].actedThisRound = false; seats[i].ready = false; } } if (countActivePlayers(seats) < 2) { api.patchState({ seats: seats, countdownActive: false }); api.announce('Not enough players to start.', { style: 'warning', duration: 2, audience: { kind: 'place' } }); return; } // Rotate dealer var dealerIdx = s.dealerSeatIndex; dealerIdx = nextOccupiedSeat(seats, dealerIdx); if (dealerIdx === -1) return; // Create and shuffle deck var deck = poker.shuffleDeck(poker.createDeck(), function () { return api.random(); }); // Deal hole cards var activeSeatIndices = []; for (var j = 0; j < seats.length; j++) { if (seats[j].active && seats[j].playerId) { activeSeatIndices.push(j); } } // Deal two cards to each player (round-robin starting left of dealer) var holeCardsMap = {}; for (var round = 0; round < 2; round++) { for (var a = 0; a < activeSeatIndices.length; a++) { var si = activeSeatIndices[(activeSeatIndices.indexOf(dealerIdx) + 1 + a) % activeSeatIndices.length]; if (!si && si !== 0) si = activeSeatIndices[a]; // Find correct starting position var dealStartIdx = -1; for (var d = 0; d < activeSeatIndices.length; d++) { if (activeSeatIndices[d] === dealerIdx) { dealStartIdx = d; break; } } var actualIdx = activeSeatIndices[(dealStartIdx + 1 + a) % activeSeatIndices.length]; if (!holeCardsMap[actualIdx]) holeCardsMap[actualIdx] = []; var card = deck.pop(); holeCardsMap[actualIdx].push(card); } } // Push hole cards to each player's state for (var seatKey in holeCardsMap) { var sIdx = parseInt(seatKey); var pid = seats[sIdx].playerId; if (pid) { api.patchObjectState(pid, { holeCards: holeCardsMap[sIdx] }); } } // Post blinds var numActive = countActivePlayers(seats); var sbIdx, bbIdx; if (numActive === 2) { // Heads-up: dealer is SB, other is BB sbIdx = dealerIdx; bbIdx = nextOccupiedSeat(seats, dealerIdx); } else { sbIdx = nextOccupiedSeat(seats, dealerIdx); bbIdx = nextOccupiedSeat(seats, sbIdx); } // Post small blind var curSmallBlind = s.smallBlind || SMALL_BLIND; var curBigBlind = s.bigBlind || BIG_BLIND; var sbAmount = Math.min(curSmallBlind, seats[sbIdx].chips); seats[sbIdx].chips -= sbAmount; seats[sbIdx].currentBet = sbAmount; seats[sbIdx].totalBet = sbAmount; if (seats[sbIdx].chips === 0) seats[sbIdx].allIn = true; // Post big blind var bbAmount = Math.min(curBigBlind, seats[bbIdx].chips); seats[bbIdx].chips -= bbAmount; seats[bbIdx].currentBet = bbAmount; seats[bbIdx].totalBet = bbAmount; if (seats[bbIdx].chips === 0) seats[bbIdx].allIn = true; var pot = sbAmount + bbAmount; // First to act is left of BB var firstToAct = nextCanActSeat(seats, bbIdx); // In heads-up, SB acts first preflop if (numActive === 2) { firstToAct = nextCanActSeat(seats, bbIdx); // actually in heads-up SB/dealer acts first preflop firstToAct = sbIdx; if (seats[sbIdx].allIn) firstToAct = nextCanActSeat(seats, sbIdx); } if (firstToAct === -1) firstToAct = bbIdx; var handNum = (s.handNumber || 0) + 1; api.patchState({ phase: 'preflop', deck: deck, communityCards: [], pot: pot, currentBet: curBigBlind, dealerSeatIndex: dealerIdx, currentTurnSeatIndex: firstToAct, seats: seats, minRaise: curBigBlind, winners: [], showdownReveal: [], handInProgress: true, handNumber: handNum, lastAction: null, sbSeatIndex: sbIdx, bbSeatIndex: bbIdx }); api.announce('🃏 Hand #' + handNum + ' — Deal!', { style: 'info', duration: 2, audience: { kind: 'place' } }); api.playSound('cdn/sfx-card-flip.mp3', { audience: { kind: 'place' } }); // If only all-in players remain, skip to showdown if (countCanAct(seats) === 0) { runOutCommunityCards(api); } } // ---- Advance Turn ---- function advanceTurn(api) { var s = api.getState(); var seats = deepCopySeats(s.seats); // Check if only 1 player unfolded if (countUnfolded(seats) <= 1) { awardPotToLastPlayer(api); return; } // Check if betting round is complete if (isRoundComplete(seats, s.currentBet)) { advancePhase(api); return; } // Find next player who can act var nextSeat = nextCanActSeat(seats, s.currentTurnSeatIndex); if (nextSeat === -1) { // All remaining players are all-in or folded advancePhase(api); return; } api.patchState({ currentTurnSeatIndex: nextSeat }); } // ---- Advance Phase ---- function advancePhase(api) { var s = api.getState(); var seats = deepCopySeats(s.seats); // Reset round bets for (var i = 0; i < seats.length; i++) { seats[i].currentBet = 0; seats[i].actedThisRound = false; } var deck = s.deck.slice(); var community = s.communityCards.slice(); var nextPhase; var cardsToReveal = 0; if (s.phase === 'preflop') { nextPhase = 'flop'; cardsToReveal = 3; } else if (s.phase === 'flop') { nextPhase = 'turn'; cardsToReveal = 1; } else if (s.phase === 'turn') { nextPhase = 'river'; cardsToReveal = 1; } else if (s.phase === 'river') { nextPhase = 'showdown'; cardsToReveal = 0; } else { return; } // Burn and deal community cards for (var c = 0; c < cardsToReveal; c++) { if (deck.length > 0) deck.pop(); // burn card if (deck.length > 0) community.push(deck.pop()); // deal card } if (nextPhase === 'showdown') { api.patchState({ phase: 'showdown', seats: seats, currentBet: 0, currentTurnSeatIndex: -1, deck: deck, communityCards: community }); doShowdown(api); return; } // Find first to act (left of dealer) var firstToAct = nextCanActSeat(seats, s.dealerSeatIndex); // Check if no one can act (everyone all-in) if (firstToAct === -1 || countCanAct(seats) <= 1) { // Run out remaining community cards api.patchState({ phase: nextPhase, seats: seats, currentBet: 0, currentTurnSeatIndex: -1, deck: deck, communityCards: community, minRaise: s.bigBlind || BIG_BLIND }); // If we need more community cards, schedule next phase immediately if (community.length < 5) { api.runInSeconds(0.8, function () { advancePhase(api); }); } else { api.runInSeconds(0.8, function () { api.patchState({ phase: 'showdown' }); doShowdown(api); }); } return; } api.patchState({ phase: nextPhase, seats: seats, currentBet: 0, currentTurnSeatIndex: firstToAct, deck: deck, communityCards: community, minRaise: s.bigBlind || BIG_BLIND }); var phaseLabel = nextPhase.charAt(0).toUpperCase() + nextPhase.slice(1); api.playSound('cdn/sfx-card-flip.mp3', { audience: { kind: 'place' } }); } // ---- Run out all remaining community cards ---- function runOutCommunityCards(api) { var s = api.getState(); if (s.communityCards.length >= 5) { api.patchState({ phase: 'showdown', currentTurnSeatIndex: -1 }); doShowdown(api); return; } // Reset round var seats = deepCopySeats(s.seats); for (var i = 0; i < seats.length; i++) { seats[i].currentBet = 0; seats[i].actedThisRound = false; } api.patchState({ seats: seats, currentBet: 0 }); // Schedule community card reveals var phasesNeeded = []; if (s.communityCards.length < 3) phasesNeeded.push('flop'); if (s.communityCards.length < 4 || phasesNeeded.length > 0) phasesNeeded.push('turn'); if (s.communityCards.length < 5 || phasesNeeded.length > 0) phasesNeeded.push('river'); var delay = 0.8; function scheduleNext() { api.runInSeconds(delay, function () { advancePhase(api); }); } scheduleNext(); } // ---- Showdown ---- function doShowdown(api) { var s = api.getState(); var seats = deepCopySeats(s.seats); var community = s.communityCards; // Collect hands for non-folded players var playerHands = []; for (var i = 0; i < seats.length; i++) { if (!seats[i].active || !seats[i].playerId || seats[i].folded) continue; var playerState = api.getObjectState(seats[i].playerId); var holeCards = (playerState && playerState.holeCards) || []; if (holeCards.length < 2) continue; var best = poker.bestHand(holeCards, community); playerHands.push({ seatIndex: i, playerId: seats[i].playerId, username: seats[i].username, holeCards: holeCards, hand: best }); } // Calculate pots var pots = poker.calculatePots(seats); if (pots.length === 0) { // Edge case — just award remaining pot pots = [{ amount: s.pot, eligibleSeatIndices: playerHands.map(function (h) { return h.seatIndex; }) }]; } var winnerInfos = []; var totalAwarded = {}; for (var p = 0; p < pots.length; p++) { var pot = pots[p]; var eligible = []; for (var h = 0; h < playerHands.length; h++) { if (pot.eligibleSeatIndices.indexOf(playerHands[h].seatIndex) !== -1) { eligible.push(playerHands[h]); } } if (eligible.length === 0) continue; // Sort by hand strength descending eligible.sort(function (a, b) { return poker.compareHands(b.hand, a.hand); }); // Find all winners (ties) var winners = [eligible[0]]; for (var w = 1; w < eligible.length; w++) { if (poker.compareHands(eligible[w].hand, eligible[0].hand) === 0) { winners.push(eligible[w]); } else { break; } } var share = Math.floor(pot.amount / winners.length); var remainder = pot.amount - (share * winners.length); for (var wi = 0; wi < winners.length; wi++) { var winAmt = share + (wi === 0 ? remainder : 0); var si = winners[wi].seatIndex; seats[si].chips += winAmt; totalAwarded[si] = (totalAwarded[si] || 0) + winAmt; winnerInfos.push({ seatIndex: si, playerId: winners[wi].playerId, username: winners[wi].username, handName: winners[wi].hand.name, holeCards: winners[wi].holeCards, bestCards: winners[wi].hand.cards, amount: winAmt, potIndex: p }); } } // Build showdown reveal (all non-folded players' cards) var showdownReveal = []; for (var r = 0; r < playerHands.length; r++) { showdownReveal.push({ seatIndex: playerHands[r].seatIndex, username: playerHands[r].username, holeCards: playerHands[r].holeCards, handName: playerHands[r].hand.name, handRank: playerHands[r].hand.rank }); } api.patchState({ phase: 'showdown', seats: seats, pot: 0, currentTurnSeatIndex: -1, winners: winnerInfos, showdownReveal: showdownReveal, handInProgress: false }); // Announce winners for (var an = 0; an < winnerInfos.length; an++) { var info = winnerInfos[an]; var msg = '🏆 ' + (info.username || 'Player') + ' wins ' + info.amount + ' with ' + info.handName + '!'; api.announce(msg, { style: 'success', duration: 3, audience: { kind: 'place' } }); } api.playSound('cdn/sfx-reward.mp3', { audience: { kind: 'place' } }); // Schedule return to waiting for ready-up api.runInSeconds(SHOWDOWN_DELAY, function () { clearHoleCards(api); var s2 = api.getState(); var waitSeats = deepCopySeats(s2.seats); // Reset all ready flags for (var ri = 0; ri < waitSeats.length; ri++) { waitSeats[ri].ready = false; } api.patchState({ phase: 'waiting', seats: waitSeats, winners: [], showdownReveal: [], lastAction: null }); if (countActivePlayers(waitSeats) >= 2) { api.announce('Ready up for the next hand!', { style: 'info', duration: 2, audience: { kind: 'place' } }); } else { api.announce('Waiting for players...', { style: 'info', duration: 2, audience: { kind: 'place' } }); } }); } // ---- Award pot when all but one fold ---- function awardPotToLastPlayer(api) { var s = api.getState(); var seats = deepCopySeats(s.seats); var winnerIdx = -1; for (var i = 0; i < seats.length; i++) { if (seats[i].active && seats[i].playerId && !seats[i].folded) { winnerIdx = i; break; } } if (winnerIdx === -1) { // No one left — shouldn't happen but reset api.patchState({ phase: 'waiting', handInProgress: false, pot: 0 }); return; } seats[winnerIdx].chips += s.pot; var username = seats[winnerIdx].username || 'Player'; api.patchState({ phase: 'showdown', seats: seats, pot: 0, currentTurnSeatIndex: -1, winners: [{ seatIndex: winnerIdx, playerId: seats[winnerIdx].playerId, username: username, handName: 'Everyone folded', holeCards: [], bestCards: [], amount: s.pot, potIndex: 0 }], showdownReveal: [], handInProgress: false, lastAction: { seat: winnerIdx, action: 'wins pot', amount: s.pot, username: username } }); api.announce('🏆 ' + username + ' wins ' + s.pot + '!', { style: 'success', duration: 3, audience: { kind: 'place' } }); api.playSound('cdn/sfx-reward.mp3', { audience: { kind: 'place' } }); // Schedule return to waiting for ready-up api.runInSeconds(SHOWDOWN_DELAY, function () { clearHoleCards(api); var s2 = api.getState(); var waitSeats = deepCopySeats(s2.seats); // Reset all ready flags for (var ri = 0; ri < waitSeats.length; ri++) { waitSeats[ri].ready = false; } api.patchState({ phase: 'waiting', seats: waitSeats, winners: [], showdownReveal: [], lastAction: null }); if (countActivePlayers(waitSeats) >= 2) { api.announce('Ready up for the next hand!', { style: 'info', duration: 2, audience: { kind: 'place' } }); } else { api.announce('Waiting for players...', { style: 'info', duration: 2, audience: { kind: 'place' } }); } }); } // ---- Clear hole cards from all players ---- function clearHoleCards(api) { var s = api.getState(); for (var i = 0; i < s.seats.length; i++) { if (s.seats[i].playerId) { api.patchObjectState(s.seats[i].playerId, { holeCards: [] }); } } } // ---- Utility ---- function findPlayerSeat(seats, playerId) { for (var i = 0; i < seats.length; i++) { if (seats[i].playerId === playerId) return i; } return -1; } function deepCopySeats(seats) { var copy = []; for (var i = 0; i < seats.length; i++) { copy.push({ playerId: seats[i].playerId, username: seats[i].username, chips: seats[i].chips, currentBet: seats[i].currentBet, totalBet: seats[i].totalBet, folded: seats[i].folded, allIn: seats[i].allIn, active: seats[i].active, actedThisRound: seats[i].actedThisRound, ready: seats[i].ready || false }); } return copy; }