2 * ============LICENSE_START=======================================================
4 * ================================================================================
5 * Copyright (C) 2019 AT&T Intellectual Property. All rights reserved.
6 * ================================================================================
7 * Licensed under the Apache License, Version 2.0 (the "License");
8 * you may not use this file except in compliance with the License.
9 * You may obtain a copy of the License at
11 * http://www.apache.org/licenses/LICENSE-2.0
13 * Unless required by applicable law or agreed to in writing, software
14 * distributed under the License is distributed on an "AS IS" BASIS,
15 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
16 * See the License for the specific language governing permissions and
17 * limitations under the License.
18 * ============LICENSE_END=========================================================
21 package org.openecomp.sdc.be.components.merge.resource;
23 import org.openecomp.sdc.be.components.merge.ComponentsMergeCommand;
24 import org.openecomp.sdc.be.dao.api.ActionStatus;
25 import org.openecomp.sdc.be.model.Resource;
26 import org.openecomp.sdc.common.log.wrappers.Logger;
27 import org.springframework.stereotype.Component;
29 import java.util.List;
32 public class ResourceDataMergeBusinessLogic implements MergeResourceBusinessLogic {
34 private static final Logger log = Logger.getLogger(ResourceDataMergeBusinessLogic.class);
35 public static final int FIRST_COMMAND = 0;
36 public static final int PENULTIMATE_COMMAND = Integer.MAX_VALUE - 1;
37 public static final int LAST_COMMAND = Integer.MAX_VALUE;
38 public static final int ANY_ORDER_COMMAND = 1;
40 private MergeCommandsFactory mergeCommandsFactory;
42 public ResourceDataMergeBusinessLogic(MergeCommandsFactory mergeCommandsFactory) {
43 this.mergeCommandsFactory = mergeCommandsFactory;
47 public ActionStatus mergeResourceEntities(Resource oldResource, Resource newResource) {
48 if (oldResource == null) {
49 return ActionStatus.OK;
51 return mergeCommandsFactory.getMergeCommands(oldResource, newResource)
52 .either(mergeCommands -> executeMergeCommands(oldResource, newResource, mergeCommands),
56 private ActionStatus executeMergeCommands(Resource oldResource, Resource newResource, List<? extends ComponentsMergeCommand> componentMergingCommands) {
57 for (ComponentsMergeCommand componentMergeCommand : componentMergingCommands) {
58 ActionStatus mergeStatus = componentMergeCommand.mergeComponents(oldResource, newResource);
59 if (mergeStatus != ActionStatus.OK) {
60 log.debug("failed on merge command {} of resource {} status is {}", componentMergeCommand.description(), newResource.getUniqueId(), mergeStatus);
64 return ActionStatus.OK;