Basis\Queue

Complexity

Total Complexity

7

Size/Duplication

Total Lines	41
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	4

Test Coverage

Coverage

100%

Importance

Changes

0

6 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	5	1
A	init()	0	9	1
A	truncate()	0	4	1
A	take()	0	7	2
A	ack()	0	4	1
A	put()	0	4	1

<?php

namespace Basis;

use Exception;
use Tarantool\Client\Client;
use Tarantool\Client\Connection\StreamConnection;
use Tarantool\Client\Packer\PurePacker;

class Queue extends Client
{
    public function __construct(Config $config)
    {
        $connection = new StreamConnection('tcp://'.$config['queue.host'].':'.$config['queue.port']);
        parent::__construct($connection, new PurePacker());
    }

    public function init($tube)
    {
        return $this->evaluate("
            box.once('$tube-tube', function()
                local queue = require('queue')
                queue.create_tube('$tube', 'fifottl')
            end)
        ");
    }

    public function truncate($tube)
    {
        $this->evaluate("require('queue').tube.$tube:truncate()");
    }

    public function take($tube, $timeout = 30)
    {
        $tasks = $this->evaluate("return require('queue').tube.$tube:take($timeout)")->getData();
        if(count($tasks)) {
            return $tasks[0];
        }
    }

    public function ack($tube, $task)
    {
        return $this->evaluate("require('queue').tube.$tube:ack($task)");
    }

    public function put($tube, $task)
    {
        return $this->evaluate("require('queue').tube.$tube:put(...)", [$task]);
    }
}