UniversalVesAdapter/src/test/java/org/onap/universalvesadapter/service/AdapterServiceTest.java

   1 /*
   2 * ============LICENSE_START=======================================================
   3 * ONAP : DCAE
   4 * ================================================================================
   5 * Copyright 2018 TechMahindra
   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 package org.onap.universalvesadapter.service;
  21
  22 import static org.junit.Assert.*;
  23 import static org.mockito.Mockito.when;
  24
  25 import java.io.FileNotFoundException;
  26 import java.io.FileReader;
  27 import java.io.IOException;
  28
  29 import org.junit.Before;
  30 import org.junit.Test;
  31 import org.junit.runner.RunWith;
  32 import org.mockito.InjectMocks;
  33 import org.mockito.MockitoAnnotations;
  34 import org.onap.dcaegen2.ves.domain.AdditionalField;
  35 import org.onap.universalvesadapter.Application;
  36 import org.onap.universalvesadapter.exception.MapperConfigException;
  37 import org.onap.universalvesadapter.service.AdapterService;
  38 import org.onap.universalvesadapter.utils.MapperConfigUtils;
  39 import org.slf4j.Logger;
  40 import org.slf4j.LoggerFactory;
  41 import org.springframework.beans.factory.annotation.Autowired;
  42 import org.springframework.beans.factory.annotation.Value;
  43 import org.springframework.boot.test.context.SpringBootTest;
  44 import org.springframework.test.context.junit4.SpringRunner;
  45 import org.springframework.util.FileCopyUtils;
  46
  47 @RunWith(SpringRunner.class)
  48 @SpringBootTest(classes=Application.class)
  49 public class AdapterServiceTest {
  50
  51 //    private final Logger eLOGGER = LoggerFactory.getLogger(this.getClass());
  52
  53         @Before
  54     public void setup() {
  55            MockitoAnnotations.initMocks(this);
  56     }
  57
  58         @Autowired
  59     @InjectMocks
  60     private AdapterService adapterService;
  61
  62
  63         //AdapterService adapterService = new AdapterService();
  64
  65     @Value("${mapperConfig.file}")
  66     private String mapperConfigFile;
  67
  68    /* @Test
  69     public void identifyEventTypeFromIncomingJson() throws MapperConfigException, FileNotFoundException, IOException {
  70
  71         String inputJsonString = "{ "
  72                 + "\"protocol version\":\"v2c\", "
  73                 + "\"notify OID\":\".1.3.6.1.4.1.74.2.46.12.1.1AAA\", "
  74                 + "\"cambria.partition\":\"dcae-snmp.client.research.att.com\", "
  75                 + "\"trap category\":\"UCSNMP-HEARTBEAT\", "
  76                 + "\"epoch_serno\": 15161177410000, "
  77                 + "\"community\":\"public\", "
  78                 + "\"time received\": 1516117741, "
  79                 + "\"agent name\":\"localhost\", "
  80                 + "\"agent address\":\"127.0.0.1\", "
  81                 + "\"community len\": 6, "
  82                 + "\"notify OID len\": 12, "
  83                 + "\"varbinds\": [{ "
  84                 + "    \"varbind_type\":\"octet\", "
  85                 + "    \"varbind_oid\":\".1.3.6.1.4.1.74.2.46.12.1.1.1\", "
  86                 + "    \"varbind_value\":\"ucsnmp heartbeat - ignore\" "
  87                 + " }, { "
  88                 + "    \"varbind_type\":\"octet\", "
  89                 + "    \"varbind_oid\":\".1.3.6.1.4.1.74.2.46.12.1.1.2\", "
  90                 + "    \"varbind_value\":\"Tue Jan 16 10:49:01 EST 2018\" "
  91                 + " }] "
  92                 + "}";
  93
  94         String domain = "";
  95
  96             String mappingConfigFileData = FileCopyUtils.copyToString(new FileReader(mapperConfigFile));
  97             MapperConfigUtils.readMapperConfigFile(mappingConfigFileData);
  98             domain = adapterService.identifyEventTypeFromIncomingJson(inputJsonString);
  99         adapterService.identifyEventTypeFromIncomingJson(inputJsonString);
 100
 101
 102         assertEquals("snmp", domain);
 103     }*/
 104          @Test
 105          public void testidentifyEventTypeFromIncomingJson() throws MapperConfigException{
 106                  String inputJsonString = "{ "
 107                + "\"protocol version\":\"v2c\", "
 108                + "\"notify OID\":\".1.3.6.1.4.1.74.2.46.12.1.1AAA\", "
 109                + "\"cambria.partition\":\"dcae-snmp.client.research.att.com\", "
 110                + "\"trap category\":\"UCSNMP-HEARTBEAT\", "
 111                + "\"epoch_serno\": 15161177410000, "
 112                + "\"community\":\"public\", "
 113                + "\"time received\": 1516117741, "
 114                + "\"agent name\":\"localhost\", "
 115                + "\"agent address\":\"127.0.0.1\", "
 116                + "\"community len\": 6, "
 117                + "\"notify OID len\": 12, "
 118                + "\"varbinds\": [{ "
 119                + "    \"varbind_type\":\"octet\", "
 120                + "    \"varbind_oid\":\".1.3.6.1.4.1.74.2.46.12.1.1.1\", "
 121                + "    \"varbind_value\":\"ucsnmp heartbeat - ignore\" "
 122                + " }, { "
 123                + "    \"varbind_type\":\"octet\", "
 124                + "    \"varbind_oid\":\".1.3.6.1.4.1.74.2.46.12.1.1.2\", "
 125                + "    \"varbind_value\":\"Tue Jan 16 10:49:01 EST 2018\" "
 126                + " }] "
 127                + "}";
 128 //               when(MapperConfigUtils.checkIncomingJsonForMatchingDomain(inputJsonString)).thenReturn("snmp");
 129                  String actualDomain=adapterService.identifyEventTypeFromIncomingJson(inputJsonString);
 130                  assertEquals("default", actualDomain);
 131          }
 132
 133 }