NOSQL\Api\base\NOSQLBase

Complexity

Total Complexity

24

Size/Duplication

Total Lines	161
Duplicated Lines	0 %

Importance

Changes	1
Bugs	0	Features	0

12 Methods

Rating	Name	Duplication	Size	Complexity
A	bulk()	0	16	2
A	getModelTableMap()	0	3	1
A	getDomain()	0	4	1
A	init()	0	5	1
A	closeTransaction()	0	1	1
A	post()	0	14	4
A	put()	0	16	5
A	get()	0	13	3
A	feedModel()	0	5	1
A	getApi()	0	4	1
A	delete()	0	13	2
A	modelList()	0	15	2

<?php
namespace NOSQL\Api\base;

use NOSQL\Dto\Model\ResultsetDto;
use NOSQL\Models\NOSQLActiveRecord;
use NOSQL\Models\NOSQLQuery;
use NOSQL\Services\Base\NOSQLManagerTrait;
use PSFS\base\dto\JsonResponse;
use PSFS\base\Logger;
use PSFS\base\types\CustomApi;

/**
 * Class NOSQLBase
 * @package NOSQL\Api\base
 * @method NOSQLActiveRecord getModel()
 * @property NOSQLActiveRecord $model
 */
abstract class NOSQLBase extends CustomApi {
    use NOSQLManagerTrait;

    const NOSQL_MODEL_PRIMARY_KEY = '_id';
    /**
     * @Injectable
     * @var \NOSQL\Services\ParserService
     */
    protected $parser;
    /**
     * @var \MongoDB\Database
     */
    protected $con;

    public function getModelTableMap()
    {
        return null;
    }

    /**
     * @param int $status
     */
    public function closeTransaction($status) { }

    /**
     * @throws \NOSQL\Exceptions\NOSQLValidationException
     * @throws \ReflectionException
     */
    public function init()
    {
        parent::init();
        $this->con = $this->parser->createConnection($this->getDomain());
        $this->model = $this->parser->hydrateModelFromRequest($this->data, get_called_class());
    }

    /**
     * @return string
     */
    public function getApi()
    {
        $class = explode('\\', get_called_class());
        return $class[count($class)-1];
    }

    /**
     * @return string
     */
    public function getDomain()
    {
        $class = explode('\\', get_called_class());
        return $class[0];
    }

    public function modelList()
    {
        $success = true;
        $code = 200;
        try {
            $className = get_called_class();
            $modelName = $className::MODEL_CLASS;
            $results = NOSQLQuery::find($modelName, $this->query, $this->con);
        } catch (\Exception $exception) {
            $results = new ResultsetDto(false);
            $success = false;
            $code = 404;
            Logger::log($exception->getMessage(), LOG_WARNING, $this->query);
        }
        return $this->json(new JsonResponse($results->items, $success, $results->count, ceil($results->count / $results->limit)), $code);
    }

    public function get($pk)
    {
        $success = true;
        $code = 200;
        try {
            $this->feedModel($pk);
        } catch (\Exception $exception) {
            $this->model = null;
            $success = false;
            $code = 404;
            Logger::log($exception->getMessage(), LOG_WARNING, [$pk]);
        }
        return $this->json(new JsonResponse(null !== $this->model ? $this->getModel()->toArray() : [], $success), $code);
    }

    public function post()
    {
        $success = false;
        $code = $message = null;
        try {
            $success = $this->getModel()->save($this->con);
        } catch (\Exception $exception) {
            $success = false;
            $message = $exception->getMessage();
            Logger::log($message, LOG_WARNING, $this->getModel()->toArray());
        } finally {
            $code = $success && null === $code ? 200 : 400;
        }
        return $this->json(new JsonResponse($this->getModel()->toArray(), $success, null, null, $message), $code);
    }

    public function put($pk)
    {
        $code = $message = null;
        try {
            $this->feedModel($pk);
            $this->getModel()->feed($this->getRequest()->getData());
            $success = $this->getModel()->update($this->con);
        } catch (\Exception $exception) {
            $this->model = null;
            $success = false;
            $message = $exception->getMessage();
            Logger::log($message, LOG_WARNING, [$pk]);
        } finally {
            $code = $success && null === $code ? 200 : 400;
        }
        return $this->json(new JsonResponse(null !== $this->model ? $this->getModel()->toArray() : [], $success, null, null, $message), $code);
    }

    public function delete($pk = null)
    {
        $code = 200;
        try {
            $this->feedModel($pk);
            $success = $this->getModel()->delete($this->con);
        } catch (\Exception $exception) {
            $this->model = null;
            $success = false;
            $code = 404;
            Logger::log($exception->getMessage(), LOG_WARNING, [$pk]);
        }
        return $this->json(new JsonResponse([], $success), $code);
    }

    public function bulk()
    {
        $code = 200;
        try {
            $className = get_called_class();
            $modelName = $className::MODEL_CLASS;
            $this->model = new $modelName();
            $inserts = $this->model->bulkInsert($this->getRequest()->getData());
            $success = $inserts > 0;
        } catch (\Exception $exception) {
            $inserts = 0;
            $success = false;
            $code = 404;
            Logger::log($exception->getMessage(), LOG_WARNING);
        }
        return $this->json(new JsonResponse($success, $success, $inserts), $code);
    }

    /**
     * @param $pk
     * @throws \PSFS\base\exception\ApiException
     */
    private function feedModel($pk)
    {
        $className = get_called_class();
        $modelName = $className::MODEL_CLASS;
        $this->model = NOSQLQuery::findPk($modelName, $pk);
    }
}