<?php

declare(strict_types=1);

namespace MonetaPhpShop\host;

use MonetaPhpShop\callback\OrderLock;

/**
 * Блокировка заказа через `GET_LOCK` MySQL: таблицы PHPShop — MyISAM, транзакций нет.
 * Имя блокировки общее для сервера MySQL, поэтому в него входит имя базы: два магазина
 * на одном сервере друг друга не ждут. Блокировка снимается и при обрыве соединения.
 */
final class MysqlOrderLock implements OrderLock
{
    /** Сколько ждать параллельное уведомление по тому же заказу, секунд. */
    private const TIMEOUT = 10;

    private const NAME = "CONCAT('moneta_', MD5(CONCAT(DATABASE(), ':', ?)))";

    /** @var Database */
    private $database;

    public function __construct(Database $database)
    {
        $this->database = $database;
    }

    public function acquire(int $orderId): bool
    {
        return (int) $this->database->fetchValue('SELECT GET_LOCK(' . self::NAME . ', ?)', [$orderId, self::TIMEOUT]) === 1;
    }

    public function release(int $orderId): void
    {
        $this->database->fetchValue('SELECT RELEASE_LOCK(' . self::NAME . ')', [$orderId]);
    }
}