1 files changed, 315 insertions, 0 deletions
diff --git a/src/test/java/org/onap/dmaap/mr/tools/ValidatorUtilTest.java b/src/test/java/org/onap/dmaap/mr/tools/ValidatorUtilTest.java
new file mode 100644
index 0000000..1306a30
--- /dev/null
+++ b/src/test/java/org/onap/dmaap/mr/tools/ValidatorUtilTest.java
@@ -0,0 +1,315 @@
+/*******************************************************************************
+ *  ============LICENSE_START=======================================================
+ *  org.onap.dmaap
+ *  ================================================================================
+ *  Copyright © 2018 IBM Intellectual Property. All rights reserved.
+ *  ================================================================================
+ *  Licensed under the Apache License, Version 2.0 (the "License");
+ *  you may not use this file except in compliance with the License.
+ *  You may obtain a copy of the License at
+ *        http://www.apache.org/licenses/LICENSE-2.0
+ *  
+ *  Unless required by applicable law or agreed to in writing, software
+ *  distributed under the License is distributed on an "AS IS" BASIS,
+ *  WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ *  See the License for the specific language governing permissions and
+ *  limitations under the License.
+ *  ============LICENSE_END=========================================================
+ *
+ *  ECOMP is a trademark and service mark of AT&T Intellectual Property.
+ *  
+ *******************************************************************************/
+
+package org.onap.dmaap.mr.tools;
+
+import static org.junit.Assert.assertEquals;
+
+import java.util.Properties;
+
+import org.junit.Test;
+
+import org.onap.dmaap.mr.test.clients.ProtocolTypeConstants;
+
+public class ValidatorUtilTest {
+
+    @Test
+    public void testValidateForDME2WithNullServiceName() {
+        Properties props = new Properties();
+        props.setProperty("TransportType", ProtocolTypeConstants.DME2.getValue());
+        try{
+            ValidatorUtil.validatePublisher(props);
+        } catch(IllegalArgumentException e) {
+            assertEquals(e.getMessage(), "Servicename is needed");
+        }
+        
+    }
+    
+    @Test
+    public void testValidateForDME2WithNullTopic() {
+        Properties props = new Properties();
+        props.setProperty("TransportType", ProtocolTypeConstants.DME2.getValue());
+        props.setProperty("ServiceName", "ServiceName");
+        try{
+            ValidatorUtil.validatePublisher(props);
+        } catch(IllegalArgumentException e) {
+            assertEquals(e.getMessage(), "topic is needed");
+        }
+        
+    }
+    
+    @Test
+    public void testValidateForDME2WithNullUserName() {
+        Properties props = new Properties();
+        props.setProperty("TransportType", ProtocolTypeConstants.DME2.getValue());
+        props.setProperty("ServiceName", "ServiceName");
+        props.setProperty("topic", "topic");
+        try{
+            ValidatorUtil.validatePublisher(props);
+        } catch(IllegalArgumentException e) {
+            assertEquals(e.getMessage(), "username is needed");
+        }
+        
+    }
+    
+    @Test
+    public void testValidateForDME2WithNullPassword() {
+        Properties props = new Properties();
+        props.setProperty("TransportType", ProtocolTypeConstants.DME2.getValue());
+        props.setProperty("ServiceName", "ServiceName");
+        props.setProperty("topic", "topic");
+        props.setProperty("username", "username");
+        
+        try{
+            ValidatorUtil.validatePublisher(props);
+        } catch(IllegalArgumentException e) {
+            assertEquals(e.getMessage(), "password is needed");
+        }
+        
+    }
+    
+    
+    
+    
+    @Test
+    public void testValidateForNonDME2WithNullServiceName() {
+        Properties props = new Properties();
+        props.setProperty("TransportType", ProtocolTypeConstants.AUTH_KEY.getValue());
+        try{
+            ValidatorUtil.validatePublisher(props);
+        } catch(IllegalArgumentException e) {
+            assertEquals(e.getMessage(), "Servicename is needed");
+        }
+        
+    }
+    
+    @Test
+    public void testValidateForNonDME2WithNullTopic() {
+        Properties props = new Properties();
+        props.setProperty("TransportType", ProtocolTypeConstants.AUTH_KEY.getValue());
+        props.setProperty("host", "ServiceName");
+        try{
+            ValidatorUtil.validatePublisher(props);
+        } catch(IllegalArgumentException e) {
+            assertEquals(e.getMessage(), "topic is needed");
+        }
+        
+    }
+    
+    @Test
+    public void testValidateForNonDME2WithNullContenttype() {
+        Properties props = new Properties();
+        props.setProperty("TransportType", ProtocolTypeConstants.AUTH_KEY.getValue());
+        props.setProperty("host", "ServiceName");
+        props.setProperty("topic", "topic");
+        try{
+            ValidatorUtil.validatePublisher(props);
+        } catch(IllegalArgumentException e) {
+            assertEquals(e.getMessage(), "contenttype is needed");
+        }
+        
+    }
+
+    
+    @Test
+    public void testValidateForNonDME2WithNullUserName() {
+        Properties props = new Properties();
+        props.setProperty("TransportType", ProtocolTypeConstants.AUTH_KEY.getValue());
+        props.setProperty("host", "ServiceName");
+        props.setProperty("topic", "topic");
+        props.setProperty("contenttype", "contenttype");
+        try{
+            ValidatorUtil.validatePublisher(props);
+        } catch(IllegalArgumentException e) {
+            assertEquals(e.getMessage(), "username is needed");
+        }
+        
+    }
+    
+    @Test
+    public void testValidateForNonDME2WithNullPassword() {
+        Properties props = new Properties();
+        props.setProperty("TransportType", ProtocolTypeConstants.AUTH_KEY.getValue());
+        props.setProperty("host", "ServiceName");
+        props.setProperty("topic", "topic");
+        props.setProperty("username", "username");
+        props.setProperty("contenttype", "contenttype");
+        
+        try{
+            ValidatorUtil.validatePublisher(props);
+        } catch(IllegalArgumentException e) {
+            assertEquals(e.getMessage(), "password is needed");
+        }
+        
+    }
+    
+    @Test
+    public void testValidateForNonDME2WithAuthKey() {
+        Properties props = new Properties();
+        props.setProperty("TransportType", ProtocolTypeConstants.AUTH_KEY.getValue());
+        props.setProperty("host", "ServiceName");
+        props.setProperty("topic", "topic");
+        props.setProperty("username", "username");
+        props.setProperty("contenttype", "contenttype");
+        props.setProperty("password", "password");
+        
+        try{
+            ValidatorUtil.validatePublisher(props);
+        } catch(IllegalArgumentException e) {
+            assertEquals(e.getMessage(), "authKey is needed");
+        }
+        
+    }
+    
+    @Test
+    public void testValidateForNonDME2WithOutAuthDate() {
+        Properties props = new Properties();
+        props.setProperty("TransportType", ProtocolTypeConstants.AUTH_KEY.getValue());
+        props.setProperty("host", "ServiceName");
+        props.setProperty("topic", "topic");
+        props.setProperty("username", "username");
+        props.setProperty("contenttype", "contenttype");
+        props.setProperty("password", "password");
+        props.setProperty("authKey", "authKey");
+        
+        
+        try{
+            ValidatorUtil.validatePublisher(props);
+        } catch(IllegalArgumentException e) {
+            assertEquals(e.getMessage(), "authDate is needed");
+        }
+    }
+    
+    @Test
+    public void testValidateForNonDME2WithAuthDate() {
+        Properties props = new Properties();
+        props.setProperty("TransportType", ProtocolTypeConstants.AUTH_KEY.getValue());
+        props.setProperty("host", "ServiceName");
+        props.setProperty("topic", "topic");
+        props.setProperty("username", "username");
+        props.setProperty("contenttype", "contenttype");
+        props.setProperty("password", "password");
+        props.setProperty("authKey", "authKey");
+        props.setProperty("authDate", "authDate");
+        
+        try{
+            ValidatorUtil.validatePublisher(props);
+        } catch(IllegalArgumentException e) {
+            assertEquals(e.getMessage(), "maxBatchSize is needed");
+        }
+    }
+        
+        
+        @Test
+        public void testValidateForNonDME2WithMaxAgeMs() {
+            Properties props = new Properties();
+            props.setProperty("TransportType", ProtocolTypeConstants.AUTH_KEY.getValue());
+            props.setProperty("host", "ServiceName");
+            props.setProperty("topic", "topic");
+            props.setProperty("username", "username");
+            props.setProperty("contenttype", "contenttype");
+            props.setProperty("password", "password");
+            props.setProperty("authKey", "authKey");
+            props.setProperty("authDate", "authDate");
+            props.setProperty("maxBatchSize", "maxBatchSize");
+            
+            try{
+                ValidatorUtil.validatePublisher(props);
+            } catch(IllegalArgumentException e) {
+                assertEquals(e.getMessage(), "maxAgeMs is needed");
+            }
+            
+     
+        
+    }
+        
+        @Test
+        public void testValidateForNonDME2WithMessageSentThreadOccurance() {
+            Properties props = new Properties();
+            props.setProperty("TransportType", ProtocolTypeConstants.AUTH_KEY.getValue());
+            props.setProperty("host", "ServiceName");
+            props.setProperty("topic", "topic");
+            props.setProperty("username", "username");
+            props.setProperty("contenttype", "contenttype");
+            props.setProperty("password", "password");
+            props.setProperty("authKey", "authKey");
+            props.setProperty("authDate", "authDate");
+            props.setProperty("maxBatchSize", "maxBatchSize");
+            props.setProperty("maxAgeMs", "maxAgeMs");
+            
+            try{
+                ValidatorUtil.validatePublisher(props);
+            } catch(IllegalArgumentException e) {
+                assertEquals(e.getMessage(), "MessageSentThreadOccurance is needed");
+            }
+            
+        }
+            
+            
+            @Test
+            public void testValidateSubscriberWithoutGroup() {
+                Properties props = new Properties();
+                props.setProperty("TransportType", ProtocolTypeConstants.AUTH_KEY.getValue());
+                props.setProperty("host", "ServiceName");
+                props.setProperty("topic", "topic");
+                props.setProperty("username", "username");
+                props.setProperty("contenttype", "contenttype");
+                props.setProperty("password", "password");
+                props.setProperty("authKey", "authKey");
+                props.setProperty("authDate", "authDate");
+                props.setProperty("maxBatchSize", "maxBatchSize");
+                props.setProperty("maxAgeMs", "maxAgeMs");
+                
+                try{
+                    ValidatorUtil.validateSubscriber(props);
+                } catch(IllegalArgumentException e) {
+                    assertEquals(e.getMessage(), "group is needed");
+                }
+     }
+            
+            @Test
+            public void testValidateSubscriberWithoutCustomer() {
+                Properties props = new Properties();
+                props.setProperty("TransportType", ProtocolTypeConstants.AUTH_KEY.getValue());
+                props.setProperty("host", "ServiceName");
+                props.setProperty("topic", "topic");
+                props.setProperty("username", "username");
+                props.setProperty("contenttype", "contenttype");
+                props.setProperty("password", "password");
+                props.setProperty("authKey", "authKey");
+                props.setProperty("authDate", "authDate");
+                props.setProperty("maxBatchSize", "maxBatchSize");
+                props.setProperty("maxAgeMs", "maxAgeMs");
+                props.setProperty("group", "group");
+                
+                try{
+                    ValidatorUtil.validateSubscriber(props);
+                } catch(IllegalArgumentException e) {
+                    assertEquals(e.getMessage(), "Consumer (Id)  is needed");
+                }
+     }
+
+    
+    
+    
+    
+}