Tubee\Collection

Complexity

Total Complexity

21

Size/Duplication

Total Lines	236
Duplicated Lines	0 %

Coupling/Cohesion

Components	3
Dependencies	8

Test Coverage

Coverage

42.86%

Importance

Changes

0

19 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	11	1
A	getCollection()	0	4	1
A	getSchema()	0	4	1
A	getResourceNamespace()	0	4	1
A	decorate()	0	15	1
A	hasEndpoint()	0	4	1
A	getEndpoint()	0	4	1
A	getEndpoints()	0	4	1
A	getSourceEndpoints()	0	9	2
A	getDestinationEndpoints()	0	9	2
A	getIdentifier()	0	4	1
A	getObjectHistory()	0	4	1
A	getObject()	0	4	1
A	getObjects()	0	4	1
A	countObjects()	0	4	1
A	createObject()	0	4	1
A	changeObject()	0	4	1
A	deleteObject()	0	4	1
A	flush()	0	4	1

<?php

declare(strict_types=1);

/**
 * tubee
 *
 * @copyright   Copryright (c) 2017-2019 gyselroth GmbH (https://gyselroth.com)
 * @license     GPL-3.0 https://opensource.org/licenses/GPL-3.0
 */

namespace Tubee;

use Generator;
use MongoDB\BSON\ObjectIdInterface;
use Psr\Http\Message\ServerRequestInterface;
use Psr\Log\LoggerInterface;
use Tubee\Collection\CollectionInterface;
use Tubee\DataObject\DataObjectInterface;
use Tubee\DataObject\Factory as DataObjectFactory;
use Tubee\Endpoint\EndpointInterface;
use Tubee\Endpoint\Factory as EndpointFactory;
use Tubee\Resource\AbstractResource;
use Tubee\Resource\AttributeResolver;
use Tubee\ResourceNamespace\ResourceNamespaceInterface;
use Tubee\Schema\SchemaInterface;

class Collection extends AbstractResource implements CollectionInterface
{
    /**
     * Kind.
     */
    public const KIND = 'Collection';

    /**
     * Collection name.
     *
     * @var string
     */
    protected $name;

    /**
     * ResourceNamespace.
     *
     * @var ResourceNamespaceInterface
     */
    protected $namespace;

    /**
     * Schema.
     *
     * @var SchemaInterface
     */
    protected $schema;

    /**
     * Logger.
     *
     * @var LoggerInterface
     */
    protected $logger;

    /**
     * Dataobject factory.
     *
     * @var DataObjectFactory
     */
    protected $object_factory;

    /**
     * Endpoint factory.
     *
     * @var EndpointFactory
     */
    protected $endpoint_factory;

    /**
     * Collection name.
     *
     * @var string
     */
    protected $collection;

    /**
     * Initialize.
     */
    public function __construct(string $name, ResourceNamespaceInterface $namespace, EndpointFactory $endpoint_factory, DataObjectFactory $object_factory, SchemaInterface $schema, LoggerInterface $logger, array $resource = [])
    {
        $this->resource = $resource;
        $this->name = $name;
        $this->collection = 'objects'.'.'.$namespace->getName().'.'.$name;
        $this->namespace = $namespace;
        $this->schema = $schema;
        $this->endpoint_factory = $endpoint_factory;
        $this->logger = $logger;
        $this->object_factory = $object_factory;
    }

    /**
     * Get collection.
     */
    public function getCollection(): string
    {
        return $this->collection;
    }

    /**
     * Get schema.
     */
    public function getSchema(): SchemaInterface
    {
        return $this->schema;
    }

    /**
     * {@inheritdoc}
     */
    public function getResourceNamespace(): ResourceNamespaceInterface
    {
        return $this->namespace;
    }

    /**
     * Decorate.
     */
    public function decorate(ServerRequestInterface $request): array
    {
        $resource = [
            '_links' => [
                'namespace' => ['href' => (string) $request->getUri()->withPath('/api/v1/namespaces/'.$this->getResourceNamespace()->getName())],
            ],
            'kind' => 'Collection',
            'namespace' => $this->namespace->getName(),
            'data' => [
                'schema' => $this->schema->getSchema(),
            ],
       ];

        return AttributeResolver::resolve($request, $this, $resource);
    }

    /**
     * {@inheritdoc}
     */
    public function hasEndpoint(string $name): bool
    {
        return $this->endpoint_factory->has($this, $name);
    }

    /**
     * {@inheritdoc}
     */
    public function getEndpoint(string $name): EndpointInterface
    {
        return $this->endpoint_factory->getOne($this, $name);
    }

    /**
     * {@inheritdoc}
     */
    public function getEndpoints(array $endpoints = [], ?int $offset = null, ?int $limit = null, ?array $sort = null): Generator
    {
        return $this->endpoint_factory->getAll($this, $endpoints, $offset, $limit, $sort);
    }

    /**
     * {@inheritdoc}
     */
    public function getSourceEndpoints(array $endpoints = [], ?int $offset = null, ?int $limit = null): Generator
    {
        $query = ['data.type' => EndpointInterface::TYPE_SOURCE];
        if ($endpoints !== []) {
            $query = ['$and' => [$query, $endpoints]];
        }

        return $this->endpoint_factory->getAll($this, $query, $offset, $limit);
    }

    /**
     * {@inheritdoc}
     */
    public function getDestinationEndpoints(array $endpoints = [], ?int $offset = null, ?int $limit = null): Generator
    {
        $query = ['data.type' => EndpointInterface::TYPE_DESTINATION];
        if ($endpoints !== []) {
            $query = ['$and' => [$query, $endpoints]];
        }

        return $this->endpoint_factory->getAll($this, $query, $offset, $limit);
    }

    /**
     * {@inheritdoc}
     */
    public function getIdentifier(): string
    {
        return $this->namespace->getIdentifier().'::'.$this->name;
    }

    /**
     * {@inheritdoc}
     */
    public function getObjectHistory(ObjectIdInterface $id, ?array $filter = null, ?int $offset = null, ?int $limit = null): Generator
    {
        return $this->object_factory->getObjectHistory($this, $id, $filter, $offset, $limit);
    }

    /**
     * {@inheritdoc}
     */
    public function getObject(array $filter, bool $include_dataset = true, int $version = 0): DataObjectInterface
    {
        return $this->object_factory->getOne($this, $filter, $include_dataset, $version);
    }

    /**
     * {@inheritdoc}
     */
    public function getObjects(array $query = [], bool $include_dataset = true, ?int $offset = null, ?int $limit = null, ?array $sort = null): Generator
    {
        return $this->object_factory->getAll($this, $query, $include_dataset, $offset, $limit, $sort);
    }

    /**
     * {@inheritdoc}
     */
    public function countObjects(array $query = [], bool $include_dataset = true, ?int $offset = null, ?int $limit = null, ?array $sort = null): int

The parameter $include_dataset is not used and could be removed.

The parameter $offset is not used and could be removed.

The parameter $limit is not used and could be removed.

The parameter $sort is not used and could be removed.

    {
        return $this->object_factory->count($this, $query);
    }

    /**
     * {@inheritdoc}
     */
    public function createObject(array $object, bool $simulate = false, ?array $endpoints = null): ObjectIdInterface
    {
        return $this->object_factory->create($this, $object, $simulate, $endpoints);
    }

    /**
     * {@inheritdoc}
     */
    public function changeObject(DataObjectInterface $object, array $data, bool $simulate = false, ?array $endpoints = null): bool
    {
        return $this->object_factory->update($this, $object, $data, $simulate, $endpoints);
    }

    /**
     * {@inheritdoc}
     */
    public function deleteObject(ObjectIdInterface $id, bool $simulate = false): bool
    {
        return $this->object_factory->deleteOne($this, $id, $simulate);
    }

    /**
     * {@inheritdoc}
     */
    public function flush(bool $simulate = false): bool
    {
        return $this->object_factory->deleteAll($this, $simulate);
    }
}