diff --git a/openmetadata-integration-tests/src/test/java/org/openmetadata/it/tests/DataProductResourceIT.java b/openmetadata-integration-tests/src/test/java/org/openmetadata/it/tests/DataProductResourceIT.java index 9a02a44c3634..ada5d778ad07 100644 --- a/openmetadata-integration-tests/src/test/java/org/openmetadata/it/tests/DataProductResourceIT.java +++ b/openmetadata-integration-tests/src/test/java/org/openmetadata/it/tests/DataProductResourceIT.java @@ -58,10 +58,12 @@ import org.openmetadata.schema.utils.JsonUtils; import org.openmetadata.schema.utils.ResultList; import org.openmetadata.sdk.client.OpenMetadataClient; +import org.openmetadata.sdk.exceptions.ApiException; import org.openmetadata.sdk.exceptions.InvalidRequestException; import org.openmetadata.sdk.models.ListParams; import org.openmetadata.sdk.models.ListResponse; import org.openmetadata.sdk.network.HttpMethod; +import org.openmetadata.sdk.network.RequestOptions; /** * Integration tests for DataProduct entity operations. @@ -214,6 +216,110 @@ protected DataProduct getVersion(UUID id, Double version) { // DATA PRODUCT-SPECIFIC TESTS // =================================================================== + @Test + void put_addFollowerForAnotherUser_403(TestNamespace ns) { + DataProduct dataProduct = createEntity(createMinimalRequest(ns)); + + ApiException exception = + assertThrows( + ApiException.class, + () -> addFollower(SdkClients.user2Client(), dataProduct.getId(), testUser3().getId())); + + assertEquals(403, exception.getStatusCode()); + assertFalse(hasFollower(dataProduct.getId(), testUser3().getId())); + } + + @Test + void delete_followerForSelf_200(TestNamespace ns) { + DataProduct dataProduct = createEntity(createMinimalRequest(ns)); + OpenMetadataClient client = SdkClients.user2Client(); + UUID userId = testUser2().getId(); + + addFollower(client, dataProduct.getId(), userId); + assertTrue(hasFollower(dataProduct.getId(), userId)); + + deleteFollower(client, dataProduct.getId(), userId); + assertFalse(hasFollower(dataProduct.getId(), userId)); + } + + @Test + void delete_followerForAnotherUserAsAdmin_200(TestNamespace ns) { + DataProduct dataProduct = createEntity(createMinimalRequest(ns)); + OpenMetadataClient client = SdkClients.adminClient(); + UUID userId = testUser3().getId(); + + addFollower(client, dataProduct.getId(), userId); + assertTrue(hasFollower(dataProduct.getId(), userId)); + + deleteFollower(client, dataProduct.getId(), userId); + assertFalse(hasFollower(dataProduct.getId(), userId)); + } + + @Test + void put_addFollowerWithNullUserId_400(TestNamespace ns) { + DataProduct dataProduct = createEntity(createMinimalRequest(ns)); + + InvalidRequestException exception = + assertThrows( + InvalidRequestException.class, + () -> + SdkClients.user2Client() + .getHttpClient() + .execute( + HttpMethod.PUT, + "/v1/dataProducts/" + dataProduct.getId() + "/followers", + "null", + ChangeEvent.class, + RequestOptions.builder() + .header("Content-Type", "application/json") + .build())); + + assertEquals(400, exception.getStatusCode()); + assertEquals("userId is required", exception.getMessage()); + } + + @Test + void delete_removeFollowerForAnotherUser_403(TestNamespace ns) { + DataProduct dataProduct = createEntity(createMinimalRequest(ns)); + addFollower(SdkClients.user3Client(), dataProduct.getId(), testUser3().getId()); + + ApiException exception = + assertThrows( + ApiException.class, + () -> + deleteFollower(SdkClients.user2Client(), dataProduct.getId(), testUser3().getId())); + + assertEquals(403, exception.getStatusCode()); + assertTrue(hasFollower(dataProduct.getId(), testUser3().getId())); + } + + private void addFollower(OpenMetadataClient client, UUID dataProductId, UUID userId) { + client + .getHttpClient() + .execute( + HttpMethod.PUT, + "/v1/dataProducts/" + dataProductId + "/followers", + userId, + ChangeEvent.class); + } + + private void deleteFollower(OpenMetadataClient client, UUID dataProductId, UUID userId) { + client + .getHttpClient() + .execute( + HttpMethod.DELETE, + "/v1/dataProducts/" + dataProductId + "/followers/" + userId, + null, + ChangeEvent.class); + } + + private boolean hasFollower(UUID dataProductId, UUID userId) { + DataProduct dataProduct = getEntityWithFields(dataProductId.toString(), "followers"); + return dataProduct.getFollowers() != null + && dataProduct.getFollowers().stream() + .anyMatch(follower -> userId.equals(follower.getId())); + } + @Test void post_dataProductWithStyle_200_OK(TestNamespace ns) { OpenMetadataClient client = SdkClients.adminClient(); diff --git a/openmetadata-service/src/main/java/org/openmetadata/service/jdbi3/EntityRepository.java b/openmetadata-service/src/main/java/org/openmetadata/service/jdbi3/EntityRepository.java index a89bcc75f38f..1b58445aa208 100644 --- a/openmetadata-service/src/main/java/org/openmetadata/service/jdbi3/EntityRepository.java +++ b/openmetadata-service/src/main/java/org/openmetadata/service/jdbi3/EntityRepository.java @@ -1767,8 +1767,9 @@ private ReadBundle buildReadBundle(T entity, ReadPlan readPlan) { return bundle; } - boolean onlyNonDeleted = isReadPlanNonDeletedOnly(readPlan); - CachedReadBundle bundleCache = onlyNonDeleted ? CacheBundle.getCachedReadBundle() : null; + boolean cacheReadBundle = + isReadPlanNonDeletedOnly(readPlan) && isCacheableEntityType(entityType); + CachedReadBundle bundleCache = cacheReadBundle ? CacheBundle.getCachedReadBundle() : null; java.util.concurrent.locks.Lock loadLock = null; CachedReadBundle.Dto initialDto = null; diff --git a/openmetadata-service/src/main/java/org/openmetadata/service/resources/EntityResource.java b/openmetadata-service/src/main/java/org/openmetadata/service/resources/EntityResource.java index ef37cb999ca8..a09bb6e03290 100644 --- a/openmetadata-service/src/main/java/org/openmetadata/service/resources/EntityResource.java +++ b/openmetadata-service/src/main/java/org/openmetadata/service/resources/EntityResource.java @@ -44,6 +44,7 @@ import java.util.IdentityHashMap; import java.util.List; import java.util.Map; +import java.util.Objects; import java.util.Set; import java.util.TreeSet; import java.util.UUID; @@ -72,6 +73,7 @@ import org.openmetadata.service.OpenMetadataApplicationConfig; import org.openmetadata.service.cache.CacheBundle; import org.openmetadata.service.cache.CacheProvider; +import org.openmetadata.service.exception.BadRequestException; import org.openmetadata.service.exception.CatalogExceptionMessage; import org.openmetadata.service.jdbi3.DeadlockRetry; import org.openmetadata.service.jdbi3.EntityRepository; @@ -160,6 +162,32 @@ protected T addHref(UriInfo uriInfo, T entity) { } } + protected Response addFollowerInternal( + SecurityContext securityContext, UUID entityId, UUID userId) { + authorizeFollowerMutation(securityContext, userId); + return repository + .addFollower(securityContext.getUserPrincipal().getName(), entityId, userId) + .toResponse(); + } + + protected Response deleteFollowerInternal( + SecurityContext securityContext, UUID entityId, UUID userId) { + authorizeFollowerMutation(securityContext, userId); + return repository + .deleteFollower(securityContext.getUserPrincipal().getName(), entityId, userId) + .toResponse(); + } + + private void authorizeFollowerMutation(SecurityContext securityContext, UUID userId) { + if (userId == null) { + throw new BadRequestException("userId is required"); + } + SubjectContext subjectContext = getSubjectContext(securityContext); + if (!Objects.equals(subjectContext.user().getId(), userId)) { + authorizer.authorizeAdmin(securityContext); + } + } + protected List getEntitySpecificOperations() { return null; } diff --git a/openmetadata-service/src/main/java/org/openmetadata/service/resources/ai/AIApplicationResource.java b/openmetadata-service/src/main/java/org/openmetadata/service/resources/ai/AIApplicationResource.java index 2a8d91b6ac11..bbd5543bac9a 100644 --- a/openmetadata-service/src/main/java/org/openmetadata/service/resources/ai/AIApplicationResource.java +++ b/openmetadata-service/src/main/java/org/openmetadata/service/resources/ai/AIApplicationResource.java @@ -368,9 +368,7 @@ public Response addFollower( description = "Id of the user to be added as follower", schema = @Schema(type = "UUID")) UUID userId) { - return repository - .addFollower(securityContext.getUserPrincipal().getName(), id, userId) - .toResponse(); + return addFollowerInternal(securityContext, id, userId); } @DELETE @@ -399,9 +397,7 @@ public Response deleteFollower( schema = @Schema(type = "UUID")) @PathParam("userId") UUID userId) { - return repository - .deleteFollower(securityContext.getUserPrincipal().getName(), id, userId) - .toResponse(); + return deleteFollowerInternal(securityContext, id, userId); } @GET diff --git a/openmetadata-service/src/main/java/org/openmetadata/service/resources/ai/AIGovernancePolicyResource.java b/openmetadata-service/src/main/java/org/openmetadata/service/resources/ai/AIGovernancePolicyResource.java index a469b705e839..f3c40165b67d 100644 --- a/openmetadata-service/src/main/java/org/openmetadata/service/resources/ai/AIGovernancePolicyResource.java +++ b/openmetadata-service/src/main/java/org/openmetadata/service/resources/ai/AIGovernancePolicyResource.java @@ -353,9 +353,7 @@ public Response addFollower( description = "Id of the user to be added as follower", schema = @Schema(type = "UUID")) UUID userId) { - return repository - .addFollower(securityContext.getUserPrincipal().getName(), id, userId) - .toResponse(); + return addFollowerInternal(securityContext, id, userId); } @DELETE @@ -384,9 +382,7 @@ public Response deleteFollower( schema = @Schema(type = "UUID")) @PathParam("userId") UUID userId) { - return repository - .deleteFollower(securityContext.getUserPrincipal().getName(), id, userId) - .toResponse(); + return deleteFollowerInternal(securityContext, id, userId); } @GET diff --git a/openmetadata-service/src/main/java/org/openmetadata/service/resources/ai/LLMModelResource.java b/openmetadata-service/src/main/java/org/openmetadata/service/resources/ai/LLMModelResource.java index 1bfbc7aeb4fe..0f5a9a2fdb13 100644 --- a/openmetadata-service/src/main/java/org/openmetadata/service/resources/ai/LLMModelResource.java +++ b/openmetadata-service/src/main/java/org/openmetadata/service/resources/ai/LLMModelResource.java @@ -362,9 +362,7 @@ public Response addFollower( description = "Id of the user to be added as follower", schema = @Schema(type = "UUID")) UUID userId) { - return repository - .addFollower(securityContext.getUserPrincipal().getName(), id, userId) - .toResponse(); + return addFollowerInternal(securityContext, id, userId); } @DELETE @@ -393,9 +391,7 @@ public Response deleteFollower( schema = @Schema(type = "UUID")) @PathParam("userId") UUID userId) { - return repository - .deleteFollower(securityContext.getUserPrincipal().getName(), id, userId) - .toResponse(); + return deleteFollowerInternal(securityContext, id, userId); } @GET diff --git a/openmetadata-service/src/main/java/org/openmetadata/service/resources/ai/McpServerResource.java b/openmetadata-service/src/main/java/org/openmetadata/service/resources/ai/McpServerResource.java index 7a602ee98364..3a91641f5ce4 100644 --- a/openmetadata-service/src/main/java/org/openmetadata/service/resources/ai/McpServerResource.java +++ b/openmetadata-service/src/main/java/org/openmetadata/service/resources/ai/McpServerResource.java @@ -379,9 +379,7 @@ public Response addFollower( description = "Id of the user to be added as follower", schema = @Schema(type = "UUID")) UUID userId) { - return repository - .addFollower(securityContext.getUserPrincipal().getName(), id, userId) - .toResponse(); + return addFollowerInternal(securityContext, id, userId); } @DELETE @@ -410,9 +408,7 @@ public Response deleteFollower( schema = @Schema(type = "UUID")) @PathParam("userId") UUID userId) { - return repository - .deleteFollower(securityContext.getUserPrincipal().getName(), id, userId) - .toResponse(); + return deleteFollowerInternal(securityContext, id, userId); } @GET diff --git a/openmetadata-service/src/main/java/org/openmetadata/service/resources/ai/PromptTemplateResource.java b/openmetadata-service/src/main/java/org/openmetadata/service/resources/ai/PromptTemplateResource.java index 416ec1d43bdb..82008dcb3d82 100644 --- a/openmetadata-service/src/main/java/org/openmetadata/service/resources/ai/PromptTemplateResource.java +++ b/openmetadata-service/src/main/java/org/openmetadata/service/resources/ai/PromptTemplateResource.java @@ -351,9 +351,7 @@ public Response addFollower( description = "Id of the user to be added as follower", schema = @Schema(type = "UUID")) UUID userId) { - return repository - .addFollower(securityContext.getUserPrincipal().getName(), id, userId) - .toResponse(); + return addFollowerInternal(securityContext, id, userId); } @DELETE @@ -382,9 +380,7 @@ public Response deleteFollower( schema = @Schema(type = "UUID")) @PathParam("userId") UUID userId) { - return repository - .deleteFollower(securityContext.getUserPrincipal().getName(), id, userId) - .toResponse(); + return deleteFollowerInternal(securityContext, id, userId); } @GET diff --git a/openmetadata-service/src/main/java/org/openmetadata/service/resources/apis/APIEndpointResource.java b/openmetadata-service/src/main/java/org/openmetadata/service/resources/apis/APIEndpointResource.java index 4f76cd9e7123..4757105b0285 100644 --- a/openmetadata-service/src/main/java/org/openmetadata/service/resources/apis/APIEndpointResource.java +++ b/openmetadata-service/src/main/java/org/openmetadata/service/resources/apis/APIEndpointResource.java @@ -479,9 +479,7 @@ public Response addFollower( description = "Id of the user to be added as follower", schema = @Schema(type = "UUID")) UUID userId) { - return repository - .addFollower(securityContext.getUserPrincipal().getName(), id, userId) - .toResponse(); + return addFollowerInternal(securityContext, id, userId); } @DELETE @@ -509,9 +507,7 @@ public Response deleteFollower( schema = @Schema(type = "string")) @PathParam("userId") String userId) { - return repository - .deleteFollower(securityContext.getUserPrincipal().getName(), id, UUID.fromString(userId)) - .toResponse(); + return deleteFollowerInternal(securityContext, id, UUID.fromString(userId)); } @PUT diff --git a/openmetadata-service/src/main/java/org/openmetadata/service/resources/charts/ChartResource.java b/openmetadata-service/src/main/java/org/openmetadata/service/resources/charts/ChartResource.java index 96ff75878e9e..7cd72186708c 100644 --- a/openmetadata-service/src/main/java/org/openmetadata/service/resources/charts/ChartResource.java +++ b/openmetadata-service/src/main/java/org/openmetadata/service/resources/charts/ChartResource.java @@ -460,9 +460,7 @@ public Response addFollower( description = "Id of the user to be added as follower", schema = @Schema(type = "UUID")) UUID userId) { - return repository - .addFollower(securityContext.getUserPrincipal().getName(), id, userId) - .toResponse(); + return addFollowerInternal(securityContext, id, userId); } @DELETE @@ -481,9 +479,7 @@ public Response deleteFollower( schema = @Schema(type = "UUID")) @PathParam("userId") UUID userId) { - return repository - .deleteFollower(securityContext.getUserPrincipal().getName(), id, userId) - .toResponse(); + return deleteFollowerInternal(securityContext, id, userId); } @DELETE diff --git a/openmetadata-service/src/main/java/org/openmetadata/service/resources/dashboards/DashboardResource.java b/openmetadata-service/src/main/java/org/openmetadata/service/resources/dashboards/DashboardResource.java index 3ac05657402a..bfa8b423b43d 100644 --- a/openmetadata-service/src/main/java/org/openmetadata/service/resources/dashboards/DashboardResource.java +++ b/openmetadata-service/src/main/java/org/openmetadata/service/resources/dashboards/DashboardResource.java @@ -475,9 +475,7 @@ public Response addFollower( description = "Id of the user to be added as follower", schema = @Schema(type = "UUID")) UUID userId) { - return repository - .addFollower(securityContext.getUserPrincipal().getName(), id, userId) - .toResponse(); + return addFollowerInternal(securityContext, id, userId); } @DELETE @@ -497,9 +495,7 @@ public Response deleteFollower( schema = @Schema(type = "UUID")) @PathParam("userId") UUID userId) { - return repository - .deleteFollower(securityContext.getUserPrincipal().getName(), id, userId) - .toResponse(); + return deleteFollowerInternal(securityContext, id, userId); } @PUT diff --git a/openmetadata-service/src/main/java/org/openmetadata/service/resources/databases/DatabaseResource.java b/openmetadata-service/src/main/java/org/openmetadata/service/resources/databases/DatabaseResource.java index 200170085ec4..d4c9ceafc709 100644 --- a/openmetadata-service/src/main/java/org/openmetadata/service/resources/databases/DatabaseResource.java +++ b/openmetadata-service/src/main/java/org/openmetadata/service/resources/databases/DatabaseResource.java @@ -880,9 +880,7 @@ public Response addFollower( description = "Id of the user to be added as follower", schema = @Schema(type = "string")) UUID userId) { - return repository - .addFollower(securityContext.getUserPrincipal().getName(), id, userId) - .toResponse(); + return addFollowerInternal(securityContext, id, userId); } @DELETE @@ -910,8 +908,6 @@ public Response deleteFollower( schema = @Schema(type = "string")) @PathParam("userId") String userId) { - return repository - .deleteFollower(securityContext.getUserPrincipal().getName(), id, UUID.fromString(userId)) - .toResponse(); + return deleteFollowerInternal(securityContext, id, UUID.fromString(userId)); } } diff --git a/openmetadata-service/src/main/java/org/openmetadata/service/resources/databases/DatabaseSchemaResource.java b/openmetadata-service/src/main/java/org/openmetadata/service/resources/databases/DatabaseSchemaResource.java index 7be0e5fa9441..ff958897941b 100644 --- a/openmetadata-service/src/main/java/org/openmetadata/service/resources/databases/DatabaseSchemaResource.java +++ b/openmetadata-service/src/main/java/org/openmetadata/service/resources/databases/DatabaseSchemaResource.java @@ -398,9 +398,7 @@ public Response addFollower( description = "Id of the user to be added as follower", schema = @Schema(type = "string")) UUID userId) { - return repository - .addFollower(securityContext.getUserPrincipal().getName(), id, userId) - .toResponse(); + return addFollowerInternal(securityContext, id, userId); } @DELETE @@ -428,9 +426,7 @@ public Response deleteFollower( schema = @Schema(type = "string")) @PathParam("userId") String userId) { - return repository - .deleteFollower(securityContext.getUserPrincipal().getName(), id, UUID.fromString(userId)) - .toResponse(); + return deleteFollowerInternal(securityContext, id, UUID.fromString(userId)); } @PATCH diff --git a/openmetadata-service/src/main/java/org/openmetadata/service/resources/databases/StoredProcedureResource.java b/openmetadata-service/src/main/java/org/openmetadata/service/resources/databases/StoredProcedureResource.java index 760da9de6b55..9db9d3a0ee7a 100644 --- a/openmetadata-service/src/main/java/org/openmetadata/service/resources/databases/StoredProcedureResource.java +++ b/openmetadata-service/src/main/java/org/openmetadata/service/resources/databases/StoredProcedureResource.java @@ -444,9 +444,7 @@ public Response addFollower( description = "Id of the user to be added as follower", schema = @Schema(type = "UUID")) UUID userId) { - return repository - .addFollower(securityContext.getUserPrincipal().getName(), id, userId) - .toResponse(); + return addFollowerInternal(securityContext, id, userId); } @DELETE @@ -474,9 +472,7 @@ public Response deleteFollower( schema = @Schema(type = "string")) @PathParam("userId") String userId) { - return repository - .deleteFollower(securityContext.getUserPrincipal().getName(), id, UUID.fromString(userId)) - .toResponse(); + return deleteFollowerInternal(securityContext, id, UUID.fromString(userId)); } @PUT diff --git a/openmetadata-service/src/main/java/org/openmetadata/service/resources/databases/TableResource.java b/openmetadata-service/src/main/java/org/openmetadata/service/resources/databases/TableResource.java index e4933d4d455e..409bb66f3ba4 100644 --- a/openmetadata-service/src/main/java/org/openmetadata/service/resources/databases/TableResource.java +++ b/openmetadata-service/src/main/java/org/openmetadata/service/resources/databases/TableResource.java @@ -828,9 +828,7 @@ public Response addFollower( description = "Id of the user to be added as follower", schema = @Schema(type = "string")) UUID userId) { - return repository - .addFollower(securityContext.getUserPrincipal().getName(), id, userId) - .toResponse(); + return addFollowerInternal(securityContext, id, userId); } @PUT @@ -1639,9 +1637,7 @@ public Response deleteFollower( schema = @Schema(type = "string")) @PathParam("userId") String userId) { - return repository - .deleteFollower(securityContext.getUserPrincipal().getName(), id, UUID.fromString(userId)) - .toResponse(); + return deleteFollowerInternal(securityContext, id, UUID.fromString(userId)); } @GET diff --git a/openmetadata-service/src/main/java/org/openmetadata/service/resources/datamodels/DashboardDataModelResource.java b/openmetadata-service/src/main/java/org/openmetadata/service/resources/datamodels/DashboardDataModelResource.java index 8a69e00aa088..b0b09ae7002c 100644 --- a/openmetadata-service/src/main/java/org/openmetadata/service/resources/datamodels/DashboardDataModelResource.java +++ b/openmetadata-service/src/main/java/org/openmetadata/service/resources/datamodels/DashboardDataModelResource.java @@ -478,9 +478,7 @@ public Response addFollower( description = "Id of the user to be added as follower", schema = @Schema(type = "UUID")) UUID userId) { - return repository - .addFollower(securityContext.getUserPrincipal().getName(), id, userId) - .toResponse(); + return addFollowerInternal(securityContext, id, userId); } @DELETE @@ -500,9 +498,7 @@ public Response deleteFollower( schema = @Schema(type = "UUID")) @PathParam("userId") UUID userId) { - return repository - .deleteFollower(securityContext.getUserPrincipal().getName(), id, userId) - .toResponse(); + return deleteFollowerInternal(securityContext, id, userId); } @PUT diff --git a/openmetadata-service/src/main/java/org/openmetadata/service/resources/domains/DataProductResource.java b/openmetadata-service/src/main/java/org/openmetadata/service/resources/domains/DataProductResource.java index d4872e75affe..5aa92dc93dd4 100644 --- a/openmetadata-service/src/main/java/org/openmetadata/service/resources/domains/DataProductResource.java +++ b/openmetadata-service/src/main/java/org/openmetadata/service/resources/domains/DataProductResource.java @@ -994,9 +994,7 @@ public Response addFollower( description = "Id of the user to be added as follower", schema = @Schema(type = "string")) UUID userId) { - return repository - .addFollower(securityContext.getUserPrincipal().getName(), id, userId) - .toResponse(); + return addFollowerInternal(securityContext, id, userId); } @DELETE @@ -1023,9 +1021,7 @@ public Response deleteFollower( schema = @Schema(type = "string")) @PathParam("userId") String userId) { - return repository - .deleteFollower(securityContext.getUserPrincipal().getName(), id, UUID.fromString(userId)) - .toResponse(); + return deleteFollowerInternal(securityContext, id, UUID.fromString(userId)); } @GET diff --git a/openmetadata-service/src/main/java/org/openmetadata/service/resources/domains/DomainResource.java b/openmetadata-service/src/main/java/org/openmetadata/service/resources/domains/DomainResource.java index 028df9d98a95..e6f1eb619aa9 100644 --- a/openmetadata-service/src/main/java/org/openmetadata/service/resources/domains/DomainResource.java +++ b/openmetadata-service/src/main/java/org/openmetadata/service/resources/domains/DomainResource.java @@ -586,9 +586,7 @@ public Response addFollower( description = "Id of the user to be added as follower", schema = @Schema(type = "string")) UUID userId) { - return repository - .addFollower(securityContext.getUserPrincipal().getName(), id, userId) - .toResponse(); + return addFollowerInternal(securityContext, id, userId); } @DELETE @@ -615,9 +613,7 @@ public Response deleteFollower( schema = @Schema(type = "string")) @PathParam("userId") String userId) { - return repository - .deleteFollower(securityContext.getUserPrincipal().getName(), id, UUID.fromString(userId)) - .toResponse(); + return deleteFollowerInternal(securityContext, id, UUID.fromString(userId)); } @GET diff --git a/openmetadata-service/src/main/java/org/openmetadata/service/resources/drives/DirectoryResource.java b/openmetadata-service/src/main/java/org/openmetadata/service/resources/drives/DirectoryResource.java index 016c1fdef4ab..0757ddaf3ccf 100644 --- a/openmetadata-service/src/main/java/org/openmetadata/service/resources/drives/DirectoryResource.java +++ b/openmetadata-service/src/main/java/org/openmetadata/service/resources/drives/DirectoryResource.java @@ -585,9 +585,7 @@ public Response addFollower( description = "Id of the user to be added as follower", schema = @Schema(type = "UUID")) UUID userId) { - return repository - .addFollower(securityContext.getUserPrincipal().getName(), id, userId) - .toResponse(); + return addFollowerInternal(securityContext, id, userId); } @DELETE @@ -616,9 +614,7 @@ public Response deleteFollower( schema = @Schema(type = "UUID")) @PathParam("userId") UUID userId) { - return repository - .deleteFollower(securityContext.getUserPrincipal().getName(), id, userId) - .toResponse(); + return deleteFollowerInternal(securityContext, id, userId); } @PUT diff --git a/openmetadata-service/src/main/java/org/openmetadata/service/resources/drives/FileResource.java b/openmetadata-service/src/main/java/org/openmetadata/service/resources/drives/FileResource.java index bcbbdd6088a9..c3df0b03974b 100644 --- a/openmetadata-service/src/main/java/org/openmetadata/service/resources/drives/FileResource.java +++ b/openmetadata-service/src/main/java/org/openmetadata/service/resources/drives/FileResource.java @@ -593,9 +593,7 @@ public Response addFollower( description = "Id of the user to be added as follower", schema = @Schema(type = "UUID")) UUID userId) { - return repository - .addFollower(securityContext.getUserPrincipal().getName(), id, userId) - .toResponse(); + return addFollowerInternal(securityContext, id, userId); } @DELETE @@ -623,9 +621,7 @@ public Response deleteFollower( schema = @Schema(type = "UUID")) @PathParam("userId") UUID userId) { - return repository - .deleteFollower(securityContext.getUserPrincipal().getName(), id, userId) - .toResponse(); + return deleteFollowerInternal(securityContext, id, userId); } @PUT diff --git a/openmetadata-service/src/main/java/org/openmetadata/service/resources/drives/SpreadsheetResource.java b/openmetadata-service/src/main/java/org/openmetadata/service/resources/drives/SpreadsheetResource.java index 28335091455c..0815f7bcea98 100644 --- a/openmetadata-service/src/main/java/org/openmetadata/service/resources/drives/SpreadsheetResource.java +++ b/openmetadata-service/src/main/java/org/openmetadata/service/resources/drives/SpreadsheetResource.java @@ -567,9 +567,7 @@ public Response addFollower( description = "Id of the user to be added as follower", schema = @Schema(type = "UUID")) UUID userId) { - return repository - .addFollower(securityContext.getUserPrincipal().getName(), id, userId) - .toResponse(); + return addFollowerInternal(securityContext, id, userId); } @DELETE @@ -598,9 +596,7 @@ public Response deleteFollower( schema = @Schema(type = "UUID")) @PathParam("userId") UUID userId) { - return repository - .deleteFollower(securityContext.getUserPrincipal().getName(), id, userId) - .toResponse(); + return deleteFollowerInternal(securityContext, id, userId); } @PUT diff --git a/openmetadata-service/src/main/java/org/openmetadata/service/resources/drives/WorksheetResource.java b/openmetadata-service/src/main/java/org/openmetadata/service/resources/drives/WorksheetResource.java index c094d0bbb595..6194141b3bb1 100644 --- a/openmetadata-service/src/main/java/org/openmetadata/service/resources/drives/WorksheetResource.java +++ b/openmetadata-service/src/main/java/org/openmetadata/service/resources/drives/WorksheetResource.java @@ -543,9 +543,7 @@ public Response addFollower( description = "Id of the user to be added as follower", schema = @Schema(type = "UUID")) UUID userId) { - return repository - .addFollower(securityContext.getUserPrincipal().getName(), id, userId) - .toResponse(); + return addFollowerInternal(securityContext, id, userId); } @DELETE @@ -574,9 +572,7 @@ public Response deleteFollower( schema = @Schema(type = "UUID")) @PathParam("userId") UUID userId) { - return repository - .deleteFollower(securityContext.getUserPrincipal().getName(), id, userId) - .toResponse(); + return deleteFollowerInternal(securityContext, id, userId); } @PUT diff --git a/openmetadata-service/src/main/java/org/openmetadata/service/resources/metrics/MetricResource.java b/openmetadata-service/src/main/java/org/openmetadata/service/resources/metrics/MetricResource.java index 9865a2218bd3..a9e187bb14e0 100644 --- a/openmetadata-service/src/main/java/org/openmetadata/service/resources/metrics/MetricResource.java +++ b/openmetadata-service/src/main/java/org/openmetadata/service/resources/metrics/MetricResource.java @@ -436,9 +436,7 @@ public Response addFollower( description = "Id of the user to be added as follower", schema = @Schema(type = "UUID")) UUID userId) { - return repository - .addFollower(securityContext.getUserPrincipal().getName(), id, userId) - .toResponse(); + return addFollowerInternal(securityContext, id, userId); } @DELETE @@ -465,9 +463,7 @@ public Response deleteFollower( schema = @Schema(type = "string")) @PathParam("userId") String userId) { - return repository - .deleteFollower(securityContext.getUserPrincipal().getName(), id, UUID.fromString(userId)) - .toResponse(); + return deleteFollowerInternal(securityContext, id, UUID.fromString(userId)); } @PUT diff --git a/openmetadata-service/src/main/java/org/openmetadata/service/resources/mlmodels/MlModelResource.java b/openmetadata-service/src/main/java/org/openmetadata/service/resources/mlmodels/MlModelResource.java index 785c2358cba3..3b8f1aebaf2a 100644 --- a/openmetadata-service/src/main/java/org/openmetadata/service/resources/mlmodels/MlModelResource.java +++ b/openmetadata-service/src/main/java/org/openmetadata/service/resources/mlmodels/MlModelResource.java @@ -419,9 +419,7 @@ public Response addFollower( description = "Id of the user to be added as follower", schema = @Schema(type = "UUID")) UUID userId) { - return repository - .addFollower(securityContext.getUserPrincipal().getName(), id, userId) - .toResponse(); + return addFollowerInternal(securityContext, id, userId); } @DELETE @@ -450,9 +448,7 @@ public Response deleteFollower( schema = @Schema(type = "UUID")) @PathParam("userId") UUID userId) { - return repository - .deleteFollower(securityContext.getUserPrincipal().getName(), id, userId) - .toResponse(); + return deleteFollowerInternal(securityContext, id, userId); } @GET diff --git a/openmetadata-service/src/main/java/org/openmetadata/service/resources/pipelines/PipelineResource.java b/openmetadata-service/src/main/java/org/openmetadata/service/resources/pipelines/PipelineResource.java index c307cdd2e5e3..14637abd4ac3 100644 --- a/openmetadata-service/src/main/java/org/openmetadata/service/resources/pipelines/PipelineResource.java +++ b/openmetadata-service/src/main/java/org/openmetadata/service/resources/pipelines/PipelineResource.java @@ -669,9 +669,7 @@ public Response addFollower( description = "Id of the user to be added as follower", schema = @Schema(type = "string")) UUID userId) { - return repository - .addFollower(securityContext.getUserPrincipal().getName(), id, userId) - .toResponse(); + return addFollowerInternal(securityContext, id, userId); } @DELETE @@ -700,9 +698,7 @@ public Response deleteFollower( schema = @Schema(type = "UUID")) @PathParam("userId") UUID userId) { - return repository - .deleteFollower(securityContext.getUserPrincipal().getName(), id, userId) - .toResponse(); + return deleteFollowerInternal(securityContext, id, userId); } @PUT diff --git a/openmetadata-service/src/main/java/org/openmetadata/service/resources/query/QueryResource.java b/openmetadata-service/src/main/java/org/openmetadata/service/resources/query/QueryResource.java index 695855121df7..d4d18fc006cd 100644 --- a/openmetadata-service/src/main/java/org/openmetadata/service/resources/query/QueryResource.java +++ b/openmetadata-service/src/main/java/org/openmetadata/service/resources/query/QueryResource.java @@ -461,9 +461,7 @@ public Response addFollower( description = "Id of the user to be added as follower", schema = @Schema(type = "UUID")) UUID userId) { - return repository - .addFollower(securityContext.getUserPrincipal().getName(), id, userId) - .toResponse(); + return addFollowerInternal(securityContext, id, userId); } @PUT @@ -518,9 +516,7 @@ public Response deleteFollower( schema = @Schema(type = "UUID")) @PathParam("userId") UUID userId) { - return repository - .deleteFollower(securityContext.getUserPrincipal().getName(), id, userId) - .toResponse(); + return deleteFollowerInternal(securityContext, id, userId); } @PUT diff --git a/openmetadata-service/src/main/java/org/openmetadata/service/resources/searchindex/SearchIndexResource.java b/openmetadata-service/src/main/java/org/openmetadata/service/resources/searchindex/SearchIndexResource.java index 2570ba07642a..59c413f7609e 100644 --- a/openmetadata-service/src/main/java/org/openmetadata/service/resources/searchindex/SearchIndexResource.java +++ b/openmetadata-service/src/main/java/org/openmetadata/service/resources/searchindex/SearchIndexResource.java @@ -541,9 +541,7 @@ public Response addFollower( description = "Id of the user to be added as follower", schema = @Schema(type = "UUID")) UUID userId) { - return repository - .addFollower(securityContext.getUserPrincipal().getName(), id, userId) - .toResponse(); + return addFollowerInternal(securityContext, id, userId); } @DELETE @@ -571,9 +569,7 @@ public Response deleteFollower( schema = @Schema(type = "string")) @PathParam("userId") String userId) { - return repository - .deleteFollower(securityContext.getUserPrincipal().getName(), id, UUID.fromString(userId)) - .toResponse(); + return deleteFollowerInternal(securityContext, id, UUID.fromString(userId)); } @PUT diff --git a/openmetadata-service/src/main/java/org/openmetadata/service/resources/services/apiservices/APIServiceResource.java b/openmetadata-service/src/main/java/org/openmetadata/service/resources/services/apiservices/APIServiceResource.java index b8555d192487..13bde8727561 100644 --- a/openmetadata-service/src/main/java/org/openmetadata/service/resources/services/apiservices/APIServiceResource.java +++ b/openmetadata-service/src/main/java/org/openmetadata/service/resources/services/apiservices/APIServiceResource.java @@ -581,9 +581,7 @@ public Response addFollower( description = "Id of the user to be added as follower", schema = @Schema(type = "string")) UUID userId) { - return repository - .addFollower(securityContext.getUserPrincipal().getName(), id, userId) - .toResponse(); + return addFollowerInternal(securityContext, id, userId); } @DELETE @@ -611,9 +609,7 @@ public Response deleteFollower( schema = @Schema(type = "string")) @PathParam("userId") String userId) { - return repository - .deleteFollower(securityContext.getUserPrincipal().getName(), id, UUID.fromString(userId)) - .toResponse(); + return deleteFollowerInternal(securityContext, id, UUID.fromString(userId)); } @PUT diff --git a/openmetadata-service/src/main/java/org/openmetadata/service/resources/services/dashboard/DashboardServiceResource.java b/openmetadata-service/src/main/java/org/openmetadata/service/resources/services/dashboard/DashboardServiceResource.java index 5ebcc81c1391..2cdfbf4a1c91 100644 --- a/openmetadata-service/src/main/java/org/openmetadata/service/resources/services/dashboard/DashboardServiceResource.java +++ b/openmetadata-service/src/main/java/org/openmetadata/service/resources/services/dashboard/DashboardServiceResource.java @@ -215,9 +215,7 @@ public Response addFollower( description = "Id of the user to be added as follower", schema = @Schema(type = "string")) UUID userId) { - return repository - .addFollower(securityContext.getUserPrincipal().getName(), id, userId) - .toResponse(); + return addFollowerInternal(securityContext, id, userId); } @DELETE @@ -245,9 +243,7 @@ public Response deleteFollower( schema = @Schema(type = "string")) @PathParam("userId") String userId) { - return repository - .deleteFollower(securityContext.getUserPrincipal().getName(), id, UUID.fromString(userId)) - .toResponse(); + return deleteFollowerInternal(securityContext, id, UUID.fromString(userId)); } @GET diff --git a/openmetadata-service/src/main/java/org/openmetadata/service/resources/services/database/DatabaseServiceResource.java b/openmetadata-service/src/main/java/org/openmetadata/service/resources/services/database/DatabaseServiceResource.java index 394a145c493f..f8e7fb6a6ef1 100644 --- a/openmetadata-service/src/main/java/org/openmetadata/service/resources/services/database/DatabaseServiceResource.java +++ b/openmetadata-service/src/main/java/org/openmetadata/service/resources/services/database/DatabaseServiceResource.java @@ -437,9 +437,7 @@ public Response addFollower( description = "Id of the user to be added as follower", schema = @Schema(type = "string")) UUID userId) { - return repository - .addFollower(securityContext.getUserPrincipal().getName(), id, userId) - .toResponse(); + return addFollowerInternal(securityContext, id, userId); } @DELETE @@ -467,9 +465,7 @@ public Response deleteFollower( schema = @Schema(type = "string")) @PathParam("userId") String userId) { - return repository - .deleteFollower(securityContext.getUserPrincipal().getName(), id, UUID.fromString(userId)) - .toResponse(); + return deleteFollowerInternal(securityContext, id, UUID.fromString(userId)); } @PATCH diff --git a/openmetadata-service/src/main/java/org/openmetadata/service/resources/services/drive/DriveServiceResource.java b/openmetadata-service/src/main/java/org/openmetadata/service/resources/services/drive/DriveServiceResource.java index fa3b7c45231c..c2183aa719a6 100644 --- a/openmetadata-service/src/main/java/org/openmetadata/service/resources/services/drive/DriveServiceResource.java +++ b/openmetadata-service/src/main/java/org/openmetadata/service/resources/services/drive/DriveServiceResource.java @@ -486,9 +486,7 @@ public Response addFollower( description = "Id of the user to be added as follower", schema = @Schema(type = "UUID")) UUID userId) { - return repository - .addFollower(securityContext.getUserPrincipal().getName(), id, userId) - .toResponse(); + return addFollowerInternal(securityContext, id, userId); } @DELETE @@ -517,9 +515,7 @@ public Response deleteFollower( schema = @Schema(type = "UUID")) @PathParam("userId") UUID userId) { - return repository - .deleteFollower(securityContext.getUserPrincipal().getName(), id, userId) - .toResponse(); + return deleteFollowerInternal(securityContext, id, userId); } @PUT diff --git a/openmetadata-service/src/main/java/org/openmetadata/service/resources/services/ingestionpipelines/IngestionPipelineResource.java b/openmetadata-service/src/main/java/org/openmetadata/service/resources/services/ingestionpipelines/IngestionPipelineResource.java index cee01bb3dfa5..46120caea457 100644 --- a/openmetadata-service/src/main/java/org/openmetadata/service/resources/services/ingestionpipelines/IngestionPipelineResource.java +++ b/openmetadata-service/src/main/java/org/openmetadata/service/resources/services/ingestionpipelines/IngestionPipelineResource.java @@ -379,9 +379,7 @@ public Response addFollower( description = "Id of the user to be added as follower", schema = @Schema(type = "string")) UUID userId) { - return repository - .addFollower(securityContext.getUserPrincipal().getName(), id, userId) - .toResponse(); + return addFollowerInternal(securityContext, id, userId); } @DELETE @@ -409,9 +407,7 @@ public Response deleteFollower( schema = @Schema(type = "string")) @PathParam("userId") String userId) { - return repository - .deleteFollower(securityContext.getUserPrincipal().getName(), id, UUID.fromString(userId)) - .toResponse(); + return deleteFollowerInternal(securityContext, id, UUID.fromString(userId)); } @GET diff --git a/openmetadata-service/src/main/java/org/openmetadata/service/resources/services/llm/LLMServiceResource.java b/openmetadata-service/src/main/java/org/openmetadata/service/resources/services/llm/LLMServiceResource.java index f2fe8332044e..d398e71c3bca 100644 --- a/openmetadata-service/src/main/java/org/openmetadata/service/resources/services/llm/LLMServiceResource.java +++ b/openmetadata-service/src/main/java/org/openmetadata/service/resources/services/llm/LLMServiceResource.java @@ -420,9 +420,7 @@ public Response addFollower( description = "Id of the user to be added as follower", schema = @Schema(type = "string")) UUID userId) { - return repository - .addFollower(securityContext.getUserPrincipal().getName(), id, userId) - .toResponse(); + return addFollowerInternal(securityContext, id, userId); } @DELETE @@ -450,9 +448,7 @@ public Response deleteFollower( schema = @Schema(type = "string")) @PathParam("userId") String userId) { - return repository - .deleteFollower(securityContext.getUserPrincipal().getName(), id, UUID.fromString(userId)) - .toResponse(); + return deleteFollowerInternal(securityContext, id, UUID.fromString(userId)); } @PATCH diff --git a/openmetadata-service/src/main/java/org/openmetadata/service/resources/services/mcp/McpServiceResource.java b/openmetadata-service/src/main/java/org/openmetadata/service/resources/services/mcp/McpServiceResource.java index 826b5505f385..1fac0d01d042 100644 --- a/openmetadata-service/src/main/java/org/openmetadata/service/resources/services/mcp/McpServiceResource.java +++ b/openmetadata-service/src/main/java/org/openmetadata/service/resources/services/mcp/McpServiceResource.java @@ -413,9 +413,7 @@ public Response addFollower( description = "Id of the user to be added as follower", schema = @Schema(type = "string")) UUID userId) { - return repository - .addFollower(securityContext.getUserPrincipal().getName(), id, userId) - .toResponse(); + return addFollowerInternal(securityContext, id, userId); } @DELETE @@ -443,9 +441,7 @@ public Response deleteFollower( schema = @Schema(type = "string")) @PathParam("userId") String userId) { - return repository - .deleteFollower(securityContext.getUserPrincipal().getName(), id, UUID.fromString(userId)) - .toResponse(); + return deleteFollowerInternal(securityContext, id, UUID.fromString(userId)); } @PATCH diff --git a/openmetadata-service/src/main/java/org/openmetadata/service/resources/services/messaging/MessagingServiceResource.java b/openmetadata-service/src/main/java/org/openmetadata/service/resources/services/messaging/MessagingServiceResource.java index 5ac5acc91193..dee77c8aad22 100644 --- a/openmetadata-service/src/main/java/org/openmetadata/service/resources/services/messaging/MessagingServiceResource.java +++ b/openmetadata-service/src/main/java/org/openmetadata/service/resources/services/messaging/MessagingServiceResource.java @@ -294,9 +294,7 @@ public Response addFollower( description = "Id of the user to be added as follower", schema = @Schema(type = "string")) UUID userId) { - return repository - .addFollower(securityContext.getUserPrincipal().getName(), id, userId) - .toResponse(); + return addFollowerInternal(securityContext, id, userId); } @DELETE @@ -324,9 +322,7 @@ public Response deleteFollower( schema = @Schema(type = "string")) @PathParam("userId") String userId) { - return repository - .deleteFollower(securityContext.getUserPrincipal().getName(), id, UUID.fromString(userId)) - .toResponse(); + return deleteFollowerInternal(securityContext, id, UUID.fromString(userId)); } @GET diff --git a/openmetadata-service/src/main/java/org/openmetadata/service/resources/services/metadata/MetadataServiceResource.java b/openmetadata-service/src/main/java/org/openmetadata/service/resources/services/metadata/MetadataServiceResource.java index 9cab5010d6d8..07fd700242d5 100644 --- a/openmetadata-service/src/main/java/org/openmetadata/service/resources/services/metadata/MetadataServiceResource.java +++ b/openmetadata-service/src/main/java/org/openmetadata/service/resources/services/metadata/MetadataServiceResource.java @@ -308,9 +308,7 @@ public Response addFollower( description = "Id of the user to be added as follower", schema = @Schema(type = "string")) UUID userId) { - return repository - .addFollower(securityContext.getUserPrincipal().getName(), id, userId) - .toResponse(); + return addFollowerInternal(securityContext, id, userId); } @DELETE @@ -338,9 +336,7 @@ public Response deleteFollower( schema = @Schema(type = "string")) @PathParam("userId") String userId) { - return repository - .deleteFollower(securityContext.getUserPrincipal().getName(), id, UUID.fromString(userId)) - .toResponse(); + return deleteFollowerInternal(securityContext, id, UUID.fromString(userId)); } @PUT diff --git a/openmetadata-service/src/main/java/org/openmetadata/service/resources/services/mlmodel/MlModelServiceResource.java b/openmetadata-service/src/main/java/org/openmetadata/service/resources/services/mlmodel/MlModelServiceResource.java index 1568140a2bf4..2a1289a09a64 100644 --- a/openmetadata-service/src/main/java/org/openmetadata/service/resources/services/mlmodel/MlModelServiceResource.java +++ b/openmetadata-service/src/main/java/org/openmetadata/service/resources/services/mlmodel/MlModelServiceResource.java @@ -280,9 +280,7 @@ public Response addFollower( description = "Id of the user to be added as follower", schema = @Schema(type = "string")) UUID userId) { - return repository - .addFollower(securityContext.getUserPrincipal().getName(), id, userId) - .toResponse(); + return addFollowerInternal(securityContext, id, userId); } @DELETE @@ -310,9 +308,7 @@ public Response deleteFollower( schema = @Schema(type = "string")) @PathParam("userId") String userId) { - return repository - .deleteFollower(securityContext.getUserPrincipal().getName(), id, UUID.fromString(userId)) - .toResponse(); + return deleteFollowerInternal(securityContext, id, UUID.fromString(userId)); } @PUT diff --git a/openmetadata-service/src/main/java/org/openmetadata/service/resources/services/pipeline/PipelineServiceResource.java b/openmetadata-service/src/main/java/org/openmetadata/service/resources/services/pipeline/PipelineServiceResource.java index c8d79e38a3b5..7d829f1665a3 100644 --- a/openmetadata-service/src/main/java/org/openmetadata/service/resources/services/pipeline/PipelineServiceResource.java +++ b/openmetadata-service/src/main/java/org/openmetadata/service/resources/services/pipeline/PipelineServiceResource.java @@ -280,9 +280,7 @@ public Response addFollower( description = "Id of the user to be added as follower", schema = @Schema(type = "string")) UUID userId) { - return repository - .addFollower(securityContext.getUserPrincipal().getName(), id, userId) - .toResponse(); + return addFollowerInternal(securityContext, id, userId); } @DELETE @@ -310,9 +308,7 @@ public Response deleteFollower( schema = @Schema(type = "string")) @PathParam("userId") String userId) { - return repository - .deleteFollower(securityContext.getUserPrincipal().getName(), id, UUID.fromString(userId)) - .toResponse(); + return deleteFollowerInternal(securityContext, id, UUID.fromString(userId)); } @PUT diff --git a/openmetadata-service/src/main/java/org/openmetadata/service/resources/services/searchIndexes/SearchServiceResource.java b/openmetadata-service/src/main/java/org/openmetadata/service/resources/services/searchIndexes/SearchServiceResource.java index 7d3b9adb9b6f..a25ad44eb616 100644 --- a/openmetadata-service/src/main/java/org/openmetadata/service/resources/services/searchIndexes/SearchServiceResource.java +++ b/openmetadata-service/src/main/java/org/openmetadata/service/resources/services/searchIndexes/SearchServiceResource.java @@ -298,9 +298,7 @@ public Response addFollower( description = "Id of the user to be added as follower", schema = @Schema(type = "string")) UUID userId) { - return repository - .addFollower(securityContext.getUserPrincipal().getName(), id, userId) - .toResponse(); + return addFollowerInternal(securityContext, id, userId); } @DELETE @@ -328,9 +326,7 @@ public Response deleteFollower( schema = @Schema(type = "string")) @PathParam("userId") String userId) { - return repository - .deleteFollower(securityContext.getUserPrincipal().getName(), id, UUID.fromString(userId)) - .toResponse(); + return deleteFollowerInternal(securityContext, id, UUID.fromString(userId)); } @GET diff --git a/openmetadata-service/src/main/java/org/openmetadata/service/resources/services/security/SecurityServiceResource.java b/openmetadata-service/src/main/java/org/openmetadata/service/resources/services/security/SecurityServiceResource.java index 1b86dd974a49..dbe410637a54 100644 --- a/openmetadata-service/src/main/java/org/openmetadata/service/resources/services/security/SecurityServiceResource.java +++ b/openmetadata-service/src/main/java/org/openmetadata/service/resources/services/security/SecurityServiceResource.java @@ -427,9 +427,7 @@ public Response addFollower( description = "Id of the user to be added as follower", schema = @Schema(type = "string")) UUID userId) { - return repository - .addFollower(securityContext.getUserPrincipal().getName(), id, userId) - .toResponse(); + return addFollowerInternal(securityContext, id, userId); } @DELETE @@ -457,9 +455,7 @@ public Response deleteFollower( schema = @Schema(type = "string")) @PathParam("userId") String userId) { - return repository - .deleteFollower(securityContext.getUserPrincipal().getName(), id, UUID.fromString(userId)) - .toResponse(); + return deleteFollowerInternal(securityContext, id, UUID.fromString(userId)); } @PATCH diff --git a/openmetadata-service/src/main/java/org/openmetadata/service/resources/services/storage/StorageServiceResource.java b/openmetadata-service/src/main/java/org/openmetadata/service/resources/services/storage/StorageServiceResource.java index a9e24a8bdfc5..fcd8a7d2d98d 100644 --- a/openmetadata-service/src/main/java/org/openmetadata/service/resources/services/storage/StorageServiceResource.java +++ b/openmetadata-service/src/main/java/org/openmetadata/service/resources/services/storage/StorageServiceResource.java @@ -264,9 +264,7 @@ public Response addFollower( description = "Id of the user to be added as follower", schema = @Schema(type = "string")) UUID userId) { - return repository - .addFollower(securityContext.getUserPrincipal().getName(), id, userId) - .toResponse(); + return addFollowerInternal(securityContext, id, userId); } @DELETE @@ -294,9 +292,7 @@ public Response deleteFollower( schema = @Schema(type = "string")) @PathParam("userId") String userId) { - return repository - .deleteFollower(securityContext.getUserPrincipal().getName(), id, UUID.fromString(userId)) - .toResponse(); + return deleteFollowerInternal(securityContext, id, UUID.fromString(userId)); } @PUT diff --git a/openmetadata-service/src/main/java/org/openmetadata/service/resources/storages/ContainerResource.java b/openmetadata-service/src/main/java/org/openmetadata/service/resources/storages/ContainerResource.java index 7253558c5979..ea1148882781 100644 --- a/openmetadata-service/src/main/java/org/openmetadata/service/resources/storages/ContainerResource.java +++ b/openmetadata-service/src/main/java/org/openmetadata/service/resources/storages/ContainerResource.java @@ -417,9 +417,7 @@ public Response addFollower( description = "Id of the user to be added as follower", schema = @Schema(type = "UUID")) UUID userId) { - return repository - .addFollower(securityContext.getUserPrincipal().getName(), id, userId) - .toResponse(); + return addFollowerInternal(securityContext, id, userId); } @DELETE @@ -448,12 +446,7 @@ public Response deleteFollower( schema = @Schema(type = "string")) @PathParam("userId") String userId) { - return repository - .deleteFollower( - securityContext.getUserPrincipal().getName(), - UUID.fromString(id), - UUID.fromString(userId)) - .toResponse(); + return deleteFollowerInternal(securityContext, UUID.fromString(id), UUID.fromString(userId)); } @GET diff --git a/openmetadata-service/src/main/java/org/openmetadata/service/resources/topics/TopicResource.java b/openmetadata-service/src/main/java/org/openmetadata/service/resources/topics/TopicResource.java index 6b092a86f0c8..1a864078a6bd 100644 --- a/openmetadata-service/src/main/java/org/openmetadata/service/resources/topics/TopicResource.java +++ b/openmetadata-service/src/main/java/org/openmetadata/service/resources/topics/TopicResource.java @@ -526,9 +526,7 @@ public Response addFollower( description = "Id of the user to be added as follower", schema = @Schema(type = "UUID")) UUID userId) { - return repository - .addFollower(securityContext.getUserPrincipal().getName(), id, userId) - .toResponse(); + return addFollowerInternal(securityContext, id, userId); } @DELETE @@ -555,9 +553,7 @@ public Response deleteFollower( schema = @Schema(type = "string")) @PathParam("userId") String userId) { - return repository - .deleteFollower(securityContext.getUserPrincipal().getName(), id, UUID.fromString(userId)) - .toResponse(); + return deleteFollowerInternal(securityContext, id, UUID.fromString(userId)); } @PUT