fix(database): adding/removing object(group) fields not working

modules/database/src/adapters/utils/validateFieldChanges.ts

@@ -17,27 +17,39 @@
 function validateSchemaFields(oldSchemaFields: Indexable, newSchemaFields: Indexable) {
   const tempObj: Fields = {};
 
   Object.keys(oldSchemaFields).forEach(key => {
     if (
       !oldSchemaFields[key].type &&
       !isString(oldSchemaFields[key]) &&
       !isArray(oldSchemaFields[key])
     ) {
       tempObj[key] = validateSchemaFields(oldSchemaFields[key], newSchemaFields[key]);
     } else {
       const oldType = oldSchemaFields[key].type ?? oldSchemaFields[key];
       if (isNil(newSchemaFields)) return;
       const newType = newSchemaFields[key]?.type ?? null;
       if (!newType) return;
       if (oldType === DataTypes.JSONB && newType === 'JSON') return;
       if (isArray(oldType) && isArray(newType)) {
-        if (JSON.stringify(oldType[0]) !== JSON.stringify(newType[0]))
+        if (typeof oldType[0] === 'object') {
+          validateObject(oldType[0], newType[0]);
+        } else if (JSON.stringify(oldType[0]) !== JSON.stringify(newType[0]))
           throw ConduitError.forbidden('Invalid schema types');
+      } else if (typeof oldType === 'object') {
+        validateObject(oldType, newType);
       } else if (!isEqual(oldType, newType)) {
         // TODO: Support schema field type migration
         throw ConduitError.forbidden('Invalid schema types');
       }
     }
   });
   return newSchemaFields;
 }
+
+function validateObject(oldType: any, newType: any) {
+  if (!oldType.hasOwnProperty('type') && !newType.hasOwnProperty('type')) {
+    validateSchemaFields(oldType, newType);
+  }
+  if (JSON.stringify(oldType[0]) !== JSON.stringify(newType[0]))
+    throw ConduitError.forbidden('Invalid schema types');
+}