cadi/aaf/src/test/java/org/onap/aaf/cadi/register/test/JU_RegistrationCreator.java

   1 /**
   2  * ============LICENSE_START====================================================
   3  * org.onap.aaf
   4  * ===========================================================================
   5  * Copyright (c) 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.aaf.cadi.register.test;
  22
  23 import static org.junit.Assert.assertEquals;
  24 import static org.junit.Assert.fail;
  25
  26 import java.net.Inet4Address;
  27 import java.net.UnknownHostException;
  28
  29 import org.junit.Test;
  30 import org.mockito.internal.configuration.DefaultInjectionEngine;
  31 import org.onap.aaf.cadi.CadiException;
  32 import org.onap.aaf.cadi.PropAccess;
  33 import org.onap.aaf.cadi.config.Config;
  34 import org.onap.aaf.cadi.register.RegistrationCreator;
  35
  36 import junit.framework.Assert;
  37 import locate.v1_0.MgmtEndpoint;
  38
  39 public class JU_RegistrationCreator {
  40
  41     private static final String DOT_OOM = ".oom";
  42
  43     @Test
  44     public void test() {
  45         PropAccess pa = new PropAccess();
  46         pa.setProperty(Config.CADI_LATITUDE, "32.7");
  47         pa.setProperty(Config.CADI_LONGITUDE, "-72.0");
  48         pa.setProperty(Config.AAF_LOCATOR_NAME, "");
  49
  50         try {
  51             String hostname = Inet4Address.getLocalHost().getHostName();
  52             String entry = "";
  53             RegistrationCreator rc = new RegistrationCreator(pa);
  54             int port = 999;
  55             for(MgmtEndpoint me : rc.create(port).getMgmtEndpoint()) {
  56                 assertEquals(hostname,me.getHostname());
  57                 assertEquals(port,me.getPort());
  58                 assertEquals(pa.getProperty(Config.CADI_LATITUDE),Float.toString(me.getLatitude()));
  59                 assertEquals(pa.getProperty(Config.CADI_LONGITUDE),Float.toString(me.getLongitude()));
  60                 assertEquals(2,me.getMajor());
  61                 assertEquals(1,me.getMinor());
  62                 assertEquals(0,me.getPatch());
  63                 assertEquals(0,me.getPkg());
  64                 assertEquals(entry,me.getName());
  65                 assertEquals("https",me.getProtocol());
  66                 assertEquals(0,me.getSpecialPorts().size());
  67             }
  68
  69             String protocol = "http";
  70             pa.setProperty(Config.AAF_LOCATOR_PROTOCOL, protocol);
  71             rc = new RegistrationCreator(pa);
  72             for(MgmtEndpoint me : rc.create(port).getMgmtEndpoint()) {
  73                 assertEquals(hostname,me.getHostname());
  74                 assertEquals(port,me.getPort());
  75                 assertEquals(pa.getProperty(Config.CADI_LATITUDE),Float.toString(me.getLatitude()));
  76                 assertEquals(pa.getProperty(Config.CADI_LONGITUDE),Float.toString(me.getLongitude()));
  77                 assertEquals(2,me.getMajor());
  78                 assertEquals(1,me.getMinor());
  79                 assertEquals(0,me.getPatch());
  80                 assertEquals(0,me.getPkg());
  81                 assertEquals("",me.getName());
  82                 assertEquals(protocol,me.getProtocol());
  83                 assertEquals(0,me.getSpecialPorts().size());
  84             }
  85
  86             pa.setProperty(Config.AAF_LOCATOR_ENTRIES, "service");
  87             rc = new RegistrationCreator(pa);
  88             for(MgmtEndpoint me : rc.create(port).getMgmtEndpoint()) {
  89                 switch(me.getName()) {
  90                     case "":
  91                         assertEquals(hostname,me.getHostname());
  92                         assertEquals(port,me.getPort());
  93                         break;
  94                     case "service":
  95                         assertEquals(hostname,me.getHostname());
  96                         assertEquals(port,me.getPort());
  97                         break;
  98                     default:
  99                         fail("unknown Locator Entry");
 100                 }
 101                 assertEquals(pa.getProperty(Config.CADI_LATITUDE),Float.toString(me.getLatitude()));
 102                 assertEquals(pa.getProperty(Config.CADI_LONGITUDE),Float.toString(me.getLongitude()));
 103                 assertEquals(2,me.getMajor());
 104                 assertEquals(1,me.getMinor());
 105                 assertEquals(0,me.getPatch());
 106                 assertEquals(0,me.getPkg());
 107                 assertEquals(protocol,me.getProtocol());
 108                 assertEquals(0,me.getSpecialPorts().size());
 109             }
 110
 111             entry = "service";
 112             pa.setProperty(Config.AAF_LOCATOR_ENTRIES, entry);
 113             rc = new RegistrationCreator(pa);
 114             for(MgmtEndpoint me : rc.create(port).getMgmtEndpoint()) {
 115                 switch(me.getName()) {
 116                     case "":
 117                         assertEquals(hostname,me.getHostname());
 118                         assertEquals(port,me.getPort());
 119                         break;
 120                     case "service":
 121                         assertEquals(hostname,me.getHostname());
 122                         assertEquals(port,me.getPort());
 123                         break;
 124                     default:
 125                         fail("unknown Locator Entry");
 126                 }
 127                 assertEquals(pa.getProperty(Config.CADI_LATITUDE),Float.toString(me.getLatitude()));
 128                 assertEquals(pa.getProperty(Config.CADI_LONGITUDE),Float.toString(me.getLongitude()));
 129                 assertEquals(2,me.getMajor());
 130                 assertEquals(1,me.getMinor());
 131                 assertEquals(0,me.getPatch());
 132                 assertEquals(0,me.getPkg());
 133                 assertEquals(protocol,me.getProtocol());
 134                 assertEquals(0,me.getSpecialPorts().size());
 135             }
 136
 137             pa.setProperty(Config.AAF_LOCATOR_CONTAINER, "oom");
 138             pa.setProperty(Config.AAF_ROOT_NS, Config.AAF_ROOT_NS_DEF);
 139             pa.setProperty(Config.AAF_LOCATOR_NAME,"%NS.%N");
 140             pa.setProperty(Config.AAF_LOCATOR_NAME+DOT_OOM,"%CNS.%NS.%N");
 141             pa.setProperty(Config.AAF_LOCATOR_CONTAINER_NS+DOT_OOM, "onap");
 142             String k8s_public_hostname="k8s.public.com";
 143             int public_port = 30001;
 144
 145             pa.setProperty(Config.AAF_LOCATOR_PUBLIC_FQDN,k8s_public_hostname);
 146             pa.setProperty(Config.AAF_LOCATOR_PUBLIC_PORT+DOT_OOM,Integer.toString(public_port));
 147             pa.setProperty(Config.AAF_LOCATOR_APP_NS, Config.AAF_ROOT_NS_DEF);
 148             rc = new RegistrationCreator(pa);
 149             for(MgmtEndpoint me : rc.create(port).getMgmtEndpoint()) {
 150                 switch(me.getName()) {
 151                     case "org.osaaf.aaf.service":
 152                         assertEquals(k8s_public_hostname,me.getHostname());
 153                         assertEquals(public_port,me.getPort());
 154                         break;
 155                     case "onap.org.osaaf.aaf.service":
 156                         assertEquals(hostname,me.getHostname());
 157                         assertEquals(port,me.getPort());
 158                         break;
 159                     default:
 160                         fail("unknown Entry Name, " + me.getName());
 161                 }
 162                 assertEquals(pa.getProperty(Config.CADI_LATITUDE),Float.toString(me.getLatitude()));
 163                 assertEquals(pa.getProperty(Config.CADI_LONGITUDE),Float.toString(me.getLongitude()));
 164                 assertEquals(2,me.getMajor());
 165                 assertEquals(1,me.getMinor());
 166                 assertEquals(0,me.getPatch());
 167                 assertEquals(0,me.getPkg());
 168                 assertEquals(protocol,me.getProtocol());
 169                 assertEquals(0,me.getSpecialPorts().size());
 170             }
 171
 172
 173         } catch (CadiException | UnknownHostException e) {
 174             Assert.fail(e.getMessage());
 175         }
 176
 177
 178     }
 179
 180 }