linter

Author: shimonewman

src/Database/Adapter/Mongo.php

@@ -11,7 +11,6 @@
 use Utopia\Database\DateTime;
 use Utopia\Database\Document;
 use Utopia\Database\Exception as DatabaseException;
-use Utopia\Database\Exception\Duplicate as DuplicateException;
 use Utopia\Database\Exception\Duplicate;
 use Utopia\Database\Exception\Timeout;
 use Utopia\Database\Query;
@@ -727,7 +726,7 @@ public function getDocument(string $collection, string $id, array $queries = [],
         }
 
         $result = $this->client->find($name, $filters, $options)->cursor->firstBatch;
-   
+
         if (empty($result)) {
             return new Document([]);
         }
@@ -857,7 +856,7 @@ private function insertDocument(string $name, array $document): array
                 $filters,
                 ['limit' => 1]
             )->cursor->firstBatch[0];
-    
+
             return $this->client->toArray($result);
         } catch (MongoException $e) {
             throw new Duplicate($e->getMessage());
@@ -953,7 +952,7 @@ public function createOrUpdateDocuments(string $collection, string $attribute, a
         if (empty($changes)) {
             return $changes;
         }
-       
+
         try {
             $name = $this->getNamespace() . '_' . $this->filter($collection);
             $attribute = $this->filter($attribute);
@@ -970,7 +969,7 @@ public function createOrUpdateDocuments(string $collection, string $attribute, a
                 $attributes['_createdAt'] = $document->getCreatedAt();
                 $attributes['_updatedAt'] = $document->getUpdatedAt();
                 $attributes['_permissions'] = $document->getPermissions();
-          
+
                 if (!empty($document->getSequence())) {
                     $attributes['_id'] = new ObjectId($document->getSequence());
                 } else {
@@ -985,7 +984,7 @@ public function createOrUpdateDocuments(string $collection, string $attribute, a
                 $record = $this->replaceChars('$', '_', $attributes);
                 $record = $this->timeToMongo($record);
                 $record = $this->removeNullKeys($record);
-               
+
 
                 // Build filter for upsert
                 $filter = ['_uid' => $document->getId()];
@@ -1009,19 +1008,19 @@ public function createOrUpdateDocuments(string $collection, string $attribute, a
                     'filter' => $filter,
                     'update' => $update,
                 ];
-            }   
-            
+            }
+
             // Use the new bulkUpsert method
             $this->client->bulkUpsert(
                 $name,
                 $operations,
-                ["ordered" => false] // TODO Do we want to continue if an error is thrown? 
+                ["ordered" => false] // TODO Do we want to continue if an error is thrown?
             );
 
             // Get sequences for documents that were created
             if (!empty($documentIds)) {
                 $sequences = $this->getSequences($collection, $documentIds, $documentTenants);
-                
+
                 foreach ($changes as $change) {
                     if (isset($sequences[$change->getNew()->getId()])) {
                         $change->getNew()->setAttribute('$sequence', $sequences[$change->getNew()->getId()]);
@@ -1032,7 +1031,7 @@ public function createOrUpdateDocuments(string $collection, string $attribute, a
         } catch (MongoException $e) {
             throw $this->processException($e);
         }
-      
+
         return \array_map(fn ($change) => $change->getNew(), $changes);
     }
 
@@ -1061,7 +1060,7 @@ protected function getSequences(string $collection, array $documentIds, array $d
 
             try {
                 $results = $this->client->find($name, $filters, ['projection' => ['_uid' => 1, '_id' => 1]]);
-                
+
                 foreach ($results->cursor->firstBatch as $result) {
                     $sequences[$result->_uid] = (string)$result->_id;
                 }
@@ -1249,7 +1248,7 @@ public function find(string $collection, array $queries = [], ?int $limit = 25,
         if ($this->sharedTables) {
             $filters['_tenant'] = $this->getTenant();
         }
-     
+
         // permissions
         if (Authorization::$status) {
             $roles = \implode('|', Authorization::getRoles());
@@ -1306,7 +1305,7 @@ public function find(string $collection, array $queries = [], ?int $limit = 25,
                     $prevAttr = $this->filter($this->getInternalKeyForAttribute($originalPrev));
 
                     $tmp = $cursor[$originalPrev];
-                    if($originalPrev === '$sequence'){
+                    if ($originalPrev === '$sequence') {
                         $tmp = new ObjectId($tmp);
                     }
 
@@ -1317,11 +1316,11 @@ public function find(string $collection, array $queries = [], ?int $limit = 25,
 
                 $tmp = $cursor[$originalAttribute];
 
-                if($originalAttribute === '$sequence'){
+                if ($originalAttribute === '$sequence') {
                     $tmp = new ObjectId($tmp);
 
                     /** If there is only $sequence attribute in $orderAttributes skip Or And  operators **/
-                    if(count($orderAttributes) === 1){
+                    if (count($orderAttributes) === 1) {
                         $filters[$attribute] = [
                             $operator => $tmp
                         ];
@@ -1356,16 +1355,16 @@ public function find(string $collection, array $queries = [], ?int $limit = 25,
         } catch (MongoException $e) {
             throw $this->processException($e);
         }
-       
+
 
         if (empty($results)) {
             return $found;
         }
-        
+
 
         foreach ($this->client->toArray($results) as $result) {
             $record = $this->replaceChars('_', '$', (array)$result);
-        
+
             $record = $this->timeToDocument($record);
 
             $found[] = new Document($record);