package tech.powerjob.client.test;

import com.alibaba.fastjson.JSONObject;
import lombok.extern.slf4j.Slf4j;
import org.junit.jupiter.api.Test;
import tech.powerjob.common.response.JobInfoDTO;
import tech.powerjob.common.response.ResultDTO;
import tech.powerjob.common.utils.CommonUtils;

/**
 * 测试容灾能力
 *
 * @author tjq
 * @since 2024/8/11
 */
@Slf4j
public class TestClusterHA extends ClientInitializer {

    @Test
    void testHa() {
        // 人工让 server 启停
        for (int i = 0; i < 1000000; i++) {

            CommonUtils.easySleep(100);

            ResultDTO<JobInfoDTO> jobInfoDTOResultDTO = powerJobClient.fetchJob(1L);

            log.info("[TestClusterHA] response: {}", JSONObject.toJSONString(jobInfoDTOResultDTO));

            if (!jobInfoDTOResultDTO.isSuccess()) {
                throw new RuntimeException("request failed!");
            }
        }
    }
}