Zenstruck\ScheduleBundle\Schedule\Extension\SingleServerExtension

Complexity

Total Complexity

4

Size/Duplication

Total Lines	31
Duplicated Lines	0 %

Test Coverage

Coverage

100%

Importance

Changes	1
Bugs	0	Features	0

4 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	4	1
A	__toString()	0	3	1
A	getMissingHandlerMessage()	0	3	1
A	aquireLock()	0	5	1

<?php

namespace Zenstruck\ScheduleBundle\Schedule\Extension;

use Symfony\Component\Lock\LockFactory;
use Zenstruck\ScheduleBundle\Schedule\Extension;

/**
 * @author Kevin Bond <kevinbond@gmail.com>
 */
final class SingleServerExtension implements Extension, HasMissingHandlerMessage
{
    public const DEFAULT_TTL = 3600;

    private $ttl;
    private $lock;

    /**
     * @param int $ttl Maximum expected lock duration in seconds
     */
    public function __construct(int $ttl = self::DEFAULT_TTL)
    {
        $this->ttl = $ttl;
        $this->lock = new Lock(self::class);
    }

    public function __toString(): string
    {
        return 'Run on single server';
    }

    public function aquireLock(LockFactory $lockFactory, string $mutex, int $timestamp): bool
    {
        $mutex .= \date('Hi', $timestamp);

        return $this->lock->aquire($lockFactory, $mutex, $this->ttl);
    }

    public function getMissingHandlerMessage(): string
    {
        return 'To use "onSingleServer" you must configure a lock factory (config path: "zenstruck_schedule.single_server_handler").';
    }
}