1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
|
/*-
* ============LICENSE_START=======================================================
* ONAP : DCAE
* ================================================================================
* Copyright 2018-2019 TechMahindra
* ================================================================================
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
* ============LICENSE_END=========================================================
*
*
* package org.onap.universalvesadapter.service;
*
* import static org.junit.Assert.*; import static org.mockito.Mockito.doNothing; import static
* org.mockito.Mockito.doReturn;
*
* import java.io.IOException; import java.util.Arrays; import java.util.Collections;
*
* import org.junit.Before; import org.junit.Ignore; import org.junit.Test; import
* org.junit.runner.RunWith; import org.mockito.ArgumentCaptor; import org.mockito.InjectMocks;
* import org.mockito.Mock; import org.mockito.Mockito; import org.mockito.MockitoAnnotations;
* import org.onap.universalvesadapter.Application; import
* org.onap.universalvesadapter.exception.DMaapException; import
* org.onap.universalvesadapter.service.DMaapService; import
* org.onap.universalvesadapter.service.VesService; import
* org.onap.universalvesadapter.utils.ParallelTasks; import org.slf4j.Logger; import
* org.slf4j.LoggerFactory; import org.springframework.beans.factory.annotation.Autowired; import
* org.springframework.boot.test.context.SpringBootTest; import
* org.springframework.test.context.junit4.SpringRunner;
*
* import com.att.nsa.mr.client.MRConsumer;
*
* @Ignore
*
* @RunWith(SpringRunner.class)
*
* @SpringBootTest(classes = Application.class) public class VesServiceTest {
*
* @InjectMocks
*
* @Autowired private VesService vesService;
*
* @Mock private DMaapService dmaapService;
*
* private final Logger eLOGGER = LoggerFactory.getLogger(this.getClass());
*
* @Before public void init() { MockitoAnnotations.initMocks(this); }
*
*
* @Test public void testStart() throws IOException {
*
* String[] incomingMessages = {"{ " + " \"protocol version \": \"v2c \", " +
* " \"notify OID \": \".1.3.6.1.4.1.74.2.46.12.1.1AAA \", " +
* " \"cambria.partition \": \"dcae-snmp.client.research.att.com \", " +
* " \"trap category \": \"UCSNMP-HEARTBEAT \", " + " \"epoch_serno \": 15161177410000, " +
* " \"community \": \"public \", " + " \"time received \": 1516117741, " +
* " \"agent name \": \"localhost \", " + " \"agent address \": \"127.0.0.1 \", " +
* " \"community len \": 6, " + " \"notify OID len \": 12, " + " \"varbinds \": [{ " +
* " \"varbind_type \": \"octet \", " +
* " \"varbind_oid \": \".1.3.6.1.4.1.74.2.46.12.1.1.1 \", " +
* " \"varbind_value \": \"ucsnmp heartbeat - ignore \" " + " }, { " +
* " \"varbind_type \": \"octet \", " +
* " \"varbind_oid \": \".1.3.6.1.4.1.74.2.46.12.1.1.2 \", " +
* " \"varbind_value \": \"Tue Jan 16 10:49:01 EST 2018 \" " + " }] " + "}"}; try { //
* Mockito.when(dmaapService.fetchAndPublishInDMaaP(null,null)).
* thenReturn(Arrays.asList(incomingMessages)).thenReturn(() -> Collections.emptyIterator());
*
* } catch (Exception e) { eLOGGER.error("Error occurred : " + e.getMessage()); }
*
* ArgumentCaptor<?> valueCapture = ArgumentCaptor.forClass(String.class); try {
* //doNothing().when(dmaapService).fetchAndPublishInDMaaP((String) valueCapture.capture()); } catch
* (DMaapException e) { eLOGGER.error("Error occurred : " + e.getMessage()); }
*
*
* new Thread(new Runnable() {
*
* @Override public void run() { // TODO Auto-generated method stub vesService.start();
*
* } }).start(); try { Thread.sleep(5000); } catch (InterruptedException e) { // TODO Auto-generated
* catch block e.printStackTrace(); } new Thread(new Runnable() {
*
* @Override public void run() { // TODO Auto-generated method stub vesService.stop();
*
* } }).start(); String result = "{\"event\":{\"commonEventHeader\":{},\"faultFields\":{},
* \"measurementsForVfScalingFields\":{\"additionalMeasurements\":[]}}}"; assertEquals(result,
* valueCapture.getValue()); }
*
* @Test public void testStop() { fail("Not yet implemented"); }
*
* }
*/
|
