Tarantool\Mapper\Event

Complexity

Total Complexity

10

Size/Duplication

Total Lines	70
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	7

Test Coverage

Coverage

92.86%

Importance

Changes

0

4 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	7	1
A	getTime()	0	4	1
A	getResponse()	0	4	1
C	render()	0	44	7

<?php

namespace Tarantool\Mapper;

use Tarantool\Client\Connection\Connection;
use Tarantool\Client\IProto;
use Tarantool\Client\Request\EvaluateRequest;
use Tarantool\Client\Request\Request;
use Tarantool\Client\Request\SelectRequest;

class Event
{
    private $time;
    private $class;
    private $request;
    private $response;

    public function __construct($time, $class, $request, $response)
    {
        $this->time = $time;
        $this->class = $class;
        $this->request = $request;
        $this->response = $response;
    }

    public function render(Manager $manager)
    {
        switch ($this->class) {
            case Connection::class:
                return 'Make connection';

            case EvaluateRequest::class:
                return trim($this->request[39]);

            case SelectRequest::class:

The case body in a switch statement must start on the line following the statement.

                $params = $this->request[IProto::KEY];
                $spaceId = $this->request[IProto::SPACE_ID];
                $index = $this->request[IProto::INDEX_ID];

                $client = $manager->getClient();
                $meta = $manager->getMeta();
                $schema = $manager->getSchema();
                $space = $schema->getSpaceName($spaceId);

                if ($meta->has($space)) {
                    $index = $meta->get($space)->getIndex($index);
                } else {
                    $data = $client->getSpace('_vindex')->select([$this->request[IProto::SPACE_ID], $index], 'primary')->getData();
                    $index = [];

                    foreach ($data[0][5] as $row) {
                        $index[] = $row[0];
                    }
                }

                if (count($params) == 1) {
                    $params = array_shift($params);
                    $index = array_shift($index);
                } else {
                    $params = json_encode($params);
                    $index = json_encode($index);
                }

                return "select $space where $index = $params";
            default:
                return json_encode($this->request);
        }
    }

    public function getTime()
    {
        return $this->time;
    }

    public function getResponse()
    {
        return $this->response;
    }
}