8x48/KnowStreaming
1
0
Fork 0
mirror of https://github.com/didi/KnowStreaming.git synced 2026-05-18 19:40:24 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

所有单测重新测试

Browse Source
This commit is contained in:
didi
2022-01-18 17:07:21 +08:00
parent 055ba9bda6
commit 34d9f9174b
30 changed files with 590 additions and 584 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
kafka-manager-extends/kafka-manager-account/src/test/java/com/xiaojukeji/kafka/manager/account/AccountServiceTest.java
View File

@@ -31,6 +31,10 @@ import java.util.List;
* @Date 2021/12/29
*/
public class AccountServiceTest extends BaseTest {
/*
此测试不能一起运行，因为一些test中会执行一次flush()，执行完毕后，缓存就不为null
后面的测试中本来应该再次刷新缓存，但由于缓存不为null，就不会再执行flush
*/
@Autowired
@InjectMocks
private AccountService accountService;

1
kafka-manager-extends/kafka-manager-bpm/src/test/java/com/xiaojukeji/kafka/manager/bpm/AbstractOrderStorageServiceTest.java
View File

@@ -60,6 +60,7 @@ public class AbstractOrderStorageServiceTest extends BaseTest {
private void cancel2WithoutAuthority() {
OrderDO orderDO = getOrderDO();
Mockito.when(orderDao.getById(Mockito.any())).thenReturn(orderDO);
Assert.assertEquals(abstractOrderStorageService.cancel(1L, "username"), ResultStatus.USER_WITHOUT_AUTHORITY);
}

4
kafka-manager-extends/kafka-manager-bpm/src/test/java/com/xiaojukeji/kafka/manager/bpm/OrderServiceTest.java
View File

@@ -12,6 +12,7 @@ import com.xiaojukeji.kafka.manager.bpm.config.BaseTest;
import com.xiaojukeji.kafka.manager.common.entity.Result;
import com.xiaojukeji.kafka.manager.common.entity.ResultStatus;
import com.xiaojukeji.kafka.manager.common.entity.pojo.OrderDO;
import com.xiaojukeji.kafka.manager.service.cache.LogicalClusterMetadataManager;
import org.mockito.InjectMocks;
import org.mockito.Mock;
import org.mockito.Mockito;
@@ -41,7 +42,8 @@ public class OrderServiceTest extends BaseTest {
private static final Long INVALID_ORDER_ID = -1L;
private static final String EXTENSIONS = "{\"clusterId\":7,\"topicName\":\"moduleTest2\",\"appId\":\"dkm_admin\",\"peakBytesIn\":104857600000}";
// EXTENSIONS中的clusterId需要是自己数据库中真实的逻辑集群id，这样createOrder才能跑通
private static final String EXTENSIONS = "{\"clusterId\":15,\"topicName\":\"moduleTest2\",\"appId\":\"dkm_admin\",\"peakBytesIn\":104857600000}";
/**
* 工单状态, 0:待审批, 1:通过, 2:拒绝, 3:取消

2
kafka-manager-extends/kafka-manager-bpm/src/test/java/com/xiaojukeji/kafka/manager/bpm/order/ApplyQuotaOrderTest.java
View File

@@ -287,7 +287,7 @@ public class ApplyQuotaOrderTest extends BaseTest {
OrderDO orderDO = getOrderDO();
OrderHandleBaseDTO orderHandleBaseDTO = getOrderHandleBaseDTO();
ResultStatus resultStatus = applyQuotaOrder.handleOrderDetail(orderDO, orderHandleBaseDTO, ADMIN);
Assert.assertEquals(resultStatus.getCode(), ResultStatus.OPERATION_FORBIDDEN.getCode());
Assert.assertEquals(resultStatus.getCode(), ResultStatus.OPERATION_FAILED.getCode());
}
@Test

1
kafka-manager-extends/kafka-manager-kcm/src/test/java/com/xiaojukeji/kafka/manager/kcm/ClusterTaskServiceTest.java
View File

@@ -250,6 +250,7 @@ public class ClusterTaskServiceTest extends BaseTest {
private void executeTask2RollbackForbiddenTest() {
Mockito.when(abstractAgent.getTaskExecuteState(Mockito.anyLong())).thenReturn(Result.buildSuc(ClusterTaskStateEnum.RUNNING));
ClusterTaskDO clusterTaskDO = getClusterTaskDO();
clusterTaskDO.setAgentRollbackTaskId(1L);
Mockito.when(clusterTaskDao.getById(Mockito.anyLong())).thenReturn(clusterTaskDO);
// operation failed

53
kafka-manager-extends/kafka-manager-monitor/src/test/java/com/xiaojukeji/kafka/manager/monitor/AbstractMonitorServiceTest.java
View File

@@ -1,53 +0,0 @@
package com.xiaojukeji.kafka.manager.monitor;
import com.xiaojukeji.kafka.manager.monitor.common.entry.Strategy;
import com.xiaojukeji.kafka.manager.monitor.component.AbstractMonitorService;
import com.xiaojukeji.kafka.manager.monitor.config.BaseTest;
import org.mockito.InjectMocks;
import org.mockito.Mock;
import org.mockito.Mockito;
import org.mockito.MockitoAnnotations;
import org.springframework.beans.factory.annotation.Autowired;
import org.testng.annotations.BeforeMethod;
import org.testng.annotations.Test;
import java.io.IOException;
import java.net.HttpURLConnection;
import java.util.ArrayList;
/**
* @author wyc
* @date 2022/1/5
*/
public class AbstractMonitorServiceTest extends BaseTest {
@Autowired
@InjectMocks
private AbstractMonitorService abstractMonitorService;
@Mock
private HttpURLConnection conn;
@BeforeMethod
public void init() {
MockitoAnnotations.initMocks(this);
}
private Strategy getStrategy() {
Strategy strategy = new Strategy();
strategy.setName("test_strategy");
strategy.setId(1L);
strategy.setPeriodDaysOfWeek("1");
strategy.setPeriodHoursOfDay("24");
strategy.setPriority(0);
strategy.setStrategyFilterList(new ArrayList<>());
strategy.setStrategyExpressionList(new ArrayList<>());
strategy.setStrategyActionList(new ArrayList<>());
return strategy;
}
@Test
public void createStrategyTest() throws IOException {
Strategy strategy = getStrategy();
Integer i = abstractMonitorService.createStrategy(strategy);
System.out.println(i);
}
}

10
kafka-manager-extends/kafka-manager-openapi/src/test/java/com/xiaojukeji/kafka/manager/openapi/ThirdPartServiceTest.java
View File

@@ -30,9 +30,9 @@ public class ThirdPartServiceTest extends BaseTest {
private final static Long REAL_CLUSTER_ID_IN_MYSQL = 1L;
private final static String REAL_TOPIC_IN_ZK = "topic_a";
private final static String REAL_TOPIC_IN_ZK = "moduleTest";
private final static String REAL_PHYSICAL_CLUSTER_NAME = "cluster1";
private final static String REAL_PHYSICAL_CLUSTER_NAME = "LogiKM_moduleTest";
private final static String ZOOKEEPER = "10.190.12.242:2181,10.190.25.160:2181,10.190.25.41:2181/wyc";
@@ -45,8 +45,8 @@ public class ThirdPartServiceTest extends BaseTest {
private final static String REAL_APP_ID = "dkm_admin";
// 要求消费topic_a这个topic的消费者所属的消费者组是group.demo
private final static String REAL_CONSUMER_GROUP_ID = "group.demo";
// 要求消费moduleTest这个topic的消费者所属的消费者组是moduleTestGroup
private final static String REAL_CONSUMER_GROUP_ID = "moduleTestGroup";
@Autowired
@InjectMocks
@@ -133,7 +133,7 @@ public class ThirdPartServiceTest extends BaseTest {
@Test
public void resetOffsetSuccessTest() {
// 要求有消费组group.demo
// 要求有消费组moduleTestGroup
Result expectedResult = Result.buildSuc();
ClusterDO clusterDO = getClusterDO();
OffsetResetDTO offsetResetDTO = getOffsetResetDTO();