appc-dg/appc-dg-shared/appc-dg-netconf/src/test/java/org/openecomp/appc/dg/netconf/impl/NetconfClientPluginImplTest.java

   1 /*-
   2  * ============LICENSE_START=======================================================
   3  * openECOMP : APP-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 org.openecomp.appc.dg.netconf.impl;
  23
  24 import com.fasterxml.jackson.databind.ObjectMapper;
  25 import org.junit.Assert;
  26 import org.junit.Before;
  27 import org.junit.Test;
  28 import org.junit.Ignore;
  29 import org.junit.runner.RunWith;
  30 import org.mockito.Matchers;
  31 import org.mockito.Mockito;
  32 import org.openecomp.appc.adapter.netconf.*;
  33 import org.openecomp.appc.adapter.netconf.util.Constants;
  34 import org.openecomp.appc.dg.netconf.impl.NetconfClientPluginImpl;
  35 import org.openecomp.appc.exceptions.APPCException;
  36 import org.openecomp.sdnc.sli.SvcLogicContext;
  37 import org.osgi.framework.Bundle;
  38 import org.osgi.framework.BundleContext;
  39 import org.osgi.framework.FrameworkUtil;
  40 import org.osgi.framework.ServiceReference;
  41 import org.powermock.api.mockito.PowerMockito;
  42 import org.powermock.core.classloader.annotations.PrepareForTest;
  43 import org.powermock.modules.junit4.PowerMockRunner;
  44
  45 import java.lang.reflect.Field;
  46 import java.text.DateFormat;
  47 import java.text.SimpleDateFormat;
  48 import java.util.Date;
  49 import java.util.HashMap;
  50 import java.util.Map;
  51
  52 import static org.powermock.api.mockito.PowerMockito.when;
  53
  54
  55
  56 @RunWith(PowerMockRunner.class)
  57 @PrepareForTest({OperationalStateValidatorFactory.class, NetconfClientPluginImpl.class, FrameworkUtil.class, ObjectMapper.class})
  58 @Ignore
  59 public class NetconfClientPluginImplTest {
  60     private NetconfClientPluginImpl netconfClientPlugin;
  61     private NetconfDataAccessService dao;
  62     private NetconfClientFactory clientFactory;
  63     private Map<String, String> params;
  64
  65     private final BundleContext bundleContext = Mockito.mock(BundleContext.class);
  66     private final Bundle bundleService = Mockito.mock(Bundle.class);
  67     private final ServiceReference sref1 = Mockito.mock(ServiceReference.class);
  68     private final ServiceReference sref2 = Mockito.mock(ServiceReference.class);
  69     private final ServiceReference sref3 = Mockito.mock(ServiceReference.class);
  70     private static final String DG_OUTPUT_STATUS_MESSAGE = "output.status.message";
  71
  72
  73     String host = "http://www.test.com";
  74     String host1 = "http://www.test1.com";
  75     String vnfType = "VNF";
  76     int port = 8080;
  77     String username = "test";
  78     String password = "test";
  79     String connectionDetails = "{\"host\":\"" + host + "\",\"port\":" + port + ",\"username\":\"" + username + "\",\"password\":\"" + password + "\",\"capabilities\":null,\"additionalProperties\":null}";
  80     String fileContent = "<?xml version=\"1.0\" encoding=\"UTF-8\"?>\n" +
  81             "<rpc message-id=\"101\" xmlns=\"urn:ietf:params:xml:ns:netconf:base:1.0\">\n" +
  82             "\t<get-config>\n" +
  83             "\t\t<source>\n" +
  84             "\t\t\t<running/>\n" +
  85             "\t\t </source>\n" +
  86             "\t</get-config>\n" +
  87             "</rpc>'";
  88     String operationalState = "<rpc message-id=\"101\" xmlns=\"urn:ietf:params:xml:ns:netconf:base:1.0\">\n" +
  89             "       <get>\n" +
  90             "              <filter>\n" +
  91             "                     <ManagedElement xmlns=\"urn:org:openecomp:appc:Test\">\n" +
  92             "                           <VnfFunction xmlns=\"urn:org:openecomop:appc:Test\">\n" +
  93             "                                  <ProcessorManagement>\n" +
  94             "                                         <MatedPair>\n" +
  95             "                                                <operationalState/>\n" +
  96             "                                                <PayloadProcessor>\n" +
  97             "                                                       <operationalState/>\n" +
  98             "                                                </PayloadProcessor>\n" +
  99             "                                         </MatedPair>\n" +
 100             "                                         <SystemController>\n" +
 101             "                                                <operationalState/>\n" +
 102             "                                         </SystemController>\n" +
 103             "                                  </ProcessorManagement>\n" +
 104             "                           </VnfFunction>\n" +
 105             "                     </ManagedElement>\n" +
 106             "              </filter>\n" +
 107             "       </get>\n" +
 108             "</rpc>\n";
 109
 110
 111     @Before
 112     public void setUp() throws NoSuchFieldException, IllegalAccessException {
 113         clientFactory = new NetconfClientFactoryMock();
 114
 115     }
 116
 117
 118     @Test
 119     public void testConfigure() throws Exception {
 120
 121         shortInit();
 122         SvcLogicContext ctx = new SvcLogicContext();
 123
 124         params = new HashMap<>();
 125         params.put(Constants.CONNECTION_DETAILS_FIELD_NAME, connectionDetails);
 126         params.put(Constants.FILE_CONTENT_FIELD_NAME, fileContent);
 127
 128         netconfClientPlugin.configure(params, ctx);
 129
 130         NetconfClientJschMock client = (NetconfClientJschMock) clientFactory.GetNetconfClient(NetconfClientType.SSH);
 131
 132         try {
 133             Assert.assertEquals("wrong configuration", fileContent, client.getConf());
 134             Assert.assertEquals("wrong host", host, client.getLastConnectionDetails().getHost());
 135             Assert.assertEquals("wrong port", port, client.getLastConnectionDetails().getPort());
 136             Assert.assertEquals("wrong username", username, client.getLastConnectionDetails().getUsername());
 137             Assert.assertEquals("wrong password", password, client.getLastConnectionDetails().getPassword());
 138             Assert.assertFalse(client.isConnection());
 139         } catch (Exception e) {
 140             Assert.fail("failed with because of " + e.getCause());
 141         }
 142
 143
 144     }
 145
 146
 147     @Test
 148     public void testConfigureNegativeIOException() throws Exception {
 149         shortInit();
 150         SvcLogicContext ctx = new SvcLogicContext();
 151
 152         params = new HashMap<>();
 153         params.put(Constants.CONNECTION_DETAILS_FIELD_NAME, "{" + connectionDetails);
 154         params.put(Constants.FILE_CONTENT_FIELD_NAME, fileContent);
 155         NetconfClientJschMock client = (NetconfClientJschMock) clientFactory.GetNetconfClient(NetconfClientType.SSH);
 156
 157
 158         try {
 159             netconfClientPlugin.configure(params, ctx);
 160             Assert.assertTrue(false);
 161         } catch (APPCException e) {
 162             Assert.assertNull(client.getLastConnectionDetails());
 163             Assert.assertNull(client.getConf());
 164         }
 165
 166     }
 167
 168     @Test
 169     public void testOperationStateValidation() throws Exception {
 170         shortInit();
 171         SvcLogicContext ctx = new SvcLogicContext();
 172         DAOServiceMock daoServiceMock = (DAOServiceMock) dao;
 173         daoServiceMock.setConfigFile(fileContent);
 174
 175         NetconfClientJschMock client = (NetconfClientJschMock) clientFactory.GetNetconfClient(NetconfClientType.SSH);
 176         client.setAnswer(operationalState);
 177
 178
 179         params = new HashMap<>();
 180         params.put(Constants.VNF_TYPE_FIELD_NAME, vnfType);
 181         params.put(Constants.VNF_HOST_IP_ADDRESS_FIELD_NAME, host1);
 182         params.put(Constants.CONNECTION_DETAILS_FIELD_NAME, connectionDetails);
 183         MockOperationalStateValidatorImpl validatorMock = new MockOperationalStateValidatorImpl();
 184         validatorMock.setConfigurationFileName("VnfGetRunningConfig");
 185
 186         PowerMockito.mockStatic(OperationalStateValidatorFactory.class);
 187         when(OperationalStateValidatorFactory.getOperationalStateValidator(Matchers.any(VnfType.class))).thenReturn(validatorMock);
 188
 189         netconfClientPlugin.operationStateValidation(params, ctx);
 190
 191         Assert.assertTrue("validation process failed", validatorMock.isValidated());
 192         Assert.assertEquals(fileContent, client.getLastMessage());
 193     }
 194
 195
 196     @Test
 197     public void testOperationStateValidationNegativeJsonProcessingNullIllegalStateException() throws Exception {
 198         shortInit();
 199         SvcLogicContext ctx = new SvcLogicContext();
 200         DAOServiceMock daoServiceMock = (DAOServiceMock) dao;
 201         daoServiceMock.setConfigFile(fileContent);
 202
 203         NetconfClientJschMock client = (NetconfClientJschMock) clientFactory.GetNetconfClient(NetconfClientType.SSH);
 204         client.setAnswer(operationalState);
 205
 206         params = new HashMap<>();
 207         params.put(Constants.VNF_TYPE_FIELD_NAME, vnfType);
 208         params.put(Constants.VNF_HOST_IP_ADDRESS_FIELD_NAME, host1);
 209         params.put(Constants.CONNECTION_DETAILS_FIELD_NAME, connectionDetails);
 210         MockOperationalStateValidatorImpl validatorMock = new MockOperationalStateValidatorImpl();
 211         validatorMock.setConfigurationFileName("VnfGetRunningConfig");
 212
 213         PowerMockito.mockStatic(OperationalStateValidatorFactory.class);
 214         when(OperationalStateValidatorFactory.getOperationalStateValidator(Matchers.any(VnfType.class))).thenReturn(validatorMock);
 215         substituteMapper(true);
 216
 217         try {
 218             netconfClientPlugin.operationStateValidation(params, ctx);
 219             substituteMapper(false);
 220         } catch (APPCException e) {
 221             substituteMapper(false);
 222             Assert.assertNotNull(ctx.getAttribute(DG_OUTPUT_STATUS_MESSAGE));
 223             Assert.assertFalse(validatorMock.isValidated());
 224             Assert.assertNull(client.getLastMessage());
 225         }
 226     }
 227
 228     @Test
 229     public void testOperationStateValidationNegativeConnectionDetailsAreNullNullPointerException() throws Exception {
 230         shortInit();
 231         SvcLogicContext ctx = new SvcLogicContext();
 232         DAOServiceMock daoServiceMock = (DAOServiceMock) dao;
 233         daoServiceMock.setConfigFile(fileContent);
 234
 235         NetconfClientJschMock client = (NetconfClientJschMock) clientFactory.GetNetconfClient(NetconfClientType.SSH);
 236         client.setAnswer(operationalState);
 237
 238
 239         params = new HashMap<>();
 240         params.put(Constants.VNF_TYPE_FIELD_NAME, vnfType);
 241         params.put(Constants.VNF_HOST_IP_ADDRESS_FIELD_NAME, host1);
 242         params.put(Constants.CONNECTION_DETAILS_FIELD_NAME, null);
 243         MockOperationalStateValidatorImpl validatorMock = new MockOperationalStateValidatorImpl();
 244         validatorMock.setConfigurationFileName("VnfGetRunningConfig");
 245
 246         PowerMockito.mockStatic(OperationalStateValidatorFactory.class);
 247         when(OperationalStateValidatorFactory.getOperationalStateValidator(Matchers.any(VnfType.class))).thenReturn(validatorMock);
 248         ObjectMapper mapper = PowerMockito.mock(ObjectMapper.class);
 249         final NetconfConnectionDetails netconfConnectionDetails = null;
 250         when(mapper.readValue(Matchers.anyString(), Matchers.any(Class.class))).thenReturn(netconfConnectionDetails);
 251
 252
 253         try {
 254             netconfClientPlugin.operationStateValidation(params, ctx);
 255             Assert.assertTrue(false);
 256         } catch (APPCException e) {
 257             Assert.assertNotNull(ctx.getAttribute(DG_OUTPUT_STATUS_MESSAGE));
 258             Assert.assertFalse("validation process failed", validatorMock.isValidated());
 259
 260         }
 261     }
 262
 263
 264     @Test
 265     public void testOperationStateValidationNegativeAppcException() throws Exception {
 266         shortInit();
 267         SvcLogicContext ctx = new SvcLogicContext();
 268         DAOServiceMock daoServiceMock = (DAOServiceMock) dao;
 269         daoServiceMock.setConfigFile(fileContent);
 270
 271         NetconfClientJschMock client = (NetconfClientJschMock) clientFactory.GetNetconfClient(NetconfClientType.SSH);
 272         client.setAnswer("wrong");
 273
 274
 275         params = new HashMap<>();
 276         params.put(Constants.VNF_TYPE_FIELD_NAME, vnfType);
 277         params.put(Constants.VNF_HOST_IP_ADDRESS_FIELD_NAME, host1);
 278         params.put(Constants.CONNECTION_DETAILS_FIELD_NAME, connectionDetails);
 279         MockOperationalStateValidatorImpl validatorMock = new MockOperationalStateValidatorImpl();
 280         validatorMock.setConfigurationFileName("VnfGetRunningConfig");
 281
 282         PowerMockito.mockStatic(OperationalStateValidatorFactory.class);
 283         when(OperationalStateValidatorFactory.getOperationalStateValidator(Matchers.any(VnfType.class))).thenReturn(validatorMock);
 284
 285
 286         try {
 287             netconfClientPlugin.operationStateValidation(params, ctx);
 288             Assert.assertTrue(false);
 289         } catch (APPCException e) {
 290             Assert.assertNotNull(ctx.getAttribute(DG_OUTPUT_STATUS_MESSAGE));
 291             Assert.assertFalse("validation process failed", validatorMock.isValidated());
 292
 293         }
 294     }
 295
 296
 297     @Test
 298     public void testOperationStateValidatioConnectionDetailsInParamsAreEmpty() throws Exception {
 299         shortInit();
 300         SvcLogicContext ctx = new SvcLogicContext();
 301         DAOServiceMock daoServiceMock = (DAOServiceMock) dao;
 302         daoServiceMock.setConfigFile(fileContent);
 303
 304         NetconfClientJschMock client = (NetconfClientJschMock) clientFactory.GetNetconfClient(NetconfClientType.SSH);
 305         client.setAnswer(operationalState);
 306         ((DAOServiceMock) dao).setConnection(getConnectionDetails());
 307
 308
 309         params = new HashMap<>();
 310         params.put(Constants.VNF_TYPE_FIELD_NAME, vnfType);
 311         params.put(Constants.VNF_HOST_IP_ADDRESS_FIELD_NAME, host1);
 312         params.put(Constants.CONNECTION_DETAILS_FIELD_NAME, "");
 313         MockOperationalStateValidatorImpl validatorMock = new MockOperationalStateValidatorImpl();
 314         validatorMock.setConfigurationFileName("VnfGetRunningConfig");
 315
 316         PowerMockito.mockStatic(OperationalStateValidatorFactory.class);
 317         when(OperationalStateValidatorFactory.getOperationalStateValidator(Matchers.any(VnfType.class))).thenReturn(validatorMock);
 318
 319         netconfClientPlugin.operationStateValidation(params, ctx);
 320
 321         Assert.assertTrue("validation process failed", validatorMock.isValidated());
 322         Assert.assertEquals(fileContent, client.getLastMessage());
 323     }
 324
 325     @Test
 326     public void testOperationStateValidatioConnectionDetailsInParamsAreNull() throws Exception {
 327         shortInit();
 328         SvcLogicContext ctx = new SvcLogicContext();
 329         DAOServiceMock daoServiceMock = (DAOServiceMock) dao;
 330         daoServiceMock.setConfigFile(fileContent);
 331
 332         NetconfClientJschMock client = (NetconfClientJschMock) clientFactory.GetNetconfClient(NetconfClientType.SSH);
 333         client.setAnswer(operationalState);
 334         ((DAOServiceMock) dao).setConnection(getConnectionDetails());
 335
 336
 337         params = new HashMap<>();
 338         params.put(Constants.VNF_TYPE_FIELD_NAME, vnfType);
 339         params.put(Constants.VNF_HOST_IP_ADDRESS_FIELD_NAME, host1);
 340         params.put(Constants.CONNECTION_DETAILS_FIELD_NAME, null);
 341         MockOperationalStateValidatorImpl validatorMock = new MockOperationalStateValidatorImpl();
 342         validatorMock.setConfigurationFileName("VnfGetRunningConfig");
 343
 344         PowerMockito.mockStatic(OperationalStateValidatorFactory.class);
 345         when(OperationalStateValidatorFactory.getOperationalStateValidator(Matchers.any(VnfType.class))).thenReturn(validatorMock);
 346
 347         netconfClientPlugin.operationStateValidation(params, ctx);
 348
 349         Assert.assertTrue("validation process failed", validatorMock.isValidated());
 350         Assert.assertEquals(fileContent, client.getLastMessage());
 351     }
 352
 353
 354     @Test
 355     public void testBackupConfiguration() throws Exception {
 356         shortInit();
 357         SvcLogicContext ctx = new SvcLogicContext();
 358         params = new HashMap<>();
 359         params.put(Constants.CONNECTION_DETAILS_FIELD_NAME, connectionDetails);
 360         NetconfClientJschMock client = (NetconfClientJschMock) clientFactory.GetNetconfClient(NetconfClientType.SSH);
 361         client.setConf(fileContent);
 362         netconfClientPlugin.backupConfiguration(params, ctx);
 363
 364         DAOServiceMock mockdao = (DAOServiceMock) dao;
 365         DateFormat dateFormat = new SimpleDateFormat("yyyy/MM/dd");
 366         Date date = new Date();
 367         String creationDateExpected = dateFormat.format(date);
 368         String creationDateActual = mockdao.getBackupConf().get("creationDate").substring(0, 10);
 369
 370
 371         Assert.assertEquals("wrong configuration in db", fileContent, mockdao.getBackupConf().get("logText"));
 372         Assert.assertEquals(creationDateExpected, creationDateActual);
 373
 374
 375     }
 376
 377
 378     @Test
 379     public void testBackupConfigurationNegativeDgErrorFieldName() throws Exception {
 380         shortInit();
 381         SvcLogicContext ctx = new SvcLogicContext();
 382         params = new HashMap<>();
 383         params.put(Constants.CONNECTION_DETAILS_FIELD_NAME, "{" + connectionDetails);
 384         NetconfClientJschMock client = (NetconfClientJschMock) clientFactory.GetNetconfClient(NetconfClientType.SSH);
 385         client.setConf(fileContent);
 386         try {
 387             netconfClientPlugin.backupConfiguration(params, ctx);
 388             Assert.assertTrue(false);
 389         } catch (APPCException e) {
 390             Assert.assertNotNull(ctx.getAttribute(DG_OUTPUT_STATUS_MESSAGE));
 391
 392             DAOServiceMock mockdao = (DAOServiceMock) dao;
 393             Assert.assertNull(mockdao.getBackupConf());
 394         }
 395
 396     }
 397
 398     @Test
 399     public void testGetConfig() throws Exception {
 400         fullInit();
 401         String entity = "123";
 402
 403         SvcLogicContext ctx = new SvcLogicContext();
 404         ctx.setAttribute("entity", entity);
 405
 406         params = new HashMap<>();
 407         params.put("conf-id", "current");
 408         params.put(Constants.CONNECTION_DETAILS_FIELD_NAME, connectionDetails);
 409         NetconfClientJschMock client = (NetconfClientJschMock) clientFactory.GetNetconfClient(NetconfClientType.SSH);
 410         client.setConf(fileContent);
 411
 412
 413         netconfClientPlugin.getConfig(params, ctx);
 414
 415         Assert.assertEquals("Success", ctx.getAttribute("getConfig_Result"));
 416         Assert.assertEquals(fileContent, ctx.getAttribute("fullConfig"));
 417         Assert.assertNotNull(ctx.getAttribute(entity + ".Configuration"));
 418         Assert.assertEquals(fileContent, ctx.getAttribute(entity + ".Configuration"));
 419     }
 420
 421
 422     @Test
 423     public void testGetConfigNegativeConfigurationNull() throws Exception {
 424         fullInit();
 425         String entity = "123";
 426
 427         SvcLogicContext ctx = new SvcLogicContext();
 428         ctx.setAttribute("entity", entity);
 429
 430         params = new HashMap<>();
 431         params.put("conf-id", "current");
 432         params.put(Constants.CONNECTION_DETAILS_FIELD_NAME, connectionDetails);
 433
 434
 435         netconfClientPlugin.getConfig(params, ctx);
 436
 437         Assert.assertEquals("failure", ctx.getAttribute("getConfig_Result"));
 438         Assert.assertNull(ctx.getAttribute("fullConfig"));
 439         Assert.assertNull(ctx.getAttribute(entity + ".Configuration"));
 440         Assert.assertNull(ctx.getAttribute(entity + ".Configuration"));
 441     }
 442
 443
 444     @Test
 445     public void testGetConfigNegativeNotSupportedConfId() throws Exception {
 446         fullInit();
 447         String entity = "123";
 448         SvcLogicContext ctx = new SvcLogicContext();
 449         ctx.setAttribute("entity", entity);
 450
 451         params = new HashMap<>();
 452         params.put("conf-id", "current1");
 453         params.put(Constants.CONNECTION_DETAILS_FIELD_NAME, connectionDetails);
 454
 455
 456         netconfClientPlugin.getConfig(params, ctx);
 457
 458         Assert.assertNull(ctx.getAttribute("getConfig_Result"));
 459         Assert.assertNull(ctx.getAttribute("fullConfig"));
 460         Assert.assertNull(ctx.getAttribute(entity + ".Configuration"));
 461         Assert.assertNull(ctx.getAttribute(entity + ".Configuration"));
 462     }
 463
 464     @Test
 465     public void testGetConfigNegativeWronjJsonConnectionDetailsException() throws Exception {
 466         fullInit();
 467         String entity = "123";
 468
 469         SvcLogicContext ctx = new SvcLogicContext();
 470         ctx.setAttribute("entity", entity);
 471
 472         params = new HashMap<>();
 473         params.put("conf-id", "current");
 474         params.put(Constants.CONNECTION_DETAILS_FIELD_NAME, "{" + connectionDetails);
 475
 476
 477         try {
 478             netconfClientPlugin.getConfig(params, ctx);
 479             Assert.assertTrue(false);
 480         } catch (APPCException e) {
 481             Assert.assertEquals("failure", ctx.getAttribute("getConfig_Result"));
 482             Assert.assertNull(ctx.getAttribute("fullConfig"));
 483             Assert.assertNull(ctx.getAttribute(entity + ".Configuration"));
 484             Assert.assertNull(ctx.getAttribute(entity + ".Configuration"));
 485             Assert.assertNotNull(ctx.getAttribute(DG_OUTPUT_STATUS_MESSAGE));
 486         }
 487
 488
 489     }
 490
 491     @Test
 492     public void testGetRunningConfig() throws Exception {
 493         fullInit();
 494         SvcLogicContext ctx = new SvcLogicContext();
 495         params = new HashMap<>();
 496         params.put("host-ip-address", host);
 497         params.put("user-name", username);
 498         params.put("password", password);
 499         params.put("port-number", String.valueOf(port));
 500
 501         NetconfClientJschMock client = (NetconfClientJschMock) clientFactory.GetNetconfClient(NetconfClientType.SSH);
 502         client.setConf(fileContent);
 503
 504         netconfClientPlugin.getRunningConfig(params, ctx);
 505
 506         Assert.assertEquals("Success", ctx.getAttribute("getRunningConfig_Result"));
 507         Assert.assertEquals(fileContent, ctx.getAttribute("running-config"));
 508         Assert.assertEquals("success", ctx.getStatus());
 509     }
 510
 511     @Test
 512     public void testGetRunningConfigWithoutPortNumberDgErrorFieldNameException() throws Exception {
 513         fullInit();
 514         SvcLogicContext ctx = new SvcLogicContext();
 515         params = new HashMap<>();
 516         params.put("host-ip-address", host);
 517         params.put("user-name", username);
 518         params.put("password", password);
 519
 520         NetconfClientJschMock client = (NetconfClientJschMock) clientFactory.GetNetconfClient(NetconfClientType.SSH);
 521         client.setConf(fileContent);
 522
 523         try {
 524             netconfClientPlugin.getRunningConfig(params, ctx);
 525             Assert.assertTrue(false);
 526         } catch (APPCException e) {
 527             Assert.assertEquals("failure", ctx.getAttribute("getRunningConfig_Result"));
 528             Assert.assertNull(ctx.getAttribute("running-config"));
 529             Assert.assertNotNull(ctx.getAttribute(DG_OUTPUT_STATUS_MESSAGE));
 530         }
 531
 532
 533     }
 534
 535     @Test
 536     public void testGetRunningConfigNegativeConfigurationNull() throws Exception {
 537         fullInit();
 538         SvcLogicContext ctx = new SvcLogicContext();
 539         params = new HashMap<>();
 540         params.put("host-ip-address", host);
 541         params.put("user-name", username);
 542         params.put("password", password);
 543         params.put("port-number", String.valueOf(port));
 544
 545         netconfClientPlugin.getRunningConfig(params, ctx);
 546
 547         Assert.assertEquals("failure", ctx.getAttribute("getRunningConfig_Result"));
 548         Assert.assertNull(ctx.getAttribute("running-config"));
 549     }
 550
 551     @Test
 552     public void testValidateMandatoryParamNegativeEmptyParamValue() throws Exception {
 553         shortInit();
 554         String paramName = "test";
 555         String paramValue = "";
 556
 557         try {
 558             netconfClientPlugin.validateMandatoryParam(paramName, paramValue);
 559             Assert.assertTrue(false);
 560         } catch (Exception e) {
 561             Assert.assertTrue(true);
 562         }
 563     }
 564
 565     @Test
 566     public void testRetrieveConnectionDetails() throws Exception {
 567         shortInit();
 568         DAOServiceMock daoServiceMock = (DAOServiceMock) dao;
 569         daoServiceMock.setConfigFile(fileContent);
 570         ConnectionDetails connectionDetails1 = getConnectionDetails();
 571         daoServiceMock.setConnection(connectionDetails1);
 572
 573         NetconfConnectionDetails connectionDetailsActual = netconfClientPlugin.retrieveConnectionDetails(VnfType.VNF);
 574
 575
 576         Assert.assertEquals("wrong host", connectionDetails1.getHost(), connectionDetailsActual.getHost());
 577         Assert.assertEquals("wrong password", connectionDetails1.getPassword(), connectionDetailsActual.getPassword());
 578         Assert.assertEquals("wrong port", connectionDetails1.getPort(), connectionDetailsActual.getPort());
 579         Assert.assertEquals("wrong usename", connectionDetails1.getUsername(), connectionDetailsActual.getUsername());
 580     }
 581
 582
 583     @Test
 584     public void testRetrieveConnectionDetailsNegativeMissingConfiguration() throws Exception {
 585         shortInit();
 586         DAOServiceMock daoServiceMock = (DAOServiceMock) dao;
 587         daoServiceMock.setConfigFile(fileContent);
 588         ConnectionDetails connectionDetails1 = getConnectionDetails();
 589         daoServiceMock.setConnection(connectionDetails1);
 590
 591         NetconfConnectionDetails connectionDetailsActual = null;
 592         try {
 593             connectionDetailsActual = netconfClientPlugin.retrieveConnectionDetails(VnfType.MOCK);
 594             Assert.assertTrue(false);
 595         } catch (APPCException e) {
 596             Assert.assertNull(connectionDetailsActual);
 597         }
 598
 599
 600     }
 601
 602     @Test
 603     public void testRetrieveConfigurationFileContent() throws Exception {
 604         shortInit();
 605
 606         DAOServiceMock daoServiceMock = (DAOServiceMock) dao;
 607         daoServiceMock.setConfigFile(fileContent);
 608
 609         Assert.assertEquals("wrong config in a database", fileContent, netconfClientPlugin.retrieveConfigurationFileContent("VnfGetRunningConfig"));
 610     }
 611
 612     private ConnectionDetails getConnectionDetails() {
 613
 614         ConnectionDetails connectionDetails = new ConnectionDetails();
 615         connectionDetails.setPassword(password);
 616         connectionDetails.setPort(port);
 617         connectionDetails.setUsername(username);
 618         connectionDetails.setHost(host);
 619         return connectionDetails;
 620     }
 621
 622
 623     private void initDao() throws NoSuchFieldException, IllegalAccessException {
 624         dao = new DAOServiceMock();
 625         PowerMockito.mockStatic(FrameworkUtil.class);
 626         when(FrameworkUtil.getBundle(Matchers.any(Class.class))).thenReturn(bundleService);
 627         when(bundleService.getBundleContext()).thenReturn(bundleContext);
 628         when(bundleContext.getServiceReference(NetconfDataAccessService.class)).thenReturn(sref1);
 629         when(bundleContext.getService(sref1)).thenReturn(dao);
 630
 631
 632     }
 633
 634     private void fullInit() throws NoSuchFieldException, IllegalAccessException {
 635         initClientFactory();
 636         initClientFactory2();
 637         initDao();
 638         netconfClientPlugin = new NetconfClientPluginImpl();
 639         netconfClientPlugin.setDao(this.dao);
 640     }
 641
 642     private void shortInit() throws NoSuchFieldException, IllegalAccessException {
 643         initClientFactory();
 644         initDao();
 645         netconfClientPlugin = new NetconfClientPluginImpl();
 646         netconfClientPlugin.setDao(this.dao);
 647     }
 648
 649     private void initClientFactory() throws NoSuchFieldException, IllegalAccessException {
 650
 651         PowerMockito.mockStatic(FrameworkUtil.class);
 652         when(FrameworkUtil.getBundle(Matchers.any(Class.class))).thenReturn(bundleService);
 653         when(bundleService.getBundleContext()).thenReturn(bundleContext);
 654         when(bundleContext.getServiceReference(NetconfClientFactory.class)).thenReturn(sref2);
 655         when(bundleContext.getService(sref2)).thenReturn(clientFactory);
 656
 657     }
 658
 659     private void initClientFactory2() {
 660         PowerMockito.mockStatic(FrameworkUtil.class);
 661         when(FrameworkUtil.getBundle(Matchers.any(Class.class))).thenReturn(bundleService);
 662         when(bundleService.getBundleContext()).thenReturn(bundleContext);
 663         when(bundleContext.getServiceReference(Matchers.anyString())).thenReturn(sref3);
 664         when(bundleContext.getService(sref3)).thenReturn(clientFactory);
 665     }
 666
 667     private void substituteMapper(boolean command) throws NoSuchFieldException, IllegalAccessException {
 668         ObjectMapper mapper = new ObjectMapperMock();
 669         ObjectMapper mapper2 = new ObjectMapper();
 670         Field field = NetconfClientPluginImpl.class.getDeclaredField("mapper");
 671         field.setAccessible(true);
 672         if (command) {
 673             field.set(netconfClientPlugin, mapper);
 674         } else {
 675             field.set(netconfClientPlugin, mapper2);
 676         }
 677     }
 678
 679 }