\r
import static org.junit.Assert.*;\r
\r
+import javax.ws.rs.BadRequestException;\r
+import javax.ws.rs.InternalServerErrorException;\r
+import javax.ws.rs.NotAllowedException;\r
+import javax.ws.rs.NotAuthorizedException;\r
+import javax.ws.rs.NotFoundException;\r
+import javax.ws.rs.ServiceUnavailableException;\r
+\r
import org.junit.After;\r
import org.junit.Before;\r
import org.junit.Test;\r
\r
}\r
\r
+ @Test\r
+ public void testToResponseNotFoundException() {\r
+\r
+ DMaaPWebExceptionMapper mapper = new DMaaPWebExceptionMapper();\r
+\r
+ try {\r
+ mapper.toResponse(new NotFoundException());\r
+ } catch (NullPointerException e) {\r
+ assertTrue(true);\r
+ }\r
+\r
+ }\r
+\r
+ @Test\r
+ public void testToResponseInternalServerErrorException() {\r
+\r
+ DMaaPWebExceptionMapper mapper = new DMaaPWebExceptionMapper();\r
+\r
+ try {\r
+ mapper.toResponse(new InternalServerErrorException());\r
+\r
+ } catch (NullPointerException e) {\r
+ assertTrue(true);\r
+ }\r
+\r
+ }\r
+\r
+ @Test\r
+ public void testToResponseNotAuthorizedException() {\r
+\r
+ DMaaPWebExceptionMapper mapper = new DMaaPWebExceptionMapper();\r
+\r
+ try {\r
+ mapper.toResponse(new NotAuthorizedException("Error", "Error"));\r
+\r
+ } catch (NullPointerException e) {\r
+ assertTrue(true);\r
+ }\r
+\r
+ }\r
+\r
+ @Test\r
+ public void testToResponseBadRequestException() {\r
+\r
+ DMaaPWebExceptionMapper mapper = new DMaaPWebExceptionMapper();\r
+\r
+ try {\r
+ mapper.toResponse(new BadRequestException());\r
+\r
+ } catch (NullPointerException e) {\r
+ assertTrue(true);\r
+ }\r
+\r
+ }\r
+\r
+ @Test\r
+ public void testToResponseNotAllowedException() {\r
+\r
+ DMaaPWebExceptionMapper mapper = new DMaaPWebExceptionMapper();\r
+\r
+ try {\r
+ mapper.toResponse(new NotAllowedException("Not Allowed"));\r
+\r
+ } catch (NullPointerException e) {\r
+ assertTrue(true);\r
+ }\r
+\r
+ }\r
+\r
+ @Test\r
+ public void testToResponseServiceUnavailableException() {\r
+\r
+ DMaaPWebExceptionMapper mapper = new DMaaPWebExceptionMapper();\r
+\r
+ try {\r
+ mapper.toResponse(new ServiceUnavailableException());\r
+\r
+ } catch (NullPointerException e) {\r
+ assertTrue(true);\r
+ }\r
+\r
+ }\r
+\r
}
\ No newline at end of file
\r
topicService.permitConsumerForTopic("enfTopicNamePlusExtra", "consumerID");\r
}\r
+ \r
+ @Test\r
+ public void testPermitConsumerForTopicWithException() throws DMaaPAccessDeniedException, CambriaApiException, IOException,\r
+ TopicExistsException, AccessDeniedException {\r
+\r
+ Assert.assertNotNull(topicService);\r
+\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.permitConsumerForTopic("enfTopicNamePlusExtra", "consumerID");\r
+ }\r
\r
@Test\r
public void testDenyConsumerForTopic() throws DMaaPAccessDeniedException, CambriaApiException, IOException,\r
\r
package com.att.nsa.dmaap.util;\r
\r
+import static org.junit.Assert.assertTrue;\r
+\r
import java.io.IOException;\r
-import java.util.logging.Level;\r
\r
import javax.servlet.FilterChain;\r
import javax.servlet.ServletException;\r
import com.att.nsa.cambria.beans.DMaaPContext;\r
import com.att.nsa.cambria.exception.DMaaPResponseCode;\r
\r
+import com.att.cadi.Access.Level; \r
+\r
@RunWith(PowerMockRunner.class)\r
@PrepareForTest({ PropertiesMapBean.class, DMaaPResponseCode.class })\r
public class DMaaPAuthFilterTest {\r
PowerMockito.when(req.getHeader("Authorization")).thenReturn("Authorization");\r
// when(dmaapContext.getResponse()).thenReturn(res);\r
filter.doFilter(req, res, chain);\r
+ assertTrue(true);\r
\r
}\r
\r
\r
// when(dmaapContext.getResponse()).thenReturn(res);\r
filter.doFilter(req, res, chain);\r
+ assertTrue(true);\r
\r
}\r
\r
+ @Test\r
+ public void testLog() {\r
+ String s[] = { "test1", "test2" };\r
+ Object[] o = s;\r
+ filter.log(Level.AUDIT, o);\r
+ filter.log(Level.DEBUG, o);\r
+ filter.log(Level.ERROR, o);\r
+ filter.log(Level.INFO, o);\r
+ filter.log(Level.INIT, o);\r
+ filter.log(Level.WARN, o);\r
+ assertTrue(true);\r
+ } \r
+ \r
}
\ No newline at end of file