Completed
Push — master ( d22295...288421 )
by Dmitry
04:25
created

Queue   A

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
Metric Value
wmc 7
lcom 1
cbo 4
dl 0
loc 41
ccs 21
cts 21
cp 1
rs 10
c 0
b 0
f 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
1
<?php
2
3
namespace Basis;
4
5
use Exception;
6
use Tarantool\Client\Client;
7
use Tarantool\Client\Connection\StreamConnection;
8
use Tarantool\Client\Packer\PurePacker;
9
10
class Queue extends Client
11
{
12 1
    public function __construct(Config $config)
13
    {
14 1
        $connection = new StreamConnection('tcp://'.$config['queue.host'].':'.$config['queue.port']);
15 1
        parent::__construct($connection, new PurePacker());
16 1
    }
17
18 1
    public function init($tube)
19
    {
20 1
        return $this->evaluate("
21 1
            box.once('$tube-tube', function()
22
                local queue = require('queue')
23 1
                queue.create_tube('$tube', 'fifottl')
24
            end)
25 1
        ");
26
    }
27
28 1
    public function truncate($tube)
29
    {
30 1
        $this->evaluate("require('queue').tube.$tube:truncate()");
31 1
    }
32
33 1
    public function take($tube, $timeout = 30)
34
    {
35 1
        $tasks = $this->evaluate("return require('queue').tube.$tube:take($timeout)")->getData();
36 1
        if(count($tasks)) {
37 1
            return $tasks[0];
38
        }
39 1
    }
40
41 1
    public function ack($tube, $task)
42
    {
43 1
        return $this->evaluate("require('queue').tube.$tube:ack($task)");
44
    }
45
46 1
    public function put($tube, $task)
47
    {
48 1
        return $this->evaluate("require('queue').tube.$tube:put(...)", [$task]);
49
    }
50
}