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.After;
34 import org.junit.AfterClass;
35 import org.junit.Before;
36 import org.junit.BeforeClass;
37 import org.junit.Test;
38 import org.onap.policy.appc.CommonHeader;
39 import org.onap.policy.appc.Request;
40 import org.onap.policy.appc.ResponseCode;
41 import org.onap.policy.appc.ResponseStatus;
42 import org.onap.policy.controlloop.actorserviceprovider.impl.BidirectionalTopicOperation.Status;
43 import org.onap.policy.controlloop.policy.PolicyResult;
45 public class AppcOperationTest extends BasicAppcOperation {
46 private AppcOperation oper;
49 public static void setUpBeforeClass() throws Exception {
50 // use same topic name for both sides
51 initBeforeClass(MY_SINK, MY_SINK);
55 public static void tearDownAfterClass() {
64 public void setUp() throws Exception {
67 oper = new AppcOperation(params, config) {
69 protected Pair<String, Request> makeRequest(int attempt) {
70 return oper.makeRequest(attempt, MY_VNF);
77 public void tearDown() {
82 public void testConstructor() {
83 assertEquals(DEFAULT_ACTOR, oper.getActorName());
84 assertEquals(DEFAULT_OPERATION, oper.getName());
88 public void testStartPreprocessorAsync() {
89 assertNotNull(oper.startPreprocessorAsync());
93 public void testMakeRequest() {
94 Pair<String, Request> result = oper.makeRequest(2, MY_VNF);
95 String subreq = result.getLeft();
96 assertNotNull(subreq);
98 Request request = result.getRight();
99 assertEquals(DEFAULT_OPERATION, request.getAction());
101 assertNotNull(request.getPayload());
103 CommonHeader header = request.getCommonHeader();
104 assertNotNull(header);
105 assertEquals(params.getRequestId(), header.getRequestId());
107 assertEquals(subreq, header.getSubRequestId());
109 // a subsequent request should have a different sub-request id
110 result = oper.makeRequest(2, MY_VNF);
111 assertNotEquals(subreq, result.getLeft());
113 assertNotNull(result.getLeft());
114 assertEquals(result.getLeft(), result.getRight().getCommonHeader().getSubRequestId());
116 // repeat using a null payload
117 params = params.toBuilder().payload(null).build();
118 oper = new AppcOperation(params, config) {
120 protected Pair<String, Request> makeRequest(int attempt) {
121 return oper.makeRequest(attempt, MY_VNF);
124 assertEquals(Map.of(AppcOperation.VNF_ID_KEY, MY_VNF), oper.makeRequest(2, MY_VNF).getRight().getPayload());
128 public void testConvertPayload() {
129 Request request = oper.makeRequest(2, MY_VNF).getRight();
133 Map.of(AppcOperation.VNF_ID_KEY, MY_VNF,
134 KEY1, Map.of("input", "hello"),
135 KEY2, Map.of("output", "world")),
136 request.getPayload());
141 * insert invalid json text into the payload.
143 Map<String, Object> payload = new TreeMap<>(params.getPayload());
144 payload.put("invalid-key", "{invalid json");
146 params = params.toBuilder().payload(payload).build();
148 oper = new AppcOperation(params, config) {
150 protected Pair<String, Request> makeRequest(int attempt) {
151 return oper.makeRequest(attempt, MY_VNF);
154 request = oper.makeRequest(2, MY_VNF).getRight();
158 Map.of(AppcOperation.VNF_ID_KEY, MY_VNF,
159 KEY1, Map.of("input", "hello"),
160 KEY2, Map.of("output", "world")),
161 request.getPayload());
166 * insert null item into the payload.
168 payload = new TreeMap<>();
169 payload.put(KEY1, "abc");
170 payload.put(KEY2, null);
171 payload.put(KEY3, "def");
172 params = params.toBuilder().payload(payload).build();
174 oper = new AppcOperation(params, config) {
176 protected Pair<String, Request> makeRequest(int attempt) {
177 return oper.makeRequest(attempt, MY_VNF);
180 request = oper.makeRequest(2, MY_VNF).getRight();
182 payload.put(AppcOperation.VNF_ID_KEY, MY_VNF);
183 payload.put(KEY1, "abc");
184 payload.put(KEY2, null);
185 payload.put(KEY3, "def");
187 assertEquals(payload, request.getPayload());
191 public void testGetExpectedKeyValues() {
192 Request request = oper.makeRequest(2, MY_VNF).getRight();
193 assertEquals(Arrays.asList(request.getCommonHeader().getSubRequestId()),
194 oper.getExpectedKeyValues(50, request));
198 public void testDetmStatusStringResponse() {
199 final ResponseStatus status = response.getStatus();
201 // null status (i.e., it's a Request, not a Response)
202 response.setStatus(null);
203 assertEquals(Status.STILL_WAITING, oper.detmStatus("", response));
204 response.setStatus(status);
208 assertThatIllegalArgumentException().isThrownBy(() -> oper.detmStatus("", response))
209 .withMessage("unknown APPC-C response status code: -45");
211 status.setCode(ResponseCode.SUCCESS.getValue());
212 assertEquals(Status.SUCCESS, oper.detmStatus("", response));
214 status.setCode(ResponseCode.FAILURE.getValue());
215 assertEquals(Status.FAILURE, oper.detmStatus("", response));
217 status.setCode(ResponseCode.ERROR.getValue());
218 assertThatIllegalArgumentException().isThrownBy(() -> oper.detmStatus("", response))
219 .withMessage("APP-C request was not accepted, code=" + ResponseCode.ERROR.getValue());
221 status.setCode(ResponseCode.REJECT.getValue());
222 assertThatIllegalArgumentException().isThrownBy(() -> oper.detmStatus("", response))
223 .withMessage("APP-C request was not accepted, code=" + ResponseCode.REJECT.getValue());
225 status.setCode(ResponseCode.ACCEPT.getValue());
226 assertEquals(Status.STILL_WAITING, oper.detmStatus("", response));
230 public void testSetOutcome() {
231 final ResponseStatus status = response.getStatus();
234 response.setStatus(null);
235 assertSame(outcome, oper.setOutcome(outcome, PolicyResult.SUCCESS, response));
236 assertEquals(PolicyResult.SUCCESS, outcome.getResult());
237 assertNotNull(outcome.getMessage());
238 response.setStatus(status);
241 status.setDescription(null);
242 assertSame(outcome, oper.setOutcome(outcome, PolicyResult.FAILURE, response));
243 assertEquals(PolicyResult.FAILURE, outcome.getResult());
244 assertNotNull(outcome.getMessage());
245 status.setDescription(MY_DESCRIPTION);
247 for (PolicyResult result : PolicyResult.values()) {
248 assertSame(outcome, oper.setOutcome(outcome, result, response));
249 assertEquals(result, outcome.getResult());
250 assertEquals(MY_DESCRIPTION, outcome.getMessage());