Merge pull request #1364 from DalgoT4D/feature/airbyte-upgrade-1.1.0

airbyte upgrade 1.1.0
DalgoT4D · Jan 11, 2025 · 56eb3c2 · 56eb3c2
2 parents 19fa936 + f4d9db8
commit 56eb3c2
Show file tree

Hide file tree

Showing 2 changed files with 48 additions and 41 deletions.
diff --git a/src/components/Connections/SchemaChangeDetailsForm.tsx b/src/components/Connections/SchemaChangeDetailsForm.tsx
@@ -120,24 +120,27 @@ const SchemaChangeDetailsForm = ({
               } else if (transform.transformType === 'add_stream') {
                 changedColumns.push(`+Stream: ${tableName}`);
               } else {
-                changedColumns = transform.updateStream.reduce((columns: string[], update: any) => {
-                  if (
-                    update.transformType === 'add_field' ||
-                    update.transformType === 'remove_field' ||
-                    update.transformType === 'update_field_schema'
-                  ) {
-                    if (update.transformType === 'update_field_schema') {
-                      columns.push(`+${update.fieldName.join(', ')}`);
-                    } else {
-                      columns.push(
-                        `${
-                          update.transformType === 'add_field' ? '+' : '-'
-                        }${update.fieldName.join(', ')}`
-                      );
+                changedColumns = transform.updateStream.fieldTransforms.reduce(
+                  (columns: string[], update: any) => {
+                    if (
+                      update.transformType === 'add_field' ||
+                      update.transformType === 'remove_field' ||
+                      update.transformType === 'update_field_schema'
+                    ) {
+                      if (update.transformType === 'update_field_schema') {
+                        columns.push(`+${update.fieldName.join(', ')}`);
+                      } else {
+                        columns.push(
+                          `${
+                            update.transformType === 'add_field' ? '+' : '-'
+                          }${update.fieldName.join(', ')}`
+                        );
+                      }
                     }
-                  }
-                  return columns;
-                }, []);
+                    return columns;
+                  },
+                  []
+                );
               }
 
               return { name: tableName, changedColumns };

diff --git a/src/components/Connections/__tests__/SchemaChangeDetailsForm.test.tsx b/src/components/Connections/__tests__/SchemaChangeDetailsForm.test.tsx
@@ -78,18 +78,20 @@ const nonBreakingData = {
               streamDescriptor: {
                 name: 'worldometer_data',
               },
-              updateStream: [
-                {
-                  transformType: 'add_field',
-                  fieldName: ['Second new column'],
-                  breaking: false,
-                },
-                {
-                  transformType: 'add_field',
-                  fieldName: ['New column of nulls'],
-                  breaking: false,
-                },
-              ],
+              updateStream: {
+                fieldTransforms: [
+                  {
+                    transformType: 'add_field',
+                    fieldName: ['Second new column'],
+                    breaking: false,
+                  },
+                  {
+                    transformType: 'add_field',
+                    fieldName: ['New column of nulls'],
+                    breaking: false,
+                  },
+                ],
+              },
             },
           ],
         },
@@ -347,18 +349,20 @@ describe('SchemaChangeDetailsForm', () => {
                   streamDescriptor: {
                     name: 'worldometer_data',
                   },
-                  updateStream: [
-                    {
-                      transformType: 'add_field',
-                      fieldName: ['Second new column'],
-                      breaking: false,
-                    },
-                    {
-                      transformType: 'add_field',
-                      fieldName: ['New column of nulls'],
-                      breaking: false,
-                    },
-                  ],
+                  updateStream: {
+                    fieldTransforms: [
+                      {
+                        transformType: 'add_field',
+                        fieldName: ['Second new column'],
+                        breaking: false,
+                      },
+                      {
+                        transformType: 'add_field',
+                        fieldName: ['New column of nulls'],
+                        breaking: false,
+                      },
+                    ],
+                  },
                 },
               ],
             },