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-id", "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         assertEquals(GuardResult.LOCK_ACQUIRED, lockLock.getA());
 759
 760         LockResult<GuardResult, TargetLock> lockLockAgain = manager.lockCurrentOperation();
 761         assertNotNull(lockLockAgain);
 762         assertEquals(GuardResult.LOCK_ACQUIRED, lockLockAgain.getA());
 763         assertEquals(lockLock.getB(), lockLockAgain.getB());
 764
 765         assertEquals(lockLock.getB(), manager.unlockCurrentOperation());
 766         assertNull(manager.unlockCurrentOperation());
 767
 768         lockLock = manager.lockCurrentOperation();
 769         assertNotNull(lockLock);
 770         PolicyGuard.unlockTarget(lockLock.getB());
 771         assertNull(manager.unlockCurrentOperation());
 772
 773         clom.startOperation(event);
 774
 775         // This call should be exception free
 776         manager.finishOperation(clom);
 777
 778         ControlLoopEventManager otherManager = makeManager(event);
 779         VirtualControlLoopNotification otherNotification = otherManager.activate(yamlStringStd, event);
 780         assertNotNull(otherNotification);
 781         assertEquals(ControlLoopNotificationType.ACTIVE, otherNotification.getNotification());
 782
 783         ControlLoopOperationManager otherClom = otherManager.processControlLoop();
 784         assertNotNull(otherClom);
 785         assertNull(otherClom.getOperationResult());
 786
 787         otherManager.finishOperation(clom);
 788     }
 789
 790     @Test
 791     public void testOnNewEvent() throws IOException, AaiException {
 792         InputStream is = new FileInputStream(new File("src/test/resources/test.yaml"));
 793         final String yamlString = IOUtils.toString(is, StandardCharsets.UTF_8);
 794
 795         UUID requestId = UUID.randomUUID();
 796         VirtualControlLoopEvent onsetEvent = new VirtualControlLoopEvent();
 797         onsetEvent.setClosedLoopControlName("TwoOnsetTest");
 798         onsetEvent.setRequestId(requestId);
 799         onsetEvent.setTarget("generic-vnf.vnf-id");
 800         onsetEvent.setClosedLoopAlarmStart(Instant.now());
 801         onsetEvent.setClosedLoopEventStatus(ControlLoopEventStatus.ONSET);
 802         onsetEvent.setAai(new HashMap<>());
 803         onsetEvent.getAai().put("generic-vnf.vnf-name", "onsetOne");
 804
 805         VirtualControlLoopEvent abatedEvent = new VirtualControlLoopEvent();
 806         abatedEvent.setClosedLoopControlName("TwoOnsetTest");
 807         abatedEvent.setRequestId(requestId);
 808         abatedEvent.setTarget("generic-vnf.vnf-id");
 809         abatedEvent.setClosedLoopAlarmStart(Instant.now());
 810         abatedEvent.setClosedLoopEventStatus(ControlLoopEventStatus.ABATED);
 811         abatedEvent.setAai(new HashMap<>());
 812         abatedEvent.getAai().put("generic-vnf.vnf-name", "onsetOne");
 813
 814         ControlLoopEventManager manager = makeManager(onsetEvent);
 815         VirtualControlLoopNotification notification = manager.activate(yamlString, onsetEvent);
 816         assertNotNull(notification);
 817         assertEquals(ControlLoopNotificationType.ACTIVE, notification.getNotification());
 818
 819         assertEquals(NEW_EVENT_STATUS.FIRST_ONSET, manager.onNewEvent(onsetEvent));
 820         assertEquals(NEW_EVENT_STATUS.FIRST_ABATEMENT, manager.onNewEvent(abatedEvent));
 821         assertEquals(NEW_EVENT_STATUS.SUBSEQUENT_ABATEMENT, manager.onNewEvent(abatedEvent));
 822
 823         VirtualControlLoopEvent checkSyntaxEvent = new VirtualControlLoopEvent();
 824         checkSyntaxEvent.setAai(null);
 825         checkSyntaxEvent.setClosedLoopAlarmEnd(null);
 826         checkSyntaxEvent.setClosedLoopAlarmStart(null);
 827         checkSyntaxEvent.setClosedLoopControlName(null);
 828         checkSyntaxEvent.setClosedLoopEventClient(null);
 829         checkSyntaxEvent.setClosedLoopEventStatus(null);
 830         checkSyntaxEvent.setFrom(null);
 831         checkSyntaxEvent.setPolicyName(null);
 832         checkSyntaxEvent.setPolicyScope(null);
 833         checkSyntaxEvent.setPolicyVersion(null);
 834         checkSyntaxEvent.setRequestId(null);
 835         checkSyntaxEvent.setTarget(null);
 836         checkSyntaxEvent.setTargetType(null);
 837         checkSyntaxEvent.setVersion(null);
 838
 839         assertEquals(NEW_EVENT_STATUS.SYNTAX_ERROR, manager.onNewEvent(checkSyntaxEvent));
 840
 841         checkSyntaxEvent.setClosedLoopEventStatus(ControlLoopEventStatus.ONSET);
 842         assertEquals(NEW_EVENT_STATUS.SYNTAX_ERROR, manager.onNewEvent(checkSyntaxEvent));
 843
 844         checkSyntaxEvent.setClosedLoopControlName(null);
 845         assertEquals(NEW_EVENT_STATUS.SYNTAX_ERROR, manager.onNewEvent(checkSyntaxEvent));
 846
 847         checkSyntaxEvent.setClosedLoopControlName("");
 848         assertEquals(NEW_EVENT_STATUS.SYNTAX_ERROR, manager.onNewEvent(checkSyntaxEvent));
 849
 850         checkSyntaxEvent.setClosedLoopControlName("TwoOnsetTest");
 851         assertEquals(NEW_EVENT_STATUS.SYNTAX_ERROR, manager.onNewEvent(checkSyntaxEvent));
 852
 853         checkSyntaxEvent.setRequestId(null);
 854         assertEquals(NEW_EVENT_STATUS.SYNTAX_ERROR, manager.onNewEvent(checkSyntaxEvent));
 855
 856         checkSyntaxEvent.setRequestId(requestId);
 857         assertEquals(NEW_EVENT_STATUS.SYNTAX_ERROR, manager.onNewEvent(checkSyntaxEvent));
 858
 859         checkSyntaxEvent.setAai(null);
 860         assertEquals(NEW_EVENT_STATUS.SYNTAX_ERROR, manager.onNewEvent(checkSyntaxEvent));
 861
 862         checkSyntaxEvent.setAai(new HashMap<>());
 863         assertEquals(NEW_EVENT_STATUS.SYNTAX_ERROR, manager.onNewEvent(checkSyntaxEvent));
 864
 865         checkSyntaxEvent.setTarget("");
 866         assertEquals(NEW_EVENT_STATUS.SYNTAX_ERROR, manager.onNewEvent(checkSyntaxEvent));
 867
 868         checkSyntaxEvent.setTarget(null);
 869         assertEquals(NEW_EVENT_STATUS.SYNTAX_ERROR, manager.onNewEvent(checkSyntaxEvent));
 870
 871         checkSyntaxEvent.setTarget("");
 872         assertEquals(NEW_EVENT_STATUS.SYNTAX_ERROR, manager.onNewEvent(checkSyntaxEvent));
 873
 874         checkSyntaxEvent.setTarget("OZ");
 875         assertEquals(NEW_EVENT_STATUS.SYNTAX_ERROR, manager.onNewEvent(checkSyntaxEvent));
 876
 877         checkSyntaxEvent.setTarget("VM_NAME");
 878         assertEquals(NEW_EVENT_STATUS.SYNTAX_ERROR, manager.onNewEvent(checkSyntaxEvent));
 879
 880         checkSyntaxEvent.setTarget("VNF_NAME");
 881         assertEquals(NEW_EVENT_STATUS.SYNTAX_ERROR, manager.onNewEvent(checkSyntaxEvent));
 882
 883         checkSyntaxEvent.setTarget("vserver.vserver-name");
 884         assertEquals(NEW_EVENT_STATUS.SYNTAX_ERROR, manager.onNewEvent(checkSyntaxEvent));
 885
 886         checkSyntaxEvent.setTarget("generic-vnf.vnf-id");
 887         assertEquals(NEW_EVENT_STATUS.SYNTAX_ERROR, manager.onNewEvent(checkSyntaxEvent));
 888
 889         checkSyntaxEvent.setTarget("generic-vnf.vnf-name");
 890         assertEquals(NEW_EVENT_STATUS.SYNTAX_ERROR, manager.onNewEvent(checkSyntaxEvent));
 891
 892         checkSyntaxEvent.setAai(null);
 893         assertEquals(NEW_EVENT_STATUS.SYNTAX_ERROR, manager.onNewEvent(checkSyntaxEvent));
 894
 895         checkSyntaxEvent.setAai(new HashMap<>());
 896         assertEquals(NEW_EVENT_STATUS.SYNTAX_ERROR, manager.onNewEvent(checkSyntaxEvent));
 897
 898         checkSyntaxEvent.getAai().put("generic-vnf.vnf-name", "onsetOne");
 899         assertEquals(NEW_EVENT_STATUS.SUBSEQUENT_ABATEMENT, manager.onNewEvent(abatedEvent));
 900
 901         checkSyntaxEvent.getAai().put("vserver.vserver-name", "onsetOne");
 902         assertEquals(NEW_EVENT_STATUS.SUBSEQUENT_ABATEMENT, manager.onNewEvent(abatedEvent));
 903
 904         checkSyntaxEvent.getAai().put("generic-vnf.vnf-id", "onsetOne");
 905         assertEquals(NEW_EVENT_STATUS.SUBSEQUENT_ABATEMENT, manager.onNewEvent(abatedEvent));
 906     }
 907
 908     @Test
 909     public void testControlLoopTimeout() throws IOException {
 910         InputStream is = new FileInputStream(new File("src/test/resources/test.yaml"));
 911         final String yamlString = IOUtils.toString(is, StandardCharsets.UTF_8);
 912
 913         UUID requestId = UUID.randomUUID();
 914         VirtualControlLoopEvent onsetEvent = new VirtualControlLoopEvent();
 915         onsetEvent.setClosedLoopControlName("TwoOnsetTest");
 916         onsetEvent.setRequestId(requestId);
 917         onsetEvent.setTarget("generic-vnf.vnf-id");
 918         onsetEvent.setClosedLoopAlarmStart(Instant.now());
 919         onsetEvent.setClosedLoopEventStatus(ControlLoopEventStatus.ONSET);
 920         onsetEvent.setAai(new HashMap<>());
 921         onsetEvent.getAai().put("generic-vnf.vnf-name", "onsetOne");
 922
 923         ControlLoopEventManager manager = makeManager(onsetEvent);
 924         assertTrue(0 == manager.getControlLoopTimeout(null));
 925         assertTrue(120 == manager.getControlLoopTimeout(120));
 926
 927         VirtualControlLoopNotification notification = manager.activate(yamlString, onsetEvent);
 928         assertNotNull(notification);
 929         assertEquals(ControlLoopNotificationType.ACTIVE, notification.getNotification());
 930
 931         assertTrue(60 == manager.getControlLoopTimeout(null));
 932     }
 933
 934     @Test
 935     public void testQueryAai() throws IOException, AaiException {
 936         InputStream is = new FileInputStream(new File("src/test/resources/test.yaml"));
 937         final String yamlString = IOUtils.toString(is, StandardCharsets.UTF_8);
 938
 939         UUID requestId = UUID.randomUUID();
 940         VirtualControlLoopEvent onsetEvent = new VirtualControlLoopEvent();
 941         onsetEvent.setClosedLoopControlName("TwoOnsetTest");
 942         onsetEvent.setRequestId(requestId);
 943         onsetEvent.setTarget("generic-vnf.vnf-id");
 944         onsetEvent.setClosedLoopAlarmStart(Instant.now());
 945         onsetEvent.setClosedLoopEventStatus(ControlLoopEventStatus.ONSET);
 946         onsetEvent.setAai(new HashMap<>());
 947         onsetEvent.getAai().put("generic-vnf.vnf-name", "onsetOne");
 948
 949         ControlLoopEventManager manager = makeManager(onsetEvent);
 950         manager.queryAai(onsetEvent);
 951
 952         VirtualControlLoopNotification notification = manager.activate(yamlString, onsetEvent);
 953         assertNotNull(notification);
 954         assertEquals(ControlLoopNotificationType.ACTIVE, notification.getNotification());
 955
 956         // repeat query with same manager
 957         manager.queryAai(onsetEvent);
 958
 959         // remaining queries each use their own manager so they will be re-executed
 960
 961         makeManager(onsetEvent).queryAai(onsetEvent);
 962
 963         onsetEvent.getAai().put("generic-vnf.is-closed-loop-disabled", "true");
 964         try {
 965             makeManager(onsetEvent).queryAai(onsetEvent);
 966             fail("test should throw an exception here");
 967         } catch (Exception e) {
 968             assertEquals("is-closed-loop-disabled is set to true on VServer or VNF", e.getMessage());
 969         }
 970         onsetEvent.getAai().put("vserver.is-closed-loop-disabled", "true");
 971         try {
 972             makeManager(onsetEvent).queryAai(onsetEvent);
 973             fail("test should throw an exception here");
 974         } catch (Exception e) {
 975             assertEquals("is-closed-loop-disabled is set to true on VServer or VNF", e.getMessage());
 976         }
 977         onsetEvent.getAai().remove("generic-vnf.is-closed-loop-disabled");
 978         try {
 979             makeManager(onsetEvent).queryAai(onsetEvent);
 980             fail("test should throw an exception here");
 981         } catch (Exception e) {
 982             assertEquals("is-closed-loop-disabled is set to true on VServer or VNF", e.getMessage());
 983         }
 984         onsetEvent.getAai().remove("vserver.is-closed-loop-disabled");
 985         makeManager(onsetEvent).queryAai(onsetEvent);
 986
 987         onsetEvent.getAai().put("generic-vnf.is-closed-loop-disabled", "false");
 988         makeManager(onsetEvent).queryAai(onsetEvent);
 989
 990         onsetEvent.getAai().remove("generic-vnf.is-closed-loop-disabled");
 991         onsetEvent.getAai().put("vserver.is-closed-loop-disabled", "false");
 992         makeManager(onsetEvent).queryAai(onsetEvent);
 993
 994         onsetEvent.getAai().remove("generic-vnf.vnf-id");
 995         onsetEvent.getAai().remove("generic-vnf.vnf-name");
 996         onsetEvent.getAai().remove("vserver.vserver-name");
 997         onsetEvent.getAai().remove("generic-vnf.is-closed-loop-disabled");
 998         onsetEvent.getAai().remove("vserver.is-closed-loop-disabled");
 999         makeManager(onsetEvent).queryAai(onsetEvent);
1000
1001         onsetEvent.getAai().put("vserver.vserver-name", "AVserver");
1002         makeManager(onsetEvent).queryAai(onsetEvent);
1003
1004         onsetEvent.getAai().put("generic-vnf.vnf-name", "AVNFName");
1005         makeManager(onsetEvent).queryAai(onsetEvent);
1006
1007         onsetEvent.getAai().put("generic-vnf.vnf-id", "AVNFID");
1008         makeManager(onsetEvent).queryAai(onsetEvent);
1009
1010         onsetEvent.getAai().remove("vserver.vserver-name");
1011         makeManager(onsetEvent).queryAai(onsetEvent);
1012
1013         onsetEvent.getAai().remove("generic-vnf.vnf-name");
1014         makeManager(onsetEvent).queryAai(onsetEvent);
1015
1016         // Force AAI errors
1017         PolicyEngine.manager.setEnvironmentProperty("aai.url", "http://localhost:9999");
1018
1019         try {
1020             makeManager(onsetEvent).queryAai(onsetEvent);
1021             fail("test should throw an exception here");
1022         } catch (Exception e) {
1023             assertEquals("Exception from queryAai: org.onap.policy.aai.util.AaiException: AAI Response is null "
1024                     + "(query by vnf-id)", e.getMessage());
1025         }
1026
1027         onsetEvent.getAai().remove("generic-vnf.vnf-id");
1028         onsetEvent.getAai().put("generic-vnf.vnf-name", "AVNFName");
1029         try {
1030             makeManager(onsetEvent).queryAai(onsetEvent);
1031             fail("test should throw an exception here");
1032         } catch (Exception e) {
1033             assertEquals("Exception from queryAai: org.onap.policy.aai.util.AaiException: AAI Response is null "
1034                     + "(query by vnf-name)", e.getMessage());
1035         }
1036
1037         onsetEvent.getAai().remove("generic-vnf.vnf-name");
1038         onsetEvent.getAai().put("vserver.vserver-name", "AVserver");
1039         try {
1040             makeManager(onsetEvent).queryAai(onsetEvent);
1041             fail("test should throw an exception here");
1042         } catch (Exception e) {
1043             assertEquals("Exception from queryAai: org.onap.policy.aai.util.AaiException: AAI Response is null "
1044                     + "(query by vserver-name)", e.getMessage());
1045         }
1046
1047         PolicyEngine.manager.setEnvironmentProperty("aai.url", "http://localhost:6666");
1048     }
1049
1050     private ControlLoopEventManager makeManager(VirtualControlLoopEvent event) {
1051         return new ControlLoopEventManager(event.getClosedLoopControlName(), event.getRequestId());
1052     }
1053 }