Wandu\Q\Adapter\ArrayAdapter

Complexity

Total Complexity

10

Size/Duplication

Total Lines	65
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	1

Test Coverage

Coverage

88%

Importance

Changes

0

6 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	4	1
A	flush()	0	4	1
A	count()	0	4	1
A	send()	0	8	1
A	receive()	0	9	3
A	remove()	0	10	3

<?php
namespace Wandu\Q\Adapter;

use Wandu\Q\Contracts\Adapter;
use Countable;

class ArrayAdapter implements Adapter, Countable
{
    /** @var array */
    protected $queue;

    public function __construct()
    {
        $this->queue = [];
    }

    /**
     * {@inheritdoc}
     */
    public function flush()
    {
        $this->queue = [];
    }

    /**
     * {@inheritdoc}
     */
    public function count()
    {
        return count($this->queue);
    }

    /**
     * {@inheritdoc}
     */
    public function send(string $payload)
    {
        $this->queue[] = [
            'id' => uniqid(),
            'payload' => $payload,
            'reserved' => false,
        ];
    }

    /**
     * {@inheritdoc}
     */
    public function receive()
    {
        foreach ($this->queue as $idx => $item) {
            if (!$item['reserved']) {
                $this->queue[$idx]['reserved'] = true;
                return new ArrayJob($item['id'], $item['payload']);
            }
        }
    }

    /**
     * {@inheritdoc}
     */
    public function remove($job)
    {
        foreach ($this->queue as $idx => $item) {
            /** @var \Wandu\Q\Adapter\ArrayJob $job */
            if ($item['id'] === $job->getIdentifier()) {
                array_splice($this->queue, $idx, 1);
                return;
            }
        }
    }
}