From ad7220f5dcb8a3acd43bca1d855012a441e97d5c Mon Sep 17 00:00:00 2001 From: Lathish Date: Thu, 16 Jul 2020 15:46:14 +0100 Subject: Updated A1 Yang model Issue-ID: CCSDK-2581 Change-Id: I816cac765c2cf09c3d0911b98b3361ef8cb3696f Signed-off-by: Lathish --- .../sdnr/northbound/a1Adapter/A1AdapterClient.java | 620 +------------ .../northbound/a1Adapter/A1AdapterProvider.java | 956 +-------------------- 2 files changed, 30 insertions(+), 1546 deletions(-) (limited to 'sdnr/northbound/a1Adapter/provider/src/main') diff --git a/sdnr/northbound/a1Adapter/provider/src/main/java/org/onap/ccsdk/features/sdnr/northbound/a1Adapter/A1AdapterClient.java b/sdnr/northbound/a1Adapter/provider/src/main/java/org/onap/ccsdk/features/sdnr/northbound/a1Adapter/A1AdapterClient.java index 324e0eae1..eb0894bd6 100644 --- a/sdnr/northbound/a1Adapter/provider/src/main/java/org/onap/ccsdk/features/sdnr/northbound/a1Adapter/A1AdapterClient.java +++ b/sdnr/northbound/a1Adapter/provider/src/main/java/org/onap/ccsdk/features/sdnr/northbound/a1Adapter/A1AdapterClient.java @@ -3,7 +3,7 @@ * openECOMP : SDN-C * ================================================================================ * Copyright (C) 2017 AT&T Intellectual Property. All rights - * reserved. + * reserved. * Modifications Copyright (C) 2020 Nordix Foundation. * ================================================================================ * Licensed under the Apache License, Version 2.0 (the "License"); @@ -22,22 +22,8 @@ package org.onap.ccsdk.features.sdnr.northbound.a1Adapter; -import java.util.Properties; import org.onap.ccsdk.sli.core.sli.SvcLogicException; -import org.onap.ccsdk.sli.core.sli.provider.MdsalHelper; import org.onap.ccsdk.sli.core.sli.provider.SvcLogicService; -import org.opendaylight.yang.gen.v1.org.onap.ccsdk.rev191212.CreatePolicyInstanceOutputBuilder; -import org.opendaylight.yang.gen.v1.org.onap.ccsdk.rev191212.CreatePolicyTypeOutputBuilder; -import org.opendaylight.yang.gen.v1.org.onap.ccsdk.rev191212.DeletePolicyInstanceOutputBuilder; -import org.opendaylight.yang.gen.v1.org.onap.ccsdk.rev191212.DeletePolicyTypeOutputBuilder; -import org.opendaylight.yang.gen.v1.org.onap.ccsdk.rev191212.GetHealthCheckOutputBuilder; -import org.opendaylight.yang.gen.v1.org.onap.ccsdk.rev191212.GetNearRTRICsOutputBuilder; -import org.opendaylight.yang.gen.v1.org.onap.ccsdk.rev191212.GetPolicyInstanceOutputBuilder; -import org.opendaylight.yang.gen.v1.org.onap.ccsdk.rev191212.GetPolicyInstancesOutputBuilder; -import org.opendaylight.yang.gen.v1.org.onap.ccsdk.rev191212.GetPolicyTypeOutputBuilder; -import org.opendaylight.yang.gen.v1.org.onap.ccsdk.rev191212.GetPolicyTypesOutputBuilder; -import org.opendaylight.yang.gen.v1.org.onap.ccsdk.rev191212.GetStatusOutputBuilder; -import org.opendaylight.yang.gen.v1.org.onap.ccsdk.rev191212.NotifyPolicyEnforcementUpdateOutputBuilder; import org.slf4j.Logger; import org.slf4j.LoggerFactory; @@ -54,606 +40,4 @@ public class A1AdapterClient { public boolean hasGraph(String module, String rpc, String version, String mode) throws SvcLogicException { return svcLogicService.hasGraph(module, rpc, version, mode); } - - // Client for GetNearRTRICs - - public Properties execute(String module, String rpc, String version, String mode, - GetNearRTRICsOutputBuilder serviceData) throws SvcLogicException { - - Properties parms = new Properties(); - - return execute(module, rpc, version, mode, serviceData, parms); - } - - public Properties execute(String module, String rpc, String version, String mode, - GetNearRTRICsOutputBuilder serviceData, Properties parms) throws SvcLogicException { - Properties localProp; - localProp = MdsalHelper.toProperties(parms, serviceData); - - if (LOG.isDebugEnabled()) { - LOG.debug("Parameters passed to SLI"); - - for (Object key : localProp.keySet()) { - String parmName = (String) key; - String parmValue = localProp.getProperty(parmName); - - LOG.debug(parmName + " = " + parmValue); - - } - } - - Properties respProps = svcLogicService.execute(module, rpc, version, mode, localProp); - - 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"))) { - return respProps; - } - - MdsalHelper.toBuilder(respProps, serviceData); - - return respProps; - } - - // Client for GetHealthCheck - - public Properties execute(String module, String rpc, String version, String mode, - GetHealthCheckOutputBuilder serviceData) throws SvcLogicException { - - Properties parms = new Properties(); - - return execute(module, rpc, version, mode, serviceData, parms); - } - - public Properties execute(String module, String rpc, String version, String mode, - GetHealthCheckOutputBuilder serviceData, Properties parms) throws SvcLogicException { - Properties localProp; - localProp = MdsalHelper.toProperties(parms, serviceData); - - if (LOG.isDebugEnabled()) { - LOG.debug("Parameters passed to SLI"); - - for (Object key : localProp.keySet()) { - String parmName = (String) key; - String parmValue = localProp.getProperty(parmName); - - LOG.debug(parmName + " = " + parmValue); - - } - } - - Properties respProps = svcLogicService.execute(module, rpc, version, mode, localProp); - - 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"))) { - return respProps; - } - - MdsalHelper.toBuilder(respProps, serviceData); - - return respProps; - } - - - // Client for getPolicyTypes - - public Properties execute(String module, String rpc, String version, String mode, - GetPolicyTypesOutputBuilder serviceData) throws SvcLogicException { - - Properties parms = new Properties(); - - return execute(module, rpc, version, mode, serviceData, parms); - } - - public Properties execute(String module, String rpc, String version, String mode, - GetPolicyTypesOutputBuilder serviceData, Properties parms) throws SvcLogicException { - Properties localProp; - localProp = MdsalHelper.toProperties(parms, serviceData); - - if (LOG.isDebugEnabled()) { - LOG.debug("Parameters passed to SLI"); - - for (Object key : localProp.keySet()) { - String parmName = (String) key; - String parmValue = localProp.getProperty(parmName); - - LOG.debug(parmName + " = " + parmValue); - - } - } - - Properties respProps = svcLogicService.execute(module, rpc, version, mode, localProp); - - 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"))) { - return respProps; - } - - MdsalHelper.toBuilder(respProps, serviceData); - - return respProps; - } - - - // Client for createPolicyType - - - public Properties execute(String module, String rpc, String version, String mode, - CreatePolicyTypeOutputBuilder serviceData) throws SvcLogicException { - - Properties parms = new Properties(); - - return execute(module, rpc, version, mode, serviceData, parms); - } - - public Properties execute(String module, String rpc, String version, String mode, - CreatePolicyTypeOutputBuilder serviceData, Properties parms) throws SvcLogicException { - Properties localProp; - localProp = MdsalHelper.toProperties(parms, serviceData); - - if (LOG.isDebugEnabled()) { - LOG.debug("Parameters passed to SLI"); - - for (Object key : localProp.keySet()) { - String parmName = (String) key; - String parmValue = localProp.getProperty(parmName); - - LOG.debug(parmName + " = " + parmValue); - - } - } - - Properties respProps = svcLogicService.execute(module, rpc, version, mode, localProp); - - 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"))) { - return respProps; - } - - MdsalHelper.toBuilder(respProps, serviceData); - - return respProps; - } - - // Client for getPolicyType - - public Properties execute(String module, String rpc, String version, String mode, - GetPolicyTypeOutputBuilder serviceData) throws SvcLogicException { - - Properties parms = new Properties(); - - return execute(module, rpc, version, mode, serviceData, parms); - } - - public Properties execute(String module, String rpc, String version, String mode, - GetPolicyTypeOutputBuilder serviceData, Properties parms) throws SvcLogicException { - Properties localProp; - localProp = MdsalHelper.toProperties(parms, serviceData); - - if (LOG.isDebugEnabled()) { - LOG.debug("Parameters passed to SLI"); - - for (Object key : localProp.keySet()) { - String parmName = (String) key; - String parmValue = localProp.getProperty(parmName); - - LOG.debug(parmName + " = " + parmValue); - - } - } - - Properties respProps = svcLogicService.execute(module, rpc, version, mode, localProp); - - 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"))) { - return respProps; - } - - MdsalHelper.toBuilder(respProps, serviceData); - - return respProps; - } - - - // Client for deletePolicyType - - public Properties execute(String module, String rpc, String version, String mode, - DeletePolicyTypeOutputBuilder serviceData) throws SvcLogicException { - - Properties parms = new Properties(); - - return execute(module, rpc, version, mode, serviceData, parms); - } - - public Properties execute(String module, String rpc, String version, String mode, - DeletePolicyTypeOutputBuilder serviceData, Properties parms) throws SvcLogicException { - Properties localProp; - localProp = MdsalHelper.toProperties(parms, serviceData); - - if (LOG.isDebugEnabled()) { - LOG.debug("Parameters passed to SLI"); - - for (Object key : localProp.keySet()) { - String parmName = (String) key; - String parmValue = localProp.getProperty(parmName); - - LOG.debug(parmName + " = " + parmValue); - - } - } - - Properties respProps = svcLogicService.execute(module, rpc, version, mode, localProp); - - 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"))) { - return respProps; - } - - MdsalHelper.toBuilder(respProps, serviceData); - - return respProps; - } - - - // Client for getPolicyInstances - - public Properties execute(String module, String rpc, String version, String mode, - GetPolicyInstancesOutputBuilder serviceData) throws SvcLogicException { - - Properties parms = new Properties(); - - return execute(module, rpc, version, mode, serviceData, parms); - } - - public Properties execute(String module, String rpc, String version, String mode, - GetPolicyInstancesOutputBuilder serviceData, Properties parms) throws SvcLogicException { - Properties localProp; - localProp = MdsalHelper.toProperties(parms, serviceData); - - if (LOG.isDebugEnabled()) { - LOG.debug("Parameters passed to SLI"); - - for (Object key : localProp.keySet()) { - String parmName = (String) key; - String parmValue = localProp.getProperty(parmName); - - LOG.debug(parmName + " = " + parmValue); - - } - } - - Properties respProps = svcLogicService.execute(module, rpc, version, mode, localProp); - - 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"))) { - return respProps; - } - - MdsalHelper.toBuilder(respProps, serviceData); - - return respProps; - } - - - - // Client for createPolicyInstance - - public Properties execute(String module, String rpc, String version, String mode, - CreatePolicyInstanceOutputBuilder serviceData) throws SvcLogicException { - - Properties parms = new Properties(); - - return execute(module, rpc, version, mode, serviceData, parms); - } - - public Properties execute(String module, String rpc, String version, String mode, - CreatePolicyInstanceOutputBuilder serviceData, Properties parms) throws SvcLogicException { - Properties localProp; - localProp = MdsalHelper.toProperties(parms, serviceData); - - if (LOG.isDebugEnabled()) { - LOG.debug("Parameters passed to SLI"); - - for (Object key : localProp.keySet()) { - String parmName = (String) key; - String parmValue = localProp.getProperty(parmName); - - LOG.debug(parmName + " = " + parmValue); - - } - } - - Properties respProps = svcLogicService.execute(module, rpc, version, mode, localProp); - - 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"))) { - return respProps; - } - - MdsalHelper.toBuilder(respProps, serviceData); - - return respProps; - } - - - // Client for getPolicyInstance - - public Properties execute(String module, String rpc, String version, String mode, - GetPolicyInstanceOutputBuilder serviceData) throws SvcLogicException { - - Properties parms = new Properties(); - - return execute(module, rpc, version, mode, serviceData, parms); - } - - public Properties execute(String module, String rpc, String version, String mode, - GetPolicyInstanceOutputBuilder serviceData, Properties parms) throws SvcLogicException { - Properties localProp; - localProp = MdsalHelper.toProperties(parms, serviceData); - - if (LOG.isDebugEnabled()) { - LOG.debug("Parameters passed to SLI"); - - for (Object key : localProp.keySet()) { - String parmName = (String) key; - String parmValue = localProp.getProperty(parmName); - - LOG.debug(parmName + " = " + parmValue); - - } - } - - Properties respProps = svcLogicService.execute(module, rpc, version, mode, localProp); - - 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"))) { - return respProps; - } - - MdsalHelper.toBuilder(respProps, serviceData); - - return respProps; - } - - // Client for deletePolicyInstance - - public Properties execute(String module, String rpc, String version, String mode, - DeletePolicyInstanceOutputBuilder serviceData) throws SvcLogicException { - - Properties parms = new Properties(); - - return execute(module, rpc, version, mode, serviceData, parms); - } - - public Properties execute(String module, String rpc, String version, String mode, - DeletePolicyInstanceOutputBuilder serviceData, Properties parms) throws SvcLogicException { - Properties localProp; - localProp = MdsalHelper.toProperties(parms, serviceData); - - if (LOG.isDebugEnabled()) { - LOG.debug("Parameters passed to SLI"); - - for (Object key : localProp.keySet()) { - String parmName = (String) key; - String parmValue = localProp.getProperty(parmName); - - LOG.debug(parmName + " = " + parmValue); - - } - } - - Properties respProps = svcLogicService.execute(module, rpc, version, mode, localProp); - - 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"))) { - return respProps; - } - - MdsalHelper.toBuilder(respProps, serviceData); - - return respProps; - } - - // Client for getStatus - - - public Properties execute(String module, String rpc, String version, String mode, - GetStatusOutputBuilder serviceData) throws SvcLogicException { - - Properties parms = new Properties(); - - return execute(module, rpc, version, mode, serviceData, parms); - } - - public Properties execute(String module, String rpc, String version, String mode, - GetStatusOutputBuilder serviceData, Properties parms) throws SvcLogicException { - Properties localProp; - localProp = MdsalHelper.toProperties(parms, serviceData); - - if (LOG.isDebugEnabled()) { - LOG.debug("Parameters passed to SLI"); - - for (Object key : localProp.keySet()) { - String parmName = (String) key; - String parmValue = localProp.getProperty(parmName); - - LOG.debug(parmName + " = " + parmValue); - - } - } - - Properties respProps = svcLogicService.execute(module, rpc, version, mode, localProp); - - 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"))) { - return respProps; - } - - MdsalHelper.toBuilder(respProps, serviceData); - - return respProps; - } - - - // Client for notifyPolicyEnforcementUpdate - - - public Properties execute(String module, String rpc, String version, String mode, - NotifyPolicyEnforcementUpdateOutputBuilder serviceData) throws SvcLogicException { - - Properties parms = new Properties(); - - return execute(module, rpc, version, mode, serviceData, parms); - } - - public Properties execute(String module, String rpc, String version, String mode, - NotifyPolicyEnforcementUpdateOutputBuilder serviceData, Properties parms) throws SvcLogicException { - Properties localProp; - localProp = MdsalHelper.toProperties(parms, serviceData); - - if (LOG.isDebugEnabled()) { - LOG.debug("Parameters passed to SLI"); - - for (Object key : localProp.keySet()) { - String parmName = (String) key; - String parmValue = localProp.getProperty(parmName); - - LOG.debug(parmName + " = " + parmValue); - - } - } - - Properties respProps = svcLogicService.execute(module, rpc, version, mode, localProp); - - 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"))) { - return respProps; - } - - MdsalHelper.toBuilder(respProps, serviceData); - - return respProps; - } - - - -} +} \ No newline at end of file diff --git a/sdnr/northbound/a1Adapter/provider/src/main/java/org/onap/ccsdk/features/sdnr/northbound/a1Adapter/A1AdapterProvider.java b/sdnr/northbound/a1Adapter/provider/src/main/java/org/onap/ccsdk/features/sdnr/northbound/a1Adapter/A1AdapterProvider.java index b10177d8f..22109b09b 100644 --- a/sdnr/northbound/a1Adapter/provider/src/main/java/org/onap/ccsdk/features/sdnr/northbound/a1Adapter/A1AdapterProvider.java +++ b/sdnr/northbound/a1Adapter/provider/src/main/java/org/onap/ccsdk/features/sdnr/northbound/a1Adapter/A1AdapterProvider.java @@ -3,7 +3,7 @@ * openECOMP : SDN-C * ================================================================================ * Copyright (C) 2017 AT&T Intellectual Property. All rights - * reserved. + * reserved. * Modifications Copyright (C) 2020 Nordix Foundation. * ================================================================================ * Licensed under the Apache License, Version 2.0 (the "License"); @@ -22,68 +22,25 @@ package org.onap.ccsdk.features.sdnr.northbound.a1Adapter; -import com.google.common.util.concurrent.Futures; import com.google.common.util.concurrent.ListenableFuture; -import java.util.Properties; import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; -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.sal.binding.api.BindingAwareBroker; import org.opendaylight.controller.sal.binding.api.RpcProviderRegistry; -import org.opendaylight.yang.gen.v1.org.onap.ccsdk.rev191212.A1ADAPTERAPIService; -import org.opendaylight.yang.gen.v1.org.onap.ccsdk.rev191212.CreatePolicyInstanceInput; -import org.opendaylight.yang.gen.v1.org.onap.ccsdk.rev191212.CreatePolicyInstanceInputBuilder; -import org.opendaylight.yang.gen.v1.org.onap.ccsdk.rev191212.CreatePolicyInstanceOutput; -import org.opendaylight.yang.gen.v1.org.onap.ccsdk.rev191212.CreatePolicyInstanceOutputBuilder; -import org.opendaylight.yang.gen.v1.org.onap.ccsdk.rev191212.CreatePolicyTypeInput; -import org.opendaylight.yang.gen.v1.org.onap.ccsdk.rev191212.CreatePolicyTypeInputBuilder; -import org.opendaylight.yang.gen.v1.org.onap.ccsdk.rev191212.CreatePolicyTypeOutput; -import org.opendaylight.yang.gen.v1.org.onap.ccsdk.rev191212.CreatePolicyTypeOutputBuilder; -import org.opendaylight.yang.gen.v1.org.onap.ccsdk.rev191212.DeletePolicyInstanceInput; -import org.opendaylight.yang.gen.v1.org.onap.ccsdk.rev191212.DeletePolicyInstanceInputBuilder; -import org.opendaylight.yang.gen.v1.org.onap.ccsdk.rev191212.DeletePolicyInstanceOutput; -import org.opendaylight.yang.gen.v1.org.onap.ccsdk.rev191212.DeletePolicyInstanceOutputBuilder; -import org.opendaylight.yang.gen.v1.org.onap.ccsdk.rev191212.DeletePolicyTypeInput; -import org.opendaylight.yang.gen.v1.org.onap.ccsdk.rev191212.DeletePolicyTypeInputBuilder; -import org.opendaylight.yang.gen.v1.org.onap.ccsdk.rev191212.DeletePolicyTypeOutput; -import org.opendaylight.yang.gen.v1.org.onap.ccsdk.rev191212.DeletePolicyTypeOutputBuilder; -import org.opendaylight.yang.gen.v1.org.onap.ccsdk.rev191212.GetHealthCheckInput; -import org.opendaylight.yang.gen.v1.org.onap.ccsdk.rev191212.GetHealthCheckInputBuilder; -import org.opendaylight.yang.gen.v1.org.onap.ccsdk.rev191212.GetHealthCheckOutput; -import org.opendaylight.yang.gen.v1.org.onap.ccsdk.rev191212.GetHealthCheckOutputBuilder; -import org.opendaylight.yang.gen.v1.org.onap.ccsdk.rev191212.GetNearRTRICsInput; -import org.opendaylight.yang.gen.v1.org.onap.ccsdk.rev191212.GetNearRTRICsInputBuilder; -import org.opendaylight.yang.gen.v1.org.onap.ccsdk.rev191212.GetNearRTRICsOutput; -import org.opendaylight.yang.gen.v1.org.onap.ccsdk.rev191212.GetNearRTRICsOutputBuilder; -import org.opendaylight.yang.gen.v1.org.onap.ccsdk.rev191212.GetPolicyInstanceInput; -import org.opendaylight.yang.gen.v1.org.onap.ccsdk.rev191212.GetPolicyInstanceInputBuilder; -import org.opendaylight.yang.gen.v1.org.onap.ccsdk.rev191212.GetPolicyInstanceOutput; -import org.opendaylight.yang.gen.v1.org.onap.ccsdk.rev191212.GetPolicyInstanceOutputBuilder; -import org.opendaylight.yang.gen.v1.org.onap.ccsdk.rev191212.GetPolicyInstancesInput; -import org.opendaylight.yang.gen.v1.org.onap.ccsdk.rev191212.GetPolicyInstancesInputBuilder; -import org.opendaylight.yang.gen.v1.org.onap.ccsdk.rev191212.GetPolicyInstancesOutput; -import org.opendaylight.yang.gen.v1.org.onap.ccsdk.rev191212.GetPolicyInstancesOutputBuilder; -import org.opendaylight.yang.gen.v1.org.onap.ccsdk.rev191212.GetPolicyTypeInput; -import org.opendaylight.yang.gen.v1.org.onap.ccsdk.rev191212.GetPolicyTypeInputBuilder; -import org.opendaylight.yang.gen.v1.org.onap.ccsdk.rev191212.GetPolicyTypeOutput; -import org.opendaylight.yang.gen.v1.org.onap.ccsdk.rev191212.GetPolicyTypeOutputBuilder; -import org.opendaylight.yang.gen.v1.org.onap.ccsdk.rev191212.GetPolicyTypesInput; -import org.opendaylight.yang.gen.v1.org.onap.ccsdk.rev191212.GetPolicyTypesInputBuilder; -import org.opendaylight.yang.gen.v1.org.onap.ccsdk.rev191212.GetPolicyTypesOutput; -import org.opendaylight.yang.gen.v1.org.onap.ccsdk.rev191212.GetPolicyTypesOutputBuilder; -import org.opendaylight.yang.gen.v1.org.onap.ccsdk.rev191212.GetStatusInput; -import org.opendaylight.yang.gen.v1.org.onap.ccsdk.rev191212.GetStatusInputBuilder; -import org.opendaylight.yang.gen.v1.org.onap.ccsdk.rev191212.GetStatusOutput; -import org.opendaylight.yang.gen.v1.org.onap.ccsdk.rev191212.GetStatusOutputBuilder; -import org.opendaylight.yang.gen.v1.org.onap.ccsdk.rev191212.NotifyPolicyEnforcementUpdateInput; -import org.opendaylight.yang.gen.v1.org.onap.ccsdk.rev191212.NotifyPolicyEnforcementUpdateInputBuilder; -import org.opendaylight.yang.gen.v1.org.onap.ccsdk.rev191212.NotifyPolicyEnforcementUpdateOutput; -import org.opendaylight.yang.gen.v1.org.onap.ccsdk.rev191212.NotifyPolicyEnforcementUpdateOutputBuilder; -import org.opendaylight.yangtools.concepts.Builder; +import org.opendaylight.yang.gen.v1.org.onap.a1.adapter.rev200122.A1ADAPTERAPIService; +import org.opendaylight.yang.gen.v1.org.onap.a1.adapter.rev200122.DeleteA1PolicyInput; +import org.opendaylight.yang.gen.v1.org.onap.a1.adapter.rev200122.DeleteA1PolicyOutput; +import org.opendaylight.yang.gen.v1.org.onap.a1.adapter.rev200122.GetA1PolicyInput; +import org.opendaylight.yang.gen.v1.org.onap.a1.adapter.rev200122.GetA1PolicyOutput; +import org.opendaylight.yang.gen.v1.org.onap.a1.adapter.rev200122.GetA1PolicyStatusInput; +import org.opendaylight.yang.gen.v1.org.onap.a1.adapter.rev200122.GetA1PolicyStatusOutput; +import org.opendaylight.yang.gen.v1.org.onap.a1.adapter.rev200122.GetA1PolicyTypeInput; +import org.opendaylight.yang.gen.v1.org.onap.a1.adapter.rev200122.GetA1PolicyTypeOutput; +import org.opendaylight.yang.gen.v1.org.onap.a1.adapter.rev200122.PutA1PolicyInput; +import org.opendaylight.yang.gen.v1.org.onap.a1.adapter.rev200122.PutA1PolicyOutput; import org.opendaylight.yangtools.yang.common.RpcResult; -import org.opendaylight.yangtools.yang.common.RpcResultBuilder; import org.slf4j.Logger; import org.slf4j.LoggerFactory; @@ -148,891 +105,34 @@ public class A1AdapterProvider implements AutoCloseable, A1ADAPTERAPIService { LOG.info("Successfully closed provider for {}", APPLICATION_NAME); } - // RPC getNearRT-RICs - - @Override - public ListenableFuture> getNearRTRICs(GetNearRTRICsInput input) { - final String svcOperation = "getNearRT-RICs"; - - Properties parms = new Properties(); - GetNearRTRICsOutputBuilder serviceDataBuilder = (GetNearRTRICsOutputBuilder) getServiceData(GET_NEARRT_RICS); - - LOG.info("Reached RPC getNearRT-RICs"); - - LOG.info(svcOperation + " called."); - - if (input == null) { - LOG.debug("exiting " + svcOperation + " because of invalid input"); - serviceDataBuilder.setResponseCode("Input is null"); - RpcResult rpcResult = - RpcResultBuilder.status(true).withResult(serviceDataBuilder.build()).build(); - return Futures.immediateFuture(rpcResult); - } - - // add input to parms - LOG.info("Adding INPUT data for " + svcOperation + " input: " + input); - GetNearRTRICsInputBuilder inputBuilder = new GetNearRTRICsInputBuilder(input); - MdsalHelper.toProperties(parms, inputBuilder.build()); - - LOG.info("Printing SLI parameters to be passed"); - - // iterate properties file to get key-value pairs - for (String key : parms.stringPropertyNames()) { - String value = parms.getProperty(key); - LOG.info("The SLI parameter in " + key + " is: " + value); - } - - // Call SLI sync method - try { - if (A1AdapterClient.hasGraph("A1-ADAPTER-API", svcOperation, null, "sync")) { - LOG.info("A1AdapterClient has a Directed Graph for '" + svcOperation + "'"); - try { - A1AdapterClient.execute("A1-ADAPTER-API", svcOperation, null, "sync", serviceDataBuilder, parms); - } catch (Exception e) { - LOG.error("Caught exception executing service logic for " + svcOperation, e); - serviceDataBuilder.setResponseCode("500"); - } - } else { - LOG.error("No service logic active for A1Adapter: '" + svcOperation + "'"); - serviceDataBuilder.setResponseCode("503"); - } - } catch (Exception e) { - LOG.error("Caught exception looking for service logic", e); - serviceDataBuilder.setResponseCode("500"); - } - - String errorCode = serviceDataBuilder.getResponseCode(); - - if (!("0".equals(errorCode) || "200".equals(errorCode))) { - LOG.error("Returned FAILED for " + svcOperation + " error code: '" + errorCode + "'"); - } else { - LOG.info("Returned SUCCESS for " + svcOperation + " "); - serviceDataBuilder.setResponseMessage("A1 Adapter Executed for GetNearRTRICs "); - } - - RpcResult rpcResult = - RpcResultBuilder.status(true).withResult(serviceDataBuilder.build()).build(); - - LOG.info("Successful exit from getNearRT-RICs "); - - return Futures.immediateFuture(rpcResult); - } - - // RPC getHealthCheck - - @Override - public ListenableFuture> getHealthCheck(GetHealthCheckInput input) { - final String svcOperation = "getHealthCheck"; - - Properties parms = new Properties(); - GetHealthCheckOutputBuilder serviceDataBuilder = (GetHealthCheckOutputBuilder) getServiceData(GET_HEALTH_CHECK); - - LOG.info("Reached RPC getHealthCheck"); - - LOG.info(svcOperation + " called."); - - if (input == null) { - LOG.debug("exiting " + svcOperation + " because of invalid input"); - serviceDataBuilder.setResponseCode("Input is null"); - RpcResult rpcResult = - RpcResultBuilder.status(true).withResult(serviceDataBuilder.build()).build(); - return Futures.immediateFuture(rpcResult); - } - - // add input to parms - LOG.info("Adding INPUT data for " + svcOperation + " input: " + input); - GetHealthCheckInputBuilder inputBuilder = new GetHealthCheckInputBuilder(input); - MdsalHelper.toProperties(parms, inputBuilder.build()); - - LOG.info("Printing SLI parameters to be passed"); - - // iterate properties file to get key-value pairs - for (String key : parms.stringPropertyNames()) { - String value = parms.getProperty(key); - LOG.info("The SLI parameter in " + key + " is: " + value); - } - - // Call SLI sync method - try { - if (A1AdapterClient.hasGraph("A1-ADAPTER-API", svcOperation, null, "sync")) { - LOG.info("A1AdapterClient has a Directed Graph for '" + svcOperation + "'"); - try { - A1AdapterClient.execute("A1-ADAPTER-API", svcOperation, null, "sync", serviceDataBuilder, parms); - } catch (Exception e) { - LOG.error("Caught exception executing service logic for " + svcOperation, e); - serviceDataBuilder.setResponseCode("500"); - } - } else { - LOG.error("No service logic active for A1Adapter: '" + svcOperation + "'"); - serviceDataBuilder.setResponseCode("503"); - } - } catch (Exception e) { - LOG.error("Caught exception looking for service logic", e); - serviceDataBuilder.setResponseCode("500"); - } - - String errorCode = serviceDataBuilder.getResponseCode(); - - if (!("0".equals(errorCode) || "200".equals(errorCode))) { - LOG.error("Returned FAILED for " + svcOperation + " error code: '" + errorCode + "'"); - } else { - LOG.info("Returned SUCCESS for " + svcOperation + " "); - serviceDataBuilder.setResponseMessage("A1 Adapter Executed for GetHealthCheck. "); - } - - RpcResult rpcResult = - RpcResultBuilder.status(true).withResult(serviceDataBuilder.build()).build(); - - LOG.info("Successful exit from getHealthCheck "); - - return Futures.immediateFuture(rpcResult); - } - - // RPC getPolicyTypes - - @Override - public ListenableFuture> getPolicyTypes(GetPolicyTypesInput input) { - final String svcOperation = "getPolicyTypes"; - - Properties parms = new Properties(); - GetPolicyTypesOutputBuilder serviceDataBuilder = (GetPolicyTypesOutputBuilder) getServiceData(GET_POLICY_TYPES); - - LOG.info("Reached RPC getPolicyTypes"); - - LOG.info(svcOperation + " called."); - - if (input == null) { - LOG.debug("exiting " + svcOperation + " because of invalid input"); - serviceDataBuilder.setResponseCode("Input is null"); - RpcResult rpcResult = - RpcResultBuilder.status(true).withResult(serviceDataBuilder.build()).build(); - return Futures.immediateFuture(rpcResult); - } - - // add input to parms - LOG.info("Adding INPUT data for " + svcOperation + " input: " + input); - GetPolicyTypesInputBuilder inputBuilder = new GetPolicyTypesInputBuilder(input); - MdsalHelper.toProperties(parms, inputBuilder.build()); - - LOG.info("Printing SLI parameters to be passed"); - - // iterate properties file to get key-value pairs - for (String key : parms.stringPropertyNames()) { - String value = parms.getProperty(key); - LOG.info("The SLI parameter in " + key + " is: " + value); - } - - // Call SLI sync method - try { - if (A1AdapterClient.hasGraph("A1-ADAPTER-API", svcOperation, null, "sync")) { - LOG.info("A1AdapterClient has a Directed Graph for '" + svcOperation + "'"); - try { - A1AdapterClient.execute("A1-ADAPTER-API", svcOperation, null, "sync", serviceDataBuilder, parms); - } catch (Exception e) { - LOG.error("Caught exception executing service logic for " + svcOperation, e); - serviceDataBuilder.setResponseCode("500"); - } - } else { - LOG.error("No service logic active for A1Adapter: '" + svcOperation + "'"); - serviceDataBuilder.setResponseCode("503"); - } - } catch (Exception e) { - LOG.error("Caught exception looking for service logic", e); - serviceDataBuilder.setResponseCode("500"); - } - - String errorCode = serviceDataBuilder.getResponseCode(); - - if (!("0".equals(errorCode) || "200".equals(errorCode))) { - LOG.error("Returned FAILED for " + svcOperation + " error code: '" + errorCode + "'"); - } else { - LOG.info("Returned SUCCESS for " + svcOperation + " "); - serviceDataBuilder.setResponseMessage("A1 Adapter Executed for GetPolicyTypes "); - } - - RpcResult rpcResult = - RpcResultBuilder.status(true).withResult(serviceDataBuilder.build()).build(); - - LOG.info("Successful exit from getPolicyTypes "); - - return Futures.immediateFuture(rpcResult); - } - - // RPC createPolicyType - - @Override - public ListenableFuture> createPolicyType(CreatePolicyTypeInput input) { - final String svcOperation = "createPolicyType"; - - Properties parms = new Properties(); - CreatePolicyTypeOutputBuilder serviceDataBuilder = - (CreatePolicyTypeOutputBuilder) getServiceData(CREATE_POLICY_TYPE); - - LOG.info("Reached RPC createPolicyType"); - - LOG.info(svcOperation + " called."); - - if (input == null) { - LOG.debug("exiting " + svcOperation + " because of invalid input"); - serviceDataBuilder.setResponseCode("Input is null"); - RpcResult rpcResult = RpcResultBuilder.status(true) - .withResult(serviceDataBuilder.build()).build(); - return Futures.immediateFuture(rpcResult); - } - - // add input to parms - LOG.info("Adding INPUT data for " + svcOperation + " input: " + input); - CreatePolicyTypeInputBuilder inputBuilder = new CreatePolicyTypeInputBuilder(input); - MdsalHelper.toProperties(parms, inputBuilder.build()); - - LOG.info("Printing SLI parameters to be passed"); - - // iterate properties file to get key-value pairs - for (String key : parms.stringPropertyNames()) { - String value = parms.getProperty(key); - LOG.info("The SLI parameter in " + key + " is: " + value); - } - - // Call SLI sync method - try { - if (A1AdapterClient.hasGraph("A1-ADAPTER-API", svcOperation, null, "sync")) { - LOG.info("A1AdapterClient has a Directed Graph for '" + svcOperation + "'"); - try { - A1AdapterClient.execute("A1-ADAPTER-API", svcOperation, null, "sync", serviceDataBuilder, parms); - } catch (Exception e) { - LOG.error("Caught exception executing service logic for " + svcOperation, e); - serviceDataBuilder.setResponseCode("500"); - } - } else { - LOG.error("No service logic active for A1Adapter: '" + svcOperation + "'"); - serviceDataBuilder.setResponseCode("503"); - } - } catch (Exception e) { - LOG.error("Caught exception looking for service logic", e); - serviceDataBuilder.setResponseCode("500"); - } - - String errorCode = serviceDataBuilder.getResponseCode(); - - if (!("0".equals(errorCode) || "200".equals(errorCode))) { - LOG.error("Returned FAILED for " + svcOperation + " error code: '" + errorCode + "'"); - } else { - LOG.info("Returned SUCCESS for " + svcOperation + " "); - serviceDataBuilder.setResponseMessage("A1 Adapter Executed for CreatePolicyType"); - } - - RpcResult rpcResult = - RpcResultBuilder.status(true).withResult(serviceDataBuilder.build()).build(); - - LOG.info("Successful exit from createPolicyType "); - - return Futures.immediateFuture(rpcResult); - } - - // RPC getPolicyType - - @Override - public ListenableFuture> getPolicyType(GetPolicyTypeInput input) { - final String svcOperation = "getPolicyType"; - - Properties parms = new Properties(); - GetPolicyTypeOutputBuilder serviceDataBuilder = (GetPolicyTypeOutputBuilder) getServiceData(GET_POLICY_TYPE); - - LOG.info("Reached RPC getPolicyType"); - - LOG.info(svcOperation + " called."); - - if (input == null) { - LOG.debug("exiting " + svcOperation + " because of invalid input"); - serviceDataBuilder.setResponseCode("Input is null"); - RpcResult rpcResult = - RpcResultBuilder.status(true).withResult(serviceDataBuilder.build()).build(); - return Futures.immediateFuture(rpcResult); - } - - // add input to parms - LOG.info("Adding INPUT data for " + svcOperation + " input: " + input); - GetPolicyTypeInputBuilder inputBuilder = new GetPolicyTypeInputBuilder(input); - MdsalHelper.toProperties(parms, inputBuilder.build()); - - LOG.info("Printing SLI parameters to be passed"); - - // iterate properties file to get key-value pairs - for (String key : parms.stringPropertyNames()) { - String value = parms.getProperty(key); - LOG.info("The SLI parameter in " + key + " is: " + value); - } - - // Call SLI sync method - try { - if (A1AdapterClient.hasGraph("A1-ADAPTER-API", svcOperation, null, "sync")) { - LOG.info("A1AdapterClient has a Directed Graph for '" + svcOperation + "'"); - try { - A1AdapterClient.execute("A1-ADAPTER-API", svcOperation, null, "sync", serviceDataBuilder, parms); - } catch (Exception e) { - LOG.error("Caught exception executing service logic for " + svcOperation, e); - serviceDataBuilder.setResponseCode("500"); - } - } else { - LOG.error("No service logic active for A1Adapter: '" + svcOperation + "'"); - serviceDataBuilder.setResponseCode("503"); - } - } catch (Exception e) { - LOG.error("Caught exception looking for service logic", e); - serviceDataBuilder.setResponseCode("500"); - } - - String errorCode = serviceDataBuilder.getResponseCode(); - - if (!("0".equals(errorCode) || "200".equals(errorCode))) { - LOG.error("Returned FAILED for " + svcOperation + " error code: '" + errorCode + "'"); - } else { - LOG.info("Returned SUCCESS for " + svcOperation + " "); - serviceDataBuilder.setResponseMessage("A1 Adapter Executed for GetPolicyType. "); - } - - RpcResult rpcResult = - RpcResultBuilder.status(true).withResult(serviceDataBuilder.build()).build(); - - LOG.info("Successful exit from getPolicyType "); - - return Futures.immediateFuture(rpcResult); - } - - // RPC deletePolicyType - - @Override - public ListenableFuture> deletePolicyType(DeletePolicyTypeInput input) { - final String svcOperation = "deletePolicyType"; - - Properties parms = new Properties(); - DeletePolicyTypeOutputBuilder serviceDataBuilder = - (DeletePolicyTypeOutputBuilder) getServiceData(DELETE_POLICY_TYPE); - - LOG.info("Reached RPC deletePolicyType"); - - LOG.info(svcOperation + " called."); - - if (input == null) { - LOG.debug("exiting " + svcOperation + " because of invalid input"); - serviceDataBuilder.setResponseCode("Input is null"); - RpcResult rpcResult = RpcResultBuilder.status(true) - .withResult(serviceDataBuilder.build()).build(); - return Futures.immediateFuture(rpcResult); - } - - // add input to parms - LOG.info("Adding INPUT data for " + svcOperation + " input: " + input); - DeletePolicyTypeInputBuilder inputBuilder = new DeletePolicyTypeInputBuilder(input); - MdsalHelper.toProperties(parms, inputBuilder.build()); - - LOG.info("Printing SLI parameters to be passed"); - - // iterate properties file to get key-value pairs - for (String key : parms.stringPropertyNames()) { - String value = parms.getProperty(key); - LOG.info("The SLI parameter in " + key + " is: " + value); - } - - // Call SLI sync method - try { - if (A1AdapterClient.hasGraph("A1-ADAPTER-API", svcOperation, null, "sync")) { - LOG.info("A1AdapterClient has a Directed Graph for '" + svcOperation + "'"); - try { - A1AdapterClient.execute("A1-ADAPTER-API", svcOperation, null, "sync", serviceDataBuilder, parms); - } catch (Exception e) { - LOG.error("Caught exception executing service logic for " + svcOperation, e); - serviceDataBuilder.setResponseCode("500"); - } - } else { - LOG.error("No service logic active for A1Adapter: '" + svcOperation + "'"); - serviceDataBuilder.setResponseCode("503"); - } - } catch (Exception e) { - LOG.error("Caught exception looking for service logic", e); - serviceDataBuilder.setResponseCode("500"); - } - - String errorCode = serviceDataBuilder.getResponseCode(); - - if (!("0".equals(errorCode) || "200".equals(errorCode))) { - LOG.error("Returned FAILED for " + svcOperation + " error code: '" + errorCode + "'"); - } else { - LOG.info("Returned SUCCESS for " + svcOperation + " "); - serviceDataBuilder.setResponseMessage("A1 Adapter Executed for DeletePolicyType "); - } - - RpcResult rpcResult = - RpcResultBuilder.status(true).withResult(serviceDataBuilder.build()).build(); - - LOG.info("Successful exit from deletePolicyType "); - - return Futures.immediateFuture(rpcResult); - } - - // RPC getPolicyInstances - - @Override - public ListenableFuture> getPolicyInstances(GetPolicyInstancesInput input) { - final String svcOperation = "getPolicyInstances"; - - Properties parms = new Properties(); - GetPolicyInstancesOutputBuilder serviceDataBuilder = - (GetPolicyInstancesOutputBuilder) getServiceData(GET_POLICY_INSTANCES); - - LOG.info("Reached RPC getPolicyInstances"); - - LOG.info(svcOperation + " called."); - - if (input == null) { - LOG.debug("exiting " + svcOperation + " because of invalid input"); - serviceDataBuilder.setResponseCode("Input is null"); - RpcResult rpcResult = RpcResultBuilder.status(true) - .withResult(serviceDataBuilder.build()).build(); - return Futures.immediateFuture(rpcResult); - } - - // add input to parms - LOG.info("Adding INPUT data for " + svcOperation + " input: " + input); - GetPolicyInstancesInputBuilder inputBuilder = new GetPolicyInstancesInputBuilder(input); - MdsalHelper.toProperties(parms, inputBuilder.build()); - - LOG.info("Printing SLI parameters to be passed"); - - // iterate properties file to get key-value pairs - for (String key : parms.stringPropertyNames()) { - String value = parms.getProperty(key); - LOG.info("The SLI parameter in " + key + " is: " + value); - } - - // Call SLI sync method - try { - if (A1AdapterClient.hasGraph("A1-ADAPTER-API", svcOperation, null, "sync")) { - LOG.info("A1AdapterClient has a Directed Graph for '" + svcOperation + "'"); - try { - A1AdapterClient.execute("A1-ADAPTER-API", svcOperation, null, "sync", serviceDataBuilder, parms); - } catch (Exception e) { - LOG.error("Caught exception executing service logic for " + svcOperation, e); - serviceDataBuilder.setResponseCode("500"); - } - } else { - LOG.error("No service logic active for A1Adapter: '" + svcOperation + "'"); - serviceDataBuilder.setResponseCode("503"); - } - } catch (Exception e) { - LOG.error("Caught exception looking for service logic", e); - serviceDataBuilder.setResponseCode("500"); - } - - String errorCode = serviceDataBuilder.getResponseCode(); - - if (!("0".equals(errorCode) || "200".equals(errorCode))) { - LOG.error("Returned FAILED for " + svcOperation + " error code: '" + errorCode + "'"); - } else { - LOG.info("Returned SUCCESS for " + svcOperation + " "); - serviceDataBuilder.setResponseMessage("A1 Adapter Executed for GetPolicyInstances "); - } - - RpcResult rpcResult = - RpcResultBuilder.status(true).withResult(serviceDataBuilder.build()).build(); - - LOG.info("Successful exit from getPolicyInstances "); - - return Futures.immediateFuture(rpcResult); - } - - - // RPC createPolicyInstance - @Override - public ListenableFuture> createPolicyInstance( - CreatePolicyInstanceInput input) { - final String svcOperation = "createPolicyInstance"; - - Properties parms = new Properties(); - CreatePolicyInstanceOutputBuilder serviceDataBuilder = - (CreatePolicyInstanceOutputBuilder) getServiceData(CREATE_POLICY_INSTANCES); - - LOG.info("Reached RPC createPolicyInstance"); - - LOG.info(svcOperation + " called."); - - if (input == null) { - LOG.debug("exiting " + svcOperation + " because of invalid input"); - serviceDataBuilder.setResponseCode("Input is null"); - RpcResult rpcResult = RpcResultBuilder.status(true) - .withResult(serviceDataBuilder.build()).build(); - return Futures.immediateFuture(rpcResult); - } - - // add input to parms - LOG.info("Adding INPUT data for " + svcOperation + " input: " + input); - CreatePolicyInstanceInputBuilder inputBuilder = new CreatePolicyInstanceInputBuilder(input); - MdsalHelper.toProperties(parms, inputBuilder.build()); - - LOG.info("Printing SLI parameters to be passed"); - - // iterate properties file to get key-value pairs - for (String key : parms.stringPropertyNames()) { - String value = parms.getProperty(key); - LOG.info("The SLI parameter in " + key + " is: " + value); - } - - // Call SLI sync method - try { - if (A1AdapterClient.hasGraph("A1-ADAPTER-API", svcOperation, null, "sync")) { - LOG.info("A1AdapterClient has a Directed Graph for '" + svcOperation + "'"); - try { - A1AdapterClient.execute("A1-ADAPTER-API", svcOperation, null, "sync", serviceDataBuilder, parms); - } catch (Exception e) { - LOG.error("Caught exception executing service logic for " + svcOperation, e); - serviceDataBuilder.setResponseCode("500"); - } - } else { - LOG.error("No service logic active for A1Adapter: '" + svcOperation + "'"); - serviceDataBuilder.setResponseCode("503"); - } - } catch (Exception e) { - LOG.error("Caught exception looking for service logic", e); - serviceDataBuilder.setResponseCode("500"); - } - - String errorCode = serviceDataBuilder.getResponseCode(); - - if (!("0".equals(errorCode) || "200".equals(errorCode))) { - LOG.error("Returned FAILED for " + svcOperation + " error code: '" + errorCode + "'"); - } else { - LOG.info("Returned SUCCESS for " + svcOperation + " "); - serviceDataBuilder.setResponseMessage("A1 Adapter Executed for CreatePolicyInstance. "); - } - - RpcResult rpcResult = RpcResultBuilder.status(true) - .withResult(serviceDataBuilder.build()).build(); - - LOG.info("Successful exit from createPolicyInstance "); - - return Futures.immediateFuture(rpcResult); + public ListenableFuture> deleteA1Policy(DeleteA1PolicyInput input) { + // TODO Auto-generated method stub + return null; } - - - // RPC getPolicyInstance - @Override - public ListenableFuture> getPolicyInstance(GetPolicyInstanceInput input) { - final String svcOperation = "getPolicyInstance"; - - Properties parms = new Properties(); - GetPolicyInstanceOutputBuilder serviceDataBuilder = - (GetPolicyInstanceOutputBuilder) getServiceData(GET_POLICY_INSTANCE); - - LOG.info("Reached RPC getPolicyInstance"); - - LOG.info(svcOperation + " called."); - - if (input == null) { - LOG.debug("exiting " + svcOperation + " because of invalid input"); - serviceDataBuilder.setResponseCode("Input is null"); - RpcResult rpcResult = RpcResultBuilder.status(true) - .withResult(serviceDataBuilder.build()).build(); - return Futures.immediateFuture(rpcResult); - } - - // add input to parms - LOG.info("Adding INPUT data for " + svcOperation + " input: " + input); - GetPolicyInstanceInputBuilder inputBuilder = new GetPolicyInstanceInputBuilder(input); - MdsalHelper.toProperties(parms, inputBuilder.build()); - - LOG.info("Printing SLI parameters to be passed"); - - // iterate properties file to get key-value pairs - for (String key : parms.stringPropertyNames()) { - String value = parms.getProperty(key); - LOG.info("The SLI parameter in " + key + " is: " + value); - } - - // Call SLI sync method - try { - if (A1AdapterClient.hasGraph("A1-ADAPTER-API", svcOperation, null, "sync")) { - LOG.info("A1AdapterClient has a Directed Graph for '" + svcOperation + "'"); - try { - A1AdapterClient.execute("A1-ADAPTER-API", svcOperation, null, "sync", serviceDataBuilder, parms); - } catch (Exception e) { - LOG.error("Caught exception executing service logic for " + svcOperation, e); - serviceDataBuilder.setResponseCode("500"); - } - } else { - LOG.error("No service logic active for A1Adapter: '" + svcOperation + "'"); - serviceDataBuilder.setResponseCode("503"); - } - } catch (Exception e) { - LOG.error("Caught exception looking for service logic", e); - serviceDataBuilder.setResponseCode("500"); - } - - String errorCode = serviceDataBuilder.getResponseCode(); - - if (!("0".equals(errorCode) || "200".equals(errorCode))) { - LOG.error("Returned FAILED for " + svcOperation + " error code: '" + errorCode + "'"); - } else { - LOG.info("Returned SUCCESS for " + svcOperation + " "); - serviceDataBuilder.setResponseMessage("A1 Adapter Executed for GetPolicyInstance. "); - } - - RpcResult rpcResult = - RpcResultBuilder.status(true).withResult(serviceDataBuilder.build()).build(); - - LOG.info("Successful exit from getPolicyInstance "); - - return Futures.immediateFuture(rpcResult); + public ListenableFuture> getA1Policy(GetA1PolicyInput input) { + // TODO Auto-generated method stub + return null; } - - - // RPC deletePolicyInstance - @Override - public ListenableFuture> deletePolicyInstance( - DeletePolicyInstanceInput input) { - final String svcOperation = "deletePolicyInstance"; - - Properties parms = new Properties(); - DeletePolicyInstanceOutputBuilder serviceDataBuilder = - (DeletePolicyInstanceOutputBuilder) getServiceData(DELETE_POLICY_INSTANCE); - - LOG.info("Reached RPC deletePolicyInstance"); - - LOG.info(svcOperation + " called."); - - if (input == null) { - LOG.debug("exiting " + svcOperation + " because of invalid input"); - serviceDataBuilder.setResponseCode("Input is null"); - RpcResult rpcResult = RpcResultBuilder.status(true) - .withResult(serviceDataBuilder.build()).build(); - return Futures.immediateFuture(rpcResult); - } - - // add input to parms - LOG.info("Adding INPUT data for " + svcOperation + " input: " + input); - DeletePolicyInstanceInputBuilder inputBuilder = new DeletePolicyInstanceInputBuilder(input); - MdsalHelper.toProperties(parms, inputBuilder.build()); - - LOG.info("Printing SLI parameters to be passed"); - - // iterate properties file to get key-value pairs - for (String key : parms.stringPropertyNames()) { - String value = parms.getProperty(key); - LOG.info("The SLI parameter in " + key + " is: " + value); - } - - // Call SLI sync method - try { - if (A1AdapterClient.hasGraph("A1-ADAPTER-API", svcOperation, null, "sync")) { - LOG.info("A1AdapterClient has a Directed Graph for '" + svcOperation + "'"); - try { - A1AdapterClient.execute("A1-ADAPTER-API", svcOperation, null, "sync", serviceDataBuilder, parms); - } catch (Exception e) { - LOG.error("Caught exception executing service logic for " + svcOperation, e); - serviceDataBuilder.setResponseCode("500"); - } - } else { - LOG.error("No service logic active for A1Adapter: '" + svcOperation + "'"); - serviceDataBuilder.setResponseCode("503"); - } - } catch (Exception e) { - LOG.error("Caught exception looking for service logic", e); - serviceDataBuilder.setResponseCode("500"); - } - - String errorCode = serviceDataBuilder.getResponseCode(); - - if (!("0".equals(errorCode) || "200".equals(errorCode))) { - LOG.error("Returned FAILED for " + svcOperation + " error code: '" + errorCode + "'"); - } else { - LOG.info("Returned SUCCESS for " + svcOperation + " "); - serviceDataBuilder.setResponseMessage("A1 Adapter Executed for DeletePolicyInstance. "); - } - - RpcResult rpcResult = RpcResultBuilder.status(true) - .withResult(serviceDataBuilder.build()).build(); - - LOG.info("Successful exit from deletePolicyInstance "); - - return Futures.immediateFuture(rpcResult); + public ListenableFuture> getA1PolicyStatus(GetA1PolicyStatusInput input) { + // TODO Auto-generated method stub + return null; } - - - // RPC getStatus - @Override - public ListenableFuture> getStatus(GetStatusInput input) { - final String svcOperation = "getStatus"; - - Properties parms = new Properties(); - GetStatusOutputBuilder serviceDataBuilder = (GetStatusOutputBuilder) getServiceData(GET_STATUS); - - LOG.info("Reached RPC getStatus"); - - LOG.info(svcOperation + " called."); - - if (input == null) { - LOG.debug("exiting " + svcOperation + " because of invalid input"); - serviceDataBuilder.setResponseCode("Input is null"); - RpcResult rpcResult = - RpcResultBuilder.status(true).withResult(serviceDataBuilder.build()).build(); - return Futures.immediateFuture(rpcResult); - } - - // add input to parms - LOG.info("Adding INPUT data for " + svcOperation + " input: " + input); - GetStatusInputBuilder inputBuilder = new GetStatusInputBuilder(input); - MdsalHelper.toProperties(parms, inputBuilder.build()); - - LOG.info("Printing SLI parameters to be passed"); - - // iterate properties file to get key-value pairs - for (String key : parms.stringPropertyNames()) { - String value = parms.getProperty(key); - LOG.info("The SLI parameter in " + key + " is: " + value); - } - - // Call SLI sync method - try { - if (A1AdapterClient.hasGraph("A1-ADAPTER-API", svcOperation, null, "sync")) { - LOG.info("A1AdapterClient has a Directed Graph for '" + svcOperation + "'"); - try { - A1AdapterClient.execute("A1-ADAPTER-API", svcOperation, null, "sync", serviceDataBuilder, parms); - } catch (Exception e) { - LOG.error("Caught exception executing service logic for " + svcOperation, e); - serviceDataBuilder.setResponseCode("500"); - } - } else { - LOG.error("No service logic active for A1Adapter: '" + svcOperation + "'"); - serviceDataBuilder.setResponseCode("503"); - } - } catch (Exception e) { - LOG.error("Caught exception looking for service logic", e); - serviceDataBuilder.setResponseCode("500"); - } - - String errorCode = serviceDataBuilder.getResponseCode(); - - if (!("0".equals(errorCode) || "200".equals(errorCode))) { - LOG.error("Returned FAILED for " + svcOperation + " error code: '" + errorCode + "'"); - } else { - LOG.info("Returned SUCCESS for " + svcOperation + " "); - serviceDataBuilder.setResponseMessage("A1 Adapter Executed for GetStatus. "); - } - - RpcResult rpcResult = - RpcResultBuilder.status(true).withResult(serviceDataBuilder.build()).build(); - - LOG.info("Successful exit from getStatus "); - - return Futures.immediateFuture(rpcResult); + public ListenableFuture> getA1PolicyType(GetA1PolicyTypeInput input) { + // TODO Auto-generated method stub + return null; } - - // RPC notifyPolicyEnforcementUpdate - @Override - public ListenableFuture> notifyPolicyEnforcementUpdate( - NotifyPolicyEnforcementUpdateInput input) { - final String svcOperation = "notifyPolicyEnforcementUpdate"; - - Properties parms = new Properties(); - NotifyPolicyEnforcementUpdateOutputBuilder serviceDataBuilder = - (NotifyPolicyEnforcementUpdateOutputBuilder) getServiceData(NOTIFICATION_ENFORECEMENT); - - LOG.info("Reached RPC notifyPolicyEnforcementUpdate"); - - LOG.info(svcOperation + " called."); - - if (input == null) { - LOG.debug("exiting " + svcOperation + " because of invalid input"); - serviceDataBuilder.setResponseCode("Input is null"); - RpcResult rpcResult = RpcResultBuilder - .status(true).withResult(serviceDataBuilder.build()).build(); - return Futures.immediateFuture(rpcResult); - } - - // add input to parms - LOG.info("Adding INPUT data for " + svcOperation + " input: " + input); - NotifyPolicyEnforcementUpdateInputBuilder inputBuilder = new NotifyPolicyEnforcementUpdateInputBuilder(input); - MdsalHelper.toProperties(parms, inputBuilder.build()); - - LOG.info("Printing SLI parameters to be passed"); - - // iterate properties file to get key-value pairs - for (String key : parms.stringPropertyNames()) { - String value = parms.getProperty(key); - LOG.info("The SLI parameter in " + key + " is: " + value); - } - - // Call SLI sync method - try { - if (A1AdapterClient.hasGraph("A1-ADAPTER-API", svcOperation, null, "sync")) { - LOG.info("A1AdapterClient has a Directed Graph for '" + svcOperation + "'"); - try { - A1AdapterClient.execute("A1-ADAPTER-API", svcOperation, null, "sync", serviceDataBuilder, parms); - } catch (Exception e) { - LOG.error("Caught exception executing service logic for " + svcOperation, e); - serviceDataBuilder.setResponseCode("500"); - } - } else { - LOG.error("No service logic active for A1Adapter: '" + svcOperation + "'"); - serviceDataBuilder.setResponseCode("503"); - } - } catch (Exception e) { - LOG.error("Caught exception looking for service logic", e); - serviceDataBuilder.setResponseCode("500"); - } - - String errorCode = serviceDataBuilder.getResponseCode(); - - if (!("0".equals(errorCode) || "200".equals(errorCode))) { - LOG.error("Returned FAILED for " + svcOperation + " error code: '" + errorCode + "'"); - } else { - LOG.info("Returned SUCCESS for " + svcOperation + " "); - serviceDataBuilder.setResponseMessage("A1 Adapter Executed for notifyPolicyEnforcementUpdate. "); - } - - RpcResult rpcResult = RpcResultBuilder - .status(true).withResult(serviceDataBuilder.build()).build(); - - LOG.info("Successful exit from notifyPolicyEnforcementUpdate "); - - return Futures.immediateFuture(rpcResult); - } - - protected Builder getServiceData(String svcOperation) { - switch (svcOperation) { - case GET_NEARRT_RICS: - return new GetNearRTRICsOutputBuilder(); - case GET_HEALTH_CHECK: - return new GetHealthCheckOutputBuilder(); - case GET_POLICY_TYPES: - return new GetPolicyTypesOutputBuilder(); - case CREATE_POLICY_TYPE: - return new CreatePolicyTypeOutputBuilder(); - case GET_POLICY_TYPE: - return new GetPolicyTypeOutputBuilder(); - case DELETE_POLICY_TYPE: - return new DeletePolicyTypeOutputBuilder(); - case GET_POLICY_INSTANCES: - return new GetPolicyInstancesOutputBuilder(); - case CREATE_POLICY_INSTANCES: - return new CreatePolicyInstanceOutputBuilder(); - case GET_POLICY_INSTANCE: - return new GetPolicyInstanceOutputBuilder(); - case DELETE_POLICY_INSTANCE: - return new DeletePolicyInstanceOutputBuilder(); - case GET_STATUS: - return new GetStatusOutputBuilder(); - case NOTIFICATION_ENFORECEMENT: - return new NotifyPolicyEnforcementUpdateOutputBuilder(); - } + public ListenableFuture> putA1Policy(PutA1PolicyInput input) { + // TODO Auto-generated method stub return null; } -} + +} \ No newline at end of file -- cgit 1.2.3-korg