Sonar Critical Fix
[dcaegen2/analytics/tca.git] / dcae-analytics-cdap-tca / src / test / java / org / openecomp / dcae / apod / analytics / cdap / tca / worker / TCADMaaPSubscriberWorkerTest.java
1 /*\r
2  * ===============================LICENSE_START======================================\r
3  *  dcae-analytics\r
4  * ================================================================================\r
5  *    Copyright © 2017 AT&T Intellectual Property. All rights reserved.\r
6  * ================================================================================\r
7  *  Licensed under the Apache License, Version 2.0 (the "License");\r
8  *  you may not use this file except in compliance with the License.\r
9  *   You may obtain a copy of the License at\r
10  *\r
11  *          http://www.apache.org/licenses/LICENSE-2.0\r
12  *\r
13  *  Unless required by applicable law or agreed to in writing, software\r
14  *  distributed under the License is distributed on an "AS IS" BASIS,\r
15  *  WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.\r
16  *  See the License for the specific language governing permissions and\r
17  *  limitations under the License.\r
18  *  ============================LICENSE_END===========================================\r
19  */\r
20 \r
21 package org.openecomp.dcae.apod.analytics.cdap.tca.worker;\r
22 \r
23 import co.cask.cdap.api.app.ApplicationSpecification;\r
24 import co.cask.cdap.api.worker.WorkerConfigurer;\r
25 import co.cask.cdap.api.worker.WorkerContext;\r
26 import org.junit.Before;\r
27 import org.junit.Test;\r
28 import org.mockito.Mockito;\r
29 import org.openecomp.dcae.apod.analytics.cdap.common.CDAPComponentsConstants;\r
30 import org.openecomp.dcae.apod.analytics.cdap.common.exception.CDAPSettingsException;\r
31 import org.openecomp.dcae.apod.analytics.cdap.tca.BaseAnalyticsCDAPTCAUnitTest;\r
32 \r
33 import static org.mockito.ArgumentMatchers.anyString;\r
34 import static org.mockito.ArgumentMatchers.eq;\r
35 import static org.mockito.Mockito.doNothing;\r
36 import static org.mockito.Mockito.mock;\r
37 import static org.mockito.Mockito.times;\r
38 import static org.mockito.Mockito.verify;\r
39 import static org.mockito.Mockito.when;\r
40 \r
41 /**\r
42  * @author Rajiv Singla . Creation Date: 12/20/2016.\r
43  */\r
44 public class TCADMaaPSubscriberWorkerTest extends BaseAnalyticsCDAPTCAUnitTest {\r
45 \r
46     private static final String TEST_SUBSCRIBER_OUTPUT_STREAM_NAME = "testSubscriberOutputStream";\r
47 \r
48     private WorkerConfigurer workerConfigurer;\r
49     private WorkerContext workerContext;\r
50     private TCADMaaPSubscriberWorker subscriberWorker;\r
51     private ApplicationSpecification mockApplicationSpecification;\r
52 \r
53     @Before\r
54     public void before() throws Exception {\r
55         workerConfigurer = mock(WorkerConfigurer.class);\r
56         workerContext = mock(WorkerContext.class);\r
57         mockApplicationSpecification = Mockito.mock(ApplicationSpecification.class);\r
58         when(workerContext.getApplicationSpecification()).thenReturn(mockApplicationSpecification);\r
59         doNothing().when(workerConfigurer).setName(anyString());\r
60         doNothing().when(workerConfigurer).setDescription(anyString());\r
61         subscriberWorker =\r
62                 new TCADMaaPSubscriberWorker(TEST_SUBSCRIBER_OUTPUT_STREAM_NAME);\r
63 \r
64     }\r
65 \r
66     @Test\r
67     public void testConfigure() throws Exception {\r
68         subscriberWorker.configure(workerConfigurer);\r
69         verify(workerConfigurer, times(1))\r
70                 .setName(eq(CDAPComponentsConstants.TCA_FIXED_DMAAP_SUBSCRIBER_WORKER));\r
71         verify(workerConfigurer, times(1))\r
72                 .setDescription(eq(CDAPComponentsConstants.TCA_FIXED_DMAAP_SUBSCRIBER_DESCRIPTION_WORKER));\r
73     }\r
74 \r
75     @Test(expected = CDAPSettingsException.class)\r
76     public void testInitializeWhenSettingsHaveErrors() throws Exception {\r
77         when(mockApplicationSpecification.getConfiguration()).thenReturn("{}");\r
78         subscriberWorker.initialize(workerContext);\r
79     }\r
80 \r
81     @Test\r
82     public void testInitializeWhenSettingsAreValid() throws Exception {\r
83         when(workerContext.getRuntimeArguments()).thenReturn(getPreferenceMap());\r
84         when(mockApplicationSpecification.getConfiguration()).thenReturn(fromStream(TCA_APP_CONFIG_FILE_LOCATION));\r
85         subscriberWorker.initialize(workerContext);\r
86     }\r
87 \r
88 }\r