From ff3eecb980bfdc8d43d2ed3a4c786d634fa6f4e2 Mon Sep 17 00:00:00 2001 From: Jessica Wagantall Date: Tue, 1 Dec 2020 11:52:01 -0800 Subject: Migrate sli-northbound repo Migrate sli-northbound repo files into new directory "northbound". Signed-off-by: Jessica Wagantall --- .../org/onap/ccsdk/sli/northbound/LcmProvider.java | 1126 -------------------- .../onap/ccsdk/sli/northbound/LcmResponseCode.java | 51 - .../sli/northbound/LcmRpcInvocationException.java | 25 - .../onap/ccsdk/sli/northbound/LcmSliClient.java | 99 -- .../resources/OSGI-INF/blueprint/lcm-blueprint.xml | 34 - .../org/opendaylight/blueprint/lcm-blueprint.xml | 34 - 6 files changed, 1369 deletions(-) delete mode 100644 lcm/provider/src/main/java/org/onap/ccsdk/sli/northbound/LcmProvider.java delete mode 100644 lcm/provider/src/main/java/org/onap/ccsdk/sli/northbound/LcmResponseCode.java delete mode 100644 lcm/provider/src/main/java/org/onap/ccsdk/sli/northbound/LcmRpcInvocationException.java delete mode 100644 lcm/provider/src/main/java/org/onap/ccsdk/sli/northbound/LcmSliClient.java delete mode 100644 lcm/provider/src/main/resources/OSGI-INF/blueprint/lcm-blueprint.xml delete mode 100644 lcm/provider/src/main/resources/org/opendaylight/blueprint/lcm-blueprint.xml (limited to 'lcm/provider/src/main') diff --git a/lcm/provider/src/main/java/org/onap/ccsdk/sli/northbound/LcmProvider.java b/lcm/provider/src/main/java/org/onap/ccsdk/sli/northbound/LcmProvider.java deleted file mode 100644 index 100496e39..000000000 --- a/lcm/provider/src/main/java/org/onap/ccsdk/sli/northbound/LcmProvider.java +++ /dev/null @@ -1,1126 +0,0 @@ -package org.onap.ccsdk.sli.northbound; -/*- - * ============LICENSE_START======================================================= - * openECOMP : SDN-C - * ================================================================================ - * Copyright (C) 2017 AT&T Intellectual Property. All rights - * reserved. - * Modifications Copyright © 2018 IBM. - * ================================================================================ - * 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========================================================= - */ - -import java.text.SimpleDateFormat; -import java.util.Date; -import java.util.Properties; -import java.util.concurrent.ExecutorService; -import java.util.concurrent.Executors; -import java.util.concurrent.Future; -import org.onap.ccsdk.sli.core.sli.provider.MdsalHelper; -import org.opendaylight.controller.md.sal.binding.api.DataBroker; -import org.opendaylight.controller.md.sal.binding.api.NotificationPublishService; -import org.opendaylight.controller.md.sal.binding.impl.AbstractForwardedDataBroker; -import org.opendaylight.controller.md.sal.dom.api.DOMDataBroker; -import org.opendaylight.controller.sal.binding.api.BindingAwareBroker; -import org.opendaylight.controller.sal.binding.api.RpcProviderRegistry; -import org.opendaylight.yang.gen.v1.org.onap.ccsdk.sli.northbound.lcm.rev180329.*; -import org.opendaylight.yang.gen.v1.org.onap.ccsdk.sli.northbound.lcm.rev180329.common.header.CommonHeaderBuilder; -import org.opendaylight.yang.gen.v1.org.onap.ccsdk.sli.northbound.lcm.rev180329.status.StatusBuilder; -import org.opendaylight.yangtools.yang.common.RpcResult; -import org.opendaylight.yangtools.yang.common.RpcResultBuilder; -import org.slf4j.Logger; -import org.slf4j.LoggerFactory; - -import com.google.common.util.concurrent.Futures; -import com.google.common.util.concurrent.ListenableFuture; - -import org.onap.ccsdk.sli.northbound.LcmResponseCode.*; - -/** - * Defines a base implementation for your provider. This class extends from a - * helper class which provides storage for the most commonly used components of - * the MD-SAL. Additionally the base class provides some basic logging and - * initialization / clean up methods. - * - */ -public class LcmProvider implements AutoCloseable, LCMService { - - private class CommonLcmFields { - private StatusBuilder statusBuilder; - private CommonHeaderBuilder commonHeaderBuilder; - private Payload payload; - - public CommonLcmFields(StatusBuilder statusBuilder, CommonHeaderBuilder commonHeaderBuilder) { - this.statusBuilder = statusBuilder; - this.commonHeaderBuilder = commonHeaderBuilder; - this.payload = null; - } - - public CommonLcmFields(StatusBuilder statusBuilder, CommonHeaderBuilder commonHeaderBuilder, Payload payload) { - this.statusBuilder = statusBuilder; - this.commonHeaderBuilder = commonHeaderBuilder; - this.payload = payload; - } - - public StatusBuilder getStatusBuilder() { - return statusBuilder; - } - - public CommonHeaderBuilder getCommonHeaderBuilder() { - return commonHeaderBuilder; - } - - public Payload getPayload() { - return payload; - } - } - - private static final Logger LOG = LoggerFactory.getLogger(LcmProvider.class); - - private static final String exceptionMessage = "Caught exception"; - - private static final String APPLICATION_NAME = "LCM"; - - private final ExecutorService executor; - protected DataBroker dataBroker; - protected DOMDataBroker domDataBroker; - protected NotificationPublishService notificationService; - protected RpcProviderRegistry rpcRegistry; - private final LcmSliClient lcmSliClient; - - protected BindingAwareBroker.RpcRegistration rpcRegistration; - - public LcmProvider(final DataBroker dataBroker, final NotificationPublishService notificationPublishService, - final RpcProviderRegistry rpcProviderRegistry, final LcmSliClient lcmSliClient) { - - LOG.info("Creating provider for {}", APPLICATION_NAME); - executor = Executors.newFixedThreadPool(1); - this.dataBroker = dataBroker; - if (dataBroker instanceof AbstractForwardedDataBroker) { - domDataBroker = ((AbstractForwardedDataBroker) dataBroker).getDelegate(); - } - notificationService = notificationPublishService; - rpcRegistry = rpcProviderRegistry; - this.lcmSliClient = lcmSliClient; - initialize(); - } - - public void initialize() { - LOG.info("Initializing {} for {}", this.getClass().getName(), APPLICATION_NAME); - - if (rpcRegistration == null) { - if (rpcRegistry != null) { - rpcRegistration = rpcRegistry.addRpcImplementation(LCMService.class, this); - LOG.info("Initialization complete for {}", APPLICATION_NAME); - } else { - LOG.warn("Error initializing {} : rpcRegistry unset", APPLICATION_NAME); - } - } - } - - protected void initializeChild() { - // Override if you have custom initialization intelligence - } - - @Override - public void close() throws Exception { - LOG.info("Closing provider for " + APPLICATION_NAME); - executor.shutdown(); - rpcRegistration.close(); - LOG.info("Successfully closed provider for " + APPLICATION_NAME); - } - - - - @Override - public ListenableFuture> checkLock(CheckLockInput input) { - CheckLockInputBuilder iBuilder = new CheckLockInputBuilder(input); - CheckLockOutputBuilder oBuilder = new CheckLockOutputBuilder(); - - try { - CommonLcmFields retval = callDG("check-lock", iBuilder.build()); - oBuilder.setStatus(retval.getStatusBuilder().build()); - oBuilder.setCommonHeader(retval.getCommonHeaderBuilder().build()); - } catch (LcmRpcInvocationException e) { - LOG.debug(exceptionMessage, e); - oBuilder.setCommonHeader(e.getCommonHeader()); - oBuilder.setStatus(e.getStatus()); - } - - RpcResult rpcResult = - RpcResultBuilder. status(true).withResult(oBuilder.build()).build(); - // return error - return Futures.immediateFuture(rpcResult); - - } - - @Override - public ListenableFuture> reboot(RebootInput input) { - RebootInputBuilder iBuilder = new RebootInputBuilder(input); - RebootOutputBuilder oBuilder = new RebootOutputBuilder(); - - try { - CommonLcmFields retval = callDG("reboot", iBuilder.build()); - oBuilder.setStatus(retval.getStatusBuilder().build()); - oBuilder.setCommonHeader(retval.getCommonHeaderBuilder().build()); - } catch (LcmRpcInvocationException e) { - LOG.debug(exceptionMessage, e); - oBuilder.setCommonHeader(e.getCommonHeader()); - oBuilder.setStatus(e.getStatus()); - } - - RpcResult rpcResult = - RpcResultBuilder. status(true).withResult(oBuilder.build()).build(); - // return error - return Futures.immediateFuture(rpcResult); - } - - @Override - public ListenableFuture> upgradeBackup(UpgradeBackupInput input) { - UpgradeBackupInputBuilder iBuilder = new UpgradeBackupInputBuilder(input); - UpgradeBackupOutputBuilder oBuilder = new UpgradeBackupOutputBuilder(); - - try { - CommonLcmFields retval = callDG("upgrade-backup", iBuilder.build()); - oBuilder.setStatus(retval.getStatusBuilder().build()); - oBuilder.setCommonHeader(retval.getCommonHeaderBuilder().build()); - - } catch (LcmRpcInvocationException e) { - LOG.debug(exceptionMessage, e); - oBuilder.setCommonHeader(e.getCommonHeader()); - oBuilder.setStatus(e.getStatus()); - } - - RpcResult rpcResult = - RpcResultBuilder. status(true).withResult(oBuilder.build()).build(); - // return error - return Futures.immediateFuture(rpcResult); - } - - @Override - public ListenableFuture> rollback(RollbackInput input) { - RollbackInputBuilder iBuilder = new RollbackInputBuilder(input); - RollbackOutputBuilder oBuilder = new RollbackOutputBuilder(); - - try { - CommonLcmFields retval = callDG("rollback", iBuilder.build()); - oBuilder.setStatus(retval.getStatusBuilder().build()); - oBuilder.setCommonHeader(retval.getCommonHeaderBuilder().build()); - if (retval.getPayload() != null) { - oBuilder.setPayload(retval.getPayload()); - } - } catch (LcmRpcInvocationException e) { - LOG.debug(exceptionMessage, e); - oBuilder.setCommonHeader(e.getCommonHeader()); - oBuilder.setStatus(e.getStatus()); - } - - RpcResult rpcResult = - RpcResultBuilder. status(true).withResult(oBuilder.build()).build(); - // return error - return Futures.immediateFuture(rpcResult); - } - - @Override - public ListenableFuture> sync(SyncInput input) { - SyncInputBuilder iBuilder = new SyncInputBuilder(input); - SyncOutputBuilder oBuilder = new SyncOutputBuilder(); - - try { - CommonLcmFields retval = callDG("sync", iBuilder.build()); - oBuilder.setStatus(retval.getStatusBuilder().build()); - oBuilder.setCommonHeader(retval.getCommonHeaderBuilder().build()); - } catch (LcmRpcInvocationException e) { - LOG.debug(exceptionMessage, e); - oBuilder.setCommonHeader(e.getCommonHeader()); - oBuilder.setStatus(e.getStatus()); - } - - RpcResult rpcResult = - RpcResultBuilder. status(true).withResult(oBuilder.build()).build(); - // return error - return Futures.immediateFuture(rpcResult); - } - - @Override - public ListenableFuture> query(QueryInput input) { - QueryInputBuilder iBuilder = new QueryInputBuilder(input); - QueryOutputBuilder oBuilder = new QueryOutputBuilder(); - - try { - CommonLcmFields retval = callDG("query", iBuilder.build()); - oBuilder.setStatus(retval.getStatusBuilder().build()); - oBuilder.setCommonHeader(retval.getCommonHeaderBuilder().build()); - } catch (LcmRpcInvocationException e) { - LOG.debug(exceptionMessage, e); - oBuilder.setCommonHeader(e.getCommonHeader()); - oBuilder.setStatus(e.getStatus()); - } - - RpcResult rpcResult = - RpcResultBuilder. status(true).withResult(oBuilder.build()).build(); - // return error - return Futures.immediateFuture(rpcResult); - } - - @Override - public ListenableFuture> configExport(ConfigExportInput input) { - ConfigExportInputBuilder iBuilder = new ConfigExportInputBuilder(input); - ConfigExportOutputBuilder oBuilder = new ConfigExportOutputBuilder(); - - try { - CommonLcmFields retval = callDG("config-export", iBuilder.build()); - oBuilder.setStatus(retval.getStatusBuilder().build()); - oBuilder.setCommonHeader(retval.getCommonHeaderBuilder().build()); - } catch (LcmRpcInvocationException e) { - LOG.debug(exceptionMessage, e); - oBuilder.setCommonHeader(e.getCommonHeader()); - oBuilder.setStatus(e.getStatus()); - } - - RpcResult rpcResult = - RpcResultBuilder. status(true).withResult(oBuilder.build()).build(); - // return error - return Futures.immediateFuture(rpcResult); - } - - @Override - public ListenableFuture> stopApplication(StopApplicationInput input) { - StopApplicationInputBuilder iBuilder = new StopApplicationInputBuilder(input); - StopApplicationOutputBuilder oBuilder = new StopApplicationOutputBuilder(); - - try { - CommonLcmFields retval = callDG("stop-application", iBuilder.build()); - oBuilder.setStatus(retval.getStatusBuilder().build()); - oBuilder.setCommonHeader(retval.getCommonHeaderBuilder().build()); - } catch (LcmRpcInvocationException e) { - LOG.debug(exceptionMessage, e); - oBuilder.setCommonHeader(e.getCommonHeader()); - oBuilder.setStatus(e.getStatus()); - } - - RpcResult rpcResult = - RpcResultBuilder. status(true).withResult(oBuilder.build()).build(); - // return error - return Futures.immediateFuture(rpcResult); - } - - @Override - public ListenableFuture> softwareUpload(SoftwareUploadInput input) { - SoftwareUploadInputBuilder iBuilder = new SoftwareUploadInputBuilder(input); - SoftwareUploadOutputBuilder oBuilder = new SoftwareUploadOutputBuilder(); - - try { - CommonLcmFields retval = callDG("software-upload", iBuilder.build()); - oBuilder.setStatus(retval.getStatusBuilder().build()); - oBuilder.setCommonHeader(retval.getCommonHeaderBuilder().build()); - } catch (LcmRpcInvocationException e) { - LOG.debug(exceptionMessage, e); - oBuilder.setCommonHeader(e.getCommonHeader()); - oBuilder.setStatus(e.getStatus()); - } - - RpcResult rpcResult = - RpcResultBuilder. status(true).withResult(oBuilder.build()).build(); - // return error - return Futures.immediateFuture(rpcResult); - } - - @Override - public ListenableFuture> resumeTraffic(ResumeTrafficInput input) { - ResumeTrafficInputBuilder iBuilder = new ResumeTrafficInputBuilder(input); - ResumeTrafficOutputBuilder oBuilder = new ResumeTrafficOutputBuilder(); - - try { - CommonLcmFields retval = callDG("resume-traffic", iBuilder.build()); - oBuilder.setStatus(retval.getStatusBuilder().build()); - oBuilder.setCommonHeader(retval.getCommonHeaderBuilder().build()); - } catch (LcmRpcInvocationException e) { - LOG.debug(exceptionMessage, e); - oBuilder.setCommonHeader(e.getCommonHeader()); - oBuilder.setStatus(e.getStatus()); - } - - RpcResult rpcResult = - RpcResultBuilder. status(true).withResult(oBuilder.build()).build(); - // return error - return Futures.immediateFuture(rpcResult); - } - - @Override - public ListenableFuture> distributeTraffic(DistributeTrafficInput input) { - DistributeTrafficInputBuilder iBuilder = new DistributeTrafficInputBuilder(input); - DistributeTrafficOutputBuilder oBuilder = new DistributeTrafficOutputBuilder(); - - try { - CommonLcmFields retval = callDG("distribute-traffic", iBuilder.build()); - oBuilder.setStatus(retval.getStatusBuilder().build()); - oBuilder.setCommonHeader(retval.getCommonHeaderBuilder().build()); - } catch (LcmRpcInvocationException e) { - LOG.debug(exceptionMessage, e); - oBuilder.setCommonHeader(e.getCommonHeader()); - oBuilder.setStatus(e.getStatus()); - } - - RpcResult rpcResult = - RpcResultBuilder. status(true).withResult(oBuilder.build()).build(); - // return error - return Futures.immediateFuture(rpcResult); - } - - @Override - public ListenableFuture> configure(ConfigureInput input) { - ConfigureInputBuilder iBuilder = new ConfigureInputBuilder(input); - ConfigureOutputBuilder oBuilder = new ConfigureOutputBuilder(); - - try { - CommonLcmFields retval = callDG("configure", iBuilder.build()); - oBuilder.setStatus(retval.getStatusBuilder().build()); - oBuilder.setCommonHeader(retval.getCommonHeaderBuilder().build()); - } catch (LcmRpcInvocationException e) { - LOG.debug(exceptionMessage, e); - oBuilder.setCommonHeader(e.getCommonHeader()); - oBuilder.setStatus(e.getStatus()); - } - - RpcResult rpcResult = - RpcResultBuilder. status(true).withResult(oBuilder.build()).build(); - // return error - return Futures.immediateFuture(rpcResult); - } - - @Override - public ListenableFuture> actionStatus(ActionStatusInput input) { - ActionStatusInputBuilder iBuilder = new ActionStatusInputBuilder(input); - ActionStatusOutputBuilder oBuilder = new ActionStatusOutputBuilder(); - - try { - CommonLcmFields retval = callDG("action-status", iBuilder.build()); - oBuilder.setStatus(retval.getStatusBuilder().build()); - oBuilder.setCommonHeader(retval.getCommonHeaderBuilder().build()); - } catch (LcmRpcInvocationException e) { - LOG.debug(exceptionMessage, e); - oBuilder.setCommonHeader(e.getCommonHeader()); - oBuilder.setStatus(e.getStatus()); - } - - RpcResult rpcResult = - RpcResultBuilder. status(true).withResult(oBuilder.build()).build(); - // return error - return Futures.immediateFuture(rpcResult); - } - - @Override - public ListenableFuture> upgradePreCheck(UpgradePreCheckInput input) { - UpgradePreCheckInputBuilder iBuilder = new UpgradePreCheckInputBuilder(input); - UpgradePreCheckOutputBuilder oBuilder = new UpgradePreCheckOutputBuilder(); - - try { - CommonLcmFields retval = callDG("upgrade-pre-check", iBuilder.build()); - oBuilder.setStatus(retval.getStatusBuilder().build()); - oBuilder.setCommonHeader(retval.getCommonHeaderBuilder().build()); - if (retval.getPayload() != null) { - oBuilder.setPayload(retval.getPayload()); - } - } catch (LcmRpcInvocationException e) { - LOG.debug(exceptionMessage, e); - oBuilder.setCommonHeader(e.getCommonHeader()); - oBuilder.setStatus(e.getStatus()); - } - - RpcResult rpcResult = - RpcResultBuilder. status(true).withResult(oBuilder.build()).build(); - // return error - return Futures.immediateFuture(rpcResult); - } - - @Override - public ListenableFuture> liveUpgrade(LiveUpgradeInput input) { - LiveUpgradeInputBuilder iBuilder = new LiveUpgradeInputBuilder(input); - LiveUpgradeOutputBuilder oBuilder = new LiveUpgradeOutputBuilder(); - - try { - CommonLcmFields retval = callDG("live-upgrade", iBuilder.build()); - oBuilder.setStatus(retval.getStatusBuilder().build()); - oBuilder.setCommonHeader(retval.getCommonHeaderBuilder().build()); - } catch (LcmRpcInvocationException e) { - LOG.debug(exceptionMessage, e); - oBuilder.setCommonHeader(e.getCommonHeader()); - oBuilder.setStatus(e.getStatus()); - } - - RpcResult rpcResult = - RpcResultBuilder. status(true).withResult(oBuilder.build()).build(); - // return error - return Futures.immediateFuture(rpcResult); - } - - @Override - public ListenableFuture> configModify(ConfigModifyInput input) { - ConfigModifyInputBuilder iBuilder = new ConfigModifyInputBuilder(input); - ConfigModifyOutputBuilder oBuilder = new ConfigModifyOutputBuilder(); - - try { - CommonLcmFields retval = callDG("config-modify", iBuilder.build()); - oBuilder.setStatus(retval.getStatusBuilder().build()); - oBuilder.setCommonHeader(retval.getCommonHeaderBuilder().build()); - } catch (LcmRpcInvocationException e) { - LOG.debug(exceptionMessage, e); - oBuilder.setCommonHeader(e.getCommonHeader()); - oBuilder.setStatus(e.getStatus()); - } - - RpcResult rpcResult = - RpcResultBuilder. status(true).withResult(oBuilder.build()).build(); - // return error - return Futures.immediateFuture(rpcResult); - } - - @Override - public ListenableFuture> restart(RestartInput input) { - RestartInputBuilder iBuilder = new RestartInputBuilder(input); - RestartOutputBuilder oBuilder = new RestartOutputBuilder(); - - try { - CommonLcmFields retval = callDG("restart", iBuilder.build()); - oBuilder.setStatus(retval.getStatusBuilder().build()); - oBuilder.setCommonHeader(retval.getCommonHeaderBuilder().build()); - } catch (LcmRpcInvocationException e) { - LOG.debug(exceptionMessage, e); - oBuilder.setCommonHeader(e.getCommonHeader()); - oBuilder.setStatus(e.getStatus()); - } - - RpcResult rpcResult = - RpcResultBuilder. status(true).withResult(oBuilder.build()).build(); - // return error - return Futures.immediateFuture(rpcResult); - } - - @Override - public ListenableFuture> healthCheck(HealthCheckInput input) { - HealthCheckInputBuilder iBuilder = new HealthCheckInputBuilder(input); - HealthCheckOutputBuilder oBuilder = new HealthCheckOutputBuilder(); - - try { - CommonLcmFields retval = callDG("health-check", iBuilder.build()); - oBuilder.setStatus(retval.getStatusBuilder().build()); - oBuilder.setCommonHeader(retval.getCommonHeaderBuilder().build()); - } catch (LcmRpcInvocationException e) { - LOG.debug(exceptionMessage, e); - oBuilder.setCommonHeader(e.getCommonHeader()); - oBuilder.setStatus(e.getStatus()); - } - - RpcResult rpcResult = - RpcResultBuilder. status(true).withResult(oBuilder.build()).build(); - // return error - return Futures.immediateFuture(rpcResult); - } - - @Override - public ListenableFuture> lock(LockInput input) { - LockInputBuilder iBuilder = new LockInputBuilder(input); - LockOutputBuilder oBuilder = new LockOutputBuilder(); - - try { - CommonLcmFields retval = callDG("lock", iBuilder.build()); - oBuilder.setStatus(retval.getStatusBuilder().build()); - oBuilder.setCommonHeader(retval.getCommonHeaderBuilder().build()); - } catch (LcmRpcInvocationException e) { - LOG.debug(exceptionMessage, e); - oBuilder.setCommonHeader(e.getCommonHeader()); - oBuilder.setStatus(e.getStatus()); - } - - RpcResult rpcResult = - RpcResultBuilder. status(true).withResult(oBuilder.build()).build(); - // return error - return Futures.immediateFuture(rpcResult); - } - - @Override - public ListenableFuture> terminate(TerminateInput input) { - TerminateInputBuilder iBuilder = new TerminateInputBuilder(input); - TerminateOutputBuilder oBuilder = new TerminateOutputBuilder(); - - try { - CommonLcmFields retval = callDG("terminate", iBuilder.build()); - oBuilder.setStatus(retval.getStatusBuilder().build()); - oBuilder.setCommonHeader(retval.getCommonHeaderBuilder().build()); - } catch (LcmRpcInvocationException e) { - LOG.debug(exceptionMessage, e); - oBuilder.setCommonHeader(e.getCommonHeader()); - oBuilder.setStatus(e.getStatus()); - } - - RpcResult rpcResult = - RpcResultBuilder. status(true).withResult(oBuilder.build()).build(); - // return error - return Futures.immediateFuture(rpcResult); - } - - @Override - public ListenableFuture> attachVolume(AttachVolumeInput input) { - AttachVolumeInputBuilder iBuilder = new AttachVolumeInputBuilder(input); - AttachVolumeOutputBuilder oBuilder = new AttachVolumeOutputBuilder(); - - try { - CommonLcmFields retval = callDG("attach-volume", iBuilder.build()); - oBuilder.setStatus(retval.getStatusBuilder().build()); - oBuilder.setCommonHeader(retval.getCommonHeaderBuilder().build()); - } catch (LcmRpcInvocationException e) { - LOG.debug(exceptionMessage, e); - oBuilder.setCommonHeader(e.getCommonHeader()); - oBuilder.setStatus(e.getStatus()); - } - - RpcResult rpcResult = - RpcResultBuilder. status(true).withResult(oBuilder.build()).build(); - // return error - return Futures.immediateFuture(rpcResult); - } - - @Override - public ListenableFuture> migrate(MigrateInput input) { - MigrateInputBuilder iBuilder = new MigrateInputBuilder(input); - MigrateOutputBuilder oBuilder = new MigrateOutputBuilder(); - - try { - CommonLcmFields retval = callDG("migrate", iBuilder.build()); - oBuilder.setStatus(retval.getStatusBuilder().build()); - oBuilder.setCommonHeader(retval.getCommonHeaderBuilder().build()); - } catch (LcmRpcInvocationException e) { - LOG.debug(exceptionMessage, e); - oBuilder.setCommonHeader(e.getCommonHeader()); - oBuilder.setStatus(e.getStatus()); - } - - RpcResult rpcResult = - RpcResultBuilder. status(true).withResult(oBuilder.build()).build(); - // return error - return Futures.immediateFuture(rpcResult); - } - - @Override - public ListenableFuture> quiesceTraffic(QuiesceTrafficInput input) { - QuiesceTrafficInputBuilder iBuilder = new QuiesceTrafficInputBuilder(input); - QuiesceTrafficOutputBuilder oBuilder = new QuiesceTrafficOutputBuilder(); - - try { - CommonLcmFields retval = callDG("quiesce-traffic", iBuilder.build()); - oBuilder.setStatus(retval.getStatusBuilder().build()); - oBuilder.setCommonHeader(retval.getCommonHeaderBuilder().build()); - } catch (LcmRpcInvocationException e) { - LOG.debug(exceptionMessage, e); - oBuilder.setCommonHeader(e.getCommonHeader()); - oBuilder.setStatus(e.getStatus()); - } - - RpcResult rpcResult = - RpcResultBuilder. status(true).withResult(oBuilder.build()).build(); - // return error - return Futures.immediateFuture(rpcResult); - } - - @Override - public ListenableFuture> configRestore(ConfigRestoreInput input) { - ConfigRestoreInputBuilder iBuilder = new ConfigRestoreInputBuilder(input); - ConfigRestoreOutputBuilder oBuilder = new ConfigRestoreOutputBuilder(); - - try { - CommonLcmFields retval = callDG("config-restore", iBuilder.build()); - oBuilder.setStatus(retval.getStatusBuilder().build()); - oBuilder.setCommonHeader(retval.getCommonHeaderBuilder().build()); - } catch (LcmRpcInvocationException e) { - LOG.debug(exceptionMessage, e); - oBuilder.setCommonHeader(e.getCommonHeader()); - oBuilder.setStatus(e.getStatus()); - } - - RpcResult rpcResult = - RpcResultBuilder. status(true).withResult(oBuilder.build()).build(); - // return error - return Futures.immediateFuture(rpcResult); - } - - @Override - public ListenableFuture> upgradeBackout(UpgradeBackoutInput input) { - UpgradeBackoutInputBuilder iBuilder = new UpgradeBackoutInputBuilder(input); - UpgradeBackoutOutputBuilder oBuilder = new UpgradeBackoutOutputBuilder(); - - try { - CommonLcmFields retval = callDG("upgrade-backout", iBuilder.build()); - oBuilder.setStatus(retval.getStatusBuilder().build()); - oBuilder.setCommonHeader(retval.getCommonHeaderBuilder().build()); - } catch (LcmRpcInvocationException e) { - LOG.debug(exceptionMessage, e); - oBuilder.setCommonHeader(e.getCommonHeader()); - oBuilder.setStatus(e.getStatus()); - } - - RpcResult rpcResult = - RpcResultBuilder. status(true).withResult(oBuilder.build()).build(); - // return error - return Futures.immediateFuture(rpcResult); - } - - @Override - public ListenableFuture> evacuate(EvacuateInput input) { - EvacuateInputBuilder iBuilder = new EvacuateInputBuilder(input); - EvacuateOutputBuilder oBuilder = new EvacuateOutputBuilder(); - - try { - CommonLcmFields retval = callDG("evacuate", iBuilder.build()); - oBuilder.setStatus(retval.getStatusBuilder().build()); - oBuilder.setCommonHeader(retval.getCommonHeaderBuilder().build()); - } catch (LcmRpcInvocationException e) { - LOG.debug(exceptionMessage, e); - oBuilder.setCommonHeader(e.getCommonHeader()); - oBuilder.setStatus(e.getStatus()); - } - - RpcResult rpcResult = - RpcResultBuilder. status(true).withResult(oBuilder.build()).build(); - // return error - return Futures.immediateFuture(rpcResult); - } - - @Override - public ListenableFuture> unlock(UnlockInput input) { - UnlockInputBuilder iBuilder = new UnlockInputBuilder(input); - UnlockOutputBuilder oBuilder = new UnlockOutputBuilder(); - - try { - CommonLcmFields retval = callDG("unlock", iBuilder.build()); - oBuilder.setStatus(retval.getStatusBuilder().build()); - oBuilder.setCommonHeader(retval.getCommonHeaderBuilder().build()); - } catch (LcmRpcInvocationException e) { - LOG.debug(exceptionMessage, e); - oBuilder.setCommonHeader(e.getCommonHeader()); - oBuilder.setStatus(e.getStatus()); - } - - RpcResult rpcResult = - RpcResultBuilder. status(true).withResult(oBuilder.build()).build(); - // return error - return Futures.immediateFuture(rpcResult); - } - - @Override - public ListenableFuture> configBackupDelete(ConfigBackupDeleteInput input) { - ConfigBackupDeleteInputBuilder iBuilder = new ConfigBackupDeleteInputBuilder(input); - ConfigBackupDeleteOutputBuilder oBuilder = new ConfigBackupDeleteOutputBuilder(); - - try { - CommonLcmFields retval = callDG("config-backup-delete", iBuilder.build()); - oBuilder.setStatus(retval.getStatusBuilder().build()); - oBuilder.setCommonHeader(retval.getCommonHeaderBuilder().build()); - } catch (LcmRpcInvocationException e) { - LOG.debug(exceptionMessage, e); - oBuilder.setCommonHeader(e.getCommonHeader()); - oBuilder.setStatus(e.getStatus()); - } - - RpcResult rpcResult = - RpcResultBuilder. status(true).withResult(oBuilder.build()).build(); - // return error - return Futures.immediateFuture(rpcResult); - } - - @Override - public ListenableFuture> upgradeSoftware(UpgradeSoftwareInput input) { - UpgradeSoftwareInputBuilder iBuilder = new UpgradeSoftwareInputBuilder(input); - UpgradeSoftwareOutputBuilder oBuilder = new UpgradeSoftwareOutputBuilder(); - - try { - CommonLcmFields retval = callDG("upgrade-software", iBuilder.build()); - oBuilder.setStatus(retval.getStatusBuilder().build()); - oBuilder.setCommonHeader(retval.getCommonHeaderBuilder().build()); - } catch (LcmRpcInvocationException e) { - LOG.debug(exceptionMessage, e); - oBuilder.setCommonHeader(e.getCommonHeader()); - oBuilder.setStatus(e.getStatus()); - } - - RpcResult rpcResult = - RpcResultBuilder. status(true).withResult(oBuilder.build()).build(); - // return error - return Futures.immediateFuture(rpcResult); - } - - @Override - public ListenableFuture> downloadNESw(DownloadNESwInput input) { - DownloadNESwInputBuilder iBuilder = new DownloadNESwInputBuilder(input); - DownloadNESwOutputBuilder oBuilder = new DownloadNESwOutputBuilder(); - - try { - CommonLcmFields retval = callDG("download-n-e-sw", iBuilder.build()); - oBuilder.setStatus(retval.getStatusBuilder().build()); - oBuilder.setCommonHeader(retval.getCommonHeaderBuilder().build()); - if (retval.getPayload() != null) { - oBuilder.setPayload(retval.getPayload()); - } - } catch (LcmRpcInvocationException e) { - LOG.debug(exceptionMessage, e); - oBuilder.setCommonHeader(e.getCommonHeader()); - oBuilder.setStatus(e.getStatus()); - } - - RpcResult rpcResult = - RpcResultBuilder. status(true).withResult(oBuilder.build()).build(); - // return error - return Futures.immediateFuture(rpcResult); - } - - @Override - public ListenableFuture> activateNESw(ActivateNESwInput input) { - ActivateNESwInputBuilder iBuilder = new ActivateNESwInputBuilder(input); - ActivateNESwOutputBuilder oBuilder = new ActivateNESwOutputBuilder(); - - try { - CommonLcmFields retval = callDG("activate-n-e-sw", iBuilder.build()); - oBuilder.setStatus(retval.getStatusBuilder().build()); - oBuilder.setCommonHeader(retval.getCommonHeaderBuilder().build()); - if (retval.getPayload() != null) { - oBuilder.setPayload(retval.getPayload()); - } - } catch (LcmRpcInvocationException e) { - LOG.debug(exceptionMessage, e); - oBuilder.setCommonHeader(e.getCommonHeader()); - oBuilder.setStatus(e.getStatus()); - } - - RpcResult rpcResult = - RpcResultBuilder. status(true).withResult(oBuilder.build()).build(); - // return error - return Futures.immediateFuture(rpcResult); - } - - @Override - public ListenableFuture> stop(StopInput input) { - StopInputBuilder iBuilder = new StopInputBuilder(input); - StopOutputBuilder oBuilder = new StopOutputBuilder(); - - try { - CommonLcmFields retval = callDG("stop", iBuilder.build()); - oBuilder.setStatus(retval.getStatusBuilder().build()); - oBuilder.setCommonHeader(retval.getCommonHeaderBuilder().build()); - } catch (LcmRpcInvocationException e) { - LOG.debug(exceptionMessage, e); - oBuilder.setCommonHeader(e.getCommonHeader()); - oBuilder.setStatus(e.getStatus()); - } - - RpcResult rpcResult = - RpcResultBuilder. status(true).withResult(oBuilder.build()).build(); - // return error - return Futures.immediateFuture(rpcResult); - } - - @Override - public ListenableFuture> detachVolume(DetachVolumeInput input) { - DetachVolumeInputBuilder iBuilder = new DetachVolumeInputBuilder(input); - DetachVolumeOutputBuilder oBuilder = new DetachVolumeOutputBuilder(); - - try { - CommonLcmFields retval = callDG("detach-volume", iBuilder.build()); - oBuilder.setStatus(retval.getStatusBuilder().build()); - oBuilder.setCommonHeader(retval.getCommonHeaderBuilder().build()); - } catch (LcmRpcInvocationException e) { - LOG.debug(exceptionMessage, e); - oBuilder.setCommonHeader(e.getCommonHeader()); - oBuilder.setStatus(e.getStatus()); - } - - RpcResult rpcResult = - RpcResultBuilder. status(true).withResult(oBuilder.build()).build(); - // return error - return Futures.immediateFuture(rpcResult); - } - - @Override - public ListenableFuture> configScaleOut(ConfigScaleOutInput input) { - ConfigScaleOutInputBuilder iBuilder = new ConfigScaleOutInputBuilder(input); - ConfigScaleOutOutputBuilder oBuilder = new ConfigScaleOutOutputBuilder(); - - try { - CommonLcmFields retval = callDG("config-scale-out", iBuilder.build()); - oBuilder.setStatus(retval.getStatusBuilder().build()); - oBuilder.setCommonHeader(retval.getCommonHeaderBuilder().build()); - } catch (LcmRpcInvocationException e) { - LOG.debug(exceptionMessage, e); - oBuilder.setCommonHeader(e.getCommonHeader()); - oBuilder.setStatus(e.getStatus()); - } - - RpcResult rpcResult = - RpcResultBuilder. status(true).withResult(oBuilder.build()).build(); - // return error - return Futures.immediateFuture(rpcResult); - } - - @Override - public ListenableFuture> upgradePostCheck(UpgradePostCheckInput input) { - UpgradePostCheckInputBuilder iBuilder = new UpgradePostCheckInputBuilder(input); - UpgradePostCheckOutputBuilder oBuilder = new UpgradePostCheckOutputBuilder(); - - try { - CommonLcmFields retval = callDG("upgrade-post-check", iBuilder.build()); - oBuilder.setStatus(retval.getStatusBuilder().build()); - oBuilder.setCommonHeader(retval.getCommonHeaderBuilder().build()); - if (retval.getPayload() != null) { - oBuilder.setPayload(retval.getPayload()); - } - } catch (LcmRpcInvocationException e) { - LOG.debug(exceptionMessage, e); - oBuilder.setCommonHeader(e.getCommonHeader()); - oBuilder.setStatus(e.getStatus()); - } - - RpcResult rpcResult = - RpcResultBuilder. status(true).withResult(oBuilder.build()).build(); - // return error - return Futures.immediateFuture(rpcResult); - } - - @Override - public ListenableFuture> test(TestInput input) { - TestInputBuilder iBuilder = new TestInputBuilder(input); - TestOutputBuilder oBuilder = new TestOutputBuilder(); - - try { - CommonLcmFields retval = callDG("test", iBuilder.build()); - oBuilder.setStatus(retval.getStatusBuilder().build()); - oBuilder.setCommonHeader(retval.getCommonHeaderBuilder().build()); - } catch (LcmRpcInvocationException e) { - LOG.debug(exceptionMessage, e); - oBuilder.setCommonHeader(e.getCommonHeader()); - oBuilder.setStatus(e.getStatus()); - } - - RpcResult rpcResult = - RpcResultBuilder. status(true).withResult(oBuilder.build()).build(); - // return error - return Futures.immediateFuture(rpcResult); - } - - @Override - public ListenableFuture> startApplication(StartApplicationInput input) { - StartApplicationInputBuilder iBuilder = new StartApplicationInputBuilder(input); - StartApplicationOutputBuilder oBuilder = new StartApplicationOutputBuilder(); - - try { - CommonLcmFields retval = callDG("start-application", iBuilder.build()); - oBuilder.setStatus(retval.getStatusBuilder().build()); - oBuilder.setCommonHeader(retval.getCommonHeaderBuilder().build()); - } catch (LcmRpcInvocationException e) { - LOG.debug(exceptionMessage, e); - oBuilder.setCommonHeader(e.getCommonHeader()); - oBuilder.setStatus(e.getStatus()); - } - - RpcResult rpcResult = - RpcResultBuilder. status(true).withResult(oBuilder.build()).build(); - // return error - return Futures.immediateFuture(rpcResult); - } - - @Override - public ListenableFuture> configBackup(ConfigBackupInput input) { - ConfigBackupInputBuilder iBuilder = new ConfigBackupInputBuilder(input); - ConfigBackupOutputBuilder oBuilder = new ConfigBackupOutputBuilder(); - - try { - CommonLcmFields retval = callDG("config-backup", iBuilder.build()); - oBuilder.setStatus(retval.getStatusBuilder().build()); - oBuilder.setCommonHeader(retval.getCommonHeaderBuilder().build()); - } catch (LcmRpcInvocationException e) { - LOG.debug(exceptionMessage, e); - oBuilder.setCommonHeader(e.getCommonHeader()); - oBuilder.setStatus(e.getStatus()); - } - - RpcResult rpcResult = - RpcResultBuilder. status(true).withResult(oBuilder.build()).build(); - // return error - return Futures.immediateFuture(rpcResult); - } - - @Override - public ListenableFuture> rebuild(RebuildInput input) { - RebuildInputBuilder iBuilder = new RebuildInputBuilder(input); - RebuildOutputBuilder oBuilder = new RebuildOutputBuilder(); - - try { - CommonLcmFields retval = callDG("rebuild", iBuilder.build()); - oBuilder.setStatus(retval.getStatusBuilder().build()); - oBuilder.setCommonHeader(retval.getCommonHeaderBuilder().build()); - } catch (LcmRpcInvocationException e) { - LOG.debug(exceptionMessage, e); - oBuilder.setCommonHeader(e.getCommonHeader()); - oBuilder.setStatus(e.getStatus()); - } - - RpcResult rpcResult = - RpcResultBuilder. status(true).withResult(oBuilder.build()).build(); - // return error - return Futures.immediateFuture(rpcResult); - } - - @Override - public ListenableFuture> audit(AuditInput input) { - AuditInputBuilder iBuilder = new AuditInputBuilder(input); - AuditOutputBuilder oBuilder = new AuditOutputBuilder(); - - try { - CommonLcmFields retval = callDG("audit", iBuilder.build()); - oBuilder.setStatus(retval.getStatusBuilder().build()); - oBuilder.setCommonHeader(retval.getCommonHeaderBuilder().build()); - } catch (LcmRpcInvocationException e) { - LOG.debug(exceptionMessage, e); - oBuilder.setCommonHeader(e.getCommonHeader()); - oBuilder.setStatus(e.getStatus()); - } - - RpcResult rpcResult = - RpcResultBuilder. status(true).withResult(oBuilder.build()).build(); - // return error - return Futures.immediateFuture(rpcResult); - } - - @Override - public ListenableFuture> start(StartInput input) { - StartInputBuilder iBuilder = new StartInputBuilder(input); - StartOutputBuilder oBuilder = new StartOutputBuilder(); - - try { - CommonLcmFields retval = callDG("start", iBuilder.build()); - oBuilder.setStatus(retval.getStatusBuilder().build()); - oBuilder.setCommonHeader(retval.getCommonHeaderBuilder().build()); - } catch (LcmRpcInvocationException e) { - LOG.debug(exceptionMessage, e); - oBuilder.setCommonHeader(e.getCommonHeader()); - oBuilder.setStatus(e.getStatus()); - } - - RpcResult rpcResult = - RpcResultBuilder. status(true).withResult(oBuilder.build()).build(); - // return error - return Futures.immediateFuture(rpcResult); - } - - @Override - public ListenableFuture> snapshot(SnapshotInput input) { - SnapshotInputBuilder iBuilder = new SnapshotInputBuilder(input); - SnapshotOutputBuilder oBuilder = new SnapshotOutputBuilder(); - - try { - CommonLcmFields retval = callDG("snapshot", iBuilder.build()); - oBuilder.setStatus(retval.getStatusBuilder().build()); - oBuilder.setCommonHeader(retval.getCommonHeaderBuilder().build()); - } catch (LcmRpcInvocationException e) { - LOG.debug(exceptionMessage, e); - oBuilder.setCommonHeader(e.getCommonHeader()); - oBuilder.setStatus(e.getStatus()); - } - - RpcResult rpcResult = - RpcResultBuilder. status(true).withResult(oBuilder.build()).build(); - // return error - return Futures.immediateFuture(rpcResult); - } - - private CommonLcmFields callDG(String rpcName, Object input) throws LcmRpcInvocationException { - - StatusBuilder statusBuilder = new StatusBuilder(); - - if (input == null) { - LOG.debug("Rejecting " +rpcName+ " because of invalid input"); - statusBuilder.setCode(LcmResponseCode.REJECT_INVALID_INPUT.getValue()); - statusBuilder.setMessage("REJECT - INVALID INPUT. Missing input"); - CommonHeaderBuilder hBuilder = new CommonHeaderBuilder(); - hBuilder.setApiVer("1"); - hBuilder.setOriginatorId("unknown"); - hBuilder.setRequestId("unset"); - hBuilder.setTimestamp(new ZULU(new SimpleDateFormat("yyyy-MM-dd'T'HH:mm:ss.SSS'Z'").format(new Date()))); - throw new LcmRpcInvocationException(statusBuilder.build(), hBuilder.build()); - } - - CommonHeaderBuilder hBuilder = new CommonHeaderBuilder(((CommonHeader)input).getCommonHeader()); - - // add input to parms - LOG.info("Adding INPUT data for "+ rpcName +" input: " + input.toString()); - Properties inputProps = new Properties(); - MdsalHelper.toProperties(inputProps, input); - - Properties respProps = new Properties(); - - // Call SLI sync method - try - { - if (lcmSliClient.hasGraph("LCM", rpcName , null, "sync")) - { - try - { - respProps = lcmSliClient.execute("LCM", rpcName, null, "sync", inputProps, domDataBroker); - } - catch (Exception e) - { - LOG.error("Caught exception executing service logic for "+ rpcName, e); - statusBuilder.setCode(LcmResponseCode.FAILURE_DG_FAILURE.getValue()); - statusBuilder.setMessage("FAILURE - DG FAILURE ("+e.getMessage()+")"); - throw new LcmRpcInvocationException(statusBuilder.build(), hBuilder.build()); - } - } else { - LOG.error("No service logic active for LCM: '" + rpcName + "'"); - - statusBuilder.setCode(LcmResponseCode.REJECT_DG_NOT_FOUND.getValue()); - statusBuilder.setMessage("FAILURE - DG not found for action "+rpcName); - throw new LcmRpcInvocationException(statusBuilder.build(), hBuilder.build()); - } - } - catch (Exception e) - { - LOG.error("Caught exception looking for service logic", e); - - statusBuilder.setCode(LcmResponseCode.FAILURE_DG_FAILURE.getValue()); - statusBuilder.setMessage("FAILURE - Unexpected error looking for DG ("+e.getMessage()+")"); - throw new LcmRpcInvocationException(statusBuilder.build(), hBuilder.build()); - } - - - StatusBuilder sBuilder = new StatusBuilder(); - MdsalHelper.toBuilder(respProps, sBuilder); - MdsalHelper.toBuilder(respProps, hBuilder); - - Payload payload = null; - String payloadValue = respProps.getProperty("payload"); - if (payloadValue != null) { - payload = new Payload(payloadValue); - } - - String statusCode = sBuilder.getCode().toString(); - - if (!"400".equals(statusCode)) { - LOG.error("Returned FAILED for "+rpcName+" error code: '" + statusCode + "'"); - } else { - LOG.info("Returned SUCCESS for "+rpcName+" "); - } - - return new CommonLcmFields(sBuilder, hBuilder, payload); - - } - -} diff --git a/lcm/provider/src/main/java/org/onap/ccsdk/sli/northbound/LcmResponseCode.java b/lcm/provider/src/main/java/org/onap/ccsdk/sli/northbound/LcmResponseCode.java deleted file mode 100644 index 76001c860..000000000 --- a/lcm/provider/src/main/java/org/onap/ccsdk/sli/northbound/LcmResponseCode.java +++ /dev/null @@ -1,51 +0,0 @@ -package org.onap.ccsdk.sli.northbound; - -public enum LcmResponseCode { - - // Accepted category - ACCEPT_ACCEPTED(100), - // Error category - ERROR_UNEXPECTED_ERROR(200), - // Rejected category - REJECT_REJECTED(300), - REJECT_INVALID_INPUT(301), - REJECT_MISSING_PARAM(302), - REJECT_PARSING_FAILED(303), - REJECT_NO_TRANSITION(304), - REJECT_ACTION_NOT_SUPPORTED(305), - REJECT_VNF_NOT_FOUND(306), - REJECT_DG_NOT_FOUND(307), - REJECT_WORKFLOW_NOT_FOUND(308), - REJECT_UNSTABLE_VNF(309), - REJECT_LOCKING_FAILURE(310), - REJECT_EXPIRED_REQUEST(311), - REJECT_DUPLICATE_REQUEST(312), - REJECT_MISSING_AAI_DATA(313), - REJECT_MULTIPLE_REQUESTS_FOR_SEARCH(315), - REJECT_POLICY_VALIDATION_FAILURE(316), - // Success category - SUCCESS(400), - // Failure category - FAILURE_DG_FAILURE(401), - FAILURE_NO_TRANSITION(402), - FAILURE_AAI_FAILURE(403), - FAILURE_EXPIRED_REQUEST(404), - FAILURE_UNEXPECTED_FAILURE(405), - FAILURE_UNSTABLE_VNF(406), - FAILURE_REQUEST_NOT_SUPPORTED(450), - // Partial success - PARTIAL_SUCCESS(500); - - - - private int value; - private LcmResponseCode(int value) { - this.value = value; - } - - public int getValue() { - return value; - } - - -} diff --git a/lcm/provider/src/main/java/org/onap/ccsdk/sli/northbound/LcmRpcInvocationException.java b/lcm/provider/src/main/java/org/onap/ccsdk/sli/northbound/LcmRpcInvocationException.java deleted file mode 100644 index 2ae2200a8..000000000 --- a/lcm/provider/src/main/java/org/onap/ccsdk/sli/northbound/LcmRpcInvocationException.java +++ /dev/null @@ -1,25 +0,0 @@ -package org.onap.ccsdk.sli.northbound; - -import org.onap.ccsdk.sli.core.sli.SvcLogicException; -import org.opendaylight.yang.gen.v1.org.onap.ccsdk.sli.northbound.lcm.rev180329.common.header.CommonHeader; -import org.opendaylight.yang.gen.v1.org.onap.ccsdk.sli.northbound.lcm.rev180329.status.Status; - -public class LcmRpcInvocationException extends SvcLogicException { - - private Status status; - private CommonHeader commonHeader; - - public LcmRpcInvocationException(Status status, CommonHeader commonHeader) { - this.status = status; - this.commonHeader = commonHeader; - } - - public Status getStatus() { - return status; - } - - public CommonHeader getCommonHeader() { - return commonHeader; - } - -} diff --git a/lcm/provider/src/main/java/org/onap/ccsdk/sli/northbound/LcmSliClient.java b/lcm/provider/src/main/java/org/onap/ccsdk/sli/northbound/LcmSliClient.java deleted file mode 100644 index 54e53c776..000000000 --- a/lcm/provider/src/main/java/org/onap/ccsdk/sli/northbound/LcmSliClient.java +++ /dev/null @@ -1,99 +0,0 @@ -package org.onap.ccsdk.sli.northbound; -/*- - * ============LICENSE_START======================================================= - * openECOMP : SDN-C - * ================================================================================ - * Copyright (C) 2017 AT&T Intellectual Property. All rights - * reserved. - * Modifications Copyright © 2018 IBM. - * ================================================================================ - * 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========================================================= - */ - - - -import java.util.Properties; - -import org.onap.ccsdk.sli.core.sli.SvcLogicException; -import org.onap.ccsdk.sli.core.sli.provider.SvcLogicService; -import org.opendaylight.controller.md.sal.dom.api.DOMDataBroker; -import org.slf4j.Logger; -import org.slf4j.LoggerFactory; - -public class LcmSliClient { - - private static final Logger LOG = LoggerFactory.getLogger(LcmSliClient.class); - - private final SvcLogicService svcLogicService; - - private String ErrorCode = "error-code"; - - public LcmSliClient(final SvcLogicService svcLogicService) { - this.svcLogicService = svcLogicService; - } - - public boolean hasGraph(String module, String rpc, String version, String mode) throws SvcLogicException - { - return svcLogicService.hasGraph(module, rpc, version, mode); - } - - - public Properties execute(String module, String rpc, String version, String mode, Properties parms, DOMDataBroker dataBroker) - throws SvcLogicException { - - - if (LOG.isDebugEnabled()) - { - LOG.debug("Parameters passed to SLI"); - - for (Object key : parms.keySet()) { - String parmName = (String) key; - String parmValue = parms.getProperty(parmName); - - LOG.debug(parmName+" = "+parmValue); - - } - } - - Properties respProps = svcLogicService.execute(module, rpc, version, mode, parms, dataBroker); - - if (LOG.isDebugEnabled()) - { - LOG.debug("Parameters returned by SLI"); - - for (Object key : respProps.keySet()) { - String parmName = (String) key; - String parmValue = respProps.getProperty(parmName); - - LOG.debug(parmName+" = "+parmValue); - - } - } - - if ("failure".equalsIgnoreCase(respProps.getProperty("SvcLogic.status"))) { - - if (!respProps.containsKey(ErrorCode)) { - respProps.setProperty(ErrorCode, "500"); - } - } else { - if (!respProps.containsKey(ErrorCode)) { - respProps.setProperty(ErrorCode, "200"); - } - } - - - return respProps; - } - -} diff --git a/lcm/provider/src/main/resources/OSGI-INF/blueprint/lcm-blueprint.xml b/lcm/provider/src/main/resources/OSGI-INF/blueprint/lcm-blueprint.xml deleted file mode 100644 index 5597d0801..000000000 --- a/lcm/provider/src/main/resources/OSGI-INF/blueprint/lcm-blueprint.xml +++ /dev/null @@ -1,34 +0,0 @@ - - - - - - - - - - - - - - - - - - - - - - - - - \ No newline at end of file diff --git a/lcm/provider/src/main/resources/org/opendaylight/blueprint/lcm-blueprint.xml b/lcm/provider/src/main/resources/org/opendaylight/blueprint/lcm-blueprint.xml deleted file mode 100644 index 5597d0801..000000000 --- a/lcm/provider/src/main/resources/org/opendaylight/blueprint/lcm-blueprint.xml +++ /dev/null @@ -1,34 +0,0 @@ - - - - - - - - - - - - - - - - - - - - - - - - - \ No newline at end of file -- cgit 1.2.3-korg