gerrit.onap Code Review - ccsdk/features.git/blob

   1 /*
   2  * ============LICENSE_START=======================================================
   3  * ONAP : ccsdk feature sdnr wt
   4  *  ================================================================================
   5  * Copyright (C) 2019 highstreet technologies GmbH Intellectual Property.
   6  * All rights 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 package org.onap.ccsdk.features.sdnr.wt.devicemanager.test;
  22
  23 import static org.junit.Assert.assertNotNull;
  24 import static org.junit.Assert.assertTrue;
  25 import static org.junit.Assert.fail;
  26 import com.google.common.io.Files;
  27 import java.io.File;
  28 import java.io.IOException;
  29 import java.nio.charset.StandardCharsets;
  30 import org.junit.After;
  31 import org.junit.Before;
  32 import org.junit.Test;
  33 import org.onap.ccsdk.features.sdnr.wt.common.configuration.ConfigurationFileRepresentation;
  34 import org.onap.ccsdk.features.sdnr.wt.devicemanager.aaiconnector.impl.config.AaiConfig;
  35 import org.onap.ccsdk.features.sdnr.wt.devicemanager.archiveservice.ArchiveCleanService;
  36 import org.onap.ccsdk.features.sdnr.wt.devicemanager.dcaeconnector.impl.config.DcaeConfig;
  37 import org.onap.ccsdk.features.sdnr.wt.devicemanager.performancemanager.impl.config.PmConfig;
  38 import org.onap.ccsdk.features.sdnr.wt.devicemanager.toggleAlarmFilter.conf.ToggleAlarmConfig;
  39 import org.slf4j.Logger;
  40 import org.slf4j.LoggerFactory;
  41
  42 public class TestDevMgrPropertiesFile {
  43
  44     private static final Logger LOG = LoggerFactory.getLogger(ArchiveCleanService.class);
  45
  46     private static final File FILENAME = new File("testdevmgrpropertiesfile.properties");
  47     private static final File AAIPROP_FILE = new File("testdevmgrpropertiesfileaaiclient.properties");
  48     private int hasChanged;
  49
  50     @Before
  51     public void init() {
  52         delete(FILENAME);
  53         delete(AAIPROP_FILE);
  54     }
  55
  56     @After
  57     public void deinit() {
  58         this.init();
  59     }
  60
  61     @Test
  62     public void testBasicConfiguration() {
  63
  64         writeFile(FILENAME, this.getContent1());
  65         writeFile(AAIPROP_FILE, this.getAaiPropertiesConfig());
  66
  67         LOG.info("Read and verify");
  68         ConfigurationFileRepresentation cfg2 = new ConfigurationFileRepresentation(FILENAME.getPath());
  69
  70         AaiConfig aaiConfig = new AaiConfig(cfg2);
  71         assertNotNull(aaiConfig);
  72         DcaeConfig dcaeConfig = new DcaeConfig(cfg2);
  73         assertNotNull(dcaeConfig);
  74         PmConfig pmConfig = new PmConfig(cfg2);
  75         assertNotNull(pmConfig);
  76         ToggleAlarmConfig toggleAlarmConfig = new ToggleAlarmConfig(cfg2);
  77         assertNotNull(toggleAlarmConfig);
  78
  79         LOG.info("Verify {} ", aaiConfig);
  80     }
  81
  82     //-- Observer not working with all testcases, because config does not support different file types.
  83     @Test
  84     public void testChangeConfiguration() {
  85
  86         LOG.info("Read and verify");
  87
  88         writeFile(FILENAME, this.getContent1());
  89         writeFile(AAIPROP_FILE, this.getAaiPropertiesConfig());
  90
  91         ConfigurationFileRepresentation cfg2 = new ConfigurationFileRepresentation(FILENAME.getPath());
  92         hasChanged = 0;
  93         cfg2.registerConfigChangedListener(() -> {
  94             hasChanged++;
  95             LOG.info("file changed listener triggered: {}", hasChanged);
  96         });
  97
  98         AaiConfig aaiConfig = new AaiConfig(cfg2);
  99         assertNotNull(aaiConfig);
 100         DcaeConfig dcaeConfig = new DcaeConfig(cfg2);
 101         assertNotNull(dcaeConfig);
 102         PmConfig pmConfig = new PmConfig(cfg2);
 103         assertNotNull(pmConfig);
 104         ToggleAlarmConfig toggleAlarmConfig = new ToggleAlarmConfig(cfg2);
 105         assertNotNull(toggleAlarmConfig);
 106
 107         LOG.info("Write new content. Changes {}", hasChanged);
 108         writeFile(FILENAME, this.getContent2());
 109
 110         int i = 10;
 111         while (hasChanged == 0 && i-- > 0) {
 112             LOG.info("Wait for Change indication.");
 113             sleep(1000);
 114         }
 115         LOG.info("Changes {}", hasChanged);
 116
 117         assertTrue("fileChanged counter " + hasChanged, hasChanged > 0);
 118         LOG.info("Test done");
 119
 120     }
 121
 122
 123     private static void sleep(int milliseconds) {
 124         try {
 125             Thread.sleep(milliseconds);
 126         } catch (InterruptedException e) {
 127             Thread.currentThread().interrupt();
 128         }
 129     }
 130
 131     public static void writeFile(File f, String content) {
 132         try {
 133             Files.asCharSink(f, StandardCharsets.UTF_8).write(content);
 134         } catch (IOException e) {
 135             fail(e.getMessage());
 136         } ;
 137         sleep(500);
 138     }
 139
 140     private void delete(File f) {
 141         if (f.exists()) {
 142             f.delete();
 143         }
 144     }
 145
 146
 147     private String getContent2() {
 148         // @formatter:off
 149         return "[dcae]\n" +
 150                 "dcaeUserCredentials=admin:admin\n" +
 151                 "dcaeUrl=http://localhost:45451/abc\n" +
 152                 "dcaeHeartbeatPeriodSeconds=120\n" +
 153                 "dcaeTestCollector=no\n" +
 154                 "\n" +
 155                 "[aots]\n" +
 156                 "userPassword=passwd\n" +
 157                 "soapurladd=off\n" +
 158                 "soapaddtimeout=10\n" +
 159                 "soapinqtimeout=20\n" +
 160                 "userName=user\n" +
 161                 "inqtemplate=inqreq.tmpl.xml\n" +
 162                 "assignedto=userid\n" +
 163                 "addtemplate=addreq.tmpl.xml\n" +
 164                 "severitypassthrough=critical,major,minor,warning\n" +
 165                 "systemuser=user\n" +
 166                 "prt-offset=1200\n" +
 167                 "soapurlinq=off\n" +
 168                 "#smtpHost=\n" +
 169                 "#smtpPort=\n" +
 170                 "#smtpUsername=\n" +
 171                 "#smtpPassword=\n" +
 172                 "#smtpSender=\n" +
 173                 "#smtpReceivers=\n" +
 174                 "\n" +
 175                 "[es]\n" +
 176                 "esCluster=sendateodl5\n" +
 177                 "\n" +
 178                 "[aai]\n" +
 179                 "#keep comment\n" +
 180                 "aaiHeaders=[\"X-TransactionId: 9999\"]\n" +
 181                 "aaiUrl=off\n" +
 182                 "aaiUserCredentials=AAI:AAI\n" +
 183                 "aaiDeleteOnMountpointRemove=true\n" +
 184                 "aaiTrustAllCerts=false\n" +
 185                 "aaiApiVersion=aai/v13\n" +
 186                 "aaiPropertiesFile=aaiclient.properties\n" +
 187                 "aaiApplicationId=SDNR\n" +
 188                 "aaiPcks12ClientCertFile=/opt/logs/externals/data/stores/keystore.client.p12\n" +
 189                 "aaiPcks12ClientCertPassphrase=adminadmin\n" +
 190                 "aaiClientConnectionTimeout=30000\n" +
 191                 "\n" +
 192                 "[pm]\n" +
 193                 "pmCluster=sendateodl5\n" +
 194                 "pmEnabled=true\n" +
 195                 "[toggleAlarmFilter]\n" +
 196                 "taEnabled=true\n" +
 197                 "taDelay=5555\n" +
 198                 "";
 199         // @formatter:on
 200     }
 201
 202     private String getContent1() {
 203         // @formatter:off
 204         return "[dcae]\n" +
 205                 "dcaeUserCredentials=admin:admin\n" +
 206                 "dcaeUrl=http://localhost:45/abc\n" +
 207                 "dcaeHeartbeatPeriodSeconds=120\n" +
 208                 "dcaeTestCollector=no\n" +
 209                 "\n" +
 210                 "[aots]\n" +
 211                 "userPassword=passwd\n" +
 212                 "soapurladd=off\n" +
 213                 "soapaddtimeout=10\n" +
 214                 "soapinqtimeout=20\n" +
 215                 "userName=user\n" +
 216                 "inqtemplate=inqreq.tmpl.xml\n" +
 217                 "assignedto=userid\n" +
 218                 "addtemplate=addreq.tmpl.xml\n" +
 219                 "severitypassthrough=critical,major,minor,warning\n" +
 220                 "systemuser=user\n" +
 221                 "prt-offset=1200\n" +
 222                 "soapurlinq=off\n" +
 223                 "#smtpHost=\n" +
 224                 "#smtpPort=\n" +
 225                 "#smtpUsername=\n" +
 226                 "#smtpPassword=\n" +
 227                 "#smtpSender=\n" +
 228                 "#smtpReceivers=\n" +
 229                 "\n" +
 230                 "[es]\n" +
 231                 "esCluster=sendateodl5\n" +
 232                 "\n" +
 233                 "[aai]\n" +
 234                 "#keep comment\n" +
 235                 "aaiHeaders=[\"X-TransactionId: 9999\"]\n" +
 236                 "aaiUrl=off\n" +
 237                 "aaiUserCredentials=AAI:AAI\n" +
 238                 "aaiDeleteOnMountpointRemove=true\n" +
 239                 "aaiTrustAllCerts=false\n" +
 240                 "aaiApiVersion=aai/v13\n" +
 241                 "aaiPropertiesFile=aaiclient.properties\n" +
 242                 "\n" +
 243                 "[pm]\n" +
 244                 "pmCluster=sendateodl5\n" +
 245                 "pmEnabled=true\n" +
 246                 "[toggleAlarmFilter]\n" +
 247                 "taEnabled=false\n" +
 248                 "taDelay=5555\n" +
 249                 "";
 250         // @formatter:on
 251     }
 252
 253     private String getAaiPropertiesConfig() {
 254         // @formatter:off
 255         return "org.onap.ccsdk.sli.adaptors.aai.ssl.key=keykey\"\"\n" +
 256                 "org.onap.ccsdk.sli.adaptors.aai.ssl.key.psswd=psswdpsswd\"\"\n" +
 257                 "org.onap.ccsdk.sli.adaptors.aai.host.certificate.ignore=\"false\"\n" +
 258                 "org.onap.ccsdk.sli.adaptors.aai.application=appxyz\"\"\n" +
 259                 "org.onap.ccsdk.sli.adaptors.aai.uri=uriu\"\"\n" +
 260                 "connection.timeout=60000\n" +
 261                 "read.timeout=60000";
 262         // @formatter:on
 263     }
 264
 265 }