summaryrefslogtreecommitdiffstats
path: root/lcm/provider/src/main
diff options
context:
space:
mode:
authorJessica Wagantall <jwagantall@linuxfoundation.org>2020-12-01 11:52:01 -0800
committerJessica Wagantall <jwagantall@linuxfoundation.org>2020-12-01 11:52:01 -0800
commitff3eecb980bfdc8d43d2ed3a4c786d634fa6f4e2 (patch)
tree680db1c4f69f5c181b8f1fb7d7d8f46942783b3e /lcm/provider/src/main
parent02b6c140f031c19cfcb791fd0142f03167db69b1 (diff)
Migrate sli-northbound repo
Migrate sli-northbound repo files into new directory "northbound". Signed-off-by: Jessica Wagantall <jwagantall@linuxfoundation.org>
Diffstat (limited to 'lcm/provider/src/main')
-rw-r--r--lcm/provider/src/main/java/org/onap/ccsdk/sli/northbound/LcmProvider.java1126
-rw-r--r--lcm/provider/src/main/java/org/onap/ccsdk/sli/northbound/LcmResponseCode.java51
-rw-r--r--lcm/provider/src/main/java/org/onap/ccsdk/sli/northbound/LcmRpcInvocationException.java25
-rw-r--r--lcm/provider/src/main/java/org/onap/ccsdk/sli/northbound/LcmSliClient.java99
-rw-r--r--lcm/provider/src/main/resources/OSGI-INF/blueprint/lcm-blueprint.xml34
-rw-r--r--lcm/provider/src/main/resources/org/opendaylight/blueprint/lcm-blueprint.xml34
6 files changed, 0 insertions, 1369 deletions
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<LCMService> 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<RpcResult<CheckLockOutput>> 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<CheckLockOutput> rpcResult =
- RpcResultBuilder.<CheckLockOutput> status(true).withResult(oBuilder.build()).build();
- // return error
- return Futures.immediateFuture(rpcResult);
-
- }
-
- @Override
- public ListenableFuture<RpcResult<RebootOutput>> 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<RebootOutput> rpcResult =
- RpcResultBuilder.<RebootOutput> status(true).withResult(oBuilder.build()).build();
- // return error
- return Futures.immediateFuture(rpcResult);
- }
-
- @Override
- public ListenableFuture<RpcResult<UpgradeBackupOutput>> 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<UpgradeBackupOutput> rpcResult =
- RpcResultBuilder.<UpgradeBackupOutput> status(true).withResult(oBuilder.build()).build();
- // return error
- return Futures.immediateFuture(rpcResult);
- }
-
- @Override
- public ListenableFuture<RpcResult<RollbackOutput>> 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<RollbackOutput> rpcResult =
- RpcResultBuilder.<RollbackOutput> status(true).withResult(oBuilder.build()).build();
- // return error
- return Futures.immediateFuture(rpcResult);
- }
-
- @Override
- public ListenableFuture<RpcResult<SyncOutput>> 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<SyncOutput> rpcResult =
- RpcResultBuilder.<SyncOutput> status(true).withResult(oBuilder.build()).build();
- // return error
- return Futures.immediateFuture(rpcResult);
- }
-
- @Override
- public ListenableFuture<RpcResult<QueryOutput>> 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<QueryOutput> rpcResult =
- RpcResultBuilder.<QueryOutput> status(true).withResult(oBuilder.build()).build();
- // return error
- return Futures.immediateFuture(rpcResult);
- }
-
- @Override
- public ListenableFuture<RpcResult<ConfigExportOutput>> 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<ConfigExportOutput> rpcResult =
- RpcResultBuilder.<ConfigExportOutput> status(true).withResult(oBuilder.build()).build();
- // return error
- return Futures.immediateFuture(rpcResult);
- }
-
- @Override
- public ListenableFuture<RpcResult<StopApplicationOutput>> 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<StopApplicationOutput> rpcResult =
- RpcResultBuilder.<StopApplicationOutput> status(true).withResult(oBuilder.build()).build();
- // return error
- return Futures.immediateFuture(rpcResult);
- }
-
- @Override
- public ListenableFuture<RpcResult<SoftwareUploadOutput>> 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<SoftwareUploadOutput> rpcResult =
- RpcResultBuilder.<SoftwareUploadOutput> status(true).withResult(oBuilder.build()).build();
- // return error
- return Futures.immediateFuture(rpcResult);
- }
-
- @Override
- public ListenableFuture<RpcResult<ResumeTrafficOutput>> 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<ResumeTrafficOutput> rpcResult =
- RpcResultBuilder.<ResumeTrafficOutput> status(true).withResult(oBuilder.build()).build();
- // return error
- return Futures.immediateFuture(rpcResult);
- }
-
- @Override
- public ListenableFuture<RpcResult<DistributeTrafficOutput>> 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<DistributeTrafficOutput> rpcResult =
- RpcResultBuilder.<DistributeTrafficOutput> status(true).withResult(oBuilder.build()).build();
- // return error
- return Futures.immediateFuture(rpcResult);
- }
-
- @Override
- public ListenableFuture<RpcResult<ConfigureOutput>> 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<ConfigureOutput> rpcResult =
- RpcResultBuilder.<ConfigureOutput> status(true).withResult(oBuilder.build()).build();
- // return error
- return Futures.immediateFuture(rpcResult);
- }
-
- @Override
- public ListenableFuture<RpcResult<ActionStatusOutput>> 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<ActionStatusOutput> rpcResult =
- RpcResultBuilder.<ActionStatusOutput> status(true).withResult(oBuilder.build()).build();
- // return error
- return Futures.immediateFuture(rpcResult);
- }
-
- @Override
- public ListenableFuture<RpcResult<UpgradePreCheckOutput>> 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<UpgradePreCheckOutput> rpcResult =
- RpcResultBuilder.<UpgradePreCheckOutput> status(true).withResult(oBuilder.build()).build();
- // return error
- return Futures.immediateFuture(rpcResult);
- }
-
- @Override
- public ListenableFuture<RpcResult<LiveUpgradeOutput>> 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<LiveUpgradeOutput> rpcResult =
- RpcResultBuilder.<LiveUpgradeOutput> status(true).withResult(oBuilder.build()).build();
- // return error
- return Futures.immediateFuture(rpcResult);
- }
-
- @Override
- public ListenableFuture<RpcResult<ConfigModifyOutput>> 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<ConfigModifyOutput> rpcResult =
- RpcResultBuilder.<ConfigModifyOutput> status(true).withResult(oBuilder.build()).build();
- // return error
- return Futures.immediateFuture(rpcResult);
- }
-
- @Override
- public ListenableFuture<RpcResult<RestartOutput>> 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<RestartOutput> rpcResult =
- RpcResultBuilder.<RestartOutput> status(true).withResult(oBuilder.build()).build();
- // return error
- return Futures.immediateFuture(rpcResult);
- }
-
- @Override
- public ListenableFuture<RpcResult<HealthCheckOutput>> 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<HealthCheckOutput> rpcResult =
- RpcResultBuilder.<HealthCheckOutput> status(true).withResult(oBuilder.build()).build();
- // return error
- return Futures.immediateFuture(rpcResult);
- }
-
- @Override
- public ListenableFuture<RpcResult<LockOutput>> 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<LockOutput> rpcResult =
- RpcResultBuilder.<LockOutput> status(true).withResult(oBuilder.build()).build();
- // return error
- return Futures.immediateFuture(rpcResult);
- }
-
- @Override
- public ListenableFuture<RpcResult<TerminateOutput>> 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<TerminateOutput> rpcResult =
- RpcResultBuilder.<TerminateOutput> status(true).withResult(oBuilder.build()).build();
- // return error
- return Futures.immediateFuture(rpcResult);
- }
-
- @Override
- public ListenableFuture<RpcResult<AttachVolumeOutput>> 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<AttachVolumeOutput> rpcResult =
- RpcResultBuilder.<AttachVolumeOutput> status(true).withResult(oBuilder.build()).build();
- // return error
- return Futures.immediateFuture(rpcResult);
- }
-
- @Override
- public ListenableFuture<RpcResult<MigrateOutput>> 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<MigrateOutput> rpcResult =
- RpcResultBuilder.<MigrateOutput> status(true).withResult(oBuilder.build()).build();
- // return error
- return Futures.immediateFuture(rpcResult);
- }
-
- @Override
- public ListenableFuture<RpcResult<QuiesceTrafficOutput>> 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<QuiesceTrafficOutput> rpcResult =
- RpcResultBuilder.<QuiesceTrafficOutput> status(true).withResult(oBuilder.build()).build();
- // return error
- return Futures.immediateFuture(rpcResult);
- }
-
- @Override
- public ListenableFuture<RpcResult<ConfigRestoreOutput>> 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<ConfigRestoreOutput> rpcResult =
- RpcResultBuilder.<ConfigRestoreOutput> status(true).withResult(oBuilder.build()).build();
- // return error
- return Futures.immediateFuture(rpcResult);
- }
-
- @Override
- public ListenableFuture<RpcResult<UpgradeBackoutOutput>> 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<UpgradeBackoutOutput> rpcResult =
- RpcResultBuilder.<UpgradeBackoutOutput> status(true).withResult(oBuilder.build()).build();
- // return error
- return Futures.immediateFuture(rpcResult);
- }
-
- @Override
- public ListenableFuture<RpcResult<EvacuateOutput>> 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<EvacuateOutput> rpcResult =
- RpcResultBuilder.<EvacuateOutput> status(true).withResult(oBuilder.build()).build();
- // return error
- return Futures.immediateFuture(rpcResult);
- }
-
- @Override
- public ListenableFuture<RpcResult<UnlockOutput>> 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<UnlockOutput> rpcResult =
- RpcResultBuilder.<UnlockOutput> status(true).withResult(oBuilder.build()).build();
- // return error
- return Futures.immediateFuture(rpcResult);
- }
-
- @Override
- public ListenableFuture<RpcResult<ConfigBackupDeleteOutput>> 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<ConfigBackupDeleteOutput> rpcResult =
- RpcResultBuilder.<ConfigBackupDeleteOutput> status(true).withResult(oBuilder.build()).build();
- // return error
- return Futures.immediateFuture(rpcResult);
- }
-
- @Override
- public ListenableFuture<RpcResult<UpgradeSoftwareOutput>> 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<UpgradeSoftwareOutput> rpcResult =
- RpcResultBuilder.<UpgradeSoftwareOutput> status(true).withResult(oBuilder.build()).build();
- // return error
- return Futures.immediateFuture(rpcResult);
- }
-
- @Override
- public ListenableFuture<RpcResult<DownloadNESwOutput>> 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<DownloadNESwOutput> rpcResult =
- RpcResultBuilder.<DownloadNESwOutput> status(true).withResult(oBuilder.build()).build();
- // return error
- return Futures.immediateFuture(rpcResult);
- }
-
- @Override
- public ListenableFuture<RpcResult<ActivateNESwOutput>> 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<ActivateNESwOutput> rpcResult =
- RpcResultBuilder.<ActivateNESwOutput> status(true).withResult(oBuilder.build()).build();
- // return error
- return Futures.immediateFuture(rpcResult);
- }
-
- @Override
- public ListenableFuture<RpcResult<StopOutput>> 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<StopOutput> rpcResult =
- RpcResultBuilder.<StopOutput> status(true).withResult(oBuilder.build()).build();
- // return error
- return Futures.immediateFuture(rpcResult);
- }
-
- @Override
- public ListenableFuture<RpcResult<DetachVolumeOutput>> 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<DetachVolumeOutput> rpcResult =
- RpcResultBuilder.<DetachVolumeOutput> status(true).withResult(oBuilder.build()).build();
- // return error
- return Futures.immediateFuture(rpcResult);
- }
-
- @Override
- public ListenableFuture<RpcResult<ConfigScaleOutOutput>> 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<ConfigScaleOutOutput> rpcResult =
- RpcResultBuilder.<ConfigScaleOutOutput> status(true).withResult(oBuilder.build()).build();
- // return error
- return Futures.immediateFuture(rpcResult);
- }
-
- @Override
- public ListenableFuture<RpcResult<UpgradePostCheckOutput>> 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<UpgradePostCheckOutput> rpcResult =
- RpcResultBuilder.<UpgradePostCheckOutput> status(true).withResult(oBuilder.build()).build();
- // return error
- return Futures.immediateFuture(rpcResult);
- }
-
- @Override
- public ListenableFuture<RpcResult<TestOutput>> 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<TestOutput> rpcResult =
- RpcResultBuilder.<TestOutput> status(true).withResult(oBuilder.build()).build();
- // return error
- return Futures.immediateFuture(rpcResult);
- }
-
- @Override
- public ListenableFuture<RpcResult<StartApplicationOutput>> 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<StartApplicationOutput> rpcResult =
- RpcResultBuilder.<StartApplicationOutput> status(true).withResult(oBuilder.build()).build();
- // return error
- return Futures.immediateFuture(rpcResult);
- }
-
- @Override
- public ListenableFuture<RpcResult<ConfigBackupOutput>> 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<ConfigBackupOutput> rpcResult =
- RpcResultBuilder.<ConfigBackupOutput> status(true).withResult(oBuilder.build()).build();
- // return error
- return Futures.immediateFuture(rpcResult);
- }
-
- @Override
- public ListenableFuture<RpcResult<RebuildOutput>> 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<RebuildOutput> rpcResult =
- RpcResultBuilder.<RebuildOutput> status(true).withResult(oBuilder.build()).build();
- // return error
- return Futures.immediateFuture(rpcResult);
- }
-
- @Override
- public ListenableFuture<RpcResult<AuditOutput>> 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<AuditOutput> rpcResult =
- RpcResultBuilder.<AuditOutput> status(true).withResult(oBuilder.build()).build();
- // return error
- return Futures.immediateFuture(rpcResult);
- }
-
- @Override
- public ListenableFuture<RpcResult<StartOutput>> 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<StartOutput> rpcResult =
- RpcResultBuilder.<StartOutput> status(true).withResult(oBuilder.build()).build();
- // return error
- return Futures.immediateFuture(rpcResult);
- }
-
- @Override
- public ListenableFuture<RpcResult<SnapshotOutput>> 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<SnapshotOutput> rpcResult =
- RpcResultBuilder.<SnapshotOutput> 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 @@
-<?xml version="1.0" encoding="UTF-8"?>
-<blueprint xmlns="http://www.osgi.org/xmlns/blueprint/v1.0.0"
- xmlns:odl="http://opendaylight.org/xmlns/blueprint/v1.0.0"
- odl:use-default-for-reference-types="true">
-
- <reference id="svcLogicService"
- interface="org.onap.ccsdk.sli.core.sli.provider.SvcLogicService" />
-
- <bean id="client" class="org.onap.ccsdk.sli.northbound.LcmSliClient">
- <argument ref="svcLogicService" />
- </bean>
-
- <reference id="dataBroker"
- interface="org.opendaylight.controller.md.sal.binding.api.DataBroker"
- odl:type="default" />
-
- <reference id="notificationService"
- interface="org.opendaylight.controller.md.sal.binding.api.NotificationPublishService"
- odl:type="default" />
-
- <reference id="rpcRegistry"
- interface="org.opendaylight.controller.sal.binding.api.RpcProviderRegistry"
- odl:type="default" />
-
- <bean id="provider" class="org.onap.ccsdk.sli.northbound.LcmProvider">
- <argument ref="dataBroker" />
- <argument ref="notificationService" />
- <argument ref="rpcRegistry" />
- <argument ref="client" />
- </bean>
-
- <odl:rpc-implementation ref="provider"/>
-
-</blueprint> \ 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 @@
-<?xml version="1.0" encoding="UTF-8"?>
-<blueprint xmlns="http://www.osgi.org/xmlns/blueprint/v1.0.0"
- xmlns:odl="http://opendaylight.org/xmlns/blueprint/v1.0.0"
- odl:use-default-for-reference-types="true">
-
- <reference id="svcLogicService"
- interface="org.onap.ccsdk.sli.core.sli.provider.SvcLogicService" />
-
- <bean id="client" class="org.onap.ccsdk.sli.northbound.LcmSliClient">
- <argument ref="svcLogicService" />
- </bean>
-
- <reference id="dataBroker"
- interface="org.opendaylight.controller.md.sal.binding.api.DataBroker"
- odl:type="default" />
-
- <reference id="notificationService"
- interface="org.opendaylight.controller.md.sal.binding.api.NotificationPublishService"
- odl:type="default" />
-
- <reference id="rpcRegistry"
- interface="org.opendaylight.controller.sal.binding.api.RpcProviderRegistry"
- odl:type="default" />
-
- <bean id="provider" class="org.onap.ccsdk.sli.northbound.LcmProvider">
- <argument ref="dataBroker" />
- <argument ref="notificationService" />
- <argument ref="rpcRegistry" />
- <argument ref="client" />
- </bean>
-
- <odl:rpc-implementation ref="provider"/>
-
-</blueprint> \ No newline at end of file