NOSQLBase::getModelTableMap() - Code Metrics - psfs/nosql - Measure and Improve Code Quality continuously with Scrutinizer

NOSQLBase::getModelTableMap() A
last analyzed 2021-02-28 16:53 UTC

↳ Parent: NOSQLBase

Complexity

Conditions	1
Paths	1

Size

Total Lines	3
Code Lines	1

Duplication

Lines	0
Ratio	0 %

Importance

Changes

Metric	Value
eloc	1
dl	0
loc	3
c	0
b	0
f	0
rs	10
cc	1
nc	1
nop	0

<?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);
    }
}

1			<?php
2			namespace NOSQL\Api\base;
3
4			use NOSQL\Dto\Model\ResultsetDto;
5			use NOSQL\Models\NOSQLActiveRecord;
6			use NOSQL\Models\NOSQLQuery;
7			use NOSQL\Services\Base\NOSQLManagerTrait;
8			use PSFS\base\dto\JsonResponse;
9			use PSFS\base\Logger;
10			use PSFS\base\types\CustomApi;
11
12			/**
13			* Class NOSQLBase
14			* @package NOSQL\Api\base
15			* @method NOSQLActiveRecord getModel()
16			* @property NOSQLActiveRecord $model
17			*/
18			abstract class NOSQLBase extends CustomApi {
19			use NOSQLManagerTrait;
20
21			const NOSQL_MODEL_PRIMARY_KEY = '_id';
22			/**
23			* @Injectable
24			* @var \NOSQL\Services\ParserService
25			*/
26			protected $parser;
27			/**
28			* @var \MongoDB\Database
29			*/
30			protected $con;
31
32			public function getModelTableMap()
33			{
34			return null;
35			}
36
37			/**
38			* @param int $status
39			*/
40			public function closeTransaction($status) { }
41
42			/**
43			* @throws \NOSQL\Exceptions\NOSQLValidationException
44			* @throws \ReflectionException
45			*/
46			public function init()
47			{
48			parent::init();
49			$this->con = $this->parser->createConnection($this->getDomain());
50			$this->model = $this->parser->hydrateModelFromRequest($this->data, get_called_class());
51			}
52
53			/**
54			* @return string
55			*/
56			public function getApi()
57			{
58			$class = explode('\\', get_called_class());
59			return $class[count($class)-1];
60			}
61
62			/**
63			* @return string
64			*/
65			public function getDomain()
66			{
67			$class = explode('\\', get_called_class());
68			return $class[0];
69			}
70
71			public function modelList()
72			{
73			$success = true;
74			$code = 200;
75			try {
76			$className = get_called_class();
77			$modelName = $className::MODEL_CLASS;
78			$results = NOSQLQuery::find($modelName, $this->query, $this->con);
79			} catch (\Exception $exception) {
80			$results = new ResultsetDto(false);
81			$success = false;
82			$code = 404;
83			Logger::log($exception->getMessage(), LOG_WARNING, $this->query);
84			}
85			return $this->json(new JsonResponse($results->items, $success, $results->count, ceil($results->count / $results->limit)), $code);
86			}
87
88			public function get($pk)
89			{
90			$success = true;
91			$code = 200;
92			try {
93			$this->feedModel($pk);
94			} catch (\Exception $exception) {
95			$this->model = null;
96			$success = false;
97			$code = 404;
98			Logger::log($exception->getMessage(), LOG_WARNING, [$pk]);
99			}
100			return $this->json(new JsonResponse(null !== $this->model ? $this->getModel()->toArray() : [], $success), $code);
101			}
102
103			public function post()
104			{
105			$success = false;
106			$code = $message = null;
107			try {
108			$success = $this->getModel()->save($this->con);
109			} catch (\Exception $exception) {
110			$success = false;
111			$message = $exception->getMessage();
112			Logger::log($message, LOG_WARNING, $this->getModel()->toArray());
113			} finally {
114			$code = $success && null === $code ? 200 : 400;
115			}
116			return $this->json(new JsonResponse($this->getModel()->toArray(), $success, null, null, $message), $code);
117			}
118
119			public function put($pk)
120			{
121			$code = $message = null;
122			try {
123			$this->feedModel($pk);
124			$this->getModel()->feed($this->getRequest()->getData());
125			$success = $this->getModel()->update($this->con);
126			} catch (\Exception $exception) {
127			$this->model = null;
128			$success = false;
129			$message = $exception->getMessage();
130			Logger::log($message, LOG_WARNING, [$pk]);
131			} finally {
132			$code = $success && null === $code ? 200 : 400;
133			}
134			return $this->json(new JsonResponse(null !== $this->model ? $this->getModel()->toArray() : [], $success, null, null, $message), $code);
135			}
136
137			public function delete($pk = null)
138			{
139			$code = 200;
140			try {
141			$this->feedModel($pk);
142			$success = $this->getModel()->delete($this->con);
143			} catch (\Exception $exception) {
144			$this->model = null;
145			$success = false;
146			$code = 404;
147			Logger::log($exception->getMessage(), LOG_WARNING, [$pk]);
148			}
149			return $this->json(new JsonResponse([], $success), $code);
150			}
151
152			public function bulk()
153			{
154			$code = 200;
155			try {
156			$className = get_called_class();
157			$modelName = $className::MODEL_CLASS;
158			$this->model = new $modelName();
159			$inserts = $this->model->bulkInsert($this->getRequest()->getData());
160			$success = $inserts > 0;
161			} catch (\Exception $exception) {
162			$inserts = 0;
163			$success = false;
164			$code = 404;
165			Logger::log($exception->getMessage(), LOG_WARNING);
166			}
167			return $this->json(new JsonResponse($success, $success, $inserts), $code);
168			}
169
170			/**
171			* @param $pk
172			* @throws \PSFS\base\exception\ApiException
173			*/
174			private function feedModel($pk)
175			{
176			$className = get_called_class();
177			$modelName = $className::MODEL_CLASS;
178			$this->model = NOSQLQuery::findPk($modelName, $pk);
179			}
180			}

psfs / nosql

NOSQLBase::getModelTableMap() A last analyzed 2021-02-28 16:53 UTC

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like

NOSQLBase::getModelTableMap() A
last analyzed 2021-02-28 16:53 UTC