Isswp101\Persimmon\Repository\ElasticsearchRepository

Complexity

Total Complexity

14

Size/Duplication

Total Lines	107
Duplicated Lines	29.91 %

Coupling/Cohesion

Components	1
Dependencies	9

Importance

Changes

0

8 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	4	1
A	instantiate()	0	8	2
A	fill()	0	5	1
A	find()	0	18	3
B	all()	0	26	4
A	insert()	11	11	1
A	update()	11	11	1
A	delete()	10	10	1

<?php

namespace Isswp101\Persimmon\Repository;

use Elasticsearch\Client;
use Elasticsearch\Common\Exceptions\Missing404Exception;
use Isswp101\Persimmon\Collection\ElasticsearchCollection;
use Isswp101\Persimmon\Collection\IElasticsearchCollection;
use Isswp101\Persimmon\CollectionParser\ElasticsearchCollectionParser;
use Isswp101\Persimmon\Contracts\Storable;
use Isswp101\Persimmon\Exceptions\ClassTypeErrorException;
use Isswp101\Persimmon\Exceptions\ModelNotFoundException;
use Isswp101\Persimmon\Model\IElasticsearchModel;
use Isswp101\Persimmon\QueryBuilder\IQueryBuilder;
use Isswp101\Persimmon\Response\ElasticsearchCollectionResponse;
use Isswp101\Persimmon\Response\ElasticsearchItemResponse;

class ElasticsearchRepository implements IRepository
{
    const SOURCE_FALSE = [false];

    private $client;

    public function __construct(Client $client)
    {
        $this->client = $client;
    }

    public function instantiate(string $class): Storable
    {
        $instance = new $class;
        if (!$instance instanceof IElasticsearchModel) {
            throw new ClassTypeErrorException(IElasticsearchModel::class);
        }
        return $instance;
    }

    protected function fill(Storable $model, ElasticsearchItemResponse $response)
    {
        $model->fill($response->source());
        $model->setPrimaryKey($response->id());
    }

    public function find($id, string $class, array $columns = []): Storable
    {
        $model = $this->instantiate($class);
        $collection = new ElasticsearchCollectionParser($model->getCollectionName());
        $params = [
            'index' => $collection->getIndex(),
            'type' => $collection->getType(),
            'id' => $id,
            '_source' => $columns === ElasticsearchRepository::SOURCE_FALSE ? false : $columns
        ];
        try {
            $response = new ElasticsearchItemResponse($this->client->get($params));

$this->client->get($params) is of type callable, but the function expects a array.

        } catch (Missing404Exception $e) {
            throw new ModelNotFoundException($class, $id);
        }
        $this->fill($model, $response);
        return $model;
    }

    public function all(
        IQueryBuilder $query,
        string $class,
        array $columns = [],
        callable $callback = null
    ): IElasticsearchCollection {
        $model = $this->instantiate($class);
        $collection = new ElasticsearchCollectionParser($model->getCollectionName());
        $params = [
            'index' => $collection->getIndex(),
            'type' => $collection->getType(),
            'body' => $query->build(),
            '_source' => $columns === ElasticsearchRepository::SOURCE_FALSE ? false : $columns
        ];
        $response = new ElasticsearchCollectionResponse($this->client->search($params));

$this->client->search($params) is of type callable, but the function expects a array.

        $models = new ElasticsearchCollection([], $response);
        foreach ($response->hits() as $hit) {
            $model = $this->instantiate($class);
            $this->fill($model, new ElasticsearchItemResponse($hit));
            if ($callback != null) {
                $callback($model);
            }
            $models->put($model->getPrimaryKey(), $model);
        }
        return $models;
    }

    public function insert(Storable $model)

This method seems to be duplicated in your project.

    {
        $collection = new ElasticsearchCollectionParser($model->getCollectionName());
        $params = [
            'index' => $collection->getIndex(),
            'type' => $collection->getType(),
            'id' => $model->getPrimaryKey(),
            'body' => $model->toArray()
        ];
        $this->client->index($params);
    }

    public function update(Storable $model)

This method seems to be duplicated in your project.

    {
        $collection = new ElasticsearchCollectionParser($model->getCollectionName());
        $params = [
            'index' => $collection->getIndex(),
            'type' => $collection->getType(),
            'id' => $model->getPrimaryKey(),
            'body' => $model->toArray()
        ];
        $this->client->index($params);
    }

    public function delete(Storable $model)

This method seems to be duplicated in your project.

    {
        $collection = new ElasticsearchCollectionParser($model->getCollectionName());
        $params = [
            'index' => $collection->getIndex(),
            'type' => $collection->getType(),
            'id' => $model->getPrimaryKey()
        ];
        $this->client->delete($params);
    }
}