insolita\cqueue\Mixins\DelayingTrait

Complexity

Total Complexity

19

Size/Duplication

Total Lines	70
Duplicated Lines	0 %

Importance

Changes	1
Bugs	0	Features	0

9 Methods

Rating	Name	Duplication	Size	Complexity
A	listDelayed()	0	7	3
A	delayedKey()	0	3	1
A	listExpired()	0	3	1
A	resume()	0	12	5
A	resumeExpired()	0	6	3
A	purgeDelayed()	0	3	1
A	resumeAt()	0	4	1
A	countDelayed()	0	3	1
A	resumeAllDelayed()	0	6	3

<?php
/**
 * Created by solly [30.10.17 23:36]
 */

namespace insolita\cqueue\Mixins;

use Carbon\Carbon;
use function in_array;

/**
 * @mixin \insolita\cqueue\CircularQueue
 **/
trait DelayingTrait
{
    
    public function resume($payload, int $delay = 0, bool $force = false)
    {
        $identity = $this->converter->toIdentity($payload);
        if ($delay === 0) {
            if ($this->storage->zSetExists($this->delayedKey(), $identity)) {
                $this->storage->moveFromZSetToList($this->queueKey(), $this->delayedKey(), $identity);

It seems like queueKey() must be provided by classes using this trait. How about adding it as abstract method to this trait?

            }elseif ($force === true || !in_array($identity, $this->storage->listItems($this->queueKey()))){
                $this->storage->listPush($this->queueKey(), [$identity]);
            }
        } else {
            $timestamp = Carbon::now()->timestamp + $delay;
            $this->storage->zSetPush($this->delayedKey(), $timestamp, $identity);
        }
    }
    public function resumeAt($payload, int $timestamp)
    {
        $identity = $this->converter->toIdentity($payload);
        $this->storage->zSetPush($this->delayedKey(), $timestamp, $identity);
    }
    public function countDelayed(): int
    {
        return $this->storage->zSetCount($this->delayedKey());
    }
    
    public function listDelayed($converted = false): array
    {
        $list = $this->storage->zSetItems($this->delayedKey());
        if ($converted === false || empty($list)) {
            return $list;
        } else {
            return array_map([$this->converter, 'toPayload'], $list);
        }
    }
    
    public function resumeAllDelayed()
    {
        $inUse = $this->listDelayed();
        if (!empty($inUse)) {
            foreach ($inUse as $identity) {
                $this->storage->moveFromZSetToList($this->queueKey(), $this->delayedKey(), $identity);
            }
        }
    }
    
    public function purgeDelayed()
    {
        $this->storage->delete($this->delayedKey());
    }
    
    protected function listExpired($expireTime): array
    {
        return $this->storage->zSetExpiredItems($this->delayedKey(), $expireTime);
    }
    
    protected function resumeExpired()
    {
        $inUseExpired = $this->listExpired(Carbon::now()->timestamp);
        if (!empty($inUseExpired)) {
            foreach ($inUseExpired as $identity) {
                $this->storage->moveFromZSetToList($this->queueKey(), $this->delayedKey(), $identity);
            }
        }
    }
    
    protected function delayedKey(): string
    {
        return $this->getName() . ':Wait';

It seems like getName() must be provided by classes using this trait. How about adding it as abstract method to this trait?

    }
}