Save changes to notifySchemaChangesByEmail field when patching a sync…

… (#5918)
airbytehq · Apr 27, 2023 · b24a549 · b24a549
1 parent e7371ab
commit b24a549
Showing 1 changed file with 9 additions and 5 deletions.
diff --git a/...e-commons-server/src/main/java/io/airbyte/commons/server/handlers/ConnectionsHandler.java b/...e-commons-server/src/main/java/io/airbyte/commons/server/handlers/ConnectionsHandler.java
@@ -384,6 +384,10 @@ private static void applyPatchToStandardSync(final StandardSync sync, final Conn
       sync.setNotifySchemaChanges(patch.getNotifySchemaChanges());
     }
 
+    if (patch.getNotifySchemaChangesByEmail() != null) {
+      sync.setNotifySchemaChangesByEmail(patch.getNotifySchemaChangesByEmail());
+    }
+
     if (patch.getNonBreakingChangesPreference() != null) {
       sync.setNonBreakingChangesPreference(ApiPojoConverters.toPersistenceNonBreakingChangesPreference(patch.getNonBreakingChangesPreference()));
     }
@@ -624,21 +628,21 @@ private static String getFrequencyStringFromScheduleType(final ScheduleType sche
     }
   }
 
-  public ConnectionReadList listConnectionsForWorkspaces(ListConnectionsForWorkspacesRequestBody listConnectionsForWorkspacesRequestBody)
+  public ConnectionReadList listConnectionsForWorkspaces(final ListConnectionsForWorkspacesRequestBody listConnectionsForWorkspacesRequestBody)
       throws IOException {
 
     final List<ConnectionRead> connectionReads = Lists.newArrayList();
 
-    Map<UUID, List<StandardSync>> workspaceIdToStandardSyncsMap = configRepository.listWorkspaceStandardSyncsPaginated(
+    final Map<UUID, List<StandardSync>> workspaceIdToStandardSyncsMap = configRepository.listWorkspaceStandardSyncsPaginated(
         listConnectionsForWorkspacesRequestBody.getWorkspaceIds(),
         listConnectionsForWorkspacesRequestBody.getIncludeDeleted(),
         PaginationHelper.pageSize(listConnectionsForWorkspacesRequestBody.getPagination()),
         PaginationHelper.rowOffset(listConnectionsForWorkspacesRequestBody.getPagination()));
 
     for (final Entry<UUID, List<StandardSync>> entry : workspaceIdToStandardSyncsMap.entrySet()) {
-      UUID workspaceId = entry.getKey();
-      for (StandardSync standardSync : entry.getValue()) {
-        ConnectionRead connectionRead = ApiPojoConverters.internalToConnectionRead(standardSync);
+      final UUID workspaceId = entry.getKey();
+      for (final StandardSync standardSync : entry.getValue()) {
+        final ConnectionRead connectionRead = ApiPojoConverters.internalToConnectionRead(standardSync);
         connectionRead.setWorkspaceId(workspaceId);
         connectionReads.add(connectionRead);
       }