Nopolabs\Yabot\Plugins\Queue\Queue

Complexity

Total Complexity

16

Size/Duplication

Total Lines	87
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	2

Importance

Changes

0

9 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	9	2
A	push()	0	5	1
A	insert()	0	16	4
A	next()	0	5	1
A	remove()	0	11	3
A	clear()	0	5	1
A	buildElement()	0	7	1
A	getQueue()	0	4	1
A	getDetails()	0	10	2

<?php

namespace Nopolabs\Yabot\Plugins\Queue;


use Nopolabs\Yabot\Message\Message;
use Nopolabs\Yabot\Helpers\StorageTrait;
use Nopolabs\Yabot\Storage\StorageInterface;

class Queue
{
    use StorageTrait;

    protected $queue;

    public function __construct(StorageInterface $storage, array $config)
    {
        $this->setStorageKey($config['storageName'] ?? 'queue');
        $this->setStorage($storage);

        $this->queue = $this->load() ?: [];

        $this->save($this->queue);
    }

    public function push($element)
    {
        $this->queue[] = $element;
        $this->save($this->queue);
    }

    public function insert($element, $index)
    {
        $queue = [];
        $idx = -1;
        foreach ($this->queue as $idx => $el) {
            if ($idx === $index) {
                $queue[] = $element;
            }
            $queue[] = $el;
        }
        if ($idx < $index) {
            $queue[] = $element;
        }
        $this->queue = $queue;
        $this->save($this->queue);
    }

    public function next()
    {
        array_shift($this->queue);
        $this->save($this->queue);
    }

    public function remove($element)
    {
        $queue = [];
        foreach ($this->queue as $el) {
            if ($el['item'] !== $element['item']) {
                $queue[] = $el;
            }
        }
        $this->queue = $queue;
        $this->save($this->queue);
    }

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

    public function buildElement(Message $msg, array $matches)
    {
        return [
            'user' => $msg->getUsername(),
            'item' => $matches['item'],
        ];
    }

    public function getQueue() : array
    {
        return $this->queue;
    }

    public function getDetails() : array
    {
        $details = [];

        foreach ($this->getQueue() as $element) {
            $details[] = json_encode($element);
        }

        return $details;
    }
}