src/test/java/org/onap/clamp/loop/LoopOperationTestItCase.java

   1 /*-
   2  * ============LICENSE_START=======================================================
   3  * ONAP CLAMP
   4  * ================================================================================
   5  * Copyright (C) 2019 Nokia Intellectual Property. All rights
   6  *                             reserved.
   7  * ================================================================================
   8  * Licensed under the Apache License, Version 2.0 (the "License");
   9  * you may not use this file except in compliance with the License.
  10  * You may obtain a copy of the License at
  11  *
  12  * http://www.apache.org/licenses/LICENSE-2.0
  13  *
  14  * Unless required by applicable law or agreed to in writing, software
  15  * distributed under the License is distributed on an "AS IS" BASIS,
  16  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  17  * See the License for the specific language governing permissions and
  18  * limitations under the License.
  19  * ============LICENSE_END============================================
  20  * ===================================================================
  21  *
  22  */
  23
  24 package org.onap.clamp.loop;
  25
  26 import static org.assertj.core.api.Assertions.assertThat;
  27
  28 import com.google.gson.Gson;
  29 import com.google.gson.GsonBuilder;
  30 import com.google.gson.JsonObject;
  31
  32 import java.io.IOException;
  33 import java.util.HashSet;
  34
  35 import org.apache.camel.Exchange;
  36 import org.apache.camel.Message;
  37 import org.json.simple.parser.ParseException;
  38 import org.junit.Test;
  39 import org.junit.runner.RunWith;
  40 import org.mockito.Mockito;
  41 import org.onap.clamp.clds.Application;
  42 import org.onap.clamp.loop.LoopOperation.TempLoopState;
  43 import org.onap.clamp.policy.microservice.MicroServicePolicy;
  44 import org.onap.clamp.policy.operational.OperationalPolicy;
  45 import org.springframework.beans.factory.annotation.Autowired;
  46 import org.springframework.boot.test.context.SpringBootTest;
  47 import org.springframework.test.context.junit4.SpringRunner;
  48
  49 @RunWith(SpringRunner.class)
  50 @SpringBootTest(classes = Application.class)
  51 public class LoopOperationTestItCase {
  52
  53     private Gson gson = new GsonBuilder().setPrettyPrinting().excludeFieldsWithoutExposeAnnotation().create();
  54     @Autowired
  55     LoopService loopService;
  56
  57     private Loop createTestLoop() {
  58         String yaml = "imports:\n" + "  - \"http://www.getcloudify.org/spec/cloudify/3.4/types.yaml\"\n"
  59             + "node_templates:\n" + "  docker_service_host:\n" + "    type: dcae.nodes.SelectedDockerHost";
  60
  61         Loop loopTest = new Loop("ControlLoopTest", yaml, "<xml></xml>");
  62         loopTest.setGlobalPropertiesJson(
  63             new Gson().fromJson("{\"dcaeDeployParameters\":" + "{\"policy_id\": \"name\"}}", JsonObject.class));
  64         loopTest.setLastComputedState(LoopState.DESIGN);
  65         loopTest.setDcaeDeploymentId("123456789");
  66         loopTest.setDcaeDeploymentStatusUrl("http4://localhost:8085");
  67         loopTest.setDcaeBlueprintId("UUID-blueprint");
  68
  69         MicroServicePolicy microServicePolicy = new MicroServicePolicy("configPolicyTest", "",
  70             "tosca_definitions_version: tosca_simple_yaml_1_0_0", true,
  71             gson.fromJson("{\"configtype\":\"json\"}", JsonObject.class), new HashSet<>());
  72         microServicePolicy.setProperties(new Gson().fromJson("{\"param1\":\"value1\"}", JsonObject.class));
  73
  74         loopTest.addMicroServicePolicy(microServicePolicy);
  75         return loopTest;
  76     }
  77
  78     @Test
  79     public void testAnalysePolicyResponse() {
  80         LoopOperation loopOp = new LoopOperation(loopService);
  81         String status1 = loopOp.analysePolicyResponse(200);
  82         String status2 = loopOp.analysePolicyResponse(404);
  83         String status3 = loopOp.analysePolicyResponse(500);
  84         String status4 = loopOp.analysePolicyResponse(503);
  85
  86         // then
  87         assertThat(status1).isEqualTo("SUBMITTED");
  88         assertThat(status2).isEqualTo("NOT_SUBMITTED");
  89         assertThat(status3).isEqualTo("IN_ERROR");
  90         assertThat(status4).isEqualTo("IN_ERROR");
  91     }
  92
  93     @Test
  94     public void testGetOperationalPolicyName() {
  95         LoopOperation loopOp = new LoopOperation(loopService);
  96         Loop loop = this.createTestLoop();
  97         String opName1 = loopOp.getOperationalPolicyName(loop);
  98         assertThat(opName1).isNull();
  99
 100         OperationalPolicy opPolicy1 = new OperationalPolicy("OperationalPolicyTest1", null,
 101             gson.fromJson("{\"type\":\"Operational\"}", JsonObject.class));
 102         loop.addOperationalPolicy(opPolicy1);
 103         String opName2 = loopOp.getOperationalPolicyName(loop);
 104         assertThat(opName2).isEqualTo("OperationalPolicyTest1");
 105     }
 106
 107     @Test
 108     public void testAnalyseDcaeResponse() throws ParseException {
 109         LoopOperation loopOp = new LoopOperation(loopService);
 110         String dcaeStatus1 = loopOp.analyseDcaeResponse(null, null);
 111         assertThat(dcaeStatus1).isEqualTo("NOT_DEPLOYED");
 112
 113         String dcaeStatus2 = loopOp.analyseDcaeResponse(null, 500);
 114         assertThat(dcaeStatus2).isEqualTo("IN_ERROR");
 115
 116         String dcaeStatus3 = loopOp.analyseDcaeResponse(null, 404);
 117         assertThat(dcaeStatus3).isEqualTo("NOT_DEPLOYED");
 118
 119         Exchange camelExchange = Mockito.mock(Exchange.class);
 120         Message mockMessage = Mockito.mock(Message.class);
 121         Mockito.when(camelExchange.getIn()).thenReturn(mockMessage);
 122         Mockito.when(mockMessage.getBody(String.class))
 123             .thenReturn("{\"operationType\":\"install\",\"status\":\"succeeded\"}");
 124         String dcaeStatus4 = loopOp.analyseDcaeResponse(camelExchange, 200);
 125         assertThat(dcaeStatus4).isEqualTo("DEPLOYED");
 126
 127         Mockito.when(mockMessage.getBody(String.class))
 128             .thenReturn("{\"operationType\":\"install\",\"status\":\"processing\"}");
 129         String dcaeStatus5 = loopOp.analyseDcaeResponse(camelExchange, 200);
 130         assertThat(dcaeStatus5).isEqualTo("PROCESSING");
 131
 132         Mockito.when(mockMessage.getBody(String.class))
 133             .thenReturn("{\"operationType\":\"install\",\"status\":\"failed\"}");
 134         String dcaeStatus6 = loopOp.analyseDcaeResponse(camelExchange, 200);
 135         assertThat(dcaeStatus6).isEqualTo("IN_ERROR");
 136
 137         Mockito.when(mockMessage.getBody(String.class))
 138             .thenReturn("{\"operationType\":\"uninstall\",\"status\":\"succeeded\"}");
 139         String dcaeStatus7 = loopOp.analyseDcaeResponse(camelExchange, 200);
 140         assertThat(dcaeStatus7).isEqualTo("NOT_DEPLOYED");
 141
 142         Mockito.when(mockMessage.getBody(String.class))
 143             .thenReturn("{\"operationType\":\"uninstall\",\"status\":\"processing\"}");
 144         String dcaeStatus8 = loopOp.analyseDcaeResponse(camelExchange, 200);
 145         assertThat(dcaeStatus8).isEqualTo("PROCESSING");
 146
 147         Mockito.when(mockMessage.getBody(String.class))
 148             .thenReturn("{\"operationType\":\"uninstall\",\"status\":\"failed\"}");
 149         String dcaeStatus9 = loopOp.analyseDcaeResponse(camelExchange, 200);
 150         assertThat(dcaeStatus9).isEqualTo("IN_ERROR");
 151     }
 152
 153     @Test
 154     public void testUpdateLoopStatus() {
 155         LoopOperation loopOp = new LoopOperation(loopService);
 156         Loop loop = this.createTestLoop();
 157         loopService.saveOrUpdateLoop(loop);
 158         LoopState newState1 = loopOp.updateLoopStatus(loop, TempLoopState.SUBMITTED, TempLoopState.DEPLOYED);
 159         LoopState dbState1 = loopService.getLoop(loop.getName()).getLastComputedState();
 160         assertThat(newState1).isEqualTo(LoopState.DEPLOYED);
 161         assertThat(dbState1).isEqualTo(LoopState.DEPLOYED);
 162
 163         LoopState newState2 = loopOp.updateLoopStatus(loop, TempLoopState.SUBMITTED, TempLoopState.NOT_DEPLOYED);
 164         LoopState dbState2 = loopService.getLoop(loop.getName()).getLastComputedState();
 165         assertThat(newState2).isEqualTo(LoopState.SUBMITTED);
 166         assertThat(dbState2).isEqualTo(LoopState.SUBMITTED);
 167
 168         LoopState newState3 = loopOp.updateLoopStatus(loop, TempLoopState.SUBMITTED, TempLoopState.PROCESSING);
 169         assertThat(newState3).isEqualTo(LoopState.WAITING);
 170
 171         LoopState newState4 = loopOp.updateLoopStatus(loop, TempLoopState.SUBMITTED, TempLoopState.IN_ERROR);
 172         assertThat(newState4).isEqualTo(LoopState.IN_ERROR);
 173
 174         LoopState newState5 = loopOp.updateLoopStatus(loop, TempLoopState.NOT_SUBMITTED, TempLoopState.DEPLOYED);
 175         assertThat(newState5).isEqualTo(LoopState.IN_ERROR);
 176
 177         LoopState newState6 = loopOp.updateLoopStatus(loop, TempLoopState.NOT_SUBMITTED, TempLoopState.PROCESSING);
 178         assertThat(newState6).isEqualTo(LoopState.IN_ERROR);
 179
 180         LoopState newState7 = loopOp.updateLoopStatus(loop, TempLoopState.NOT_SUBMITTED, TempLoopState.NOT_DEPLOYED);
 181         assertThat(newState7).isEqualTo(LoopState.DESIGN);
 182
 183         LoopState newState8 = loopOp.updateLoopStatus(loop, TempLoopState.IN_ERROR, TempLoopState.DEPLOYED);
 184         assertThat(newState8).isEqualTo(LoopState.IN_ERROR);
 185
 186         LoopState newState9 = loopOp.updateLoopStatus(loop, TempLoopState.IN_ERROR, TempLoopState.NOT_DEPLOYED);
 187         assertThat(newState9).isEqualTo(LoopState.IN_ERROR);
 188
 189         LoopState newState10 = loopOp.updateLoopStatus(loop, TempLoopState.IN_ERROR, TempLoopState.PROCESSING);
 190         assertThat(newState10).isEqualTo(LoopState.IN_ERROR);
 191
 192         LoopState newState11 = loopOp.updateLoopStatus(loop, TempLoopState.IN_ERROR, TempLoopState.IN_ERROR);
 193         assertThat(newState11).isEqualTo(LoopState.IN_ERROR);
 194     }
 195
 196     @Test
 197     public void testUpdateLoopInfo() throws ParseException {
 198         Loop loop = this.createTestLoop();
 199         loopService.saveOrUpdateLoop(loop);
 200
 201         Exchange camelExchange = Mockito.mock(Exchange.class);
 202         Message mockMessage = Mockito.mock(Message.class);
 203         Mockito.when(camelExchange.getIn()).thenReturn(mockMessage);
 204         Mockito.when(mockMessage.getBody(String.class))
 205             .thenReturn("{\"links\":{\"status\":\"http://testhost/dcae-operationstatus\",\"test2\":\"test2\"}}");
 206
 207         LoopOperation loopOp = new LoopOperation(loopService);
 208         loopOp.updateLoopInfo(camelExchange, loop, "testNewId");
 209
 210         Loop newLoop = loopService.getLoop(loop.getName());
 211         String newDeployId = newLoop.getDcaeDeploymentId();
 212         String newDeploymentStatusUrl = newLoop.getDcaeDeploymentStatusUrl();
 213
 214         assertThat(newDeployId).isEqualTo("testNewId");
 215         assertThat(newDeploymentStatusUrl).isEqualTo("http4://testhost/dcae-operationstatus");
 216     }
 217
 218     @Test
 219     public void testGetDeploymentId() {
 220         Loop loop = this.createTestLoop();
 221         LoopOperation loopOp = new LoopOperation(loopService);
 222         String deploymentId1 = loopOp.getDeploymentId(loop);
 223         assertThat(deploymentId1).isEqualTo("123456789");
 224
 225         loop.setDcaeDeploymentId(null);
 226         String deploymentId2 = loopOp.getDeploymentId(loop);
 227         assertThat(deploymentId2).startsWith("CLAMP_");
 228
 229         loop.setDcaeDeploymentId("");
 230         String deploymentId3 = loopOp.getDeploymentId(loop);
 231         assertThat(deploymentId3).startsWith("CLAMP_");
 232         assertThat(deploymentId3).isNotEqualTo(deploymentId2);
 233     }
 234
 235     @Test
 236     public void testGetDeployPayload() throws IOException {
 237         Loop loop = this.createTestLoop();
 238         LoopOperation loopOp = new LoopOperation(loopService);
 239         String deploymentPayload = loopOp.getDeployPayload(loop);
 240
 241         String expectedPayload = "{\"serviceTypeId\":\"UUID-blueprint\",\"inputs\":{\"policy_id\":\"name\"}}";
 242         assertThat(deploymentPayload).isEqualTo(expectedPayload);
 243     }
 244 }