gerrit.onap Code Review - policy/drools-applications.git/blob

   1 /*-
   2  * ============LICENSE_START=======================================================
   3  * unit test
   4  * ================================================================================
   5  * Copyright (C) 2017-2018 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.eventmanager;
  22
  23 import static org.junit.Assert.assertEquals;
  24 import static org.junit.Assert.assertNotNull;
  25 import static org.junit.Assert.assertNull;
  26 import static org.junit.Assert.assertTrue;
  27 import static org.junit.Assert.fail;
  28
  29 import java.io.File;
  30 import java.io.FileInputStream;
  31 import java.io.IOException;
  32 import java.io.InputStream;
  33 import java.nio.charset.StandardCharsets;
  34 import java.time.Instant;
  35 import java.util.HashMap;
  36 import java.util.UUID;
  37
  38 import org.apache.commons.io.IOUtils;
  39 import org.junit.AfterClass;
  40 import org.junit.BeforeClass;
  41 import org.junit.Test;
  42 import org.onap.policy.aai.AaiGetVnfResponse;
  43 import org.onap.policy.aai.AaiGetVserverResponse;
  44 import org.onap.policy.aai.RelatedToProperty;
  45 import org.onap.policy.aai.RelatedToPropertyItem;
  46 import org.onap.policy.aai.Relationship;
  47 import org.onap.policy.aai.RelationshipData;
  48 import org.onap.policy.aai.RelationshipDataItem;
  49 import org.onap.policy.aai.RelationshipList;
  50 import org.onap.policy.aai.util.AaiException;
  51 import org.onap.policy.controlloop.ControlLoopEventStatus;
  52 import org.onap.policy.controlloop.ControlLoopException;
  53 import org.onap.policy.controlloop.ControlLoopNotificationType;
  54 import org.onap.policy.controlloop.Util;
  55 import org.onap.policy.controlloop.VirtualControlLoopEvent;
  56 import org.onap.policy.controlloop.VirtualControlLoopNotification;
  57 import org.onap.policy.controlloop.eventmanager.ControlLoopEventManager.NEW_EVENT_STATUS;
  58 import org.onap.policy.controlloop.policy.ControlLoopPolicy;
  59 import org.onap.policy.controlloop.policy.PolicyResult;
  60 import org.onap.policy.drools.http.server.HttpServletServer;
  61 import org.onap.policy.drools.system.PolicyEngine;
  62 import org.onap.policy.guard.GuardResult;
  63 import org.onap.policy.guard.PolicyGuard;
  64 import org.onap.policy.guard.PolicyGuard.LockResult;
  65 import org.onap.policy.guard.TargetLock;
  66 import org.slf4j.Logger;
  67 import org.slf4j.LoggerFactory;
  68
  69 public class ControlLoopEventManagerTest {
  70     private static final Logger logger = LoggerFactory.getLogger(ControlLoopEventManagerTest.class);
  71
  72     private static VirtualControlLoopEvent onset;
  73
  74     {
  75         onset = new VirtualControlLoopEvent();
  76         onset.setClosedLoopControlName("ControlLoop-vUSP");
  77         onset.setRequestId(UUID.randomUUID());
  78         onset.setTarget("VM_NAME");
  79         onset.setClosedLoopAlarmStart(Instant.now());
  80         onset.setAai(new HashMap<String, String>());
  81         onset.getAai().put("cloud-region.identity-url", "foo");
  82         onset.getAai().put("vserver.selflink", "bar");
  83         onset.getAai().put("generic-vnf.vnf-id", "83f674e8-7555-44d7-9a39-bdc3770b0491");
  84         onset.setClosedLoopEventStatus(ControlLoopEventStatus.ONSET);
  85     }
  86
  87     /**
  88      * Set up test class.
  89      */
  90     @BeforeClass
  91     public static void setUpSimulator() {
  92         try {
  93             org.onap.policy.simulators.Util.buildAaiSim();
  94         } catch (Exception e) {
  95             fail(e.getMessage());
  96         }
  97         PolicyEngine.manager.setEnvironmentProperty("aai.username", "AAI");
  98         PolicyEngine.manager.setEnvironmentProperty("aai.password", "AAI");
  99         PolicyEngine.manager.setEnvironmentProperty("aai.url", "http://localhost:6666");
 100     }
 101
 102     @AfterClass
 103     public static void tearDownSimulator() {
 104         HttpServletServer.factory.destroy();
 105     }
 106
 107     @Test
 108     public void testAaiVnfInfo() {
 109         final Util.Pair<ControlLoopPolicy, String> pair = Util.loadYaml("src/test/resources/test.yaml");
 110         onset.setClosedLoopControlName(pair.key.getControlLoop().getControlLoopName());
 111         try {
 112             AaiGetVnfResponse response = getQueryByVnfId2(
 113                     PolicyEngine.manager.getEnvironmentProperty("aai.url")
 114                             + "/aai/v11/network/generic-vnfs/generic-vnf/",
 115                     PolicyEngine.manager.getEnvironmentProperty("aai.username"),
 116                     PolicyEngine.manager.getEnvironmentProperty("aai.password"), UUID.randomUUID(),
 117                     "5e49ca06-2972-4532-9ed4-6d071588d792");
 118             assertNotNull(response);
 119             logger.info("testAAIVnfInfo test result is " + (response == null ? "null" : "not null"));
 120         } catch (Exception e) {
 121             logger.error("testAAIVnfInfo Exception: ", e);
 122             fail(e.getMessage());
 123         }
 124     }
 125
 126     @Test
 127     public void testAaiVnfInfo2() {
 128         final Util.Pair<ControlLoopPolicy, String> pair = Util.loadYaml("src/test/resources/test.yaml");
 129         onset.setClosedLoopControlName(pair.key.getControlLoop().getControlLoopName());
 130         try {
 131             AaiGetVnfResponse response = getQueryByVnfName2(
 132                     PolicyEngine.manager.getEnvironmentProperty("aai.url")
 133                             + "/aai/v11/network/generic-vnfs/generic-vnf?vnf-name=",
 134                     PolicyEngine.manager.getEnvironmentProperty("aai.username"),
 135                     PolicyEngine.manager.getEnvironmentProperty("aai.password"), UUID.randomUUID(), "lll_vnf_010317");
 136             assertNotNull(response);
 137             logger.info("testAAIVnfInfo2 test result is " + (response == null ? "null" : "not null"));
 138         } catch (Exception e) {
 139             logger.error("testAAIVnfInfo2 Exception: ", e);
 140             fail(e.getMessage());
 141         }
 142     }
 143
 144     @Test
 145     public void testAaiVserver() {
 146         final Util.Pair<ControlLoopPolicy, String> pair = Util.loadYaml("src/test/resources/test.yaml");
 147         onset.setClosedLoopControlName(pair.key.getControlLoop().getControlLoopName());
 148         try {
 149             AaiGetVserverResponse response = getQueryByVserverName2(
 150                     PolicyEngine.manager.getEnvironmentProperty("aai.url") + "/aai/v11/nodes/vservers?vserver-name=",
 151                     PolicyEngine.manager.getEnvironmentProperty("aai.username"),
 152                     PolicyEngine.manager.getEnvironmentProperty("aai.password"), UUID.randomUUID(),
 153                     "USMSO1SX7NJ0103UJZZ01-vjunos0");
 154             assertNotNull(response);
 155             logger.info("testAAIVserver test result is " + (response == null ? "null" : "not null"));
 156         } catch (Exception e) {
 157             logger.error("testAAIVserver Exception: ", e);
 158             fail(e.getMessage());
 159         }
 160     }
 161
 162     @Test
 163     public void testIsClosedLoopDisabled() {
 164         //
 165         // Load up the policy
 166         //
 167         final Util.Pair<ControlLoopPolicy, String> pair = Util.loadYaml("src/test/resources/test.yaml");
 168         onset.setClosedLoopControlName(pair.key.getControlLoop().getControlLoopName());
 169
 170         try {
 171             logger.info("testIsClosedLoopDisabled --");
 172             AaiGetVnfResponse response = getQueryByVnfId2(
 173                     PolicyEngine.manager.getEnvironmentProperty("aai.url")
 174                             + "/aai/v11/network/generic-vnfs/generic-vnf/",
 175                     PolicyEngine.manager.getEnvironmentProperty("aai.username"),
 176                     PolicyEngine.manager.getEnvironmentProperty("aai.password"), UUID.randomUUID(),
 177                     "5e49ca06-2972-4532-9ed4-6d071588d792");
 178             assertNotNull(response);
 179
 180             // TODO: Handle this
 181             // boolean disabled = ControlLoopEventManager.isClosedLoopDisabled(response);
 182             // logger.info("QueryByVnfID - isClosedLoopDisabled: " + disabled);
 183
 184             response = getQueryByVnfName2(
 185                     PolicyEngine.manager.getEnvironmentProperty("aai.url")
 186                             + "/aai/v11/network/generic-vnfs/generic-vnf?vnf-name=",
 187                     PolicyEngine.manager.getEnvironmentProperty("aai.username"),
 188                     PolicyEngine.manager.getEnvironmentProperty("aai.password"), UUID.randomUUID(), "lll_vnf_010317");
 189             assertNotNull(response);
 190             // TODO: Handle this
 191             // disabled = ControlLoopEventManager.isClosedLoopDisabled(response);
 192             // logger.info("QueryByVnfName - isClosedLoopDisabled: " + disabled);
 193
 194             AaiGetVserverResponse response2 = getQueryByVserverName2(
 195                     PolicyEngine.manager.getEnvironmentProperty("aai.url") + "/aai/v11/nodes/vservers?vserver-name=",
 196                     PolicyEngine.manager.getEnvironmentProperty("aai.user"),
 197                     PolicyEngine.manager.getEnvironmentProperty("aai.password"), UUID.randomUUID(),
 198                     "USMSO1SX7NJ0103UJZZ01-vjunos0");
 199             assertNotNull(response2);
 200             // TODO: Handle this
 201             // disabled = ControlLoopEventManager.isClosedLoopDisabled(response2);
 202             // logger.info("QueryByVserverName - isClosedLoopDisabled: " + disabled);
 203         } catch (Exception e) {
 204             fail(e.getMessage());
 205         }
 206     }
 207
 208     @Test
 209     public void abatemetCheckEventSyntaxTest() {
 210         VirtualControlLoopEvent event = new VirtualControlLoopEvent();
 211         event.setClosedLoopControlName("abatementAAI");
 212         event.setRequestId(UUID.randomUUID());
 213         event.setTarget("generic-vnf.vnf-id");
 214         event.setClosedLoopAlarmStart(Instant.now());
 215         event.setClosedLoopEventStatus(ControlLoopEventStatus.ABATED);
 216         ControlLoopEventManager manager = makeManager(event);
 217         assertNull(manager.getVnfResponse());
 218         assertNull(manager.getVserverResponse());
 219         try {
 220             manager.checkEventSyntax(event);
 221         } catch (ControlLoopException e) {
 222             logger.debug("ControlLoopException in abatemetCheckEventSyntaxTest: " + e.getMessage());
 223             e.printStackTrace();
 224             fail("Exception in check event syntax");
 225         }
 226         assertNull(manager.getVnfResponse());
 227         assertNull(manager.getVserverResponse());
 228
 229
 230         event.setAai(new HashMap<>());
 231         event.getAai().put("generic-vnf.vnf-name", "abatementTest");
 232         try {
 233             manager.checkEventSyntax(event);
 234         } catch (ControlLoopException e) {
 235             logger.debug("ControlLoopException in abatemetCheckEventSyntaxTest: " + e.getMessage());
 236             e.printStackTrace();
 237             fail("Exception in check event syntax");
 238         }
 239         assertNull(manager.getVnfResponse());
 240         assertNull(manager.getVserverResponse());
 241     }
 242
 243     @Test
 244     public void subsequentOnsetTest() {
 245         UUID requestId = UUID.randomUUID();
 246         VirtualControlLoopEvent event = new VirtualControlLoopEvent();
 247         event.setClosedLoopControlName("TwoOnsetTest");
 248         event.setRequestId(requestId);
 249         event.setTarget("generic-vnf.vnf-id");
 250         event.setClosedLoopAlarmStart(Instant.now());
 251         event.setClosedLoopEventStatus(ControlLoopEventStatus.ONSET);
 252         event.setAai(new HashMap<>());
 253         event.getAai().put("generic-vnf.vnf-name", "onsetOne");
 254
 255         ControlLoopEventManager manager = makeManager(event);
 256         VirtualControlLoopNotification notification = manager.activate(event);
 257
 258         assertNotNull(notification);
 259         assertEquals(ControlLoopNotificationType.ACTIVE, notification.getNotification());
 260
 261         ControlLoopEventManager.NEW_EVENT_STATUS status = null;
 262         try {
 263             status = manager.onNewEvent(event);
 264         } catch (AaiException e) {
 265             logger.warn(e.toString());
 266             fail("A&AI Query Failed");
 267         }
 268         assertNotNull(status);
 269         assertEquals(ControlLoopEventManager.NEW_EVENT_STATUS.FIRST_ONSET, status);
 270
 271         AaiGetVnfResponse response = manager.getVnfResponse();
 272         assertNotNull(response);
 273         assertNull(manager.getVserverResponse());
 274
 275         VirtualControlLoopEvent event2 = new VirtualControlLoopEvent();
 276         event2.setClosedLoopControlName("TwoOnsetTest");
 277         event2.setRequestId(requestId);
 278         event2.setTarget("generic-vnf.vnf-id");
 279         event2.setClosedLoopAlarmStart(Instant.now());
 280         event2.setClosedLoopEventStatus(ControlLoopEventStatus.ONSET);
 281         event2.setAai(new HashMap<>());
 282         event2.getAai().put("generic-vnf.vnf-name", "onsetTwo");
 283
 284
 285         try {
 286             status = manager.onNewEvent(event2);
 287         } catch (AaiException e) {
 288             logger.warn(e.toString());
 289             fail("A&AI Query Failed");
 290         }
 291         assertEquals(ControlLoopEventManager.NEW_EVENT_STATUS.SUBSEQUENT_ONSET, status);
 292         AaiGetVnfResponse response2 = manager.getVnfResponse();
 293         assertNotNull(response2);
 294         // We should not have queried AAI, so the stored response should be the same
 295         assertEquals(response, response2);
 296         assertNull(manager.getVserverResponse());
 297     }
 298
 299     /**
 300      * Simulate a response.
 301      */
 302     public static AaiGetVnfResponse getQueryByVnfId2(String urlGet, String username, String password, UUID requestId,
 303             String key) {
 304         AaiGetVnfResponse response = new AaiGetVnfResponse();
 305
 306         response.setVnfId("83f674e8-7555-44d7-9a39-bdc3770b0491");
 307         response.setVnfName("lll_vnf_010317");
 308         response.setVnfType("Basa-122216-Service/VidVsamp12BaseVolume 1");
 309         response.setServiceId("a9a77d5a-123e-4ca2-9eb9-0b015d2ee0fb");
 310         response.setOrchestrationStatus("Created");
 311         response.setInMaint("false");
 312         response.setIsClosedLoopDisabled("false");
 313         response.setResourceVersion("1494001988835");
 314         response.setModelInvariantId("f18be3cd-d446-456e-9109-121d9b62feaa");
 315
 316         final RelationshipList relationshipList = new RelationshipList();
 317         final Relationship relationship = new Relationship();
 318         RelationshipData relationshipData = new RelationshipData();
 319         RelationshipDataItem relationshipDataItem = new RelationshipDataItem();
 320
 321         relationshipDataItem.setRelationshipKey("customer.global-customer-id");
 322         relationshipDataItem.setRelationshipValue("MSO_1610_ST");
 323         relationshipData.getRelationshipData().add(relationshipDataItem);
 324
 325         relationshipDataItem.setRelationshipKey("service-subscription.service-type");
 326         relationshipDataItem.setRelationshipValue("MSO-dev-service-type");
 327         relationshipData.getRelationshipData().add(relationshipDataItem);
 328
 329         relationshipDataItem.setRelationshipKey("service-instance.service-instance-id");
 330         relationshipDataItem.setRelationshipValue("e1e9c97c-02c0-4919-9b4c-eb5d5ef68970");
 331         relationshipData.getRelationshipData().add(relationshipDataItem);
 332
 333         RelatedToProperty relatedToProperty = new RelatedToProperty();
 334         RelatedToPropertyItem item = new RelatedToPropertyItem();
 335         item.setPropertyKey("service-instance.service-instance-name");
 336         item.setPropertyValue("lll_svc_010317");
 337         relatedToProperty.getRelatedTo().add(item);
 338
 339         relationship.setRelatedTo("service-instance");
 340         relationship.setRelatedLink(
 341                 "/aai/v11/business/customers/customer/MSO_1610_ST/service-subscriptions/service-subscription"
 342                         + "/MSO-dev-service-type/service-instances/service-instance/"
 343                         + "e1e9c97c-02c0-4919-9b4c-eb5d5ef68970");
 344         relationship.setRelationshipData(relationshipData);
 345         relationship.setRelatedToProperty(relatedToProperty);
 346
 347         relationshipList.getRelationshipList().add(relationship);
 348         response.setRelationshipList(relationshipList);
 349
 350         return response;
 351     }
 352
 353     /**
 354      * Simulate a response.
 355      */
 356     public static AaiGetVnfResponse getQueryByVnfName2(String urlGet, String username, String password, UUID requestId,
 357             String key) {
 358         AaiGetVnfResponse response = new AaiGetVnfResponse();
 359
 360         response.setVnfId("83f674e8-7555-44d7-9a39-bdc3770b0491");
 361         response.setVnfName("lll_vnf_010317");
 362         response.setVnfType("Basa-122216-Service/VidVsamp12BaseVolume 1");
 363         response.setServiceId("a9a77d5a-123e-4ca2-9eb9-0b015d2ee0fb");
 364         response.setOrchestrationStatus("Created");
 365         response.setInMaint("false");
 366         response.setIsClosedLoopDisabled("false");
 367         response.setResourceVersion("1494001988835");
 368         response.setModelInvariantId("f18be3cd-d446-456e-9109-121d9b62feaa");
 369
 370         final RelationshipList relationshipList = new RelationshipList();
 371         final Relationship relationship = new Relationship();
 372         RelationshipData relationshipData = new RelationshipData();
 373         RelationshipDataItem relationshipDataItem = new RelationshipDataItem();
 374
 375         relationshipDataItem.setRelationshipKey("customer.global-customer-id");
 376         relationshipDataItem.setRelationshipValue("MSO_1610_ST");
 377         relationshipData.getRelationshipData().add(relationshipDataItem);
 378
 379         relationshipDataItem.setRelationshipKey("service-subscription.service-type");
 380         relationshipDataItem.setRelationshipValue("MSO-dev-service-type");
 381         relationshipData.getRelationshipData().add(relationshipDataItem);
 382
 383         relationshipDataItem.setRelationshipKey("service-instance.service-instance-id");
 384         relationshipDataItem.setRelationshipValue("e1e9c97c-02c0-4919-9b4c-eb5d5ef68970");
 385         relationshipData.getRelationshipData().add(relationshipDataItem);
 386
 387         RelatedToProperty relatedToProperty = new RelatedToProperty();
 388         RelatedToPropertyItem item = new RelatedToPropertyItem();
 389         item.setPropertyKey("service-instance.service-instance-name");
 390         item.setPropertyValue("lll_svc_010317");
 391         relatedToProperty.getRelatedTo().add(item);
 392
 393         relationship.setRelatedTo("service-instance");
 394         relationship.setRelatedLink(
 395                 "/aai/v11/business/customers/customer/MSO_1610_ST/service-subscriptions/service-subscription"
 396                         + "/MSO-dev-service-type/service-instances/service-instance/"
 397                         + "e1e9c97c-02c0-4919-9b4c-eb5d5ef68970");
 398         relationship.setRelationshipData(relationshipData);
 399         relationship.setRelatedToProperty(relatedToProperty);
 400
 401         relationshipList.getRelationshipList().add(relationship);
 402         response.setRelationshipList(relationshipList);
 403
 404         return response;
 405     }
 406
 407     /**
 408      * Simulate a response.
 409      */
 410     public static AaiGetVserverResponse getQueryByVserverName2(String urlGet, String username, String password,
 411             UUID requestId, String key) {
 412         AaiGetVserverResponse response = new AaiGetVserverResponse();
 413
 414         response.setVserverId("d0668d4f-c25e-4a1b-87c4-83845c01efd8");
 415         response.setVserverName("USMSO1SX7NJ0103UJZZ01-vjunos0");
 416         response.setVserverName2("vjunos0");
 417         response.setVserverSelflink(
 418                 "https://aai-ext1.test.att.com:8443/aai/v7/cloud-infrastructure/cloud-regions/cloud-region/att-aic/AAIAIC25/tenants/tenant/USMSO1SX7NJ0103UJZZ01%3A%3AuCPE-VMS/vservers/vserver/d0668d4f-c25e-4a1b-87c4-83845c01efd8");
 419         response.setInMaint("false");
 420         response.setIsClosedLoopDisabled("false");
 421         response.setResourceVersion("1494001931513");
 422
 423         final RelationshipList relationshipList = new RelationshipList();
 424         final Relationship relationship = new Relationship();
 425         RelationshipData relationshipData = new RelationshipData();
 426         RelationshipDataItem relationshipDataItem = new RelationshipDataItem();
 427
 428         relationshipDataItem.setRelationshipKey("customer.global-customer-id");
 429         relationshipDataItem.setRelationshipValue("MSO_1610_ST");
 430         relationshipData.getRelationshipData().add(relationshipDataItem);
 431
 432         relationshipDataItem.setRelationshipKey("service-subscription.service-type");
 433         relationshipDataItem.setRelationshipValue("MSO-dev-service-type");
 434         relationshipData.getRelationshipData().add(relationshipDataItem);
 435
 436         relationshipDataItem.setRelationshipKey("service-instance.service-instance-id");
 437         relationshipDataItem.setRelationshipValue("e1e9c97c-02c0-4919-9b4c-eb5d5ef68970");
 438         relationshipData.getRelationshipData().add(relationshipDataItem);
 439
 440         RelatedToProperty relatedToProperty = new RelatedToProperty();
 441         RelatedToPropertyItem item = new RelatedToPropertyItem();
 442         item.setPropertyKey("service-instance.service-instance-name");
 443         item.setPropertyValue("lll_svc_010317");
 444         relatedToProperty.getRelatedTo().add(item);
 445
 446         relationship.setRelatedTo("service-instance");
 447         relationship.setRelatedLink(
 448                 "/aai/v11/business/customers/customer/MSO_1610_ST/service-subscriptions/service-subscription"
 449                         + "/MSO-dev-service-type/service-instances/service-instance/"
 450                         + "e1e9c97c-02c0-4919-9b4c-eb5d5ef68970");
 451         relationship.setRelationshipData(relationshipData);
 452         relationship.setRelatedToProperty(relatedToProperty);
 453
 454         relationshipList.getRelationshipList().add(relationship);
 455         response.setRelationshipList(relationshipList);
 456
 457         return response;
 458     }
 459
 460     @Test
 461     public void testMethods() {
 462         ControlLoopEventManager clem = new ControlLoopEventManager("MyClosedLoopName", UUID.randomUUID());
 463
 464         clem.setActivated(true);
 465         assertEquals(true, clem.isActivated());
 466
 467         clem.setControlLoopResult("SUCCESS");
 468         assertEquals("SUCCESS", clem.getControlLoopResult());
 469
 470         clem.setControlLoopTimedOut();
 471         assertEquals(true, clem.isControlLoopTimedOut());
 472
 473         clem.setNumAbatements(12345);
 474         assertEquals(Integer.valueOf(12345), clem.getNumAbatements());
 475
 476         clem.setNumOnsets(54321);
 477         assertEquals(Integer.valueOf(54321), clem.getNumOnsets());
 478
 479         assertNull(clem.getOnsetEvent());
 480         assertNull(clem.getAbatementEvent());
 481         assertNull(clem.getProcessor());
 482
 483         assertEquals(true, clem.isActive());
 484         assertEquals(false, clem.releaseLock());
 485         assertEquals(true, clem.isControlLoopTimedOut());
 486
 487         assertNull(clem.unlockCurrentOperation());
 488     }
 489
 490     @Test
 491     public void testAlreadyActivated() {
 492         UUID requestId = UUID.randomUUID();
 493         VirtualControlLoopEvent event = new VirtualControlLoopEvent();
 494         event.setClosedLoopControlName("TwoOnsetTest");
 495         event.setRequestId(requestId);
 496         event.setTarget("generic-vnf.vnf-id");
 497         event.setClosedLoopAlarmStart(Instant.now());
 498         event.setClosedLoopEventStatus(ControlLoopEventStatus.ONSET);
 499         event.setAai(new HashMap<>());
 500         event.getAai().put("generic-vnf.vnf-name", "onsetOne");
 501
 502         ControlLoopEventManager manager = makeManager(event);
 503         manager.setActivated(true);
 504         VirtualControlLoopNotification notification = manager.activate(event);
 505         assertEquals(ControlLoopNotificationType.REJECTED, notification.getNotification());
 506     }
 507
 508     @Test
 509     public void testActivationYaml() throws IOException {
 510         InputStream is = new FileInputStream(new File("src/test/resources/test.yaml"));
 511         final String yamlString = IOUtils.toString(is, StandardCharsets.UTF_8);
 512
 513         InputStream isBad = new FileInputStream(new File("src/test/resources/notutf8.yaml"));
 514         final String yamlStringBad = IOUtils.toString(isBad, StandardCharsets.UTF_8);
 515
 516         UUID requestId = UUID.randomUUID();
 517         VirtualControlLoopEvent event = new VirtualControlLoopEvent();
 518         event.setClosedLoopControlName("TwoOnsetTest");
 519         event.setRequestId(requestId);
 520         event.setTarget("generic-vnf.vnf-id");
 521         event.setClosedLoopAlarmStart(Instant.now());
 522         event.setClosedLoopEventStatus(ControlLoopEventStatus.ONSET);
 523         event.setAai(new HashMap<>());
 524         event.getAai().put("generic-vnf.vnf-name", "onsetOne");
 525
 526         ControlLoopEventManager manager = makeManager(event);
 527
 528         // Null YAML should fail
 529         VirtualControlLoopNotification notificationNull = manager.activate(null, event);
 530         assertNotNull(notificationNull);
 531         assertEquals(ControlLoopNotificationType.REJECTED, notificationNull.getNotification());
 532
 533         // Empty YAML should fail
 534         VirtualControlLoopNotification notificationEmpty = manager.activate("", event);
 535         assertNotNull(notificationEmpty);
 536         assertEquals(ControlLoopNotificationType.REJECTED, notificationEmpty.getNotification());
 537
 538         // Bad YAML should fail
 539         VirtualControlLoopNotification notificationBad = manager.activate(yamlStringBad, event);
 540         assertNotNull(notificationBad);
 541         assertEquals(ControlLoopNotificationType.REJECTED, notificationBad.getNotification());
 542
 543         VirtualControlLoopNotification notification = manager.activate(yamlString, event);
 544         assertNotNull(notification);
 545         assertEquals(ControlLoopNotificationType.ACTIVE, notification.getNotification());
 546
 547         // Another activate should fail
 548         VirtualControlLoopNotification notificationActive = manager.activate(yamlString, event);
 549         assertNotNull(notificationActive);
 550         assertEquals(ControlLoopNotificationType.REJECTED, notificationActive.getNotification());
 551     }
 552
 553     @Test
 554     public void testControlLoopFinal() throws ControlLoopException, IOException {
 555         InputStream is = new FileInputStream(new File("src/test/resources/test.yaml"));
 556         final String yamlString = IOUtils.toString(is, StandardCharsets.UTF_8);
 557
 558         UUID requestId = UUID.randomUUID();
 559         VirtualControlLoopEvent event = new VirtualControlLoopEvent();
 560         event.setClosedLoopControlName("TwoOnsetTest");
 561         event.setRequestId(requestId);
 562         event.setTarget("generic-vnf.vnf-id");
 563         event.setClosedLoopAlarmStart(Instant.now());
 564         event.setClosedLoopEventStatus(ControlLoopEventStatus.ONSET);
 565         event.setAai(new HashMap<>());
 566         event.getAai().put("generic-vnf.vnf-name", "onsetOne");
 567
 568         ControlLoopEventManager manager = makeManager(event);
 569         try {
 570             manager.isControlLoopFinal();
 571             fail("test should throw an exception here");
 572         } catch (ControlLoopException e) {
 573             assertEquals("ControlLoopEventManager MUST be activated first.", e.getMessage());
 574         }
 575
 576         manager.setActivated(true);
 577         try {
 578             manager.isControlLoopFinal();
 579             fail("test should throw an exception here");
 580         } catch (ControlLoopException e) {
 581             assertEquals("No onset event for ControlLoopEventManager.", e.getMessage());
 582         }
 583
 584         manager.setActivated(false);
 585         VirtualControlLoopNotification notification = manager.activate(yamlString, event);
 586         assertNotNull(notification);
 587         assertEquals(ControlLoopNotificationType.ACTIVE, notification.getNotification());
 588
 589         VirtualControlLoopNotification clfNotification = manager.isControlLoopFinal();
 590         assertNull(clfNotification);
 591
 592         manager.getProcessor().nextPolicyForResult(PolicyResult.SUCCESS);
 593         clfNotification = manager.isControlLoopFinal();
 594         assertNotNull(clfNotification);
 595         assertEquals(ControlLoopNotificationType.FINAL_SUCCESS, clfNotification.getNotification());
 596
 597         manager = new ControlLoopEventManager(event.getClosedLoopControlName(), event.getRequestId());
 598         notification = manager.activate(yamlString, event);
 599         assertNotNull(notification);
 600         assertEquals(ControlLoopNotificationType.ACTIVE, notification.getNotification());
 601
 602         manager.getProcessor().nextPolicyForResult(PolicyResult.FAILURE_EXCEPTION);
 603         clfNotification = manager.isControlLoopFinal();
 604         assertNotNull(clfNotification);
 605         assertEquals(ControlLoopNotificationType.FINAL_FAILURE, clfNotification.getNotification());
 606
 607         manager = new ControlLoopEventManager(event.getClosedLoopControlName(), event.getRequestId());
 608         notification = manager.activate(yamlString, event);
 609         assertNotNull(notification);
 610         assertEquals(ControlLoopNotificationType.ACTIVE, notification.getNotification());
 611
 612         manager.getProcessor().nextPolicyForResult(PolicyResult.FAILURE_GUARD);
 613         clfNotification = manager.isControlLoopFinal();
 614         assertNotNull(clfNotification);
 615         assertEquals(ControlLoopNotificationType.FINAL_FAILURE, clfNotification.getNotification());
 616
 617         manager.setControlLoopTimedOut();
 618         clfNotification = manager.isControlLoopFinal();
 619         assertNotNull(clfNotification);
 620         assertEquals(ControlLoopNotificationType.FINAL_FAILURE, clfNotification.getNotification());
 621     }
 622
 623     @Test
 624     public void testProcessControlLoop() throws ControlLoopException, IOException, AaiException {
 625         InputStream is = new FileInputStream(new File("src/test/resources/test.yaml"));
 626         final String yamlString = IOUtils.toString(is, StandardCharsets.UTF_8);
 627
 628         UUID requestId = UUID.randomUUID();
 629         VirtualControlLoopEvent event = new VirtualControlLoopEvent();
 630         event.setClosedLoopControlName("TwoOnsetTest");
 631         event.setRequestId(requestId);
 632         event.setTarget("generic-vnf.vnf-id");
 633         event.setClosedLoopAlarmStart(Instant.now());
 634         event.setClosedLoopEventStatus(ControlLoopEventStatus.ONSET);
 635         event.setAai(new HashMap<>());
 636         event.getAai().put("generic-vnf.vnf-name", "onsetOne");
 637
 638         ControlLoopEventManager manager = makeManager(event);
 639         try {
 640             manager.processControlLoop();
 641             fail("test should throw an exception here");
 642         } catch (Exception e) {
 643             assertEquals("ControlLoopEventManager MUST be activated first.", e.getMessage());
 644         }
 645
 646         manager.setActivated(true);
 647         try {
 648             manager.processControlLoop();
 649             fail("test should throw an exception here");
 650         } catch (Exception e) {
 651             assertEquals("No onset event for ControlLoopEventManager.", e.getMessage());
 652         }
 653
 654         manager.setActivated(false);
 655         VirtualControlLoopNotification notification = manager.activate(yamlString, event);
 656         assertNotNull(notification);
 657         assertEquals(ControlLoopNotificationType.ACTIVE, notification.getNotification());
 658
 659         ControlLoopOperationManager clom = manager.processControlLoop();
 660         assertNotNull(clom);
 661         assertNull(clom.getOperationResult());
 662
 663         // Test operation in progress
 664         try {
 665             manager.processControlLoop();
 666             fail("test should throw an exception here");
 667         } catch (Exception e) {
 668             assertEquals("Already working an Operation, do not call this method.", e.getMessage());
 669         }
 670
 671         manager = new ControlLoopEventManager(event.getClosedLoopControlName(), event.getRequestId());
 672         notification = manager.activate(yamlString, event);
 673         assertNotNull(notification);
 674         assertEquals(ControlLoopNotificationType.ACTIVE, notification.getNotification());
 675
 676         manager.getProcessor().nextPolicyForResult(PolicyResult.FAILURE_GUARD);
 677         VirtualControlLoopNotification clfNotification = manager.isControlLoopFinal();
 678         assertNotNull(clfNotification);
 679         assertEquals(ControlLoopNotificationType.FINAL_FAILURE, clfNotification.getNotification());
 680
 681         // Test operation completed
 682         try {
 683             manager.processControlLoop();
 684             fail("test should throw an exception here");
 685         } catch (Exception e) {
 686             assertEquals("Control Loop is in FINAL state, do not call this method.", e.getMessage());
 687         }
 688
 689         manager = new ControlLoopEventManager(event.getClosedLoopControlName(), event.getRequestId());
 690         notification = manager.activate(yamlString, event);
 691         assertNotNull(notification);
 692         assertEquals(ControlLoopNotificationType.ACTIVE, notification.getNotification());
 693         manager.getProcessor().nextPolicyForResult(PolicyResult.FAILURE);
 694
 695         // Test operation with no next policy defined
 696         try {
 697             manager.processControlLoop();
 698             fail("test should throw an exception here");
 699         } catch (Exception e) {
 700             assertEquals("The target type is null", e.getMessage());
 701         }
 702     }
 703
 704     @Test
 705     public void testFinishOperation() throws IOException, ControlLoopException, AaiException {
 706         InputStream is = new FileInputStream(new File("src/test/resources/testSOactor.yaml"));
 707         final String yamlString = IOUtils.toString(is, StandardCharsets.UTF_8);
 708
 709         InputStream isStd = new FileInputStream(new File("src/test/resources/test.yaml"));
 710         final String yamlStringStd = IOUtils.toString(isStd, StandardCharsets.UTF_8);
 711
 712         UUID requestId = UUID.randomUUID();
 713         VirtualControlLoopEvent event = new VirtualControlLoopEvent();
 714         event.setClosedLoopControlName("TwoOnsetTest");
 715         event.setRequestId(requestId);
 716         event.setTarget("generic-vnf.vnf-id");
 717         event.setClosedLoopAlarmStart(Instant.now());
 718         event.setClosedLoopEventStatus(ControlLoopEventStatus.ONSET);
 719         event.setAai(new HashMap<>());
 720         event.getAai().put("generic-vnf.vnf-name", "onsetOne");
 721
 722         ControlLoopEventManager manager = makeManager(event);
 723         try {
 724             manager.finishOperation(null);
 725             fail("test should throw an exception here");
 726         } catch (Exception e) {
 727             assertEquals("No operation to finish.", e.getMessage());
 728         }
 729
 730         manager.setActivated(true);
 731         try {
 732             manager.finishOperation(null);
 733             fail("test should throw an exception here");
 734         } catch (Exception e) {
 735             assertEquals("No operation to finish.", e.getMessage());
 736         }
 737
 738         manager.setActivated(false);
 739         VirtualControlLoopNotification notification = manager.activate(yamlString, event);
 740         assertNotNull(notification);
 741         assertEquals(ControlLoopNotificationType.ACTIVE, notification.getNotification());
 742
 743         try {
 744             manager.lockCurrentOperation();
 745             fail("test should throw an exception here");
 746         } catch (Exception e) {
 747             assertEquals("Do not have a current operation.", e.getMessage());
 748         }
 749
 750         assertNull(manager.unlockCurrentOperation());
 751
 752         ControlLoopOperationManager clom = manager.processControlLoop();
 753         assertNotNull(clom);
 754         assertNull(clom.getOperationResult());
 755
 756         LockResult<GuardResult, TargetLock> lockLock = manager.lockCurrentOperation();
 757         assertNotNull(lockLock);
 758
 759         LockResult<GuardResult, TargetLock> lockLockAgain = manager.lockCurrentOperation();
 760         assertNotNull(lockLockAgain);
 761         assertEquals(lockLock.getB(), lockLockAgain.getB());
 762
 763         assertEquals(lockLock.getB(), manager.unlockCurrentOperation());
 764         assertNull(manager.unlockCurrentOperation());
 765
 766         lockLock = manager.lockCurrentOperation();
 767         assertNotNull(lockLock);
 768         PolicyGuard.unlockTarget(lockLock.getB());
 769         assertNull(manager.unlockCurrentOperation());
 770
 771         clom.startOperation(event);
 772
 773         // This call should be exception free
 774         manager.finishOperation(clom);
 775
 776         ControlLoopEventManager otherManager = makeManager(event);
 777         VirtualControlLoopNotification otherNotification = otherManager.activate(yamlStringStd, event);
 778         assertNotNull(otherNotification);
 779         assertEquals(ControlLoopNotificationType.ACTIVE, otherNotification.getNotification());
 780
 781         ControlLoopOperationManager otherClom = otherManager.processControlLoop();
 782         assertNotNull(otherClom);
 783         assertNull(otherClom.getOperationResult());
 784
 785         otherManager.finishOperation(clom);
 786     }
 787
 788     @Test
 789     public void testOnNewEvent() throws IOException, AaiException {
 790         InputStream is = new FileInputStream(new File("src/test/resources/test.yaml"));
 791         final String yamlString = IOUtils.toString(is, StandardCharsets.UTF_8);
 792
 793         UUID requestId = UUID.randomUUID();
 794         VirtualControlLoopEvent onsetEvent = new VirtualControlLoopEvent();
 795         onsetEvent.setClosedLoopControlName("TwoOnsetTest");
 796         onsetEvent.setRequestId(requestId);
 797         onsetEvent.setTarget("generic-vnf.vnf-id");
 798         onsetEvent.setClosedLoopAlarmStart(Instant.now());
 799         onsetEvent.setClosedLoopEventStatus(ControlLoopEventStatus.ONSET);
 800         onsetEvent.setAai(new HashMap<>());
 801         onsetEvent.getAai().put("generic-vnf.vnf-name", "onsetOne");
 802
 803         VirtualControlLoopEvent abatedEvent = new VirtualControlLoopEvent();
 804         abatedEvent.setClosedLoopControlName("TwoOnsetTest");
 805         abatedEvent.setRequestId(requestId);
 806         abatedEvent.setTarget("generic-vnf.vnf-id");
 807         abatedEvent.setClosedLoopAlarmStart(Instant.now());
 808         abatedEvent.setClosedLoopEventStatus(ControlLoopEventStatus.ABATED);
 809         abatedEvent.setAai(new HashMap<>());
 810         abatedEvent.getAai().put("generic-vnf.vnf-name", "onsetOne");
 811
 812         ControlLoopEventManager manager = makeManager(onsetEvent);
 813         VirtualControlLoopNotification notification = manager.activate(yamlString, onsetEvent);
 814         assertNotNull(notification);
 815         assertEquals(ControlLoopNotificationType.ACTIVE, notification.getNotification());
 816
 817         assertEquals(NEW_EVENT_STATUS.FIRST_ONSET, manager.onNewEvent(onsetEvent));
 818         assertEquals(NEW_EVENT_STATUS.FIRST_ABATEMENT, manager.onNewEvent(abatedEvent));
 819         assertEquals(NEW_EVENT_STATUS.SUBSEQUENT_ABATEMENT, manager.onNewEvent(abatedEvent));
 820
 821         VirtualControlLoopEvent checkSyntaxEvent = new VirtualControlLoopEvent();
 822         checkSyntaxEvent.setAai(null);
 823         checkSyntaxEvent.setClosedLoopAlarmEnd(null);
 824         checkSyntaxEvent.setClosedLoopAlarmStart(null);
 825         checkSyntaxEvent.setClosedLoopControlName(null);
 826         checkSyntaxEvent.setClosedLoopEventClient(null);
 827         checkSyntaxEvent.setClosedLoopEventStatus(null);
 828         checkSyntaxEvent.setFrom(null);
 829         checkSyntaxEvent.setPolicyName(null);
 830         checkSyntaxEvent.setPolicyScope(null);
 831         checkSyntaxEvent.setPolicyVersion(null);
 832         checkSyntaxEvent.setRequestId(null);
 833         checkSyntaxEvent.setTarget(null);
 834         checkSyntaxEvent.setTargetType(null);
 835         checkSyntaxEvent.setVersion(null);
 836
 837         assertEquals(NEW_EVENT_STATUS.SYNTAX_ERROR, manager.onNewEvent(checkSyntaxEvent));
 838
 839         checkSyntaxEvent.setClosedLoopEventStatus(ControlLoopEventStatus.ONSET);
 840         assertEquals(NEW_EVENT_STATUS.SYNTAX_ERROR, manager.onNewEvent(checkSyntaxEvent));
 841
 842         checkSyntaxEvent.setClosedLoopControlName(null);
 843         assertEquals(NEW_EVENT_STATUS.SYNTAX_ERROR, manager.onNewEvent(checkSyntaxEvent));
 844
 845         checkSyntaxEvent.setClosedLoopControlName("");
 846         assertEquals(NEW_EVENT_STATUS.SYNTAX_ERROR, manager.onNewEvent(checkSyntaxEvent));
 847
 848         checkSyntaxEvent.setClosedLoopControlName("TwoOnsetTest");
 849         assertEquals(NEW_EVENT_STATUS.SYNTAX_ERROR, manager.onNewEvent(checkSyntaxEvent));
 850
 851         checkSyntaxEvent.setRequestId(null);
 852         assertEquals(NEW_EVENT_STATUS.SYNTAX_ERROR, manager.onNewEvent(checkSyntaxEvent));
 853
 854         checkSyntaxEvent.setRequestId(requestId);
 855         assertEquals(NEW_EVENT_STATUS.SYNTAX_ERROR, manager.onNewEvent(checkSyntaxEvent));
 856
 857         checkSyntaxEvent.setAai(null);
 858         assertEquals(NEW_EVENT_STATUS.SYNTAX_ERROR, manager.onNewEvent(checkSyntaxEvent));
 859
 860         checkSyntaxEvent.setAai(new HashMap<>());
 861         assertEquals(NEW_EVENT_STATUS.SYNTAX_ERROR, manager.onNewEvent(checkSyntaxEvent));
 862
 863         checkSyntaxEvent.setTarget("");
 864         assertEquals(NEW_EVENT_STATUS.SYNTAX_ERROR, manager.onNewEvent(checkSyntaxEvent));
 865
 866         checkSyntaxEvent.setTarget(null);
 867         assertEquals(NEW_EVENT_STATUS.SYNTAX_ERROR, manager.onNewEvent(checkSyntaxEvent));
 868
 869         checkSyntaxEvent.setTarget("");
 870         assertEquals(NEW_EVENT_STATUS.SYNTAX_ERROR, manager.onNewEvent(checkSyntaxEvent));
 871
 872         checkSyntaxEvent.setTarget("OZ");
 873         assertEquals(NEW_EVENT_STATUS.SYNTAX_ERROR, manager.onNewEvent(checkSyntaxEvent));
 874
 875         checkSyntaxEvent.setTarget("VM_NAME");
 876         assertEquals(NEW_EVENT_STATUS.SYNTAX_ERROR, manager.onNewEvent(checkSyntaxEvent));
 877
 878         checkSyntaxEvent.setTarget("VNF_NAME");
 879         assertEquals(NEW_EVENT_STATUS.SYNTAX_ERROR, manager.onNewEvent(checkSyntaxEvent));
 880
 881         checkSyntaxEvent.setTarget("vserver.vserver-name");
 882         assertEquals(NEW_EVENT_STATUS.SYNTAX_ERROR, manager.onNewEvent(checkSyntaxEvent));
 883
 884         checkSyntaxEvent.setTarget("generic-vnf.vnf-id");
 885         assertEquals(NEW_EVENT_STATUS.SYNTAX_ERROR, manager.onNewEvent(checkSyntaxEvent));
 886
 887         checkSyntaxEvent.setTarget("generic-vnf.vnf-name");
 888         assertEquals(NEW_EVENT_STATUS.SYNTAX_ERROR, manager.onNewEvent(checkSyntaxEvent));
 889
 890         checkSyntaxEvent.setAai(null);
 891         assertEquals(NEW_EVENT_STATUS.SYNTAX_ERROR, manager.onNewEvent(checkSyntaxEvent));
 892
 893         checkSyntaxEvent.setAai(new HashMap<>());
 894         assertEquals(NEW_EVENT_STATUS.SYNTAX_ERROR, manager.onNewEvent(checkSyntaxEvent));
 895
 896         checkSyntaxEvent.getAai().put("generic-vnf.vnf-name", "onsetOne");
 897         assertEquals(NEW_EVENT_STATUS.SUBSEQUENT_ABATEMENT, manager.onNewEvent(abatedEvent));
 898
 899         checkSyntaxEvent.getAai().put("vserver.vserver-name", "onsetOne");
 900         assertEquals(NEW_EVENT_STATUS.SUBSEQUENT_ABATEMENT, manager.onNewEvent(abatedEvent));
 901
 902         checkSyntaxEvent.getAai().put("generic-vnf.vnf-id", "onsetOne");
 903         assertEquals(NEW_EVENT_STATUS.SUBSEQUENT_ABATEMENT, manager.onNewEvent(abatedEvent));
 904     }
 905
 906     @Test
 907     public void testControlLoopTimeout() throws IOException {
 908         InputStream is = new FileInputStream(new File("src/test/resources/test.yaml"));
 909         final String yamlString = IOUtils.toString(is, StandardCharsets.UTF_8);
 910
 911         UUID requestId = UUID.randomUUID();
 912         VirtualControlLoopEvent onsetEvent = new VirtualControlLoopEvent();
 913         onsetEvent.setClosedLoopControlName("TwoOnsetTest");
 914         onsetEvent.setRequestId(requestId);
 915         onsetEvent.setTarget("generic-vnf.vnf-id");
 916         onsetEvent.setClosedLoopAlarmStart(Instant.now());
 917         onsetEvent.setClosedLoopEventStatus(ControlLoopEventStatus.ONSET);
 918         onsetEvent.setAai(new HashMap<>());
 919         onsetEvent.getAai().put("generic-vnf.vnf-name", "onsetOne");
 920
 921         ControlLoopEventManager manager = makeManager(onsetEvent);
 922         assertTrue(0 == manager.getControlLoopTimeout(null));
 923         assertTrue(120 == manager.getControlLoopTimeout(120));
 924
 925         VirtualControlLoopNotification notification = manager.activate(yamlString, onsetEvent);
 926         assertNotNull(notification);
 927         assertEquals(ControlLoopNotificationType.ACTIVE, notification.getNotification());
 928
 929         assertTrue(60 == manager.getControlLoopTimeout(null));
 930     }
 931
 932     @Test
 933     public void testQueryAai() throws IOException, AaiException {
 934         InputStream is = new FileInputStream(new File("src/test/resources/test.yaml"));
 935         final String yamlString = IOUtils.toString(is, StandardCharsets.UTF_8);
 936
 937         UUID requestId = UUID.randomUUID();
 938         VirtualControlLoopEvent onsetEvent = new VirtualControlLoopEvent();
 939         onsetEvent.setClosedLoopControlName("TwoOnsetTest");
 940         onsetEvent.setRequestId(requestId);
 941         onsetEvent.setTarget("generic-vnf.vnf-id");
 942         onsetEvent.setClosedLoopAlarmStart(Instant.now());
 943         onsetEvent.setClosedLoopEventStatus(ControlLoopEventStatus.ONSET);
 944         onsetEvent.setAai(new HashMap<>());
 945         onsetEvent.getAai().put("generic-vnf.vnf-name", "onsetOne");
 946
 947         ControlLoopEventManager manager = makeManager(onsetEvent);
 948         manager.queryAai(onsetEvent);
 949
 950         VirtualControlLoopNotification notification = manager.activate(yamlString, onsetEvent);
 951         assertNotNull(notification);
 952         assertEquals(ControlLoopNotificationType.ACTIVE, notification.getNotification());
 953
 954         // repeat query with same manager
 955         manager.queryAai(onsetEvent);
 956
 957         // remaining queries each use their own manager so they will be re-executed
 958
 959         makeManager(onsetEvent).queryAai(onsetEvent);
 960
 961         onsetEvent.getAai().put("generic-vnf.is-closed-loop-disabled", "true");
 962         try {
 963             makeManager(onsetEvent).queryAai(onsetEvent);
 964             fail("test should throw an exception here");
 965         } catch (Exception e) {
 966             assertEquals("is-closed-loop-disabled is set to true on VServer or VNF", e.getMessage());
 967         }
 968         onsetEvent.getAai().put("vserver.is-closed-loop-disabled", "true");
 969         try {
 970             makeManager(onsetEvent).queryAai(onsetEvent);
 971             fail("test should throw an exception here");
 972         } catch (Exception e) {
 973             assertEquals("is-closed-loop-disabled is set to true on VServer or VNF", e.getMessage());
 974         }
 975         onsetEvent.getAai().remove("generic-vnf.is-closed-loop-disabled");
 976         try {
 977             makeManager(onsetEvent).queryAai(onsetEvent);
 978             fail("test should throw an exception here");
 979         } catch (Exception e) {
 980             assertEquals("is-closed-loop-disabled is set to true on VServer or VNF", e.getMessage());
 981         }
 982         onsetEvent.getAai().remove("vserver.is-closed-loop-disabled");
 983         makeManager(onsetEvent).queryAai(onsetEvent);
 984
 985         onsetEvent.getAai().put("generic-vnf.is-closed-loop-disabled", "false");
 986         makeManager(onsetEvent).queryAai(onsetEvent);
 987
 988         onsetEvent.getAai().remove("generic-vnf.is-closed-loop-disabled");
 989         onsetEvent.getAai().put("vserver.is-closed-loop-disabled", "false");
 990         makeManager(onsetEvent).queryAai(onsetEvent);
 991
 992         onsetEvent.getAai().remove("generic-vnf.vnf-id");
 993         onsetEvent.getAai().remove("generic-vnf.vnf-name");
 994         onsetEvent.getAai().remove("vserver.vserver-name");
 995         onsetEvent.getAai().remove("generic-vnf.is-closed-loop-disabled");
 996         onsetEvent.getAai().remove("vserver.is-closed-loop-disabled");
 997         makeManager(onsetEvent).queryAai(onsetEvent);
 998
 999         onsetEvent.getAai().put("vserver.vserver-name", "AVserver");
1000         makeManager(onsetEvent).queryAai(onsetEvent);
1001
1002         onsetEvent.getAai().put("generic-vnf.vnf-name", "AVNFName");
1003         makeManager(onsetEvent).queryAai(onsetEvent);
1004
1005         onsetEvent.getAai().put("generic-vnf.vnf-id", "AVNFID");
1006         makeManager(onsetEvent).queryAai(onsetEvent);
1007
1008         onsetEvent.getAai().remove("vserver.vserver-name");
1009         makeManager(onsetEvent).queryAai(onsetEvent);
1010
1011         onsetEvent.getAai().remove("generic-vnf.vnf-name");
1012         makeManager(onsetEvent).queryAai(onsetEvent);
1013
1014         // Force AAI errors
1015         PolicyEngine.manager.setEnvironmentProperty("aai.url", "http://localhost:9999");
1016
1017         try {
1018             makeManager(onsetEvent).queryAai(onsetEvent);
1019             fail("test should throw an exception here");
1020         } catch (Exception e) {
1021             assertEquals("Exception from queryAai: org.onap.policy.aai.util.AaiException: AAI Response is null "
1022                     + "(query by vnf-id)", e.getMessage());
1023         }
1024
1025         onsetEvent.getAai().remove("generic-vnf.vnf-id");
1026         onsetEvent.getAai().put("generic-vnf.vnf-name", "AVNFName");
1027         try {
1028             makeManager(onsetEvent).queryAai(onsetEvent);
1029             fail("test should throw an exception here");
1030         } catch (Exception e) {
1031             assertEquals("Exception from queryAai: org.onap.policy.aai.util.AaiException: AAI Response is null "
1032                     + "(query by vnf-name)", e.getMessage());
1033         }
1034
1035         onsetEvent.getAai().remove("generic-vnf.vnf-name");
1036         onsetEvent.getAai().put("vserver.vserver-name", "AVserver");
1037         try {
1038             makeManager(onsetEvent).queryAai(onsetEvent);
1039             fail("test should throw an exception here");
1040         } catch (Exception e) {
1041             assertEquals("Exception from queryAai: org.onap.policy.aai.util.AaiException: AAI Response is null "
1042                     + "(query by vserver-name)", e.getMessage());
1043         }
1044
1045         PolicyEngine.manager.setEnvironmentProperty("aai.url", "http://localhost:6666");
1046     }
1047
1048     private ControlLoopEventManager makeManager(VirtualControlLoopEvent event) {
1049         return new ControlLoopEventManager(event.getClosedLoopControlName(), event.getRequestId());
1050     }
1051 }