Розробка мобільного додатку для аукціону

Розробка мобільного додатку для аукціону

Аукціонне додаток—один з найтехнічно вимогливих продуктів у мобільної розробці. Причина: стан лота змінюється в реальному часі, кожні кілька секунд може з'явитися нова ставка, й користувач на іншій стороні чекає миттєвого результату. Затримка в 2 секунди при відображенні чужої ставки—й користувач робить ставку на вже програну позицію.

Реальний час: WebSocket як основа

Polling для аукціону—неприйнятно. WebSocket з переподключенням—стандарт:

// iOS: WebSocket через URLSessionWebSocketTask
class AuctionWebSocket {
    private var webSocketTask: URLSessionWebSocketTask?
    private var reconnectTimer: Timer?

    func connect(auctionId: String) {
        let url = URL(string: "wss://api.yourauction.com/auctions/\(auctionId)/live")!
        webSocketTask = URLSession.shared.webSocketTask(with: url)
        webSocketTask?.resume()
        receive()
    }

    private func receive() {
        webSocketTask?.receive { [weak self] result in
            switch result {
            case .success(let message):
                if case .string(let text) = message {
                    self?.handleMessage(text)
                }
                self?.receive() // продовжуємо слухати
            case .failure:
                self?.scheduleReconnect()
            }
        }
    }

    private func scheduleReconnect() {
        reconnectTimer?.invalidate()
        reconnectTimer = Timer.scheduledTimer(withTimeInterval: 3.0, repeats: false) { [weak self] _ in
            self?.connect(auctionId: self?.currentAuctionId ?? "")
        }
    }
}

// Android: OkHttp WebSocket
class AuctionWebSocketManager(
    private val client: OkHttpClient,
    private val scope: CoroutineScope
) {
    private val _events = MutableSharedFlow<AuctionEvent>()
    val events: SharedFlow<AuctionEvent> = _events.asSharedFlow()

    fun connect(auctionId: String) {
        val request = Request.Builder()
            .url("wss://api.yourauction.com/auctions/$auctionId/live")
            .build()

        client.newWebSocket(request, object : WebSocketListener() {
            override fun onMessage(webSocket: WebSocket, text: String) {
                scope.launch {
                    val event = json.decodeFromString<AuctionEvent>(text)
                    _events.emit(event)
                }
            }

            override fun onFailure(webSocket: WebSocket, t: Throwable, response: Response?) {
                scope.launch {
                    delay(3000)
                    connect(auctionId)
                }
            }
        })
    }
}

Типи подій від сервера: BID_PLACED (нова ставка), AUCTION_EXTENDED (час продовжено), AUCTION_ENDED, YOU_WON, YOU_WERE_OUTBID.

Гонка умов при ставках

Найскладніша бізнес-логіка: два користувачі роблять ставку одночасно. Приклад:

1. Поточна ставка: 1000 ₽
2. Користувач A бачить 1000 ₽, робить ставку 1100 ₽
3. Користувач B бачить 1000 ₽, робить ставку 1050 ₽
4. Обидві ставки приходять на сервер одночасно

Правильне рішення—оптимистична блокування з версією лота:

def place_bid(user_id: str, lot_id: str, amount: Decimal, expected_version: int) -> BidResult:
    with db.transaction():
        lot = db.select_for_update(f"SELECT * FROM lots WHERE id = %s", lot_id)

        if lot.version != expected_version:
            # За це время хтось уже підняв ставку
            return BidResult(
                success=False,
                reason="LOT_UPDATED",
                current_bid=lot.current_bid,
                new_version=lot.version
            )

        if amount <= lot.current_bid:
            return BidResult(
                success=False,
                reason="BID_TOO_LOW",
                current_bid=lot.current_bid,
                new_version=lot.version
            )

        db.execute(
            "UPDATE lots SET current_bid=%s, current_bidder=%s, version=version+1 WHERE id=%s",
            (amount, user_id, lot_id)
        )
        db.execute(
            "INSERT INTO bids (lot_id, user_id, amount) VALUES (%s, %s, %s)",
            (lot_id, user_id, amount)
        )

        broadcast_to_websockets(lot_id, {
            "type": "BID_PLACED",
            "amount": str(amount),
            "bidder": mask_username(user_id),
            "version": lot.version + 1
        })

        return BidResult(success=True, new_version=lot.version + 1)

При LOT_UPDATED клієнт отримує актуальну ставку та може запропонувати користувачеві нову з урахуванням поточної ціни.

Автоставка (proxy bidding)

Користувач встановлює максимальну суму, яку готов заплатити. Система автоматично підвищує його ставку у відповідь на ставки конкурентів—до встановленого максимуму.

def process_autobid(lot_id: str, new_bid_amount: Decimal, new_bidder_id: str):
    """Перевіряємо автоставки після кожної нової ставки"""
    autobids = db.get_active_autobids(lot_id, exclude_user=new_bidder_id)

    for autobid in sorted(autobids, key=lambda x: x.max_amount, reverse=True):
        counter_amount = new_bid_amount + lot.bid_step

        if counter_amount <= autobid.max_amount:
            # Автоматично ставимо від імені тримача автоставки
            place_bid(autobid.user_id, lot_id, counter_amount, lot.version)
            break

Автоставка—джерело конфліктів з користувачами, тому важлива детальна історія: «Ваша ставка 1 200 ₽ була автоматично підвищена у відповідь на ставку 1 100 ₽».

Продовження часу anti-sniping

Снайпинг—ставка в останні секунди. Щоб його уникнути, аукціон продовжується при ставці в кінці:

ANTI_SNIPING_THRESHOLD = timedelta(minutes=2)
ANTI_SNIPING_EXTENSION = timedelta(minutes=2)

def after_bid_placed(lot_id: str):
    lot = db.get_lot(lot_id)
    time_remaining = lot.ends_at - datetime.utcnow()

    if time_remaining < ANTI_SNIPING_THRESHOLD:
        new_end_time = lot.ends_at + ANTI_SNIPING_EXTENSION
        db.update_lot_end_time(lot_id, new_end_time)
        broadcast_to_websockets(lot_id, {
            "type": "AUCTION_EXTENDED",
            "new_end_time": new_end_time.isoformat()
        })

Таймер на клієнті синхронізується з серверним часом при отриманні AUCTION_EXTENDED.

Платіжна логіка

Переможець отримує push-повідомлення та має обмежений час (24–48 годин) для оплати. Якщо не оплатив—лот переходить наступному за ставкою або виставляється повторно.

Для цінних лотів—передплата перед участю: депозит блокується при реєстрації на торги, повертається переможцям.

Комісія з продажу (покупця або продавця) утримується при оплаті. Payouts продавцю—через Stripe Connect або аналог.

Ориентири по терміні

Вартість розраховується індивідуально після аналізу вимог.