models-interactions/model-actors/actor.sdnr/src/test/java/org/onap/policy/controlloop/actor/sdnr/SdnrOperationTest.java

   1 /*-
   2  * ============LICENSE_START=======================================================
   3  * SdnrOperation
   4  * ================================================================================
   5  * Copyright (C) 2020-2022 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
  10  *
  11  *      http://www.apache.org/licenses/LICENSE-2.0
  12  *
  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=========================================================
  19  */
  20
  21 package org.onap.policy.controlloop.actor.sdnr;
  22
  23 import static org.assertj.core.api.Assertions.assertThat;
  24 import static org.assertj.core.api.Assertions.assertThatIllegalStateException;
  25 import static org.junit.Assert.assertEquals;
  26 import static org.junit.Assert.assertNotNull;
  27 import static org.junit.Assert.assertSame;
  28 import static org.junit.Assert.assertTrue;
  29
  30 import java.util.List;
  31 import org.junit.After;
  32 import org.junit.AfterClass;
  33 import org.junit.Before;
  34 import org.junit.BeforeClass;
  35 import org.junit.Test;
  36 import org.onap.policy.controlloop.actor.test.BasicBidirectionalTopicOperation;
  37 import org.onap.policy.controlloop.actorserviceprovider.OperationProperties;
  38 import org.onap.policy.controlloop.actorserviceprovider.OperationResult;
  39 import org.onap.policy.controlloop.actorserviceprovider.impl.BidirectionalTopicOperation.Status;
  40 import org.onap.policy.controlloop.actorserviceprovider.parameters.BidirectionalTopicConfig;
  41 import org.onap.policy.controlloop.actorserviceprovider.parameters.BidirectionalTopicParams;
  42 import org.onap.policy.sdnr.PciCommonHeader;
  43 import org.onap.policy.sdnr.PciMessage;
  44 import org.onap.policy.sdnr.PciRequest;
  45 import org.onap.policy.sdnr.util.StatusCodeEnum;
  46
  47 public class SdnrOperationTest extends BasicSdnrOperation {
  48
  49     private SdnrOperation operation;
  50
  51     @BeforeClass
  52     public static void setUpBeforeClass() throws Exception {
  53         BasicBidirectionalTopicOperation.initBeforeClass(MY_SINK, MY_SOURCE);
  54     }
  55
  56     @AfterClass
  57     public static void tearDownAfterClass() {
  58         destroyAfterClass();
  59     }
  60
  61     /**
  62      * Setup.
  63      */
  64     @Before
  65     @Override
  66     public void setUp() throws Exception {
  67         super.setUp();
  68
  69         operation = new SdnrOperation(params, config);
  70         operation.setProperty(OperationProperties.EVENT_PAYLOAD, "my payload");
  71     }
  72
  73     @After
  74     @Override
  75     public void tearDown() {
  76         super.tearDown();
  77     }
  78
  79     @Test
  80     public void testSdnrOperation() {
  81         assertEquals(DEFAULT_ACTOR, operation.getActorName());
  82         assertEquals(DEFAULT_OPERATION, operation.getName());
  83     }
  84
  85     @Test
  86     public void testGetPropertyNames() {
  87         assertThat(operation.getPropertyNames()).isEqualTo(List.of(OperationProperties.EVENT_PAYLOAD));
  88     }
  89
  90     @Test
  91     public void testMakeRequest() {
  92         operation.generateSubRequestId(1);
  93
  94         PciMessage request = operation.makeRequest(1);
  95
  96         assertNotNull(request.getBody());
  97         assertEquals("1.0", request.getVersion());
  98         assertEquals("request", request.getType());
  99         assertEquals(DEFAULT_OPERATION.toLowerCase(), request.getRpcName());
 100
 101         PciRequest input = request.getBody().getInput();
 102         assertNotNull(input);
 103         assertEquals(DEFAULT_OPERATION, input.getAction());
 104
 105         PciCommonHeader header = input.getCommonHeader();
 106         assertNotNull(header);
 107         assertEquals(params.getRequestId(), header.getRequestId());
 108     }
 109
 110     /**
 111      * Tests makeRequest() when a property is missing.
 112      */
 113     @Test
 114     public void testMakeRequestMissingProperty() {
 115         operation = new SdnrOperation(params, config);
 116
 117         operation.generateSubRequestId(1);
 118         outcome.setSubRequestId(operation.getSubRequestId());
 119
 120         assertThatIllegalStateException().isThrownBy(() -> operation.makeRequest(1))
 121                         .withMessageContaining("missing event payload");
 122     }
 123
 124     @Test
 125     public void testGetExpectedKeyValues() {
 126         operation.generateSubRequestId(1);
 127
 128         PciMessage request = operation.makeRequest(1);
 129         assertEquals(List.of(request.getBody().getInput().getCommonHeader().getSubRequestId()),
 130                         operation.getExpectedKeyValues(50, request));
 131     }
 132
 133     /**
 134      * Tests "success" case with simulator.
 135      */
 136     @Test
 137     public void testSuccess() throws Exception {
 138         BidirectionalTopicParams opParams =
 139                         BidirectionalTopicParams.builder().sinkTopic(MY_SINK).sourceTopic(MY_SOURCE).build();
 140         config = new BidirectionalTopicConfig(blockingExecutor, opParams, topicMgr, SdnrOperation.SELECTOR_KEYS);
 141
 142         params = params.toBuilder().retry(0).timeoutSec(5).executor(blockingExecutor).build();
 143
 144         operation = new SdnrOperation(params, config);
 145         operation.setProperty(OperationProperties.EVENT_PAYLOAD, "my payload");
 146
 147         outcome = operation.start().get();
 148         assertEquals(OperationResult.SUCCESS, outcome.getResult());
 149         assertTrue(outcome.getResponse() instanceof PciMessage);
 150     }
 151
 152     @Test
 153     public void testDetmStatusStringResponse() {
 154         final org.onap.policy.sdnr.Status status = response.getBody().getOutput().getStatus();
 155
 156         // null status
 157         response.getBody().getOutput().setStatus(null);
 158         assertEquals(Status.FAILURE, operation.detmStatus("", response));
 159         response.getBody().getOutput().setStatus(status);
 160
 161         // invalid code
 162         status.setCode(-45);
 163         assertEquals(Status.FAILURE, operation.detmStatus("", response));
 164
 165
 166         status.setValue(StatusCodeEnum.ACCEPTED.toString());
 167         status.setCode(StatusCodeEnum.toValue(StatusCodeEnum.ACCEPTED));
 168         assertEquals(Status.STILL_WAITING, operation.detmStatus("", response));
 169
 170         status.setValue(StatusCodeEnum.SUCCESS.toString());
 171         status.setCode(StatusCodeEnum.toValue(StatusCodeEnum.SUCCESS));
 172         assertEquals(Status.SUCCESS, operation.detmStatus("", response));
 173
 174         status.setValue(StatusCodeEnum.REJECT.toString());
 175         status.setCode(StatusCodeEnum.toValue(StatusCodeEnum.REJECT));
 176         assertEquals(Status.FAILURE, operation.detmStatus("", response));
 177
 178         status.setValue(StatusCodeEnum.REJECT.toString());
 179         status.setCode(313);
 180         assertEquals(Status.FAILURE, operation.detmStatus("", response));
 181
 182         status.setValue(StatusCodeEnum.ERROR.toString());
 183         status.setCode(StatusCodeEnum.toValue(StatusCodeEnum.ERROR));
 184         assertEquals(Status.FAILURE, operation.detmStatus("", response));
 185
 186         status.setValue(StatusCodeEnum.FAILURE.toString());
 187         status.setCode(450);
 188         assertEquals(Status.FAILURE, operation.detmStatus("", response));
 189     }
 190
 191     @Test
 192     public void testSetOutcome() {
 193         // with a status value
 194         checkOutcome();
 195         assertEquals(StatusCodeEnum.SUCCESS.toString(), outcome.getMessage());
 196
 197         // null status value
 198         response.getBody().getOutput().getStatus().setValue(null);
 199         checkOutcome();
 200
 201         // null status
 202         response.getBody().getOutput().setStatus(null);
 203         checkOutcome();
 204
 205         // null output
 206         response.getBody().setOutput(null);
 207         checkOutcome();
 208
 209         // null body
 210         response.setBody(null);
 211         checkOutcome();
 212     }
 213
 214     protected void checkOutcome() {
 215         assertSame(outcome, operation.setOutcome(outcome, OperationResult.SUCCESS, response));
 216         assertEquals(OperationResult.SUCCESS, outcome.getResult());
 217         assertNotNull(outcome.getMessage());
 218         assertSame(response, outcome.getResponse());
 219     }
 220 }