diff options
author | Amichai Hemli <amichai.hemli@intl.att.com> | 2019-12-19 14:41:58 +0000 |
---|---|---|
committer | Gerrit Code Review <gerrit@onap.org> | 2019-12-19 14:41:58 +0000 |
commit | 0788ea75c265efb8a030d7a846f7dfb06e2bcbd7 (patch) | |
tree | 8ebc45d938da37cb8f1da2bc6110d335117e54bb /vid-app-common/src/main/java/org/onap | |
parent | 169e68bdb8c53c7f675f1fd5dce9849edb532988 (diff) | |
parent | fecb7b8df6d8f589fd879b41731e7495cf657c92 (diff) |
Merge "Tweak add resources summarizing function in service instance"
Diffstat (limited to 'vid-app-common/src/main/java/org/onap')
-rw-r--r-- | vid-app-common/src/main/java/org/onap/vid/services/AsyncInstantiationBusinessLogicImpl.java | 40 |
1 files changed, 19 insertions, 21 deletions
diff --git a/vid-app-common/src/main/java/org/onap/vid/services/AsyncInstantiationBusinessLogicImpl.java b/vid-app-common/src/main/java/org/onap/vid/services/AsyncInstantiationBusinessLogicImpl.java index d1b475cb4..c0ee7ea4f 100644 --- a/vid-app-common/src/main/java/org/onap/vid/services/AsyncInstantiationBusinessLogicImpl.java +++ b/vid-app-common/src/main/java/org/onap/vid/services/AsyncInstantiationBusinessLogicImpl.java @@ -20,9 +20,10 @@ package org.onap.vid.services; -import static java.util.stream.Collectors.counting; import static java.util.function.Function.identity; +import static java.util.stream.Collectors.counting; import static java.util.stream.Collectors.groupingBy; +import static java.util.stream.Stream.concat; import static org.apache.commons.lang3.ObjectUtils.defaultIfNull; import static org.onap.vid.controller.MsoController.SVC_INSTANCE_ID; import static org.onap.vid.controller.MsoController.VNF_INSTANCE_ID; @@ -33,16 +34,13 @@ import java.io.IOException; import java.time.ZonedDateTime; import java.util.ArrayList; import java.util.Calendar; -import java.util.Collection; import java.util.Date; -import java.util.HashMap; import java.util.List; import java.util.Map; +import java.util.Objects; import java.util.UUID; import java.util.function.Consumer; -import java.util.function.Function; -import java.util.stream.Collectors; -import org.apache.commons.collections.CollectionUtils; +import java.util.stream.Stream; import org.apache.commons.lang3.StringUtils; import org.hibernate.SessionFactory; import org.onap.portalsdk.core.logging.logic.EELFLoggerDelegate; @@ -69,6 +67,7 @@ import org.onap.vid.mso.MsoBusinessLogicImpl; import org.onap.vid.mso.MsoProperties; import org.onap.vid.mso.MsoUtil; import org.onap.vid.mso.RestObject; +import org.onap.vid.mso.model.ModelInfo; import org.onap.vid.mso.rest.AsyncRequestStatus; import org.onap.vid.mso.rest.RequestStatus; import org.onap.vid.properties.Features; @@ -186,26 +185,25 @@ public class AsyncInstantiationBusinessLogicImpl implements return uuids; } - public Map<String, Long> getSummarizedChildrenMap(ServiceInstantiation serviceInstantiation){ - List<String> existingTypesList = new ArrayList<>(); - Map<String, Long> existingTypesCounters; + public Map<String, Long> getSummarizedChildrenMap(ServiceInstantiation serviceInstantiation){ + Stream<String> existingTypesStream = + allDeepChildResources(serviceInstantiation) + .map(BaseResource::getModelInfo) + .filter(Objects::nonNull) + .map(ModelInfo::getModelType); - existingTypesList = getChildrenList(serviceInstantiation, existingTypesList); - existingTypesCounters = existingTypesList.stream().collect(groupingBy(identity(), counting())); + Map<String, Long> existingTypesCounters = + existingTypesStream.collect(groupingBy(identity(), counting())); return existingTypesCounters; } - private List<String> getChildrenList(BaseResource resource, List<String> list){ - Collection<? extends BaseResource> children = resource.getChildren(); - if (CollectionUtils.isNotEmpty(children)){ - children.forEach( child -> { - String childType = child.getModelInfo().getModelType(); - getChildrenList(child, list); - list.add(childType); - }); - } - return list; + private Stream<BaseResource> allDeepChildResources(BaseResource resource) { + return resource + .getChildren() + .stream() + .map(it -> concat(Stream.of(it), allDeepChildResources(it))) + .flatMap(identity()); } private ServiceInfo.ServiceAction getAction(ServiceInstantiation request) { |