sdnr/wt/devicemanager/provider/src/test/java/org/onap/ccsdk/features/sdnr/wt/devicemanager/test/TestAai.java

   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.assertEquals;
  24 import static org.junit.Assert.assertTrue;
  25 import static org.junit.Assert.fail;
  26
  27 import com.google.common.io.Files;
  28 import com.sun.net.httpserver.HttpExchange;
  29 import com.sun.net.httpserver.HttpHandler;
  30 import com.sun.net.httpserver.HttpServer;
  31 import java.io.File;
  32 import java.io.IOException;
  33 import java.io.OutputStream;
  34 import java.net.InetSocketAddress;
  35 import java.nio.charset.StandardCharsets;
  36 import java.util.ArrayList;
  37 import java.util.List;
  38 import java.util.concurrent.ExecutorService;
  39 import java.util.concurrent.Executors;
  40 import org.junit.After;
  41 import org.junit.AfterClass;
  42 import org.junit.Before;
  43 import org.junit.BeforeClass;
  44 import org.junit.Test;
  45 import org.onap.ccsdk.features.sdnr.wt.common.configuration.ConfigurationFileRepresentation;
  46 import org.onap.ccsdk.features.sdnr.wt.common.util.ResourceFileLoader;
  47 import org.onap.ccsdk.features.sdnr.wt.devicemanager.aaiconnector.impl.AaiProviderClient;
  48 import org.onap.ccsdk.features.sdnr.wt.devicemanager.aaiconnector.impl.config.AaiConfig;
  49 import org.onap.ccsdk.features.sdnr.wt.devicemanager.types.InventoryInformationDcae;
  50
  51 public class TestAai {
  52
  53         private static final String CONFIGURATIONTESTFILE = "test.properties"; // for
  54         private static final String ENABLEDAAI_TESTCONFIG_FILENAME = "test2.properties";
  55         private static final File ENABLEDAAI_TESTCONFIG_FILE = new File(ENABLEDAAI_TESTCONFIG_FILENAME);
  56         private static final int AAI_SERVER_PORT = 45454;
  57         private static final String TESTCONFIG_CONTENT = "[dcae]\n" + "dcaeUserCredentials=admin:admin\n" + "dcaeUrl=off\n"
  58                         + "dcaeHeartbeatPeriodSeconds=120\n" + "dcaeTestCollector=no\n" + "\n" + "[aots]\n"
  59                         + "userPassword=passwd\n" + "soapurladd=off\n" + "soapaddtimeout=10\n" + "soapinqtimeout=20\n"
  60                         + "userName=user\n" + "inqtemplate=inqreq.tmpl.xml\n" + "assignedto=userid\n"
  61                         + "addtemplate=addreq.tmpl.xml\n" + "severitypassthrough=critical,major,minor,warning\n"
  62                         + "systemuser=user\n" + "prt-offset=1200\n" + "soapurlinq=off\n" + "#smtpHost=\n" + "#smtpPort=\n"
  63                         + "#smtpUsername=\n" + "#smtpPassword=\n" + "#smtpSender=\n" + "#smtpReceivers=\n" + "\n" + "[es]\n"
  64                         + "esCluster=sendateodl5\n" + "\n" + "[aai]\n" + "#keep comment\n"
  65                         + "aaiHeaders=[\"X-TransactionId: 9999\"]\n" + "aaiUrl=http://localhost:" + AAI_SERVER_PORT + "\n"
  66                         + "aaiUserCredentials=AAI:AAI\n" + "aaiDeleteOnMountpointRemove=true\n" + "aaiTrustAllCerts=false\n"
  67                         + "aaiApiVersion=aai/v13\n" + "aaiPropertiesFile=aaiclient.properties\n" + "aaiApplicationId=SDNR\n"
  68                         + "aaiPcks12ClientCertFile=/opt/logs/externals/data/stores/keystore.client.p12\n"
  69                         + "aaiPcks12ClientCertPassphrase=adminadmin\n" + "aaiClientConnectionTimeout=30000\n" + "\n" + "[pm]\n"
  70                         + "pmCluster=sendateodl5\n" + "pmEnabled=true\n" + "\n" + "";
  71
  72         private static final String EXT_TEST_URL="https://testaai.onap.org:8443";
  73         private static final String EXT_TEST_KEY="test.key";
  74         private static final String EXT_TEST_PASSWD="test123";
  75         private static final String EXT_TEST_APPLICATIONID="SDNC";
  76         private static final long EXT_TEST_CONN_TIMEOUT=6000;
  77
  78
  79         private static final CharSequence TESTCONFIG_CONTENT_EXT = "[aai]\n" + "#keep comment\n"
  80                         + "aaiHeaders=[\"X-TransactionId: 9999\"]\n" + "aaiUrl=http://localhost:" + AAI_SERVER_PORT + "\n"
  81                         + "aaiUserCredentials=AAI:AAI\n" + "aaiDeleteOnMountpointRemove=true\n" + "aaiTrustAllCerts=false\n"
  82                         + "aaiApiVersion=aai/v13\n" + "aaiPropertiesFile=aaiclient.properties\n" +
  83                         //            "aaiApplicationId=SDNR\n" +
  84                         //            "aaiPcks12ClientCertFile=/opt/logs/externals/data/stores/keystore.client.p12\n" +
  85                         //            "aaiPcks12ClientCertPassphrase=adminadmin\n" +
  86                         //            "aaiClientConnectionTimeout=30000\n" +
  87                         "\n";
  88         private static final CharSequence TESTCONFIG_CONTENT_EXT2 = "org.onap.ccsdk.sli.adaptors.aai.ssl.key="+EXT_TEST_KEY+"\n"
  89                         + "org.onap.ccsdk.sli.adaptors.aai.ssl.key.psswd="+EXT_TEST_PASSWD+"\n"
  90                         + "org.onap.ccsdk.sli.adaptors.aai.host.certificate.ignore=false\n"
  91                         + "org.onap.ccsdk.sli.adaptors.aai.application="+EXT_TEST_APPLICATIONID+"\n"
  92                         + "org.onap.ccsdk.sli.adaptors.aai.uri="+EXT_TEST_URL+"\n"
  93                         + "connection.timeout="+EXT_TEST_CONN_TIMEOUT+"\n";
  94         private static HttpServer server;
  95         private static ExecutorService httpThreadPool;
  96         private static ConfigurationFileRepresentation globalCfg;
  97
  98         @Test
  99         public void test() {
 100
 101                 String testConfigurationFileName = ResourceFileLoader.getFile(this, CONFIGURATIONTESTFILE).getAbsolutePath();
 102                 ConfigurationFileRepresentation cfg = new ConfigurationFileRepresentation(testConfigurationFileName);
 103
 104                 AaiProviderClient provider = new AaiProviderClient(cfg, null);
 105
 106                 String mountPointName = "testDevice 01";
 107                 String type = "Unit";
 108                 String model = "Horizon Compact+";
 109                 String vendor = "DragonWave-X";
 110                 String ipv4 = "127.0.0.1";
 111                 String ipv6 = "::1";
 112                 List<String> ifInfos = new ArrayList<>();
 113                 ifInfos.add("LP-MWPS-RADIO");
 114                 InventoryInformationDcae ii = new InventoryInformationDcae(type, model, vendor, ipv4, ipv6, ifInfos);
 115                 System.out.println("registering device");
 116                 provider.onDeviceRegistered(mountPointName, ii);
 117                 try {
 118                         Thread.sleep(5000);
 119                 } catch (InterruptedException e) {
 120                         e.printStackTrace();
 121                 }
 122                 System.out.println("unregistering device");
 123                 provider.onDeviceUnregistered(mountPointName);
 124                 System.out.println("finished");
 125                 try {
 126                         provider.close();
 127                 } catch (Exception e) {
 128                         e.printStackTrace();
 129                 }
 130         }
 131
 132         @Test
 133         public void test2() {
 134                 try {
 135                         Thread.sleep(3000);
 136                 } catch (InterruptedException e1) {
 137                         e1.printStackTrace();
 138                 }
 139                 AaiProviderClient provider = new AaiProviderClient(globalCfg, null);
 140
 141                 String mountPointName = "testDevice 01";
 142                 String type = "Unit";
 143                 String model = "Horizon Compact+";
 144                 String vendor = "DragonWave-X";
 145                 String ipv4 = "127.0.0.1";
 146                 String ipv6 = "::1";
 147                 List<String> ifInfos = new ArrayList<>();
 148                 ifInfos.add("LP-MWPS-RADIO");
 149                 InventoryInformationDcae ii = new InventoryInformationDcae(type, model, vendor, ipv4, ipv6, ifInfos);
 150                 System.out.println("registering device");
 151                 provider.onDeviceRegistered(mountPointName);
 152                 provider.onDeviceRegistered(mountPointName, ii);
 153                 try {
 154                         Thread.sleep(5000);
 155                 } catch (InterruptedException e) {
 156                         e.printStackTrace();
 157                 }
 158                 System.out.println("unregistering device");
 159                 provider.onDeviceUnregistered(mountPointName);
 160                 System.out.println("finished");
 161                 try {
 162                         provider.close();
 163                 } catch (Exception e) {
 164                         e.printStackTrace();
 165                 }
 166         }
 167
 168         @Test
 169         public void testExtendedProperties() {
 170                 File testConfigurationFileName = new File("abbsads.properties");
 171                 File extfile = new File("aaiclient.properties");
 172                 if (testConfigurationFileName.exists()) {
 173                         testConfigurationFileName.delete();
 174                 }
 175                 if (extfile.exists()) {
 176                         extfile.delete();
 177                 }
 178                 try {
 179                         Files.asCharSink(testConfigurationFileName, StandardCharsets.UTF_8).write(TESTCONFIG_CONTENT_EXT);
 180                 } catch (IOException e) {
 181                         e.printStackTrace();
 182                         fail("problem writing a test config file: " + e.getMessage());
 183                 }
 184                 try {
 185                         Files.asCharSink(extfile, StandardCharsets.UTF_8).write(TESTCONFIG_CONTENT_EXT2);
 186                 } catch (IOException e) {
 187                         e.printStackTrace();
 188                         fail("problem writing a second test config file: " + e.getMessage());
 189                 }
 190
 191                 ConfigurationFileRepresentation cfg = new ConfigurationFileRepresentation(testConfigurationFileName);
 192                 AaiConfig config = new AaiConfig(cfg);
 193                 System.out.println(config.toString());
 194
 195                 assertTrue(config.getBaseUrl().startsWith(EXT_TEST_URL));
 196                 assertEquals(EXT_TEST_KEY,config.getPcks12CertificateFilename());
 197                 assertEquals(EXT_TEST_PASSWD,config.getPcks12CertificatePassphrase());
 198                 assertEquals(EXT_TEST_APPLICATIONID,config.getHeaders().get("X-FromAppId"));
 199                 assertEquals(EXT_TEST_CONN_TIMEOUT,config.getConnectionTimeout());
 200
 201                 if (testConfigurationFileName.exists()) {
 202                         testConfigurationFileName.delete();
 203                 }
 204                 if (extfile.exists()) {
 205                         extfile.delete();
 206                 }
 207
 208         }
 209
 210         @BeforeClass
 211         public static void initAaiTestWebserver() throws IOException {
 212                 try {
 213                         Files.asCharSink(ENABLEDAAI_TESTCONFIG_FILE, StandardCharsets.UTF_8).write(TESTCONFIG_CONTENT);
 214                 } catch (IOException e1) {
 215                         fail(e1.getMessage());
 216                 }
 217                 //globalCfg=HtDevicemanagerConfiguration.getTestConfiguration(ENABLEDAAI_TESTCONFIG_FILENAME,true);
 218                 globalCfg = new ConfigurationFileRepresentation(ENABLEDAAI_TESTCONFIG_FILENAME);
 219                 server = HttpServer.create(new InetSocketAddress(AAI_SERVER_PORT), 0);
 220                 httpThreadPool = Executors.newFixedThreadPool(5);
 221                 server.setExecutor(httpThreadPool);
 222                 AaiConfig config = new AaiConfig(globalCfg);
 223                 server.createContext(config.getBaseUri(), new MyHandler());
 224                 //server.createContext("/", new MyRootHandler());
 225                 server.setExecutor(null); // creates a default executor
 226                 server.start();
 227                 System.out.println("http server started");
 228         }
 229
 230         @AfterClass
 231         public static void stopTestWebserver() {
 232                 if (server != null) {
 233                         server.stop(0);
 234                         httpThreadPool.shutdownNow();
 235                         System.out.println("http server stopped");
 236                 }
 237                 if (ENABLEDAAI_TESTCONFIG_FILE.exists()) {
 238                         ENABLEDAAI_TESTCONFIG_FILE.delete();
 239                 }
 240
 241         }
 242
 243         static class MyHandler implements HttpHandler {
 244                 @Override
 245                 public void handle(HttpExchange t) throws IOException {
 246                         String method = t.getRequestMethod();
 247                         System.out.println("req method: " + method);
 248                         OutputStream os = null;
 249                         try {
 250                                 String res = "";
 251                                 if (method.equals("GET")) {
 252                                         t.sendResponseHeaders(404, res.length());
 253                                         os = t.getResponseBody();
 254                                         os.write(res.getBytes());
 255                                 } else if (method.equals("DELETE")) {
 256                                         t.sendResponseHeaders(200, res.length());
 257                                         os = t.getResponseBody();
 258                                         os.write(res.getBytes());
 259                                 } else if (method.equals("PUT")) {
 260                                         t.sendResponseHeaders(200, res.length());
 261                                         os = t.getResponseBody();
 262                                         os.write(res.getBytes());
 263                                 } else {
 264                                         t.sendResponseHeaders(404, 0);
 265                                 }
 266                                 System.out.println("req handled successful");
 267
 268                         } catch (Exception e) {
 269                                 System.out.println(e.getMessage());
 270                         } finally {
 271                                 if (os != null) {
 272                                         os.close();
 273                                 }
 274                         }
 275                 }
 276         }
 277 }