Fantasy Cricket Live Auction Platform for IPL 2026

# Simplified: server-authoritative bid handling and timer extension

async def place_bid(self, league_id: str, bid: int, bidder: str) -> tuple[bool, str]:
    lock = get_bid_lock(int(league_id))
    acquired = await asyncio.to_thread(lock.acquire, blocking=True)
    if not acquired:
        return False, "Could not acquire bid lock"

    try:
        queue = self._get_bid_queue(league_id)
        queue.append({"bid": bid, "bidder": bidder})
        now = _utc_timestamp()

        while queue:
            current = queue.pop(0)
            async with self._lock:
                state = self._leagues[league_id]["state"]
                if state["auction_state"] != AuctionPhase.BIDDING.value:
                    return False, "Auction not active"

                current_price = int(state.get("current_bid") or 0)
                new_bid = int(current["bid"])
                if new_bid <= current_price:
                    return False, "Bid must be higher"

                # Read current deadline
                ts = state.get("timer_end_timestamp")
                remaining = float(ts) - now if ts is not None else 0.0

                # Update price + bidder
                state["current_bid"] = new_bid
                state["highest_bidder"] = current["bidder"]

                # Only extend in the last-second window; otherwise keep the deadline
                if remaining > 0 and remaining <= LAST_SECOND_EXTEND_THRESHOLD:
                    state["timer_end_timestamp"] = now + LAST_SECOND_EXTEND_BY
                elif remaining <= 0:
                    timer_sec = state.get("bid_timer_seconds") or BID_TIMER_RESET
                    state["timer_end_timestamp"] = now + int(timer_sec)

        asyncio.create_task(self.save_snapshot(league_id))
        return True, ""
    finally:
        await asyncio.to_thread(lock.release)