insolita\cqueue\CircularQueue

Complexity

Total Complexity

6

Size/Duplication

Total Lines	33
Duplicated Lines	0 %

Importance

Changes	1
Bugs	0	Features	0

4 Methods

Rating	Name	Duplication	Size	Complexity
A	beforePull()	0	3	1
A	pull()	0	12	3
A	countTotal()	0	3	1
A	next()	0	4	1

<?php
/**
 * Created by solly [31.10.17 15:41]
 */

namespace insolita\cqueue;

use Carbon\Carbon;
use insolita\cqueue\Contracts\DelayingInterface;
use insolita\cqueue\Mixins\DelayingTrait;

class CircularQueue extends SimpleCircularQueue implements DelayingInterface
{
    use DelayingTrait;

The trait insolita\cqueue\Mixins\DelayingTrait requires the property $timestamp which is not provided by insolita\cqueue\CircularQueue.

    
    public function countTotal():int
    {
        return $this->countQueued() + $this->countDelayed();
    }
    
    public function next()
    {
        $this->beforePull();
        return parent::next();
    }
    
    public function pull(int $ttl = 0)
    {
        $this->beforePull();
        $item = $this->storage->listPop($this->queueKey());
        if (!$item) {
            return $this->emptyQueueBehavior->resolve($this);
        } else {
            if ($ttl > 0) {
                $resumeTime = Carbon::now()->timestamp + $ttl;
                $this->storage->zSetPush($this->delayedKey(), $resumeTime, $item);
            }
            return $this->converter->toPayload($item);
        }
    }
    
    protected function beforePull()
    {
        $this->resumeExpired();
    }
}