fix: error shallowing

Author: Moumouls

src/Adapters/Storage/Postgres/PostgresStorageAdapter.js

@@ -627,13 +627,11 @@ const buildWhereClause = ({ schema, query, index, caseInsensitive }): WhereClaus
       const distance = fieldValue.$maxDistance;
       const distanceInKM = distance * 6371 * 1000;
       patterns.push(
-        `ST_DistanceSphere($${index}:name::geometry, POINT($${index + 1}, $${
-          index + 2
+        `ST_DistanceSphere($${index}:name::geometry, POINT($${index + 1}, $${index + 2
         })::geometry) <= $${index + 3}`
       );
       sorts.push(
-        `ST_DistanceSphere($${index}:name::geometry, POINT($${index + 1}, $${
-          index + 2
+        `ST_DistanceSphere($${index}:name::geometry, POINT($${index + 1}, $${index + 2
         })::geometry) ASC`
       );
       values.push(fieldName, point.longitude, point.latitude, distanceInKM);
@@ -681,8 +679,7 @@ const buildWhereClause = ({ schema, query, index, caseInsensitive }): WhereClaus
       }
       const distanceInKM = distance * 6371 * 1000;
       patterns.push(
-        `ST_DistanceSphere($${index}:name::geometry, POINT($${index + 1}, $${
-          index + 2
+        `ST_DistanceSphere($${index}:name::geometry, POINT($${index + 1}, $${index + 2
         })::geometry) <= $${index + 3}`
       );
       values.push(fieldName, point.longitude, point.latitude, distanceInKM);
@@ -877,7 +874,7 @@ export class PostgresStorageAdapter implements StorageAdapter {
 
     const { client, pgp } = createClient(uri, options);
     this._client = client;
-    this._onchange = () => {};
+    this._onchange = () => { };
     this._pgp = pgp;
     this._uuid = uuidv4();
     this.canSortOnJoinTables = false;
@@ -1018,7 +1015,13 @@ export class PostgresStorageAdapter implements StorageAdapter {
         }
       } catch (e) {
         const columnDoesNotExistError = e.errors && e.errors[0] && e.errors[0].code === '42703';
-        if (columnDoesNotExistError && !this.disableIndexFieldValidation) {
+        // Specific case when the column does not exist
+        if (columnDoesNotExistError) {
+          // If the disableIndexFieldValidation is true, we should ignore the error
+          if (!this.disableIndexFieldValidation) {
+            throw e;
+          }
+        } else {
           throw e;
         }
       }
@@ -1638,16 +1641,14 @@ export class PostgresStorageAdapter implements StorageAdapter {
         index += 2;
       } else if (fieldValue.__op === 'Remove') {
         updatePatterns.push(
-          `$${index}:name = array_remove(COALESCE($${index}:name, '[]'::jsonb), $${
-            index + 1
+          `$${index}:name = array_remove(COALESCE($${index}:name, '[]'::jsonb), $${index + 1
           }::jsonb)`
         );
         values.push(fieldName, JSON.stringify(fieldValue.objects));
         index += 2;
       } else if (fieldValue.__op === 'AddUnique') {
         updatePatterns.push(
-          `$${index}:name = array_add_unique(COALESCE($${index}:name, '[]'::jsonb), $${
-            index + 1
+          `$${index}:name = array_add_unique(COALESCE($${index}:name, '[]'::jsonb), $${index + 1
           }::jsonb)`
         );
         values.push(fieldName, JSON.stringify(fieldValue.objects));
@@ -1758,8 +1759,7 @@ export class PostgresStorageAdapter implements StorageAdapter {
           updateObject = `COALESCE($${index}:name, '{}'::jsonb)`;
         }
         updatePatterns.push(
-          `$${index}:name = (${updateObject} ${deletePatterns} ${incrementPatterns} || $${
-            index + 1 + keysToDelete.length
+          `$${index}:name = (${updateObject} ${deletePatterns} ${incrementPatterns} || $${index + 1 + keysToDelete.length
           }::jsonb )`
         );
         values.push(fieldName, ...keysToDelete, JSON.stringify(fieldValue));
@@ -2198,8 +2198,7 @@ export class PostgresStorageAdapter implements StorageAdapter {
                     groupByFields.push(`"${source}"`);
                   }
                   columns.push(
-                    `EXTRACT(${
-                      mongoAggregateToPostgres[operation]
+                    `EXTRACT(${mongoAggregateToPostgres[operation]
                     } FROM $${index}:name AT TIME ZONE 'UTC')::integer AS $${index + 1}:name`
                   );
                   values.push(source, alias);