Tubee\ResourceNamespace\Factory

Complexity

Total Complexity

11

Size/Duplication

Total Lines	110
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	5

Test Coverage

Coverage

78.79%

Importance

Changes

0

9 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	5	1
A	has()	0	4	1
A	getAll()	0	4	1
A	getOne()	0	14	2
A	update()	0	8	1
A	deleteOne()	0	6	1
A	add()	0	11	2
A	watch()	0	4	1
A	build()	0	4	1

<?php

declare(strict_types=1);

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

namespace Tubee\ResourceNamespace;

use Generator;
use MongoDB\BSON\ObjectIdInterface;
use MongoDB\Database;
use Psr\Log\LoggerInterface;
use Tubee\Collection\Factory as CollectionFactory;
use Tubee\Resource\Factory as ResourceFactory;
use Tubee\ResourceNamespace;

class Factory extends ResourceFactory
{
    /**
     * Collection name.
     */
    public const COLLECTION_NAME = 'namespaces';

    /**
     * Datatype.
     *
     * @var CollectionFactory
     */
    protected $collection_factory;

    /**
     * Initialize.
     */
    public function __construct(Database $db, CollectionFactory $collection_factory, LoggerInterface $logger)
    {
        $this->collection_factory = $collection_factory;
        parent::__construct($db, $logger);
    }

    /**
     * Has namespace.
     */
    public function has(string $name): bool
    {
        return $this->db->{self::COLLECTION_NAME}->count(['name' => $name]) > 0;
    }

    /**
     * Get all.
     */
    public function getAll(?array $query = null, ?int $offset = null, ?int $limit = null, ?array $sort = null): Generator
    {
        return $this->getAllFrom($this->db->{self::COLLECTION_NAME}, $query, $offset, $limit, $sort);
    }

    /**
     * Get namespace.
     */
    public function getOne(string $name): ResourceNamespaceInterface
    {
        $result = $this->db->{self::COLLECTION_NAME}->findOne([
            'name' => $name,
        ], [
            'projection' => ['history' => 0],
        ]);

        if ($result === null) {
            throw new Exception\NotFound('namespace '.$name.' is not registered');
        }

        return $this->build($result);
    }

    /**
     * Update.
     */
    public function update(ResourceNamespaceInterface $resource, array $data): bool
    {
        $data['name'] = $resource->getName();
        $data['kind'] = $resource->getKind();
        $data = $this->validate($data);

        return $this->updateIn($this->db->{self::COLLECTION_NAME}, $resource, $data);
    }

    /**
     * Delete by name.
     */
    public function deleteOne(string $name): bool
    {
        $resource = $this->getOne($name);

        return $this->deleteFrom($this->db->{self::COLLECTION_NAME}, $resource->getId());
    }

    /**
     * Add namespace.
     */
    public function add(array $resource): ObjectIdInterface
    {
        $resource['kind'] = 'Namespace';
        $resource = $this->validate($resource);

        if ($this->has($resource['name'])) {
            throw new Exception\NotUnique('namespace '.$resource['name'].' does already exists');
        }

        return $this->addTo($this->db->{self::COLLECTION_NAME}, $resource);
    }

    /**
     * Change stream.
     */
    public function watch(?ObjectIdInterface $after = null, bool $existing = true, ?array $query = null, ?int $offset = null, ?int $limit = null, ?array $sort = null): Generator
    {
        return $this->watchFrom($this->db->{self::COLLECTION_NAME}, $after, $existing, $query, null, $offset, $limit, $sort);
    }

    /**
     * Build instance.
     */
    public function build(array $resource): ResourceNamespaceInterface
    {
        return $this->initResource(new ResourceNamespace($resource['name'], $this, $this->collection_factory, $resource));
    }
}