NilPortugues\Foundation\Infrastructure\Model\Repository\EloquentMongoDB\EloquentWriteRepository

Complexity

Total Complexity

12

Size/Duplication

Total Lines	127
Duplicated Lines	17.32 %

Coupling/Cohesion

Components	1
Dependencies	6

Importance

Changes	2
Bugs	0	Features	0

7 Methods

Rating	Name	Duplication	Size	Complexity
A	count()	11	11	2
A	exists()	0	7	1
A	add()	0	7	1
A	addAll()	0	15	3
A	remove()	0	6	1
A	removeAll()	11	11	2
A	transactional()	0	8	2

<?php

namespace NilPortugues\Foundation\Infrastructure\Model\Repository\EloquentMongoDB;

use NilPortugues\Foundation\Domain\Model\Repository\Contracts\Filter;
use NilPortugues\Foundation\Domain\Model\Repository\Contracts\Identity;
use NilPortugues\Foundation\Domain\Model\Repository\Contracts\WriteRepository;

class EloquentWriteRepository extends BaseEloquentRepository implements WriteRepository
{
    /**
     * Returns the total amount of elements in the repository given the restrictions provided by the Filter object.
     *
     * @param Filter|null $filter
     *
     * @return int
     */
    public function count(Filter $filter = null)

This method seems to be duplicated in your project.

    {
        $model = self::$instance;
        $query = $model->query();

        if ($filter) {
            EloquentFilter::filter($query, $filter);

$query of type object<Illuminate\Database\Eloquent\Builder> is not a sub-type of object<Jenssegers\Mongodb\Eloquent\Builder>. It seems like you assume a child class of the class Illuminate\Database\Eloquent\Builder to be always present.

        }

        return (int) $query->getQuery()->count();
    }

    /**
     * Returns whether an entity with the given id exists.
     *
     * @param $id
     *
     * @return bool
     */
    public function exists(Identity $id)
    {
        $model = self::$instance;
        $result = $model->query()->where($model->getKeyName(), '=', $id->id())->first();

        return null !== $result;
    }

    /**
     * Adds a new entity to the storage.
     *
     * @param Identity $value
     *
     * @return mixed
     */
    public function add(Identity $value)
    {
        $this->guard($value);
        $value->save();

It seems like you code against a concrete implementation and not the interface NilPortugues\Foundation\Domain\Model\Repository\Contracts\Identity as the method save() does only exist in the following implementations of said interface: NilPortugues\Example\Persistence\Eloquent\User.

        return $value;
    }

    /**
     * Adds a collections of entities to the storage.
     *
     * @param array $values
     *
     * @return mixed
     *
     * @throws \Exception
     */
    public function addAll(array $values)
    {
        $model = self::$instance;
        $ids = [];
        try {
            foreach ($values as $value) {
                $this->guard($value);
                $value->save();
                $ids[] = $value->getIdAttribute('_id');
            }
        } catch (\Exception $e) {
            $model->destroy($ids);
            throw $e;
        }
    }

    /**
     * Removes the entity with the given id.
     *
     * @param $id
     *
     * @return bool
     */
    public function remove(Identity $id)
    {
        $model = self::$instance;

        return (bool) $model->query()->find($id->id())->delete();
    }

    /**
     * Removes all elements in the repository given the restrictions provided by the Filter object.
     * If $filter is null, all the repository data will be deleted.
     *
     * @param Filter $filter
     *
     * @return bool
     */
    public function removeAll(Filter $filter = null)

This method seems to be duplicated in your project.

    {
        $model = self::$instance;
        $query = $model->query();

        if ($filter) {
            EloquentFilter::filter($query, $filter);

$query of type object<Illuminate\Database\Eloquent\Builder> is not a sub-type of object<Jenssegers\Mongodb\Eloquent\Builder>. It seems like you assume a child class of the class Illuminate\Database\Eloquent\Builder to be always present.

        }

        return $query->delete();
    }

    /**
     * Repository data is added or removed as a whole block.
     * Must work or fail and rollback any persisted/erased data.
     *
     * @param callable $transaction
     *
     * @throws \Exception
     */
    public function transactional(callable $transaction)
    {
        try {
            $transaction();
        } catch (\Exception $e) {
            throw $e;
        }
    }
}