resource-assignment/provider/src/test/java/jtest/org/onap/ccsdk/sli/adaptors/ra/TestRelease.java

   1 /*-
   2  * ============LICENSE_START=======================================================
   3  * openECOMP : SDN-C
   4  * ================================================================================
   5  * Copyright (C) 2017 AT&T Intellectual Property. All rights
   6  *                         reserved.
   7  * ================================================================================
   8  * Licensed under the Apache License, Version 2.0 (the "License");
   9  * you may not use this file except in compliance with the License.
  10  * You may obtain a copy of the License at
  11  *
  12  *      http://www.apache.org/licenses/LICENSE-2.0
  13  *
  14  * Unless required by applicable law or agreed to in writing, software
  15  * distributed under the License is distributed on an "AS IS" BASIS,
  16  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  17  * See the License for the specific language governing permissions and
  18  * limitations under the License.
  19  * ============LICENSE_END=========================================================
  20  */
  21
  22 package jtest.org.onap.ccsdk.sli.adaptors.ra;
  23
  24 import org.junit.Assert;
  25 import org.junit.FixMethodOrder;
  26 import org.junit.Test;
  27 import org.junit.runner.RunWith;
  28 import org.junit.runners.MethodSorters;
  29 import org.onap.ccsdk.sli.core.sli.SvcLogicContext;
  30 import org.onap.ccsdk.sli.core.sli.SvcLogicException;
  31 import org.onap.ccsdk.sli.core.sli.SvcLogicResource.QueryStatus;
  32 import org.onap.ccsdk.sli.adaptors.ra.ResourceAllocator;
  33 import org.slf4j.Logger;
  34 import org.slf4j.LoggerFactory;
  35 import org.springframework.beans.factory.annotation.Autowired;
  36 import org.springframework.test.context.ContextConfiguration;
  37 import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;
  38
  39 @RunWith(SpringJUnit4ClassRunner.class)
  40 @ContextConfiguration(locations = { "classpath:test-context.xml" })
  41 @FixMethodOrder(MethodSorters.NAME_ASCENDING)
  42 public class TestRelease {
  43
  44     private static final Logger log = LoggerFactory.getLogger(TestRelease.class);
  45
  46     @Autowired(required = true)
  47     private ResourceAllocator resourceAllocator;
  48
  49     @Autowired(required = true)
  50     private DataSetup dataSetup;
  51
  52     @Test
  53     public void test001() throws Exception {
  54         String t = "001";
  55         log.info("============== release " + t + " ================================");
  56         log.info("=== Test release - cancel - new start");
  57
  58         String service1 = "release" + t + "/service1";
  59
  60         dataSetup.cleanup();
  61         dataSetup.setupVpePort("MTSNJA4LCP1", "mtanjrsv126", "ae0", "PROV", "juniper-vpe-image");
  62         dataSetup.setupVplspePort("MTSNJA4LCP1", "mtsnj303vr1", "xe-0/0/2", "PROV", null);
  63         dataSetup.setupService(service1, "Pending", 2, 200000, "mtanjrsv126", "mtsnj303vr1", "MTSNJA4LCP1/Server1");
  64
  65         Assert.assertTrue(dataSetup.serviceCorrectInDb(service1, "Pending", 2, 200000));
  66
  67         SvcLogicContext ctx = new SvcLogicContext();
  68         ctx.setAttribute("tmp.resource-allocator.request-type", "Cancel");
  69         ctx.setAttribute("tmp.resource-allocator.service-instance-id", service1);
  70
  71         QueryStatus st = resourceAllocator.release("NetworkCapacity", null, ctx);
  72
  73         log.info("Result: " + st);
  74
  75         Assert.assertTrue(st == QueryStatus.SUCCESS);
  76         Assert.assertTrue(dataSetup.serviceNotInDb(service1, null, null));
  77     }
  78
  79     @Test
  80     public void test002() throws Exception {
  81         String t = "002";
  82         log.info("============== release " + t + " ================================");
  83         log.info("=== Test release - cancel - change");
  84
  85         String service1 = "release" + t + "/service1";
  86
  87         dataSetup.cleanup();
  88         dataSetup.setupVpePort("MTSNJA4LCP1", "mtanjrsv126", "ae0", "PROV", "juniper-vpe-image");
  89         dataSetup.setupVplspePort("MTSNJA4LCP1", "mtsnj303vr1", "xe-0/0/2", "PROV", null);
  90         dataSetup.setupService(service1, "Active", 2, 200000, "mtanjrsv126", "mtsnj303vr1", "MTSNJA4LCP1/Server1");
  91         dataSetup.setupService(service1, "Pending", 3, 400000, "mtanjrsv126", "mtsnj303vr1", "MTSNJA4LCP1/Server1");
  92
  93         Assert.assertTrue(dataSetup.serviceCorrectInDb(service1, "Active", 2, 200000));
  94         Assert.assertTrue(dataSetup.serviceCorrectInDb(service1, "Pending", 3, 400000));
  95
  96         SvcLogicContext ctx = new SvcLogicContext();
  97         ctx.setAttribute("tmp.resource-allocator.request-type", "Cancel");
  98         ctx.setAttribute("tmp.resource-allocator.service-instance-id", service1);
  99
 100         QueryStatus st = resourceAllocator.release("NetworkCapacity", null, ctx);
 101
 102         log.info("Result: " + st);
 103
 104         Assert.assertTrue(st == QueryStatus.SUCCESS);
 105         Assert.assertTrue(dataSetup.serviceCorrectInDb(service1, "Active", 2, 200000));
 106         Assert.assertTrue(dataSetup.serviceNotInDb(service1, null, 3));
 107     }
 108
 109     @Test
 110     public void test003() throws Exception {
 111         String t = "003";
 112         log.info("============== release " + t + " ================================");
 113         log.info("=== Test release - cancel - active there, but no pending - should do nothing and return success");
 114
 115         String service1 = "release" + t + "/service1";
 116
 117         dataSetup.cleanup();
 118         dataSetup.setupVpePort("MTSNJA4LCP1", "mtanjrsv126", "ae0", "PROV", "juniper-vpe-image");
 119         dataSetup.setupVplspePort("MTSNJA4LCP1", "mtsnj303vr1", "xe-0/0/2", "PROV", null);
 120         dataSetup.setupService(service1, "Active", 2, 200000, "mtanjrsv126", "mtsnj303vr1", "MTSNJA4LCP1/Server1");
 121
 122         Assert.assertTrue(dataSetup.serviceCorrectInDb(service1, "Active", 2, 200000));
 123
 124         SvcLogicContext ctx = new SvcLogicContext();
 125         ctx.setAttribute("tmp.resource-allocator.request-type", "Cancel");
 126         ctx.setAttribute("tmp.resource-allocator.service-instance-id", service1);
 127
 128         QueryStatus st = resourceAllocator.release("NetworkCapacity", null, ctx);
 129
 130         log.info("Result: " + st);
 131
 132         Assert.assertTrue(st == QueryStatus.SUCCESS);
 133         Assert.assertTrue(dataSetup.serviceCorrectInDb(service1, "Active", 2, 200000));
 134     }
 135
 136     @Test
 137     public void test004() throws Exception {
 138         String t = "004";
 139         log.info("============== release " + t + " ================================");
 140         log.info("=== Test release - cancel - nothing in DB - should return success");
 141
 142         String service1 = "release" + t + "/service1";
 143
 144         dataSetup.cleanup();
 145
 146         SvcLogicContext ctx = new SvcLogicContext();
 147         ctx.setAttribute("tmp.resource-allocator.request-type", "Cancel");
 148         ctx.setAttribute("tmp.resource-allocator.service-instance-id", service1);
 149
 150         QueryStatus st = resourceAllocator.release("NetworkCapacity", null, ctx);
 151
 152         log.info("Result: " + st);
 153
 154         Assert.assertTrue(st == QueryStatus.SUCCESS);
 155         Assert.assertTrue(dataSetup.serviceNotInDb(service1, null, null));
 156     }
 157
 158     @Test
 159     public void test005() throws Exception {
 160         String t = "005";
 161         log.info("============== release " + t + " ================================");
 162         log.info("=== Test release - activate - new start");
 163
 164         String service1 = "release" + t + "/service1";
 165
 166         dataSetup.cleanup();
 167         dataSetup.setupVpePort("MTSNJA4LCP1", "mtanjrsv126", "ae0", "PROV", "juniper-vpe-image");
 168         dataSetup.setupVplspePort("MTSNJA4LCP1", "mtsnj303vr1", "xe-0/0/2", "PROV", null);
 169         dataSetup.setupService(service1, "Pending", 2, 200000, "mtanjrsv126", "mtsnj303vr1", "MTSNJA4LCP1/Server1");
 170
 171         Assert.assertTrue(dataSetup.serviceCorrectInDb(service1, "Pending", 2, 200000));
 172
 173         SvcLogicContext ctx = new SvcLogicContext();
 174         ctx.setAttribute("tmp.resource-allocator.request-type", "Activate");
 175         ctx.setAttribute("tmp.resource-allocator.service-instance-id", service1);
 176
 177         QueryStatus st = resourceAllocator.release("NetworkCapacity", null, ctx);
 178
 179         log.info("Result: " + st);
 180
 181         Assert.assertTrue(st == QueryStatus.SUCCESS);
 182         Assert.assertTrue(dataSetup.serviceCorrectInDb(service1, "Active", 2, 200000));
 183     }
 184
 185     @Test
 186     public void test006() throws Exception {
 187         String t = "006";
 188         log.info("============== release " + t + " ================================");
 189         log.info("=== Test release - actovate - change");
 190
 191         String service1 = "release" + t + "/service1";
 192
 193         dataSetup.cleanup();
 194         dataSetup.setupVpePort("MTSNJA4LCP1", "mtanjrsv126", "ae0", "PROV", "juniper-vpe-image");
 195         dataSetup.setupVplspePort("MTSNJA4LCP1", "mtsnj303vr1", "xe-0/0/2", "PROV", null);
 196         dataSetup.setupService(service1, "Active", 2, 200000, "mtanjrsv126", "mtsnj303vr1", "MTSNJA4LCP1/Server1");
 197         dataSetup.setupService(service1, "Pending", 3, 400000, "mtanjrsv126", "mtsnj303vr1", "MTSNJA4LCP1/Server1");
 198
 199         Assert.assertTrue(dataSetup.serviceCorrectInDb(service1, "Active", 2, 200000));
 200         Assert.assertTrue(dataSetup.serviceCorrectInDb(service1, "Pending", 3, 400000));
 201
 202         SvcLogicContext ctx = new SvcLogicContext();
 203         ctx.setAttribute("tmp.resource-allocator.request-type", "Activate");
 204         ctx.setAttribute("tmp.resource-allocator.service-instance-id", service1);
 205
 206         QueryStatus st = resourceAllocator.release("NetworkCapacity", null, ctx);
 207
 208         log.info("Result: " + st);
 209
 210         Assert.assertTrue(st == QueryStatus.SUCCESS);
 211         Assert.assertTrue(dataSetup.serviceCorrectInDb(service1, "Active", 3, 400000));
 212         Assert.assertTrue(dataSetup.serviceNotInDb(service1, null, 2));
 213     }
 214
 215     @Test
 216     public void test007() throws Exception {
 217         String t = "007";
 218         log.info("============== release " + t + " ================================");
 219         log.info("=== Test release - activate - active there, but no pending - should do nothing and return success");
 220
 221         String service1 = "release" + t + "/service1";
 222
 223         dataSetup.cleanup();
 224         dataSetup.setupVpePort("MTSNJA4LCP1", "mtanjrsv126", "ae0", "PROV", "juniper-vpe-image");
 225         dataSetup.setupVplspePort("MTSNJA4LCP1", "mtsnj303vr1", "xe-0/0/2", "PROV", null);
 226         dataSetup.setupService(service1, "Active", 2, 200000, "mtanjrsv126", "mtsnj303vr1", "MTSNJA4LCP1/Server1");
 227
 228         Assert.assertTrue(dataSetup.serviceCorrectInDb(service1, "Active", 2, 200000));
 229
 230         SvcLogicContext ctx = new SvcLogicContext();
 231         ctx.setAttribute("tmp.resource-allocator.request-type", "Activate");
 232         ctx.setAttribute("tmp.resource-allocator.service-instance-id", service1);
 233
 234         QueryStatus st = resourceAllocator.release("NetworkCapacity", null, ctx);
 235
 236         log.info("Result: " + st);
 237
 238         Assert.assertTrue(st == QueryStatus.SUCCESS);
 239         Assert.assertTrue(dataSetup.serviceCorrectInDb(service1, "Active", 2, 200000));
 240     }
 241
 242     @Test
 243     public void test008() throws Exception {
 244         String t = "008";
 245         log.info("============== release " + t + " ================================");
 246         log.info("=== Test release - activate - nothing in DB - should return success");
 247
 248         String service1 = "release" + t + "/service1";
 249
 250         dataSetup.cleanup();
 251
 252         SvcLogicContext ctx = new SvcLogicContext();
 253         ctx.setAttribute("tmp.resource-allocator.request-type", "Activate");
 254         ctx.setAttribute("tmp.resource-allocator.service-instance-id", service1);
 255
 256         QueryStatus st = resourceAllocator.release("NetworkCapacity", null, ctx);
 257
 258         log.info("Result: " + st);
 259
 260         Assert.assertTrue(st == QueryStatus.SUCCESS);
 261         Assert.assertTrue(dataSetup.serviceNotInDb(service1, null, null));
 262     }
 263
 264     @Test
 265     public void test009() throws Exception {
 266         String t = "009";
 267         log.info("============== release " + t + " ================================");
 268         log.info("=== Test release - disconnect - only pending in DB");
 269
 270         String service1 = "release" + t + "/service1";
 271
 272         dataSetup.cleanup();
 273         dataSetup.setupVpePort("MTSNJA4LCP1", "mtanjrsv126", "ae0", "PROV", "juniper-vpe-image");
 274         dataSetup.setupVplspePort("MTSNJA4LCP1", "mtsnj303vr1", "xe-0/0/2", "PROV", null);
 275         dataSetup.setupService(service1, "Pending", 2, 200000, "mtanjrsv126", "mtsnj303vr1", "MTSNJA4LCP1/Server1");
 276
 277         Assert.assertTrue(dataSetup.serviceCorrectInDb(service1, "Pending", 2, 200000));
 278
 279         SvcLogicContext ctx = new SvcLogicContext();
 280         ctx.setAttribute("tmp.resource-allocator.request-type", "Disconnect");
 281         ctx.setAttribute("tmp.resource-allocator.service-instance-id", service1);
 282
 283         QueryStatus st = resourceAllocator.release("NetworkCapacity", null, ctx);
 284
 285         log.info("Result: " + st);
 286
 287         Assert.assertTrue(st == QueryStatus.SUCCESS);
 288         Assert.assertTrue(dataSetup.serviceNotInDb(service1, null, null));
 289     }
 290
 291     @Test
 292     public void test010() throws Exception {
 293         String t = "010";
 294         log.info("============== release " + t + " ================================");
 295         log.info("=== Test release - disconnect - only active in DB");
 296
 297         String service1 = "release" + t + "/service1";
 298
 299         dataSetup.cleanup();
 300         dataSetup.setupVpePort("MTSNJA4LCP1", "mtanjrsv126", "ae0", "PROV", "juniper-vpe-image");
 301         dataSetup.setupVplspePort("MTSNJA4LCP1", "mtsnj303vr1", "xe-0/0/2", "PROV", null);
 302         dataSetup.setupService(service1, "Active", 2, 200000, "mtanjrsv126", "mtsnj303vr1", "MTSNJA4LCP1/Server1");
 303
 304         Assert.assertTrue(dataSetup.serviceCorrectInDb(service1, "Active", 2, 200000));
 305
 306         SvcLogicContext ctx = new SvcLogicContext();
 307         ctx.setAttribute("tmp.resource-allocator.request-type", "Disconnect");
 308         ctx.setAttribute("tmp.resource-allocator.service-instance-id", service1);
 309
 310         QueryStatus st = resourceAllocator.release("NetworkCapacity", null, ctx);
 311
 312         log.info("Result: " + st);
 313
 314         Assert.assertTrue(st == QueryStatus.SUCCESS);
 315         Assert.assertTrue(dataSetup.serviceNotInDb(service1, null, null));
 316     }
 317
 318     @Test
 319     public void test011() throws Exception {
 320         String t = "011";
 321         log.info("============== release " + t + " ================================");
 322         log.info("=== Test release - disconnect - both active and pending in DB");
 323
 324         String service1 = "release" + t + "/service1";
 325
 326         dataSetup.cleanup();
 327         dataSetup.setupVpePort("MTSNJA4LCP1", "mtanjrsv126", "ae0", "PROV", "juniper-vpe-image");
 328         dataSetup.setupVplspePort("MTSNJA4LCP1", "mtsnj303vr1", "xe-0/0/2", "PROV", null);
 329         dataSetup.setupService(service1, "Active", 2, 200000, "mtanjrsv126", "mtsnj303vr1", "MTSNJA4LCP1/Server1");
 330         dataSetup.setupService(service1, "Pending", 3, 400000, "mtanjrsv126", "mtsnj303vr1", "MTSNJA4LCP1/Server1");
 331
 332         Assert.assertTrue(dataSetup.serviceCorrectInDb(service1, "Active", 2, 200000));
 333         Assert.assertTrue(dataSetup.serviceCorrectInDb(service1, "Pending", 3, 400000));
 334
 335         SvcLogicContext ctx = new SvcLogicContext();
 336         ctx.setAttribute("tmp.resource-allocator.request-type", "Disconnect");
 337         ctx.setAttribute("tmp.resource-allocator.service-instance-id", service1);
 338
 339         QueryStatus st = resourceAllocator.release("NetworkCapacity", null, ctx);
 340
 341         log.info("Result: " + st);
 342
 343         Assert.assertTrue(st == QueryStatus.SUCCESS);
 344         Assert.assertTrue(dataSetup.serviceNotInDb(service1, null, null));
 345     }
 346
 347     @Test
 348     public void test012() throws Exception {
 349         String t = "012";
 350         log.info("============== release " + t + " ================================");
 351         log.info("=== Test release - disconnect - nothing in DB - should return success");
 352
 353         String service1 = "release" + t + "/service1";
 354
 355         dataSetup.cleanup();
 356
 357         SvcLogicContext ctx = new SvcLogicContext();
 358         ctx.setAttribute("tmp.resource-allocator.request-type", "Disconnect");
 359         ctx.setAttribute("tmp.resource-allocator.service-instance-id", service1);
 360
 361         QueryStatus st = resourceAllocator.release("NetworkCapacity", null, ctx);
 362
 363         log.info("Result: " + st);
 364
 365         Assert.assertTrue(st == QueryStatus.SUCCESS);
 366         Assert.assertTrue(dataSetup.serviceNotInDb(service1, null, null));
 367     }
 368
 369     @Test
 370     public void test013() throws Exception {
 371         String t = "013";
 372         log.info("============== release " + t + " ================================");
 373         log.info("=== Test input validations - request-type missing in input");
 374
 375         String service1 = "release" + t + "/service1";
 376
 377         SvcLogicContext ctx = new SvcLogicContext();
 378         ctx.setAttribute("tmp.resource-allocator.service-instance-id", service1);
 379
 380         try {
 381             resourceAllocator.release("NetworkCapacity", null, ctx);
 382         } catch (SvcLogicException e) {
 383             Assert.assertTrue(e.getMessage().equals(
 384                     "tmp.resource-allocator.request-type is required in ResourceAllocator"));
 385             return;
 386         }
 387         Assert.fail("SvcLogicException expected");
 388     }
 389
 390     @Test
 391     public void test014() throws Exception {
 392         String t = "014";
 393         log.info("============== release " + t + " ================================");
 394         log.info("=== Test input validations - invalid request-type in input");
 395
 396         String service1 = "release" + t + "/service1";
 397
 398         SvcLogicContext ctx = new SvcLogicContext();
 399         ctx.setAttribute("tmp.resource-allocator.request-type", "xxxxx");
 400         ctx.setAttribute("tmp.resource-allocator.service-instance-id", service1);
 401
 402         try {
 403             resourceAllocator.release("NetworkCapacity", null, ctx);
 404         } catch (SvcLogicException e) {
 405             Assert.assertTrue(e.getMessage().equals(
 406                     "Invalid tmp.resource-allocator.request-type: xxxxx. Supported values are Cancel, Activate, Disconnect."));
 407             return;
 408         }
 409         Assert.fail("SvcLogicException expected");
 410     }
 411
 412     @Test
 413     public void test015() throws Exception {
 414         String t = "015";
 415         log.info("============== release " + t + " ================================");
 416         log.info("=== Test input validations - missing service-instance-id in input");
 417
 418         SvcLogicContext ctx = new SvcLogicContext();
 419         ctx.setAttribute("tmp.resource-allocator.request-type", "Cancel");
 420
 421         try {
 422             resourceAllocator.release("NetworkCapacity", null, ctx);
 423         } catch (SvcLogicException e) {
 424             Assert.assertTrue(e.getMessage().equals(
 425                     "tmp.resource-allocator.service-instance-id is required in ResourceAllocator"));
 426             return;
 427         }
 428         Assert.fail("SvcLogicException expected");
 429     }
 430 }