cadi/core/src/main/java/org/onap/aaf/cadi/config/RegistrationPropHolder.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.config;
  22
  23 import java.net.Inet4Address;
  24 import java.net.UnknownHostException;
  25
  26 import org.onap.aaf.cadi.Access;
  27 import org.onap.aaf.cadi.Access.Level;
  28 import org.onap.aaf.cadi.CadiException;
  29 import org.onap.aaf.cadi.util.Split;
  30
  31 public class RegistrationPropHolder {
  32         private final String PUBLIC_NAME="%NS.%N";
  33         private final String REGI="RegistrationProperty: %s='%s'";
  34         private final Access access;
  35         public String hostname;
  36         private int port;
  37         public String public_fqdn;
  38         private Integer public_port;
  39         public Float latitude;
  40         public Float longitude;
  41         public final String default_fqdn;
  42         public final String default_container_ns;
  43         public final String default_name;
  44         public final String lentries;
  45         public final String lcontainer;
  46         public final String default_container;
  47         private static boolean firstlog = true;
  48
  49         public RegistrationPropHolder(final Access access, final int port) throws UnknownHostException, CadiException {
  50                 this.access = access;
  51                 StringBuilder errs = new StringBuilder();
  52                 String str;
  53                 this.port = port;
  54
  55                 lentries=access.getProperty(Config.AAF_LOCATOR_ENTRIES,"");
  56                 default_container = access.getProperty(Config.AAF_LOCATOR_CONTAINER, "");
  57                 if(firstlog) {
  58                         access.printf(Level.INIT, REGI,"default_container",default_container);
  59                 }
  60                 if(!default_container.isEmpty()) {
  61                         lcontainer=',' + default_container; // "" makes a blank default Public Entry
  62                         str = access.getProperty(Config.AAF_LOCATOR_PUBLIC_PORT+'.'+default_container, null);
  63                         if(str==null) {
  64                                 str = access.getProperty(Config.AAF_LOCATOR_PUBLIC_PORT, null);
  65                         }
  66                 } else {
  67                         lcontainer=default_container;
  68                         str = access.getProperty(Config.AAF_LOCATOR_PUBLIC_PORT, null);
  69                 }
  70                 if(str!=null) {
  71                         public_port=Integer.decode(str);
  72                 }
  73                 if(firstlog) {
  74                         access.printf(Level.INIT, "RegistrationProperty: public_port='%d'",public_port);
  75                 }
  76
  77                 hostname = access.getProperty(Config.HOSTNAME, null);
  78                 if (hostname==null) {
  79                         hostname = Inet4Address.getLocalHost().getHostName();
  80                 }
  81                 if (hostname==null) {
  82                         mustBeDefined(errs,Config.HOSTNAME);
  83                 }
  84                 if(firstlog) {
  85                         access.printf(Level.INIT, REGI,"hostname",hostname);
  86                 }
  87
  88                 public_fqdn = access.getProperty(Config.AAF_LOCATOR_PUBLIC_FQDN, hostname);
  89                 if(firstlog) {
  90                         access.printf(Level.INIT, REGI,"public_fqdn",public_fqdn);
  91                 }
  92
  93                 // Allow Container to reset the standard name for public
  94                 String container_public_name = access.getProperty(Config.AAF_LOCATOR_PUBLIC_NAME+'.'+default_container, null);
  95                 if(container_public_name==null) {
  96                         container_public_name = access.getProperty(Config.AAF_LOCATOR_PUBLIC_NAME, null);
  97                         if(container_public_name==null) {
  98                                 container_public_name = access.getProperty(Config.AAF_LOCATOR_NAME, PUBLIC_NAME);
  99                         }
 100                 }
 101                 default_name = container_public_name;
 102
 103                 if(firstlog) {
 104                         access.printf(Level.INIT, REGI,"default_name",default_name);
 105                 }
 106
 107                 latitude=null;
 108                 String slatitude = access.getProperty(Config.CADI_LATITUDE, null);
 109                 if(slatitude == null) {
 110                         mustBeDefined(errs,Config.CADI_LATITUDE);
 111                 } else {
 112                         latitude = Float.parseFloat(slatitude);
 113                 }
 114                 if(firstlog) {
 115                         access.printf(Level.INIT, REGI,"latitude",slatitude);
 116                 }
 117
 118                 longitude=null;
 119                 String slongitude = access.getProperty(Config.CADI_LONGITUDE, null);
 120                 if(slongitude == null) {
 121                         mustBeDefined(errs,Config.CADI_LONGITUDE);
 122                 } else {
 123                         longitude = Float.parseFloat(slongitude);
 124                 }
 125                 if(firstlog) {
 126                         access.printf(Level.INIT, REGI,"longitude",slongitude);
 127                 }
 128
 129                 String dot_le;
 130                 // Note: only one of the ports can be public...  Therefore, only the last
 131                 for(String le : Split.splitTrim(',', lcontainer)) {
 132                         dot_le = le.isEmpty()?le :"."+le;
 133                         str = access.getProperty(Config.AAF_LOCATOR_PUBLIC_FQDN+dot_le,null);
 134                         if( str != null && !str.isEmpty()) {
 135                                 public_fqdn=str;
 136                                 if(firstlog) {
 137                                         access.printf(Level.INIT, "RegistrationProperty: public_hostname(overloaded by %s)='%s'",dot_le,public_fqdn);
 138                                 }
 139                         }
 140                 }
 141
 142                 default_fqdn = access.getProperty(Config.AAF_LOCATOR_FQDN, hostname);
 143                 if(firstlog) {
 144                         access.printf(Level.INIT, REGI,"default_fqdn",default_fqdn);
 145                 }
 146                 default_container_ns = access.getProperty(Config.AAF_LOCATOR_CONTAINER_NS,"");
 147                 if(firstlog) {
 148                         access.printf(Level.INIT, REGI,"default_container_ns",default_container_ns);
 149                 }
 150                 if(errs.length()>0) {
 151                         throw new CadiException(errs.toString());
 152                 }
 153                 firstlog = false;
 154         }
 155
 156         private void mustBeDefined(StringBuilder errs, String propname) {
 157                 errs.append('\n');
 158                 errs.append(propname);
 159                 errs.append(" must be defined.");
 160
 161         }
 162
 163         public String getEntryFQDN(final String entry, final String dot_le) {
 164                 String str;
 165                 if(public_fqdn!=null && dot_le.isEmpty()) {
 166                         str = public_fqdn;
 167                 } else {
 168                         str = access.getProperty(Config.AAF_LOCATOR_FQDN+dot_le, default_fqdn);
 169                 }
 170                 return replacements("RegistrationPropHolder.getEntryFQDN",str,entry,dot_le);
 171         }
 172
 173         public String getEntryName(final String entry, final String dot_le) {
 174                 String str;
 175                 if(dot_le.isEmpty()) {
 176                         str = default_name;
 177                 } else {
 178                         str = access.getProperty(Config.AAF_LOCATOR_NAME+dot_le, default_name);
 179                 }
 180                 return replacements("RegistrationPropHolder.getEntryName",str,entry,dot_le);
 181         }
 182
 183         public String getPublicEntryName(final String entry, final String dot_le) {
 184                 String str = access.getProperty(Config.AAF_LOCATOR_PUBLIC_NAME+dot_le, null);
 185                 if(str==null) {
 186                         str = access.getProperty(Config.AAF_LOCATOR_PUBLIC_NAME,null);
 187                 }
 188                 if(str==null) {
 189                         str = default_name;
 190                 }
 191                 return replacements("RegistrationPropHolder.getEntryName",str,entry,dot_le);
 192         }
 193
 194
 195         private String getNS(String dot_le) {
 196                 String ns;
 197                 ns = access.getProperty(Config.AAF_LOCATOR_APP_NS+dot_le,null);
 198                 if(ns==null) {
 199                         ns = access.getProperty(Config.AAF_LOCATOR_APP_NS, "AAF_NS");
 200                 }
 201                 return ns;
 202         }
 203
 204
 205         public String replacements(final String fromCode, final String source, final String name, final String _dot_le) {
 206                 if(source == null) {
 207                         return "";
 208                 } else if(source.isEmpty()) {
 209                         return source;
 210                 }
 211                 String value = source;
 212                 String dot_le;
 213                 if(_dot_le==null) {
 214                         dot_le = default_container.isEmpty()?"":'.'+default_container;
 215                 } else {
 216                         dot_le = _dot_le;
 217                 }
 218
 219         String aaf_locator_host = access.getProperty(Config.AAF_LOCATE_URL+dot_le,null);
 220         if(aaf_locator_host==null) {
 221                 aaf_locator_host = access.getProperty(Config.AAF_LOCATE_URL,null);
 222         }
 223
 224         String str;
 225         if(aaf_locator_host!=null) {
 226                         if("https://AAF_LOCATE_URL".equals(value)) {
 227                                 value = aaf_locator_host;
 228                         } else {
 229                         str = aaf_locator_host;
 230                                 if(value.indexOf(Config.AAF_LOCATE_URL_TAG)>=0) {
 231                                         if(!str.endsWith("/")) {
 232                                                 str+='/';
 233                                         }
 234                                         if(!str.endsWith("/locate/")) {
 235                                                 str+="locate/";
 236                                         }
 237                                         if(value.startsWith("http:")) {
 238                                                 value = value.replace("http://AAF_LOCATE_URL/", str);
 239                                         } else {
 240                                                 value = value.replace("https://AAF_LOCATE_URL/", str);
 241
 242                                         }
 243                                 }
 244                         }
 245         }
 246
 247                 int atC = value.indexOf("%C");
 248                 if(atC>=0) {
 249                         // aaf_locator_container_ns
 250                         str = access.getProperty(Config.AAF_LOCATOR_CONTAINER_NS+dot_le, default_container_ns);
 251                         if(str.isEmpty()) {
 252                                 value = value.replace("%CNS"+'.', str);
 253                         }
 254                         value = value.replace("%CNS", str);
 255
 256                         str = access.getProperty(Config.AAF_LOCATOR_CONTAINER+dot_le,default_container);
 257                         if(str.isEmpty()) {
 258                                 value = value.replace("%C"+'.', str);
 259                         }
 260                         value = value.replace("%C", str);
 261                 }
 262
 263                 if(value.indexOf("%NS")>=0) {
 264                         str = getNS(dot_le);
 265                         if(str==null || str.isEmpty()) {
 266                                 value = value.replace("%NS"+'.', "");
 267                         } else {
 268                                 value = value.replace("%NS", str);
 269                         }
 270                 }
 271
 272                 // aaf_root_ns
 273                 if(value.indexOf("AAF_NS")>=0) {
 274                         str = access.getProperty(Config.AAF_ROOT_NS, Config.AAF_ROOT_NS_DEF) + '.';
 275                         String temp = value.replace("%AAF_NS.", str);
 276                         if(temp.equals(value)) { // intended
 277                                 value = value.replace("AAF_NS.", str); // Backward Compatibility
 278                         } else {
 279                                 value = temp;
 280                         }
 281                 }
 282
 283
 284                 if(value.indexOf('%')>=0) {
 285             // These shouldn't be expected to have dot elements
 286             if(name!=null) {
 287               value = value.replace("%N", name);
 288             }
 289             if(default_fqdn!=null) {
 290               value = value.replace("%DF", default_fqdn);
 291             }
 292             if(public_fqdn!=null) {
 293               value = value.replace("%PH", public_fqdn);
 294             }
 295                 }
 296                 access.printf(Level.DEBUG,
 297                                 "RegistrationReplacement from %s, source: %s, dot_le: %s, value: %s",
 298                                 fromCode,source,dot_le,value);
 299
 300                 return value;
 301         }
 302
 303         public int getEntryPort(final String dot_le) {
 304                 return public_port!=null && dot_le.isEmpty()?
 305                                 public_port:
 306                                 port;
 307         }
 308
 309         public Access access() {
 310                 return access;
 311         }
 312 }