NOSQL\Models\base\NOSQLParserTrait

Complexity

Total Complexity

13

Size/Duplication

Total Lines	90
Duplicated Lines	0 %

Importance

Changes	2
Bugs	0	Features	0

8 Methods

Rating	Name	Duplication	Size	Complexity
A	getDomain()	0	3	1
A	addIndex()	0	2	1
A	getSchema()	0	3	1
A	setSchema()	0	3	1
A	hydrate()	0	19	5
A	addProperty()	0	2	1
A	initConnection()	0	6	2
A	setDomain()	0	3	1

<?php
namespace NOSQL\Models\base;

use MongoDB\Database;
use NOSQL\Dto\CollectionDto;
use NOSQL\Dto\IndexDto;
use NOSQL\Dto\PropertyDto;
use NOSQL\Exceptions\NOSQLParserException;
use NOSQL\Models\NOSQLActiveRecord;
use NOSQL\Services\NOSQLService;
use NOSQL\Services\ParserService;
use PSFS\base\Cache;
use PSFS\base\types\helpers\GeneratorHelper;

/**
 * Trait NOSQLParserTrait
 * @package NOSQL\Models\base
 */
trait NOSQLParserTrait {
    protected $domain;
    /**
     * @var CollectionDto
     */
    protected $schema;

    /**
     * @return mixed
     */
    public function getDomain()
    {
        return $this->domain;
    }

    /**
     * @param mixed $domain
     */
    public function setDomain($domain)
    {
        $this->domain = $domain;
    }

    /**
     * @return CollectionDto
     */
    public function getSchema()
    {
        return $this->schema;
    }

    /**
     * @param CollectionDto $schema
     */
    public function setSchema(CollectionDto $schema)
    {
        $this->schema = $schema;
    }

    /**
     * @param PropertyDto $property
     */
    public function addProperty(PropertyDto $property) {
        $this->schema->properties[] = $property;
    }

    /**
     * @param IndexDto $index
     */
    public function addIndex(IndexDto $index) {
        $this->schema->indexes[] = $index;
    }

    /**
     * @throws NOSQLParserException
     * @throws \PSFS\base\exception\GeneratorException
     */
    protected function hydrate() {
        if(empty($this->domain)) {
            throw new NOSQLParserException(t('Domain not defined'), NOSQLParserException::NOSQL_PARSER_DOMAIN_NOT_DEFINED);

NOSQL\Exceptions\NOSQLParserException::NOSQL_PARSER_DOMAIN_NOT_DEFINED of type string is incompatible with the type integer expected by parameter $code of NOSQL\Exceptions\NOSQLParserException::__construct().

        }
        $paths = NOSQLService::getDomainPaths($this->domain);
        $schemaFilename = $paths['base'] . 'Config' . DIRECTORY_SEPARATOR . 'schema.json';
        if(file_exists($schemaFilename)) {
            $schema = Cache::getInstance()->getDataFromFile($schemaFilename, Cache::JSON, true);
            $class = get_called_class();
            $this->schema = new CollectionDto(false);
            foreach($schema as $collection) {
                $collectionName = $collection['name'];
                if(false !== strpos($class, $collectionName)) {
                    $this->schema->fromArray($collection);
                    break;
                }
            }
        } else {
            throw  new NOSQLParserException(t('Schema file not exists'), NOSQLParserException::NOSQL_PARSER_SCHEMA_NOT_DEFINED);
        }
    }

    /**
     * @param Database $con
     * @param NOSQLActiveRecord $model
     * @return Database
     */
    public static function initConnection(NOSQLActiveRecord $model, Database $con = null)
    {
        if (null === $con) {
            $con = ParserService::getInstance()->createConnection($model->getDomain());
        }
        return $con;
    }

}