HELLODATA-1895 - fix

kanton-bern · Dec 2, 2024 · c6dab1c · c6dab1c
1 parent df8a45a
commit c6dab1c
Show file tree

Hide file tree

Showing 2 changed files with 14 additions and 21 deletions.
diff --git a/...hellodata/commons/sidecars/resources/v1/user/request/SupersetDashboardsForUserUpdate.java b/...hellodata/commons/sidecars/resources/v1/user/request/SupersetDashboardsForUserUpdate.java
@@ -35,7 +35,6 @@
 @JsonIgnoreProperties(ignoreUnknown = true)
 public class SupersetDashboardsForUserUpdate {
     List<DashboardForUserDto> dashboards;
-    private int supersetUserId;
     private String supersetUserName;
     private String supersetUserEmail;
     private String supersetFirstName;

diff --git a/...data-portal-api/src/main/java/ch/bedag/dap/hellodata/portal/user/service/UserService.java b/...data-portal-api/src/main/java/ch/bedag/dap/hellodata/portal/user/service/UserService.java
@@ -593,27 +593,21 @@ private void updateDashboardRoleForUser(UUID userId, List<DashboardForUserDto> d
         try {
             SupersetDashboardsForUserUpdate supersetDashboardsForUserUpdate = new SupersetDashboardsForUserUpdate();
             UserEntity userEntity = getUserEntity(userId);
-            SubsystemUser userInInstance = metaInfoResourceService.findUserInInstance(userEntity.getEmail(), supersetInstanceName);
-            if (userInInstance != null) {
-                supersetDashboardsForUserUpdate.setSupersetUserId(userInInstance.getId());
-                supersetDashboardsForUserUpdate.setSupersetUserName(userInInstance.getUsername());
-                supersetDashboardsForUserUpdate.setSupersetUserEmail(userInInstance.getEmail());
-                supersetDashboardsForUserUpdate.setDashboards(dashboardForUserDtoList);
-                supersetDashboardsForUserUpdate.setSupersetFirstName(userInInstance.getFirstName());
-                supersetDashboardsForUserUpdate.setSupersetLastName(userInInstance.getLastName());
-                supersetDashboardsForUserUpdate.setActive(userInInstance.isActive());
-                String subject = SlugifyUtil.slugify(supersetInstanceName + RequestReplySubject.UPDATE_DASHBOARD_ROLES_FOR_USER.getSubject());
-                log.info("[updateDashboardRoleForUser] Sending request to subject: {}", subject);
-                Message reply =
-                        connection.request(subject, objectMapper.writeValueAsString(supersetDashboardsForUserUpdate).getBytes(StandardCharsets.UTF_8), Duration.ofSeconds(10));
-                if (reply == null) {
-                    log.warn("Reply is null, please verify superset sidecar or nats connection");
-                } else {
-                    reply.ack();
-                    log.info("[updateDashboardRoleForUser] Response received: " + new String(reply.getData()));
-                }
+            supersetDashboardsForUserUpdate.setSupersetUserName(userEntity.getUsername());
+            supersetDashboardsForUserUpdate.setSupersetUserEmail(userEntity.getEmail());
+            supersetDashboardsForUserUpdate.setDashboards(dashboardForUserDtoList);
+            supersetDashboardsForUserUpdate.setSupersetFirstName(userEntity.getFirstName());
+            supersetDashboardsForUserUpdate.setSupersetLastName(userEntity.getLastName());
+            supersetDashboardsForUserUpdate.setActive(userEntity.isEnabled());
+            String subject = SlugifyUtil.slugify(supersetInstanceName + RequestReplySubject.UPDATE_DASHBOARD_ROLES_FOR_USER.getSubject());
+            log.info("[updateDashboardRoleForUser] Sending request to subject: {}", subject);
+            Message reply =
+                    connection.request(subject, objectMapper.writeValueAsString(supersetDashboardsForUserUpdate).getBytes(StandardCharsets.UTF_8), Duration.ofSeconds(10));
+            if (reply == null) {
+                log.warn("Reply is null, please verify superset sidecar or nats connection");
             } else {
-                log.error("User {} not found in superset instance {}!", userEntity.getEmail(), supersetInstanceName);
+                reply.ack();
+                log.info("[updateDashboardRoleForUser] Response received: " + new String(reply.getData()));
             }
         } catch (Exception e) {
             log.error("Error updating dashboard role for user", e);