-/*-\r
- * ============LICENSE_START=======================================================\r
- * ONAP Policy Engine\r
- * ================================================================================\r
- * Copyright (C) 2017 AT&T Intellectual Property. All rights reserved.\r
- * ================================================================================\r
- * Licensed under the Apache License, Version 2.0 (the "License");\r
- * you may not use this file except in compliance with the License.\r
- * You may obtain a copy of the License at\r
- * \r
- * http://www.apache.org/licenses/LICENSE-2.0\r
- * \r
- * Unless required by applicable law or agreed to in writing, software\r
- * distributed under the License is distributed on an "AS IS" BASIS,\r
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.\r
- * See the License for the specific language governing permissions and\r
- * limitations under the License.\r
- * ============LICENSE_END=========================================================\r
- */\r
-\r
-package com.att.nsa.dmaap.service;\r
-\r
-import static org.junit.Assert.assertTrue;\r
-import static org.junit.Assert.fail;\r
-import static org.mockito.Matchers.anyString;\r
-\r
-import java.io.ByteArrayInputStream;\r
-import java.io.FileInputStream;\r
-\r
-//import static org.mockito.Matchers.anyString;\r
-//import static org.mockito.Mockito.when;\r
-\r
-import java.io.IOException;\r
-import java.io.InputStream;\r
-\r
-import javax.servlet.ServletOutputStream;\r
-import javax.servlet.http.HttpServletRequest;\r
-import javax.servlet.http.HttpServletResponse;\r
-\r
-import org.apache.commons.io.IOUtils;\r
-import org.json.JSONArray;\r
-import org.json.JSONException;\r
-import org.json.JSONObject;\r
-import org.junit.After;\r
-import org.junit.Assert;\r
-import org.junit.Before;\r
-import org.junit.Test;\r
-import org.junit.runner.RunWith;\r
-import org.mockito.InjectMocks;\r
-import org.mockito.Mock;\r
-import org.mockito.MockitoAnnotations;\r
-import org.powermock.api.mockito.PowerMockito;\r
-import org.powermock.core.classloader.annotations.PrepareForTest;\r
-import org.powermock.modules.junit4.PowerMockRunner;\r
-\r
-import com.att.ajsc.beans.PropertiesMapBean;\r
-import com.att.ajsc.filemonitor.AJSCPropertiesMap;\r
-import org.onap.dmaap.dmf.mr.CambriaApiException;\r
-import org.onap.dmaap.dmf.mr.beans.DMaaPContext;\r
-import org.onap.dmaap.dmf.mr.beans.DMaaPKafkaMetaBroker;\r
-import org.onap.dmaap.dmf.mr.constants.CambriaConstants;\r
-import org.onap.dmaap.dmf.mr.exception.DMaaPAccessDeniedException;\r
-import org.onap.dmaap.dmf.mr.exception.DMaaPErrorMessages;\r
-import org.onap.dmaap.dmf.mr.metabroker.Broker.TopicExistsException;\r
-import org.onap.dmaap.dmf.mr.metabroker.Topic;\r
-import org.onap.dmaap.dmf.mr.security.DMaaPAAFAuthenticator;\r
-import org.onap.dmaap.dmf.mr.security.DMaaPAAFAuthenticatorImpl;\r
-import org.onap.dmaap.dmf.mr.security.DMaaPAuthenticator;\r
-import org.onap.dmaap.dmf.mr.service.MMService;\r
-import org.onap.dmaap.dmf.mr.utils.ConfigurationReader;\r
-import com.att.nsa.configs.ConfigDbException;\r
-import com.att.nsa.dmaap.mmagent.CreateMirrorMaker;\r
-import com.att.nsa.dmaap.mmagent.MirrorMaker;\r
-import com.att.nsa.dmaap.mmagent.UpdateMirrorMaker;\r
-import com.att.nsa.security.NsaAcl;\r
-import com.att.nsa.security.NsaApiKey;\r
-import com.att.nsa.security.db.simple.NsaSimpleApiKey;\r
-import com.google.gson.Gson;\r
-\r
-//@RunWith(MockitoJUnitRunner.class)\r
-@RunWith(PowerMockRunner.class)\r
-@PrepareForTest({ PropertiesMapBean.class, AJSCPropertiesMap.class })\r
-public class MMRestServiceTest {\r
-\r
- @InjectMocks\r
- MMRestService mmRestService;\r
-\r
- @Mock\r
- private MMService mmservice;\r
-\r
- @Mock\r
- CreateMirrorMaker cMirroMaker;\r
-\r
- @Mock\r
- UpdateMirrorMaker uMirroMaker;\r
-\r
- private TopicRestService service = new TopicRestService();\r
- @Mock\r
- private DMaaPErrorMessages errorMessages;\r
-\r
- @Mock\r
- DMaaPContext dmaapContext;\r
-\r
- @Mock\r
- ConfigurationReader configReader;\r
-\r
- @Mock\r
- ServletOutputStream oStream;\r
-\r
- @Mock\r
- DMaaPAuthenticator<NsaSimpleApiKey> dmaaPAuthenticator;\r
-\r
- @Mock\r
- MirrorMaker mMaker;\r
-\r
- @Mock\r
- DMaaPAAFAuthenticator dmaapAAFauthenticator;\r
-\r
- @Mock\r
- DMaaPAAFAuthenticatorImpl impl;\r
-\r
- @Mock\r
- NsaApiKey user;\r
-\r
- @Mock\r
- NsaSimpleApiKey nsaSimpleApiKey;\r
-\r
- @Mock\r
- HttpServletRequest httpServReq;\r
-\r
- @Mock\r
- HttpServletResponse httpServRes;\r
-\r
- @Mock\r
- InputStream iStream;\r
-\r
- @Mock\r
- DMaaPKafkaMetaBroker dmaapKafkaMetaBroker;\r
-\r
- @Mock\r
- Topic createdTopic;\r
-\r
- @Mock\r
- NsaAcl nsaAcl;\r
-\r
- @Mock\r
- JSONObject jsonObj;\r
-\r
- @Mock\r
- JSONArray jsonArray;\r
-\r
- @Before\r
- public void setUp() throws Exception {\r
-\r
- MockitoAnnotations.initMocks(this);\r
- }\r
-\r
- @After\r
- public void tearDown() throws Exception {\r
- }\r
-\r
- @Test\r
- public void testCallCreateMirrorMaker() throws Exception {\r
- prepareForTestCommon();\r
-\r
- // String sampleJson = ""{ messageID:\"test\", createMirrorMaker: {\r
- // name:\"test\", consumer:\"test\", producer:\"test\",\r
- // whitelist:\"test\",status:\"test\" }}";\r
- String sampleJson = "{ messageID:\"test\", createMirrorMaker: { name:\"test\", consumer:\"test\", producer:\"test\"}}";\r
- InputStream inputSteam = new ByteArrayInputStream(sampleJson.getBytes());\r
- mmRestService.callCreateMirrorMaker(inputSteam);\r
- assertTrue(true);\r
-\r
- }\r
- @Test\r
- public void testCallCreateMirrorMaker_error4() throws Exception {\r
- prepareForTestCommon();\r
-\r
- // String sampleJson = ""{ messageID:\"test\", createMirrorMaker: {\r
- // name:\"test\", consumer:\"test\", producer:\"test\",\r
- // whitelist:\"test\",status:\"test\" }}";\r
- String sampleJson = "{ messageID:\"test\", createMirrorMaker: { name:\"test@#\", consumer:\"test\", producer:\"test\"}}";\r
- InputStream inputSteam = new ByteArrayInputStream(sampleJson.getBytes());\r
- mmRestService.callCreateMirrorMaker(inputSteam);\r
- assertTrue(true);\r
-\r
- }\r
- @Test\r
- public void testCallCreateMirrorMaker_3() throws Exception {\r
- prepareForTestCommon();\r
-\r
- // String sampleJson = ""{ messageID:\"test\", createMirrorMaker: {\r
- // name:\"test\", consumer:\"test\", producer:\"test\",\r
- // whitelist:\"test\",status:\"test\" }}";\r
- String sampleJson = "{ messageID:\"test\", createMirrorMaker: { name:\"\", consumer:\"test\", producer:\"test\"}}";\r
- InputStream inputSteam = new ByteArrayInputStream(sampleJson.getBytes());\r
- mmRestService.callCreateMirrorMaker(inputSteam);\r
- assertTrue(true);\r
-\r
- }\r
- @Test\r
- public void testCallCreateMirrorMaker_error2() throws Exception {\r
- prepareForTestCommon();\r
-\r
- // String sampleJson = ""{ messageID:\"test\", createMirrorMaker: {\r
- // name:\"test\", consumer:\"test\", producer:\"test\",\r
- // whitelist:\"test\",status:\"test\" }}";\r
- String sampleJson = "{ messageID:\"test\", createMirrorMaker: { name:\"test\", consumer:\"test\", producer:\"test\",whitelist:\"test\"}}";\r
- InputStream inputSteam = new ByteArrayInputStream(sampleJson.getBytes());\r
- mmRestService.callCreateMirrorMaker(inputSteam);\r
- assertTrue(true);\r
-\r
- }\r
- \r
- @Test\r
- public void testCallCreateMirrorMaker_error1() throws Exception {\r
- prepareForTestCommon();\r
-\r
- // String sampleJson = ""{ messageID:\"test\", createMirrorMaker: {\r
- // name:\"test\", consumer:\"test\", producer:\"test\",\r
- // whitelist:\"test\",status:\"test\" }}";\r
- String sampleJson = "{ messageID:\"test\"}";\r
- InputStream inputSteam = new ByteArrayInputStream(sampleJson.getBytes());\r
- mmRestService.callCreateMirrorMaker(inputSteam);\r
- assertTrue(true);\r
-\r
- }\r
-\r
- @Test\r
- public void testCallListAllMirrorMaker() throws Exception {\r
- prepareForTestCommon();\r
-\r
- String sampleJson = "{ messageID:\"test\", createMirrorMaker: { name:\"test\", consumer:\"test\", producer:\"test\", whitelist:\"test\",status:\"test\" }}";\r
- InputStream inputSteam = new ByteArrayInputStream(sampleJson.getBytes());\r
- mmRestService.callListAllMirrorMaker(inputSteam);\r
- assertTrue(true);\r
- }\r
-\r
- @Test\r
- public void testCallUpdateMirrorMaker() throws Exception {\r
- prepareForTestCommon();\r
-\r
- String sampleJson = "{ messageID:\"test\", updateMirrorMaker: { name:\"test\", consumer:\"test\", producer:\"test\"}}";\r
- InputStream inputSteam = new ByteArrayInputStream(sampleJson.getBytes());\r
- mmRestService.callUpdateMirrorMaker(inputSteam);\r
- assertTrue(true);\r
- }\r
- \r
- @Test\r
- public void testCallUpdateMirrorMaker_error1() throws Exception {\r
- prepareForTestCommon();\r
-\r
- String sampleJson = "{ messageID:\"test@1\", updateMirrorMaker: { name:\"test\", consumer:\"test\", producer:\"test\"}}";\r
- InputStream inputSteam = new ByteArrayInputStream(sampleJson.getBytes());\r
- mmRestService.callUpdateMirrorMaker(inputSteam);\r
- assertTrue(true);\r
- }\r
- @Test\r
- public void testCallUpdateMirrorMaker_error2() throws Exception {\r
- prepareForTestCommon();\r
-\r
- String sampleJson = "{ messageID:\"test\", updateMirrorMaker: { name:\"\", consumer:\"test\", producer:\"test\"}}";\r
- InputStream inputSteam = new ByteArrayInputStream(sampleJson.getBytes());\r
- mmRestService.callUpdateMirrorMaker(inputSteam);\r
- assertTrue(true);\r
- }\r
- @Test\r
- public void testCallUpdateMirrorMaker_error3() throws Exception{\r
- prepareForTestCommon();\r
-\r
- String sampleJson = "{ messageID:\"test\", updateMirrorMaker: { name:\"test\", consumer:\"test\", producer:\"test\", whitelist:\"test\",status:\"test\"}}";\r
- InputStream inputSteam = new ByteArrayInputStream(sampleJson.getBytes());\r
- mmRestService.callUpdateMirrorMaker(inputSteam);\r
- assertTrue(true);\r
- }\r
- @Test\r
- public void testCallUpdateMirrorMaker_error4() throws Exception {\r
- prepareForTestCommon();\r
-\r
- String sampleJson = "{ messageID:\"test\"}}";\r
- InputStream inputSteam = new ByteArrayInputStream(sampleJson.getBytes());\r
- mmRestService.callUpdateMirrorMaker(inputSteam);\r
- assertTrue(true);\r
- }\r
-\r
- @Test\r
- public void testCallDeleteMirrorMaker() throws Exception {\r
- prepareForTestCommon();\r
-\r
- String sampleJson = "{ messageID:\"test\", deleteMirrorMaker: { name:\"test\", consumer:\"test\", producer:\"test\", whitelist:\"test\",status:\"test\" }}";\r
- InputStream inputSteam = new ByteArrayInputStream(sampleJson.getBytes());\r
- mmRestService.callDeleteMirrorMaker(inputSteam);\r
- assertTrue(true);\r
- }\r
-\r
- @Test\r
- public void testListWhiteList() throws Exception {\r
- prepareForTestCommon();\r
-\r
- String sampleJson = "{ name:\"test\", namespace:\"test\"}}";\r
- InputStream inputSteam = new ByteArrayInputStream(sampleJson.getBytes());\r
- mmRestService.listWhiteList(inputSteam);\r
- assertTrue(true);\r
- }\r
-\r
- @Test\r
- public void testCreateWhiteList() throws Exception {\r
- prepareForTestCommon();\r
- String sampleJson = "{ name:\"test\", namespace:\"test\", whitelistTopicName:\"test\"}}";\r
- InputStream inputSteam = new ByteArrayInputStream(sampleJson.getBytes());\r
-\r
- mmRestService.createWhiteList(inputSteam);\r
- assertTrue(true);\r
- }\r
-\r
- @Test\r
- public void testDeleteWhiteList() throws Exception {\r
- prepareForTestCommon();\r
-\r
- String sampleJson = "{ name:\"test\", namespace:\"test\", whitelistTopicName:\"test\"}}";\r
- InputStream inputSteam = new ByteArrayInputStream(sampleJson.getBytes());\r
- mmRestService.deleteWhiteList(inputSteam);\r
- assertTrue(true);\r
- }\r
-\r
- private void prepareForTestCommon() throws Exception {\r
- Assert.assertNotNull(mmRestService);\r
- PowerMockito.when(dmaapContext.getRequest()).thenReturn(httpServReq);\r
- PowerMockito.when(dmaapAAFauthenticator.aafAuthentication(httpServReq, "admin")).thenReturn(true);\r
- PowerMockito.when(httpServReq.isUserInRole("admin")).thenReturn(true);\r
-\r
- PowerMockito.mockStatic(AJSCPropertiesMap.class);\r
-\r
- assertTrue(true);\r
-\r
- PowerMockito.when(AJSCPropertiesMap.getProperty(CambriaConstants.msgRtr_prop, "msgRtr.mirrormakeradmin.aaf"))\r
- .thenReturn("admin");\r
- PowerMockito\r
- .when(AJSCPropertiesMap.getProperty(CambriaConstants.msgRtr_prop, "msgRtr.mirrormakeruser.aaf.create"))\r
- .thenReturn("aafcreate");\r
-\r
- PowerMockito.when(AJSCPropertiesMap.getProperty(CambriaConstants.msgRtr_prop, "msgRtr.mirrormakeruser.aaf"))\r
- .thenReturn("admin");\r
-\r
- PowerMockito.when(AJSCPropertiesMap.getProperty(CambriaConstants.msgRtr_prop, "msgRtr.mirrormaker.timeout"))\r
- .thenReturn("100");\r
-\r
- PowerMockito.when(AJSCPropertiesMap.getProperty(CambriaConstants.msgRtr_prop, "msgRtr.mirrormaker.topic"))\r
- .thenReturn("mirrormaker.topic");\r
-\r
- PowerMockito\r
- .when(AJSCPropertiesMap.getProperty(CambriaConstants.msgRtr_prop, "msgRtr.mirrormaker.consumergroup"))\r
- .thenReturn("mirrormaker.consumergroup");\r
-\r
- PowerMockito.when(AJSCPropertiesMap.getProperty(CambriaConstants.msgRtr_prop, "msgRtr.mirrormaker.consumerid"))\r
- .thenReturn("mirrormaker.consumerid");\r
-\r
- PowerMockito.when(dmaapContext.getRequest()).thenReturn(httpServReq);\r
-\r
- PowerMockito.when(httpServReq.isUserInRole("admin")).thenReturn(true);\r
-\r
- // PowerMockito.when(httpServReq.getHeader("Authorization")).thenReturn("Admin");\r
- PowerMockito.when(dmaapAAFauthenticator.aafAuthentication(httpServReq, "admin.aaf")).thenReturn(true);\r
- PowerMockito.when(dmaapAAFauthenticator.aafAuthentication(httpServReq, "admin")).thenReturn(true);\r
- PowerMockito.when(httpServReq.getHeader("Authorization")).thenReturn("Admin");\r
- PowerMockito.when(dmaapAAFauthenticator.aafAuthentication(httpServReq, "admin")).thenReturn(true);\r
- PowerMockito.when(dmaapAAFauthenticator.aafAuthentication(httpServReq, "aafcreatetest|create"))\r
- .thenReturn(true);\r
-\r
- PowerMockito.when(cMirroMaker.getCreateMirrorMaker()).thenReturn(mMaker);\r
-\r
- PowerMockito.when(mMaker.getName()).thenReturn("mirroMakerName");\r
- PowerMockito.when(dmaapContext.getConfigReader()).thenReturn(configReader);\r
- PowerMockito.when(dmaapContext.getRequest()).thenReturn(httpServReq);\r
- PowerMockito.when(httpServReq.getHeader("Authorization")).thenReturn("Authorization");\r
-\r
- PowerMockito.when(dmaapContext.getResponse()).thenReturn(httpServRes);\r
- PowerMockito.when(configReader.getfMetaBroker()).thenReturn(dmaapKafkaMetaBroker);\r
- PowerMockito.when(httpServReq.getMethod()).thenReturn("HEAD");\r
-\r
- PowerMockito.when(dmaapKafkaMetaBroker.getTopic(anyString())).thenReturn(null);\r
- }\r
-\r
-}\r
+/*-
+ * ============LICENSE_START=======================================================
+ * ONAP Policy Engine
+ * ================================================================================
+ * Copyright (C) 2017 AT&T Intellectual Property. All rights reserved.
+ * ================================================================================
+ * 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.dmaap.service;
+
+import static org.junit.Assert.assertTrue;
+import static org.junit.Assert.fail;
+import static org.mockito.Matchers.anyString;
+
+import java.io.ByteArrayInputStream;
+import java.io.FileInputStream;
+
+//import static org.mockito.Matchers.anyString;
+//import static org.mockito.Mockito.when;
+
+import java.io.IOException;
+import java.io.InputStream;
+
+import javax.servlet.ServletOutputStream;
+import javax.servlet.http.HttpServletRequest;
+import javax.servlet.http.HttpServletResponse;
+
+import org.apache.commons.io.IOUtils;
+import org.json.JSONArray;
+import org.json.JSONException;
+import org.json.JSONObject;
+import org.junit.After;
+import org.junit.Assert;
+import org.junit.Before;
+import org.junit.Test;
+import org.junit.runner.RunWith;
+import org.mockito.InjectMocks;
+import org.mockito.Mock;
+import org.mockito.MockitoAnnotations;
+import org.powermock.api.mockito.PowerMockito;
+import org.powermock.core.classloader.annotations.PrepareForTest;
+import org.powermock.modules.junit4.PowerMockRunner;
+
+import com.att.ajsc.beans.PropertiesMapBean;
+import com.att.ajsc.filemonitor.AJSCPropertiesMap;
+import org.onap.dmaap.dmf.mr.CambriaApiException;
+import org.onap.dmaap.dmf.mr.beans.DMaaPContext;
+import org.onap.dmaap.dmf.mr.beans.DMaaPKafkaMetaBroker;
+import org.onap.dmaap.dmf.mr.constants.CambriaConstants;
+import org.onap.dmaap.dmf.mr.exception.DMaaPAccessDeniedException;
+import org.onap.dmaap.dmf.mr.exception.DMaaPErrorMessages;
+import org.onap.dmaap.dmf.mr.metabroker.Broker.TopicExistsException;
+import org.onap.dmaap.dmf.mr.metabroker.Topic;
+import org.onap.dmaap.dmf.mr.security.DMaaPAAFAuthenticator;
+import org.onap.dmaap.dmf.mr.security.DMaaPAAFAuthenticatorImpl;
+import org.onap.dmaap.dmf.mr.security.DMaaPAuthenticator;
+import org.onap.dmaap.dmf.mr.service.MMService;
+import org.onap.dmaap.dmf.mr.utils.ConfigurationReader;
+import com.att.nsa.configs.ConfigDbException;
+import org.onap.dmaap.mmagent.CreateMirrorMaker;
+import org.onap.dmaap.mmagent.MirrorMaker;
+import org.onap.dmaap.mmagent.UpdateMirrorMaker;
+import com.att.nsa.security.NsaAcl;
+import com.att.nsa.security.NsaApiKey;
+import com.att.nsa.security.db.simple.NsaSimpleApiKey;
+import com.google.gson.Gson;
+
+//@RunWith(MockitoJUnitRunner.class)
+@RunWith(PowerMockRunner.class)
+@PrepareForTest({ PropertiesMapBean.class, AJSCPropertiesMap.class })
+public class MMRestServiceTest {
+
+ @InjectMocks
+ MMRestService mmRestService;
+
+ @Mock
+ private MMService mmservice;
+
+ @Mock
+ CreateMirrorMaker cMirroMaker;
+
+ @Mock
+ UpdateMirrorMaker uMirroMaker;
+
+ private TopicRestService service = new TopicRestService();
+ @Mock
+ private DMaaPErrorMessages errorMessages;
+
+ @Mock
+ DMaaPContext dmaapContext;
+
+ @Mock
+ ConfigurationReader configReader;
+
+ @Mock
+ ServletOutputStream oStream;
+
+ @Mock
+ DMaaPAuthenticator<NsaSimpleApiKey> dmaaPAuthenticator;
+
+ @Mock
+ MirrorMaker mMaker;
+
+ @Mock
+ DMaaPAAFAuthenticator dmaapAAFauthenticator;
+
+ @Mock
+ DMaaPAAFAuthenticatorImpl impl;
+
+ @Mock
+ NsaApiKey user;
+
+ @Mock
+ NsaSimpleApiKey nsaSimpleApiKey;
+
+ @Mock
+ HttpServletRequest httpServReq;
+
+ @Mock
+ HttpServletResponse httpServRes;
+
+ @Mock
+ InputStream iStream;
+
+ @Mock
+ DMaaPKafkaMetaBroker dmaapKafkaMetaBroker;
+
+ @Mock
+ Topic createdTopic;
+
+ @Mock
+ NsaAcl nsaAcl;
+
+ @Mock
+ JSONObject jsonObj;
+
+ @Mock
+ JSONArray jsonArray;
+
+ @Before
+ public void setUp() throws Exception {
+
+ MockitoAnnotations.initMocks(this);
+ }
+
+ @After
+ public void tearDown() throws Exception {
+ }
+
+ @Test
+ public void testCallCreateMirrorMaker() throws Exception {
+ prepareForTestCommon();
+
+ // String sampleJson = ""{ messageID:\"test\", createMirrorMaker: {
+ // name:\"test\", consumer:\"test\", producer:\"test\",
+ // whitelist:\"test\",status:\"test\" }}";
+ String sampleJson = "{ messageID:\"test\", createMirrorMaker: { name:\"test\", consumer:\"test\", producer:\"test\"}}";
+ InputStream inputSteam = new ByteArrayInputStream(sampleJson.getBytes());
+ mmRestService.callCreateMirrorMaker(inputSteam);
+ assertTrue(true);
+
+ }
+ @Test
+ public void testCallCreateMirrorMaker_error4() throws Exception {
+ prepareForTestCommon();
+
+ // String sampleJson = ""{ messageID:\"test\", createMirrorMaker: {
+ // name:\"test\", consumer:\"test\", producer:\"test\",
+ // whitelist:\"test\",status:\"test\" }}";
+ String sampleJson = "{ messageID:\"test\", createMirrorMaker: { name:\"test@#\", consumer:\"test\", producer:\"test\"}}";
+ InputStream inputSteam = new ByteArrayInputStream(sampleJson.getBytes());
+ mmRestService.callCreateMirrorMaker(inputSteam);
+ assertTrue(true);
+
+ }
+ @Test
+ public void testCallCreateMirrorMaker_3() throws Exception {
+ prepareForTestCommon();
+
+ // String sampleJson = ""{ messageID:\"test\", createMirrorMaker: {
+ // name:\"test\", consumer:\"test\", producer:\"test\",
+ // whitelist:\"test\",status:\"test\" }}";
+ String sampleJson = "{ messageID:\"test\", createMirrorMaker: { name:\"\", consumer:\"test\", producer:\"test\"}}";
+ InputStream inputSteam = new ByteArrayInputStream(sampleJson.getBytes());
+ mmRestService.callCreateMirrorMaker(inputSteam);
+ assertTrue(true);
+
+ }
+ @Test
+ public void testCallCreateMirrorMaker_error2() throws Exception {
+ prepareForTestCommon();
+
+ // String sampleJson = ""{ messageID:\"test\", createMirrorMaker: {
+ // name:\"test\", consumer:\"test\", producer:\"test\",
+ // whitelist:\"test\",status:\"test\" }}";
+ String sampleJson = "{ messageID:\"test\", createMirrorMaker: { name:\"test\", consumer:\"test\", producer:\"test\",whitelist:\"test\"}}";
+ InputStream inputSteam = new ByteArrayInputStream(sampleJson.getBytes());
+ mmRestService.callCreateMirrorMaker(inputSteam);
+ assertTrue(true);
+
+ }
+
+ @Test
+ public void testCallCreateMirrorMaker_error1() throws Exception {
+ prepareForTestCommon();
+
+ // String sampleJson = ""{ messageID:\"test\", createMirrorMaker: {
+ // name:\"test\", consumer:\"test\", producer:\"test\",
+ // whitelist:\"test\",status:\"test\" }}";
+ String sampleJson = "{ messageID:\"test\"}";
+ InputStream inputSteam = new ByteArrayInputStream(sampleJson.getBytes());
+ mmRestService.callCreateMirrorMaker(inputSteam);
+ assertTrue(true);
+
+ }
+
+ @Test
+ public void testCallListAllMirrorMaker() throws Exception {
+ prepareForTestCommon();
+
+ String sampleJson = "{ messageID:\"test\", createMirrorMaker: { name:\"test\", consumer:\"test\", producer:\"test\", whitelist:\"test\",status:\"test\" }}";
+ InputStream inputSteam = new ByteArrayInputStream(sampleJson.getBytes());
+ mmRestService.callListAllMirrorMaker(inputSteam);
+ assertTrue(true);
+ }
+
+ @Test
+ public void testCallUpdateMirrorMaker() throws Exception {
+ prepareForTestCommon();
+
+ String sampleJson = "{ messageID:\"test\", updateMirrorMaker: { name:\"test\", consumer:\"test\", producer:\"test\"}}";
+ InputStream inputSteam = new ByteArrayInputStream(sampleJson.getBytes());
+ mmRestService.callUpdateMirrorMaker(inputSteam);
+ assertTrue(true);
+ }
+
+ @Test
+ public void testCallUpdateMirrorMaker_error1() throws Exception {
+ prepareForTestCommon();
+
+ String sampleJson = "{ messageID:\"test@1\", updateMirrorMaker: { name:\"test\", consumer:\"test\", producer:\"test\"}}";
+ InputStream inputSteam = new ByteArrayInputStream(sampleJson.getBytes());
+ mmRestService.callUpdateMirrorMaker(inputSteam);
+ assertTrue(true);
+ }
+ @Test
+ public void testCallUpdateMirrorMaker_error2() throws Exception {
+ prepareForTestCommon();
+
+ String sampleJson = "{ messageID:\"test\", updateMirrorMaker: { name:\"\", consumer:\"test\", producer:\"test\"}}";
+ InputStream inputSteam = new ByteArrayInputStream(sampleJson.getBytes());
+ mmRestService.callUpdateMirrorMaker(inputSteam);
+ assertTrue(true);
+ }
+ @Test
+ public void testCallUpdateMirrorMaker_error3() throws Exception{
+ prepareForTestCommon();
+
+ String sampleJson = "{ messageID:\"test\", updateMirrorMaker: { name:\"test\", consumer:\"test\", producer:\"test\", whitelist:\"test\",status:\"test\"}}";
+ InputStream inputSteam = new ByteArrayInputStream(sampleJson.getBytes());
+ mmRestService.callUpdateMirrorMaker(inputSteam);
+ assertTrue(true);
+ }
+ @Test
+ public void testCallUpdateMirrorMaker_error4() throws Exception {
+ prepareForTestCommon();
+
+ String sampleJson = "{ messageID:\"test\"}}";
+ InputStream inputSteam = new ByteArrayInputStream(sampleJson.getBytes());
+ mmRestService.callUpdateMirrorMaker(inputSteam);
+ assertTrue(true);
+ }
+
+ @Test
+ public void testCallDeleteMirrorMaker() throws Exception {
+ prepareForTestCommon();
+
+ String sampleJson = "{ messageID:\"test\", deleteMirrorMaker: { name:\"test\", consumer:\"test\", producer:\"test\", whitelist:\"test\",status:\"test\" }}";
+ InputStream inputSteam = new ByteArrayInputStream(sampleJson.getBytes());
+ mmRestService.callDeleteMirrorMaker(inputSteam);
+ assertTrue(true);
+ }
+
+ @Test
+ public void testListWhiteList() throws Exception {
+ prepareForTestCommon();
+
+ String sampleJson = "{ name:\"test\", namespace:\"test\"}}";
+ InputStream inputSteam = new ByteArrayInputStream(sampleJson.getBytes());
+ mmRestService.listWhiteList(inputSteam);
+ assertTrue(true);
+ }
+
+ @Test
+ public void testCreateWhiteList() throws Exception {
+ prepareForTestCommon();
+ String sampleJson = "{ name:\"test\", namespace:\"test\", whitelistTopicName:\"test\"}}";
+ InputStream inputSteam = new ByteArrayInputStream(sampleJson.getBytes());
+
+ mmRestService.createWhiteList(inputSteam);
+ assertTrue(true);
+ }
+
+ @Test
+ public void testDeleteWhiteList() throws Exception {
+ prepareForTestCommon();
+
+ String sampleJson = "{ name:\"test\", namespace:\"test\", whitelistTopicName:\"test\"}}";
+ InputStream inputSteam = new ByteArrayInputStream(sampleJson.getBytes());
+ mmRestService.deleteWhiteList(inputSteam);
+ assertTrue(true);
+ }
+
+ private void prepareForTestCommon() throws Exception {
+ Assert.assertNotNull(mmRestService);
+ PowerMockito.when(dmaapContext.getRequest()).thenReturn(httpServReq);
+ PowerMockito.when(dmaapAAFauthenticator.aafAuthentication(httpServReq, "admin")).thenReturn(true);
+ PowerMockito.when(httpServReq.isUserInRole("admin")).thenReturn(true);
+
+ PowerMockito.mockStatic(AJSCPropertiesMap.class);
+
+ assertTrue(true);
+
+ PowerMockito.when(AJSCPropertiesMap.getProperty(CambriaConstants.msgRtr_prop, "msgRtr.mirrormakeradmin.aaf"))
+ .thenReturn("admin");
+ PowerMockito
+ .when(AJSCPropertiesMap.getProperty(CambriaConstants.msgRtr_prop, "msgRtr.mirrormakeruser.aaf.create"))
+ .thenReturn("aafcreate");
+
+ PowerMockito.when(AJSCPropertiesMap.getProperty(CambriaConstants.msgRtr_prop, "msgRtr.mirrormakeruser.aaf"))
+ .thenReturn("admin");
+
+ PowerMockito.when(AJSCPropertiesMap.getProperty(CambriaConstants.msgRtr_prop, "msgRtr.mirrormaker.timeout"))
+ .thenReturn("100");
+
+ PowerMockito.when(AJSCPropertiesMap.getProperty(CambriaConstants.msgRtr_prop, "msgRtr.mirrormaker.topic"))
+ .thenReturn("mirrormaker.topic");
+
+ PowerMockito
+ .when(AJSCPropertiesMap.getProperty(CambriaConstants.msgRtr_prop, "msgRtr.mirrormaker.consumergroup"))
+ .thenReturn("mirrormaker.consumergroup");
+
+ PowerMockito.when(AJSCPropertiesMap.getProperty(CambriaConstants.msgRtr_prop, "msgRtr.mirrormaker.consumerid"))
+ .thenReturn("mirrormaker.consumerid");
+
+ PowerMockito.when(dmaapContext.getRequest()).thenReturn(httpServReq);
+
+ PowerMockito.when(httpServReq.isUserInRole("admin")).thenReturn(true);
+
+ // PowerMockito.when(httpServReq.getHeader("Authorization")).thenReturn("Admin");
+ PowerMockito.when(dmaapAAFauthenticator.aafAuthentication(httpServReq, "admin.aaf")).thenReturn(true);
+ PowerMockito.when(dmaapAAFauthenticator.aafAuthentication(httpServReq, "admin")).thenReturn(true);
+ PowerMockito.when(httpServReq.getHeader("Authorization")).thenReturn("Admin");
+ PowerMockito.when(dmaapAAFauthenticator.aafAuthentication(httpServReq, "admin")).thenReturn(true);
+ PowerMockito.when(dmaapAAFauthenticator.aafAuthentication(httpServReq, "aafcreatetest|create"))
+ .thenReturn(true);
+
+ PowerMockito.when(cMirroMaker.getCreateMirrorMaker()).thenReturn(mMaker);
+
+ PowerMockito.when(mMaker.getName()).thenReturn("mirroMakerName");
+ PowerMockito.when(dmaapContext.getConfigReader()).thenReturn(configReader);
+ PowerMockito.when(dmaapContext.getRequest()).thenReturn(httpServReq);
+ PowerMockito.when(httpServReq.getHeader("Authorization")).thenReturn("Authorization");
+
+ PowerMockito.when(dmaapContext.getResponse()).thenReturn(httpServRes);
+ PowerMockito.when(configReader.getfMetaBroker()).thenReturn(dmaapKafkaMetaBroker);
+ PowerMockito.when(httpServReq.getMethod()).thenReturn("HEAD");
+
+ PowerMockito.when(dmaapKafkaMetaBroker.getTopic(anyString())).thenReturn(null);
+ }
+
+}
Code Review / dmaap / messagerouter / messageservice.git / blobdiff