Basis\Toolkit

Complexity

Total Complexity

19

Size/Duplication

Total Lines	105
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	1

Test Coverage

Coverage

68.18%

Importance

Changes

0

17 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	4	1
A	create()	0	4	1
A	dispatch()	0	4	1
A	find()	0	4	1
A	findOne()	0	4	1
A	findOrCreate()	0	4	1
A	findOrFail()	0	4	1
A	fire()	0	4	1
A	get()	0	4	1
A	getDate()	0	4	1
A	getMapper()	0	4	1
A	getRepository()	0	7	2
A	getQueue()	0	15	2
A	remove()	0	4	1
A	select()	0	4	1
A	insert()	0	4	1
A	__debugInfo()	0	6	1

<?php

namespace Basis;

use Tarantool\Mapper\Entity;
use Tarantool\Mapper\Mapper;
use Tarantool\Mapper\Pool;
use Tarantool\Queue\Queue;

trait Toolkit
{
    protected $app;

    public function __construct(Application $app)
    {
        $this->app = $app;
    }

    protected function create(string $space, array $data) : Entity
    {
        return $this->getRepository($space)->create($data)->save();
    }

    protected function dispatch(string $job, array $params = [], string $service = null)
    {
        return $this->app->dispatch($job, $params, $service);
    }

    protected function find(string $space, $params = []) : array
    {
        return $this->getRepository($space)->find($params);
    }

    protected function findOne(string $space, $params = []) : ?Entity
    {
        return $this->getRepository($space)->findOne($params);
    }

    protected function findOrCreate(string $space, $params = []) : Entity
    {
        return $this->getRepository($space)->findOrCreate($params);
    }

    protected function findOrFail(string $space, $params = []) : Entity
    {
        return $this->getRepository($space)->findOrFail($params);
    }

    protected function fire(string $event, array $context)
    {
        return $this->get(Event::class)->fire($event, $context);
    }

    protected function get(string $class)
    {
        return $this->app->get($class);
    }

    protected function getDate()
    {
        return call_user_func_array([$this->get(Converter::class), 'getDate'], func_get_args());
    }

    protected function getMapper()
    {
        return $this->get(Mapper::class);
    }

    protected function getRepository($space)
    {
        if (strpos($space, '.') !== false) {
            return $this->get(Pool::class)->getRepository($space);
        }
        return $this->get(Mapper::class)->getRepository($space);
    }

    protected function getQueue($tube)
    {
        $alias = "queue.$tube";
        if (!$this->app->hasShared($alias, true)) {
            $client = $this->getMapper()->getClient();
            $client->evaluate("
                if queue == nil then
                    queue = require('queue')
                end
            ");
            $this->app->share($alias, new Queue($client, $tube));
        }

        return $this->app->get($alias);
    }

    protected function remove(string $space, array $params = [])
    {
        return $this->getRepository($space)->remove($params);
    }

    protected function select($fields, string $table, array $params)
    {
        return $this->get(Clickhouse::class)->select($fields, $table, $params);
    }

    protected function insert(string $table, array $data, array $headers)
    {
        return $this->get(Clickhouse::class)->insert($table, $data, $headers);
    }

    public function __debugInfo()
    {
        $info = get_object_vars($this);
        unset($info['app']);
        return $info;
    }
}