diff options
Diffstat (limited to 'appc-sequence-generator/appc-sequence-generator-bundle')
4 files changed, 204 insertions, 77 deletions
diff --git a/appc-sequence-generator/appc-sequence-generator-bundle/src/main/java/org/onap/appc/seqgen/impl/RestartSequenceGenerator.java b/appc-sequence-generator/appc-sequence-generator-bundle/src/main/java/org/onap/appc/seqgen/impl/RestartSequenceGenerator.java index 85d5bc923..5ab0b5408 100644 --- a/appc-sequence-generator/appc-sequence-generator-bundle/src/main/java/org/onap/appc/seqgen/impl/RestartSequenceGenerator.java +++ b/appc-sequence-generator/appc-sequence-generator-bundle/src/main/java/org/onap/appc/seqgen/impl/RestartSequenceGenerator.java @@ -5,6 +5,8 @@ * Copyright (C) 2017-2018 AT&T Intellectual Property. All rights reserved. * ================================================================================ * Copyright (C) 2017 Amdocs + * ================================================================================ + * Modifications Copyright (C) 2019 Ericsson * ============================================================================= * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. @@ -26,13 +28,12 @@ package org.onap.appc.seqgen.impl; import com.att.eelf.configuration.EELFLogger; import com.att.eelf.configuration.EELFManager; import org.onap.appc.domainmodel.Vserver; -import org.onap.appc.exceptions.APPCException; import org.onap.appc.seqgen.SequenceGenerator; import org.onap.appc.seqgen.objects.ActionIdentifier; import org.onap.appc.seqgen.objects.Constants; import org.onap.appc.seqgen.objects.Response; import org.onap.appc.seqgen.objects.SequenceGeneratorInput; -import org.onap.appc.seqgen.objects.Transaction;; +import org.onap.appc.seqgen.objects.Transaction; import java.util.HashMap; import java.util.LinkedList; diff --git a/appc-sequence-generator/appc-sequence-generator-bundle/src/main/java/org/onap/appc/seqgen/impl/StopSequenceGenerator.java b/appc-sequence-generator/appc-sequence-generator-bundle/src/main/java/org/onap/appc/seqgen/impl/StopSequenceGenerator.java index 63ec1731e..9b73b0848 100644 --- a/appc-sequence-generator/appc-sequence-generator-bundle/src/main/java/org/onap/appc/seqgen/impl/StopSequenceGenerator.java +++ b/appc-sequence-generator/appc-sequence-generator-bundle/src/main/java/org/onap/appc/seqgen/impl/StopSequenceGenerator.java @@ -5,6 +5,8 @@ * Copyright (C) 2017-2018 AT&T Intellectual Property. All rights reserved. * ================================================================================ * Copyright (C) 2017 Amdocs + * ================================================================================ + * Modifications Copyright (C) 2019 Ericsson * ============================================================================= * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. @@ -23,7 +25,6 @@ package org.onap.appc.seqgen.impl; -import org.apache.commons.lang3.StringUtils; import org.onap.appc.dg.flowbuilder.FlowBuilder; import org.onap.appc.dg.flowbuilder.impl.FlowBuilderFactory; import org.onap.appc.dg.flowbuilder.exception.InvalidDependencyModelException; diff --git a/appc-sequence-generator/appc-sequence-generator-bundle/src/main/java/org/onap/appc/seqgen/provider/SequenceGeneratorProvider.java b/appc-sequence-generator/appc-sequence-generator-bundle/src/main/java/org/onap/appc/seqgen/provider/SequenceGeneratorProvider.java index f00a05455..940cc2ab7 100644 --- a/appc-sequence-generator/appc-sequence-generator-bundle/src/main/java/org/onap/appc/seqgen/provider/SequenceGeneratorProvider.java +++ b/appc-sequence-generator/appc-sequence-generator-bundle/src/main/java/org/onap/appc/seqgen/provider/SequenceGeneratorProvider.java @@ -5,6 +5,8 @@ * Copyright (C) 2017-2018 AT&T Intellectual Property. All rights reserved. * ================================================================================ * Copyright (C) 2017 Amdocs + * ================================================================================ + * Modifications Copyright (C) 2019 Ericsson * ============================================================================= * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. @@ -23,28 +25,16 @@ package org.onap.appc.seqgen.provider; -import com.att.eelf.configuration.EELFLogger; -import com.att.eelf.configuration.EELFManager; -import com.google.common.util.concurrent.Futures; +import java.util.HashMap; +import java.util.HashSet; +import java.util.LinkedList; +import java.util.List; +import java.util.Map; +import java.util.Set; +import java.util.concurrent.ExecutorService; +import java.util.concurrent.Executors; +import java.util.concurrent.Future; import org.apache.commons.lang.StringUtils; -import org.opendaylight.controller.md.sal.binding.api.DataBroker; -import org.opendaylight.controller.sal.binding.api.BindingAwareBroker; -import org.opendaylight.controller.sal.binding.api.NotificationProviderService; -import org.opendaylight.controller.sal.binding.api.RpcProviderRegistry; -import org.opendaylight.yang.gen.v1.org.onap.appc.sequencegenerator.rev170706.GenerateSequenceInput; -import org.opendaylight.yang.gen.v1.org.onap.appc.sequencegenerator.rev170706.GenerateSequenceOutput; -import org.opendaylight.yang.gen.v1.org.onap.appc.sequencegenerator.rev170706.GenerateSequenceOutputBuilder; -import org.opendaylight.yang.gen.v1.org.onap.appc.sequencegenerator.rev170706.SequenceGeneratorService; -import org.opendaylight.yang.gen.v1.org.onap.appc.sequencegenerator.rev170706.dependency.info.dependency.info.Vnfcs; -import org.opendaylight.yang.gen.v1.org.onap.appc.sequencegenerator.rev170706.inventory.info.inventory.info.vnf.info.Vm; -import org.opendaylight.yang.gen.v1.org.onap.appc.sequencegenerator.rev170706.response.StatusBuilder; -import org.opendaylight.yang.gen.v1.org.onap.appc.sequencegenerator.rev170706.response.Transactions; -import org.opendaylight.yang.gen.v1.org.onap.appc.sequencegenerator.rev170706.response.TransactionsBuilder; -import org.opendaylight.yang.gen.v1.org.onap.appc.sequencegenerator.rev170706.response.transactions.ActionIdentifier; -import org.opendaylight.yang.gen.v1.org.onap.appc.sequencegenerator.rev170706.response.transactions.*; -import org.opendaylight.yang.gen.v1.org.onap.appc.sequencegenerator.rev170706.response.transactions.responses.ResponseActionBuilder; -import org.opendaylight.yangtools.yang.common.RpcResult; -import org.opendaylight.yangtools.yang.common.RpcResultBuilder; import org.onap.appc.dg.objects.InventoryModel; import org.onap.appc.dg.objects.Node; import org.onap.appc.dg.objects.VnfcDependencyModel; @@ -63,18 +53,34 @@ import org.onap.appc.seqgen.objects.Response; import org.onap.appc.seqgen.objects.SequenceGeneratorInput; import org.onap.appc.seqgen.objects.SequenceGeneratorInputBuilder; import org.onap.appc.seqgen.objects.Transaction; -import java.util.HashMap; -import java.util.HashSet; -import java.util.LinkedList; -import java.util.List; -import java.util.Map; -import java.util.Set; -import java.util.concurrent.ExecutorService; -import java.util.concurrent.Executors; -import java.util.concurrent.Future; +import org.opendaylight.controller.md.sal.binding.api.DataBroker; +import org.opendaylight.controller.sal.binding.api.BindingAwareBroker; +import org.opendaylight.controller.sal.binding.api.NotificationProviderService; +import org.opendaylight.controller.sal.binding.api.RpcProviderRegistry; +import org.opendaylight.yang.gen.v1.org.onap.appc.sequencegenerator.rev170706.GenerateSequenceInput; +import org.opendaylight.yang.gen.v1.org.onap.appc.sequencegenerator.rev170706.GenerateSequenceOutput; +import org.opendaylight.yang.gen.v1.org.onap.appc.sequencegenerator.rev170706.GenerateSequenceOutputBuilder; +import org.opendaylight.yang.gen.v1.org.onap.appc.sequencegenerator.rev170706.SequenceGeneratorService; +import org.opendaylight.yang.gen.v1.org.onap.appc.sequencegenerator.rev170706.dependency.info.dependency.info.Vnfcs; +import org.opendaylight.yang.gen.v1.org.onap.appc.sequencegenerator.rev170706.inventory.info.inventory.info.vnf.info.Vm; +import org.opendaylight.yang.gen.v1.org.onap.appc.sequencegenerator.rev170706.response.StatusBuilder; +import org.opendaylight.yang.gen.v1.org.onap.appc.sequencegenerator.rev170706.response.Transactions; +import org.opendaylight.yang.gen.v1.org.onap.appc.sequencegenerator.rev170706.response.TransactionsBuilder; +import org.opendaylight.yang.gen.v1.org.onap.appc.sequencegenerator.rev170706.response.transactions.ActionIdentifier; +import org.opendaylight.yang.gen.v1.org.onap.appc.sequencegenerator.rev170706.response.transactions.ActionIdentifierBuilder; +import org.opendaylight.yang.gen.v1.org.onap.appc.sequencegenerator.rev170706.response.transactions.PrecheckOptions; +import org.opendaylight.yang.gen.v1.org.onap.appc.sequencegenerator.rev170706.response.transactions.PrecheckOptionsBuilder; +import org.opendaylight.yang.gen.v1.org.onap.appc.sequencegenerator.rev170706.response.transactions.Responses; +import org.opendaylight.yang.gen.v1.org.onap.appc.sequencegenerator.rev170706.response.transactions.ResponsesBuilder; +import org.opendaylight.yang.gen.v1.org.onap.appc.sequencegenerator.rev170706.response.transactions.responses.ResponseActionBuilder; +import org.opendaylight.yangtools.yang.common.RpcResult; +import org.opendaylight.yangtools.yang.common.RpcResultBuilder; +import com.att.eelf.configuration.EELFLogger; +import com.att.eelf.configuration.EELFManager; +import com.google.common.util.concurrent.Futures; -public class SequenceGeneratorProvider implements AutoCloseable,SequenceGeneratorService{ +public class SequenceGeneratorProvider implements AutoCloseable,SequenceGeneratorService { protected DataBroker dataBroker; protected RpcProviderRegistry rpcRegistry; protected NotificationProviderService notificationService; @@ -83,8 +89,8 @@ public class SequenceGeneratorProvider implements AutoCloseable,SequenceGenerato private final ExecutorService executor; private final static String APP_NAME = "SequenceGeneratorProvider"; - public SequenceGeneratorProvider(DataBroker dataBroker2, NotificationProviderService notificationProviderService - , RpcProviderRegistry rpcRegistry2) { + public SequenceGeneratorProvider(DataBroker dataBroker2, NotificationProviderService notificationProviderService, + RpcProviderRegistry rpcRegistry2) { log.info("Creating provider for " + APP_NAME); executor = Executors.newFixedThreadPool(1); this.dataBroker = dataBroker2; @@ -104,7 +110,7 @@ public class SequenceGeneratorProvider implements AutoCloseable,SequenceGenerato if(this.executor != null){ executor.shutdown(); } - if(this.rpcRegistration != null){ + if(this.rpcRegistration != null) { rpcRegistration.close(); } log.info("Successfully closed provider for " + APP_NAME); @@ -133,7 +139,7 @@ public class SequenceGeneratorProvider implements AutoCloseable,SequenceGenerato private RpcResult<GenerateSequenceOutput> buildSuccessResponse(List<Transaction> transactions) { log.info("Building response from the list of transactions"); List<Transactions> transactionList = new LinkedList<>(); - for(Transaction transaction:transactions){ + for(Transaction transaction: transactions) { ActionIdentifier actionIdentifier = buildActionIdentifierForResponse(transaction); List<PrecheckOptions> precheckOptions = buildPrecheckOptionsForResponse(transaction); List<Responses> responseList = getResponses(transaction); @@ -175,7 +181,7 @@ public class SequenceGeneratorProvider implements AutoCloseable,SequenceGenerato private List<PrecheckOptions> buildPrecheckOptionsForResponse(Transaction transaction) { log.info("Adding Precheck options to response"); List<PrecheckOptions> precheckOptions = new LinkedList<>(); - if(transaction.getPrecheckOptions()!=null){ + if(transaction.getPrecheckOptions() != null){ for(PreCheckOption option:transaction.getPrecheckOptions()){ PrecheckOptions precheckOption = new PrecheckOptionsBuilder() .setParamName(option.getParamName()) @@ -193,23 +199,23 @@ public class SequenceGeneratorProvider implements AutoCloseable,SequenceGenerato for(Response resp : transaction.getResponses()){ Map<String,String> responseActions = resp.getResponseAction(); ResponseActionBuilder responseActionBuilder = new ResponseActionBuilder(); - if(responseActions.get(Constants.ResponseAction.WAIT.getAction())!=null){ + if(responseActions.get(Constants.ResponseAction.WAIT.getAction()) != null){ responseActionBuilder = responseActionBuilder.setWait(Integer.parseInt(responseActions.get(Constants.ResponseAction.WAIT.getAction()))); } - if(responseActions.get(Constants.ResponseAction.RETRY.getAction())!=null){ + if(responseActions.get(Constants.ResponseAction.RETRY.getAction()) != null){ responseActionBuilder = responseActionBuilder.setRetry(Integer.parseInt(responseActions.get(Constants.ResponseAction.RETRY.getAction()))); } if(responseActions.get(Constants.ResponseAction.CONTINUE.getAction().toLowerCase())!=null){ responseActionBuilder = responseActionBuilder .setContinue(Boolean.parseBoolean(responseActions.get(Constants.ResponseAction.CONTINUE.getAction().toLowerCase()))); } - if(responseActions.get(Constants.ResponseAction.IGNORE.getAction()) !=null){ + if(responseActions.get(Constants.ResponseAction.IGNORE.getAction()) != null){ responseActionBuilder = responseActionBuilder.setIgnore(Boolean.parseBoolean(responseActions.get(Constants.ResponseAction.IGNORE.getAction()))); } - if(responseActions.get(Constants.ResponseAction.STOP.getAction()) !=null){ + if(responseActions.get(Constants.ResponseAction.STOP.getAction()) != null){ responseActionBuilder = responseActionBuilder.setStop(Boolean.parseBoolean(responseActions.get(Constants.ResponseAction.STOP.getAction()))); } - if(responseActions.get(Constants.ResponseAction.JUMP.getAction()) !=null){ + if(responseActions.get(Constants.ResponseAction.JUMP.getAction()) != null){ responseActionBuilder = responseActionBuilder.setJump(Integer.parseInt(responseActions.get(Constants.ResponseAction.JUMP.getAction()))); } Responses response = new ResponsesBuilder() @@ -230,8 +236,8 @@ public class SequenceGeneratorProvider implements AutoCloseable,SequenceGenerato InventoryModel inventoryModel = readInventoryModel(input); VnfcDependencyModel dependencyModel = readDependencyModel(input); - if(dependencyModel!=null){ - validateInventoryModelWithDependencyModel(dependencyModel,inventoryModel); + if(dependencyModel != null){ + validateInventoryModelWithDependencyModel(dependencyModel, inventoryModel); } SequenceGeneratorInputBuilder builder = new SequenceGeneratorInputBuilder() @@ -251,8 +257,8 @@ public class SequenceGeneratorProvider implements AutoCloseable,SequenceGenerato if(input.getTunableParameters() != null){ builder = builder.tunableParameter(Constants.RETRY_COUNT,String.valueOf(input.getTunableParameters().getRetryCount())) .tunableParameter(Constants.WAIT_TIME,String.valueOf(input.getTunableParameters().getWaitTime())); - if(input.getTunableParameters().getStrategy() !=null){ - builder = builder.tunableParameter(Constants.STRATEGY,input.getTunableParameters().getStrategy().name()); + if(input.getTunableParameters().getStrategy() != null){ + builder = builder.tunableParameter(Constants.STRATEGY,input.getTunableParameters().getStrategy().name()); } } return builder; @@ -260,18 +266,18 @@ public class SequenceGeneratorProvider implements AutoCloseable,SequenceGenerato private SequenceGeneratorInputBuilder buildCapabilitiesForSeqGenInput(GenerateSequenceInput input, SequenceGeneratorInputBuilder builder) { log.info("Initializing capabilities based on YANG object."); - if(input.getCapabilities() !=null){ - if(input.getCapabilities().getVnf()!=null){ - builder = builder.capability("vnf",input.getCapabilities().getVnf()); + if(input.getCapabilities() != null){ + if(input.getCapabilities().getVnf() != null){ + builder = builder.capability("vnf", input.getCapabilities().getVnf()); } - if(input.getCapabilities().getVnfc()!=null){ - builder = builder.capability("vnfc",input.getCapabilities().getVnfc()); + if(input.getCapabilities().getVnfc() != null){ + builder = builder.capability("vnfc", input.getCapabilities().getVnfc()); } - if(input.getCapabilities().getVm()!=null){ - builder = builder.capability("vm",input.getCapabilities().getVm()); + if(input.getCapabilities().getVm() != null){ + builder = builder.capability("vm", input.getCapabilities().getVm()); } - if(input.getCapabilities().getVfModule()!=null){ - builder = builder.capability("vf-module",input.getCapabilities().getVfModule()); + if(input.getCapabilities().getVfModule() != null){ + builder = builder.capability("vf-module", input.getCapabilities().getVfModule()); } } @@ -318,7 +324,7 @@ public class SequenceGeneratorProvider implements AutoCloseable,SequenceGenerato log.info("Building RequestInfo from Yang object"); RequestInfoBuilder requestInfobuilder = buildRequestInformation(input); - if(input.getRequestInfo().getActionIdentifier() !=null){ + if(input.getRequestInfo().getActionIdentifier() != null){ requestInfobuilder = buildActionIdentifiers(input, requestInfobuilder); } @@ -344,16 +350,16 @@ public class SequenceGeneratorProvider implements AutoCloseable,SequenceGenerato } private void validateMandatory(GenerateSequenceInput input) throws APPCException { - if(input.getRequestInfo() ==null){ + if(input.getRequestInfo() == null){ throw new APPCException("Request Info is not present in the request"); } - if(input.getRequestInfo().getAction() ==null){ + if(input.getRequestInfo().getAction() == null){ throw new APPCException("Action is not present in the request"); } - if(input.getInventoryInfo() ==null){ + if(input.getInventoryInfo() == null){ throw new APPCException("inventoryInfo is not provided in the input"); } - if (input.getInventoryInfo().getVnfInfo()== null) { + if (input.getInventoryInfo().getVnfInfo() == null) { log.error("vnfInfo is null in the input"); throw new APPCException("vnfInfo is missing in the input"); } @@ -366,23 +372,23 @@ public class SequenceGeneratorProvider implements AutoCloseable,SequenceGenerato private VnfcDependencyModel readDependencyModel(GenerateSequenceInput input) throws APPCException{ log.info("Initializing DependencyModel from YANG model."); - if(input.getDependencyInfo() == null || input.getDependencyInfo().getVnfcs() ==null || input.getDependencyInfo().getVnfcs().isEmpty()){ + if(input.getDependencyInfo() == null || input.getDependencyInfo().getVnfcs() == null || input.getDependencyInfo().getVnfcs().isEmpty()){ log.info("No dependency model information is present for the request."); return null; } List<Vnfcs> vnfcs = input.getDependencyInfo().getVnfcs(); Set<Node<org.onap.appc.domainmodel.Vnfc>> dependencies = new HashSet<>(); - Set<String> parentVnfcs=new HashSet<>(); - Set<String> allVnfcTypes=new HashSet<>(); - for(Vnfcs vnfcObj:vnfcs){ + Set<String> parentVnfcs = new HashSet<>(); + Set<String> allVnfcTypes = new HashSet<>(); + for(Vnfcs vnfcObj:vnfcs) { org.onap.appc.domainmodel.Vnfc vnfc = new org.onap.appc.domainmodel.Vnfc(); vnfc.setVnfcType(vnfcObj.getVnfcType()); allVnfcTypes.add(vnfcObj.getVnfcType()); vnfc.setResilienceType(vnfcObj.getResilience()); Node<Vnfc> currentNode = buildVnfcNodeForDependenyInfo(dependencies, vnfcObj, vnfc); - for(String parentVnfcType:vnfcObj.getParents()){ + for(String parentVnfcType:vnfcObj.getParents()) { parentVnfcs.add(parentVnfcType); - Node<Vnfc> parentNode = readNode(parentVnfcType,dependencies); + Node<Vnfc> parentNode = readNode(parentVnfcType, dependencies); if(parentNode == null){ Vnfc parentVnfc = new Vnfc(); parentVnfc.setVnfcType(parentVnfcType); @@ -397,14 +403,14 @@ public class SequenceGeneratorProvider implements AutoCloseable,SequenceGenerato } for(String parent:parentVnfcs){ if(!allVnfcTypes.contains(parent)){ - throw new APPCException("Dependency model missing vnfc type "+parent); + throw new APPCException("Dependency model missing vnfc type " + parent); } } return new VnfcDependencyModel(dependencies); } private Node<Vnfc> buildVnfcNodeForDependenyInfo(Set<Node<Vnfc>> dependencies, Vnfcs vnfcObj, Vnfc vnfc) { - Node<Vnfc> currentNode = readNode(vnfcObj.getVnfcType(),dependencies); + Node<Vnfc> currentNode = readNode(vnfcObj.getVnfcType(), dependencies); if(currentNode == null){ currentNode = new Node<>(vnfc); dependencies.add(currentNode); @@ -429,9 +435,9 @@ public class SequenceGeneratorProvider implements AutoCloseable,SequenceGenerato log.info("Initializing InventoryModel from Yang input model"); Vnf vnf = createVnfForInventoryModel(input); - Map<org.onap.appc.domainmodel.Vnfc,List<Vserver>> map = new HashMap<>(); + Map<org.onap.appc.domainmodel.Vnfc, List<Vserver>> map = new HashMap<>(); buildVserverDetailsForInventoryModel(input, vnf, map); - for(Map.Entry<org.onap.appc.domainmodel.Vnfc,List<Vserver>> entry:map.entrySet()){ + for(Map.Entry<org.onap.appc.domainmodel.Vnfc, List<Vserver>> entry:map.entrySet()){ org.onap.appc.domainmodel.Vnfc vnfc = entry.getKey(); List<Vserver> vmList = entry.getValue(); vnfc.addVservers(vmList); @@ -440,23 +446,23 @@ public class SequenceGeneratorProvider implements AutoCloseable,SequenceGenerato } private void buildVserverDetailsForInventoryModel(GenerateSequenceInput input, Vnf vnf, Map<Vnfc, List<Vserver>> map) throws APPCException { - if(input.getInventoryInfo().getVnfInfo().getVm().size()<1){ + if(input.getInventoryInfo().getVnfInfo().getVm().size() < 1) { throw new APPCException("vnfInfo is missing in the input"); } - for(Vm vm:input.getInventoryInfo().getVnfInfo().getVm()){ + for(Vm vm:input.getInventoryInfo().getVnfInfo().getVm()) { if(StringUtils.isBlank(vm.getVserverId())){ throw new APPCException("vserver-id not found "); } Vserver vserver=new Vserver(); vserver.setId(vm.getVserverId()); if(!StringUtils.isBlank(vm.getVnfc().getVnfcName()) && - !StringUtils.isBlank(vm.getVnfc().getVnfcType())){ + !StringUtils.isBlank(vm.getVnfc().getVnfcType())) { Vnfc vfc = new Vnfc(); vfc.setVnfcName(vm.getVnfc().getVnfcName()); vfc.setVnfcType(vm.getVnfc().getVnfcType()); vserver.setVnfc(vfc); List<Vserver> vms = map.get(vfc); - if(vms ==null){ + if(vms ==null) { vms = new LinkedList<>(); map.put(vfc,vms); } @@ -477,7 +483,7 @@ public class SequenceGeneratorProvider implements AutoCloseable,SequenceGenerato private RpcResult<GenerateSequenceOutput> buildFailureResponse(String errorMessage){ GenerateSequenceOutputBuilder sequenceGeneratorOutputBuilder=new GenerateSequenceOutputBuilder(); - StatusBuilder statusBuilder =new StatusBuilder(); + StatusBuilder statusBuilder = new StatusBuilder(); statusBuilder.setCode(401); statusBuilder.setMessage(errorMessage); sequenceGeneratorOutputBuilder.setStatus(statusBuilder.build()); diff --git a/appc-sequence-generator/appc-sequence-generator-bundle/src/test/java/org/onap/appc/seqgen/provider/SequenceGeneratorProviderTest.java b/appc-sequence-generator/appc-sequence-generator-bundle/src/test/java/org/onap/appc/seqgen/provider/SequenceGeneratorProviderTest.java new file mode 100644 index 000000000..7f54718f0 --- /dev/null +++ b/appc-sequence-generator/appc-sequence-generator-bundle/src/test/java/org/onap/appc/seqgen/provider/SequenceGeneratorProviderTest.java @@ -0,0 +1,119 @@ +/* + * ============LICENSE_START======================================================= + * ONAP : APPC + * ================================================================================ + * Copyright (C) 2019 Ericsson + * ================================================================================ + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + * + * ============LICENSE_END========================================================= + */ + +package org.onap.appc.seqgen.provider; + +import static org.junit.Assert.assertTrue; +import java.util.ArrayList; +import java.util.List; +import org.junit.Test; +import org.mockito.Mockito; +import org.opendaylight.controller.md.sal.binding.api.DataBroker; +import org.opendaylight.controller.sal.binding.api.BindingAwareBroker; +import org.opendaylight.controller.sal.binding.api.NotificationProviderService; +import org.opendaylight.controller.sal.binding.api.RpcProviderRegistry; +import org.opendaylight.yang.gen.v1.org.onap.appc.sequencegenerator.rev170706.GenerateSequenceInput; +import org.opendaylight.yang.gen.v1.org.onap.appc.sequencegenerator.rev170706.GenerateSequenceInputBuilder; +import org.opendaylight.yang.gen.v1.org.onap.appc.sequencegenerator.rev170706.SequenceGeneratorService; +import org.opendaylight.yang.gen.v1.org.onap.appc.sequencegenerator.rev170706.dependency.info.DependencyInfo; +import org.opendaylight.yang.gen.v1.org.onap.appc.sequencegenerator.rev170706.dependency.info.DependencyInfoBuilder; +import org.opendaylight.yang.gen.v1.org.onap.appc.sequencegenerator.rev170706.dependency.info.dependency.info.Vnfcs; +import org.opendaylight.yang.gen.v1.org.onap.appc.sequencegenerator.rev170706.dependency.info.dependency.info.VnfcsBuilder; +import org.opendaylight.yang.gen.v1.org.onap.appc.sequencegenerator.rev170706.inventory.info.InventoryInfo; +import org.opendaylight.yang.gen.v1.org.onap.appc.sequencegenerator.rev170706.inventory.info.InventoryInfoBuilder; +import org.opendaylight.yang.gen.v1.org.onap.appc.sequencegenerator.rev170706.inventory.info.inventory.info.VnfInfo; +import org.opendaylight.yang.gen.v1.org.onap.appc.sequencegenerator.rev170706.inventory.info.inventory.info.VnfInfoBuilder; +import org.opendaylight.yang.gen.v1.org.onap.appc.sequencegenerator.rev170706.inventory.info.inventory.info.vnf.info.Vm; +import org.opendaylight.yang.gen.v1.org.onap.appc.sequencegenerator.rev170706.inventory.info.inventory.info.vnf.info.VmBuilder; +import org.opendaylight.yang.gen.v1.org.onap.appc.sequencegenerator.rev170706.inventory.info.inventory.info.vnf.info.vm.Vnfc; +import org.opendaylight.yang.gen.v1.org.onap.appc.sequencegenerator.rev170706.inventory.info.inventory.info.vnf.info.vm.VnfcBuilder; +import org.opendaylight.yang.gen.v1.org.onap.appc.sequencegenerator.rev170706.request.info.RequestInfo; +import org.opendaylight.yang.gen.v1.org.onap.appc.sequencegenerator.rev170706.request.info.RequestInfo.Action; +import org.opendaylight.yang.gen.v1.org.onap.appc.sequencegenerator.rev170706.request.info.RequestInfo.ActionLevel; +import org.opendaylight.yang.gen.v1.org.onap.appc.sequencegenerator.rev170706.request.info.RequestInfoBuilder; +import org.opendaylight.yangtools.yang.common.RpcResult; + + +public class SequenceGeneratorProviderTest { + + private DataBroker dataBroker = Mockito.mock(DataBroker.class); + private RpcProviderRegistry rpcRegistry = Mockito.mock(RpcProviderRegistry.class); + private NotificationProviderService notificationService = Mockito.mock(NotificationProviderService.class); + + @Test + public void testClose() throws Exception { + BindingAwareBroker.RpcRegistration<SequenceGeneratorService> registration = + (BindingAwareBroker.RpcRegistration<SequenceGeneratorService>) Mockito.mock(BindingAwareBroker.RpcRegistration.class); + Mockito.doReturn(registration).when(rpcRegistry).addRpcImplementation(Mockito.any(), Mockito.any()); + SequenceGeneratorProvider provider = new SequenceGeneratorProvider(dataBroker, notificationService, rpcRegistry); + provider.close(); + Mockito.verify(provider.rpcRegistration).close(); + } + + @Test + public void testGenerateSequence() throws Exception { + BindingAwareBroker.RpcRegistration<SequenceGeneratorService> registration = + (BindingAwareBroker.RpcRegistration<SequenceGeneratorService>) Mockito.mock(BindingAwareBroker.RpcRegistration.class); + Mockito.doReturn(registration).when(rpcRegistry).addRpcImplementation(Mockito.any(), Mockito.any()); + SequenceGeneratorProvider provider = new SequenceGeneratorProvider(dataBroker, notificationService, rpcRegistry); + GenerateSequenceInputBuilder builder = new GenerateSequenceInputBuilder(); + RequestInfoBuilder riBuilder = new RequestInfoBuilder(); + riBuilder.setAction(Action.Start); + riBuilder.setActionLevel(ActionLevel.Vm); + riBuilder.setPayload("PAYLOAD"); + RequestInfo info = riBuilder.build(); + builder.setRequestInfo(info); + InventoryInfoBuilder iiBuilder = new InventoryInfoBuilder(); + VnfInfoBuilder viBuilder = new VnfInfoBuilder(); + viBuilder.setVnfId("VNF_ID"); + List<Vm> vmList = new ArrayList<Vm>(); + VmBuilder vmBuilder = new VmBuilder(); + vmBuilder.setVmId("VM_ID"); + vmBuilder.setVserverId("VSERVER_ID"); + VnfcBuilder vnfcBuilder = new VnfcBuilder(); + vnfcBuilder.setVnfcName("VNFC_NAME"); + vnfcBuilder.setVnfcType("VNFC_TYPE"); + Vnfc vnfc = vnfcBuilder.build(); + vmBuilder.setVnfc(vnfc); + Vm vm = vmBuilder.build(); + vmList.add(vm); + viBuilder.setVm(vmList); + VnfInfo vnfInfo = viBuilder.build(); + iiBuilder.setVnfInfo(vnfInfo); + InventoryInfo iInfo = iiBuilder.build(); + builder.setInventoryInfo(iInfo); + DependencyInfoBuilder dependencyBuilder = new DependencyInfoBuilder(); + List<Vnfcs> vnfcsList = new ArrayList<>(); + VnfcsBuilder vnfcsBuilder = new VnfcsBuilder(); + vnfcsBuilder.setVnfcType("VNFC_TYPE"); + List<String> parentList = new ArrayList<>(); + parentList.add("VNFC_TYPE"); + vnfcsBuilder.setParents(parentList); + Vnfcs vnfcs = vnfcsBuilder.build(); + vnfcsList.add(vnfcs); + dependencyBuilder.setVnfcs(vnfcsList); + DependencyInfo dependencyInfo = dependencyBuilder.build(); + builder.setDependencyInfo(dependencyInfo); + GenerateSequenceInput input = builder.build(); + assertTrue(provider.generateSequence(input).get() instanceof RpcResult); + } + +} |