diff --git a/gravitee-apim-rest-api/gravitee-apim-rest-api-management-v2/gravitee-apim-rest-api-management-v2-rest/src/main/java/io/gravitee/rest/api/management/v2/rest/resource/api/ApiSubscriptionsResource.java b/gravitee-apim-rest-api/gravitee-apim-rest-api-management-v2/gravitee-apim-rest-api-management-v2-rest/src/main/java/io/gravitee/rest/api/management/v2/rest/resource/api/ApiSubscriptionsResource.java index 62df156368d..a3a1d7b0c2e 100644 --- a/gravitee-apim-rest-api/gravitee-apim-rest-api-management-v2/gravitee-apim-rest-api-management-v2-rest/src/main/java/io/gravitee/rest/api/management/v2/rest/resource/api/ApiSubscriptionsResource.java +++ b/gravitee-apim-rest-api/gravitee-apim-rest-api-management-v2/gravitee-apim-rest-api-management-v2-rest/src/main/java/io/gravitee/rest/api/management/v2/rest/resource/api/ApiSubscriptionsResource.java @@ -23,6 +23,7 @@ import io.gravitee.apim.core.subscription.use_case.CloseSubscriptionUseCase; import io.gravitee.common.data.domain.Page; import io.gravitee.common.http.MediaType; +import io.gravitee.repository.management.model.ApplicationStatus; import io.gravitee.rest.api.management.v2.rest.mapper.*; import io.gravitee.rest.api.management.v2.rest.model.*; import io.gravitee.rest.api.management.v2.rest.model.Error; @@ -496,7 +497,7 @@ private void expandData(List subscriptions, Set expands) { .map(subscription -> (subscription.getApplication()).getId()) .collect(Collectors.toSet()); final Collection applications = applicationMapper.mapToBaseApplicationList( - applicationService.findByIds(executionContext, applicationIds) + applicationService.findByIdsAndStatus(executionContext, applicationIds, ApplicationStatus.ACTIVE) ); applications.forEach(application -> subscriptions diff --git a/gravitee-apim-rest-api/gravitee-apim-rest-api-management-v2/gravitee-apim-rest-api-management-v2-rest/src/test/java/io/gravitee/rest/api/management/v2/rest/resource/api/ApiSubscriptionsResource_GetTest.java b/gravitee-apim-rest-api/gravitee-apim-rest-api-management-v2/gravitee-apim-rest-api-management-v2-rest/src/test/java/io/gravitee/rest/api/management/v2/rest/resource/api/ApiSubscriptionsResource_GetTest.java index 736781f979d..6bf6adbd4b3 100644 --- a/gravitee-apim-rest-api/gravitee-apim-rest-api-management-v2/gravitee-apim-rest-api-management-v2-rest/src/test/java/io/gravitee/rest/api/management/v2/rest/resource/api/ApiSubscriptionsResource_GetTest.java +++ b/gravitee-apim-rest-api/gravitee-apim-rest-api-management-v2/gravitee-apim-rest-api-management-v2-rest/src/test/java/io/gravitee/rest/api/management/v2/rest/resource/api/ApiSubscriptionsResource_GetTest.java @@ -31,6 +31,7 @@ import fixtures.PlanFixtures; import fixtures.SubscriptionFixtures; import fixtures.UserFixtures; +import io.gravitee.repository.management.model.ApplicationStatus; import io.gravitee.rest.api.management.v2.rest.model.Error; import io.gravitee.rest.api.management.v2.rest.model.Subscription; import io.gravitee.rest.api.model.SubscriptionEntity; @@ -139,9 +140,10 @@ public void should_return_subscription_with_expands() { .thenReturn(Set.of(PlanFixtures.aPlanEntityV4().toBuilder().id(PLAN).build())); when( - applicationService.findByIds( + applicationService.findByIdsAndStatus( eq(GraviteeContext.getExecutionContext()), - argThat(argument -> List.of(APPLICATION).containsAll(argument)) + argThat(argument -> List.of(APPLICATION).containsAll(argument)), + ApplicationStatus.ACTIVE ) ) .thenReturn(Set.of(ApplicationFixtures.anApplicationListItem().toBuilder().id(APPLICATION).build())); diff --git a/gravitee-apim-rest-api/gravitee-apim-rest-api-management-v2/gravitee-apim-rest-api-management-v2-rest/src/test/java/io/gravitee/rest/api/management/v2/rest/resource/api/ApiSubscriptionsResource_ListTest.java b/gravitee-apim-rest-api/gravitee-apim-rest-api-management-v2/gravitee-apim-rest-api-management-v2-rest/src/test/java/io/gravitee/rest/api/management/v2/rest/resource/api/ApiSubscriptionsResource_ListTest.java index 81ea3c2067c..08d34be7993 100644 --- a/gravitee-apim-rest-api/gravitee-apim-rest-api-management-v2/gravitee-apim-rest-api-management-v2-rest/src/test/java/io/gravitee/rest/api/management/v2/rest/resource/api/ApiSubscriptionsResource_ListTest.java +++ b/gravitee-apim-rest-api/gravitee-apim-rest-api-management-v2/gravitee-apim-rest-api-management-v2-rest/src/test/java/io/gravitee/rest/api/management/v2/rest/resource/api/ApiSubscriptionsResource_ListTest.java @@ -33,6 +33,7 @@ import fixtures.PlanFixtures; import fixtures.SubscriptionFixtures; import io.gravitee.common.data.domain.Page; +import io.gravitee.repository.management.model.ApplicationStatus; import io.gravitee.rest.api.management.v2.rest.model.Error; import io.gravitee.rest.api.management.v2.rest.model.Links; import io.gravitee.rest.api.management.v2.rest.model.Pagination; @@ -211,9 +212,10 @@ public void should_return_list_of_subscriptions_with_expands() { ) ); when( - applicationService.findByIds( + applicationService.findByIdsAndStatus( eq(GraviteeContext.getExecutionContext()), - argThat(argument -> List.of("application-1", "application-2").containsAll(argument)) + argThat(argument -> List.of("application-1", "application-2").containsAll(argument)), + ApplicationStatus.ACTIVE ) ) .thenReturn( diff --git a/gravitee-apim-rest-api/gravitee-apim-rest-api-portal/gravitee-apim-rest-api-portal-rest/src/main/java/io/gravitee/rest/api/portal/rest/resource/ApplicationsResource.java b/gravitee-apim-rest-api/gravitee-apim-rest-api-portal/gravitee-apim-rest-api-portal-rest/src/main/java/io/gravitee/rest/api/portal/rest/resource/ApplicationsResource.java index 58ee7d2b9cc..1bdf2fa6b8a 100644 --- a/gravitee-apim-rest-api/gravitee-apim-rest-api-portal/gravitee-apim-rest-api-portal-rest/src/main/java/io/gravitee/rest/api/portal/rest/resource/ApplicationsResource.java +++ b/gravitee-apim-rest-api/gravitee-apim-rest-api-portal/gravitee-apim-rest-api-portal-rest/src/main/java/io/gravitee/rest/api/portal/rest/resource/ApplicationsResource.java @@ -21,6 +21,7 @@ import io.gravitee.common.http.MediaType; import io.gravitee.repository.management.api.search.Order; +import io.gravitee.repository.management.model.ApplicationStatus; import io.gravitee.rest.api.model.ApiKeyMode; import io.gravitee.rest.api.model.ApplicationEntity; import io.gravitee.rest.api.model.NewApplicationEntity; @@ -242,7 +243,11 @@ protected List transformPageContent(final ExecutionContext executio return Collections.emptyList(); } - Set applicationListItems = applicationService.findByIds(executionContext, pageContent); + Set applicationListItems = applicationService.findByIdsAndStatus( + executionContext, + pageContent, + ApplicationStatus.ACTIVE + ); Comparator orderingComparator = Comparator.comparingInt(pageContent::indexOf); return applicationListItems diff --git a/gravitee-apim-rest-api/gravitee-apim-rest-api-portal/gravitee-apim-rest-api-portal-rest/src/test/java/io/gravitee/rest/api/portal/rest/resource/ApplicationsResourceTest.java b/gravitee-apim-rest-api/gravitee-apim-rest-api-portal/gravitee-apim-rest-api-portal-rest/src/test/java/io/gravitee/rest/api/portal/rest/resource/ApplicationsResourceTest.java index fa4666b6220..dd95df96450 100644 --- a/gravitee-apim-rest-api/gravitee-apim-rest-api-portal/gravitee-apim-rest-api-portal-rest/src/test/java/io/gravitee/rest/api/portal/rest/resource/ApplicationsResourceTest.java +++ b/gravitee-apim-rest-api/gravitee-apim-rest-api-portal/gravitee-apim-rest-api-portal-rest/src/test/java/io/gravitee/rest/api/portal/rest/resource/ApplicationsResourceTest.java @@ -22,6 +22,7 @@ import io.gravitee.common.http.HttpStatusCode; import io.gravitee.repository.management.api.search.Order; +import io.gravitee.repository.management.model.ApplicationStatus; import io.gravitee.rest.api.model.*; import io.gravitee.rest.api.model.application.ApplicationListItem; import io.gravitee.rest.api.model.application.ApplicationSettings; @@ -37,7 +38,6 @@ import jakarta.ws.rs.core.HttpHeaders; import jakarta.ws.rs.core.Response; import java.util.*; -import java.util.stream.Collectors; import org.junit.Before; import org.junit.Test; import org.mockito.ArgumentCaptor; @@ -73,14 +73,14 @@ public void init() { .findIdsByUser(eq(GraviteeContext.getExecutionContext()), any(), any()); doReturn(new HashSet<>(Arrays.asList(applicationA, applicationB))) .when(applicationService) - .findByIds(eq(GraviteeContext.getExecutionContext()), eq(Arrays.asList("A", "B"))); + .findByIdsAndStatus(eq(GraviteeContext.getExecutionContext()), eq(Arrays.asList("A", "B")), ApplicationStatus.ACTIVE); doReturn(new HashSet<>(Arrays.asList(applicationB, applicationA))) .when(applicationService) - .findByIds(eq(GraviteeContext.getExecutionContext()), eq(Arrays.asList("B", "A"))); + .findByIdsAndStatus(eq(GraviteeContext.getExecutionContext()), eq(Arrays.asList("B", "A")), ApplicationStatus.ACTIVE); doReturn(new HashSet<>(Arrays.asList(applicationB))) .when(applicationService) - .findByIds(eq(GraviteeContext.getExecutionContext()), eq(List.of("B"))); + .findByIdsAndStatus(eq(GraviteeContext.getExecutionContext()), eq(List.of("B")), ApplicationStatus.ACTIVE); doReturn(new Application().id("A").name("A")) .when(applicationMapper) @@ -149,7 +149,7 @@ public void shouldGetApplicationsOrderByName() { .findIdsByUser(eq(GraviteeContext.getExecutionContext()), any(), eq(sort)); doReturn(mockApplications) .when(applicationService) - .findByIds(eq(GraviteeContext.getExecutionContext()), eq(Arrays.asList("A", "B", "C", "D"))); + .findByIdsAndStatus(eq(GraviteeContext.getExecutionContext()), eq(Arrays.asList("A", "B", "C", "D")), ApplicationStatus.ACTIVE); doReturn(new Application().id("A").name("A")) .when(applicationMapper) diff --git a/gravitee-apim-rest-api/gravitee-apim-rest-api-service/src/main/java/io/gravitee/rest/api/service/ApplicationService.java b/gravitee-apim-rest-api/gravitee-apim-rest-api-service/src/main/java/io/gravitee/rest/api/service/ApplicationService.java index e9e9e2c1a2f..fd0f1422d6c 100644 --- a/gravitee-apim-rest-api/gravitee-apim-rest-api-service/src/main/java/io/gravitee/rest/api/service/ApplicationService.java +++ b/gravitee-apim-rest-api/gravitee-apim-rest-api-service/src/main/java/io/gravitee/rest/api/service/ApplicationService.java @@ -43,7 +43,11 @@ public interface ApplicationService { ApplicationEntity findById(final ExecutionContext executionContext, String applicationId); - Set findByIds(final ExecutionContext executionContext, Collection applicationIds); + Set findByIdsAndStatus( + final ExecutionContext executionContext, + Collection applicationIds, + ApplicationStatus applicationStatus + ); default Set findByUser(final ExecutionContext executionContext, String username) { return findByUser(executionContext, username, null); diff --git a/gravitee-apim-rest-api/gravitee-apim-rest-api-service/src/main/java/io/gravitee/rest/api/service/impl/ApplicationAlertServiceImpl.java b/gravitee-apim-rest-api/gravitee-apim-rest-api-service/src/main/java/io/gravitee/rest/api/service/impl/ApplicationAlertServiceImpl.java index 4ab88442c6a..04f240de47a 100644 --- a/gravitee-apim-rest-api/gravitee-apim-rest-api-service/src/main/java/io/gravitee/rest/api/service/impl/ApplicationAlertServiceImpl.java +++ b/gravitee-apim-rest-api/gravitee-apim-rest-api-service/src/main/java/io/gravitee/rest/api/service/impl/ApplicationAlertServiceImpl.java @@ -28,7 +28,7 @@ import io.gravitee.alert.api.trigger.Trigger; import io.gravitee.common.event.Event; import io.gravitee.notifier.api.Notification; -import io.gravitee.repository.management.api.AlertTriggerRepository; +import io.gravitee.repository.management.model.ApplicationStatus; import io.gravitee.rest.api.model.ApplicationEntity; import io.gravitee.rest.api.model.MembershipEntity; import io.gravitee.rest.api.model.MembershipReferenceType; @@ -51,7 +51,6 @@ import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.beans.factory.annotation.Value; -import org.springframework.context.annotation.Lazy; import org.springframework.scheduling.annotation.Async; import org.springframework.stereotype.Component; import org.springframework.util.CollectionUtils; @@ -320,7 +319,7 @@ private void updateAlertsRecipients(ApplicationAlertMembershipEvent alertMembers // get recipients for each application final Map> recipientsByApplicationId = applicationService - .findByIds(executionContext, new ArrayList<>(applicationIds)) + .findByIdsAndStatus(executionContext, new ArrayList<>(applicationIds), ApplicationStatus.ACTIVE) .stream() .collect( Collectors.toMap( diff --git a/gravitee-apim-rest-api/gravitee-apim-rest-api-service/src/main/java/io/gravitee/rest/api/service/impl/ApplicationServiceImpl.java b/gravitee-apim-rest-api/gravitee-apim-rest-api-service/src/main/java/io/gravitee/rest/api/service/impl/ApplicationServiceImpl.java index 622dbc9958d..56e940917a1 100644 --- a/gravitee-apim-rest-api/gravitee-apim-rest-api-service/src/main/java/io/gravitee/rest/api/service/impl/ApplicationServiceImpl.java +++ b/gravitee-apim-rest-api/gravitee-apim-rest-api-service/src/main/java/io/gravitee/rest/api/service/impl/ApplicationServiceImpl.java @@ -233,7 +233,11 @@ public ApplicationEntity findById(final ExecutionContext executionContext, Strin } @Override - public Set findByIds(final ExecutionContext executionContext, Collection applicationIds) { + public Set findByIdsAndStatus( + final ExecutionContext executionContext, + Collection applicationIds, + ApplicationStatus applicationStatus + ) { try { LOGGER.debug("Find application by IDs: {}", applicationIds); diff --git a/gravitee-apim-rest-api/gravitee-apim-rest-api-service/src/main/java/io/gravitee/rest/api/service/impl/MessageServiceImpl.java b/gravitee-apim-rest-api/gravitee-apim-rest-api-service/src/main/java/io/gravitee/rest/api/service/impl/MessageServiceImpl.java index 40ed848f190..f16b3852611 100644 --- a/gravitee-apim-rest-api/gravitee-apim-rest-api-service/src/main/java/io/gravitee/rest/api/service/impl/MessageServiceImpl.java +++ b/gravitee-apim-rest-api/gravitee-apim-rest-api-service/src/main/java/io/gravitee/rest/api/service/impl/MessageServiceImpl.java @@ -23,6 +23,7 @@ import io.gravitee.repository.management.api.SubscriptionRepository; import io.gravitee.repository.management.api.search.SubscriptionCriteria; import io.gravitee.repository.management.model.Api; +import io.gravitee.repository.management.model.ApplicationStatus; import io.gravitee.repository.management.model.Audit; import io.gravitee.repository.management.model.Subscription; import io.gravitee.rest.api.model.*; @@ -322,7 +323,7 @@ private Set getIndirectMemberIds(ExecutionContext context, List // get all indirect members List applicationsGroups = applicationService - .findByIds(context, applicationIds) + .findByIdsAndStatus(context, applicationIds, ApplicationStatus.ACTIVE) .stream() .filter(application -> application.getGroups() != null) .flatMap((ApplicationListItem applicationListItem) -> applicationListItem.getGroups().stream()) diff --git a/gravitee-apim-rest-api/gravitee-apim-rest-api-service/src/main/java/io/gravitee/rest/api/service/impl/SubscriptionServiceImpl.java b/gravitee-apim-rest-api/gravitee-apim-rest-api-service/src/main/java/io/gravitee/rest/api/service/impl/SubscriptionServiceImpl.java index a8791167cdc..0663b4562f7 100644 --- a/gravitee-apim-rest-api/gravitee-apim-rest-api-service/src/main/java/io/gravitee/rest/api/service/impl/SubscriptionServiceImpl.java +++ b/gravitee-apim-rest-api/gravitee-apim-rest-api-service/src/main/java/io/gravitee/rest/api/service/impl/SubscriptionServiceImpl.java @@ -1595,7 +1595,11 @@ public Metadata getMetadata(ExecutionContext executionContext, SubscriptionMetad .map(withApplications -> { Set appIds = subscriptions.stream().map(SubscriptionEntity::getApplication).collect(toSet()); return applicationService - .findByIds(new ExecutionContext(query.getOrganization(), query.getEnvironment()), appIds) + .findByIdsAndStatus( + new ExecutionContext(query.getOrganization(), query.getEnvironment()), + appIds, + ApplicationStatus.ACTIVE + ) .stream() .collect(toMap(ApplicationListItem::getId, Function.identity())); }); diff --git a/gravitee-apim-rest-api/gravitee-apim-rest-api-service/src/test/java/io/gravitee/rest/api/service/impl/ApplicationService_FindByIdsTest.java b/gravitee-apim-rest-api/gravitee-apim-rest-api-service/src/test/java/io/gravitee/rest/api/service/impl/ApplicationService_FindByIdsAndStatusTest.java similarity index 86% rename from gravitee-apim-rest-api/gravitee-apim-rest-api-service/src/test/java/io/gravitee/rest/api/service/impl/ApplicationService_FindByIdsTest.java rename to gravitee-apim-rest-api/gravitee-apim-rest-api-service/src/test/java/io/gravitee/rest/api/service/impl/ApplicationService_FindByIdsAndStatusTest.java index 161f1a3f7d8..6e93450df73 100644 --- a/gravitee-apim-rest-api/gravitee-apim-rest-api-service/src/test/java/io/gravitee/rest/api/service/impl/ApplicationService_FindByIdsTest.java +++ b/gravitee-apim-rest-api/gravitee-apim-rest-api-service/src/test/java/io/gravitee/rest/api/service/impl/ApplicationService_FindByIdsAndStatusTest.java @@ -53,7 +53,7 @@ * @author GraviteeSource Team */ @RunWith(MockitoJUnitRunner.class) -public class ApplicationService_FindByIdsTest { +public class ApplicationService_FindByIdsAndStatusTest { private static final List APPLICATION_IDS = Arrays.asList("id-app-1", "id-app-2"); @@ -114,7 +114,7 @@ public void tearDown() { } @Test - public void shouldFindByIds() throws TechnicalException { + public void shouldFindByIdsAndStatus() throws TechnicalException { ExecutionContext executionContext = GraviteeContext.getExecutionContext(); ApplicationCriteria criteria = new ApplicationCriteria.Builder() .ids(Sets.newHashSet(APPLICATION_IDS)) @@ -124,14 +124,18 @@ public void shouldFindByIds() throws TechnicalException { doReturn(new Page(Arrays.asList(app1, app2), 1, 2, 2)).when(applicationRepository).search(criteria, null); doReturn(2).when(primaryOwners).size(); - final Set applications = applicationService.findByIds(executionContext, APPLICATION_IDS); + final Set applications = applicationService.findByIdsAndStatus( + executionContext, + APPLICATION_IDS, + ApplicationStatus.ACTIVE + ); assertNotNull(applications); assertEquals(APPLICATION_IDS, applications.stream().map(ApplicationListItem::getId).collect(Collectors.toList())); } @Test - public void shouldFindByIdsWithDuplicatedIds() throws TechnicalException { + public void shouldFindByIdsAndStatusWithDuplicatedIdsAndStatus() throws TechnicalException { ExecutionContext executionContext = GraviteeContext.getExecutionContext(); ApplicationCriteria criteria = new ApplicationCriteria.Builder() .ids(Sets.newHashSet(APPLICATION_IDS)) @@ -142,9 +146,10 @@ public void shouldFindByIdsWithDuplicatedIds() throws TechnicalException { doReturn(new Page<>(Arrays.asList(app1, app2), 1, 2, 2)).when(applicationRepository).search(criteria, null); doReturn(2).when(primaryOwners).size(); - final Set applications = applicationService.findByIds( + final Set applications = applicationService.findByIdsAndStatus( executionContext, - List.of("id-app-1", "id-app-1", "id-app-2") + List.of("id-app-1", "id-app-1", "id-app-2"), + ApplicationStatus.ACTIVE ); assertNotNull(applications); @@ -152,7 +157,7 @@ public void shouldFindByIdsWithDuplicatedIds() throws TechnicalException { } @Test - public void shouldFindByIdsWithNoEnvironmentCriteria() throws TechnicalException { + public void shouldFindByIdsAndStatusWithNoEnvironmentCriteria() throws TechnicalException { ExecutionContext executionContext = new ExecutionContext("DEFAULT", null); ApplicationCriteria criteria = new ApplicationCriteria.Builder() .ids(Sets.newHashSet(APPLICATION_IDS)) @@ -161,17 +166,25 @@ public void shouldFindByIdsWithNoEnvironmentCriteria() throws TechnicalException doReturn(new Page(Arrays.asList(app1, app2), 1, 2, 2)).when(applicationRepository).search(criteria, null); doReturn(2).when(primaryOwners).size(); - final Set applications = applicationService.findByIds(executionContext, APPLICATION_IDS); + final Set applications = applicationService.findByIdsAndStatus( + executionContext, + APPLICATION_IDS, + ApplicationStatus.ACTIVE + ); assertNotNull(applications); assertEquals(APPLICATION_IDS, applications.stream().map(ApplicationListItem::getId).collect(Collectors.toList())); } @Test - public void shouldFindByIdsWithEmptySet() throws TechnicalException { + public void shouldFindByIdsAndStatusWithEmptySet() throws TechnicalException { ExecutionContext executionContext = GraviteeContext.getExecutionContext(); - final Set applications = applicationService.findByIds(executionContext, Collections.emptySet()); + final Set applications = applicationService.findByIdsAndStatus( + executionContext, + Collections.emptySet(), + ApplicationStatus.ACTIVE + ); assertNotNull(applications); assertTrue(applications.isEmpty()); @@ -188,7 +201,11 @@ public void shouldThrowsIfNoPrimaryOwner() throws TechnicalException { .build(); doReturn(new Page(Arrays.asList(app1, app2), 1, 2, 2)).when(applicationRepository).search(criteria, null); - final Set applications = applicationService.findByIds(GraviteeContext.getExecutionContext(), APPLICATION_IDS); + final Set applications = applicationService.findByIdsAndStatus( + GraviteeContext.getExecutionContext(), + APPLICATION_IDS, + ApplicationStatus.ACTIVE + ); assertNotNull(applications); assertEquals(APPLICATION_IDS, applications.stream().map(ApplicationListItem::getId).collect(Collectors.toList())); @@ -197,6 +214,6 @@ public void shouldThrowsIfNoPrimaryOwner() throws TechnicalException { @Test(expected = TechnicalManagementException.class) public void shouldThrowTechnicalManagementException() throws TechnicalException { when(applicationRepository.search(any(), any())).thenThrow(new TechnicalException()); - applicationService.findByIds(GraviteeContext.getExecutionContext(), APPLICATION_IDS); + applicationService.findByIdsAndStatus(GraviteeContext.getExecutionContext(), APPLICATION_IDS, ApplicationStatus.ACTIVE); } } diff --git a/gravitee-apim-rest-api/gravitee-apim-rest-api-service/src/test/java/io/gravitee/rest/api/service/impl/MessageService_GetRecipientIdsTest.java b/gravitee-apim-rest-api/gravitee-apim-rest-api-service/src/test/java/io/gravitee/rest/api/service/impl/MessageService_GetRecipientIdsTest.java index cbb63d35cfc..ae4104cb4c4 100644 --- a/gravitee-apim-rest-api/gravitee-apim-rest-api-service/src/test/java/io/gravitee/rest/api/service/impl/MessageService_GetRecipientIdsTest.java +++ b/gravitee-apim-rest-api/gravitee-apim-rest-api-service/src/test/java/io/gravitee/rest/api/service/impl/MessageService_GetRecipientIdsTest.java @@ -25,6 +25,7 @@ import io.gravitee.repository.management.api.SubscriptionRepository; import io.gravitee.repository.management.model.Api; import io.gravitee.repository.management.model.Application; +import io.gravitee.repository.management.model.ApplicationStatus; import io.gravitee.repository.management.model.Subscription; import io.gravitee.rest.api.model.*; import io.gravitee.rest.api.model.application.ApplicationListItem; @@ -253,7 +254,10 @@ public void shouldGetApiConsumersWithGroups() throws TechnicalException { ApplicationListItem appListItem = new ApplicationListItem(); appListItem.setId(app.getId()); appListItem.setGroups(app.getGroups()); - when(mockApplicationService.findByIds(GraviteeContext.getExecutionContext(), List.of(app.getId()))).thenReturn(Set.of(appListItem)); + when( + mockApplicationService.findByIdsAndStatus(GraviteeContext.getExecutionContext(), List.of(app.getId()), ApplicationStatus.ACTIVE) + ) + .thenReturn(Set.of(appListItem)); MembershipEntity membershipGroup = new MembershipEntity(); membershipGroup.setId("membership-group-id"); diff --git a/gravitee-apim-rest-api/gravitee-apim-rest-api-service/src/test/java/io/gravitee/rest/api/service/impl/SubscriptionServiceTest.java b/gravitee-apim-rest-api/gravitee-apim-rest-api-service/src/test/java/io/gravitee/rest/api/service/impl/SubscriptionServiceTest.java index 720fd611289..9a8475ff629 100644 --- a/gravitee-apim-rest-api/gravitee-apim-rest-api-service/src/test/java/io/gravitee/rest/api/service/impl/SubscriptionServiceTest.java +++ b/gravitee-apim-rest-api/gravitee-apim-rest-api-service/src/test/java/io/gravitee/rest/api/service/impl/SubscriptionServiceTest.java @@ -58,6 +58,7 @@ import io.gravitee.repository.management.api.SubscriptionRepository; import io.gravitee.repository.management.api.search.SubscriptionCriteria; import io.gravitee.repository.management.model.ApiKey; +import io.gravitee.repository.management.model.ApplicationStatus; import io.gravitee.repository.management.model.Subscription; import io.gravitee.rest.api.idp.api.authentication.UserDetails; import io.gravitee.rest.api.model.*; @@ -72,7 +73,6 @@ import io.gravitee.rest.api.model.v4.api.GenericApiEntity; import io.gravitee.rest.api.model.v4.plan.PlanMode; import io.gravitee.rest.api.service.ApiKeyService; -import io.gravitee.rest.api.service.ApiService; import io.gravitee.rest.api.service.ApplicationService; import io.gravitee.rest.api.service.AuditService; import io.gravitee.rest.api.service.GroupService; @@ -81,7 +81,6 @@ import io.gravitee.rest.api.service.ParameterService; import io.gravitee.rest.api.service.SubscriptionService; import io.gravitee.rest.api.service.UserService; -import io.gravitee.rest.api.service.common.ExecutionContext; import io.gravitee.rest.api.service.common.GraviteeContext; import io.gravitee.rest.api.service.exceptions.ApiKeyAlreadyExistingException; import io.gravitee.rest.api.service.exceptions.PlanAlreadyClosedException; @@ -1757,7 +1756,9 @@ public void shouldGetAllMetadataWithSubscriptions() { assertFalse(metadata.toMap().isEmpty()); assertNotNull(metadata); - Mockito.verify(applicationService, times(1)).findByIds(eq(GraviteeContext.getExecutionContext()), eq(Set.of(APPLICATION_ID))); + Mockito + .verify(applicationService, times(1)) + .findByIdsAndStatus(eq(GraviteeContext.getExecutionContext()), eq(Set.of(APPLICATION_ID)), ApplicationStatus.ACTIVE); Mockito .verify(apiSearchService, times(1)) .findGenericByEnvironmentAndIdIn(eq(GraviteeContext.getExecutionContext()), eq(Set.of(API_ID))); @@ -1784,7 +1785,9 @@ public void shouldGetEmptyMetadataWithSubscriptions() { Metadata metadata = subscriptionService.getMetadata(GraviteeContext.getExecutionContext(), query); assertNotNull(metadata); - Mockito.verify(applicationService, times(0)).findByIds(eq(GraviteeContext.getExecutionContext()), eq(Set.of(APPLICATION_ID))); + Mockito + .verify(applicationService, times(0)) + .findByIdsAndStatus(eq(GraviteeContext.getExecutionContext()), eq(Set.of(APPLICATION_ID)), ApplicationStatus.ACTIVE); Mockito .verify(apiSearchService, times(0)) .findGenericByEnvironmentAndIdIn(eq(GraviteeContext.getExecutionContext()), eq(Set.of(API_ID))); @@ -1813,7 +1816,9 @@ public void shouldFillApiMetadataAfterService() { assertFalse(metadata.toMap().isEmpty()); assertNotNull(metadata); - Mockito.verify(applicationService, times(0)).findByIds(eq(GraviteeContext.getExecutionContext()), eq(Set.of(APPLICATION_ID))); + Mockito + .verify(applicationService, times(0)) + .findByIdsAndStatus(eq(GraviteeContext.getExecutionContext()), eq(Set.of(APPLICATION_ID)), ApplicationStatus.ACTIVE); Mockito .verify(apiSearchService, times(1)) .findGenericByEnvironmentAndIdIn(eq(GraviteeContext.getExecutionContext()), eq(Set.of(API_ID)));