Entails renaming VFCxxx classes and updated drl files, as well.
Change-Id: Ib31c61a35536df22772de6090761b22beb1b561b
Issue-ID: POLICY-1145
Signed-off-by: Jim Hahn <jrh3@att.com>
/*-
* ============LICENSE_START=======================================================
* Copyright (C) 2017-2018 Intel Corp. All rights reserved.
- * Modifications Copyright (C) 2018 AT&T Intellectual Property. All rights reserved.
+ * Modifications Copyright (C) 2018-2019 AT&T Intellectual Property. All rights reserved.
* ================================================================================
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
import org.onap.policy.controlloop.policy.Policy;
import org.onap.policy.drools.system.PolicyEngine;
import org.onap.policy.rest.RESTManager;
-import org.onap.policy.vfc.VFCHealActionVmInfo;
-import org.onap.policy.vfc.VFCHealAdditionalParams;
-import org.onap.policy.vfc.VFCHealRequest;
-import org.onap.policy.vfc.VFCRequest;
+import org.onap.policy.vfc.VfcHealActionVmInfo;
+import org.onap.policy.vfc.VfcHealAdditionalParams;
+import org.onap.policy.vfc.VfcHealRequest;
+import org.onap.policy.vfc.VfcRequest;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
* @param vnfResponse the VNF response
* @return the constructed request
*/
- public static VFCRequest constructRequest(VirtualControlLoopEvent onset, ControlLoopOperation operation,
+ public static VfcRequest constructRequest(VirtualControlLoopEvent onset, ControlLoopOperation operation,
Policy policy, AaiGetVnfResponse vnfResponse) {
// Construct an VFC request
- VFCRequest request = new VFCRequest();
+ VfcRequest request = new VfcRequest();
String serviceInstance = onset.getAai().get("service-instance.service-instance-id");
if (serviceInstance == null || "".equals(serviceInstance)) {
AaiGetVnfResponse tempVnfResp = vnfResponse;
}
serviceInstance = tempVnfResp.getServiceId();
}
- request.setNSInstanceId(serviceInstance);
+ request.setNsInstanceId(serviceInstance);
request.setRequestId(onset.getRequestId());
- request.setHealRequest(new VFCHealRequest());
+ request.setHealRequest(new VfcHealRequest());
request.getHealRequest().setVnfInstanceId(onset.getAai().get("generic-vnf.vnf-id"));
request.getHealRequest().setCause(operation.getMessage());
- request.getHealRequest().setAdditionalParams(new VFCHealAdditionalParams());
+ request.getHealRequest().setAdditionalParams(new VfcHealAdditionalParams());
if (policy.getRecipe().toLowerCase().equalsIgnoreCase(RECIPE_RESTART)) {
request.getHealRequest().getAdditionalParams().setAction("restartvm");
- request.getHealRequest().getAdditionalParams().setActionInfo(new VFCHealActionVmInfo());
+ request.getHealRequest().getAdditionalParams().setActionInfo(new VfcHealActionVmInfo());
request.getHealRequest().getAdditionalParams().getActionInfo()
.setVmid(onset.getAai().get("vserver.vserver-id"));
request.getHealRequest().getAdditionalParams().getActionInfo()
/*-
* ============LICENSE_START=======================================================
- * TestVFCActorServiceProvider
+ * ONAP - Policy Drools Applications
* ================================================================================
* Copyright (C) 2018 Ericsson. All rights reserved.
- * Modifications Copyright (C) 2018 AT&T Corp. All rights reserved.
+ * Modifications Copyright (C) 2018-2019 AT&T Corp. All rights reserved.
* ================================================================================
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
import org.onap.policy.controlloop.policy.Policy;
import org.onap.policy.drools.system.PolicyEngine;
import org.onap.policy.simulators.Util;
-import org.onap.policy.vfc.VFCRequest;
+import org.onap.policy.vfc.VfcRequest;
public class VfcActorServiceProviderTest {
policy.setRecipe("Restart");
assertNotNull(VfcActorServiceProvider.constructRequest(onset, operation, policy, new AaiGetVnfResponse()));
- VFCRequest request =
+ VfcRequest request =
VfcActorServiceProvider.constructRequest(onset, operation, policy, new AaiGetVnfResponse());
assertEquals(requestId, Objects.requireNonNull(request).getRequestId());
* ============LICENSE_START=======================================================
* controlloop operation manager
* ================================================================================
- * Copyright (C) 2017-2018 AT&T Intellectual Property. All rights reserved.
+ * Copyright (C) 2017-2019 AT&T Intellectual Property. All rights reserved.
* ================================================================================
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
import org.onap.policy.sdnc.SdncResponse;
import org.onap.policy.sdnr.PciResponseWrapper;
import org.onap.policy.so.SOResponseWrapper;
-import org.onap.policy.vfc.VFCResponse;
+import org.onap.policy.vfc.VfcResponse;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
// Cast SO response and handle it
//
return onResponse((SOResponseWrapper) response);
- } else if (response instanceof VFCResponse) {
+ } else if (response instanceof VfcResponse) {
//
// Cast VFC response and handle it
//
- return onResponse((VFCResponse) response);
+ return onResponse((VfcResponse) response);
} else if (response instanceof SdncResponse) {
//
// Cast SDNC response and handle it
* @param vfcResponse the VFC response
* @return The result of the response handling
*/
- private PolicyResult onResponse(VFCResponse vfcResponse) {
+ private PolicyResult onResponse(VfcResponse vfcResponse) {
if ("finished".equalsIgnoreCase(vfcResponse.getResponseDescriptor().getStatus())) {
//
// Consider it as success
* ============LICENSE_START=======================================================
* unit test
* ================================================================================
- * Copyright (C) 2017-2018 AT&T Intellectual Property. All rights reserved.
+ * Copyright (C) 2017-2019 AT&T Intellectual Property. All rights reserved.
* ================================================================================
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
import org.onap.policy.drools.system.PolicyEngine;
import org.onap.policy.so.SOResponse;
import org.onap.policy.so.SOResponseWrapper;
-import org.onap.policy.vfc.VFCResponse;
-import org.onap.policy.vfc.VFCResponseDescriptor;
+import org.onap.policy.vfc.VfcResponse;
+import org.onap.policy.vfc.VfcResponseDescriptor;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
soResponse.setHttpResponseCode(500);
assertEquals(PolicyResult.FAILURE, clom.onResponse(soRw));
- VFCResponse vfcResponse = new VFCResponse();
- VFCResponseDescriptor responseDescriptor = new VFCResponseDescriptor();
+ VfcResponse vfcResponse = new VfcResponse();
+ VfcResponseDescriptor responseDescriptor = new VfcResponseDescriptor();
vfcResponse.setResponseDescriptor(responseDescriptor);
responseDescriptor.setStatus("finished");
+++ /dev/null
-<?xml version="1.0"?>
-<!--
- ============LICENSE_START=======================================================
- Copyright (C) 2018 AT&T Technologies. All rights reserved.
- ================================================================================
- 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.
-
- SPDX-License-Identifier: Apache-2.0
- ============LICENSE_END=========================================================
--->
-
-<!DOCTYPE suppressions PUBLIC
- "-//Puppy Crawl//DTD Suppressions 1.0//EN"
- "http://www.puppycrawl.com/dtds/suppressions_1_0.dtd">
-
-<suppressions>
- <suppress checks="AbbreviationAsWordInName"
- files="VFCManager.java|VFCHealActionVmInfo.java|VFCHealAdditionalParams.java|VFCHealRequest.java|VFCRequest.java|VFCResponseDescriptor.java|VFCResponse.java"
- lines="1-9999"/>
-</suppressions>
<includeTestResources>true</includeTestResources>
<excludes>
</excludes>
- <suppressionsLocation>${project.basedir}/checkstyle-suppressions.xml</suppressionsLocation>
<consoleOutput>true</consoleOutput>
<failsOnViolation>true</failsOnViolation>
<violationSeverity>warning</violationSeverity>
/*-
* ============LICENSE_START=======================================================
* Copyright (C) 2017 Intel Corp. All rights reserved.
- * Modifications Copyright (C) 2018 AT&T Corporation. All rights reserved.
+ * Modifications Copyright (C) 2018-2019 AT&T Corporation. All rights reserved.
* ================================================================================
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
import java.io.Serializable;
-public class VFCHealActionVmInfo implements Serializable {
+public class VfcHealActionVmInfo implements Serializable {
private static final long serialVersionUID = 3208673205100673119L;
@SerializedName("vmname")
private String vmname;
- public VFCHealActionVmInfo() {
- // Default constructor for VFCHealActionVmInfo
+ public VfcHealActionVmInfo() {
+ // Default constructor
}
public String getVmid() {
/*-
* ============LICENSE_START=======================================================
* Copyright (C) 2017 Intel Corp. All rights reserved.
- * Modifications Copyright (C) 2018 AT&T Corporation. All rights reserved.
+ * Modifications Copyright (C) 2018-2019 AT&T Corporation. All rights reserved.
* ================================================================================
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
import java.io.Serializable;
-public class VFCHealAdditionalParams implements Serializable {
+public class VfcHealAdditionalParams implements Serializable {
private static final long serialVersionUID = 2656694137285096191L;
private String action;
@SerializedName("actionvminfo")
- private VFCHealActionVmInfo actionInfo;
+ private VfcHealActionVmInfo actionInfo;
- public VFCHealAdditionalParams() {
- // Default constructor for VFCHealAdditionalParams
+ public VfcHealAdditionalParams() {
+ // Default constructor
}
public String getAction() {
this.action = action;
}
- public VFCHealActionVmInfo getActionInfo() {
+ public VfcHealActionVmInfo getActionInfo() {
return actionInfo;
}
- public void setActionInfo(VFCHealActionVmInfo actionInfo) {
+ public void setActionInfo(VfcHealActionVmInfo actionInfo) {
this.actionInfo = actionInfo;
}
}
/*-
* ============LICENSE_START=======================================================
* Copyright (C) 2017 Intel Corp. All rights reserved.
- * Modifications Copyright (C) 2018 AT&T Corporation. All rights reserved.
+ * Modifications Copyright (C) 2018-2019 AT&T Corporation. All rights reserved.
* ================================================================================
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
import java.io.Serializable;
-public class VFCHealRequest implements Serializable {
+public class VfcHealRequest implements Serializable {
private static final long serialVersionUID = -7341931593089709247L;
private String cause;
@SerializedName("additionalParams")
- private VFCHealAdditionalParams additionalParams;
+ private VfcHealAdditionalParams additionalParams;
- public VFCHealRequest() {
- // Default constructor for VFCHealRequest
+ public VfcHealRequest() {
+ // Default constructor
}
public String getVnfInstanceId() {
this.cause = cause;
}
- public VFCHealAdditionalParams getAdditionalParams() {
+ public VfcHealAdditionalParams getAdditionalParams() {
return additionalParams;
}
- public void setAdditionalParams(VFCHealAdditionalParams additionalParams) {
+ public void setAdditionalParams(VfcHealAdditionalParams additionalParams) {
this.additionalParams = additionalParams;
}
}
/*-
* ============LICENSE_START=======================================================
* Copyright (C) 2017-2018 Intel Corp, AT&T. All rights reserved.
- * Modifications Copyright (C) 2018 AT&T Corporation. All rights reserved.
+ * Modifications Copyright (C) 2018-2019 AT&T Corporation. All rights reserved.
* ================================================================================
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
-public final class VFCManager implements Runnable {
+public final class VfcManager implements Runnable {
private static final String SYSTEM_LS = System.lineSeparator();
private String vfcUrlBase;
private String username;
private String password;
- private VFCRequest vfcRequest;
+ private VfcRequest vfcRequest;
private WorkingMemory workingMem;
- private static final Logger logger = LoggerFactory.getLogger(VFCManager.class);
+ private static final Logger logger = LoggerFactory.getLogger(VfcManager.class);
private static final Logger netLogger =
LoggerFactory.getLogger(org.onap.policy.common.endpoints.event.comm.Topic.NETWORK_LOGGER);
* @param wm Drools working memory
* @param request request
*/
- public VFCManager(WorkingMemory wm, VFCRequest request) {
+ public VfcManager(WorkingMemory wm, VfcRequest request) {
if (wm == null || request == null) {
throw new IllegalArgumentException(
- "the parameters \"wm\" and \"request\" on the VFCManager constructor may not be null");
+ "the parameters \"wm\" and \"request\" on the VfcManager constructor may not be null");
}
workingMem = wm;
vfcRequest = request;
restManager = new RESTManager();
// use getPEManagerEnvProperty() for required properties; others are optional
- setVFCParams(getPEManagerEnvProperty("vfc.url"), PolicyEngine.manager.getEnvironmentProperty("vfc.username"),
+ setVfcParams(getPeManagerEnvProperty("vfc.url"), PolicyEngine.manager.getEnvironmentProperty("vfc.username"),
PolicyEngine.manager.getEnvironmentProperty("vfc.password"));
}
* @param name username
* @param pwd password
*/
- public void setVFCParams(String baseUrl, String name, String pwd) {
+ public void setVfcParams(String baseUrl, String name, String pwd) {
vfcUrlBase = baseUrl + "/api/nslcm/v1";
username = name;
password = pwd;
Map<String, String> headers = new HashMap<>();
Pair<Integer, String> httpDetails;
- VFCResponse responseError = new VFCResponse();
- responseError.setResponseDescriptor(new VFCResponseDescriptor());
+ VfcResponse responseError = new VfcResponse();
+ responseError.setResponseDescriptor(new VfcResponseDescriptor());
responseError.getResponseDescriptor().setStatus("error");
headers.put("Accept", "application/json");
- String vfcUrl = vfcUrlBase + "/ns/" + vfcRequest.getNSInstanceId() + "/heal";
+ String vfcUrl = vfcUrlBase + "/ns/" + vfcRequest.getNsInstanceId() + "/heal";
try {
String vfcRequestJson = Serialization.gsonPretty.toJson(vfcRequest);
netLogger.info("[OUT|{}|{}|]{}{}", "VFC", vfcUrl, SYSTEM_LS, vfcRequestJson);
}
try {
- VFCResponse response = Serialization.gsonPretty.fromJson(httpDetails.second, VFCResponse.class);
+ VfcResponse response = Serialization.gsonPretty.fromJson(httpDetails.second, VfcResponse.class);
netLogger.info("[IN|{}|{}|]{}{}", "VFC", vfcUrl, SYSTEM_LS, httpDetails.second);
String body = Serialization.gsonPretty.toJson(response);
logger.debug("Response to VFC Heal post:");
int attemptsLeft = 20;
String urlGet = vfcUrlBase + "/jobs/" + jobId;
- VFCResponse responseGet = null;
+ VfcResponse responseGet = null;
while (attemptsLeft-- > 0) {
netLogger.info("[OUT|{}|{}|]", "VFC", urlGet);
Pair<Integer, String> httpDetailsGet = restManager.get(urlGet, username, password, headers);
- responseGet = Serialization.gsonPretty.fromJson(httpDetailsGet.second, VFCResponse.class);
+ responseGet = Serialization.gsonPretty.fromJson(httpDetailsGet.second, VfcResponse.class);
netLogger.info("[IN|{}|{}|]{}{}", "VFC", urlGet, SYSTEM_LS, httpDetailsGet.second);
responseGet.setRequestId(vfcRequest.getRequestId().toString());
body = Serialization.gsonPretty.toJson(responseGet);
workingMem.insert(responseGet);
}
} catch (JsonSyntaxException e) {
- logger.error("Failed to deserialize into VFCResponse {}", e.getLocalizedMessage(), e);
+ logger.error("Failed to deserialize into VfcResponse {}", e.getLocalizedMessage(), e);
} catch (InterruptedException e) {
logger.error("Interrupted exception: {}", e.getLocalizedMessage(), e);
Thread.currentThread().interrupt();
} catch (Exception e) {
- logger.error("Unknown error deserializing into VFCResponse {}", e.getLocalizedMessage(), e);
+ logger.error("Unknown error deserializing into VfcResponse {}", e.getLocalizedMessage(), e);
}
}
* @return the property value
*/
- private String getPEManagerEnvProperty(String enginePropertyName) {
+ private String getPeManagerEnvProperty(String enginePropertyName) {
String enginePropertyValue = PolicyEngine.manager.getEnvironmentProperty(enginePropertyName);
if (enginePropertyValue == null) {
throw new IllegalArgumentException("The value of policy engine manager environment property \""
/*-
* ============LICENSE_START=======================================================
* Copyright (C) 2017 Intel Corp. All rights reserved.
- * Modifications Copyright (C) 2018 AT&T Corporation. All rights reserved.
+ * Modifications Copyright (C) 2018-2019 AT&T Corporation. All rights reserved.
* ================================================================================
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
import java.io.Serializable;
import java.util.UUID;
-public class VFCRequest implements Serializable {
+public class VfcRequest implements Serializable {
private static final long serialVersionUID = 3736300970326332512L;
// These fields are not serialized and not part of JSON
private transient UUID requestId;
@SerializedName("healVnfData")
- private VFCHealRequest healRequest;
+ private VfcHealRequest healRequest;
- public VFCRequest() {
- // Default constructor for VFCRequest
+ public VfcRequest() {
+ // Default constructor
}
- public String getNSInstanceId() {
+ public String getNsInstanceId() {
return nsInstanceId;
}
- public void setNSInstanceId(String nsInstanceId) {
+ public void setNsInstanceId(String nsInstanceId) {
this.nsInstanceId = nsInstanceId;
}
this.requestId = requestId;
}
- public VFCHealRequest getHealRequest() {
+ public VfcHealRequest getHealRequest() {
return healRequest;
}
- public void setHealRequest(VFCHealRequest healRequest) {
+ public void setHealRequest(VfcHealRequest healRequest) {
this.healRequest = healRequest;
}
}
/*-
* ============LICENSE_START=======================================================
* Copyright (C) 2017 Intel Corp. All rights reserved.
- * Modifications Copyright (C) 2018 AT&T Corporation. All rights reserved.
+ * Modifications Copyright (C) 2018-2019 AT&T Corporation. All rights reserved.
* ================================================================================
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
import java.io.Serializable;
-public class VFCResponse implements Serializable {
+public class VfcResponse implements Serializable {
private static final long serialVersionUID = 9151443891238218455L;
private String jobId;
@SerializedName("responseDescriptor")
- private VFCResponseDescriptor responseDescriptor;
+ private VfcResponseDescriptor responseDescriptor;
private transient String requestId;
- public VFCResponse() {
- // Default constructor for VFCResponse
+ public VfcResponse() {
+ // Default constructor
}
public String getJobId() {
this.jobId = jobId;
}
- public VFCResponseDescriptor getResponseDescriptor() {
+ public VfcResponseDescriptor getResponseDescriptor() {
return responseDescriptor;
}
- public void setResponseDescriptor(VFCResponseDescriptor responseDescriptor) {
+ public void setResponseDescriptor(VfcResponseDescriptor responseDescriptor) {
this.responseDescriptor = responseDescriptor;
}
/*-
* ============LICENSE_START=======================================================
* Copyright (C) 2017 Intel Corp. All rights reserved.
- * Modifications Copyright (C) 2018 AT&T Corporation. All rights reserved.
+ * Modifications Copyright (C) 2018-2019 AT&T Corporation. All rights reserved.
* ================================================================================
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
import java.io.Serializable;
import java.util.List;
-public class VFCResponseDescriptor implements Serializable {
+public class VfcResponseDescriptor implements Serializable {
private static final long serialVersionUID = 6827782899144150158L;
private String responseId;
@SerializedName("responseHistoryList")
- private List<VFCResponseDescriptor> responseHistoryList;
+ private List<VfcResponseDescriptor> responseHistoryList;
- public VFCResponseDescriptor() {
- // Default constructor for VFCResponseDescriptor
+ public VfcResponseDescriptor() {
+ // Default constructor
}
public String getStatus() {
this.responseId = responseId;
}
- public List<VFCResponseDescriptor> getResponseHistoryList() {
+ public List<VfcResponseDescriptor> getResponseHistoryList() {
return responseHistoryList;
}
- public void setResponseHistoryList(List<VFCResponseDescriptor> responseHistoryList) {
+ public void setResponseHistoryList(List<VfcResponseDescriptor> responseHistoryList) {
this.responseHistoryList = responseHistoryList;
}
/*-
* ============LICENSE_START=======================================================
* Copyright (C) 2017 Intel Corp. All rights reserved.
- * Modifications Copyright (C) 2018 AT&T Corporation. All rights reserved.
+ * Modifications Copyright (C) 2018-2019 AT&T Corporation. All rights reserved.
* ================================================================================
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
@Test
public void test() {
- VFCRequest request = new VFCRequest();
+ VfcRequest request = new VfcRequest();
- request.setNSInstanceId("100");
- request.setHealRequest(new VFCHealRequest());
+ request.setNsInstanceId("100");
+ request.setHealRequest(new VfcHealRequest());
request.getHealRequest().setVnfInstanceId("1");
request.getHealRequest().setCause("vm is down");
- request.getHealRequest().setAdditionalParams(new VFCHealAdditionalParams());
+ request.getHealRequest().setAdditionalParams(new VfcHealAdditionalParams());
request.getHealRequest().getAdditionalParams().setAction("restartvm");
- request.getHealRequest().getAdditionalParams().setActionInfo(new VFCHealActionVmInfo());
+ request.getHealRequest().getAdditionalParams().setActionInfo(new VfcHealActionVmInfo());
request.getHealRequest().getAdditionalParams().getActionInfo().setVmid("33");
request.getHealRequest().getAdditionalParams().getActionInfo().setVmname("xgw-smp11");
String body = Serialization.gsonPretty.toJson(request);
System.out.println(body);
- VFCResponse response = new VFCResponse();
+ VfcResponse response = new VfcResponse();
response.setJobId("1");
body = Serialization.gsonPretty.toJson(response);
System.out.println(body);
- response.setResponseDescriptor(new VFCResponseDescriptor());
+ response.setResponseDescriptor(new VfcResponseDescriptor());
response.getResponseDescriptor().setProgress("40");
response.getResponseDescriptor().setStatus("processing");
response.getResponseDescriptor().setStatusDescription("OMC VMs are decommissioned in VIM");
body = Serialization.gsonPretty.toJson(response);
System.out.println(body);
- VFCResponseDescriptor responseDescriptor = new VFCResponseDescriptor();
+ VfcResponseDescriptor responseDescriptor = new VfcResponseDescriptor();
responseDescriptor.setProgress("20");
responseDescriptor.setStatus("processing");
responseDescriptor.setStatusDescription("OMC VMs are decommissioned in VIM");
body = Serialization.gsonPretty.toJson(response);
System.out.println(body);
- response = Serialization.gsonPretty.fromJson(body, VFCResponse.class);
+ response = Serialization.gsonPretty.fromJson(body, VfcResponse.class);
body = Serialization.gsonPretty.toJson(response);
System.out.println(body);
* vfc
* ================================================================================
* Copyright (C) 2018 Ericsson. All rights reserved.
- * Modifications Copyright (C) 2018 AT&T Corporation. All rights reserved.
+ * Modifications Copyright (C) 2018-2019 AT&T Corporation. All rights reserved.
* ================================================================================
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
@Test
public void testVfcHealActionVmInfo() {
- VFCHealActionVmInfo actionInfo = new VFCHealActionVmInfo();
+ VfcHealActionVmInfo actionInfo = new VfcHealActionVmInfo();
assertNotNull(actionInfo);
assertNotEquals(0, actionInfo.hashCode());
* vfc
* ================================================================================
* Copyright (C) 2018 Ericsson. All rights reserved.
- * Modifications Copyright (C) 2018 AT&T Corporation. All rights reserved.
+ * Modifications Copyright (C) 2018-2019 AT&T Corporation. All rights reserved.
* ================================================================================
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
@Test
public void testVfcHealAdditionalParameters() {
- VFCHealAdditionalParams additionalParams = new VFCHealAdditionalParams();
+ VfcHealAdditionalParams additionalParams = new VfcHealAdditionalParams();
assertNotNull(additionalParams);
assertNotEquals(0, additionalParams.hashCode());
additionalParams.setAction(action);
assertEquals(action, additionalParams.getAction());
- VFCHealActionVmInfo actionInfo = new VFCHealActionVmInfo();
+ VfcHealActionVmInfo actionInfo = new VfcHealActionVmInfo();
additionalParams.setActionInfo(actionInfo );
assertEquals(actionInfo, additionalParams.getActionInfo());
* vfc
* ================================================================================
* Copyright (C) 2018 Ericsson. All rights reserved.
- * Modifications Copyright (C) 2018 AT&T Corporation. All rights reserved.
+ * Modifications Copyright (C) 2018-2019 AT&T Corporation. All rights reserved.
* ================================================================================
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
@Test
public void testVfcHealRequest() {
- VFCHealRequest request = new VFCHealRequest();
+ VfcHealRequest request = new VfcHealRequest();
assertNotNull(request);
assertNotEquals(0, request.hashCode());
request.setCause(cause);
assertEquals(cause, request.getCause());
- VFCHealAdditionalParams additionalParams = new VFCHealAdditionalParams();
+ VfcHealAdditionalParams additionalParams = new VfcHealAdditionalParams();
request.setAdditionalParams(additionalParams);
assertEquals(additionalParams, request.getAdditionalParams());
* vfc
* ================================================================================
* Copyright (C) 2018 Ericsson, AT&T. All rights reserved.
- * Modifications Copyright (C) 2018 AT&T Corporation. All rights reserved.
+ * Modifications Copyright (C) 2018-2019 AT&T Corporation. All rights reserved.
* ================================================================================
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
private Pair<Integer, String> httpResponseBadResponse;
private Pair<Integer, String> httpResponseErr;
- private VFCRequest request;
- private VFCResponse response;
+ private VfcRequest request;
+ private VfcResponse response;
@BeforeClass
public static void beforeTestVfcManager() {
*/
@Before
public void createRequestAndResponse() {
- VFCHealActionVmInfo actionInfo = new VFCHealActionVmInfo();
+ VfcHealActionVmInfo actionInfo = new VfcHealActionVmInfo();
actionInfo.setVmid("TheWizard");
actionInfo.setVmname("The Wizard of Oz");
- VFCHealAdditionalParams additionalParams = new VFCHealAdditionalParams();
+ VfcHealAdditionalParams additionalParams = new VfcHealAdditionalParams();
additionalParams.setAction("Go Home");
additionalParams.setActionInfo(actionInfo);
- VFCHealRequest healRequest = new VFCHealRequest();
+ VfcHealRequest healRequest = new VfcHealRequest();
healRequest.setAdditionalParams(additionalParams);
healRequest.setCause("WestWitch");
healRequest.setVnfInstanceId("EmeraldCity");
final UUID requestId = UUID.randomUUID();
- request = new VFCRequest();
+ request = new VfcRequest();
request.setHealRequest(healRequest);
- request.setNSInstanceId("Dorothy");
+ request.setNsInstanceId("Dorothy");
request.setRequestId(requestId);
- List<VFCResponseDescriptor> responseHistoryList = new ArrayList<>();;
+ List<VfcResponseDescriptor> responseHistoryList = new ArrayList<>();;
- VFCResponseDescriptor responseDescriptor = new VFCResponseDescriptor();
+ VfcResponseDescriptor responseDescriptor = new VfcResponseDescriptor();
responseDescriptor.setErrorCode("1234");
responseDescriptor.setProgress("Follow The Yellow Brick Road");
responseDescriptor.setResponseHistoryList(responseHistoryList);
responseDescriptor.setStatus("finished");
responseDescriptor.setStatusDescription("There's no place like home");
- response = new VFCResponse();
+ response = new VfcResponse();
response.setJobId("1234");
response.setRequestId(request.getRequestId().toString());
response.setResponseDescriptor(responseDescriptor);
@Test
public void testVfcInitiation() {
try {
- new VFCManager(null, null);
+ new VfcManager(null, null);
fail("test should throw an exception here");
}
catch (IllegalArgumentException e) {
- assertEquals("the parameters \"wm\" and \"request\" on the VFCManager constructor may not be null",
+ assertEquals("the parameters \"wm\" and \"request\" on the VfcManager constructor may not be null",
e.getMessage());
}
try {
- new VFCManager(mockedWorkingMemory, null);
+ new VfcManager(mockedWorkingMemory, null);
fail("test should throw an exception here");
}
catch (IllegalArgumentException e) {
- assertEquals("the parameters \"wm\" and \"request\" on the VFCManager constructor may not be null",
+ assertEquals("the parameters \"wm\" and \"request\" on the VfcManager constructor may not be null",
e.getMessage());
}
try {
- new VFCManager(mockedWorkingMemory, request);
+ new VfcManager(mockedWorkingMemory, request);
fail("test should throw an exception here");
}
catch (IllegalArgumentException e) {
// add url; username & password are not required
PolicyEngine.manager.getEnvironment().put("vfc.url", "http://somewhere.over.the.rainbow");
- new VFCManager(mockedWorkingMemory, request);
+ new VfcManager(mockedWorkingMemory, request);
// url & username, but no password
PolicyEngine.manager.getEnvironment().put("vfc.username", "Dorothy");
// url, username, and password
PolicyEngine.manager.getEnvironment().put("vfc.password", "Toto");
- new VFCManager(mockedWorkingMemory, request);
+ new VfcManager(mockedWorkingMemory, request);
}
@Test
PolicyEngine.manager.getEnvironment().put("vfc.username", "Dorothy");
PolicyEngine.manager.getEnvironment().put("vfc.password", "Exception");
- VFCManager manager = new VFCManager(mockedWorkingMemory, request);
+ VfcManager manager = new VfcManager(mockedWorkingMemory, request);
manager.setRestManager(mockedRestManager);
Thread managerThread = new Thread(manager);
PolicyEngine.manager.getEnvironment().put("vfc.username", "Dorothy");
PolicyEngine.manager.getEnvironment().put("vfc.password", "Null");
- VFCManager manager = new VFCManager(mockedWorkingMemory, request);
+ VfcManager manager = new VfcManager(mockedWorkingMemory, request);
manager.setRestManager(mockedRestManager);
Thread managerThread = new Thread(manager);
PolicyEngine.manager.getEnvironment().put("vfc.username", "Dorothy");
PolicyEngine.manager.getEnvironment().put("vfc.password", "Error0");
- VFCManager manager = new VFCManager(mockedWorkingMemory, request);
+ VfcManager manager = new VfcManager(mockedWorkingMemory, request);
manager.setRestManager(mockedRestManager);
Thread managerThread = new Thread(manager);
PolicyEngine.manager.getEnvironment().put("vfc.username", "Dorothy");
PolicyEngine.manager.getEnvironment().put("vfc.password", "BadResponse");
- VFCManager manager = new VFCManager(mockedWorkingMemory, request);
+ VfcManager manager = new VfcManager(mockedWorkingMemory, request);
manager.setRestManager(mockedRestManager);
Thread managerThread = new Thread(manager);
PolicyEngine.manager.getEnvironment().put("vfc.username", "Dorothy");
PolicyEngine.manager.getEnvironment().put("vfc.password", "OK");
- VFCManager manager = new VFCManager(mockedWorkingMemory, request);
+ VfcManager manager = new VfcManager(mockedWorkingMemory, request);
manager.setRestManager(mockedRestManager);
Thread managerThread = new Thread(manager);
* vfc
* ================================================================================
* Copyright (C) 2018 Ericsson. All rights reserved.
- * Modifications Copyright (C) 2018 AT&T Corporation. All rights reserved.
+ * Modifications Copyright (C) 2018-2019 AT&T Corporation. All rights reserved.
* ================================================================================
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
@Test
public void testVfcRequest() {
- VFCRequest request = new VFCRequest();
+ VfcRequest request = new VfcRequest();
assertNotNull(request);
assertNotEquals(0, request.hashCode());
String nsInstanceId = "Dorothy";
- request.setNSInstanceId(nsInstanceId);
- assertEquals(nsInstanceId, request.getNSInstanceId());
+ request.setNsInstanceId(nsInstanceId);
+ assertEquals(nsInstanceId, request.getNsInstanceId());
UUID requestId = UUID.randomUUID();
request.setRequestId(requestId);
assertEquals(requestId, request.getRequestId());
- VFCHealRequest healRequest = new VFCHealRequest();
+ VfcHealRequest healRequest = new VfcHealRequest();
request.setHealRequest(healRequest);
assertEquals(healRequest, request.getHealRequest());
* vfc
* ================================================================================
* Copyright (C) 2018 Ericsson. All rights reserved.
- * Modifications Copyright (C) 2018 AT&T Corporation. All rights reserved.
+ * Modifications Copyright (C) 2018-2019 AT&T Corporation. All rights reserved.
* ================================================================================
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
@Test
public void testVfcResponseDescriptor() {
- VFCResponseDescriptor descriptor = new VFCResponseDescriptor();
+ VfcResponseDescriptor descriptor = new VfcResponseDescriptor();
assertNotNull(descriptor);
assertNotEquals(0, descriptor.hashCode());
descriptor.setProgress(progress);
assertEquals(progress, descriptor.getProgress());
- List<VFCResponseDescriptor> responseHistoryList = new ArrayList<>();
+ List<VfcResponseDescriptor> responseHistoryList = new ArrayList<>();
descriptor.setResponseHistoryList(responseHistoryList);
assertEquals(responseHistoryList, descriptor.getResponseHistoryList());
* vfc
* ================================================================================
* Copyright (C) 2018 Ericsson. All rights reserved.
- * Modifications Copyright (C) 2018 AT&T Corporation. All rights reserved.
+ * Modifications Copyright (C) 2018-2019 AT&T Corporation. All rights reserved.
* ================================================================================
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
@Test
public void testVfcResponse() {
- VFCResponse response = new VFCResponse();
+ VfcResponse response = new VfcResponse();
assertNotNull(response);
assertNotEquals(0, response.hashCode());
response.setRequestId(requestId);
assertEquals(requestId, response.getRequestId());
- VFCResponseDescriptor responseDescriptor = new VFCResponseDescriptor();
+ VfcResponseDescriptor responseDescriptor = new VfcResponseDescriptor();
response.setResponseDescriptor(responseDescriptor);
assertEquals(responseDescriptor, response.getResponseDescriptor());
* ============LICENSE_START=======================================================
* simulators
* ================================================================================
- * Copyright (C) 2017-2018 AT&T Intellectual Property. All rights reserved.
+ * Copyright (C) 2017-2019 AT&T Intellectual Property. All rights reserved.
* ================================================================================
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
import org.onap.policy.drools.utils.logging.LoggerUtil;
import org.onap.policy.rest.RESTManager;
import org.onap.policy.rest.RESTManager.Pair;
-import org.onap.policy.vfc.VFCResponse;
+import org.onap.policy.vfc.VfcResponse;
import org.onap.policy.vfc.util.Serialization;
public class VfcSimulatorTest {
new HashMap<String, String>(), "application/json", "Some Request Here");
assertNotNull(httpDetails);
assertTrue(httpDetails.first == 202);
- final VFCResponse response = Serialization.gsonPretty.fromJson(httpDetails.second, VFCResponse.class);
+ final VfcResponse response = Serialization.gsonPretty.fromJson(httpDetails.second, VfcResponse.class);
assertNotNull(response);
}
final Pair<Integer, String> httpDetails = new RESTManager().get("http://localhost:6668/api/nslcm/v1/jobs/1234",
"username", "password", new HashMap<String, String>());
assertNotNull(httpDetails);
- final VFCResponse response = Serialization.gsonPretty.fromJson(httpDetails.second, VFCResponse.class);
+ final VfcResponse response = Serialization.gsonPretty.fromJson(httpDetails.second, VfcResponse.class);
assertNotNull(response);
}
}
* ============LICENSE_START=======================================================
* ONAP
* ================================================================================
- * Copyright (C) 2017-2018 AT&T Intellectual Property. All rights reserved.
+ * Copyright (C) 2017-2019 AT&T Intellectual Property. All rights reserved.
* ================================================================================
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
import org.onap.policy.sdnr.PciResponseWrapper;
import org.onap.policy.sdnr.PciRequest;
import org.onap.policy.sdnr.PciResponse;
-import org.onap.policy.vfc.VFCRequest;
-import org.onap.policy.vfc.VFCResponse;
-import org.onap.policy.vfc.VFCManager;
+import org.onap.policy.vfc.VfcRequest;
+import org.onap.policy.vfc.VfcResponse;
+import org.onap.policy.vfc.VfcManager;
import org.onap.policy.so.SOManager;
import org.onap.policy.so.SORequest;
import org.onap.policy.so.SORequestStatus;
}
break;
case "VFC":
- if (request instanceof VFCRequest) {
+ if (request instanceof VfcRequest) {
// Start VFC thread
- Thread t = new Thread(new VFCManager(drools.getWorkingMemory(), (VFCRequest)request));
+ Thread t = new Thread(new VfcManager(drools.getWorkingMemory(), (VfcRequest)request));
t.start();
}
break;
$opTimer : ControlLoopTimer( closedLoopControlName == $event.getClosedLoopControlName(),
requestID == $event.getRequestId().toString(), timerType == "Operation", !expired )
$lock : TargetLock (requestID == $event.getRequestId())
- $response : VFCResponse( requestId.toString() == $event.getRequestId().toString() )
+ $response : VfcResponse( requestId.toString() == $event.getRequestId().toString() )
then
Logger logger = LoggerFactory.getLogger(drools.getRule().getPackage());
logger.info("{}: {}", $params.getClosedLoopControlName(), drools.getRule().getName());
* ============LICENSE_START=======================================================
* ONAP
* ================================================================================
- * Copyright (C) 2018 AT&T Intellectual Property. All rights reserved.
+ * Copyright (C) 2018-2019 AT&T Intellectual Property. All rights reserved.
* ================================================================================
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
import org.onap.policy.sdnr.PciResponseWrapper;
import org.onap.policy.sdnr.PciRequest;
import org.onap.policy.sdnr.PciResponse;
-import org.onap.policy.vfc.VFCRequest;
-import org.onap.policy.vfc.VFCResponse;
-import org.onap.policy.vfc.VFCManager;
+import org.onap.policy.vfc.VfcRequest;
+import org.onap.policy.vfc.VfcResponse;
+import org.onap.policy.vfc.VfcManager;
import org.onap.policy.so.SOManager;
import org.onap.policy.so.SORequest;
import org.onap.policy.so.SORequestStatus;
}
break;
case "VFC":
- if (request instanceof VFCRequest) {
+ if (request instanceof VfcRequest) {
// Start VFC thread
- Thread t = new Thread(new VFCManager(drools.getWorkingMemory(), (VFCRequest)request));
+ Thread t = new Thread(new VfcManager(drools.getWorkingMemory(), (VfcRequest)request));
t.start();
}
break;
$opTimer : ControlLoopTimer( closedLoopControlName == $event.getClosedLoopControlName(),
requestID == $event.getRequestId().toString(), timerType == "Operation", !expired )
$lock : TargetLock (requestID == $event.getRequestId())
- $response : VFCResponse( requestId.toString() == $event.getRequestId().toString() )
+ $response : VfcResponse( requestId.toString() == $event.getRequestId().toString() )
then
Logger logger = LoggerFactory.getLogger(drools.getRule().getPackage());
logger.info("{}: {}", $clName, $params.getPolicyName() + "." + drools.getRule().getName());
* ============LICENSE_START=======================================================
* ONAP
* ================================================================================
- * Copyright (C) 2018 AT&T Intellectual Property. All rights reserved.
+ * Copyright (C) 2018-2019 AT&T Intellectual Property. All rights reserved.
* ================================================================================
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
import org.onap.policy.appclcm.LcmRequest;
import org.onap.policy.appclcm.LcmResponse;
import org.onap.policy.appclcm.LcmCommonHeader;
-import org.onap.policy.vfc.VFCRequest;
-import org.onap.policy.vfc.VFCResponse;
-import org.onap.policy.vfc.VFCManager;
+import org.onap.policy.vfc.VfcRequest;
+import org.onap.policy.vfc.VfcResponse;
+import org.onap.policy.vfc.VfcManager;
import org.onap.policy.so.SOManager;
import org.onap.policy.so.SORequest;
import org.onap.policy.so.SORequestStatus;
}
break;
case "VFC":
- if (request instanceof VFCRequest) {
+ if (request instanceof VfcRequest) {
// Start VFC thread
- Thread t = new Thread(new VFCManager(drools.getWorkingMemory(), (VFCRequest)request));
+ Thread t = new Thread(new VfcManager(drools.getWorkingMemory(), (VfcRequest)request));
t.start();
}
break;
$operation : ControlLoopOperationManager( onset.closedLoopControlName == $event.getClosedLoopControlName(), onset.getRequestId() == $event.getRequestId() )
$opTimer : OperationTimer( closedLoopControlName == $event.getClosedLoopControlName(), requestID == $event.getRequestId().toString() )
$lock : TargetLock (requestID == $event.getRequestId())
- $response : VFCResponse( requestId.toString() == $event.getRequestId().toString() )
+ $response : VfcResponse( requestId.toString() == $event.getRequestId().toString() )
then
Logger logger = LoggerFactory.getLogger(drools.getRule().getPackage());
logger.info("{}: {}", $params.getClosedLoopControlName(), drools.getRule().getName());
* demo
* ================================================================================
* Copyright (C) 2017-2018 Intel Corp. All rights reserved.
- * Modifications Copyright (C) 2018 AT&T Intellectual Property. All rights reserved.
+ * Modifications Copyright (C) 2018-2019 AT&T Intellectual Property. All rights reserved.
* ================================================================================
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
import org.onap.policy.drools.system.PolicyController;
import org.onap.policy.drools.system.PolicyEngine;
import org.onap.policy.drools.utils.logging.LoggerUtil;
-import org.onap.policy.vfc.VFCRequest;
+import org.onap.policy.vfc.VfcRequest;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
logger.debug("The control loop timed out");
fail("Control Loop Timed Out");
}
- } else if (obj instanceof VFCRequest) {
+ } else if (obj instanceof VfcRequest) {
logger.debug("\n============ VFC received the request!!! ===========\n");
}
}
Code Review / policy / drools-applications.git / commitdiff