From 11e022eae3b211d8605813e6c46abeef9a68cdd3 Mon Sep 17 00:00:00 2001 From: Oleksandra Ishchuk Date: Wed, 17 Dec 2025 22:23:38 +0100 Subject: [PATCH 1/4] fix: Call access-control batchUpdateDataItems with external dataItemsIds --- .../AccessControlConfiguration.java | 4 +- .../stream/service/AccessGroupService.java | 97 +++++++++++---- .../service/AccessGroupServiceTest.java | 115 +++++++++++++++--- ...sGroupServiceUpdateFunctionGroupsTest.java | 4 +- 4 files changed, 179 insertions(+), 41 deletions(-) diff --git a/stream-access-control/access-control-core/src/main/java/com/backbase/stream/configuration/AccessControlConfiguration.java b/stream-access-control/access-control-core/src/main/java/com/backbase/stream/configuration/AccessControlConfiguration.java index 7b21e2d66..4842ee72a 100644 --- a/stream-access-control/access-control-core/src/main/java/com/backbase/stream/configuration/AccessControlConfiguration.java +++ b/stream-access-control/access-control-core/src/main/java/com/backbase/stream/configuration/AccessControlConfiguration.java @@ -7,6 +7,7 @@ import com.backbase.accesscontrol.permissioncheck.api.service.v1.PermissionCheckApi; import com.backbase.accesscontrol.serviceagreement.api.service.v1.ServiceAgreementApi; import com.backbase.accesscontrol.usercontext.api.service.v1.UserContextApi; +import com.backbase.dbs.arrangement.api.service.v3.ArrangementsApi; import com.backbase.dbs.user.api.service.v2.IdentityManagementApi; import com.backbase.dbs.user.api.service.v2.UserManagementApi; import com.backbase.dbs.user.profile.api.service.v2.UserProfileManagementApi; @@ -82,6 +83,7 @@ public CustomerAccessGroupService customerAccessGroupService(CustomerAccessGroup @Bean public AccessGroupService accessGroupService( UserManagementApi usersApi, + ArrangementsApi arrangementsApi, DeletionProperties configurationProperties, BatchResponseUtils batchResponseUtils, AccessControlConfigurationProperties accessControlConfigurationProperties, @@ -95,7 +97,7 @@ public AccessGroupService accessGroupService( AssignPermissionsApi assignPermissionsApi, com.backbase.accesscontrol.assignpermissions.api.integration.v1.AssignPermissionsApi assignPermissionsIntegrationApi, UserContextApi userContextApi) { - return new AccessGroupService(usersApi, batchResponseUtils, configurationProperties, + return new AccessGroupService(usersApi, arrangementsApi, batchResponseUtils, configurationProperties, accessControlConfigurationProperties, permissionCheckApi, dataGroupServiceApi, dataGroupIntegrationApi, functionGroupServiceApi, functionGroupIntegrationApi, diff --git a/stream-access-control/access-control-core/src/main/java/com/backbase/stream/service/AccessGroupService.java b/stream-access-control/access-control-core/src/main/java/com/backbase/stream/service/AccessGroupService.java index 2bcc23380..e41bf406f 100644 --- a/stream-access-control/access-control-core/src/main/java/com/backbase/stream/service/AccessGroupService.java +++ b/stream-access-control/access-control-core/src/main/java/com/backbase/stream/service/AccessGroupService.java @@ -42,6 +42,10 @@ import com.backbase.accesscontrol.serviceagreement.api.service.v1.model.ServiceAgreementParticipants; import com.backbase.accesscontrol.serviceagreement.api.service.v1.model.ServiceAgreementUpdateRequest; import com.backbase.accesscontrol.usercontext.api.service.v1.UserContextApi; +import com.backbase.dbs.arrangement.api.service.v3.ArrangementsApi; +import com.backbase.dbs.arrangement.api.service.v3.model.ArrangementItem; +import com.backbase.dbs.arrangement.api.service.v3.model.ArrangementSearchesListResponse; +import com.backbase.dbs.arrangement.api.service.v3.model.ArrangementsSearchesPostRequest; import com.backbase.dbs.user.api.service.v2.UserManagementApi; import com.backbase.dbs.user.api.service.v2.model.GetUser; import com.backbase.stream.configuration.AccessControlConfigurationProperties; @@ -126,6 +130,8 @@ public class AccessGroupService { @NonNull private final UserManagementApi usersApi; @NonNull + private final ArrangementsApi arrangementsApiService; + @NonNull private final BatchResponseUtils batchResponseUtils; @NonNull private final DeletionProperties deletionProperties; @@ -195,7 +201,6 @@ public Mono getServiceAgreementByExternalId(String externalId) } /** - * * @param streamTask * @param serviceAgreement * @return Service Agreement @@ -971,18 +976,48 @@ public Mono setupProductGroups(ProductGroupTask streamTask) { public Mono updateExistingDataGroupsBatch(BatchProductGroupTask task, List existingDataGroups, List productGroups) { List batchUpdateRequest = new ArrayList<>(); - final Set affectedArrangements = Stream.concat( - productGroups.stream().map(StreamUtils::getInternalProductIds).flatMap(List::stream), - productGroups.stream().map(BaseProductGroup::getCustomDataGroupItems).flatMap(List::stream) - .map(CustomDataGroupItem::getInternalId)) - .collect(Collectors.toSet()); + final Map affectedArrangementsInternalToExternalIds = Stream.concat( + productGroups.stream() + .flatMap(StreamUtils::getAllProducts) + .filter(Objects::nonNull) + .map(p -> new java.util.AbstractMap.SimpleEntry<>(p.getInternalId(), p.getExternalId())), + productGroups.stream() + .map(BaseProductGroup::getCustomDataGroupItems) + .filter(Objects::nonNull) + .flatMap(List::stream) + .map(i -> new java.util.AbstractMap.SimpleEntry<>(i.getInternalId(), i.getExternalId()))) + .filter(e -> e.getKey() != null && e.getValue() != null) + .collect(Collectors.toMap(Map.Entry::getKey, Map.Entry::getValue, (a, b) -> a)); + if (task.getIngestionMode().isDataGroupsReplaceEnabled()) { // if REPLACE mode, existing products (not sent in the request) also need to be added to the set of affected arrangements. - affectedArrangements.addAll(existingDataGroups.stream() + Set exitingArrangementInternalIds = existingDataGroups.stream() .map(DataGroup::getItems) + .filter(Objects::nonNull) .flatMap(Set::stream) - .collect(Collectors.toSet()) - ); + .collect(Collectors.toSet()); + // Fetch external ids for existing arrangements (used to call access-control api to add/remove data group items). + List existingArrangementItems = arrangementsApiService.postSearchArrangements( + new ArrangementsSearchesPostRequest() + .arrangementIds(exitingArrangementInternalIds) + .size(exitingArrangementInternalIds.size())) + .map(ArrangementSearchesListResponse::getArrangementElements) + .blockOptional() + .orElseGet(Collections::emptyList); + + if (existingArrangementItems.size() != exitingArrangementInternalIds.size()) { + log.debug("Arrangements from arrangement domain have size {} but expected {} for existing arrangements", + existingArrangementItems.size(), exitingArrangementInternalIds.size()); + } + + if (!CollectionUtils.isEmpty(existingArrangementItems)) { + existingArrangementItems.forEach(arrangementItem -> { + if (exitingArrangementInternalIds.contains(arrangementItem.getId())) { + affectedArrangementsInternalToExternalIds.put( + arrangementItem.getId(), arrangementItem.getExternalArrangementId()); + } + }); + } } existingDataGroups.forEach(dbsDataGroup -> { @@ -990,24 +1025,36 @@ public Mono updateExistingDataGroupsBatch(BatchProductGro Optional pg = productGroups.stream() .filter(it -> isEquals(it, dbsDataGroup)) .findFirst(); + // it should be external data item ids (both add and remove) Set arrangementsToAdd = new HashSet<>(); Set arrangementsToRemove = new HashSet<>(); - affectedArrangements.forEach(arrangement -> pg.ifPresent(p -> { - boolean shouldBeInGroup = StreamUtils.getInternalProductIds(pg.get()).contains(arrangement) || - pg.get().getCustomDataGroupItems().stream().map(CustomDataGroupItem::getInternalId) - .anyMatch(arrangement::equals); - if (!dbsDataGroup.getItems().contains(arrangement) && shouldBeInGroup) { - // ADD. - log.debug("Arrangement item {} to be added to Data Group {}", arrangement, dbsDataGroup.getName()); - arrangementsToAdd.add(arrangement); - } - if (dbsDataGroup.getItems().contains(arrangement) && !shouldBeInGroup) { - // remove. - log.debug("Arrangement item {} to be removed from Data Group {}", arrangement, - dbsDataGroup.getName()); - arrangementsToRemove.add(arrangement); - } - })); + affectedArrangementsInternalToExternalIds.keySet() + .forEach(arrangementInternalId -> pg.ifPresent(p -> { + boolean shouldBeInGroup = + StreamUtils.getInternalProductIds(pg.get()).contains(arrangementInternalId) || + pg.get().getCustomDataGroupItems().stream().map(CustomDataGroupItem::getInternalId) + .anyMatch(arrangementInternalId::equals); + if (!dbsDataGroup.getItems().contains(arrangementInternalId) + && affectedArrangementsInternalToExternalIds.containsKey(arrangementInternalId) + && shouldBeInGroup) { + // ADD. + String arrangementExternalId = affectedArrangementsInternalToExternalIds.get( + arrangementInternalId); + log.debug("Arrangement item {} with External Id {} to be added to Data Group {}", + arrangementInternalId, arrangementExternalId, dbsDataGroup.getName()); + arrangementsToAdd.add(arrangementExternalId); + } + if (dbsDataGroup.getItems().contains(arrangementInternalId) + && affectedArrangementsInternalToExternalIds.containsKey(arrangementInternalId) + && !shouldBeInGroup) { + // REMOVE. + String arrangementExternalId = affectedArrangementsInternalToExternalIds.get( + arrangementInternalId); + log.debug("Arrangement item {} with External Id {} to be removed from Data Group {}", + arrangementInternalId, arrangementExternalId, dbsDataGroup.getName()); + arrangementsToRemove.add(arrangementExternalId); + } + })); if (!CollectionUtils.isEmpty(arrangementsToAdd)) { batchUpdateRequest.add(new DataItemBatchUpdate() .dataGroupIdentifier(new DataGroupNameIdentifier() diff --git a/stream-access-control/access-control-core/src/test/java/com/backbase/stream/service/AccessGroupServiceTest.java b/stream-access-control/access-control-core/src/test/java/com/backbase/stream/service/AccessGroupServiceTest.java index 2f80c3cc0..ed2c2c661 100644 --- a/stream-access-control/access-control-core/src/test/java/com/backbase/stream/service/AccessGroupServiceTest.java +++ b/stream-access-control/access-control-core/src/test/java/com/backbase/stream/service/AccessGroupServiceTest.java @@ -61,6 +61,10 @@ import com.backbase.accesscontrol.usercontext.api.service.v1.UserContextApi; import com.backbase.accesscontrol.usercontext.api.service.v1.model.ContextServiceAgreement; import com.backbase.accesscontrol.usercontext.api.service.v1.model.GetContexts; +import com.backbase.dbs.arrangement.api.service.v3.ArrangementsApi; +import com.backbase.dbs.arrangement.api.service.v3.model.ArrangementItem; +import com.backbase.dbs.arrangement.api.service.v3.model.ArrangementSearchesListResponse; +import com.backbase.dbs.arrangement.api.service.v3.model.ArrangementsSearchesPostRequest; import com.backbase.dbs.user.api.service.v2.UserManagementApi; import com.backbase.stream.configuration.AccessControlConfigurationProperties; import com.backbase.stream.configuration.DeletionProperties; @@ -116,6 +120,7 @@ import reactor.core.publisher.Flux; import reactor.core.publisher.Mono; import reactor.test.StepVerifier; +import wiremock.org.checkerframework.common.value.qual.ArrayLenRange; @ExtendWith(MockitoExtension.class) class AccessGroupServiceTest { @@ -125,6 +130,8 @@ class AccessGroupServiceTest { @Mock private UserManagementApi usersApi; @Mock + ArrangementsApi arrangementsApi; + @Mock private PermissionCheckApi permissionCheckServiceApi; @Mock private DataGroupApi dataGroupServiceApi; @@ -815,6 +822,18 @@ void updateExistingDataGroupsBatchWithSameInDbsIngestionModeReplace() { "Repository Group Engagement Template Notification", BaseProductGroup.ProductGroupTypeEnum.REPOSITORIES, "engagement-template-notification"); + when(arrangementsApi.postSearchArrangements(any())) + .thenReturn( + Mono.just(new ArrangementSearchesListResponse() + .arrangementElements( + List.of( + new ArrangementItem().id("template-custom-test") + .externalArrangementId("template-custom-test-ext"), + new ArrangementItem().id("engagement-template-custom-test") + .externalArrangementId("engagement-template-custom-test-ext"), + new ArrangementItem().id("engagement-template-notification-test") + .externalArrangementId("engagement-template-notification-test-ext"))))); + // When subject.updateExistingDataGroupsBatch(batchProductGroupTask, List.of(dataGroupItemTemplateCustom, @@ -863,6 +882,18 @@ void updateExistingDataGroupsBatchWithMissingInDbsIngestionModeReplace() { .status(StatusEnum.HTTP_STATUS_OK) .resourceId("test-resource-id"))); + when(arrangementsApi.postSearchArrangements(any())) + .thenReturn( + Mono.just(new ArrangementSearchesListResponse() + .arrangementElements( + List.of( + new ArrangementItem().id("template-custom-test") + .externalArrangementId("template-custom-test-ext"), + new ArrangementItem().id("engagement-template-custom-test") + .externalArrangementId("engagement-template-custom-test-ext"), + new ArrangementItem().id("engagement-template-notification-test") + .externalArrangementId("engagement-template-notification-test-ext"))))); + // When subject.updateExistingDataGroupsBatch(batchProductGroupTask, List.of(dataGroupItemTemplateCustom, @@ -911,6 +942,19 @@ void updateExistingDataGroupsBatchWithIncorrectInDbsIngestionModeReplace() { "Repository Group Engagement Template Notification", "Repository Group Engagement Template Notification", BaseProductGroup.ProductGroupTypeEnum.REPOSITORIES, "engagement-template-notification"); + + when(arrangementsApi.postSearchArrangements(any())) + .thenReturn( + Mono.just(new ArrangementSearchesListResponse() + .arrangementElements( + List.of( + new ArrangementItem().id("template-custom-test") + .externalArrangementId("template-custom-test-ext"), + new ArrangementItem().id("engagement-template-custom-test") + .externalArrangementId("engagement-template-custom-test-ext"), + new ArrangementItem().id("engagement-template-notification-test") + .externalArrangementId("engagement-template-notification-test-ext"))))); + when(dataGroupIntegrationApi.batchUpdateDataItems(any())) .thenReturn( Flux.just(new com.backbase.accesscontrol.datagroup.api.integration.v1.model.BatchResponseItemExtended() @@ -933,22 +977,22 @@ void updateExistingDataGroupsBatchWithIncorrectInDbsIngestionModeReplace() { assertEquals(6, actions.size()); assertTrue( actionForItemIsPresent(actions, com.backbase.accesscontrol.datagroup.api.integration.v1.model.Action.REMOVE, - "template-custom-test")); + "template-custom-test-ext")); assertTrue( actionForItemIsPresent(actions, com.backbase.accesscontrol.datagroup.api.integration.v1.model.Action.REMOVE, - "engagement-template-custom-test")); + "engagement-template-custom-test-ext")); assertTrue( actionForItemIsPresent(actions, com.backbase.accesscontrol.datagroup.api.integration.v1.model.Action.REMOVE, - "engagement-template-notification-test")); + "engagement-template-notification-test-ext")); assertTrue( actionForItemIsPresent(actions, com.backbase.accesscontrol.datagroup.api.integration.v1.model.Action.ADD, - "template-custom")); + "template-custom-ext")); assertTrue( actionForItemIsPresent(actions, com.backbase.accesscontrol.datagroup.api.integration.v1.model.Action.ADD, - "engagement-template-custom")); + "engagement-template-custom-ext")); assertTrue( actionForItemIsPresent(actions, com.backbase.accesscontrol.datagroup.api.integration.v1.model.Action.ADD, - "engagement-template-notification")); + "engagement-template-notification-ext")); } @Test @@ -972,6 +1016,15 @@ void updateExistingDataGroupsDoesNotRemoveCustomDataGroups() { "rep desc", BaseProductGroup.ProductGroupTypeEnum.REPOSITORIES, "repository-dg-item2"); + when(arrangementsApi.postSearchArrangements(any())) + .thenReturn( + Mono.just(new ArrangementSearchesListResponse() + .arrangementElements( + List.of( + new ArrangementItem().id("custom-dg-item1").externalArrangementId("custom-dg-item1-ext"), + new ArrangementItem().id("custom-dg-item2").externalArrangementId("custom-dg-item2-ext"), + new ArrangementItem().id("repository-dg-item1").externalArrangementId("repository-dg-item1-ext"))))); + when(dataGroupIntegrationApi.batchUpdateDataItems(any())) .thenReturn( Flux.just(new com.backbase.accesscontrol.datagroup.api.integration.v1.model.BatchResponseItemExtended() @@ -991,23 +1044,23 @@ void updateExistingDataGroupsDoesNotRemoveCustomDataGroups() { assertTrue( actionForItemIsPresent(actions, com.backbase.accesscontrol.datagroup.api.integration.v1.model.Action.ADD, - "repository-dg-item2")); + "repository-dg-item2-ext")); assertTrue( actionForItemIsPresent(actions, com.backbase.accesscontrol.datagroup.api.integration.v1.model.Action.REMOVE, - "repository-dg-item1")); + "repository-dg-item1-ext")); // the following assertions is to test if for some reason "custom-dg-item1" and "custom-dg-item2" ended up paired with "repository-dg-item*" ;) assertFalse( actionForItemIsPresent(actions, com.backbase.accesscontrol.datagroup.api.integration.v1.model.Action.REMOVE, - "custom-dg-item1")); + "custom-dg-item1-ext")); assertFalse( actionForItemIsPresent(actions, com.backbase.accesscontrol.datagroup.api.integration.v1.model.Action.REMOVE, - "custom-dg-item2")); + "custom-dg-item2-ext")); assertFalse( actionForItemIsPresent(actions, com.backbase.accesscontrol.datagroup.api.integration.v1.model.Action.ADD, - "custom-dg-item1")); + "custom-dg-item1-ext")); assertFalse( actionForItemIsPresent(actions, com.backbase.accesscontrol.datagroup.api.integration.v1.model.Action.ADD, - "custom-dg-item2")); + "custom-dg-item2-ext")); } @Test @@ -1027,6 +1080,13 @@ void updateArrangementDataGroupsWhenArrangementAlreadyExists() { .addCurrentAccountsItem(new CurrentAccount().internalId("debitAccountInId").name("arrangement1") .externalId("debitAccountExId")); + when(arrangementsApi.postSearchArrangements(any())) + .thenReturn( + Mono.just(new ArrangementSearchesListResponse() + .arrangementElements( + List.of( + new ArrangementItem().id("debitAccountInId").externalArrangementId("debitAccountExId"))))); + subject.updateExistingDataGroupsBatch(batchProductGroupTask, List.of(existingDGroup), List.of(upsertProductGroupArrangement)) @@ -1047,6 +1107,13 @@ void updateArrangementDataGroupsWhenArrangementItemDoesNotExist() { DataGroup existingDGroup = new DataGroup().id("debitAccountInId1").name("arrangement1") .addItemsItem("debitAccountExId1").serviceAgreementId("saInId"); + when(arrangementsApi.postSearchArrangements(any())) + .thenReturn( + Mono.just(new ArrangementSearchesListResponse() + .arrangementElements( + List.of( + new ArrangementItem().id("debitAccountExId1").externalArrangementId("debitAccountExId1"))))); + when(dataGroupIntegrationApi.batchUpdateDataItems(any())) .thenReturn( Flux.just(new com.backbase.accesscontrol.datagroup.api.integration.v1.model.BatchResponseItemExtended() @@ -1070,7 +1137,7 @@ void updateArrangementDataGroupsWhenArrangementItemDoesNotExist() { assertEquals(2, actions.size()); assertTrue( actionForItemIsPresent(actions, com.backbase.accesscontrol.datagroup.api.integration.v1.model.Action.ADD, - "debitAccountInId2")); + "debitAccountExId2")); assertTrue( actionForItemIsPresent(actions, com.backbase.accesscontrol.datagroup.api.integration.v1.model.Action.REMOVE, "debitAccountExId1")); @@ -1091,6 +1158,14 @@ void updateExistingDataGroupsHandleError() { BaseProductGroup upsertProductGroupCustom = buildBaseProductGroup("Custom data group item", "custom desc", ProductGroupTypeEnum.CUSTOM, "custom-dg-item2"); + + when(arrangementsApi.postSearchArrangements(any())) + .thenReturn( + Mono.just(new ArrangementSearchesListResponse() + .arrangementElements( + List.of( + new ArrangementItem().id("custom-dg-item1").externalArrangementId("custom-dg-item1-ext"))))); + when(dataGroupIntegrationApi.batchUpdateDataItems(any())).thenReturn( Flux.error(WebClientResponseException.create(500, "Internal error", null, null, null, null))); @@ -1121,6 +1196,18 @@ void updateExistingDataGroupsBatchWithEmptyDbsIngestionModeReplace() { "Repository Group Engagement Template Notification", BaseProductGroup.ProductGroupTypeEnum.REPOSITORIES, "engagement-template-notification"); + when(arrangementsApi.postSearchArrangements(any())) + .thenReturn( + Mono.just(new ArrangementSearchesListResponse() + .arrangementElements( + List.of( + new ArrangementItem().id("template-custom-test") + .externalArrangementId("template-custom-test-ext"), + new ArrangementItem().id("engagement-template-custom-test") + .externalArrangementId("engagement-template-custom-test-ext"), + new ArrangementItem().id("engagement-template-notification-test") + .externalArrangementId("engagement-template-notification-test-ext"))))); + // When subject.updateExistingDataGroupsBatch(batchProductGroupTask, List.of(), @@ -1469,7 +1556,7 @@ private BaseProductGroup buildBaseProductGroup(String name, String description, productGroup.setDescription(description); productGroup.setProductGroupType(productGroupTypeEnum); productGroup.setCustomDataGroupItems(Arrays.stream(dataGroupItemId) - .map(dgi -> new CustomDataGroupItem().internalId(dgi).externalId(dgi)).toList()); + .map(dgi -> new CustomDataGroupItem().internalId(dgi).externalId(dgi + "-ext")).toList()); return productGroup; } diff --git a/stream-access-control/access-control-core/src/test/java/com/backbase/stream/service/AccessGroupServiceUpdateFunctionGroupsTest.java b/stream-access-control/access-control-core/src/test/java/com/backbase/stream/service/AccessGroupServiceUpdateFunctionGroupsTest.java index 45086616a..43e6c03c6 100644 --- a/stream-access-control/access-control-core/src/test/java/com/backbase/stream/service/AccessGroupServiceUpdateFunctionGroupsTest.java +++ b/stream-access-control/access-control-core/src/test/java/com/backbase/stream/service/AccessGroupServiceUpdateFunctionGroupsTest.java @@ -19,6 +19,7 @@ import com.backbase.accesscontrol.permissioncheck.api.service.v1.PermissionCheckApi; import com.backbase.accesscontrol.serviceagreement.api.service.v1.ServiceAgreementApi; import com.backbase.accesscontrol.usercontext.api.service.v1.UserContextApi; +import com.backbase.dbs.arrangement.api.service.v3.ArrangementsApi; import com.backbase.dbs.user.api.service.v2.UserManagementApi; import com.backbase.stream.configuration.AccessControlConfigurationProperties; import com.backbase.stream.configuration.DeletionProperties; @@ -34,7 +35,6 @@ import java.time.LocalDateTime; import java.time.OffsetDateTime; import java.time.ZoneOffset; -import java.util.Arrays; import java.util.Collections; import java.util.List; import java.util.Map; @@ -60,6 +60,8 @@ class AccessGroupServiceUpdateFunctionGroupsTest { @Mock private UserManagementApi usersApi; @Mock + private ArrangementsApi arrangementsApi; + @Mock private PermissionCheckApi permissionCheckServiceApi; @Mock private DataGroupApi dataGroupServiceApi; From 71067e039d5ecf5bda87d8b184376c76d8cab89f Mon Sep 17 00:00:00 2001 From: Oleksandra Ishchuk Date: Thu, 18 Dec 2025 16:00:07 +0100 Subject: [PATCH 2/4] Make implementation more reactive --- .../stream/service/AccessGroupService.java | 160 +++++++++--------- .../service/AccessGroupServiceTest.java | 26 +-- 2 files changed, 79 insertions(+), 107 deletions(-) diff --git a/stream-access-control/access-control-core/src/main/java/com/backbase/stream/service/AccessGroupService.java b/stream-access-control/access-control-core/src/main/java/com/backbase/stream/service/AccessGroupService.java index e41bf406f..913a4e289 100644 --- a/stream-access-control/access-control-core/src/main/java/com/backbase/stream/service/AccessGroupService.java +++ b/stream-access-control/access-control-core/src/main/java/com/backbase/stream/service/AccessGroupService.java @@ -82,6 +82,7 @@ import java.util.Collection; import java.util.Collections; import java.util.EnumMap; +import java.util.HashMap; import java.util.HashSet; import java.util.List; import java.util.Map; @@ -989,94 +990,92 @@ public Mono updateExistingDataGroupsBatch(BatchProductGro .filter(e -> e.getKey() != null && e.getValue() != null) .collect(Collectors.toMap(Map.Entry::getKey, Map.Entry::getValue, (a, b) -> a)); - if (task.getIngestionMode().isDataGroupsReplaceEnabled()) { + Mono> affectedArrangementsMono = // if REPLACE mode, existing products (not sent in the request) also need to be added to the set of affected arrangements. - Set exitingArrangementInternalIds = existingDataGroups.stream() - .map(DataGroup::getItems) - .filter(Objects::nonNull) - .flatMap(Set::stream) - .collect(Collectors.toSet()); - // Fetch external ids for existing arrangements (used to call access-control api to add/remove data group items). - List existingArrangementItems = arrangementsApiService.postSearchArrangements( - new ArrangementsSearchesPostRequest() - .arrangementIds(exitingArrangementInternalIds) - .size(exitingArrangementInternalIds.size())) - .map(ArrangementSearchesListResponse::getArrangementElements) - .blockOptional() - .orElseGet(Collections::emptyList); - - if (existingArrangementItems.size() != exitingArrangementInternalIds.size()) { - log.debug("Arrangements from arrangement domain have size {} but expected {} for existing arrangements", - existingArrangementItems.size(), exitingArrangementInternalIds.size()); - } - - if (!CollectionUtils.isEmpty(existingArrangementItems)) { - existingArrangementItems.forEach(arrangementItem -> { - if (exitingArrangementInternalIds.contains(arrangementItem.getId())) { - affectedArrangementsInternalToExternalIds.put( - arrangementItem.getId(), arrangementItem.getExternalArrangementId()); + task.getIngestionMode().isDataGroupsReplaceEnabled() + ? Mono.defer(() -> { + Set existingInternalIds = existingDataGroups.stream() + .map(DataGroup::getItems) + .filter(Objects::nonNull) + .flatMap(Set::stream) + .collect(Collectors.toSet()); + if (existingInternalIds.isEmpty()) { + return Mono.just(affectedArrangementsInternalToExternalIds); } - }); + // Fetch external ids for existing arrangements (used to call access-control api to add/remove data group items). + return arrangementsApiService.postSearchArrangements( + new ArrangementsSearchesPostRequest() + .arrangementIds(existingInternalIds) + .size(existingInternalIds.size())) + .map(ArrangementSearchesListResponse::getArrangementElements) + .defaultIfEmpty(Collections.emptyList()) + .map(items -> { + Map merged = new HashMap<>(affectedArrangementsInternalToExternalIds); + items.forEach(item -> { + if (existingInternalIds.contains(item.getId())) { + merged.putIfAbsent(item.getId(), item.getExternalArrangementId()); + } + }); + return merged; + }); } - } - - existingDataGroups.forEach(dbsDataGroup -> { - // get group matching DBS one. - Optional pg = productGroups.stream() - .filter(it -> isEquals(it, dbsDataGroup)) - .findFirst(); - // it should be external data item ids (both add and remove) - Set arrangementsToAdd = new HashSet<>(); - Set arrangementsToRemove = new HashSet<>(); - affectedArrangementsInternalToExternalIds.keySet() - .forEach(arrangementInternalId -> pg.ifPresent(p -> { + ) : Mono.just(affectedArrangementsInternalToExternalIds); + + return affectedArrangementsMono.flatMap(affectedArrangements -> { + existingDataGroups.forEach(dbsDataGroup -> { + // get group matching DBS one. + Optional pg = productGroups.stream() + .filter(it -> isEquals(it, dbsDataGroup)) + .findFirst(); + // it should be external data item ids (both add and remove) + Set arrangementsToAdd = new HashSet<>(); + Set arrangementsToRemove = new HashSet<>(); + affectedArrangements.forEach((internalId, externalId) -> { boolean shouldBeInGroup = - StreamUtils.getInternalProductIds(pg.get()).contains(arrangementInternalId) || - pg.get().getCustomDataGroupItems().stream().map(CustomDataGroupItem::getInternalId) - .anyMatch(arrangementInternalId::equals); - if (!dbsDataGroup.getItems().contains(arrangementInternalId) - && affectedArrangementsInternalToExternalIds.containsKey(arrangementInternalId) - && shouldBeInGroup) { + StreamUtils.getInternalProductIds(pg.get()).contains(internalId) || + pg.get().getCustomDataGroupItems().stream() + .map(CustomDataGroupItem::getInternalId) + .anyMatch(internalId::equals); + if (dbsDataGroup.getItems() != null && !dbsDataGroup.getItems().contains(internalId) && shouldBeInGroup) { // ADD. - String arrangementExternalId = affectedArrangementsInternalToExternalIds.get( - arrangementInternalId); log.debug("Arrangement item {} with External Id {} to be added to Data Group {}", - arrangementInternalId, arrangementExternalId, dbsDataGroup.getName()); - arrangementsToAdd.add(arrangementExternalId); + internalId, externalId, dbsDataGroup.getName()); + arrangementsToAdd.add(externalId); } - if (dbsDataGroup.getItems().contains(arrangementInternalId) - && affectedArrangementsInternalToExternalIds.containsKey(arrangementInternalId) - && !shouldBeInGroup) { + if (dbsDataGroup.getItems().contains(internalId) && !shouldBeInGroup) { // REMOVE. - String arrangementExternalId = affectedArrangementsInternalToExternalIds.get( - arrangementInternalId); log.debug("Arrangement item {} with External Id {} to be removed from Data Group {}", - arrangementInternalId, arrangementExternalId, dbsDataGroup.getName()); - arrangementsToRemove.add(arrangementExternalId); + internalId, externalId, dbsDataGroup.getName()); + arrangementsToRemove.add(externalId); } - })); - if (!CollectionUtils.isEmpty(arrangementsToAdd)) { - batchUpdateRequest.add(new DataItemBatchUpdate() - .dataGroupIdentifier(new DataGroupNameIdentifier() - .name(dbsDataGroup.getName()) - .dataGroupType(dbsDataGroup.getType()) - .externalServiceAgreementId(task.getData().getServiceAgreement().getExternalId())) - .action(Action.ADD) - .dataItems(arrangementsToAdd) - ); - } - if (!CollectionUtils.isEmpty(arrangementsToRemove)) { - batchUpdateRequest.add(new DataItemBatchUpdate() - .dataGroupIdentifier(new DataGroupNameIdentifier() - .name(dbsDataGroup.getName()) - .dataGroupType(dbsDataGroup.getType()) - .externalServiceAgreementId(task.getData().getServiceAgreement().getExternalId())) - .action(Action.REMOVE) - .dataItems(arrangementsToRemove) - ); + }); + if (!CollectionUtils.isEmpty(arrangementsToAdd)) { + batchUpdateRequest.add(new DataItemBatchUpdate() + .dataGroupIdentifier(new DataGroupNameIdentifier() + .name(dbsDataGroup.getName()) + .dataGroupType(dbsDataGroup.getType()) + .externalServiceAgreementId(task.getData().getServiceAgreement().getExternalId())) + .action(Action.ADD) + .dataItems(arrangementsToAdd) + ); + } + if (!CollectionUtils.isEmpty(arrangementsToRemove)) { + batchUpdateRequest.add(new DataItemBatchUpdate() + .dataGroupIdentifier(new DataGroupNameIdentifier() + .name(dbsDataGroup.getName()) + .dataGroupType(dbsDataGroup.getType()) + .externalServiceAgreementId(task.getData().getServiceAgreement().getExternalId())) + .action(Action.REMOVE) + .dataItems(arrangementsToRemove) + ); + } + }); + if (CollectionUtils.isEmpty(batchUpdateRequest)) { + log.debug("All Product Groups are up to date."); + task.info(ACCESS_GROUP, "update", "SUCCESS", prettyPrintProductGroupNames(task), null, + "All Product Groups are up to date."); + return Mono.just(task); } - }); - if (!CollectionUtils.isEmpty(batchUpdateRequest)) { return updateDataGroupItems(batchUpdateRequest) .doOnNext(response -> task.info(ACCESS_GROUP, "update", response.getStatus().toString(), response.getResourceId(), null, @@ -1092,12 +1091,7 @@ public Mono updateExistingDataGroupsBatch(BatchProductGro }) .collectList() .thenReturn(task); - } else { - log.debug("All Product Groups are up to date."); - task.info(ACCESS_GROUP, "update", "SUCCESS", prettyPrintProductGroupNames(task), null, - "All Product Groups are up to date."); - return Mono.just(task); - } + }); } @NotNull diff --git a/stream-access-control/access-control-core/src/test/java/com/backbase/stream/service/AccessGroupServiceTest.java b/stream-access-control/access-control-core/src/test/java/com/backbase/stream/service/AccessGroupServiceTest.java index ed2c2c661..b84232d46 100644 --- a/stream-access-control/access-control-core/src/test/java/com/backbase/stream/service/AccessGroupServiceTest.java +++ b/stream-access-control/access-control-core/src/test/java/com/backbase/stream/service/AccessGroupServiceTest.java @@ -16,6 +16,7 @@ import static org.mockito.Mockito.never; import static org.mockito.Mockito.times; import static org.mockito.Mockito.verify; +import static org.mockito.Mockito.verifyNoInteractions; import static org.mockito.Mockito.when; import static org.springframework.http.HttpStatus.BAD_REQUEST; @@ -882,18 +883,6 @@ void updateExistingDataGroupsBatchWithMissingInDbsIngestionModeReplace() { .status(StatusEnum.HTTP_STATUS_OK) .resourceId("test-resource-id"))); - when(arrangementsApi.postSearchArrangements(any())) - .thenReturn( - Mono.just(new ArrangementSearchesListResponse() - .arrangementElements( - List.of( - new ArrangementItem().id("template-custom-test") - .externalArrangementId("template-custom-test-ext"), - new ArrangementItem().id("engagement-template-custom-test") - .externalArrangementId("engagement-template-custom-test-ext"), - new ArrangementItem().id("engagement-template-notification-test") - .externalArrangementId("engagement-template-notification-test-ext"))))); - // When subject.updateExistingDataGroupsBatch(batchProductGroupTask, List.of(dataGroupItemTemplateCustom, @@ -1196,18 +1185,6 @@ void updateExistingDataGroupsBatchWithEmptyDbsIngestionModeReplace() { "Repository Group Engagement Template Notification", BaseProductGroup.ProductGroupTypeEnum.REPOSITORIES, "engagement-template-notification"); - when(arrangementsApi.postSearchArrangements(any())) - .thenReturn( - Mono.just(new ArrangementSearchesListResponse() - .arrangementElements( - List.of( - new ArrangementItem().id("template-custom-test") - .externalArrangementId("template-custom-test-ext"), - new ArrangementItem().id("engagement-template-custom-test") - .externalArrangementId("engagement-template-custom-test-ext"), - new ArrangementItem().id("engagement-template-notification-test") - .externalArrangementId("engagement-template-notification-test-ext"))))); - // When subject.updateExistingDataGroupsBatch(batchProductGroupTask, List.of(), @@ -1218,6 +1195,7 @@ void updateExistingDataGroupsBatchWithEmptyDbsIngestionModeReplace() { // Then verify(dataGroupIntegrationApi, times(0)).batchUpdateDataItems(any()); + verifyNoInteractions(arrangementsApi); } From 7955d98620d2be2e059ed55c7b73ec2b1bc348b1 Mon Sep 17 00:00:00 2001 From: Oleksandra Ishchuk Date: Thu, 18 Dec 2025 16:09:47 +0100 Subject: [PATCH 3/4] Bump version to 9.1.0 --- pom.xml | 2 +- stream-access-control/access-control-core/pom.xml | 2 +- stream-access-control/pom.xml | 2 +- stream-approvals/approvals-bootstrap-task/pom.xml | 2 +- stream-approvals/approvals-core/pom.xml | 2 +- stream-approvals/pom.xml | 2 +- stream-audiences/audiences-core/pom.xml | 2 +- stream-audiences/pom.xml | 2 +- stream-compositions/api/cursors-api/pom.xml | 2 +- .../api/cursors-api/transaction-cursor-api/pom.xml | 2 +- .../api/integrations-api/legal-entity-integration-api/pom.xml | 2 +- .../integrations-api/payment-order-integration-api/pom.xml | 2 +- stream-compositions/api/integrations-api/pom.xml | 2 +- .../integrations-api/product-catalog-integration-api/pom.xml | 2 +- .../api/integrations-api/product-integration-api/pom.xml | 2 +- .../api/integrations-api/transaction-integration-api/pom.xml | 2 +- stream-compositions/api/pom.xml | 2 +- .../api/service-api/legal-entity-composition-api/pom.xml | 2 +- .../api/service-api/payment-order-composition-api/pom.xml | 2 +- stream-compositions/api/service-api/pom.xml | 2 +- .../api/service-api/product-catalog-composition-api/pom.xml | 2 +- .../api/service-api/product-composition-api/pom.xml | 2 +- .../api/service-api/transaction-composition-api/pom.xml | 2 +- stream-compositions/cursors/pom.xml | 2 +- stream-compositions/cursors/transaction-cursor/pom.xml | 2 +- stream-compositions/events/grandcentral/pom.xml | 2 +- stream-compositions/events/legal-entity-egress/pom.xml | 2 +- stream-compositions/events/legal-entity-ingress/pom.xml | 2 +- stream-compositions/events/pom.xml | 2 +- stream-compositions/events/product-catalog-egress/pom.xml | 2 +- stream-compositions/events/product-catalog-ingress/pom.xml | 2 +- stream-compositions/events/product-egress/pom.xml | 2 +- stream-compositions/events/product-ingress/pom.xml | 2 +- stream-compositions/events/transaction-egress/pom.xml | 2 +- stream-compositions/events/transaction-ingress/pom.xml | 2 +- stream-compositions/pom.xml | 4 ++-- .../services/legal-entity-composition-service/pom.xml | 2 +- .../services/payment-order-composition-service/pom.xml | 2 +- stream-compositions/services/pom.xml | 2 +- .../services/product-catalog-composition-service/pom.xml | 2 +- .../services/product-composition-service/pom.xml | 2 +- .../services/transaction-composition-service/pom.xml | 2 +- stream-compositions/test-utils/pom.xml | 2 +- stream-contacts/contacts-core/pom.xml | 2 +- stream-contacts/pom.xml | 2 +- stream-cursor/cursor-core/pom.xml | 2 +- stream-cursor/cursor-http/pom.xml | 2 +- stream-cursor/cursor-publishers/pom.xml | 2 +- stream-cursor/cursor-store/pom.xml | 2 +- stream-cursor/pom.xml | 2 +- stream-customer-profile/customer-profile-core/pom.xml | 2 +- stream-customer-profile/pom.xml | 2 +- stream-dbs-clients/pom.xml | 2 +- stream-investment/investment-core/pom.xml | 2 +- stream-investment/pom.xml | 2 +- stream-legal-entity/legal-entity-bootstrap-task/pom.xml | 2 +- stream-legal-entity/legal-entity-core/pom.xml | 2 +- stream-legal-entity/legal-entity-http/pom.xml | 2 +- stream-legal-entity/pom.xml | 2 +- stream-limits/limits-core/pom.xml | 2 +- stream-limits/pom.xml | 2 +- stream-loans/loans-core/pom.xml | 2 +- stream-loans/pom.xml | 2 +- stream-models/approval-model/pom.xml | 2 +- stream-models/legal-entity-model/pom.xml | 2 +- stream-models/pom.xml | 2 +- stream-models/portfolio-model/pom.xml | 2 +- stream-models/product-catalog-model/pom.xml | 2 +- stream-payment-order/payment-order-core/pom.xml | 2 +- stream-payment-order/pom.xml | 2 +- stream-plan-manager/plan-manager-core/pom.xml | 2 +- stream-plan-manager/pom.xml | 2 +- stream-portfolio/pom.xml | 2 +- stream-portfolio/portfolio-bootstrap-task/pom.xml | 2 +- stream-portfolio/portfolio-core/pom.xml | 2 +- stream-portfolio/portfolio-http/pom.xml | 2 +- stream-product-catalog/pom.xml | 2 +- stream-product-catalog/product-catalog-core/pom.xml | 2 +- stream-product-catalog/product-catalog-http/pom.xml | 2 +- stream-product-catalog/product-catalog-task/pom.xml | 2 +- stream-product/pom.xml | 2 +- stream-product/product-core/pom.xml | 2 +- stream-product/product-ingestion-saga/pom.xml | 2 +- stream-sdk/pom.xml | 2 +- stream-sdk/stream-parent/pom.xml | 2 +- stream-sdk/stream-parent/stream-context-propagation/pom.xml | 2 +- stream-sdk/stream-parent/stream-dbs-web-client/pom.xml | 2 +- stream-sdk/stream-parent/stream-openapi-support/pom.xml | 2 +- stream-sdk/stream-parent/stream-test-support/pom.xml | 2 +- stream-sdk/stream-parent/stream-worker/pom.xml | 2 +- stream-sdk/stream-starter-parents/pom.xml | 2 +- .../stream-starter-parents/stream-http-starter-parent/pom.xml | 4 ++-- .../stream-starter-parents/stream-task-starter-parent/pom.xml | 4 ++-- stream-sdk/stream-starter/pom.xml | 2 +- stream-transactions/pom.xml | 2 +- stream-transactions/transactions-core/pom.xml | 2 +- stream-transactions/transactions-item-writer/pom.xml | 2 +- 97 files changed, 100 insertions(+), 100 deletions(-) diff --git a/pom.xml b/pom.xml index 71d63a6c7..94b85aaa3 100644 --- a/pom.xml +++ b/pom.xml @@ -11,7 +11,7 @@ com.backbase.stream stream-services - 8.11.1 + 9.1.0 pom Stream :: Services diff --git a/stream-access-control/access-control-core/pom.xml b/stream-access-control/access-control-core/pom.xml index 9dd9287a3..a2a60cdb9 100644 --- a/stream-access-control/access-control-core/pom.xml +++ b/stream-access-control/access-control-core/pom.xml @@ -5,7 +5,7 @@ com.backbase.stream stream-access-control - 8.11.1 + 9.1.0 access-control-core diff --git a/stream-access-control/pom.xml b/stream-access-control/pom.xml index e7d6af717..72e2cbda7 100644 --- a/stream-access-control/pom.xml +++ b/stream-access-control/pom.xml @@ -5,7 +5,7 @@ com.backbase.stream stream-services - 8.11.1 + 9.1.0 stream-access-control diff --git a/stream-approvals/approvals-bootstrap-task/pom.xml b/stream-approvals/approvals-bootstrap-task/pom.xml index 96daa9375..eda122355 100644 --- a/stream-approvals/approvals-bootstrap-task/pom.xml +++ b/stream-approvals/approvals-bootstrap-task/pom.xml @@ -5,7 +5,7 @@ com.backbase.stream stream-task-starter-parent - 8.11.1 + 9.1.0 ../../stream-sdk/stream-starter-parents/stream-task-starter-parent diff --git a/stream-approvals/approvals-core/pom.xml b/stream-approvals/approvals-core/pom.xml index 031f4df75..054977057 100644 --- a/stream-approvals/approvals-core/pom.xml +++ b/stream-approvals/approvals-core/pom.xml @@ -5,7 +5,7 @@ com.backbase.stream stream-approvals - 8.11.1 + 9.1.0 approvals-core diff --git a/stream-approvals/pom.xml b/stream-approvals/pom.xml index 0cca5e9c3..06c4faa9f 100644 --- a/stream-approvals/pom.xml +++ b/stream-approvals/pom.xml @@ -5,7 +5,7 @@ com.backbase.stream stream-services - 8.11.1 + 9.1.0 stream-approvals diff --git a/stream-audiences/audiences-core/pom.xml b/stream-audiences/audiences-core/pom.xml index aae5f368b..b6fda4920 100644 --- a/stream-audiences/audiences-core/pom.xml +++ b/stream-audiences/audiences-core/pom.xml @@ -5,7 +5,7 @@ com.backbase.stream stream-audiences - 8.11.1 + 9.1.0 audiences-core diff --git a/stream-audiences/pom.xml b/stream-audiences/pom.xml index a6826922e..ed47f4a9c 100644 --- a/stream-audiences/pom.xml +++ b/stream-audiences/pom.xml @@ -5,7 +5,7 @@ com.backbase.stream stream-services - 8.11.1 + 9.1.0 stream-audiences diff --git a/stream-compositions/api/cursors-api/pom.xml b/stream-compositions/api/cursors-api/pom.xml index 0f59f7180..4e1295243 100644 --- a/stream-compositions/api/cursors-api/pom.xml +++ b/stream-compositions/api/cursors-api/pom.xml @@ -5,7 +5,7 @@ api com.backbase.stream.compositions - 8.11.1 + 9.1.0 cursors-api diff --git a/stream-compositions/api/cursors-api/transaction-cursor-api/pom.xml b/stream-compositions/api/cursors-api/transaction-cursor-api/pom.xml index a924e9c98..7b9cec383 100644 --- a/stream-compositions/api/cursors-api/transaction-cursor-api/pom.xml +++ b/stream-compositions/api/cursors-api/transaction-cursor-api/pom.xml @@ -5,7 +5,7 @@ cursors-api com.backbase.stream.compositions - 8.11.1 + 9.1.0 4.0.0 diff --git a/stream-compositions/api/integrations-api/legal-entity-integration-api/pom.xml b/stream-compositions/api/integrations-api/legal-entity-integration-api/pom.xml index f2ec80dc9..1b9355d1e 100644 --- a/stream-compositions/api/integrations-api/legal-entity-integration-api/pom.xml +++ b/stream-compositions/api/integrations-api/legal-entity-integration-api/pom.xml @@ -6,7 +6,7 @@ integrations-api com.backbase.stream.compositions - 8.11.1 + 9.1.0 com.backbase.stream.compositions.api diff --git a/stream-compositions/api/integrations-api/payment-order-integration-api/pom.xml b/stream-compositions/api/integrations-api/payment-order-integration-api/pom.xml index 7202e0359..45b6181e6 100644 --- a/stream-compositions/api/integrations-api/payment-order-integration-api/pom.xml +++ b/stream-compositions/api/integrations-api/payment-order-integration-api/pom.xml @@ -6,7 +6,7 @@ integrations-api com.backbase.stream.compositions - 8.11.1 + 9.1.0 com.backbase.stream.compositions.api diff --git a/stream-compositions/api/integrations-api/pom.xml b/stream-compositions/api/integrations-api/pom.xml index 2be79a0b4..0dc59d808 100644 --- a/stream-compositions/api/integrations-api/pom.xml +++ b/stream-compositions/api/integrations-api/pom.xml @@ -6,7 +6,7 @@ api com.backbase.stream.compositions - 8.11.1 + 9.1.0 integrations-api diff --git a/stream-compositions/api/integrations-api/product-catalog-integration-api/pom.xml b/stream-compositions/api/integrations-api/product-catalog-integration-api/pom.xml index fddf39d0f..51ed79dfb 100644 --- a/stream-compositions/api/integrations-api/product-catalog-integration-api/pom.xml +++ b/stream-compositions/api/integrations-api/product-catalog-integration-api/pom.xml @@ -6,7 +6,7 @@ integrations-api com.backbase.stream.compositions - 8.11.1 + 9.1.0 com.backbase.stream.compositions.api diff --git a/stream-compositions/api/integrations-api/product-integration-api/pom.xml b/stream-compositions/api/integrations-api/product-integration-api/pom.xml index a540d003d..39af0a1da 100644 --- a/stream-compositions/api/integrations-api/product-integration-api/pom.xml +++ b/stream-compositions/api/integrations-api/product-integration-api/pom.xml @@ -6,7 +6,7 @@ integrations-api com.backbase.stream.compositions - 8.11.1 + 9.1.0 com.backbase.stream.compositions.api diff --git a/stream-compositions/api/integrations-api/transaction-integration-api/pom.xml b/stream-compositions/api/integrations-api/transaction-integration-api/pom.xml index 8b4441e0b..bfec96e77 100644 --- a/stream-compositions/api/integrations-api/transaction-integration-api/pom.xml +++ b/stream-compositions/api/integrations-api/transaction-integration-api/pom.xml @@ -6,7 +6,7 @@ integrations-api com.backbase.stream.compositions - 8.11.1 + 9.1.0 com.backbase.stream.compositions.api diff --git a/stream-compositions/api/pom.xml b/stream-compositions/api/pom.xml index 5bc7bcef2..db56f8dd8 100644 --- a/stream-compositions/api/pom.xml +++ b/stream-compositions/api/pom.xml @@ -5,7 +5,7 @@ com.backbase.stream stream-compositions - 8.11.1 + 9.1.0 com.backbase.stream.compositions diff --git a/stream-compositions/api/service-api/legal-entity-composition-api/pom.xml b/stream-compositions/api/service-api/legal-entity-composition-api/pom.xml index c5a2e8473..c225033b2 100644 --- a/stream-compositions/api/service-api/legal-entity-composition-api/pom.xml +++ b/stream-compositions/api/service-api/legal-entity-composition-api/pom.xml @@ -5,7 +5,7 @@ com.backbase.stream.compositions service-api - 8.11.1 + 9.1.0 com.backbase.stream.compositions.api diff --git a/stream-compositions/api/service-api/payment-order-composition-api/pom.xml b/stream-compositions/api/service-api/payment-order-composition-api/pom.xml index 1620a33df..846e1b3d2 100644 --- a/stream-compositions/api/service-api/payment-order-composition-api/pom.xml +++ b/stream-compositions/api/service-api/payment-order-composition-api/pom.xml @@ -6,7 +6,7 @@ service-api com.backbase.stream.compositions - 8.11.1 + 9.1.0 com.backbase.stream.compositions.api diff --git a/stream-compositions/api/service-api/pom.xml b/stream-compositions/api/service-api/pom.xml index 823feb54d..46dea98ce 100644 --- a/stream-compositions/api/service-api/pom.xml +++ b/stream-compositions/api/service-api/pom.xml @@ -6,7 +6,7 @@ com.backbase.stream.compositions api - 8.11.1 + 9.1.0 service-api diff --git a/stream-compositions/api/service-api/product-catalog-composition-api/pom.xml b/stream-compositions/api/service-api/product-catalog-composition-api/pom.xml index 4f90236af..b9861c7c4 100644 --- a/stream-compositions/api/service-api/product-catalog-composition-api/pom.xml +++ b/stream-compositions/api/service-api/product-catalog-composition-api/pom.xml @@ -6,7 +6,7 @@ service-api com.backbase.stream.compositions - 8.11.1 + 9.1.0 com.backbase.stream.compositions.api diff --git a/stream-compositions/api/service-api/product-composition-api/pom.xml b/stream-compositions/api/service-api/product-composition-api/pom.xml index 4356f2080..6dff7b0f3 100644 --- a/stream-compositions/api/service-api/product-composition-api/pom.xml +++ b/stream-compositions/api/service-api/product-composition-api/pom.xml @@ -6,7 +6,7 @@ service-api com.backbase.stream.compositions - 8.11.1 + 9.1.0 com.backbase.stream.compositions.api diff --git a/stream-compositions/api/service-api/transaction-composition-api/pom.xml b/stream-compositions/api/service-api/transaction-composition-api/pom.xml index 9e74d8098..e58e0b35b 100644 --- a/stream-compositions/api/service-api/transaction-composition-api/pom.xml +++ b/stream-compositions/api/service-api/transaction-composition-api/pom.xml @@ -6,7 +6,7 @@ service-api com.backbase.stream.compositions - 8.11.1 + 9.1.0 com.backbase.stream.compositions.api diff --git a/stream-compositions/cursors/pom.xml b/stream-compositions/cursors/pom.xml index 7ccad7c90..94fe2b94b 100644 --- a/stream-compositions/cursors/pom.xml +++ b/stream-compositions/cursors/pom.xml @@ -5,7 +5,7 @@ stream-compositions com.backbase.stream - 8.11.1 + 9.1.0 4.0.0 diff --git a/stream-compositions/cursors/transaction-cursor/pom.xml b/stream-compositions/cursors/transaction-cursor/pom.xml index 2fdda9624..efe4ed0eb 100644 --- a/stream-compositions/cursors/transaction-cursor/pom.xml +++ b/stream-compositions/cursors/transaction-cursor/pom.xml @@ -5,7 +5,7 @@ com.backbase.stream.compositions cursors - 8.11.1 + 9.1.0 4.0.0 diff --git a/stream-compositions/events/grandcentral/pom.xml b/stream-compositions/events/grandcentral/pom.xml index 126feeddf..7153d9ef5 100644 --- a/stream-compositions/events/grandcentral/pom.xml +++ b/stream-compositions/events/grandcentral/pom.xml @@ -5,7 +5,7 @@ events com.backbase.stream.compositions - 8.11.1 + 9.1.0 com.backbase.stream.compositions.events diff --git a/stream-compositions/events/legal-entity-egress/pom.xml b/stream-compositions/events/legal-entity-egress/pom.xml index 1fd71ff97..a4f4f29e6 100644 --- a/stream-compositions/events/legal-entity-egress/pom.xml +++ b/stream-compositions/events/legal-entity-egress/pom.xml @@ -5,7 +5,7 @@ events com.backbase.stream.compositions - 8.11.1 + 9.1.0 com.backbase.stream.compositions.events diff --git a/stream-compositions/events/legal-entity-ingress/pom.xml b/stream-compositions/events/legal-entity-ingress/pom.xml index 08bb86f34..b5b56b9ef 100644 --- a/stream-compositions/events/legal-entity-ingress/pom.xml +++ b/stream-compositions/events/legal-entity-ingress/pom.xml @@ -5,7 +5,7 @@ events com.backbase.stream.compositions - 8.11.1 + 9.1.0 com.backbase.stream.compositions.events diff --git a/stream-compositions/events/pom.xml b/stream-compositions/events/pom.xml index 0fd85d94b..0cb4f4d38 100644 --- a/stream-compositions/events/pom.xml +++ b/stream-compositions/events/pom.xml @@ -6,7 +6,7 @@ com.backbase.stream stream-compositions - 8.11.1 + 9.1.0 com.backbase.stream.compositions diff --git a/stream-compositions/events/product-catalog-egress/pom.xml b/stream-compositions/events/product-catalog-egress/pom.xml index b1837d97d..8af4ff157 100644 --- a/stream-compositions/events/product-catalog-egress/pom.xml +++ b/stream-compositions/events/product-catalog-egress/pom.xml @@ -5,7 +5,7 @@ events com.backbase.stream.compositions - 8.11.1 + 9.1.0 com.backbase.stream.compositions.events diff --git a/stream-compositions/events/product-catalog-ingress/pom.xml b/stream-compositions/events/product-catalog-ingress/pom.xml index 8230c00b4..3867072db 100644 --- a/stream-compositions/events/product-catalog-ingress/pom.xml +++ b/stream-compositions/events/product-catalog-ingress/pom.xml @@ -5,7 +5,7 @@ events com.backbase.stream.compositions - 8.11.1 + 9.1.0 com.backbase.stream.compositions.events diff --git a/stream-compositions/events/product-egress/pom.xml b/stream-compositions/events/product-egress/pom.xml index f55c2e06e..7bb54455b 100644 --- a/stream-compositions/events/product-egress/pom.xml +++ b/stream-compositions/events/product-egress/pom.xml @@ -5,7 +5,7 @@ events com.backbase.stream.compositions - 8.11.1 + 9.1.0 com.backbase.stream.compositions.events diff --git a/stream-compositions/events/product-ingress/pom.xml b/stream-compositions/events/product-ingress/pom.xml index 065006846..7a04e07a7 100644 --- a/stream-compositions/events/product-ingress/pom.xml +++ b/stream-compositions/events/product-ingress/pom.xml @@ -5,7 +5,7 @@ events com.backbase.stream.compositions - 8.11.1 + 9.1.0 com.backbase.stream.compositions.events diff --git a/stream-compositions/events/transaction-egress/pom.xml b/stream-compositions/events/transaction-egress/pom.xml index 297f5f243..20d1ed55f 100644 --- a/stream-compositions/events/transaction-egress/pom.xml +++ b/stream-compositions/events/transaction-egress/pom.xml @@ -5,7 +5,7 @@ events com.backbase.stream.compositions - 8.11.1 + 9.1.0 com.backbase.stream.compositions.events diff --git a/stream-compositions/events/transaction-ingress/pom.xml b/stream-compositions/events/transaction-ingress/pom.xml index c13053e43..fea537935 100644 --- a/stream-compositions/events/transaction-ingress/pom.xml +++ b/stream-compositions/events/transaction-ingress/pom.xml @@ -5,7 +5,7 @@ events com.backbase.stream.compositions - 8.11.1 + 9.1.0 com.backbase.stream.compositions.events diff --git a/stream-compositions/pom.xml b/stream-compositions/pom.xml index 79c404db3..08d99e5bf 100644 --- a/stream-compositions/pom.xml +++ b/stream-compositions/pom.xml @@ -7,13 +7,13 @@ com.backbase.stream stream-starter - 8.11.1 + 9.1.0 ../stream-sdk/stream-starter com.backbase.stream stream-compositions - 8.11.1 + 9.1.0 pom Stream :: Compositions diff --git a/stream-compositions/services/legal-entity-composition-service/pom.xml b/stream-compositions/services/legal-entity-composition-service/pom.xml index 1cd2bb8ff..e9bf25b79 100644 --- a/stream-compositions/services/legal-entity-composition-service/pom.xml +++ b/stream-compositions/services/legal-entity-composition-service/pom.xml @@ -7,7 +7,7 @@ com.backbase.stream.compositions services - 8.11.1 + 9.1.0 legal-entity-composition-service diff --git a/stream-compositions/services/payment-order-composition-service/pom.xml b/stream-compositions/services/payment-order-composition-service/pom.xml index 31d482f62..545bb7690 100644 --- a/stream-compositions/services/payment-order-composition-service/pom.xml +++ b/stream-compositions/services/payment-order-composition-service/pom.xml @@ -6,7 +6,7 @@ com.backbase.stream.compositions services - 8.11.1 + 9.1.0 payment-order-composition-service diff --git a/stream-compositions/services/pom.xml b/stream-compositions/services/pom.xml index 0eb833b7f..7638b5f4a 100644 --- a/stream-compositions/services/pom.xml +++ b/stream-compositions/services/pom.xml @@ -6,7 +6,7 @@ com.backbase.stream stream-compositions - 8.11.1 + 9.1.0 com.backbase.stream.compositions diff --git a/stream-compositions/services/product-catalog-composition-service/pom.xml b/stream-compositions/services/product-catalog-composition-service/pom.xml index 60b4162a1..bb9a5b507 100644 --- a/stream-compositions/services/product-catalog-composition-service/pom.xml +++ b/stream-compositions/services/product-catalog-composition-service/pom.xml @@ -5,7 +5,7 @@ com.backbase.stream.compositions services - 8.11.1 + 9.1.0 product-catalog-composition-service diff --git a/stream-compositions/services/product-composition-service/pom.xml b/stream-compositions/services/product-composition-service/pom.xml index 795dca4da..5e257ea97 100644 --- a/stream-compositions/services/product-composition-service/pom.xml +++ b/stream-compositions/services/product-composition-service/pom.xml @@ -7,7 +7,7 @@ com.backbase.stream.compositions services - 8.11.1 + 9.1.0 product-composition-service diff --git a/stream-compositions/services/transaction-composition-service/pom.xml b/stream-compositions/services/transaction-composition-service/pom.xml index 03d56877b..4c3413692 100644 --- a/stream-compositions/services/transaction-composition-service/pom.xml +++ b/stream-compositions/services/transaction-composition-service/pom.xml @@ -5,7 +5,7 @@ com.backbase.stream.compositions services - 8.11.1 + 9.1.0 transaction-composition-service diff --git a/stream-compositions/test-utils/pom.xml b/stream-compositions/test-utils/pom.xml index a8bf72271..245305f74 100644 --- a/stream-compositions/test-utils/pom.xml +++ b/stream-compositions/test-utils/pom.xml @@ -6,7 +6,7 @@ stream-compositions com.backbase.stream - 8.11.1 + 9.1.0 com.backbase.stream.compositions diff --git a/stream-contacts/contacts-core/pom.xml b/stream-contacts/contacts-core/pom.xml index 57b79c5fb..13b136e5c 100644 --- a/stream-contacts/contacts-core/pom.xml +++ b/stream-contacts/contacts-core/pom.xml @@ -5,7 +5,7 @@ com.backbase.stream stream-contacts - 8.11.1 + 9.1.0 contacts-core diff --git a/stream-contacts/pom.xml b/stream-contacts/pom.xml index 9e4a3cabd..a4e2ddb00 100644 --- a/stream-contacts/pom.xml +++ b/stream-contacts/pom.xml @@ -5,7 +5,7 @@ com.backbase.stream stream-services - 8.11.1 + 9.1.0 stream-contacts diff --git a/stream-cursor/cursor-core/pom.xml b/stream-cursor/cursor-core/pom.xml index 0ffb5bbe8..bac5d6b02 100644 --- a/stream-cursor/cursor-core/pom.xml +++ b/stream-cursor/cursor-core/pom.xml @@ -5,7 +5,7 @@ com.backbase.stream stream-cursor - 8.11.1 + 9.1.0 cursor-core diff --git a/stream-cursor/cursor-http/pom.xml b/stream-cursor/cursor-http/pom.xml index e9d04d31e..c76abb06a 100644 --- a/stream-cursor/cursor-http/pom.xml +++ b/stream-cursor/cursor-http/pom.xml @@ -5,7 +5,7 @@ com.backbase.stream stream-http-starter-parent - 8.11.1 + 9.1.0 ../../stream-sdk/stream-starter-parents/stream-http-starter-parent diff --git a/stream-cursor/cursor-publishers/pom.xml b/stream-cursor/cursor-publishers/pom.xml index a12d659a0..76425a2e1 100644 --- a/stream-cursor/cursor-publishers/pom.xml +++ b/stream-cursor/cursor-publishers/pom.xml @@ -5,7 +5,7 @@ com.backbase.stream stream-cursor - 8.11.1 + 9.1.0 cursor-publishers diff --git a/stream-cursor/cursor-store/pom.xml b/stream-cursor/cursor-store/pom.xml index bacbf62b1..f24136b96 100644 --- a/stream-cursor/cursor-store/pom.xml +++ b/stream-cursor/cursor-store/pom.xml @@ -5,7 +5,7 @@ com.backbase.stream stream-cursor - 8.11.1 + 9.1.0 cursor-store diff --git a/stream-cursor/pom.xml b/stream-cursor/pom.xml index b7610fe46..01541a7b6 100644 --- a/stream-cursor/pom.xml +++ b/stream-cursor/pom.xml @@ -5,7 +5,7 @@ com.backbase.stream stream-services - 8.11.1 + 9.1.0 stream-cursor diff --git a/stream-customer-profile/customer-profile-core/pom.xml b/stream-customer-profile/customer-profile-core/pom.xml index 29d80cc92..1e85bbc53 100644 --- a/stream-customer-profile/customer-profile-core/pom.xml +++ b/stream-customer-profile/customer-profile-core/pom.xml @@ -5,7 +5,7 @@ com.backbase.stream stream-customer-profile - 8.11.1 + 9.1.0 customer-profile-core diff --git a/stream-customer-profile/pom.xml b/stream-customer-profile/pom.xml index 0cb57f79b..cf835a9b6 100644 --- a/stream-customer-profile/pom.xml +++ b/stream-customer-profile/pom.xml @@ -5,7 +5,7 @@ com.backbase.stream stream-services - 8.11.1 + 9.1.0 stream-customer-profile diff --git a/stream-dbs-clients/pom.xml b/stream-dbs-clients/pom.xml index 9323e73ce..e37eee5d4 100644 --- a/stream-dbs-clients/pom.xml +++ b/stream-dbs-clients/pom.xml @@ -5,7 +5,7 @@ com.backbase.stream stream-services - 8.11.1 + 9.1.0 stream-dbs-clients diff --git a/stream-investment/investment-core/pom.xml b/stream-investment/investment-core/pom.xml index 20d7533ff..cceefe67f 100644 --- a/stream-investment/investment-core/pom.xml +++ b/stream-investment/investment-core/pom.xml @@ -5,7 +5,7 @@ com.backbase.stream stream-investment - 8.11.1 + 9.1.0 investment-core diff --git a/stream-investment/pom.xml b/stream-investment/pom.xml index 97aac0a13..a06d79f4f 100644 --- a/stream-investment/pom.xml +++ b/stream-investment/pom.xml @@ -5,7 +5,7 @@ com.backbase.stream stream-services - 8.11.1 + 9.1.0 stream-investment diff --git a/stream-legal-entity/legal-entity-bootstrap-task/pom.xml b/stream-legal-entity/legal-entity-bootstrap-task/pom.xml index bc043fc97..ad4223922 100644 --- a/stream-legal-entity/legal-entity-bootstrap-task/pom.xml +++ b/stream-legal-entity/legal-entity-bootstrap-task/pom.xml @@ -5,7 +5,7 @@ com.backbase.stream stream-task-starter-parent - 8.11.1 + 9.1.0 ../../stream-sdk/stream-starter-parents/stream-task-starter-parent diff --git a/stream-legal-entity/legal-entity-core/pom.xml b/stream-legal-entity/legal-entity-core/pom.xml index bc6187b38..9af6cbd0a 100644 --- a/stream-legal-entity/legal-entity-core/pom.xml +++ b/stream-legal-entity/legal-entity-core/pom.xml @@ -5,7 +5,7 @@ com.backbase.stream stream-legal-entity - 8.11.1 + 9.1.0 legal-entity-core diff --git a/stream-legal-entity/legal-entity-http/pom.xml b/stream-legal-entity/legal-entity-http/pom.xml index 3f65cbabe..e488ea81a 100644 --- a/stream-legal-entity/legal-entity-http/pom.xml +++ b/stream-legal-entity/legal-entity-http/pom.xml @@ -5,7 +5,7 @@ com.backbase.stream stream-http-starter-parent - 8.11.1 + 9.1.0 ../../stream-sdk/stream-starter-parents/stream-http-starter-parent diff --git a/stream-legal-entity/pom.xml b/stream-legal-entity/pom.xml index 5af4fdc09..14c7ca33f 100644 --- a/stream-legal-entity/pom.xml +++ b/stream-legal-entity/pom.xml @@ -5,7 +5,7 @@ com.backbase.stream stream-services - 8.11.1 + 9.1.0 stream-legal-entity diff --git a/stream-limits/limits-core/pom.xml b/stream-limits/limits-core/pom.xml index cce29ddf2..48e2281e6 100644 --- a/stream-limits/limits-core/pom.xml +++ b/stream-limits/limits-core/pom.xml @@ -5,7 +5,7 @@ com.backbase.stream stream-limits - 8.11.1 + 9.1.0 limits-core diff --git a/stream-limits/pom.xml b/stream-limits/pom.xml index d9b927fd5..afb3c985c 100644 --- a/stream-limits/pom.xml +++ b/stream-limits/pom.xml @@ -5,7 +5,7 @@ com.backbase.stream stream-services - 8.11.1 + 9.1.0 stream-limits diff --git a/stream-loans/loans-core/pom.xml b/stream-loans/loans-core/pom.xml index 53ff5cdcf..3b53b1afc 100644 --- a/stream-loans/loans-core/pom.xml +++ b/stream-loans/loans-core/pom.xml @@ -5,7 +5,7 @@ com.backbase.stream stream-loans - 8.11.1 + 9.1.0 loans-core diff --git a/stream-loans/pom.xml b/stream-loans/pom.xml index 98e82bb41..18ea85146 100644 --- a/stream-loans/pom.xml +++ b/stream-loans/pom.xml @@ -5,7 +5,7 @@ com.backbase.stream stream-services - 8.11.1 + 9.1.0 stream-loans diff --git a/stream-models/approval-model/pom.xml b/stream-models/approval-model/pom.xml index c318dc613..384bb11c3 100644 --- a/stream-models/approval-model/pom.xml +++ b/stream-models/approval-model/pom.xml @@ -5,7 +5,7 @@ com.backbase.stream stream-models - 8.11.1 + 9.1.0 approval-model diff --git a/stream-models/legal-entity-model/pom.xml b/stream-models/legal-entity-model/pom.xml index 49919b368..af07a1c0b 100644 --- a/stream-models/legal-entity-model/pom.xml +++ b/stream-models/legal-entity-model/pom.xml @@ -5,7 +5,7 @@ com.backbase.stream stream-models - 8.11.1 + 9.1.0 legal-entity-model diff --git a/stream-models/pom.xml b/stream-models/pom.xml index 94d54a920..5df7a3e99 100644 --- a/stream-models/pom.xml +++ b/stream-models/pom.xml @@ -5,7 +5,7 @@ com.backbase.stream stream-services - 8.11.1 + 9.1.0 stream-models diff --git a/stream-models/portfolio-model/pom.xml b/stream-models/portfolio-model/pom.xml index 5f1cf18e1..44ddfcf82 100644 --- a/stream-models/portfolio-model/pom.xml +++ b/stream-models/portfolio-model/pom.xml @@ -5,7 +5,7 @@ com.backbase.stream stream-models - 8.11.1 + 9.1.0 portfolio-model diff --git a/stream-models/product-catalog-model/pom.xml b/stream-models/product-catalog-model/pom.xml index 61a6affc3..ae34dfb79 100644 --- a/stream-models/product-catalog-model/pom.xml +++ b/stream-models/product-catalog-model/pom.xml @@ -5,7 +5,7 @@ com.backbase.stream stream-models - 8.11.1 + 9.1.0 product-catalog-model diff --git a/stream-payment-order/payment-order-core/pom.xml b/stream-payment-order/payment-order-core/pom.xml index 63d2736ee..06ed2ba11 100644 --- a/stream-payment-order/payment-order-core/pom.xml +++ b/stream-payment-order/payment-order-core/pom.xml @@ -6,7 +6,7 @@ com.backbase.stream stream-payment-order - 8.11.1 + 9.1.0 payment-order-core diff --git a/stream-payment-order/pom.xml b/stream-payment-order/pom.xml index 7709c9ab5..64da29161 100644 --- a/stream-payment-order/pom.xml +++ b/stream-payment-order/pom.xml @@ -6,7 +6,7 @@ com.backbase.stream stream-services - 8.11.1 + 9.1.0 stream-payment-order diff --git a/stream-plan-manager/plan-manager-core/pom.xml b/stream-plan-manager/plan-manager-core/pom.xml index 8594efa2b..bb797d156 100644 --- a/stream-plan-manager/plan-manager-core/pom.xml +++ b/stream-plan-manager/plan-manager-core/pom.xml @@ -5,7 +5,7 @@ com.backbase.stream stream-plan-manager - 8.11.1 + 9.1.0 plan-manager-core diff --git a/stream-plan-manager/pom.xml b/stream-plan-manager/pom.xml index 7a0e98549..6615c160c 100644 --- a/stream-plan-manager/pom.xml +++ b/stream-plan-manager/pom.xml @@ -5,7 +5,7 @@ com.backbase.stream stream-services - 8.11.1 + 9.1.0 stream-plan-manager diff --git a/stream-portfolio/pom.xml b/stream-portfolio/pom.xml index a3d7f84a8..eace8fff0 100644 --- a/stream-portfolio/pom.xml +++ b/stream-portfolio/pom.xml @@ -5,7 +5,7 @@ com.backbase.stream stream-services - 8.11.1 + 9.1.0 stream-portfolio diff --git a/stream-portfolio/portfolio-bootstrap-task/pom.xml b/stream-portfolio/portfolio-bootstrap-task/pom.xml index 2f81755e8..1e0f24fab 100644 --- a/stream-portfolio/portfolio-bootstrap-task/pom.xml +++ b/stream-portfolio/portfolio-bootstrap-task/pom.xml @@ -5,7 +5,7 @@ com.backbase.stream stream-task-starter-parent - 8.11.1 + 9.1.0 ../../stream-sdk/stream-starter-parents/stream-task-starter-parent diff --git a/stream-portfolio/portfolio-core/pom.xml b/stream-portfolio/portfolio-core/pom.xml index 9046ffcfe..f90a7649d 100644 --- a/stream-portfolio/portfolio-core/pom.xml +++ b/stream-portfolio/portfolio-core/pom.xml @@ -5,7 +5,7 @@ com.backbase.stream stream-portfolio - 8.11.1 + 9.1.0 portfolio-core diff --git a/stream-portfolio/portfolio-http/pom.xml b/stream-portfolio/portfolio-http/pom.xml index 64c39e642..e631483f7 100644 --- a/stream-portfolio/portfolio-http/pom.xml +++ b/stream-portfolio/portfolio-http/pom.xml @@ -5,7 +5,7 @@ com.backbase.stream stream-http-starter-parent - 8.11.1 + 9.1.0 ../../stream-sdk/stream-starter-parents/stream-http-starter-parent diff --git a/stream-product-catalog/pom.xml b/stream-product-catalog/pom.xml index a257d379a..181f27add 100644 --- a/stream-product-catalog/pom.xml +++ b/stream-product-catalog/pom.xml @@ -5,7 +5,7 @@ com.backbase.stream stream-services - 8.11.1 + 9.1.0 stream-product-catalog diff --git a/stream-product-catalog/product-catalog-core/pom.xml b/stream-product-catalog/product-catalog-core/pom.xml index ec8dbaa88..27b1578ba 100644 --- a/stream-product-catalog/product-catalog-core/pom.xml +++ b/stream-product-catalog/product-catalog-core/pom.xml @@ -5,7 +5,7 @@ com.backbase.stream stream-product-catalog - 8.11.1 + 9.1.0 product-catalog-core diff --git a/stream-product-catalog/product-catalog-http/pom.xml b/stream-product-catalog/product-catalog-http/pom.xml index fbdbac32a..3977481b0 100644 --- a/stream-product-catalog/product-catalog-http/pom.xml +++ b/stream-product-catalog/product-catalog-http/pom.xml @@ -6,7 +6,7 @@ com.backbase.stream stream-http-starter-parent - 8.11.1 + 9.1.0 ../../stream-sdk/stream-starter-parents/stream-http-starter-parent diff --git a/stream-product-catalog/product-catalog-task/pom.xml b/stream-product-catalog/product-catalog-task/pom.xml index b28aab9ca..ba7443895 100644 --- a/stream-product-catalog/product-catalog-task/pom.xml +++ b/stream-product-catalog/product-catalog-task/pom.xml @@ -5,7 +5,7 @@ com.backbase.stream stream-task-starter-parent - 8.11.1 + 9.1.0 ../../stream-sdk/stream-starter-parents/stream-task-starter-parent diff --git a/stream-product/pom.xml b/stream-product/pom.xml index aa43009b6..e9a14404a 100644 --- a/stream-product/pom.xml +++ b/stream-product/pom.xml @@ -5,7 +5,7 @@ com.backbase.stream stream-services - 8.11.1 + 9.1.0 stream-product diff --git a/stream-product/product-core/pom.xml b/stream-product/product-core/pom.xml index 36597cf7e..c25ee1653 100644 --- a/stream-product/product-core/pom.xml +++ b/stream-product/product-core/pom.xml @@ -5,7 +5,7 @@ com.backbase.stream stream-product - 8.11.1 + 9.1.0 product-core diff --git a/stream-product/product-ingestion-saga/pom.xml b/stream-product/product-ingestion-saga/pom.xml index 7ee10f7d0..ba76acc4d 100644 --- a/stream-product/product-ingestion-saga/pom.xml +++ b/stream-product/product-ingestion-saga/pom.xml @@ -5,7 +5,7 @@ com.backbase.stream stream-product - 8.11.1 + 9.1.0 product-ingestion-saga diff --git a/stream-sdk/pom.xml b/stream-sdk/pom.xml index 49c37689e..3ae6bb97b 100644 --- a/stream-sdk/pom.xml +++ b/stream-sdk/pom.xml @@ -4,7 +4,7 @@ com.backbase.stream stream-sdk - 8.11.1 + 9.1.0 pom Stream :: SDK diff --git a/stream-sdk/stream-parent/pom.xml b/stream-sdk/stream-parent/pom.xml index 3c8919dd5..50f1e6853 100644 --- a/stream-sdk/stream-parent/pom.xml +++ b/stream-sdk/stream-parent/pom.xml @@ -11,7 +11,7 @@ com.backbase.stream stream-parent - 8.11.1 + 9.1.0 pom Stream :: SDK :: Parent Parent for all Stream SDK modules diff --git a/stream-sdk/stream-parent/stream-context-propagation/pom.xml b/stream-sdk/stream-parent/stream-context-propagation/pom.xml index bb6980fed..af2fe086b 100644 --- a/stream-sdk/stream-parent/stream-context-propagation/pom.xml +++ b/stream-sdk/stream-parent/stream-context-propagation/pom.xml @@ -5,7 +5,7 @@ com.backbase.stream stream-parent - 8.11.1 + 9.1.0 stream-context-propagation diff --git a/stream-sdk/stream-parent/stream-dbs-web-client/pom.xml b/stream-sdk/stream-parent/stream-dbs-web-client/pom.xml index 6746445b6..be813c324 100644 --- a/stream-sdk/stream-parent/stream-dbs-web-client/pom.xml +++ b/stream-sdk/stream-parent/stream-dbs-web-client/pom.xml @@ -5,7 +5,7 @@ com.backbase.stream stream-parent - 8.11.1 + 9.1.0 stream-dbs-web-client diff --git a/stream-sdk/stream-parent/stream-openapi-support/pom.xml b/stream-sdk/stream-parent/stream-openapi-support/pom.xml index 5e60679df..839128fef 100644 --- a/stream-sdk/stream-parent/stream-openapi-support/pom.xml +++ b/stream-sdk/stream-parent/stream-openapi-support/pom.xml @@ -5,7 +5,7 @@ com.backbase.stream stream-parent - 8.11.1 + 9.1.0 stream-openapi-support diff --git a/stream-sdk/stream-parent/stream-test-support/pom.xml b/stream-sdk/stream-parent/stream-test-support/pom.xml index 2f0e0ea5f..b61ed3f3a 100644 --- a/stream-sdk/stream-parent/stream-test-support/pom.xml +++ b/stream-sdk/stream-parent/stream-test-support/pom.xml @@ -5,7 +5,7 @@ com.backbase.stream stream-parent - 8.11.1 + 9.1.0 stream-test-support diff --git a/stream-sdk/stream-parent/stream-worker/pom.xml b/stream-sdk/stream-parent/stream-worker/pom.xml index 20674e75d..8a963e9f3 100644 --- a/stream-sdk/stream-parent/stream-worker/pom.xml +++ b/stream-sdk/stream-parent/stream-worker/pom.xml @@ -5,7 +5,7 @@ com.backbase.stream stream-parent - 8.11.1 + 9.1.0 stream-worker diff --git a/stream-sdk/stream-starter-parents/pom.xml b/stream-sdk/stream-starter-parents/pom.xml index 28151f9ab..5cf334906 100644 --- a/stream-sdk/stream-starter-parents/pom.xml +++ b/stream-sdk/stream-starter-parents/pom.xml @@ -5,7 +5,7 @@ com.backbase.stream stream-parent - 8.11.1 + 9.1.0 ../stream-parent diff --git a/stream-sdk/stream-starter-parents/stream-http-starter-parent/pom.xml b/stream-sdk/stream-starter-parents/stream-http-starter-parent/pom.xml index 81337cf72..ca136c449 100644 --- a/stream-sdk/stream-starter-parents/stream-http-starter-parent/pom.xml +++ b/stream-sdk/stream-starter-parents/stream-http-starter-parent/pom.xml @@ -6,13 +6,13 @@ com.backbase.stream stream-starter - 8.11.1 + 9.1.0 ../../stream-starter com.backbase.stream stream-http-starter-parent - 8.11.1 + 9.1.0 pom Stream :: SDK :: HTTP Services Starter Parent for Stream HTTP Services diff --git a/stream-sdk/stream-starter-parents/stream-task-starter-parent/pom.xml b/stream-sdk/stream-starter-parents/stream-task-starter-parent/pom.xml index ebb0fe1fa..d2a81cfdc 100644 --- a/stream-sdk/stream-starter-parents/stream-task-starter-parent/pom.xml +++ b/stream-sdk/stream-starter-parents/stream-task-starter-parent/pom.xml @@ -5,13 +5,13 @@ com.backbase.stream stream-starter - 8.11.1 + 9.1.0 ../../stream-starter com.backbase.stream stream-task-starter-parent - 8.11.1 + 9.1.0 pom Stream :: SDK :: Task Starter Parent for Stream Executable Tasks diff --git a/stream-sdk/stream-starter/pom.xml b/stream-sdk/stream-starter/pom.xml index 0857d48fc..392e793d9 100644 --- a/stream-sdk/stream-starter/pom.xml +++ b/stream-sdk/stream-starter/pom.xml @@ -10,7 +10,7 @@ com.backbase.stream stream-starter Stream :: SDK :: stream-starter - 8.11.1 + 9.1.0 pom diff --git a/stream-transactions/pom.xml b/stream-transactions/pom.xml index 04a348245..73df4b1a6 100644 --- a/stream-transactions/pom.xml +++ b/stream-transactions/pom.xml @@ -5,7 +5,7 @@ com.backbase.stream stream-services - 8.11.1 + 9.1.0 stream-transactions diff --git a/stream-transactions/transactions-core/pom.xml b/stream-transactions/transactions-core/pom.xml index 4512461d9..58675d055 100644 --- a/stream-transactions/transactions-core/pom.xml +++ b/stream-transactions/transactions-core/pom.xml @@ -5,7 +5,7 @@ com.backbase.stream stream-transactions - 8.11.1 + 9.1.0 transactions-core diff --git a/stream-transactions/transactions-item-writer/pom.xml b/stream-transactions/transactions-item-writer/pom.xml index d2962673b..8789b7bf4 100644 --- a/stream-transactions/transactions-item-writer/pom.xml +++ b/stream-transactions/transactions-item-writer/pom.xml @@ -5,7 +5,7 @@ com.backbase.stream stream-parent - 8.11.1 + 9.1.0 ../../stream-sdk/stream-parent From 39a489b1c2a5e7d205f7c43dcd24506e21c11a54 Mon Sep 17 00:00:00 2001 From: Oleksandra Ishchuk Date: Thu, 18 Dec 2025 16:13:24 +0100 Subject: [PATCH 4/4] Fix CHANGELOG.md file --- CHANGELOG.md | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/CHANGELOG.md b/CHANGELOG.md index b5798dc74..6534e4e1c 100644 --- a/CHANGELOG.md +++ b/CHANGELOG.md @@ -1,11 +1,13 @@ # Changelog All notable changes to this project will be documented in this file. -## [8.8.1](https://github.com/Backbase/stream-services/compare/8.8.0...8.8.1) +## [9.1.0](https://github.com/Backbase/stream-services/compare/9.0.0...9.1.0) ### Changed - added partitioning to a batch permission update request -### Changed + - fix update data group items request to access-control (use externalDataItemIds instead of internal) + ## [9.0.0](https://github.com/Backbase/stream-services/compare/8.8.0...9.0.0) +### Changed - Upgraded to bb bom 2025.10.2 ## [8.8.0](https://github.com/Backbase/stream-services/compare/8.7.0...8.8.0)