coverage unit test

Change-Id: Ib1b5a43fe1974b1276a7367b32bd63ee506c2232
Signed-off-by: zm330 <zhangminyj@chinamobile.com>
Issue-ID: DCAEGEN2-1468

4 files changed, 245 insertions, 0 deletions

diff --git a/components/datalake-handler/feeder/src/test/java/org/onap/datalake/feeder/controller/KafkaControllerTest.java b/components/datalake-handler/feeder/src/test/java/org/onap/datalake/feeder/controller/KafkaControllerTest.java
new file mode 100644
index 00000000..1469e938
--- /dev/null
+++ b/components/datalake-handler/feeder/src/test/java/org/onap/datalake/feeder/controller/KafkaControllerTest.java
@@ -0,0 +1,83 @@
+/*
+ * ============LICENSE_START=======================================================
+ * ONAP : DataLake
+ * ================================================================================
+ * Copyright 2019 China Mobile
+ *=================================================================================
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ * ============LICENSE_END=========================================================
+ */
+
+package org.onap.datalake.feeder.controller;
+
+import org.junit.Test;
+import org.junit.runner.RunWith;
+import org.mockito.InjectMocks;
+import org.mockito.Mock;
+import org.mockito.junit.MockitoJUnitRunner;
+import org.onap.datalake.feeder.domain.Kafka;
+import org.onap.datalake.feeder.dto.KafkaConfig;
+import org.onap.datalake.feeder.repository.KafkaRepository;
+import org.onap.datalake.feeder.service.KafkaService;
+import org.springframework.validation.BindingResult;
+
+import javax.servlet.http.HttpServletResponse;
+
+import java.io.IOException;
+
+import static org.junit.Assert.*;
+import static org.mockito.Mockito.when;
+
+@RunWith(MockitoJUnitRunner.class)
+public class KafkaControllerTest {
+
+    @Mock
+    private HttpServletResponse httpServletResponse;
+
+    @Mock
+    private BindingResult mockBindingResult;
+
+    @Mock
+    private KafkaService kafkaService;
+
+    @Mock
+    private KafkaRepository kafkaRepository;
+
+    @Mock
+    private Kafka kafka;
+
+    @InjectMocks
+    private KafkaController kafkaController;
+    @Test
+    public void createKafka() throws IOException {
+        String id = "123";
+        KafkaConfig kafkaConfig = new KafkaConfig();
+        kafkaConfig.setId(id);
+        kafkaConfig.setName("123");
+        when(kafkaService.getKafkaById(kafkaConfig.getId())).thenReturn(null).thenReturn(kafka);
+        when(kafkaRepository.save(kafka)).thenReturn(null);
+        when(kafkaService.fillKafkaConfiguration(kafkaConfig)).thenReturn(kafka);
+        when(mockBindingResult.hasErrors()).thenReturn(false,true,false,true);
+
+        kafkaController.createKafka(kafkaConfig,mockBindingResult,httpServletResponse);
+        kafkaController.createKafka(kafkaConfig,mockBindingResult,httpServletResponse);
+
+        kafkaController.updateKafka(kafkaConfig,mockBindingResult,id,httpServletResponse);
+        kafkaController.updateKafka(kafkaConfig,mockBindingResult,id,httpServletResponse);
+
+        kafkaController.deleteKafka(id,httpServletResponse);
+
+        when(kafkaService.getAllKafka()).thenReturn(null);
+        kafkaController.queryAllKafka();
+    }
+}
\ No newline at end of file
diff --git a/components/datalake-handler/feeder/src/test/java/org/onap/datalake/feeder/dto/KafkaConfigTest.java b/components/datalake-handler/feeder/src/test/java/org/onap/datalake/feeder/dto/KafkaConfigTest.java
new file mode 100644
index 00000000..7ab22733
--- /dev/null
+++ b/components/datalake-handler/feeder/src/test/java/org/onap/datalake/feeder/dto/KafkaConfigTest.java
@@ -0,0 +1,33 @@
+/*
+ * ============LICENSE_START=======================================================
+ * ONAP : DataLake
+ * ================================================================================
+ * Copyright 2019 China Mobile
+ *=================================================================================
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ * ============LICENSE_END=========================================================
+ */
+package org.onap.datalake.feeder.dto;
+
+import org.junit.Test;
+
+import static org.junit.Assert.*;
+
+public class KafkaConfigTest {
+
+    @Test
+    public void testKafkaConfig(){
+        KafkaConfig kafkaConfig = new KafkaConfig();
+    }
+
+}
\ No newline at end of file
diff --git a/components/datalake-handler/feeder/src/test/java/org/onap/datalake/feeder/service/DesignTypeServiceTest.java b/components/datalake-handler/feeder/src/test/java/org/onap/datalake/feeder/service/DesignTypeServiceTest.java
new file mode 100644
index 00000000..5879deb6
--- /dev/null
+++ b/components/datalake-handler/feeder/src/test/java/org/onap/datalake/feeder/service/DesignTypeServiceTest.java
@@ -0,0 +1,59 @@
+/*
+ * ============LICENSE_START=======================================================
+ * ONAP : DataLake
+ * ================================================================================
+ * Copyright 2019 China Mobile
+ *=================================================================================
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ * ============LICENSE_END=========================================================
+ */
+package org.onap.datalake.feeder.service;
+
+import org.junit.Test;
+import org.junit.runner.RunWith;
+import org.mockito.InjectMocks;
+import org.mockito.Mock;
+import org.mockito.junit.MockitoJUnitRunner;
+import org.onap.datalake.feeder.domain.DesignType;
+import org.onap.datalake.feeder.dto.DesignTypeConfig;
+import org.onap.datalake.feeder.repository.DesignTypeRepository;
+
+import java.util.ArrayList;
+import java.util.List;
+
+import static org.junit.Assert.*;
+import static org.mockito.Mockito.when;
+
+@RunWith(MockitoJUnitRunner.class)
+public class DesignTypeServiceTest {
+
+    @Mock
+    private DesignTypeRepository designTypeRepository;
+
+    @InjectMocks
+    private DesignTypeService designTypeService;
+
+    @Test
+    public void testDesignTypeService(){
+        List<DesignType> designTypeList = new ArrayList<>();
+        DesignType designType = new DesignType();
+        designType.setName("test");
+        //DesignTypeConfig designTypeConfig = new DesignTypeConfig();
+        //designTypeConfig.setDesignType("test");
+        //designTypeConfig.setDisplay("test");
+        designTypeList.add(designType);
+        when(designTypeRepository.findAll()).thenReturn(designTypeList);
+        assertNotNull(designTypeService.getDesignTypes());
+    }
+
+}
\ No newline at end of file
diff --git a/components/datalake-handler/feeder/src/test/java/org/onap/datalake/feeder/service/KafkaServiceTest.java b/components/datalake-handler/feeder/src/test/java/org/onap/datalake/feeder/service/KafkaServiceTest.java
new file mode 100644
index 00000000..3bdeb1a2
--- /dev/null
+++ b/components/datalake-handler/feeder/src/test/java/org/onap/datalake/feeder/service/KafkaServiceTest.java
@@ -0,0 +1,70 @@
+/*
+ * ============LICENSE_START=======================================================
+ * ONAP : DATALAKE
+ * ================================================================================
+ * Copyright 2019 China Mobile
+ *=================================================================================
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ * ============LICENSE_END=========================================================
+ */
+
+package org.onap.datalake.feeder.service;
+
+import org.junit.Test;
+import org.junit.runner.RunWith;
+import org.mockito.InjectMocks;
+import org.mockito.Mock;
+import org.mockito.junit.MockitoJUnitRunner;
+import org.onap.datalake.feeder.domain.Kafka;
+import org.onap.datalake.feeder.dto.KafkaConfig;
+import org.onap.datalake.feeder.repository.KafkaRepository;
+
+import java.util.ArrayList;
+import java.util.List;
+import java.util.Optional;
+
+import static org.junit.Assert.*;
+import static org.mockito.Mockito.when;
+
+@RunWith(MockitoJUnitRunner.class)
+public class KafkaServiceTest {
+
+    @InjectMocks
+    private KafkaService kafkaService;
+
+    @Mock
+    private KafkaRepository kafkaRepository;
+
+    @Mock
+    private KafkaConfig kafkaConfig;
+
+    @Test
+    public void testKafkaServer(){
+        String kafkaId = "123";
+        Kafka kafka = new Kafka();
+        kafka.setId(kafkaId);
+
+        List<Kafka> kafkas = new ArrayList<>();
+        kafkas.add(kafka);
+
+        when(kafkaRepository.findById(kafkaId)).thenReturn(Optional.of(kafka));
+        Kafka kafkaById = kafkaService.getKafkaById(kafkaId);
+        assertEquals(kafka,kafkaById);
+
+        when(kafkaRepository.findAll()).thenReturn(kafkas);
+        assertNotNull(kafkaService.getAllKafka());
+
+        kafkaService.fillKafkaConfiguration(kafkaConfig);
+    }
+
+}
\ No newline at end of file