psfs / nosql

src/NOSQL/Services/ParserService.php

Spacing +4 added lines, -4 removed lines

@@ -28,11 +28,11 @@ 
         $dns .= '@' . Config::getParam('nosql.host', 'localhost', $lowerDomain);
 
         $database = Config::getParam('nosql.database', 'nosql', $lowerDomain);
-        if(null !== Config::getParam('nosql.replicaset')) {
+        if (null !== Config::getParam('nosql.replicaset')) {
             $dns .= '/' . $database . '?ssl=true&replicaSet=' . Config::getParam('nosql.replicaset', null, $lowerDomain);
             $dns .= '&authSource=admin&serverSelectionTryOnce=false&serverSelectionTimeoutMS=15000';
         } else {
-            if(strtolower($protocol) !== 'mongodb+srv') {
+            if (strtolower($protocol) !== 'mongodb+srv') {
                 $dns .= ':' . Config::getParam('nosql.port', '27017', $lowerDomain);
             }
             $dns .= '/' . $database . "?authSource=admin";
@@ -52,7 +52,7 @@ 
      */
     public function checkAndSave($domain, $collection, NOSQLModelDto $dto) {
         $errors = $dto->validate();
-        if(empty($errors)) {
+        if (empty($errors)) {
 
         } else {
             throw new ApiException(t('Dto not valid'), 400);
@@ -69,7 +69,7 @@ 
     public function hydrateModelFromRequest(array $data, $className) {
         $model = null;
         $reflectionClass = new \ReflectionClass($className);
-        if($reflectionClass->isSubclassOf(NOSQLBase::class)) {
+        if ($reflectionClass->isSubclassOf(NOSQLBase::class)) {
             /** @var NOSQLActiveRecord $modelName */
             $modelName = $className::MODEL_CLASS;
             $model = $modelName::fromArray($data);

src/NOSQL/Models/NOSQLQuery.php

Spacing +11 added lines, -11 removed lines

@@ -28,7 +28,7 @@ 
         $con = NOSQLParserTrait::initConnection($model, $con);
         $collection = $con->selectCollection($model->getSchema()->name);
         $result = $collection->findOne(['_id' => new ObjectId($pk)]);
-        if(null !== $result) {
+        if (null !== $result) {
             $model->feed($result->getArrayCopy());
         } else {
             throw new ApiException(t('Document not found'), 404);
@@ -55,21 +55,21 @@ 
 
         $resultSet->count = $collection->countDocuments($filters, $nosqlOptions);
 
-        $nosqlOptions["limit"] = (integer)(array_key_exists(Api::API_LIMIT_FIELD, $criteria) ? $criteria[Api::API_LIMIT_FIELD] : Config::getParam('pagination.limit', 50));
-        $page = (integer)(array_key_exists(Api::API_PAGE_FIELD, $criteria) ? $criteria[Api::API_PAGE_FIELD] : 1);
+        $nosqlOptions["limit"] = (integer) (array_key_exists(Api::API_LIMIT_FIELD, $criteria) ? $criteria[Api::API_LIMIT_FIELD] : Config::getParam('pagination.limit', 50));
+        $page = (integer) (array_key_exists(Api::API_PAGE_FIELD, $criteria) ? $criteria[Api::API_PAGE_FIELD] : 1);
         $nosqlOptions["skip"] = ($page === 1) ? 0 : ($page - 1) * $nosqlOptions["limit"];
 
         if ((array_key_exists(Api::API_ORDER_FIELD, $criteria)) && (is_array($criteria[Api::API_ORDER_FIELD]))) {
             $nosqlOptions["sort"] = [];
             foreach ($criteria[Api::API_ORDER_FIELD] as $field => $direction) {
-                $nosqlOptions["sort"][$field] = (abs($direction) === 1)  ? $direction : 1;
+                $nosqlOptions["sort"][$field] = (abs($direction) === 1) ? $direction : 1;
             }
         }
 
         $results = $collection->find($filters, $nosqlOptions);
         /** @var  $result */
         $items = $results->toArray();
-        foreach($items as $item) {
+        foreach ($items as $item) {
             $model->feed($item->getArrayCopy(), true);
             $resultSet->items[] = $model->getDtoCopy(true);
         }
@@ -98,7 +98,7 @@ 
         // Check index collation
         $options = [];
         $indexes = $collection->listIndexes();
-        foreach($indexes as $index) {
+        foreach ($indexes as $index) {
             $indexInfo = $index->__debugInfo();
             if (empty(array_diff(array_keys($index["key"]), array_keys($filters)))) {
                 if (array_key_exists("collation", $indexInfo)) {
@@ -110,7 +110,7 @@ 
         }
 
         if (array_key_exists("collation", $options)) {
-            foreach($filters as $key=>$filter) {
+            foreach ($filters as $key=>$filter) {
                 if (is_string($criteria[$key])) {
                     $filters[$key] = $criteria[$key];
                 }
@@ -129,7 +129,7 @@ 
         $filterValue = $criteria[$property->name];
         $matchOperator = is_array($filterValue) ? $filterValue[0] : self::NOSQL_EQUAL_OPERATOR;
         if (is_array($filterValue)) {
-            if(in_array($matchOperator, [
+            if (in_array($matchOperator, [
                 self::NOSQL_NOT_NULL_OPERATOR,
                 self::NOSQL_IN_OPERATOR,
             ], true)) {
@@ -144,7 +144,7 @@ 
                     self::NOSQL_IN_OPERATOR => $filterValue,
                 ];
             }
-        } elseif(in_array($filterValue, [
+        } elseif (in_array($filterValue, [
             self::NOSQL_NOT_NULL_OPERATOR,
         ], true)) {
             $filterValue = [
@@ -168,9 +168,9 @@ 
                         break;
                 }
             } elseif (NOSQLBase::NOSQL_TYPE_INTEGER === $property->type) {
-                $filterValue = (integer)$filterValue;
+                $filterValue = (integer) $filterValue;
             } else {
-                $filterValue = (float)$filterValue;
+                $filterValue = (float) $filterValue;
             }
             $filterValue = [
                 self::NOSQL_EQUAL_OPERATOR => $filterValue,