2 * ============LICENSE_START=======================================================
4 * ================================================================================
5 * Copyright (C) 2020 AT&T Intellectual Property. All rights reserved.
6 * ================================================================================
7 * Licensed under the Apache License, Version 2.0 (the "License");
8 * you may not use this file except in compliance with the License.
9 * You may obtain a copy of the License at
11 * http://www.apache.org/licenses/LICENSE-2.0
13 * Unless required by applicable law or agreed to in writing, software
14 * distributed under the License is distributed on an "AS IS" BASIS,
15 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
16 * See the License for the specific language governing permissions and
17 * limitations under the License.
18 * ============LICENSE_END=========================================================
21 package org.onap.policy.controlloop.actor.appc;
23 import static org.assertj.core.api.Assertions.assertThatIllegalArgumentException;
24 import static org.junit.Assert.assertEquals;
25 import static org.junit.Assert.assertNotEquals;
26 import static org.junit.Assert.assertNotNull;
27 import static org.junit.Assert.assertSame;
29 import java.util.Arrays;
31 import java.util.TreeMap;
32 import org.apache.commons.lang3.tuple.Pair;
33 import org.junit.Before;
34 import org.junit.Test;
35 import org.onap.policy.appc.CommonHeader;
36 import org.onap.policy.appc.Request;
37 import org.onap.policy.appc.ResponseCode;
38 import org.onap.policy.appc.ResponseStatus;
39 import org.onap.policy.controlloop.actorserviceprovider.impl.BidirectionalTopicOperation.Status;
40 import org.onap.policy.controlloop.policy.PolicyResult;
42 public class AppcOperationTest extends BasicAppcOperation {
43 private AppcOperation oper;
49 public void setUp() throws Exception {
52 oper = new AppcOperation(params, config) {
54 protected Pair<String, Request> makeRequest(int attempt) {
55 return oper.makeRequest(attempt, MY_VNF);
61 public void testAppcOperation() {
62 assertEquals(DEFAULT_ACTOR, oper.getActorName());
63 assertEquals(DEFAULT_OPERATION, oper.getName());
67 public void testStartPreprocessorAsync() {
68 assertNotNull(oper.startPreprocessorAsync());
72 public void testMakeRequest() {
73 Pair<String, Request> result = oper.makeRequest(2, MY_VNF);
74 String subreq = result.getLeft();
75 assertNotNull(subreq);
77 Request request = result.getRight();
78 assertEquals(DEFAULT_OPERATION, request.getAction());
80 assertNotNull(request.getPayload());
82 CommonHeader header = request.getCommonHeader();
83 assertNotNull(header);
84 assertEquals(params.getRequestId(), header.getRequestId());
86 assertEquals(subreq, header.getSubRequestId());
88 // a subsequent request should have a different sub-request id
89 result = oper.makeRequest(2, MY_VNF);
90 assertNotEquals(subreq, result.getLeft());
92 assertNotNull(result.getLeft());
93 assertEquals(result.getLeft(), result.getRight().getCommonHeader().getSubRequestId());
95 // repeat using a null payload
96 params = params.toBuilder().payload(null).build();
97 oper = new AppcOperation(params, config) {
99 protected Pair<String, Request> makeRequest(int attempt) {
100 return oper.makeRequest(attempt, MY_VNF);
103 assertEquals(Map.of(AppcOperation.VNF_ID_KEY, MY_VNF), oper.makeRequest(2, MY_VNF).getRight().getPayload());
107 public void testConvertPayload() {
108 Request request = oper.makeRequest(2, MY_VNF).getRight();
112 Map.of(AppcOperation.VNF_ID_KEY, MY_VNF,
113 KEY1, Map.of("input", "hello"),
114 KEY2, Map.of("output", "world")),
115 request.getPayload());
120 * insert invalid json text into the payload.
122 Map<String, Object> payload = new TreeMap<>(params.getPayload());
123 payload.put("invalid-key", "{invalid json");
125 params = params.toBuilder().payload(payload).build();
127 oper = new AppcOperation(params, config) {
129 protected Pair<String, Request> makeRequest(int attempt) {
130 return oper.makeRequest(attempt, MY_VNF);
133 request = oper.makeRequest(2, MY_VNF).getRight();
137 Map.of(AppcOperation.VNF_ID_KEY, MY_VNF,
138 KEY1, Map.of("input", "hello"),
139 KEY2, Map.of("output", "world")),
140 request.getPayload());
145 * insert null item into the payload.
147 payload = new TreeMap<>();
148 payload.put(KEY1, "abc");
149 payload.put(KEY2, null);
150 payload.put(KEY3, "def");
151 params = params.toBuilder().payload(payload).build();
153 oper = new AppcOperation(params, config) {
155 protected Pair<String, Request> makeRequest(int attempt) {
156 return oper.makeRequest(attempt, MY_VNF);
159 request = oper.makeRequest(2, MY_VNF).getRight();
161 payload.put(AppcOperation.VNF_ID_KEY, MY_VNF);
162 payload.put(KEY1, "abc");
163 payload.put(KEY2, null);
164 payload.put(KEY3, "def");
166 assertEquals(payload, request.getPayload());
170 public void testGetExpectedKeyValues() {
171 Request request = oper.makeRequest(2, MY_VNF).getRight();
172 assertEquals(Arrays.asList(request.getCommonHeader().getSubRequestId()),
173 oper.getExpectedKeyValues(50, request));
177 public void testDetmStatusStringResponse() {
178 final ResponseStatus status = response.getStatus();
181 response.setStatus(null);
182 assertThatIllegalArgumentException().isThrownBy(() -> oper.detmStatus("", response))
183 .withMessage("APP-C response is missing the response status");
184 response.setStatus(status);
188 assertThatIllegalArgumentException().isThrownBy(() -> oper.detmStatus("", response))
189 .withMessage("unknown APPC-C response status code: -45");
191 status.setCode(ResponseCode.SUCCESS.getValue());
192 assertEquals(Status.SUCCESS, oper.detmStatus("", response));
194 status.setCode(ResponseCode.FAILURE.getValue());
195 assertEquals(Status.FAILURE, oper.detmStatus("", response));
197 status.setCode(ResponseCode.ERROR.getValue());
198 assertThatIllegalArgumentException().isThrownBy(() -> oper.detmStatus("", response))
199 .withMessage("APP-C request was not accepted, code=" + ResponseCode.ERROR.getValue());
201 status.setCode(ResponseCode.REJECT.getValue());
202 assertThatIllegalArgumentException().isThrownBy(() -> oper.detmStatus("", response))
203 .withMessage("APP-C request was not accepted, code=" + ResponseCode.REJECT.getValue());
205 status.setCode(ResponseCode.ACCEPT.getValue());
206 assertEquals(Status.STILL_WAITING, oper.detmStatus("", response));
210 public void testSetOutcome() {
211 final ResponseStatus status = response.getStatus();
214 response.setStatus(null);
215 assertSame(outcome, oper.setOutcome(outcome, PolicyResult.SUCCESS, response));
216 assertEquals(PolicyResult.SUCCESS, outcome.getResult());
217 assertNotNull(outcome.getMessage());
218 response.setStatus(status);
221 status.setDescription(null);
222 assertSame(outcome, oper.setOutcome(outcome, PolicyResult.FAILURE, response));
223 assertEquals(PolicyResult.FAILURE, outcome.getResult());
224 assertNotNull(outcome.getMessage());
225 status.setDescription(MY_DESCRIPTION);
227 for (PolicyResult result : PolicyResult.values()) {
228 assertSame(outcome, oper.setOutcome(outcome, result, response));
229 assertEquals(result, outcome.getResult());
230 assertEquals(MY_DESCRIPTION, outcome.getMessage());