</arguments>\r
</buildCommand>\r
<buildCommand>\r
- <name>org.eclipse.m2e.core.maven2Builder</name>\r
+ <name>org.springframework.ide.eclipse.core.springbuilder</name>\r
<arguments>\r
</arguments>\r
</buildCommand>\r
<buildCommand>\r
- <name>org.springframework.ide.eclipse.core.springbuilder</name>\r
+ <name>org.springframework.ide.eclipse.boot.validation.springbootbuilder</name>\r
<arguments>\r
</arguments>\r
</buildCommand>\r
<buildCommand>\r
- <name>org.springframework.ide.eclipse.boot.validation.springbootbuilder</name>\r
+ <name>org.eclipse.m2e.core.maven2Builder</name>\r
<arguments>\r
</arguments>\r
</buildCommand>\r
<version>2.8.5</version>
<scope>test</scope>
</dependency>
+
+ <dependency>
+ <groupId>com.fasterxml.jackson.core</groupId>
+ <artifactId>jackson-databind</artifactId>
+ <version>2.3.3</version>
+ </dependency>
<dependency>
<groupId>org.powermock</groupId>
<artifactId>powermock-api-mockito</artifactId>
- <version>1.5.6</version>
+ <version>1.6.4</version>
<scope>test</scope>
</dependency>
<dependency>
<groupId>org.powermock</groupId>
<artifactId>powermock-module-junit4</artifactId>
- <version>1.5.6</version>
+ <version>1.6.4</version>
<scope>test</scope>
</dependency>
<dependency>
<groupId>org.powermock</groupId>
<artifactId>powermock-module-junit4-rule</artifactId>
- <version>1.5.6</version>
+ <version>1.6.4</version>
<scope>test</scope>
</dependency>
+ <dependency>
+ <groupId>org.mockito</groupId>
+ <artifactId>mockito-core</artifactId>
+ <version>1.10.19</version>
+ <scope>test</scope>
+ </dependency>
</dependencies>
<build>
import org.junit.Before;\r
import org.junit.Test;\r
\r
+import com.att.nsa.cambria.CambriaApiException;\r
+\r
public class DMaaPCambriaLimiterTest {\r
\r
@Before\r
\r
}\r
\r
+ @Test\r
+ public void testOnCall() {\r
+ \r
+ DMaaPCambriaLimiter limiter = new DMaaPCambriaLimiter(1, 3);\r
+ try {\r
+ limiter.onCall("testTopic", "ConsumerGroup1", "client2");\r
+ } catch (CambriaApiException e) {\r
+ // TODO Auto-generated catch block\r
+ e.printStackTrace();\r
+ }\r
+ \r
+ String trueValue = "True";\r
+ assertTrue(trueValue.equalsIgnoreCase("True"));\r
+ \r
+ }\r
+ \r
+ @Test\r
+ public void testOnSend() {\r
+ \r
+ DMaaPCambriaLimiter limiter = new DMaaPCambriaLimiter(3, 3);\r
+ limiter.onSend("testTopic", "consumerGroup1", "client1", 100);\r
+ \r
+ String trueValue = "True";\r
+ assertTrue(trueValue.equalsIgnoreCase("True"));\r
+ \r
+ }\r
+ \r
\r
\r
}\r
+++ /dev/null
-/*-\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.cambria.beans;\r
-\r
-import static org.junit.Assert.*;\r
-\r
-import org.junit.After;\r
-import org.junit.Before;\r
-import org.junit.Test;\r
-\r
-import com.att.nsa.cambria.CambriaApiException;\r
-\r
-public class DMaaPCambriaLimiterTest2 {\r
-\r
- @Before\r
- public void setUp() throws Exception {\r
- }\r
-\r
- @After\r
- public void tearDown() throws Exception {\r
- }\r
-\r
- @Test\r
- public void testOnCall() {\r
- \r
- DMaaPCambriaLimiter limiter = new DMaaPCambriaLimiter(3, 3);\r
- try {\r
- limiter.onCall("testTopic", "ConsumerGroup1", "client2");\r
- } catch (CambriaApiException e) {\r
- // TODO Auto-generated catch block\r
- e.printStackTrace();\r
- }\r
- \r
- String trueValue = "True";\r
- assertTrue(trueValue.equalsIgnoreCase("True"));\r
- \r
- }\r
- \r
- \r
-\r
-}\r
+++ /dev/null
-/*-\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.cambria.beans;\r
-\r
-import static org.junit.Assert.*;\r
-\r
-import org.junit.After;\r
-import org.junit.Before;\r
-import org.junit.Test;\r
-\r
-import com.att.nsa.cambria.CambriaApiException;\r
-\r
-public class DMaaPCambriaLimiterTest3 {\r
-\r
- @Before\r
- public void setUp() throws Exception {\r
- }\r
-\r
- @After\r
- public void tearDown() throws Exception {\r
- }\r
-\r
- @Test\r
- public void testOnSend() {\r
- \r
- DMaaPCambriaLimiter limiter = new DMaaPCambriaLimiter(3, 3);\r
- limiter.onSend("testTopic", "consumerGroup1", "client1", 100);\r
- \r
- String trueValue = "True";\r
- assertTrue(trueValue.equalsIgnoreCase("True"));\r
- \r
- }\r
- \r
- \r
-\r
-}\r
\r
@RunWith(Suite.class)\r
@SuiteClasses({ ApiKeyBeanTest.class, ApiKeyBeanTest2.class, ApiKeyBeanTest3.class, ApiKeyBeanTest4.class, ApiKeyBeanTest5.class, ApiKeyBeanTest6.class, \r
- DMaaPCambriaLimiterTest.class, DMaaPCambriaLimiterTest2.class,DMaaPCambriaLimiterTest3.class,DMaaPContextTest.class, DMaaPContextTest2.class, \r
+ DMaaPCambriaLimiterTest.class, DMaaPContextTest.class, DMaaPContextTest2.class, \r
DMaaPContextTest3.class,DMaaPContextTest4.class,DMaaPContextTest5.class,DMaaPContextTest6.class,\r
LogDetailsTest.class, LogDetailsTest2.class,LogDetailsTest3.class,LogDetailsTest4.class,LogDetailsTest5.class,LogDetailsTest6.class,\r
LogDetailsTest7.class,LogDetailsTest8.class,LogDetailsTest9.class,LogDetailsTest10.class,LogDetailsTest11.class,LogDetailsTest12.class,\r
\r
}\r
\r
+ @Test\r
+ public void testGetPublisherLogDetails(){\r
+ \r
+ LogDetails details = new LogDetails();\r
+ details.setTotalMessageCount(1);\r
+ details.setConsumeTimestamp("02-27-1018");\r
+ details.setSubscriberGroupId("1");\r
+ details.setSubscriberId("1");\r
+ assertEquals(details.getTotalMessageCount(),1);\r
+ assertEquals(details.getConsumeTimestamp(),"02-27-1018");\r
+ assertEquals(details.getSubscriberId(),"1");\r
+ assertEquals(details.getSubscriberGroupId(),"1");\r
+ }\r
+ \r
\r
\r
}\r
* ============LICENSE_END=========================================================\r
*/\r
\r
-\r
package com.att.nsa.cambria.service.impl;\r
\r
import static org.junit.Assert.*;\r
\r
import java.io.IOException;\r
-import java.util.Date;\r
\r
+import com.att.nsa.cambria.backends.ConsumerFactory;\r
import com.att.nsa.cambria.beans.DMaaPContext;\r
-import com.att.nsa.cambria.embed.EmbedConfigurationReader;\r
+import com.att.nsa.cambria.security.DMaaPAuthenticatorImpl;\r
import com.att.nsa.cambria.utils.ConfigurationReader;\r
+import com.att.nsa.cambria.utils.DMaaPResponseBuilder;\r
import com.att.nsa.configs.ConfigDbException;\r
-import com.att.nsa.drumlin.till.data.sha1HmacSigner;\r
+import com.att.nsa.limits.Blacklist;\r
import com.att.nsa.security.ReadWriteSecuredResource.AccessDeniedException;\r
+import com.att.nsa.security.db.simple.NsaSimpleApiKey;\r
\r
-import org.junit.AfterClass;\r
-import org.junit.BeforeClass;\r
+import org.junit.After;\r
+import org.junit.Before;\r
import org.junit.Test;\r
-import org.springframework.mock.web.MockHttpServletRequest;\r
-import org.springframework.mock.web.MockHttpServletResponse;\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
+@RunWith(PowerMockRunner.class)\r
+@PrepareForTest({ DMaaPAuthenticatorImpl.class, DMaaPResponseBuilder.class })\r
public class AdminServiceImplemTest {\r
- \r
- private static DMaaPContext context = new DMaaPContext();\r
- \r
- private static EmbedConfigurationReader embedConfigurationReader = new EmbedConfigurationReader();\r
-\r
- @BeforeClass\r
- public static void setUp() throws Exception {\r
-\r
- final long nowMs = System.currentTimeMillis();\r
- Date date = new Date(nowMs + 10000);\r
-\r
- final String serverCalculatedSignature = sha1HmacSigner.sign(date.toString(), "password");\r
- MockHttpServletRequest request = new MockHttpServletRequest();\r
- request.addHeader("X-Auth", "admin:" + serverCalculatedSignature);\r
-\r
- //NsaSimpleApiKey apiKey = new NsaSimpleApiKey("admin", "password");\r
- // PowerMockito.when(baseNsaApiDbImpl.loadApiKey("b/7ouTn9FfEw2PQwL0ov/Q==")).thenReturn(apiKey);\r
-\r
- request.addHeader("X-Date", date);\r
- request.addHeader("Date", date);\r
- MockHttpServletResponse response = new MockHttpServletResponse();\r
- context.setRequest(request);\r
- context.setResponse(response);\r
- context.setConfigReader(embedConfigurationReader.buildConfigurationReader());\r
+\r
+ @InjectMocks\r
+ AdminServiceImpl adminServiceImpl;\r
+\r
+ @Mock\r
+ DMaaPContext dmaapContext;\r
+ @Mock\r
+ ConsumerFactory factory;\r
+\r
+ @Mock\r
+ ConfigurationReader configReader;\r
+ @Mock\r
+ Blacklist Blacklist;\r
+\r
+ @Before\r
+ public void setUp() throws Exception {\r
+\r
+ MockitoAnnotations.initMocks(this);\r
+ PowerMockito.mockStatic(DMaaPAuthenticatorImpl.class);\r
+ NsaSimpleApiKey user = new NsaSimpleApiKey("admin", "password");\r
+\r
+ PowerMockito.when(dmaapContext.getConfigReader()).thenReturn(configReader);\r
+ PowerMockito.when(configReader.getfConsumerFactory()).thenReturn(factory);\r
+ PowerMockito.when(configReader.getfIpBlackList()).thenReturn(Blacklist);\r
+\r
+ PowerMockito.when(DMaaPAuthenticatorImpl.getAuthenticatedUser(dmaapContext)).thenReturn(user);\r
+ PowerMockito.mockStatic(DMaaPResponseBuilder.class);\r
}\r
\r
- @AfterClass\r
- public static void tearDown() throws Exception {\r
- embedConfigurationReader.tearDown();\r
+ @After\r
+ public void tearDown() throws Exception {\r
}\r
\r
- \r
- //ISSUES WITH AUTHENTICATION\r
+ // ISSUES WITH AUTHENTICATION\r
@Test\r
public void testShowConsumerCache() {\r
- \r
- AdminServiceImpl adminServiceImpl = new AdminServiceImpl();\r
+\r
try {\r
- adminServiceImpl.showConsumerCache(context);\r
+ adminServiceImpl.showConsumerCache(dmaapContext);\r
} catch (IOException | AccessDeniedException e) {\r
// TODO Auto-generated catch block\r
e.printStackTrace();\r
} catch (NullPointerException e) {\r
// TODO Auto-generated catch block\r
- //e.printStackTrace();\r
+ // e.printStackTrace();\r
assertTrue(true);\r
}\r
- \r
- \r
+\r
String trueValue = "True";\r
assertTrue(trueValue.equalsIgnoreCase("True"));\r
- \r
- \r
+\r
}\r
- \r
+\r
@Test\r
public void testDropConsumerCache() {\r
- \r
- AdminServiceImpl adminServiceImpl = new AdminServiceImpl();\r
+\r
try {\r
- adminServiceImpl.dropConsumerCache(context);\r
+ adminServiceImpl.dropConsumerCache(dmaapContext);\r
} catch (IOException | AccessDeniedException e) {\r
// TODO Auto-generated catch block\r
e.printStackTrace();\r
} catch (NullPointerException e) {\r
// TODO Auto-generated catch block\r
- //e.printStackTrace();\r
+ // e.printStackTrace();\r
assertTrue(true);\r
}\r
- \r
- \r
+\r
String trueValue = "True";\r
assertTrue(trueValue.equalsIgnoreCase("True"));\r
- \r
- \r
+\r
}\r
- \r
+\r
@Test\r
public void testGetBlacklist() {\r
- \r
- AdminServiceImpl adminServiceImpl = new AdminServiceImpl();\r
+\r
try {\r
- adminServiceImpl.getBlacklist(context);\r
+ adminServiceImpl.getBlacklist(dmaapContext);\r
} catch (IOException | AccessDeniedException e) {\r
// TODO Auto-generated catch block\r
e.printStackTrace();\r
} catch (NullPointerException e) {\r
// TODO Auto-generated catch block\r
- //e.printStackTrace();\r
+ // e.printStackTrace();\r
assertTrue(true);\r
}\r
- \r
- \r
+\r
String trueValue = "True";\r
assertTrue(trueValue.equalsIgnoreCase("True"));\r
- \r
- \r
+\r
}\r
- \r
+\r
@Test\r
public void testAddToBlacklist() {\r
- \r
- AdminServiceImpl adminServiceImpl = new AdminServiceImpl();\r
+\r
try {\r
- adminServiceImpl.addToBlacklist(context, "120.120.120.120");\r
+ adminServiceImpl.addToBlacklist(dmaapContext, "120.120.120.120");\r
} catch (IOException | AccessDeniedException | ConfigDbException e) {\r
// TODO Auto-generated catch block\r
e.printStackTrace();\r
} catch (NullPointerException e) {\r
// TODO Auto-generated catch block\r
- //e.printStackTrace();\r
+ // e.printStackTrace();\r
assertTrue(true);\r
}\r
- \r
- \r
+\r
String trueValue = "True";\r
assertTrue(trueValue.equalsIgnoreCase("True"));\r
- \r
- \r
+\r
}\r
- \r
+\r
@Test\r
public void testRemoveFromBlacklist() {\r
- \r
- AdminServiceImpl adminServiceImpl = new AdminServiceImpl();\r
+\r
try {\r
- adminServiceImpl.addToBlacklist(context, "120.120.120.120");\r
+ adminServiceImpl.removeFromBlacklist(dmaapContext, "120.120.120.120");\r
} catch (IOException | AccessDeniedException | ConfigDbException e) {\r
// TODO Auto-generated catch block\r
e.printStackTrace();\r
} catch (NullPointerException e) {\r
// TODO Auto-generated catch block\r
- //e.printStackTrace();\r
+ // e.printStackTrace();\r
assertTrue(true);\r
}\r
- \r
- \r
+\r
String trueValue = "True";\r
assertTrue(trueValue.equalsIgnoreCase("True"));\r
- \r
- \r
+\r
}\r
- \r
- \r
\r
}\r
import static org.junit.Assert.*;\r
\r
import java.io.IOException;\r
+import java.util.Arrays;\r
+import java.util.HashSet;\r
+import java.util.Map;\r
+import java.util.Set;\r
\r
+import com.att.nsa.cambria.backends.ConsumerFactory;\r
import com.att.nsa.cambria.beans.ApiKeyBean;\r
import com.att.nsa.cambria.beans.DMaaPContext;\r
+import com.att.nsa.cambria.security.DMaaPAuthenticatorImpl;\r
+import com.att.nsa.cambria.utils.ConfigurationReader;\r
+import com.att.nsa.cambria.utils.DMaaPResponseBuilder;\r
+import com.att.nsa.cambria.utils.Emailer;\r
import com.att.nsa.configs.ConfigDbException;\r
+import com.att.nsa.limits.Blacklist;\r
import com.att.nsa.security.ReadWriteSecuredResource.AccessDeniedException;\r
+import com.att.nsa.security.db.NsaApiDb;\r
import com.att.nsa.security.db.NsaApiDb.KeyExistsException;\r
+import com.att.nsa.security.db.simple.NsaSimpleApiKey;\r
\r
import org.junit.After;\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
+@RunWith(PowerMockRunner.class)\r
+@PrepareForTest({ DMaaPAuthenticatorImpl.class, DMaaPResponseBuilder.class })\r
public class ApiKeysServiceImplTest {\r
+ \r
+ @InjectMocks\r
+ ApiKeysServiceImpl service;\r
+\r
+ @Mock\r
+ DMaaPContext dmaapContext;\r
+ @Mock\r
+ ConsumerFactory factory;\r
+\r
+ @Mock\r
+ ConfigurationReader configReader;\r
+ @Mock\r
+ Blacklist Blacklist;\r
+ @Mock\r
+ Emailer emailer;\r
\r
@Before\r
public void setUp() throws Exception {\r
+\r
+ MockitoAnnotations.initMocks(this);\r
+ PowerMockito.mockStatic(DMaaPAuthenticatorImpl.class);\r
+ NsaSimpleApiKey user = new NsaSimpleApiKey("admin", "password");\r
+\r
+ PowerMockito.when(dmaapContext.getConfigReader()).thenReturn(configReader);\r
+ PowerMockito.when(configReader.getfConsumerFactory()).thenReturn(factory);\r
+ PowerMockito.when(configReader.getfIpBlackList()).thenReturn(Blacklist);\r
+ \r
+ PowerMockito.when(configReader.getfApiKeyDb()).thenReturn(fApiKeyDb);\r
+ PowerMockito.when(configReader.getSystemEmailer()).thenReturn(emailer);\r
+ PowerMockito.when(DMaaPAuthenticatorImpl.getAuthenticatedUser(dmaapContext)).thenReturn(user);\r
+ PowerMockito.mockStatic(DMaaPResponseBuilder.class);\r
+ \r
}\r
\r
@After\r
@Test\r
public void testGetAllApiKeys() {\r
\r
- /* ApiKeysServiceImpl service = new ApiKeysServiceImpl();\r
+ service = new ApiKeysServiceImpl();\r
try {\r
- service.getAllApiKeys(new DMaaPContext());\r
+ service.getAllApiKeys(dmaapContext);\r
} catch (NullPointerException e) {\r
// TODO Auto-generated catch block\r
//e.printStackTrace();\r
- assertTrue(true);\r
+ \r
} catch (ConfigDbException e) {\r
// TODO Auto-generated catch block\r
e.printStackTrace();\r
} catch (IOException e) {\r
// TODO Auto-generated catch block\r
e.printStackTrace();\r
- }*/\r
+ }\r
+ assertTrue(true);\r
\r
}\r
\r
@Test\r
public void testGetApiKey() {\r
- /*\r
+ \r
ApiKeysServiceImpl service = new ApiKeysServiceImpl();\r
try {\r
- service.getApiKey(new DMaaPContext(), "k35Hdw6Sde");\r
+ service.getApiKey(dmaapContext, "testkey");\r
} catch (NullPointerException e) {\r
// TODO Auto-generated catch block\r
//e.printStackTrace();\r
e.printStackTrace();\r
} catch (IOException e) {\r
// TODO Auto-generated catch block\r
+ }\r
+ assertTrue(true);\r
+ \r
+ }\r
+ \r
+ @Test\r
+ public void testGetApiKey_error() {\r
+ \r
+ ApiKeysServiceImpl service = new ApiKeysServiceImpl();\r
+ try {\r
+ service.getApiKey(dmaapContext, "k35Hdw6Sde");\r
+ } catch (NullPointerException e) {\r
+ // TODO Auto-generated catch block\r
+ //e.printStackTrace();\r
+ } catch (ConfigDbException e) {\r
+ // TODO Auto-generated catch block\r
e.printStackTrace();\r
- }*/\r
+ } catch (IOException e) {\r
+ // TODO Auto-generated catch block\r
+ assertTrue(true);\r
+ }\r
\r
}\r
\r
@Test\r
public void testCreateApiKey() {\r
\r
- /* ApiKeysServiceImpl service = new ApiKeysServiceImpl();\r
+ ApiKeysServiceImpl service = new ApiKeysServiceImpl();\r
try {\r
- service.createApiKey(new DMaaPContext(), new ApiKeyBean("hs647a@att.com", "testing apikey bean"));\r
+ service.createApiKey(dmaapContext, new ApiKeyBean("test@onap.com", "testing apikey bean"));\r
} catch (NullPointerException e) {\r
// TODO Auto-generated catch block\r
//e.printStackTrace();\r
- assertTrue(true);\r
} catch (ConfigDbException e) {\r
// TODO Auto-generated catch block\r
e.printStackTrace();\r
// TODO Auto-generated catch block\r
e.printStackTrace();\r
} catch(NoClassDefFoundError e) {\r
+ \r
+ }\r
+ assertTrue(true);\r
+ }\r
+ \r
+ @Test\r
+ public void testUpdateApiKey() {\r
+ \r
+ ApiKeysServiceImpl service = new ApiKeysServiceImpl();\r
+ try {\r
+ \r
+ service.updateApiKey(dmaapContext, "admin", new ApiKeyBean("test@onapt.com", "testing apikey bean"));\r
+ } catch (NullPointerException e) {\r
+ // TODO Auto-generated catch block\r
+ //e.printStackTrace();\r
+ } catch (ConfigDbException e) {\r
+ // TODO Auto-generated catch block\r
+ e.printStackTrace();\r
+ } catch (IOException e) {\r
+ // TODO Auto-generated catch block\r
+ e.printStackTrace();\r
+ } catch (AccessDeniedException e) {\r
+ // TODO Auto-generated catch block\r
+ e.printStackTrace();\r
+ }\r
+ assertTrue(true);\r
+ \r
+ }\r
+ @Test\r
+ public void testUpdateApiKey_error() {\r
+ \r
+ ApiKeysServiceImpl service = new ApiKeysServiceImpl();\r
+ try {\r
+ \r
+ service.updateApiKey(dmaapContext, null, new ApiKeyBean("test@onapt.com", "testing apikey bean"));\r
+ } catch (NullPointerException e) {\r
+ // TODO Auto-generated catch block\r
+ //e.printStackTrace();\r
+ assertTrue(true);\r
+ } catch (ConfigDbException e) {\r
+ // TODO Auto-generated catch block\r
+ e.printStackTrace();\r
+ } catch (IOException e) {\r
+ // TODO Auto-generated catch block\r
assertTrue(true);\r
- }*/\r
+ } catch (AccessDeniedException e) {\r
+ // TODO Auto-generated catch block\r
+ e.printStackTrace();\r
+ }\r
\r
}\r
\r
@Test\r
- public void testUpdateApiKey() {\r
+ public void testDeleteApiKey() {\r
\r
-/* ApiKeysServiceImpl service = new ApiKeysServiceImpl();\r
+ ApiKeysServiceImpl service = new ApiKeysServiceImpl();\r
try {\r
\r
- service.updateApiKey(new DMaaPContext(), "k6dWUcw4N", new ApiKeyBean("hs647a@att.com", "testing apikey bean"));\r
+ service.deleteApiKey(dmaapContext, null);\r
} catch (NullPointerException e) {\r
// TODO Auto-generated catch block\r
//e.printStackTrace();\r
// TODO Auto-generated catch block\r
e.printStackTrace();\r
}\r
- */\r
+ \r
}\r
\r
@Test\r
- public void testDeleteApiKey() {\r
+ public void testDeleteApiKey_error() {\r
\r
- /* ApiKeysServiceImpl service = new ApiKeysServiceImpl();\r
+ ApiKeysServiceImpl service = new ApiKeysServiceImpl();\r
try {\r
\r
- service.deleteApiKey(new DMaaPContext(), "k6dWUcw4N");\r
+ service.deleteApiKey(dmaapContext, "admin");\r
} catch (NullPointerException e) {\r
// TODO Auto-generated catch block\r
//e.printStackTrace();\r
} catch (AccessDeniedException e) {\r
// TODO Auto-generated catch block\r
e.printStackTrace();\r
- }*/\r
+ }\r
\r
}\r
+ \r
+ NsaApiDb<NsaSimpleApiKey> fApiKeyDb= new NsaApiDb<NsaSimpleApiKey>() {\r
+ \r
+ \r
+ Set<String> keys = new HashSet<>(Arrays.asList("testkey","admin"));\r
+ \r
+ \r
+ @Override\r
+ public NsaSimpleApiKey createApiKey(String arg0, String arg1)\r
+ throws com.att.nsa.security.db.NsaApiDb.KeyExistsException, ConfigDbException {\r
+ // TODO Auto-generated method stub\r
+ return new NsaSimpleApiKey(arg0, arg1);\r
+ }\r
+\r
+ @Override\r
+ public boolean deleteApiKey(NsaSimpleApiKey arg0) throws ConfigDbException {\r
+ // TODO Auto-generated method stub\r
+ return false;\r
+ }\r
+\r
+ @Override\r
+ public boolean deleteApiKey(String arg0) throws ConfigDbException {\r
+ // TODO Auto-generated method stub\r
+ return false;\r
+ }\r
+\r
+ @Override\r
+ public Map<String, NsaSimpleApiKey> loadAllKeyRecords() throws ConfigDbException {\r
+ // TODO Auto-generated method stub\r
+ return null;\r
+ }\r
+\r
+ @Override\r
+ public Set<String> loadAllKeys() throws ConfigDbException {\r
+ // TODO Auto-generated method stub\r
+ \r
+ return keys ;\r
+ }\r
+\r
+ @Override\r
+ public NsaSimpleApiKey loadApiKey(String arg0) throws ConfigDbException {\r
+ if(!keys.contains(arg0)){\r
+ return null;\r
+ }\r
+ return new NsaSimpleApiKey(arg0, "password");\r
+ }\r
+\r
+ @Override\r
+ public void saveApiKey(NsaSimpleApiKey arg0) throws ConfigDbException {\r
+ // TODO Auto-generated method stub\r
+ \r
+ }\r
+ };\r
}
\ No newline at end of file
* ============LICENSE_END=========================================================\r
*/\r
\r
-\r
package com.att.nsa.cambria.service.impl;\r
\r
import static org.junit.Assert.*;\r
import java.io.ByteArrayInputStream;\r
import java.io.IOException;\r
import java.io.InputStream;\r
+import java.util.Arrays;\r
+import java.util.HashSet;\r
+import java.util.Map;\r
+import java.util.Set;\r
\r
+import com.att.ajsc.beans.PropertiesMapBean;\r
+import com.att.ajsc.filemonitor.AJSCPropertiesMap;\r
import com.att.nsa.cambria.CambriaApiException;\r
+import com.att.nsa.cambria.backends.ConsumerFactory;\r
import com.att.nsa.cambria.backends.ConsumerFactory.UnavailableException;\r
import com.att.nsa.cambria.beans.DMaaPContext;\r
+import com.att.nsa.cambria.beans.DMaaPKafkaMetaBroker;\r
+import com.att.nsa.cambria.constants.CambriaConstants;\r
+import com.att.nsa.cambria.exception.DMaaPErrorMessages;\r
+import com.att.nsa.cambria.metabroker.Topic;\r
import com.att.nsa.cambria.metabroker.Broker.TopicExistsException;\r
+import com.att.nsa.cambria.security.DMaaPAuthenticatorImpl;\r
+import com.att.nsa.cambria.utils.ConfigurationReader;\r
+import com.att.nsa.cambria.utils.DMaaPResponseBuilder;\r
+import com.att.nsa.cambria.utils.Emailer;\r
import com.att.nsa.configs.ConfigDbException;\r
import com.att.nsa.drumlin.till.nv.rrNvReadable.missingReqdSetting;\r
+import com.att.nsa.limits.Blacklist;\r
import com.att.nsa.security.ReadWriteSecuredResource.AccessDeniedException;\r
+import com.att.nsa.security.db.NsaApiDb;\r
+import com.att.nsa.security.db.simple.NsaSimpleApiKey;\r
\r
import org.junit.After;\r
import org.junit.Before;\r
import org.junit.Test;\r
+import org.junit.runner.RunWith;\r
+import static org.mockito.Matchers.anyString;\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
+import org.springframework.mock.web.MockHttpServletRequest;\r
+import org.springframework.mock.web.MockHttpServletResponse;\r
\r
+@RunWith(PowerMockRunner.class)\r
+@PrepareForTest({ DMaaPAuthenticatorImpl.class, DMaaPResponseBuilder.class, PropertiesMapBean.class,\r
+ AJSCPropertiesMap.class })\r
public class MMServiceImplTest {\r
\r
+ @InjectMocks\r
+ MMServiceImpl service;\r
+\r
+ @Mock\r
+ DMaaPContext dmaapContext;\r
+ @Mock\r
+ ConsumerFactory factory;\r
+ @Mock\r
+ private DMaaPErrorMessages errorMessages;\r
+ @Mock\r
+ ConfigurationReader configReader;\r
+ @Mock\r
+ Blacklist Blacklist;\r
+ @Mock\r
+ Emailer emailer;\r
+ @Mock\r
+ DMaaPKafkaMetaBroker dmaapKafkaMetaBroker;\r
+ @Mock\r
+ Topic metatopic;\r
+\r
@Before\r
public void setUp() throws Exception {\r
+\r
+ MockitoAnnotations.initMocks(this);\r
+ PowerMockito.mockStatic(DMaaPAuthenticatorImpl.class);\r
+ NsaSimpleApiKey user = new NsaSimpleApiKey("admin", "password");\r
+\r
+ PowerMockito.when(dmaapContext.getConfigReader()).thenReturn(configReader);\r
+ PowerMockito.when(configReader.getfConsumerFactory()).thenReturn(factory);\r
+ PowerMockito.when(configReader.getfIpBlackList()).thenReturn(Blacklist);\r
+\r
+ PowerMockito.when(configReader.getfApiKeyDb()).thenReturn(fApiKeyDb);\r
+ PowerMockito.when(configReader.getSystemEmailer()).thenReturn(emailer);\r
+ PowerMockito.when(DMaaPAuthenticatorImpl.getAuthenticatedUser(dmaapContext)).thenReturn(user);\r
+ PowerMockito.mockStatic(DMaaPResponseBuilder.class);\r
+\r
+ MockHttpServletRequest request = new MockHttpServletRequest();\r
+ MockHttpServletResponse response = new MockHttpServletResponse();\r
+ PowerMockito.when(dmaapContext.getRequest()).thenReturn(request);\r
+ PowerMockito.when(dmaapContext.getResponse()).thenReturn(response);\r
+\r
+ PowerMockito.mockStatic(AJSCPropertiesMap.class);\r
+ PowerMockito.mockStatic(PropertiesMapBean.class);\r
+ PowerMockito.when(AJSCPropertiesMap.getProperty(CambriaConstants.msgRtr_prop, "timeout")).thenReturn("1000");\r
+ PowerMockito.when(AJSCPropertiesMap.getProperty(CambriaConstants.msgRtr_prop, "pretty")).thenReturn("true");\r
+ PowerMockito.when(AJSCPropertiesMap.getProperty(CambriaConstants.msgRtr_prop, "meta")).thenReturn("true");\r
+ PowerMockito.when(configReader.getfMetaBroker()).thenReturn(dmaapKafkaMetaBroker);\r
+\r
}\r
\r
@After\r
public void tearDown() throws Exception {\r
}\r
- \r
+\r
@Test\r
- public void testAddWhiteList() {\r
- \r
- MMServiceImpl service = new MMServiceImpl();\r
+ public void testSubscribe_Blacklistip() {\r
+\r
try {\r
- service.addWhiteList();\r
+ PowerMockito.when(Blacklist.contains("127.0.0.1")).thenReturn(true);\r
+ service.subscribe(dmaapContext, "testTopic", "CG1", "23");\r
} catch (org.json.JSONException e) {\r
// TODO Auto-generated catch block\r
e.printStackTrace();\r
} catch (NullPointerException e) {\r
// TODO Auto-generated catch block\r
- //e.printStackTrace();\r
+ // e.printStackTrace();\r
+ } catch (CambriaApiException e) {\r
assertTrue(true);\r
- } \r
- \r
- String trueValue = "True";\r
- assertTrue(trueValue.equalsIgnoreCase("True"));\r
- \r
+ } catch (ConfigDbException e) {\r
+ // TODO Auto-generated catch block\r
+ e.printStackTrace();\r
+ } catch (TopicExistsException e) {\r
+ // TODO Auto-generated catch block\r
+ e.printStackTrace();\r
+ } catch (AccessDeniedException e) {\r
+ // TODO Auto-generated catch block\r
+ e.printStackTrace();\r
+ } catch (UnavailableException e) {\r
+ // TODO Auto-generated catch block\r
+ e.printStackTrace();\r
+ } catch (IOException e) {\r
+ // TODO Auto-generated catch block\r
+ e.printStackTrace();\r
+ }\r
+\r
}\r
- \r
+\r
@Test\r
- public void testRemoveWhiteList() {\r
- \r
- MMServiceImpl service = new MMServiceImpl();\r
+ public void testSubscribe_NullTopic() {\r
+\r
try {\r
- service.removeWhiteList();\r
+ PowerMockito.when(dmaapKafkaMetaBroker.getTopic(anyString())).thenReturn(null);\r
+ service.subscribe(dmaapContext, "testTopic", "CG1", "23");\r
} catch (org.json.JSONException e) {\r
// TODO Auto-generated catch block\r
e.printStackTrace();\r
} catch (NullPointerException e) {\r
// TODO Auto-generated catch block\r
- //e.printStackTrace();\r
+ // e.printStackTrace();\r
assertTrue(true);\r
- } \r
- \r
- String trueValue = "True";\r
- assertTrue(trueValue.equalsIgnoreCase("True"));\r
- \r
+ } catch (CambriaApiException e) {\r
+ assertTrue(true);\r
+ } catch (ConfigDbException e) {\r
+ // TODO Auto-generated catch block\r
+ e.printStackTrace();\r
+ } catch (TopicExistsException e) {\r
+ // TODO Auto-generated catch block\r
+ e.printStackTrace();\r
+ } catch (AccessDeniedException e) {\r
+ // TODO Auto-generated catch block\r
+ e.printStackTrace();\r
+ } catch (UnavailableException e) {\r
+ // TODO Auto-generated catch block\r
+ e.printStackTrace();\r
+ } catch (IOException e) {\r
+ // TODO Auto-generated catch block\r
+ e.printStackTrace();\r
+ }\r
+\r
}\r
- \r
+\r
@Test\r
- public void testListWhiteList() {\r
- \r
- MMServiceImpl service = new MMServiceImpl();\r
+ public void testPushEvents_wttransaction() {\r
+\r
+ String source = "source of my InputStream";\r
+\r
try {\r
- service.listWhiteList();\r
+ InputStream iStream = new ByteArrayInputStream(source.getBytes("UTF-8"));\r
+ service.pushEvents(dmaapContext, "msgrtr.apinode.metrics.dmaap", iStream, "3", "12:00:00");\r
+\r
} catch (org.json.JSONException e) {\r
// TODO Auto-generated catch block\r
e.printStackTrace();\r
} catch (NullPointerException e) {\r
// TODO Auto-generated catch block\r
- //e.printStackTrace();\r
+ // e.printStackTrace();\r
assertTrue(true);\r
- } \r
- \r
- String trueValue = "True";\r
- assertTrue(trueValue.equalsIgnoreCase("True"));\r
- \r
+ } catch (CambriaApiException e) {\r
+ assertTrue(true);\r
+ } catch (ConfigDbException e) {\r
+ // TODO Auto-generated catch block\r
+ e.printStackTrace();\r
+ } catch (TopicExistsException e) {\r
+ // TODO Auto-generated catch block\r
+ e.printStackTrace();\r
+ } catch (AccessDeniedException e) {\r
+ // TODO Auto-generated catch block\r
+ e.printStackTrace();\r
+ } catch (IOException e) {\r
+ // TODO Auto-generated catch block\r
+ e.printStackTrace();\r
+ } catch (missingReqdSetting e) {\r
+ // TODO Auto-generated catch block\r
+ e.printStackTrace();\r
+ }\r
}\r
- \r
+\r
@Test\r
- public void testSubscribe() {\r
- \r
- MMServiceImpl service = new MMServiceImpl();\r
+ public void testPushEvents() {\r
+\r
+ String source = "source of my InputStream";\r
+\r
try {\r
- service.subscribe(new DMaaPContext(), "testTopic", "CG1", "23");\r
+ InputStream iStream = new ByteArrayInputStream(source.getBytes("UTF-8"));\r
+ service.pushEvents(dmaapContext, "testTopic", iStream, "3", "12:00:00");\r
+\r
} catch (org.json.JSONException e) {\r
// TODO Auto-generated catch block\r
e.printStackTrace();\r
} catch (NullPointerException e) {\r
// TODO Auto-generated catch block\r
- //e.printStackTrace();\r
+ // e.printStackTrace();\r
assertTrue(true);\r
} catch (CambriaApiException e) {\r
- // TODO Auto-generated catch block\r
- e.printStackTrace();\r
+ assertTrue(true);\r
} catch (ConfigDbException e) {\r
// TODO Auto-generated catch block\r
e.printStackTrace();\r
} catch (AccessDeniedException e) {\r
// TODO Auto-generated catch block\r
e.printStackTrace();\r
- } catch (UnavailableException e) {\r
+ } catch (IOException e) {\r
// TODO Auto-generated catch block\r
e.printStackTrace();\r
- } catch (IOException e) {\r
+ } catch (missingReqdSetting e) {\r
// TODO Auto-generated catch block\r
e.printStackTrace();\r
- } \r
- \r
- String trueValue = "True";\r
- assertTrue(trueValue.equalsIgnoreCase("True"));\r
- \r
+ }\r
+\r
}\r
- \r
+\r
@Test\r
- public void testPushEvents() {\r
- \r
- MMServiceImpl service = new MMServiceImpl();\r
- \r
+ public void testPushEvents_blacklistip() {\r
+\r
String source = "source of my InputStream";\r
- \r
+\r
try {\r
+ PowerMockito.when(Blacklist.contains("127.0.0.1")).thenReturn(true);\r
InputStream iStream = new ByteArrayInputStream(source.getBytes("UTF-8"));\r
- service.pushEvents(new DMaaPContext(), "testTopic", iStream, "3", "12:00:00");\r
- \r
+ service.pushEvents(dmaapContext, "testTopic", iStream, "3", "12:00:00");\r
+\r
} catch (org.json.JSONException e) {\r
// TODO Auto-generated catch block\r
e.printStackTrace();\r
} catch (NullPointerException e) {\r
// TODO Auto-generated catch block\r
- //e.printStackTrace();\r
+ // e.printStackTrace();\r
assertTrue(true);\r
} catch (CambriaApiException e) {\r
- // TODO Auto-generated catch block\r
- e.printStackTrace();\r
+ assertTrue(true);\r
} catch (ConfigDbException e) {\r
// TODO Auto-generated catch block\r
e.printStackTrace();\r
} catch (missingReqdSetting e) {\r
// TODO Auto-generated catch block\r
e.printStackTrace();\r
- } \r
- \r
- String trueValue = "True";\r
- assertTrue(trueValue.equalsIgnoreCase("True"));\r
- \r
+ }\r
+\r
}\r
- \r
- \r
+\r
+ NsaApiDb<NsaSimpleApiKey> fApiKeyDb = new NsaApiDb<NsaSimpleApiKey>() {\r
+\r
+ Set<String> keys = new HashSet<>(Arrays.asList("testkey", "admin"));\r
+\r
+ @Override\r
+ public NsaSimpleApiKey createApiKey(String arg0, String arg1)\r
+ throws com.att.nsa.security.db.NsaApiDb.KeyExistsException, ConfigDbException {\r
+ // TODO Auto-generated method stub\r
+ return new NsaSimpleApiKey(arg0, arg1);\r
+ }\r
+\r
+ @Override\r
+ public boolean deleteApiKey(NsaSimpleApiKey arg0) throws ConfigDbException {\r
+ // TODO Auto-generated method stub\r
+ return false;\r
+ }\r
+\r
+ @Override\r
+ public boolean deleteApiKey(String arg0) throws ConfigDbException {\r
+ // TODO Auto-generated method stub\r
+ return false;\r
+ }\r
+\r
+ @Override\r
+ public Map<String, NsaSimpleApiKey> loadAllKeyRecords() throws ConfigDbException {\r
+ // TODO Auto-generated method stub\r
+ return null;\r
+ }\r
+\r
+ @Override\r
+ public Set<String> loadAllKeys() throws ConfigDbException {\r
+ // TODO Auto-generated method stub\r
+\r
+ return keys;\r
+ }\r
+\r
+ @Override\r
+ public NsaSimpleApiKey loadApiKey(String arg0) throws ConfigDbException {\r
+ if (!keys.contains(arg0)) {\r
+ return null;\r
+ }\r
+ return new NsaSimpleApiKey(arg0, "password");\r
+ }\r
+\r
+ @Override\r
+ public void saveApiKey(NsaSimpleApiKey arg0) throws ConfigDbException {\r
+ // TODO Auto-generated method stub\r
+\r
+ }\r
+ };\r
+\r
}\r
import org.json.JSONObject;\r
import org.junit.Assert;\r
import org.junit.Before;\r
-import org.junit.ClassRule;\r
-import org.junit.Rule;\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
-import org.powermock.modules.junit4.rule.PowerMockRule;\r
-import org.springframework.beans.factory.annotation.Autowired;\r
-import org.springframework.test.context.ContextConfiguration;\r
-import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;\r
\r
import com.att.ajsc.beans.PropertiesMapBean;\r
+import com.att.ajsc.filemonitor.AJSCPropertiesMap;\r
import com.att.nsa.cambria.CambriaApiException;\r
import com.att.nsa.cambria.beans.DMaaPContext;\r
import com.att.nsa.cambria.beans.DMaaPKafkaMetaBroker;\r
import com.att.nsa.cambria.metabroker.Topic;\r
import com.att.nsa.cambria.security.DMaaPAAFAuthenticator;\r
import com.att.nsa.cambria.security.DMaaPAuthenticator;\r
+import com.att.nsa.cambria.security.DMaaPAuthenticatorImpl;\r
import com.att.nsa.cambria.utils.ConfigurationReader;\r
import com.att.nsa.cambria.utils.DMaaPResponseBuilder;\r
import com.att.nsa.configs.ConfigDbException;\r
import com.att.nsa.security.db.simple.NsaSimpleApiKey;\r
\r
//@RunWith(MockitoJUnitRunner.class)\r
-//@RunWith(PowerMockRunner.class)\r
-//@RunWith(SpringJUnit4ClassRunner.class)\r
-//@ContextConfiguration("classpath:/spring-context.xml")\r
-//@PrepareForTest({ PropertiesMapBean.class })\r
+@RunWith(PowerMockRunner.class)\r
+@PrepareForTest({ PropertiesMapBean.class, DMaaPAuthenticatorImpl.class,AJSCPropertiesMap.class,DMaaPResponseBuilder.class })\r
public class TopicServiceImplTest {\r
\r
- /*@Rule\r
- public PowerMockRule rule = new PowerMockRule();*/\r
- \r
- //@Autowired\r
- /*TopicServiceImpl topicService;\r
+ TopicServiceImpl topicService;\r
\r
@Mock\r
private DMaaPErrorMessages errorMessages;\r
MockitoAnnotations.initMocks(this);\r
topicService = new TopicServiceImpl();\r
topicService.setErrorMessages(errorMessages);\r
+ NsaSimpleApiKey user = new NsaSimpleApiKey("admin", "password");\r
+ PowerMockito.mockStatic(DMaaPAuthenticatorImpl.class);\r
+ PowerMockito.when(DMaaPAuthenticatorImpl.getAuthenticatedUser(dmaapContext)).thenReturn(user);\r
}\r
\r
@Test(expected = DMaaPAccessDeniedException.class)\r
when(createdTopic.getWriterAcl()).thenReturn(nsaAcl);\r
topicService.getPublishersByTopicName(dmaapContext, "topicNamespace.name");\r
}\r
- \r
+\r
@Test(expected = TopicExistsException.class)\r
public void testGetConsumersByTopicName_nullTopic() throws DMaaPAccessDeniedException, CambriaApiException,\r
IOException, TopicExistsException, JSONException, ConfigDbException, AccessDeniedException {\r
when(httpServReq.getMethod()).thenReturn("HEAD");\r
\r
when(dmaapKafkaMetaBroker.getTopic("topicNamespace.name")).thenReturn(createdTopic);\r
- \r
+\r
when(createdTopic.getReaderAcl()).thenReturn(nsaAcl);\r
\r
topicService.getConsumersByTopicName(dmaapContext, "topicNamespace.name");\r
}\r
- \r
-// @Test\r
-// public void testDeleteTopic() throws DMaaPAccessDeniedException, CambriaApiException,\r
-// IOException, TopicExistsException, JSONException, ConfigDbException, AccessDeniedException {\r
-//\r
-// Assert.assertNotNull(topicService);\r
-//\r
-// PowerMockito.mockStatic(DMaaPResponseBuilder.class);\r
-// \r
-// PowerMockito.mockStatic(AJSCPropertiesMap.class);\r
-// \r
-// PowerMockito.when(AJSCPropertiesMap.\r
-// getProperty(CambriaConstants.msgRtr_prop,"msgRtr.topicfactory.aaf")).thenReturn("topicFactoryAAF");\r
-// \r
-// \r
-// when(dmaapContext.getConfigReader()).thenReturn(configReader);\r
-// when(dmaapContext.getRequest()).thenReturn(httpServReq);\r
-// when(dmaapContext.getResponse()).thenReturn(httpServRes);\r
-// when(configReader.getfMetaBroker()).thenReturn(dmaapKafkaMetaBroker);\r
-// when(httpServReq.getMethod()).thenReturn("HEAD");\r
-//\r
-// when(dmaapKafkaMetaBroker.getTopic("topicNamespace.name")).thenReturn(createdTopic);\r
-// \r
-// when(createdTopic.getReaderAcl()).thenReturn(nsaAcl);\r
-//\r
-// topicService.getPublishersByTopicName(dmaapContext, "topicNamespace.name");\r
-// }\r
-// \r
-// \r
-// \r
- \r
- @Test(expected = TopicExistsException.class)\r
- public void testPermitPublisherForTopic_nullTopic() throws DMaaPAccessDeniedException, CambriaApiException,\r
- IOException, TopicExistsException, JSONException, ConfigDbException, AccessDeniedException {\r
+\r
+ @Test\r
+ public void testGetPublishersByTopicName() throws DMaaPAccessDeniedException, CambriaApiException, IOException,\r
+ TopicExistsException, JSONException, ConfigDbException, AccessDeniedException {\r
\r
Assert.assertNotNull(topicService);\r
\r
- when(httpServReq.getHeader("AppName")).thenReturn("MyApp");\r
+ PowerMockito.mockStatic(DMaaPResponseBuilder.class);\r
+\r
+ PowerMockito.mockStatic(AJSCPropertiesMap.class);\r
+\r
+ PowerMockito.when(AJSCPropertiesMap.getProperty(CambriaConstants.msgRtr_prop, "msgRtr.topicfactory.aaf"))\r
+ .thenReturn("topicFactoryAAF");\r
+\r
+ when(dmaapContext.getConfigReader()).thenReturn(configReader);\r
when(dmaapContext.getRequest()).thenReturn(httpServReq);\r
- when(configReader.getfSecurityManager()).thenReturn(dmaaPAuthenticator);\r
- when(dmaaPAuthenticator.authenticate(dmaapContext)).thenReturn(nsaSimpleApiKey);\r
- \r
+ when(dmaapContext.getResponse()).thenReturn(httpServRes);\r
+ when(configReader.getfMetaBroker()).thenReturn(dmaapKafkaMetaBroker);\r
+ when(httpServReq.getMethod()).thenReturn("HEAD");\r
+\r
+ when(dmaapKafkaMetaBroker.getTopic("topicNamespace.name")).thenReturn(createdTopic);\r
+\r
+ when(createdTopic.getReaderAcl()).thenReturn(nsaAcl);\r
+\r
+ topicService.getPublishersByTopicName(dmaapContext, "topicNamespace.name");\r
+ }\r
+ \r
+ @Test(expected=TopicExistsException.class)\r
+ public void testGetPublishersByTopicNameError() throws DMaaPAccessDeniedException, CambriaApiException, IOException,\r
+ TopicExistsException, JSONException, ConfigDbException, AccessDeniedException {\r
+\r
+ Assert.assertNotNull(topicService);\r
+\r
PowerMockito.mockStatic(DMaaPResponseBuilder.class);\r
+\r
+ PowerMockito.mockStatic(AJSCPropertiesMap.class);\r
+\r
+ PowerMockito.when(AJSCPropertiesMap.getProperty(CambriaConstants.msgRtr_prop, "msgRtr.topicfactory.aaf"))\r
+ .thenReturn("topicFactoryAAF");\r
+\r
when(dmaapContext.getConfigReader()).thenReturn(configReader);\r
when(dmaapContext.getRequest()).thenReturn(httpServReq);\r
when(dmaapContext.getResponse()).thenReturn(httpServRes);\r
\r
when(dmaapKafkaMetaBroker.getTopic("topicNamespace.name")).thenReturn(null);\r
\r
- topicService.permitPublisherForTopic(dmaapContext, "topicNamespace.name", "producerId");\r
+ when(createdTopic.getReaderAcl()).thenReturn(nsaAcl);\r
+\r
+ topicService.getPublishersByTopicName(dmaapContext, "topicNamespace.name");\r
}\r
- \r
+\r
@Test\r
- public void testPermitPublisherForTopic_NonNullTopic() throws DMaaPAccessDeniedException, CambriaApiException,\r
- IOException, TopicExistsException, JSONException, ConfigDbException, AccessDeniedException {\r
+ public void testdeleteTopic() throws DMaaPAccessDeniedException, CambriaApiException, IOException,\r
+ TopicExistsException, JSONException, ConfigDbException, AccessDeniedException {\r
\r
Assert.assertNotNull(topicService);\r
\r
+ // PowerMockito.mockStatic(AJSCPropertiesMap.class);\r
+ PowerMockito.mockStatic(AJSCPropertiesMap.class);\r
+ PowerMockito.when(AJSCPropertiesMap.getProperty(CambriaConstants.msgRtr_prop, "msgRtr.topicfactory.aaf"))\r
+ .thenReturn("hello");\r
+\r
+ when(dmaaPAuthenticator.authenticate(dmaapContext)).thenReturn(null);\r
when(httpServReq.getHeader("AppName")).thenReturn("MyApp");\r
+ when(httpServReq.getHeader("Authorization")).thenReturn("Admin");\r
when(dmaapContext.getRequest()).thenReturn(httpServReq);\r
+\r
when(configReader.getfSecurityManager()).thenReturn(dmaaPAuthenticator);\r
- when(dmaaPAuthenticator.authenticate(dmaapContext)).thenReturn(nsaSimpleApiKey);\r
- \r
- PowerMockito.mockStatic(DMaaPResponseBuilder.class);\r
when(dmaapContext.getConfigReader()).thenReturn(configReader);\r
- when(dmaapContext.getRequest()).thenReturn(httpServReq);\r
- when(dmaapContext.getResponse()).thenReturn(httpServRes);\r
when(configReader.getfMetaBroker()).thenReturn(dmaapKafkaMetaBroker);\r
- when(httpServReq.getMethod()).thenReturn("HEAD");\r
+ when(dmaapKafkaMetaBroker.getTopic("topicNamespace.topic")).thenReturn(createdTopic);\r
+ TopicBean topicBean = new TopicBean();\r
+ topicBean.setTopicName("enfTopicNamePlusExtra");\r
\r
- when(dmaapKafkaMetaBroker.getTopic("topicNamespace.name")).thenReturn(createdTopic);\r
- \r
- \r
- topicService.permitPublisherForTopic(dmaapContext, "topicNamespace.name", "producerId");\r
+ topicService.deleteTopic(dmaapContext, "topicNamespace.topic");\r
}\r
\r
- \r
- @Test(expected = TopicExistsException.class)\r
- public void testDenyPublisherForTopic_nullTopic() throws DMaaPAccessDeniedException, CambriaApiException,\r
- IOException, TopicExistsException, JSONException, ConfigDbException, AccessDeniedException {\r
+ @Test(expected=TopicExistsException.class)\r
+ public void testdeleteTopic_nulltopic() throws DMaaPAccessDeniedException, CambriaApiException, IOException,\r
+ TopicExistsException, JSONException, ConfigDbException, AccessDeniedException {\r
\r
Assert.assertNotNull(topicService);\r
\r
+ // PowerMockito.mockStatic(AJSCPropertiesMap.class);\r
+ PowerMockito.mockStatic(AJSCPropertiesMap.class);\r
+ PowerMockito.when(AJSCPropertiesMap.getProperty(CambriaConstants.msgRtr_prop, "msgRtr.topicfactory.aaf"))\r
+ .thenReturn("hello");\r
+\r
+ when(dmaaPAuthenticator.authenticate(dmaapContext)).thenReturn(null);\r
when(httpServReq.getHeader("AppName")).thenReturn("MyApp");\r
+ when(httpServReq.getHeader("Authorization")).thenReturn("Admin");\r
when(dmaapContext.getRequest()).thenReturn(httpServReq);\r
+\r
when(configReader.getfSecurityManager()).thenReturn(dmaaPAuthenticator);\r
- when(dmaaPAuthenticator.authenticate(dmaapContext)).thenReturn(nsaSimpleApiKey);\r
- \r
- PowerMockito.mockStatic(DMaaPResponseBuilder.class);\r
when(dmaapContext.getConfigReader()).thenReturn(configReader);\r
- when(dmaapContext.getRequest()).thenReturn(httpServReq);\r
- when(dmaapContext.getResponse()).thenReturn(httpServRes);\r
when(configReader.getfMetaBroker()).thenReturn(dmaapKafkaMetaBroker);\r
- when(httpServReq.getMethod()).thenReturn("HEAD");\r
+ when(dmaapKafkaMetaBroker.getTopic("topicNamespace.topic")).thenReturn(null);\r
+ TopicBean topicBean = new TopicBean();\r
+ topicBean.setTopicName("enfTopicNamePlusExtra");\r
\r
- when(dmaapKafkaMetaBroker.getTopic("topicNamespace.name")).thenReturn(null);\r
+ topicService.deleteTopic(dmaapContext, "topicNamespace.topic");\r
+ }\r
+ \r
+ @Test(expected=DMaaPAccessDeniedException.class)\r
+ public void testdeleteTopic_authHeader() throws DMaaPAccessDeniedException, CambriaApiException, IOException,\r
+ TopicExistsException, JSONException, ConfigDbException, AccessDeniedException {\r
+\r
+ Assert.assertNotNull(topicService);\r
\r
- topicService.denyPublisherForTopic(dmaapContext, "topicNamespace.name", "producerId");\r
+ // PowerMockito.mockStatic(AJSCPropertiesMap.class);\r
+ PowerMockito.mockStatic(AJSCPropertiesMap.class);\r
+ PowerMockito.when(AJSCPropertiesMap.getProperty(CambriaConstants.msgRtr_prop, "msgRtr.topicfactory.aaf"))\r
+ .thenReturn("hello");\r
+\r
+ when(dmaaPAuthenticator.authenticate(dmaapContext)).thenReturn(null);\r
+ when(httpServReq.getHeader("AppName")).thenReturn("MyApp");\r
+ when(httpServReq.getHeader("Authorization")).thenReturn("Admin");\r
+ when(dmaapContext.getRequest()).thenReturn(httpServReq);\r
+\r
+ when(configReader.getfSecurityManager()).thenReturn(dmaaPAuthenticator);\r
+ when(dmaapContext.getConfigReader()).thenReturn(configReader);\r
+ when(configReader.getfMetaBroker()).thenReturn(dmaapKafkaMetaBroker);\r
+ when(dmaapKafkaMetaBroker.getTopic("topicNamespace.topic")).thenReturn(createdTopic);\r
+ TopicBean topicBean = new TopicBean();\r
+ topicBean.setTopicName("enfTopicNamePlusExtra");\r
+ PowerMockito.when(DMaaPAuthenticatorImpl.getAuthenticatedUser(dmaapContext)).thenReturn(null);\r
+ topicService.deleteTopic(dmaapContext, "topicNamespace.topic");\r
}\r
\r
@Test\r
- public void testDenyPublisherForTopic_NonNullTopic() throws DMaaPAccessDeniedException, CambriaApiException,\r
- IOException, TopicExistsException, JSONException, ConfigDbException, AccessDeniedException {\r
+ public void testPermitConsumerForTopic() throws DMaaPAccessDeniedException, CambriaApiException, IOException,\r
+ TopicExistsException, JSONException, ConfigDbException, AccessDeniedException {\r
\r
Assert.assertNotNull(topicService);\r
\r
+ // PowerMockito.mockStatic(AJSCPropertiesMap.class);\r
+ PowerMockito.mockStatic(AJSCPropertiesMap.class);\r
+ PowerMockito.when(AJSCPropertiesMap.getProperty(CambriaConstants.msgRtr_prop, "msgRtr.topicfactory.aaf"))\r
+ .thenReturn("hello");\r
+\r
+ when(dmaaPAuthenticator.authenticate(dmaapContext)).thenReturn(null);\r
when(httpServReq.getHeader("AppName")).thenReturn("MyApp");\r
+ when(httpServReq.getHeader("Authorization")).thenReturn("Admin");\r
when(dmaapContext.getRequest()).thenReturn(httpServReq);\r
+\r
when(configReader.getfSecurityManager()).thenReturn(dmaaPAuthenticator);\r
- when(dmaaPAuthenticator.authenticate(dmaapContext)).thenReturn(nsaSimpleApiKey);\r
- \r
- PowerMockito.mockStatic(DMaaPResponseBuilder.class);\r
when(dmaapContext.getConfigReader()).thenReturn(configReader);\r
- when(dmaapContext.getRequest()).thenReturn(httpServReq);\r
- when(dmaapContext.getResponse()).thenReturn(httpServRes);\r
when(configReader.getfMetaBroker()).thenReturn(dmaapKafkaMetaBroker);\r
- when(httpServReq.getMethod()).thenReturn("HEAD");\r
+ when(dmaapKafkaMetaBroker.getTopic("topicNamespace.topic")).thenReturn(createdTopic);\r
+ TopicBean topicBean = new TopicBean();\r
+ topicBean.setTopicName("enfTopicNamePlusExtra");\r
\r
- when(dmaapKafkaMetaBroker.getTopic("topicNamespace.name")).thenReturn(createdTopic);\r
- \r
- \r
- topicService.denyPublisherForTopic(dmaapContext, "topicNamespace.name", "producerId");\r
+ topicService.permitConsumerForTopic(dmaapContext, "topicNamespace.topic", "admin");\r
}\r
\r
- @Test(expected = TopicExistsException.class)\r
- public void testPermitConsumerForTopic_nullTopic() throws DMaaPAccessDeniedException, CambriaApiException,\r
- IOException, TopicExistsException, JSONException, ConfigDbException, AccessDeniedException {\r
+ @Test(expected=TopicExistsException.class)\r
+ public void testPermitConsumerForTopic_nulltopic() throws DMaaPAccessDeniedException, CambriaApiException, IOException,\r
+ TopicExistsException, JSONException, ConfigDbException, AccessDeniedException {\r
\r
Assert.assertNotNull(topicService);\r
\r
+ // PowerMockito.mockStatic(AJSCPropertiesMap.class);\r
+ PowerMockito.mockStatic(AJSCPropertiesMap.class);\r
+ PowerMockito.when(AJSCPropertiesMap.getProperty(CambriaConstants.msgRtr_prop, "msgRtr.topicfactory.aaf"))\r
+ .thenReturn("hello");\r
+\r
+ when(dmaaPAuthenticator.authenticate(dmaapContext)).thenReturn(null);\r
when(httpServReq.getHeader("AppName")).thenReturn("MyApp");\r
+ when(httpServReq.getHeader("Authorization")).thenReturn("Admin");\r
when(dmaapContext.getRequest()).thenReturn(httpServReq);\r
+\r
when(configReader.getfSecurityManager()).thenReturn(dmaaPAuthenticator);\r
- when(dmaaPAuthenticator.authenticate(dmaapContext)).thenReturn(nsaSimpleApiKey);\r
- \r
- PowerMockito.mockStatic(DMaaPResponseBuilder.class);\r
when(dmaapContext.getConfigReader()).thenReturn(configReader);\r
- when(dmaapContext.getRequest()).thenReturn(httpServReq);\r
- when(dmaapContext.getResponse()).thenReturn(httpServRes);\r
when(configReader.getfMetaBroker()).thenReturn(dmaapKafkaMetaBroker);\r
- when(httpServReq.getMethod()).thenReturn("HEAD");\r
-\r
- when(dmaapKafkaMetaBroker.getTopic("topicNamespace.name")).thenReturn(null);\r
+ when(dmaapKafkaMetaBroker.getTopic("topicNamespace.topic")).thenReturn(null);\r
+ TopicBean topicBean = new TopicBean();\r
+ topicBean.setTopicName("enfTopicNamePlusExtra");\r
\r
- topicService.permitConsumerForTopic(dmaapContext, "topicNamespace.name", "consumerID");\r
+ topicService.permitConsumerForTopic(dmaapContext, "topicNamespace.topic", "admin");\r
}\r
\r
@Test\r
- public void testPermitConsumerForTopic_NonNullTopic() throws DMaaPAccessDeniedException, CambriaApiException,\r
- IOException, TopicExistsException, JSONException, ConfigDbException, AccessDeniedException {\r
+ public void testdenyConsumerForTopic() throws DMaaPAccessDeniedException, CambriaApiException, IOException,\r
+ TopicExistsException, JSONException, ConfigDbException, AccessDeniedException {\r
\r
Assert.assertNotNull(topicService);\r
\r
+ // PowerMockito.mockStatic(AJSCPropertiesMap.class);\r
+ PowerMockito.mockStatic(AJSCPropertiesMap.class);\r
+ PowerMockito.when(AJSCPropertiesMap.getProperty(CambriaConstants.msgRtr_prop, "msgRtr.topicfactory.aaf"))\r
+ .thenReturn("hello");\r
+\r
+ when(dmaaPAuthenticator.authenticate(dmaapContext)).thenReturn(null);\r
when(httpServReq.getHeader("AppName")).thenReturn("MyApp");\r
+ when(httpServReq.getHeader("Authorization")).thenReturn("Admin");\r
when(dmaapContext.getRequest()).thenReturn(httpServReq);\r
+\r
when(configReader.getfSecurityManager()).thenReturn(dmaaPAuthenticator);\r
- when(dmaaPAuthenticator.authenticate(dmaapContext)).thenReturn(nsaSimpleApiKey);\r
- \r
- PowerMockito.mockStatic(DMaaPResponseBuilder.class);\r
when(dmaapContext.getConfigReader()).thenReturn(configReader);\r
+ when(configReader.getfMetaBroker()).thenReturn(dmaapKafkaMetaBroker);\r
+ when(dmaapKafkaMetaBroker.getTopic("topicNamespace.topic")).thenReturn(createdTopic);\r
+ TopicBean topicBean = new TopicBean();\r
+ topicBean.setTopicName("enfTopicNamePlusExtra");\r
+\r
+ topicService.denyConsumerForTopic(dmaapContext, "topicNamespace.topic", "admin");\r
+ }\r
+ \r
+ @Test(expected=TopicExistsException.class)\r
+ public void testdenyConsumerForTopic_nulltopic() throws DMaaPAccessDeniedException, CambriaApiException, IOException,\r
+ TopicExistsException, JSONException, ConfigDbException, AccessDeniedException {\r
+\r
+ Assert.assertNotNull(topicService);\r
+\r
+ // PowerMockito.mockStatic(AJSCPropertiesMap.class);\r
+ PowerMockito.mockStatic(AJSCPropertiesMap.class);\r
+ PowerMockito.when(AJSCPropertiesMap.getProperty(CambriaConstants.msgRtr_prop, "msgRtr.topicfactory.aaf"))\r
+ .thenReturn("hello");\r
+\r
+ when(dmaaPAuthenticator.authenticate(dmaapContext)).thenReturn(null);\r
+ when(httpServReq.getHeader("AppName")).thenReturn("MyApp");\r
+ when(httpServReq.getHeader("Authorization")).thenReturn("Admin");\r
when(dmaapContext.getRequest()).thenReturn(httpServReq);\r
- when(dmaapContext.getResponse()).thenReturn(httpServRes);\r
+\r
+ when(configReader.getfSecurityManager()).thenReturn(dmaaPAuthenticator);\r
+ when(dmaapContext.getConfigReader()).thenReturn(configReader);\r
when(configReader.getfMetaBroker()).thenReturn(dmaapKafkaMetaBroker);\r
- when(httpServReq.getMethod()).thenReturn("HEAD");\r
+ when(dmaapKafkaMetaBroker.getTopic("topicNamespace.topic")).thenReturn(null);\r
+ TopicBean topicBean = new TopicBean();\r
+ topicBean.setTopicName("enfTopicNamePlusExtra");\r
\r
- when(dmaapKafkaMetaBroker.getTopic("topicNamespace.name")).thenReturn(createdTopic);\r
- \r
- \r
- topicService.permitConsumerForTopic(dmaapContext, "topicNamespace.name", "consumerID");\r
+ topicService.denyConsumerForTopic(dmaapContext, "topicNamespace.topic", "admin");\r
}\r
\r
\r
- @Test(expected = TopicExistsException.class)\r
- public void testDenyConsumerForTopic_nullTopic() throws DMaaPAccessDeniedException, CambriaApiException,\r
- IOException, TopicExistsException, JSONException, ConfigDbException, AccessDeniedException {\r
+ @Test\r
+ public void testPermitPublisherForTopic() throws DMaaPAccessDeniedException, CambriaApiException, IOException,\r
+ TopicExistsException, JSONException, ConfigDbException, AccessDeniedException {\r
\r
Assert.assertNotNull(topicService);\r
\r
+ // PowerMockito.mockStatic(AJSCPropertiesMap.class);\r
+ PowerMockito.mockStatic(AJSCPropertiesMap.class);\r
+ PowerMockito.when(AJSCPropertiesMap.getProperty(CambriaConstants.msgRtr_prop, "msgRtr.topicfactory.aaf"))\r
+ .thenReturn("hello");\r
+\r
+ when(dmaaPAuthenticator.authenticate(dmaapContext)).thenReturn(null);\r
when(httpServReq.getHeader("AppName")).thenReturn("MyApp");\r
+ when(httpServReq.getHeader("Authorization")).thenReturn("Admin");\r
when(dmaapContext.getRequest()).thenReturn(httpServReq);\r
+\r
when(configReader.getfSecurityManager()).thenReturn(dmaaPAuthenticator);\r
- when(dmaaPAuthenticator.authenticate(dmaapContext)).thenReturn(nsaSimpleApiKey);\r
- \r
- PowerMockito.mockStatic(DMaaPResponseBuilder.class);\r
when(dmaapContext.getConfigReader()).thenReturn(configReader);\r
- when(dmaapContext.getRequest()).thenReturn(httpServReq);\r
- when(dmaapContext.getResponse()).thenReturn(httpServRes);\r
when(configReader.getfMetaBroker()).thenReturn(dmaapKafkaMetaBroker);\r
- when(httpServReq.getMethod()).thenReturn("HEAD");\r
+ when(dmaapKafkaMetaBroker.getTopic("topicNamespace.topic")).thenReturn(createdTopic);\r
+ TopicBean topicBean = new TopicBean();\r
+ topicBean.setTopicName("enfTopicNamePlusExtra");\r
\r
- when(dmaapKafkaMetaBroker.getTopic("topicNamespace.name")).thenReturn(null);\r
+ topicService.permitPublisherForTopic(dmaapContext, "topicNamespace.topic", "admin");\r
+ }\r
+ \r
+ @Test(expected=TopicExistsException.class)\r
+ public void testPermitPublisherForTopic_nulltopic() throws DMaaPAccessDeniedException, CambriaApiException, IOException,\r
+ TopicExistsException, JSONException, ConfigDbException, AccessDeniedException {\r
+\r
+ Assert.assertNotNull(topicService);\r
+\r
+ // PowerMockito.mockStatic(AJSCPropertiesMap.class);\r
+ PowerMockito.mockStatic(AJSCPropertiesMap.class);\r
+ PowerMockito.when(AJSCPropertiesMap.getProperty(CambriaConstants.msgRtr_prop, "msgRtr.topicfactory.aaf"))\r
+ .thenReturn("hello");\r
+\r
+ when(dmaaPAuthenticator.authenticate(dmaapContext)).thenReturn(null);\r
+ when(httpServReq.getHeader("AppName")).thenReturn("MyApp");\r
+ when(httpServReq.getHeader("Authorization")).thenReturn("Admin");\r
+ when(dmaapContext.getRequest()).thenReturn(httpServReq);\r
+\r
+ when(configReader.getfSecurityManager()).thenReturn(dmaaPAuthenticator);\r
+ when(dmaapContext.getConfigReader()).thenReturn(configReader);\r
+ when(configReader.getfMetaBroker()).thenReturn(dmaapKafkaMetaBroker);\r
+ when(dmaapKafkaMetaBroker.getTopic("topicNamespace.topic")).thenReturn(null);\r
+ TopicBean topicBean = new TopicBean();\r
+ topicBean.setTopicName("enfTopicNamePlusExtra");\r
\r
- topicService.denyConsumerForTopic(dmaapContext, "topicNamespace.name", "consumerID");\r
+ topicService.permitPublisherForTopic(dmaapContext, "topicNamespace.topic", "admin");\r
}\r
\r
@Test\r
- public void testDenyConsumerForTopic_NonNullTopic() throws DMaaPAccessDeniedException, CambriaApiException,\r
- IOException, TopicExistsException, JSONException, ConfigDbException, AccessDeniedException {\r
+ public void testDenyPublisherForTopic() throws DMaaPAccessDeniedException, CambriaApiException, IOException,\r
+ TopicExistsException, JSONException, ConfigDbException, AccessDeniedException {\r
\r
Assert.assertNotNull(topicService);\r
\r
+ // PowerMockito.mockStatic(AJSCPropertiesMap.class);\r
+ PowerMockito.mockStatic(AJSCPropertiesMap.class);\r
+ PowerMockito.when(AJSCPropertiesMap.getProperty(CambriaConstants.msgRtr_prop, "msgRtr.topicfactory.aaf"))\r
+ .thenReturn("hello");\r
+\r
+ when(dmaaPAuthenticator.authenticate(dmaapContext)).thenReturn(null);\r
when(httpServReq.getHeader("AppName")).thenReturn("MyApp");\r
+ when(httpServReq.getHeader("Authorization")).thenReturn("Admin");\r
when(dmaapContext.getRequest()).thenReturn(httpServReq);\r
+\r
when(configReader.getfSecurityManager()).thenReturn(dmaaPAuthenticator);\r
- when(dmaaPAuthenticator.authenticate(dmaapContext)).thenReturn(nsaSimpleApiKey);\r
- \r
+ when(dmaapContext.getConfigReader()).thenReturn(configReader);\r
+ when(configReader.getfMetaBroker()).thenReturn(dmaapKafkaMetaBroker);\r
+ when(dmaapKafkaMetaBroker.getTopic("topicNamespace.topic")).thenReturn(createdTopic);\r
+ TopicBean topicBean = new TopicBean();\r
+ topicBean.setTopicName("enfTopicNamePlusExtra");\r
+\r
+ topicService.denyPublisherForTopic(dmaapContext, "topicNamespace.topic", "admin");;\r
+ }\r
+ \r
+ @Test(expected=TopicExistsException.class)\r
+ public void testDenyPublisherForTopic_nulltopic() throws DMaaPAccessDeniedException, CambriaApiException, IOException,\r
+ TopicExistsException, JSONException, ConfigDbException, AccessDeniedException {\r
+\r
+ Assert.assertNotNull(topicService);\r
+\r
+ // PowerMockito.mockStatic(AJSCPropertiesMap.class);\r
+ PowerMockito.mockStatic(AJSCPropertiesMap.class);\r
+ PowerMockito.when(AJSCPropertiesMap.getProperty(CambriaConstants.msgRtr_prop, "msgRtr.topicfactory.aaf"))\r
+ .thenReturn("hello");\r
+\r
+ when(dmaaPAuthenticator.authenticate(dmaapContext)).thenReturn(null);\r
+ when(httpServReq.getHeader("AppName")).thenReturn("MyApp");\r
+ when(httpServReq.getHeader("Authorization")).thenReturn("Admin");\r
+ when(dmaapContext.getRequest()).thenReturn(httpServReq);\r
+\r
+ when(configReader.getfSecurityManager()).thenReturn(dmaaPAuthenticator);\r
+ when(dmaapContext.getConfigReader()).thenReturn(configReader);\r
+ when(configReader.getfMetaBroker()).thenReturn(dmaapKafkaMetaBroker);\r
+ when(dmaapKafkaMetaBroker.getTopic("topicNamespace.topic")).thenReturn(null);\r
+ TopicBean topicBean = new TopicBean();\r
+ topicBean.setTopicName("enfTopicNamePlusExtra");\r
+\r
+ topicService.denyPublisherForTopic(dmaapContext, "topicNamespace.topic", "admin");;\r
+ }\r
+ \r
+ @Test\r
+ public void testGetAllTopics() throws DMaaPAccessDeniedException, CambriaApiException, IOException,\r
+ TopicExistsException, JSONException, ConfigDbException, AccessDeniedException {\r
+\r
+ Assert.assertNotNull(topicService);\r
+\r
+ // PowerMockito.mockStatic(AJSCPropertiesMap.class);\r
+ PowerMockito.mockStatic(AJSCPropertiesMap.class);\r
+ PowerMockito.when(AJSCPropertiesMap.getProperty(CambriaConstants.msgRtr_prop, "msgRtr.topicfactory.aaf"))\r
+ .thenReturn("hello");\r
PowerMockito.mockStatic(DMaaPResponseBuilder.class);\r
+ when(dmaaPAuthenticator.authenticate(dmaapContext)).thenReturn(null);\r
+ when(httpServReq.getHeader("AppName")).thenReturn("MyApp");\r
+ when(httpServReq.getHeader("Authorization")).thenReturn("Admin");\r
+ when(dmaapContext.getRequest()).thenReturn(httpServReq);\r
+\r
+ when(configReader.getfSecurityManager()).thenReturn(dmaaPAuthenticator);\r
when(dmaapContext.getConfigReader()).thenReturn(configReader);\r
+ when(configReader.getfMetaBroker()).thenReturn(dmaapKafkaMetaBroker);\r
+ when(dmaapKafkaMetaBroker.getTopic("topicNamespace.topic")).thenReturn(createdTopic);\r
+ TopicBean topicBean = new TopicBean();\r
+ topicBean.setTopicName("enfTopicNamePlusExtra");\r
+\r
+ topicService.getAllTopics(dmaapContext);\r
+ }\r
+ \r
+ @Test\r
+ public void testGetTopics() throws DMaaPAccessDeniedException, CambriaApiException, IOException,\r
+ TopicExistsException, JSONException, ConfigDbException, AccessDeniedException {\r
+\r
+ Assert.assertNotNull(topicService);\r
+\r
+ // PowerMockito.mockStatic(AJSCPropertiesMap.class);\r
+ PowerMockito.mockStatic(AJSCPropertiesMap.class);\r
+ PowerMockito.when(AJSCPropertiesMap.getProperty(CambriaConstants.msgRtr_prop, "msgRtr.topicfactory.aaf"))\r
+ .thenReturn("hello");\r
+ PowerMockito.mockStatic(DMaaPResponseBuilder.class);\r
+ when(dmaaPAuthenticator.authenticate(dmaapContext)).thenReturn(null);\r
+ when(httpServReq.getHeader("AppName")).thenReturn("MyApp");\r
+ when(httpServReq.getHeader("Authorization")).thenReturn("Admin");\r
when(dmaapContext.getRequest()).thenReturn(httpServReq);\r
- when(dmaapContext.getResponse()).thenReturn(httpServRes);\r
+\r
+ when(configReader.getfSecurityManager()).thenReturn(dmaaPAuthenticator);\r
+ when(dmaapContext.getConfigReader()).thenReturn(configReader);\r
when(configReader.getfMetaBroker()).thenReturn(dmaapKafkaMetaBroker);\r
- when(httpServReq.getMethod()).thenReturn("HEAD");\r
+ when(dmaapKafkaMetaBroker.getTopic("topicNamespace.topic")).thenReturn(createdTopic);\r
+ TopicBean topicBean = new TopicBean();\r
+ topicBean.setTopicName("enfTopicNamePlusExtra");\r
+\r
+ topicService.getTopics(dmaapContext);\r
+ }\r
+ \r
+\r
\r
- when(dmaapKafkaMetaBroker.getTopic("topicNamespace.name")).thenReturn(createdTopic);\r
- \r
- \r
- topicService.denyConsumerForTopic(dmaapContext, "topicNamespace.name", "consumerID");\r
- }*/\r
}\r
+++ /dev/null
-/*-\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.cambria.service.impl;\r
-\r
-import static org.mockito.Matchers.anyBoolean;\r
-import static org.mockito.Matchers.anyInt;\r
-import static org.mockito.Matchers.anyString;\r
-import static org.mockito.Mockito.times;\r
-import static org.mockito.Mockito.verify;\r
-import static org.mockito.Mockito.when;\r
-\r
-import java.io.IOException;\r
-import java.util.Arrays;\r
-import java.util.HashSet;\r
-\r
-import javax.servlet.ServletOutputStream;\r
-import javax.servlet.http.HttpServletRequest;\r
-import javax.servlet.http.HttpServletResponse;\r
-\r
-import org.json.JSONArray;\r
-import org.json.JSONException;\r
-import org.json.JSONObject;\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 com.att.nsa.cambria.CambriaApiException;\r
-import com.att.nsa.cambria.beans.DMaaPContext;\r
-import com.att.nsa.cambria.beans.DMaaPKafkaMetaBroker;\r
-import com.att.nsa.cambria.beans.TopicBean;\r
-import com.att.nsa.cambria.constants.CambriaConstants;\r
-import com.att.nsa.cambria.exception.DMaaPAccessDeniedException;\r
-import com.att.nsa.cambria.exception.DMaaPErrorMessages;\r
-import com.att.nsa.cambria.metabroker.Broker.TopicExistsException;\r
-import com.att.nsa.cambria.metabroker.Topic;\r
-import com.att.nsa.cambria.security.DMaaPAAFAuthenticator;\r
-import com.att.nsa.cambria.security.DMaaPAuthenticator;\r
-import com.att.nsa.cambria.utils.ConfigurationReader;\r
-import com.att.nsa.cambria.utils.DMaaPResponseBuilder;\r
-import com.att.nsa.configs.ConfigDbException;\r
-import com.att.nsa.security.NsaAcl;\r
-import com.att.nsa.security.NsaApiKey;\r
-import com.att.nsa.security.ReadWriteSecuredResource.AccessDeniedException;\r
-import com.att.nsa.security.db.simple.NsaSimpleApiKey;\r
-\r
-//@RunWith(MockitoJUnitRunner.class)\r
-@RunWith(PowerMockRunner.class)\r
-@PrepareForTest({ PropertiesMapBean.class })\r
-public class TopicServiceImplTest22 {\r
-\r
- \r
- TopicServiceImpl topicService;\r
-\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
- DMaaPAAFAuthenticator dmaapAAFauthenticator;\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
- 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() {\r
- MockitoAnnotations.initMocks(this);\r
- topicService = new TopicServiceImpl();\r
- topicService.setErrorMessages(errorMessages);\r
- }\r
-\r
- @Test(expected = DMaaPAccessDeniedException.class)\r
- public void testCreateTopicWithEnforcedName()\r
- throws DMaaPAccessDeniedException, CambriaApiException, IOException, TopicExistsException {\r
-\r
- Assert.assertNotNull(topicService);\r
-\r
- PowerMockito.mockStatic(PropertiesMapBean.class);\r
-\r
- when(PropertiesMapBean.getProperty(CambriaConstants.msgRtr_prop, "enforced.topic.name.AAF"))\r
- .thenReturn("enfTopicName");\r
-\r
- when(httpServReq.getHeader("AppName")).thenReturn("MyApp");\r
- when(dmaapContext.getRequest()).thenReturn(httpServReq);\r
- when(dmaaPAuthenticator.authenticate(dmaapContext)).thenReturn(nsaSimpleApiKey);\r
- when(configReader.getfSecurityManager()).thenReturn(dmaaPAuthenticator);\r
- when(dmaapContext.getConfigReader()).thenReturn(configReader);\r
-\r
- TopicBean topicBean = new TopicBean();\r
- topicBean.setTopicName("enfTopicNamePlusExtra");\r
-\r
- topicService.createTopic(dmaapContext, topicBean);\r
- }\r
-\r
- @Test\r
- public void testCreateTopicWithTopicNameNotEnforced()\r
- throws DMaaPAccessDeniedException, CambriaApiException, IOException, TopicExistsException {\r
-\r
- Assert.assertNotNull(topicService);\r
-\r
- PowerMockito.mockStatic(PropertiesMapBean.class);\r
- PowerMockito.mockStatic(DMaaPResponseBuilder.class);\r
-\r
- when(PropertiesMapBean.getProperty(CambriaConstants.msgRtr_prop, "enforced.topic.name.AAF"))\r
- .thenReturn("enfTopicName");\r
-\r
- when(dmaapContext.getRequest()).thenReturn(httpServReq);\r
- when(dmaapContext.getResponse()).thenReturn(httpServRes);\r
-\r
- when(httpServReq.getHeader("AppName")).thenReturn("MyApp");\r
- when(httpServReq.getMethod()).thenReturn("HEAD");\r
-\r
- when(dmaaPAuthenticator.authenticate(dmaapContext)).thenReturn(nsaSimpleApiKey);\r
- when(configReader.getfSecurityManager()).thenReturn(dmaaPAuthenticator);\r
- when(dmaapContext.getConfigReader()).thenReturn(configReader);\r
- when(configReader.getfMetaBroker()).thenReturn(dmaapKafkaMetaBroker);\r
-\r
- when(nsaAcl.isActive()).thenReturn(true);\r
- when(nsaAcl.getUsers()).thenReturn(new HashSet<>(Arrays.asList("user1,user2".split(","))));\r
-\r
- when(createdTopic.getName()).thenReturn("topicName");\r
- when(createdTopic.getOwner()).thenReturn("Owner");\r
- when(createdTopic.getDescription()).thenReturn("Description");\r
- when(createdTopic.getReaderAcl()).thenReturn(nsaAcl);\r
- when(createdTopic.getWriterAcl()).thenReturn(nsaAcl);\r
-\r
- when(dmaapKafkaMetaBroker.createTopic(anyString(), anyString(), anyString(), anyInt(), anyInt(), anyBoolean()))\r
- .thenReturn(createdTopic);\r
-\r
- TopicBean topicBean = new TopicBean();\r
- topicBean.setTopicName("NotEnforcedTopicName");\r
-\r
- topicService.createTopic(dmaapContext, topicBean);\r
-\r
- verify(dmaapKafkaMetaBroker, times(1)).createTopic(anyString(), anyString(), anyString(), anyInt(), anyInt(),\r
- anyBoolean());\r
- }\r
-\r
- @Test(expected = DMaaPAccessDeniedException.class)\r
- public void testCreateTopicNoUserInContextAndNoAuthHeader()\r
- throws DMaaPAccessDeniedException, CambriaApiException, IOException, TopicExistsException {\r
-\r
- Assert.assertNotNull(topicService);\r
-\r
- PowerMockito.mockStatic(PropertiesMapBean.class);\r
-\r
- when(PropertiesMapBean.getProperty(CambriaConstants.msgRtr_prop, "enforced.topic.name.AAF"))\r
- .thenReturn("enfTopicName");\r
-\r
- when(httpServReq.getHeader("Authorization")).thenReturn(null);\r
- when(dmaapContext.getRequest()).thenReturn(httpServReq);\r
- when(dmaaPAuthenticator.authenticate(dmaapContext)).thenReturn(null);\r
-\r
- when(configReader.getfSecurityManager()).thenReturn(dmaaPAuthenticator);\r
- when(dmaapContext.getConfigReader()).thenReturn(configReader);\r
-\r
- TopicBean topicBean = new TopicBean();\r
- topicBean.setTopicName("enfTopicNamePlusExtra");\r
-\r
- topicService.createTopic(dmaapContext, topicBean);\r
- }\r
-\r
- @Test(expected = DMaaPAccessDeniedException.class)\r
- public void testCreateTopicNoUserInContextAndAuthHeaderAndPermitted()\r
- throws DMaaPAccessDeniedException, CambriaApiException, IOException, TopicExistsException {\r
-\r
- Assert.assertNotNull(topicService);\r
-\r
- PowerMockito.mockStatic(PropertiesMapBean.class);\r
-\r
- when(PropertiesMapBean.getProperty(CambriaConstants.msgRtr_prop, "enforced.topic.name.AAF"))\r
- .thenReturn("enfTopicName");\r
-\r
- when(httpServReq.getHeader("Authorization")).thenReturn("Authorization");\r
- when(dmaapContext.getRequest()).thenReturn(httpServReq);\r
- when(dmaaPAuthenticator.authenticate(dmaapContext)).thenReturn(null);\r
-\r
- when(configReader.getfSecurityManager()).thenReturn(dmaaPAuthenticator);\r
- when(dmaapContext.getConfigReader()).thenReturn(configReader);\r
-\r
- // when(dmaapAAFauthenticator.aafAuthentication(httpServReq,\r
- // anyString())).thenReturn(false);\r
-\r
- TopicBean topicBean = new TopicBean();\r
- topicBean.setTopicName("enfTopicNamePlusExtra");\r
-\r
- topicService.createTopic(dmaapContext, topicBean);\r
- }\r
-\r
- @Test(expected = TopicExistsException.class)\r
- public void testGetTopics_null_topic() throws DMaaPAccessDeniedException, CambriaApiException, IOException,\r
- TopicExistsException, JSONException, ConfigDbException {\r
-\r
- Assert.assertNotNull(topicService);\r
- PowerMockito.mockStatic(DMaaPResponseBuilder.class);\r
- when(dmaapContext.getConfigReader()).thenReturn(configReader);\r
- when(dmaapContext.getRequest()).thenReturn(httpServReq);\r
- when(dmaapContext.getResponse()).thenReturn(httpServRes);\r
- when(configReader.getfMetaBroker()).thenReturn(dmaapKafkaMetaBroker);\r
- when(httpServReq.getMethod()).thenReturn("HEAD");\r
-\r
- when(dmaapKafkaMetaBroker.getTopic(anyString())).thenReturn(null);\r
-\r
- topicService.getTopic(dmaapContext, "topicName");\r
- }\r
-\r
- @Test\r
- public void testGetTopics_NonNull_topic() throws DMaaPAccessDeniedException, CambriaApiException, IOException,\r
- TopicExistsException, JSONException, ConfigDbException {\r
-\r
- Assert.assertNotNull(topicService);\r
- PowerMockito.mockStatic(DMaaPResponseBuilder.class);\r
- when(dmaapContext.getConfigReader()).thenReturn(configReader);\r
- when(dmaapContext.getRequest()).thenReturn(httpServReq);\r
- when(dmaapContext.getResponse()).thenReturn(httpServRes);\r
- when(configReader.getfMetaBroker()).thenReturn(dmaapKafkaMetaBroker);\r
-\r
- when(dmaapKafkaMetaBroker.getTopic(anyString())).thenReturn(createdTopic);\r
-\r
- when(createdTopic.getName()).thenReturn("topicName");\r
- when(createdTopic.getDescription()).thenReturn("topicDescription");\r
- when(createdTopic.getOwners()).thenReturn(new HashSet<>(Arrays.asList("user1,user2".split(","))));\r
-\r
- when(createdTopic.getReaderAcl()).thenReturn(nsaAcl);\r
- when(createdTopic.getWriterAcl()).thenReturn(nsaAcl);\r
-\r
- when(httpServReq.getMethod()).thenReturn("HEAD");\r
-\r
- when(httpServRes.getOutputStream()).thenReturn(oStream);\r
-\r
- topicService.getTopic(dmaapContext, "topicName");\r
- }\r
-\r
- @Test(expected = TopicExistsException.class)\r
- public void testGetPublishersByTopicName_nullTopic() throws DMaaPAccessDeniedException, CambriaApiException,\r
- IOException, TopicExistsException, JSONException, ConfigDbException, AccessDeniedException {\r
-\r
- Assert.assertNotNull(topicService);\r
-\r
- PowerMockito.mockStatic(DMaaPResponseBuilder.class);\r
- when(dmaapContext.getConfigReader()).thenReturn(configReader);\r
- when(dmaapContext.getRequest()).thenReturn(httpServReq);\r
- when(dmaapContext.getResponse()).thenReturn(httpServRes);\r
- when(configReader.getfMetaBroker()).thenReturn(dmaapKafkaMetaBroker);\r
- when(httpServReq.getMethod()).thenReturn("HEAD");\r
-\r
- when(dmaapKafkaMetaBroker.getTopic("topicNamespace.name")).thenReturn(null);\r
-\r
- topicService.getPublishersByTopicName(dmaapContext, "topicNamespace.name");\r
-\r
- }\r
-\r
- @Test\r
- public void testGetPublishersByTopicName_nonNullTopic() throws DMaaPAccessDeniedException, CambriaApiException,\r
- IOException, TopicExistsException, JSONException, ConfigDbException, AccessDeniedException {\r
-\r
- Assert.assertNotNull(topicService);\r
-\r
- PowerMockito.mockStatic(DMaaPResponseBuilder.class);\r
- when(dmaapContext.getConfigReader()).thenReturn(configReader);\r
- when(dmaapContext.getRequest()).thenReturn(httpServReq);\r
- when(dmaapContext.getResponse()).thenReturn(httpServRes);\r
- when(configReader.getfMetaBroker()).thenReturn(dmaapKafkaMetaBroker);\r
- when(httpServReq.getMethod()).thenReturn("HEAD");\r
-\r
- when(dmaapKafkaMetaBroker.getTopic("topicNamespace.name")).thenReturn(createdTopic);\r
- when(createdTopic.getWriterAcl()).thenReturn(nsaAcl);\r
- topicService.getPublishersByTopicName(dmaapContext, "topicNamespace.name");\r
- }\r
- \r
- @Test(expected = TopicExistsException.class)\r
- public void testGetConsumersByTopicName_nullTopic() throws DMaaPAccessDeniedException, CambriaApiException,\r
- IOException, TopicExistsException, JSONException, ConfigDbException, AccessDeniedException {\r
-\r
- Assert.assertNotNull(topicService);\r
-\r
- PowerMockito.mockStatic(DMaaPResponseBuilder.class);\r
- when(dmaapContext.getConfigReader()).thenReturn(configReader);\r
- when(dmaapContext.getRequest()).thenReturn(httpServReq);\r
- when(dmaapContext.getResponse()).thenReturn(httpServRes);\r
- when(configReader.getfMetaBroker()).thenReturn(dmaapKafkaMetaBroker);\r
- when(httpServReq.getMethod()).thenReturn("HEAD");\r
-\r
- when(dmaapKafkaMetaBroker.getTopic("topicNamespace.name")).thenReturn(null);\r
-\r
- topicService.getConsumersByTopicName(dmaapContext, "topicNamespace.name");\r
-\r
- }\r
-\r
- @Test\r
- public void testGetConsumersByTopicName_nonNullTopic() throws DMaaPAccessDeniedException, CambriaApiException,\r
- IOException, TopicExistsException, JSONException, ConfigDbException, AccessDeniedException {\r
-\r
- Assert.assertNotNull(topicService);\r
-\r
- PowerMockito.mockStatic(DMaaPResponseBuilder.class);\r
- when(dmaapContext.getConfigReader()).thenReturn(configReader);\r
- when(dmaapContext.getRequest()).thenReturn(httpServReq);\r
- when(dmaapContext.getResponse()).thenReturn(httpServRes);\r
- when(configReader.getfMetaBroker()).thenReturn(dmaapKafkaMetaBroker);\r
- when(httpServReq.getMethod()).thenReturn("HEAD");\r
-\r
- when(dmaapKafkaMetaBroker.getTopic("topicNamespace.name")).thenReturn(createdTopic);\r
- \r
- when(createdTopic.getReaderAcl()).thenReturn(nsaAcl);\r
-\r
- topicService.getConsumersByTopicName(dmaapContext, "topicNamespace.name");\r
- }\r
- \r
-// @Test\r
-// public void testDeleteTopic() throws DMaaPAccessDeniedException, CambriaApiException,\r
-// IOException, TopicExistsException, JSONException, ConfigDbException, AccessDeniedException {\r
-//\r
-// Assert.assertNotNull(topicService);\r
-//\r
-// PowerMockito.mockStatic(DMaaPResponseBuilder.class);\r
-// \r
-// PowerMockito.mockStatic(AJSCPropertiesMap.class);\r
-// \r
-// PowerMockito.when(AJSCPropertiesMap.\r
-// getProperty(CambriaConstants.msgRtr_prop,"msgRtr.topicfactory.aaf")).thenReturn("topicFactoryAAF");\r
-// \r
-// \r
-// when(dmaapContext.getConfigReader()).thenReturn(configReader);\r
-// when(dmaapContext.getRequest()).thenReturn(httpServReq);\r
-// when(dmaapContext.getResponse()).thenReturn(httpServRes);\r
-// when(configReader.getfMetaBroker()).thenReturn(dmaapKafkaMetaBroker);\r
-// when(httpServReq.getMethod()).thenReturn("HEAD");\r
-//\r
-// when(dmaapKafkaMetaBroker.getTopic("topicNamespace.name")).thenReturn(createdTopic);\r
-// \r
-// when(createdTopic.getReaderAcl()).thenReturn(nsaAcl);\r
-//\r
-// topicService.getPublishersByTopicName(dmaapContext, "topicNamespace.name");\r
-// }\r
-// \r
-// \r
-// \r
- \r
- /*@Test public void testdeleteTopic() throws DMaaPAccessDeniedException,\r
- CambriaApiException, IOException, TopicExistsException, JSONException,\r
- ConfigDbException, AccessDeniedException {\r
- \r
- Assert.assertNotNull(topicService);\r
- \r
- //PowerMockito.mockStatic(AJSCPropertiesMap.class);\r
- PowerMockito.mockStatic(AJSCPropertiesMap.class);\r
- PowerMockito.when(AJSCPropertiesMap.getProperty(CambriaConstants.\r
- msgRtr_prop,"msgRtr.topicfactory.aaf")) .thenReturn("hello");\r
- \r
- when(dmaaPAuthenticator.authenticate(dmaapContext)).thenReturn(null);\r
- when(httpServReq.getHeader("AppName")).thenReturn("MyApp");\r
- when(httpServReq.getHeader("Authorization")).thenReturn("Admin");\r
- when(dmaapContext.getRequest()).thenReturn(httpServReq);\r
- \r
- when(configReader.getfSecurityManager()).thenReturn(dmaaPAuthenticator);\r
- when(dmaapContext.getConfigReader()).thenReturn(configReader);\r
- \r
- TopicBean topicBean = new TopicBean();\r
- topicBean.setTopicName("enfTopicNamePlusExtra");\r
- \r
- topicService.deleteTopic(dmaapContext, "topicNamespace.topic"); }*/\r
- \r
- \r
-}\r
package com.att.nsa.cambria.service.impl;\r
\r
import static org.junit.Assert.*;\r
+import static org.mockito.Mockito.when;\r
\r
import java.io.IOException;\r
+import java.util.ArrayList;\r
+import java.util.Arrays;\r
+import java.util.HashMap;\r
+import java.util.HashSet;\r
+import java.util.List;\r
+import java.util.Map;\r
+import java.util.Set;\r
\r
+import com.att.nsa.cambria.backends.ConsumerFactory;\r
import com.att.nsa.cambria.beans.DMaaPContext;\r
+import com.att.nsa.cambria.beans.DMaaPKafkaMetaBroker;\r
+import com.att.nsa.cambria.metabroker.Topic;\r
+import com.att.nsa.cambria.security.DMaaPAuthenticatorImpl;\r
+import com.att.nsa.cambria.utils.ConfigurationReader;\r
+import com.att.nsa.cambria.utils.DMaaPResponseBuilder;\r
import com.att.nsa.configs.ConfigDbException;\r
-import com.att.nsa.security.ReadWriteSecuredResource.AccessDeniedException;\r
+import com.att.nsa.security.db.NsaApiDb;\r
+import com.att.nsa.security.db.simple.NsaSimpleApiKey;\r
\r
import org.junit.After;\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
+@RunWith(PowerMockRunner.class)\r
+@PrepareForTest({ DMaaPAuthenticatorImpl.class, DMaaPResponseBuilder.class })\r
public class UIServiceImplTest {\r
\r
+ @InjectMocks\r
+ UIServiceImpl service;\r
+\r
+ @Mock\r
+ DMaaPContext dmaapContext;\r
+ @Mock\r
+ ConsumerFactory factory;\r
+\r
+ @Mock\r
+ ConfigurationReader configReader;\r
+\r
+ @Mock\r
+ DMaaPKafkaMetaBroker dmaapKafkaMetaBroker;\r
+\r
+ @Mock\r
+ Topic metatopic;\r
+\r
@Before\r
public void setUp() throws Exception {\r
+ MockitoAnnotations.initMocks(this);\r
+ PowerMockito.mockStatic(DMaaPAuthenticatorImpl.class);\r
+ NsaSimpleApiKey user = new NsaSimpleApiKey("admin", "password");\r
+\r
+ PowerMockito.when(dmaapContext.getConfigReader()).thenReturn(configReader);\r
+ PowerMockito.when(configReader.getfConsumerFactory()).thenReturn(factory);\r
+\r
+ PowerMockito.when(configReader.getfApiKeyDb()).thenReturn(fApiKeyDb);\r
+ PowerMockito.when(DMaaPAuthenticatorImpl.getAuthenticatedUser(dmaapContext)).thenReturn(user);\r
+ PowerMockito.mockStatic(DMaaPResponseBuilder.class);\r
+ PowerMockito.when(configReader.getfMetaBroker()).thenReturn(dmaapKafkaMetaBroker);\r
}\r
\r
@After\r
\r
@Test\r
public void testHello() {\r
- \r
- UIServiceImpl service = new UIServiceImpl();\r
+\r
try {\r
- service.hello(new DMaaPContext());\r
+ service.hello(dmaapContext);\r
} catch (IOException e) {\r
// TODO Auto-generated catch block\r
e.printStackTrace();\r
- } \r
- \r
+ }\r
+\r
String trueValue = "True";\r
assertTrue(trueValue.equalsIgnoreCase("True"));\r
- \r
+\r
}\r
- \r
+\r
@Test\r
public void testGetApiKeysTable() {\r
- \r
- UIServiceImpl service = new UIServiceImpl();\r
+\r
try {\r
- service.getApiKeysTable(new DMaaPContext());\r
+ service.getApiKeysTable(dmaapContext);\r
} catch (NullPointerException e) {\r
// TODO Auto-generated catch block\r
- //e.printStackTrace();\r
+ // e.printStackTrace();\r
assertTrue(true);\r
} catch (ConfigDbException e) {\r
// TODO Auto-generated catch block\r
// TODO Auto-generated catch block\r
e.printStackTrace();\r
}\r
- \r
+ assertTrue(true);\r
+\r
}\r
- \r
+\r
@Test\r
public void testGetApiKey() {\r
- \r
- UIServiceImpl service = new UIServiceImpl();\r
+\r
try {\r
- service.getApiKey(new DMaaPContext(), "k56HmWT72J");\r
+ service.getApiKey(dmaapContext, "admin");\r
} catch (NullPointerException e) {\r
// TODO Auto-generated catch block\r
- //e.printStackTrace();\r
+ // e.printStackTrace();\r
assertTrue(true);\r
} catch (ConfigDbException e) {\r
// TODO Auto-generated catch block\r
// TODO Auto-generated catch block\r
e.printStackTrace();\r
} catch (Exception e) {\r
+ // TODO Auto-generated catch block\r
+ assertTrue(true);\r
+ }\r
+\r
+ }\r
+\r
+ @Test\r
+ public void testGetApiKey_invalidkey() {\r
+\r
+ try {\r
+ service.getApiKey(dmaapContext, "k56HmWT72J");\r
+ } catch (NullPointerException e) {\r
+ // TODO Auto-generated catch block\r
+ // e.printStackTrace();\r
+ assertTrue(true);\r
+ } catch (ConfigDbException e) {\r
+ // TODO Auto-generated catch block\r
+ e.printStackTrace();\r
+ } catch (IOException e) {\r
// TODO Auto-generated catch block\r
e.printStackTrace();\r
+ } catch (Exception e) {\r
+ // TODO Auto-generated catch block\r
+ assertTrue(true);\r
}\r
- \r
+\r
}\r
- \r
+\r
@Test\r
public void testGetTopicsTable() {\r
- \r
- UIServiceImpl service = new UIServiceImpl();\r
+\r
try {\r
- service.getTopicsTable(new DMaaPContext());\r
+ List<Topic> topics = new ArrayList<Topic>();\r
+ topics.add(metatopic);\r
+ when(dmaapKafkaMetaBroker.getAllTopics()).thenReturn(topics);\r
+ service.getTopicsTable(dmaapContext);\r
} catch (NullPointerException e) {\r
// TODO Auto-generated catch block\r
- //e.printStackTrace();\r
- assertTrue(true);\r
+ // e.printStackTrace();\r
+\r
} catch (ConfigDbException e) {\r
// TODO Auto-generated catch block\r
e.printStackTrace();\r
// TODO Auto-generated catch block\r
e.printStackTrace();\r
}\r
- \r
+ assertTrue(true);\r
+\r
}\r
- \r
+\r
@Test\r
public void testGetTopic() {\r
- \r
- UIServiceImpl service = new UIServiceImpl();\r
+\r
try {\r
- service.getTopic(new DMaaPContext(), "testTopic");\r
+ when(dmaapKafkaMetaBroker.getTopic("testTopic")).thenReturn(metatopic);\r
+ service.getTopic(dmaapContext, "testTopic");\r
} catch (NullPointerException e) {\r
// TODO Auto-generated catch block\r
- //e.printStackTrace();\r
- assertTrue(true);\r
+ // e.printStackTrace();\r
+\r
} catch (ConfigDbException e) {\r
// TODO Auto-generated catch block\r
e.printStackTrace();\r
// TODO Auto-generated catch block\r
e.printStackTrace();\r
}\r
- \r
+ assertTrue(true);\r
+ }\r
+\r
+ @Test\r
+ public void testGetTopic_nulltopic() {\r
+\r
+ try {\r
+ when(dmaapKafkaMetaBroker.getTopic("topicNamespace.topic")).thenReturn(null);\r
+ service.getTopic(dmaapContext, "testTopic");\r
+ } catch (NullPointerException e) {\r
+ // TODO Auto-generated catch block\r
+ // e.printStackTrace();\r
+ } catch (ConfigDbException e) {\r
+ // TODO Auto-generated catch block\r
+ e.printStackTrace();\r
+ } catch (IOException e) {\r
+ // TODO Auto-generated catch block\r
+ e.printStackTrace();\r
+ } catch (Exception e) {\r
+ // TODO Auto-generated catch block\r
+ assertTrue(true);\r
+ }\r
+\r
}\r
- \r
+\r
+ NsaApiDb<NsaSimpleApiKey> fApiKeyDb = new NsaApiDb<NsaSimpleApiKey>() {\r
+\r
+ Set<String> keys = new HashSet<>(Arrays.asList("testkey", "admin"));\r
+\r
+ @Override\r
+ public NsaSimpleApiKey createApiKey(String arg0, String arg1)\r
+ throws com.att.nsa.security.db.NsaApiDb.KeyExistsException, ConfigDbException {\r
+ // TODO Auto-generated method stub\r
+ return new NsaSimpleApiKey(arg0, arg1);\r
+ }\r
+\r
+ @Override\r
+ public boolean deleteApiKey(NsaSimpleApiKey arg0) throws ConfigDbException {\r
+ // TODO Auto-generated method stub\r
+ return false;\r
+ }\r
+\r
+ @Override\r
+ public boolean deleteApiKey(String arg0) throws ConfigDbException {\r
+ // TODO Auto-generated method stub\r
+ return false;\r
+ }\r
+\r
+ @Override\r
+ public Map<String, NsaSimpleApiKey> loadAllKeyRecords() throws ConfigDbException {\r
+ Map<String, NsaSimpleApiKey> map = new HashMap<String, NsaSimpleApiKey>();\r
+ map.put("testkey", new NsaSimpleApiKey("testkey", "password"));\r
+ map.put("admin", new NsaSimpleApiKey("admin", "password"));\r
+\r
+ return map;\r
+ }\r
+\r
+ @Override\r
+ public Set<String> loadAllKeys() throws ConfigDbException {\r
+ // TODO Auto-generated method stub\r
+\r
+ return keys;\r
+ }\r
+\r
+ @Override\r
+ public NsaSimpleApiKey loadApiKey(String arg0) throws ConfigDbException {\r
+ if (!keys.contains(arg0)) {\r
+ return null;\r
+ }\r
+ return new NsaSimpleApiKey(arg0, "password");\r
+ }\r
+\r
+ @Override\r
+ public void saveApiKey(NsaSimpleApiKey arg0) throws ConfigDbException {\r
+ // TODO Auto-generated method stub\r
+\r
+ }\r
+ };\r
+\r
}\r
Code Review / dmaap / messagerouter / msgrtr.git / commitdiff