feat:upgrade to 2023.0.6. (#1646)

pull/1648/head
Haotian Zhang 2 months ago committed by GitHub
parent 6371548d90
commit 5f462b0cd6
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194

@ -2,4 +2,5 @@
--- ---
- [fix:fix PolarisContextProperties instantiated twice causing NPE.](https://github.com/Tencent/spring-cloud-tencent/pull/1641) - [fix:fix PolarisContextProperties instantiated twice causing NPE.](https://github.com/Tencent/spring-cloud-tencent/pull/1641)
- [feat: support tsf 2024.](https://github.com/Tencent/spring-cloud-tencent/pull/1645) - [feat: support tsf gw.](https://github.com/Tencent/spring-cloud-tencent/pull/1645)
- [feat:upgrade to 2023.0.6.](https://github.com/Tencent/spring-cloud-tencent/pull/1646)

@ -5,7 +5,7 @@
<parent> <parent>
<groupId>org.springframework.cloud</groupId> <groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-build</artifactId> <artifactId>spring-cloud-build</artifactId>
<version>4.1.5</version> <version>4.1.6</version>
<relativePath/> <relativePath/>
</parent> </parent>
<modelVersion>4.0.0</modelVersion> <modelVersion>4.0.0</modelVersion>
@ -90,16 +90,16 @@
<properties> <properties>
<!-- Project revision --> <!-- Project revision -->
<revision>2.0.3.0-2023.0.5-SNAPSHOT</revision> <revision>2.1.0.0-2023.0.6-SNAPSHOT</revision>
<!-- Spring Framework --> <!-- Spring Framework -->
<spring.framework.version>6.1.20</spring.framework.version> <spring.framework.version>6.1.21</spring.framework.version>
<!-- Spring Boot --> <!-- Spring Boot -->
<spring.boot.version>3.3.12</spring.boot.version> <spring.boot.version>3.3.13</spring.boot.version>
<!-- Spring Cloud --> <!-- Spring Cloud -->
<spring.cloud.version>2023.0.5</spring.cloud.version> <spring.cloud.version>2023.0.6</spring.cloud.version>
<!-- Maven Plugin Versions --> <!-- Maven Plugin Versions -->
<jacoco.version>0.8.12</jacoco.version> <jacoco.version>0.8.12</jacoco.version>

@ -30,7 +30,6 @@ import com.tencent.cloud.polaris.context.config.PolarisContextAutoConfiguration;
import com.tencent.cloud.rpc.enhancement.config.RpcEnhancementAutoConfiguration; import com.tencent.cloud.rpc.enhancement.config.RpcEnhancementAutoConfiguration;
import com.tencent.polaris.client.util.Utils; import com.tencent.polaris.client.util.Utils;
import org.junit.jupiter.api.AfterAll; import org.junit.jupiter.api.AfterAll;
import org.junit.jupiter.api.Assertions;
import org.junit.jupiter.api.BeforeAll; import org.junit.jupiter.api.BeforeAll;
import org.junit.jupiter.api.Test; import org.junit.jupiter.api.Test;
import org.junit.jupiter.api.extension.ExtendWith; import org.junit.jupiter.api.extension.ExtendWith;
@ -101,16 +100,16 @@ public class PolarisCircuitBreakerTest {
Method getConfigurationsMethod = ReflectionUtils.findMethod(PolarisCircuitBreakerFactory.class, Method getConfigurationsMethod = ReflectionUtils.findMethod(PolarisCircuitBreakerFactory.class,
"getConfigurations"); "getConfigurations");
Assertions.assertNotNull(getConfigurationsMethod); assertThat(getConfigurationsMethod).isNotNull();
ReflectionUtils.makeAccessible(getConfigurationsMethod); ReflectionUtils.makeAccessible(getConfigurationsMethod);
Map<?, ?> values = (Map<?, ?>) ReflectionUtils.invokeMethod(getConfigurationsMethod, polarisCircuitBreakerFactory); Map<?, ?> values = (Map<?, ?>) ReflectionUtils.invokeMethod(getConfigurationsMethod, polarisCircuitBreakerFactory);
Assertions.assertNotNull(values); assertThat(values).isNotNull();
Assertions.assertEquals(1, values.size()); assertThat(values.size()).isEqualTo(1);
Utils.sleepUninterrupted(10 * 1000); Utils.sleepUninterrupted(10 * 1000);
Assertions.assertEquals(0, values.size()); assertThat(values.size()).isEqualTo(0);
}); });
} }

@ -19,13 +19,14 @@ package com.tencent.cloud.polaris.circuitbreaker.common;
import java.lang.reflect.Method; import java.lang.reflect.Method;
import org.junit.jupiter.api.Assertions;
import org.junit.jupiter.api.Test; import org.junit.jupiter.api.Test;
import org.junit.jupiter.api.extension.ExtendWith; import org.junit.jupiter.api.extension.ExtendWith;
import org.mockito.junit.jupiter.MockitoExtension; import org.mockito.junit.jupiter.MockitoExtension;
import org.springframework.web.reactive.function.client.WebClientResponseException; import org.springframework.web.reactive.function.client.WebClientResponseException;
import static org.assertj.core.api.Assertions.assertThat;
/** /**
* Test for ${@link PolarisResultToErrorCode}. * Test for ${@link PolarisResultToErrorCode}.
* *
@ -38,7 +39,7 @@ class PolarisResultToErrorCodeTest {
@Test @Test
void testOnSuccess() { void testOnSuccess() {
Assertions.assertEquals(200, converter.onSuccess("any value")); assertThat(converter.onSuccess("any value")).isEqualTo(200);
} }
@Test @Test
@ -51,7 +52,7 @@ class PolarisResultToErrorCodeTest {
int errorCode = converter.onError(exception); int errorCode = converter.onError(exception);
// Then // Then
Assertions.assertEquals(404, errorCode); assertThat(errorCode).isEqualTo(404);
} }
@Test @Test
@ -60,7 +61,7 @@ class PolarisResultToErrorCodeTest {
int errorCode = converter.onError(new RuntimeException("test")); int errorCode = converter.onError(new RuntimeException("test"));
// Then // Then
Assertions.assertEquals(-1, errorCode); assertThat(errorCode).isEqualTo(-1);
} }
@Test @Test
@ -72,7 +73,7 @@ class PolarisResultToErrorCodeTest {
int errorCode = converter.onError(exception); int errorCode = converter.onError(exception);
// Then // Then
Assertions.assertEquals(-1, errorCode); assertThat(errorCode).isEqualTo(-1);
} }
@Test @Test
@ -85,10 +86,10 @@ class PolarisResultToErrorCodeTest {
// test exist class // test exist class
boolean result1 = (boolean) checkClassExist.invoke(converter, "java.lang.String"); boolean result1 = (boolean) checkClassExist.invoke(converter, "java.lang.String");
Assertions.assertTrue(result1); assertThat(result1).isTrue();
// test not exist class // test not exist class
boolean result2 = (boolean) checkClassExist.invoke(converter, "com.nonexistent.Class"); boolean result2 = (boolean) checkClassExist.invoke(converter, "com.nonexistent.Class");
Assertions.assertFalse(result2); assertThat(result2).isFalse();
} }
} }

@ -28,7 +28,6 @@ import com.tencent.polaris.circuitbreak.client.exception.CallAbortedException;
import feign.InvocationHandlerFactory; import feign.InvocationHandlerFactory;
import feign.Target; import feign.Target;
import feign.codec.Decoder; import feign.codec.Decoder;
import org.junit.jupiter.api.Assertions;
import org.junit.jupiter.api.BeforeEach; import org.junit.jupiter.api.BeforeEach;
import org.junit.jupiter.api.Test; import org.junit.jupiter.api.Test;
import org.junit.jupiter.api.extension.ExtendWith; import org.junit.jupiter.api.extension.ExtendWith;
@ -37,6 +36,7 @@ import org.mockito.junit.jupiter.MockitoExtension;
import org.springframework.cloud.openfeign.FallbackFactory; import org.springframework.cloud.openfeign.FallbackFactory;
import static org.assertj.core.api.Assertions.assertThat;
import static org.assertj.core.api.AssertionsForClassTypes.assertThatThrownBy; import static org.assertj.core.api.AssertionsForClassTypes.assertThatThrownBy;
import static org.mockito.ArgumentMatchers.any; import static org.mockito.ArgumentMatchers.any;
import static org.mockito.Mockito.mock; import static org.mockito.Mockito.mock;
@ -84,20 +84,20 @@ class PolarisFeignCircuitBreakerInvocationHandlerTest {
@Test @Test
void testConstructorWithNullTarget() { void testConstructorWithNullTarget() {
Assertions.assertThrows(NullPointerException.class, () -> assertThatThrownBy(() ->
new PolarisFeignCircuitBreakerInvocationHandler( new PolarisFeignCircuitBreakerInvocationHandler(
null, dispatch, fallbackFactory, decoder null, dispatch, fallbackFactory, decoder
) )
); ).isExactlyInstanceOf(NullPointerException.class);
} }
@Test @Test
void testConstructorWithNullDispatch() { void testConstructorWithNullDispatch() {
Assertions.assertThrows(NullPointerException.class, () -> assertThatThrownBy(() ->
new PolarisFeignCircuitBreakerInvocationHandler( new PolarisFeignCircuitBreakerInvocationHandler(
target, null, fallbackFactory, decoder target, null, fallbackFactory, decoder
) )
); ).isExactlyInstanceOf(NullPointerException.class);
} }
@Test @Test
@ -108,9 +108,9 @@ class PolarisFeignCircuitBreakerInvocationHandlerTest {
Map<Method, Method> result = PolarisFeignCircuitBreakerInvocationHandler.toFallbackMethod(testDispatch); Map<Method, Method> result = PolarisFeignCircuitBreakerInvocationHandler.toFallbackMethod(testDispatch);
Assertions.assertNotNull(result); assertThat(result).isNotNull();
Assertions.assertTrue(result.containsKey(method)); assertThat(result.containsKey(method)).isTrue();
Assertions.assertEquals(method, result.get(method)); assertThat(result.get(method)).isEqualTo(method);
} }
@Test @Test
@ -119,10 +119,10 @@ class PolarisFeignCircuitBreakerInvocationHandlerTest {
Object mockProxy = mock(Object.class); Object mockProxy = mock(Object.class);
// Test equals with null // Test equals with null
Assertions.assertFalse((Boolean) handler.invoke(mockProxy, equalsMethod, new Object[] {null})); assertThat((Boolean) handler.invoke(mockProxy, equalsMethod, new Object[] {null})).isFalse();
// Test equals with non-proxy object // Test equals with non-proxy object
Assertions.assertFalse((Boolean) handler.invoke(mockProxy, equalsMethod, new Object[] {new Object()})); assertThat((Boolean) handler.invoke(mockProxy, equalsMethod, new Object[] {new Object()})).isFalse();
} }
@Test @Test
@ -131,7 +131,7 @@ class PolarisFeignCircuitBreakerInvocationHandlerTest {
Object mockProxy = mock(Object.class); Object mockProxy = mock(Object.class);
when(target.toString()).thenReturn("TestTarget"); when(target.toString()).thenReturn("TestTarget");
Assertions.assertEquals("TestTarget", handler.invoke(mockProxy, toStringMethod, null)); assertThat(handler.invoke(mockProxy, toStringMethod, null)).isEqualTo("TestTarget");
} }
@Test @Test
@ -178,7 +178,7 @@ class PolarisFeignCircuitBreakerInvocationHandlerTest {
Object result = handler.invoke(null, testMethod, new Object[] {}); Object result = handler.invoke(null, testMethod, new Object[] {});
// Verify // Verify
Assertions.assertEquals(expected, result); assertThat(result).isEqualTo(expected);
} }
@Test @Test
@ -190,8 +190,8 @@ class PolarisFeignCircuitBreakerInvocationHandlerTest {
decoder decoder
); );
Assertions.assertEquals(handler, testHandler); assertThat(testHandler).isEqualTo(handler);
Assertions.assertEquals(handler.hashCode(), testHandler.hashCode()); assertThat(testHandler.hashCode()).isEqualTo(handler.hashCode());
} }
interface TestInterface { interface TestInterface {

@ -20,12 +20,12 @@ package com.tencent.cloud.polaris.circuitbreaker.instrument.feign;
import feign.Feign; import feign.Feign;
import feign.RequestLine; import feign.RequestLine;
import feign.Target; import feign.Target;
import org.junit.jupiter.api.Assertions;
import org.junit.jupiter.api.BeforeEach; import org.junit.jupiter.api.BeforeEach;
import org.junit.jupiter.api.Test; import org.junit.jupiter.api.Test;
import org.springframework.cloud.openfeign.FallbackFactory; import org.springframework.cloud.openfeign.FallbackFactory;
import static org.assertj.core.api.Assertions.assertThat;
import static org.mockito.ArgumentMatchers.any; import static org.mockito.ArgumentMatchers.any;
import static org.mockito.Mockito.mock; import static org.mockito.Mockito.mock;
import static org.mockito.Mockito.when; import static org.mockito.Mockito.when;
@ -45,7 +45,7 @@ public class PolarisFeignCircuitBreakerTest {
@Test @Test
public void testBuilderNotNull() { public void testBuilderNotNull() {
Assertions.assertNotNull(builder); assertThat(builder).isNotNull();
} }
@Test @Test
@ -67,8 +67,8 @@ public class PolarisFeignCircuitBreakerTest {
MyService result = builder.target(target, fallback); MyService result = builder.target(target, fallback);
// Verify that the result is not null and the fallback factory is used // Verify that the result is not null and the fallback factory is used
Assertions.assertNotNull(result); assertThat(result).isNotNull();
Assertions.assertEquals("Fallback Hello", result.sayHello()); assertThat(result.sayHello()).isEqualTo("Fallback Hello");
} }
@Test @Test
@ -93,8 +93,8 @@ public class PolarisFeignCircuitBreakerTest {
MyService result = builder.target(target, fallbackFactory); MyService result = builder.target(target, fallbackFactory);
// Verify that the result is not null and the fallback factory is used // Verify that the result is not null and the fallback factory is used
Assertions.assertNotNull(result); assertThat(result).isNotNull();
Assertions.assertEquals("Fallback Hello", result.sayHello()); assertThat(result.sayHello()).isEqualTo("Fallback Hello");
} }
@Test @Test
@ -112,8 +112,7 @@ public class PolarisFeignCircuitBreakerTest {
MyService result = builder.target(target); MyService result = builder.target(target);
// Verify that the result is not null // Verify that the result is not null
Assertions.assertNotNull(result); assertThat(result).isNotNull();
// Additional verifications can be added here based on the implementation
} }
@Test @Test
@ -122,8 +121,7 @@ public class PolarisFeignCircuitBreakerTest {
Feign feign = builder.build(null); Feign feign = builder.build(null);
// Verify that the Feign instance is not null // Verify that the Feign instance is not null
Assertions.assertNotNull(feign); assertThat(feign).isNotNull();
// Additional verifications can be added here based on the implementation
} }
public interface MyService { public interface MyService {

@ -23,11 +23,13 @@ import java.util.HashMap;
import java.util.Map; import java.util.Map;
import com.tencent.polaris.api.pojo.CircuitBreakerStatus; import com.tencent.polaris.api.pojo.CircuitBreakerStatus;
import org.junit.jupiter.api.Assertions;
import org.junit.jupiter.api.Test; import org.junit.jupiter.api.Test;
import org.junit.jupiter.api.extension.ExtendWith; import org.junit.jupiter.api.extension.ExtendWith;
import org.mockito.junit.jupiter.MockitoExtension; import org.mockito.junit.jupiter.MockitoExtension;
import static org.assertj.core.api.Assertions.assertThat;
import static org.assertj.core.api.Assertions.assertThatNoException;
/** /**
* Tests for {@link PolarisCircuitBreakerHttpResponse}. * Tests for {@link PolarisCircuitBreakerHttpResponse}.
* *
@ -39,10 +41,10 @@ public class PolarisCircuitBreakerHttpResponseTest {
void testConstructorWithCodeOnly() throws IOException { void testConstructorWithCodeOnly() throws IOException {
PolarisCircuitBreakerHttpResponse response = new PolarisCircuitBreakerHttpResponse(200); PolarisCircuitBreakerHttpResponse response = new PolarisCircuitBreakerHttpResponse(200);
Assertions.assertEquals(200, response.getStatusCode().value()); assertThat(response.getStatusCode().value()).isEqualTo(200);
Assertions.assertNotNull(response.getHeaders()); assertThat(response.getHeaders()).isNotNull();
Assertions.assertTrue(response.getHeaders().isEmpty()); assertThat(response.getHeaders()).isEmpty();
Assertions.assertNull(response.getBody()); assertThat(response.getBody()).isNull();
} }
@Test @Test
@ -50,10 +52,10 @@ public class PolarisCircuitBreakerHttpResponseTest {
String body = "test body"; String body = "test body";
PolarisCircuitBreakerHttpResponse response = new PolarisCircuitBreakerHttpResponse(200, body); PolarisCircuitBreakerHttpResponse response = new PolarisCircuitBreakerHttpResponse(200, body);
Assertions.assertEquals(200, response.getStatusCode().value()); assertThat(response.getStatusCode().value()).isEqualTo(200);
Assertions.assertNotNull(response.getHeaders()); assertThat(response.getHeaders()).isNotNull();
Assertions.assertTrue(response.getHeaders().isEmpty()); assertThat(response.getHeaders()).isEmpty();
Assertions.assertNotNull(response.getBody()); assertThat(response.getBody()).isNotNull();
} }
@Test @Test
@ -65,12 +67,12 @@ public class PolarisCircuitBreakerHttpResponseTest {
PolarisCircuitBreakerHttpResponse response = new PolarisCircuitBreakerHttpResponse(200, headers, body); PolarisCircuitBreakerHttpResponse response = new PolarisCircuitBreakerHttpResponse(200, headers, body);
Assertions.assertEquals(200, response.getStatusCode().value()); assertThat(response.getStatusCode().value()).isEqualTo(200);
Assertions.assertNotNull(response.getHeaders()); assertThat(response.getHeaders()).isNotNull();
Assertions.assertEquals(2, response.getHeaders().size()); assertThat(response.getHeaders().size()).isEqualTo(2);
Assertions.assertTrue(response.getHeaders().containsKey("Content-Type")); assertThat(response.getHeaders()).containsKey("Content-Type");
Assertions.assertTrue(response.getHeaders().containsKey("Authorization")); assertThat(response.getHeaders()).containsKey("Authorization");
Assertions.assertNotNull(response.getBody()); assertThat(response.getBody()).isNotNull();
} }
@Test @Test
@ -81,43 +83,43 @@ public class PolarisCircuitBreakerHttpResponseTest {
PolarisCircuitBreakerHttpResponse response = new PolarisCircuitBreakerHttpResponse(fallbackInfo); PolarisCircuitBreakerHttpResponse response = new PolarisCircuitBreakerHttpResponse(fallbackInfo);
Assertions.assertEquals(200, response.getStatusCode().value()); assertThat(response.getStatusCode().value()).isEqualTo(200);
Assertions.assertEquals(fallbackInfo, response.getFallbackInfo()); assertThat(response.getFallbackInfo()).isEqualTo(fallbackInfo);
Assertions.assertNotNull(response.getHeaders()); assertThat(response.getHeaders()).isNotNull();
Assertions.assertTrue(response.getHeaders().containsKey("Content-Type")); assertThat(response.getHeaders()).containsKey("Content-Type");
Assertions.assertNotNull(response.getBody()); assertThat(response.getBody()).isNotNull();
} }
@Test @Test
void testGetStatusTextWithValidHttpStatus() { void testGetStatusTextWithValidHttpStatus() {
PolarisCircuitBreakerHttpResponse response = new PolarisCircuitBreakerHttpResponse(200); PolarisCircuitBreakerHttpResponse response = new PolarisCircuitBreakerHttpResponse(200);
Assertions.assertEquals("OK", response.getStatusText()); assertThat(response.getStatusText()).isEqualTo("OK");
} }
@Test @Test
void testGetStatusTextWithInvalidHttpStatus() { void testGetStatusTextWithInvalidHttpStatus() {
PolarisCircuitBreakerHttpResponse response = new PolarisCircuitBreakerHttpResponse(999); PolarisCircuitBreakerHttpResponse response = new PolarisCircuitBreakerHttpResponse(999);
Assertions.assertEquals("", response.getStatusText()); assertThat(response.getStatusText()).isEqualTo("");
} }
@Test @Test
void testClose() { void testClose() {
PolarisCircuitBreakerHttpResponse response = new PolarisCircuitBreakerHttpResponse(200, "test body"); PolarisCircuitBreakerHttpResponse response = new PolarisCircuitBreakerHttpResponse(200, "test body");
InputStream body = response.getBody(); InputStream body = response.getBody();
Assertions.assertNotNull(body); assertThat(body).isNotNull();
response.close(); response.close();
// Verify that reading from closed stream throws exception // Verify that reading from closed stream throws exception
Assertions.assertDoesNotThrow(() -> body.read()); assertThatNoException().isThrownBy(() -> body.read());
} }
@Test @Test
void testCloseWithNullBody() { void testCloseWithNullBody() {
PolarisCircuitBreakerHttpResponse response = new PolarisCircuitBreakerHttpResponse(200); PolarisCircuitBreakerHttpResponse response = new PolarisCircuitBreakerHttpResponse(200);
Assertions.assertNull(response.getBody()); assertThat(response.getBody()).isNull();
// Should not throw exception when closing null body // Should not throw exception when closing null body
Assertions.assertDoesNotThrow(() -> response.close()); assertThatNoException().isThrownBy(() -> response.close());
} }
} }

@ -33,7 +33,6 @@ import com.tencent.cloud.polaris.context.config.PolarisContextProperties;
import com.tencent.polaris.configuration.api.core.ConfigFileService; import com.tencent.polaris.configuration.api.core.ConfigFileService;
import com.tencent.polaris.configuration.api.core.ConfigKVFile; import com.tencent.polaris.configuration.api.core.ConfigKVFile;
import com.tencent.polaris.configuration.client.internal.RevisableConfigFileGroup; import com.tencent.polaris.configuration.client.internal.RevisableConfigFileGroup;
import org.junit.jupiter.api.Assertions;
import org.junit.jupiter.api.BeforeEach; import org.junit.jupiter.api.BeforeEach;
import org.junit.jupiter.api.Test; import org.junit.jupiter.api.Test;
import org.junit.jupiter.api.extension.ExtendWith; import org.junit.jupiter.api.extension.ExtendWith;
@ -354,21 +353,20 @@ public class PolarisConfigFileLocatorTest {
testProperties.setCheckAddress(checkAddress); testProperties.setCheckAddress(checkAddress);
testProperties.setShutdownIfConnectToConfigServerFailed(shutdownIfConnectToConfigServerFailed); testProperties.setShutdownIfConnectToConfigServerFailed(shutdownIfConnectToConfigServerFailed);
Assertions.assertEquals(enabled, testProperties.isEnabled()); assertThat(testProperties.isEnabled()).isEqualTo(enabled);
Assertions.assertEquals(address, testProperties.getAddress()); assertThat(testProperties.getAddress()).isEqualTo(address);
Assertions.assertEquals(port, testProperties.getPort()); assertThat(testProperties.getPort()).isEqualTo(port);
Assertions.assertEquals(token, testProperties.getToken()); assertThat(testProperties.getToken()).isEqualTo(token);
Assertions.assertEquals(autoRefresh, testProperties.isAutoRefresh()); assertThat(testProperties.isAutoRefresh()).isEqualTo(autoRefresh);
Assertions.assertEquals(refreshType, testProperties.getRefreshType()); assertThat(testProperties.getRefreshType()).isEqualTo(refreshType);
Assertions.assertEquals(groups, testProperties.getGroups()); assertThat(testProperties.getGroups()).isEqualTo(groups);
Assertions.assertEquals(preference, testProperties.isPreference()); assertThat(testProperties.isPreference()).isEqualTo(preference);
Assertions.assertEquals(dataSource, testProperties.getDataSource()); assertThat(testProperties.getDataSource()).isEqualTo(dataSource);
Assertions.assertEquals(localFileRootPath, testProperties.getLocalFileRootPath()); assertThat(testProperties.getLocalFileRootPath()).isEqualTo(localFileRootPath);
Assertions.assertEquals(internalEnabled, testProperties.isInternalEnabled()); assertThat(testProperties.isInternalEnabled()).isEqualTo(internalEnabled);
Assertions.assertEquals(checkAddress, testProperties.isCheckAddress()); assertThat(testProperties.isCheckAddress()).isEqualTo(checkAddress);
Assertions.assertEquals(shutdownIfConnectToConfigServerFailed, testProperties.isShutdownIfConnectToConfigServerFailed()); assertThat(testProperties.isShutdownIfConnectToConfigServerFailed()).isEqualTo(shutdownIfConnectToConfigServerFailed);
assertThat(testProperties.toString()).isNotNull();
Assertions.assertNotNull(testProperties.toString());
} }
private void clearCompositePropertySourceCache() { private void clearCompositePropertySourceCache() {

@ -26,7 +26,6 @@ import com.tencent.polaris.api.config.consumer.ServiceRouterConfig;
import com.tencent.polaris.factory.ConfigAPIFactory; import com.tencent.polaris.factory.ConfigAPIFactory;
import com.tencent.polaris.factory.config.ConfigurationImpl; import com.tencent.polaris.factory.config.ConfigurationImpl;
import com.tencent.polaris.plugins.router.nearby.NearbyRouterConfig; import com.tencent.polaris.plugins.router.nearby.NearbyRouterConfig;
import org.junit.jupiter.api.Assertions;
import org.junit.jupiter.api.Test; import org.junit.jupiter.api.Test;
import org.springframework.boot.autoconfigure.AutoConfigurations; import org.springframework.boot.autoconfigure.AutoConfigurations;
@ -60,7 +59,7 @@ public class RouterBootstrapAutoConfigurationTest {
routerConfigModifier.modify((ConfigurationImpl) configuration); routerConfigModifier.modify((ConfigurationImpl) configuration);
NearbyRouterConfig nearbyRouterConfig = configuration.getConsumer().getServiceRouter().getPluginConfig( NearbyRouterConfig nearbyRouterConfig = configuration.getConsumer().getServiceRouter().getPluginConfig(
ServiceRouterConfig.DEFAULT_ROUTER_NEARBY, NearbyRouterConfig.class); ServiceRouterConfig.DEFAULT_ROUTER_NEARBY, NearbyRouterConfig.class);
Assertions.assertEquals("CAMPUS", nearbyRouterConfig.getMatchLevel().name()); assertThat(nearbyRouterConfig.getMatchLevel().name()).isEqualTo("CAMPUS");
}); });
} }
} }

@ -5,7 +5,7 @@
<parent> <parent>
<groupId>org.springframework.cloud</groupId> <groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-dependencies-parent</artifactId> <artifactId>spring-cloud-dependencies-parent</artifactId>
<version>4.1.5</version> <version>4.1.6</version>
<relativePath/> <relativePath/>
</parent> </parent>
<modelVersion>4.0.0</modelVersion> <modelVersion>4.0.0</modelVersion>
@ -71,10 +71,10 @@
<properties> <properties>
<!-- Project revision --> <!-- Project revision -->
<revision>2.0.3.0-2023.0.5-SNAPSHOT</revision> <revision>2.1.0.0-2023.0.6-SNAPSHOT</revision>
<!-- Polaris SDK version --> <!-- Polaris SDK version -->
<polaris.version>2.0.3.0-SNAPSHOT</polaris.version> <polaris.version>2.1.0.0-SNAPSHOT</polaris.version>
<!-- Dependencies --> <!-- Dependencies -->
<springdoc.version>2.2.0</springdoc.version> <springdoc.version>2.2.0</springdoc.version>

@ -17,7 +17,6 @@
package com.tencent.cloud.plugin.gateway; package com.tencent.cloud.plugin.gateway;
import org.junit.jupiter.api.Assertions;
import org.junit.jupiter.api.BeforeEach; import org.junit.jupiter.api.BeforeEach;
import org.junit.jupiter.api.Test; import org.junit.jupiter.api.Test;
import org.mockito.Mock; import org.mockito.Mock;
@ -28,6 +27,7 @@ import org.springframework.cloud.gateway.filter.ReactiveLoadBalancerClientFilter
import org.springframework.cloud.loadbalancer.support.LoadBalancerClientFactory; import org.springframework.cloud.loadbalancer.support.LoadBalancerClientFactory;
import org.springframework.context.ApplicationContext; import org.springframework.context.ApplicationContext;
import static org.assertj.core.api.Assertions.assertThat;
import static org.mockito.Mockito.mock; import static org.mockito.Mockito.mock;
import static org.mockito.Mockito.when; import static org.mockito.Mockito.when;
@ -62,7 +62,7 @@ public class PolarisReactiveLoadBalancerClientFilterBeanPostProcessorTest {
@Test @Test
void testGetOrder() { void testGetOrder() {
int order = processor.getOrder(); int order = processor.getOrder();
Assertions.assertEquals(PolarisReactiveLoadBalancerClientFilterBeanPostProcessor.ORDER, order); assertThat(order).isEqualTo(PolarisReactiveLoadBalancerClientFilterBeanPostProcessor.ORDER);
} }
@Test @Test
@ -75,7 +75,7 @@ public class PolarisReactiveLoadBalancerClientFilterBeanPostProcessorTest {
Object result = processor.postProcessAfterInitialization(originalInterceptor, beanName); Object result = processor.postProcessAfterInitialization(originalInterceptor, beanName);
// Assert // Assert
Assertions.assertInstanceOf(PolarisReactiveLoadBalancerClientFilter.class, result); assertThat(result).isInstanceOf(PolarisReactiveLoadBalancerClientFilter.class);
} }
@Test @Test
@ -88,7 +88,7 @@ public class PolarisReactiveLoadBalancerClientFilterBeanPostProcessorTest {
Object result = processor.postProcessAfterInitialization(originalBean, beanName); Object result = processor.postProcessAfterInitialization(originalBean, beanName);
// Assert // Assert
Assertions.assertSame(originalBean, result); assertThat(result).isSameAs(originalBean);
} }
} }

@ -20,7 +20,6 @@ package com.tencent.cloud.plugin.gateway;
import com.tencent.cloud.common.constant.MetadataConstant; import com.tencent.cloud.common.constant.MetadataConstant;
import com.tencent.cloud.common.metadata.MetadataContext; import com.tencent.cloud.common.metadata.MetadataContext;
import com.tencent.cloud.common.metadata.MetadataContextHolder; import com.tencent.cloud.common.metadata.MetadataContextHolder;
import org.junit.jupiter.api.Assertions;
import org.junit.jupiter.api.BeforeEach; import org.junit.jupiter.api.BeforeEach;
import org.junit.jupiter.api.Test; import org.junit.jupiter.api.Test;
import org.junit.jupiter.api.extension.ExtendWith; import org.junit.jupiter.api.extension.ExtendWith;
@ -44,6 +43,7 @@ import static org.mockito.Mockito.when;
@ExtendWith(MockitoExtension.class) @ExtendWith(MockitoExtension.class)
class PolarisReactiveLoadBalancerClientFilterTest { class PolarisReactiveLoadBalancerClientFilterTest {
private final MetadataContext testContext = new MetadataContext();
@Mock @Mock
private LoadBalancerClientFactory clientFactory; private LoadBalancerClientFactory clientFactory;
@Mock @Mock
@ -54,9 +54,7 @@ class PolarisReactiveLoadBalancerClientFilterTest {
private ServerWebExchange exchange; private ServerWebExchange exchange;
@Mock @Mock
private GatewayFilterChain chain; private GatewayFilterChain chain;
private PolarisReactiveLoadBalancerClientFilter polarisFilter; private PolarisReactiveLoadBalancerClientFilter polarisFilter;
private final MetadataContext testContext = new MetadataContext();
@BeforeEach @BeforeEach
void setUp() { void setUp() {
@ -82,11 +80,11 @@ class PolarisReactiveLoadBalancerClientFilterTest {
when(originalFilter.filter(exchange, chain)) when(originalFilter.filter(exchange, chain))
.thenReturn(Mono.empty()); .thenReturn(Mono.empty());
MetadataContext before = MetadataContextHolder.get(); MetadataContext before = MetadataContextHolder.get();
Assertions.assertNotEquals(testContext, before); assertThat(before).isNotEqualTo(testContext);
// Act // Act
polarisFilter.filter(exchange, chain); polarisFilter.filter(exchange, chain);
MetadataContext after = MetadataContextHolder.get(); MetadataContext after = MetadataContextHolder.get();
Assertions.assertEquals(testContext, after); assertThat(after).isEqualTo(testContext);
} }
@Test @Test
@ -102,6 +100,6 @@ class PolarisReactiveLoadBalancerClientFilterTest {
MetadataContext after = MetadataContextHolder.get(); MetadataContext after = MetadataContextHolder.get();
// Assert // Assert
Assertions.assertEquals(before, after); assertThat(after).isEqualTo(before);
} }
} }

@ -24,7 +24,6 @@ import java.util.Map;
import com.tencent.cloud.polaris.discovery.PolarisDiscoveryClient; import com.tencent.cloud.polaris.discovery.PolarisDiscoveryClient;
import com.tencent.cloud.polaris.discovery.reactive.PolarisReactiveDiscoveryClient; import com.tencent.cloud.polaris.discovery.reactive.PolarisReactiveDiscoveryClient;
import org.junit.jupiter.api.Assertions;
import org.junit.jupiter.api.BeforeEach; import org.junit.jupiter.api.BeforeEach;
import org.junit.jupiter.api.Test; import org.junit.jupiter.api.Test;
import org.mockito.Mockito; import org.mockito.Mockito;
@ -127,7 +126,8 @@ class ContextGatewayPropertiesManagerTest {
ContextGatewayFilter filter = new ContextGatewayFilter(manager, null); ContextGatewayFilter filter = new ContextGatewayFilter(manager, null);
MockServerHttpRequest request = MockServerHttpRequest.post("http://localhost/context/testNS/testSvc/api/exact").build(); MockServerHttpRequest request = MockServerHttpRequest.post("http://localhost/context/testNS/testSvc/api/exact")
.build();
String[] apis = filter.rebuildMsApi(request, group, request.getPath().value()); String[] apis = filter.rebuildMsApi(request, group, request.getPath().value());
// Test path matching // Test path matching
@ -223,7 +223,6 @@ class ContextGatewayPropertiesManagerTest {
"POST|/headerNS/svcFromHeader/api/test", "POST|/headerNS/svcFromHeader/api/test",
"/api/test"); "/api/test");
} }
private void testPositionCombination(ApiType apiType, Position namespacePos, Position servicePos, private void testPositionCombination(ApiType apiType, Position namespacePos, Position servicePos,
@ -287,19 +286,19 @@ class ContextGatewayPropertiesManagerTest {
void testGroupContext() { void testGroupContext() {
GroupContext group1 = new GroupContext(); GroupContext group1 = new GroupContext();
group1.setComment("testComment"); group1.setComment("testComment");
Assertions.assertEquals("testComment", group1.getComment()); assertThat(group1.getComment()).isEqualTo("testComment");
GroupContext.ContextPredicate contextPredicate = new GroupContext.ContextPredicate(); GroupContext.ContextPredicate contextPredicate = new GroupContext.ContextPredicate();
contextPredicate.setContext("testContext"); contextPredicate.setContext("testContext");
Assertions.assertEquals("testContext", contextPredicate.getContext()); assertThat(contextPredicate.getContext()).isEqualTo("testContext");
GroupContext.ContextRoute contextRoute = new GroupContext.ContextRoute(); GroupContext.ContextRoute contextRoute = new GroupContext.ContextRoute();
contextRoute.setPathMapping("testPathMapping"); contextRoute.setPathMapping("testPathMapping");
Assertions.assertEquals("testPathMapping", contextRoute.getPathMapping()); assertThat(contextRoute.getPathMapping()).isEqualTo("testPathMapping");
contextRoute.setHost("testHost"); contextRoute.setHost("testHost");
Assertions.assertEquals("testHost", contextRoute.getHost()); assertThat(contextRoute.getHost()).isEqualTo("testHost");
contextRoute.setMetadata(Collections.singletonMap("testKey", "testValue")); contextRoute.setMetadata(Collections.singletonMap("testKey", "testValue"));
Assertions.assertEquals(1, contextRoute.getMetadata().size()); assertThat(contextRoute.getMetadata().size()).isEqualTo(1);
} }
} }

@ -17,7 +17,6 @@
package com.tencent.cloud.plugin.gateway.context; package com.tencent.cloud.plugin.gateway.context;
import org.junit.jupiter.api.Assertions;
import org.junit.jupiter.api.Test; import org.junit.jupiter.api.Test;
import org.springframework.boot.test.context.runner.ApplicationContextRunner; import org.springframework.boot.test.context.runner.ApplicationContextRunner;
@ -48,7 +47,7 @@ class ContextRoutePredicateFactoryTest {
// Act // Act
ContextRoutePredicateFactory.Config config = factory.newConfig(); ContextRoutePredicateFactory.Config config = factory.newConfig();
config.setGroup("g1"); config.setGroup("g1");
Assertions.assertEquals("g1", config.getGroup()); assertThat(config.getGroup()).isEqualTo("g1");
GatewayPredicate gatewayPredicate = (GatewayPredicate) factory.apply(config); GatewayPredicate gatewayPredicate = (GatewayPredicate) factory.apply(config);
gatewayPredicate.toString(); gatewayPredicate.toString();
@ -57,8 +56,8 @@ class ContextRoutePredicateFactoryTest {
MockServerHttpRequest.get("/test").build()); MockServerHttpRequest.get("/test").build());
exchange.getAttributes().put(GATEWAY_PREDICATE_PATH_CONTAINER_ATTR, "mock"); exchange.getAttributes().put(GATEWAY_PREDICATE_PATH_CONTAINER_ATTR, "mock");
Assertions.assertTrue(gatewayPredicate.test(exchange)); assertThat(gatewayPredicate.test(exchange)).isTrue();
Assertions.assertEquals(config, gatewayPredicate.getConfig()); assertThat(gatewayPredicate.getConfig()).isEqualTo(config);
}); });
} }

@ -18,7 +18,6 @@
package com.tencent.cloud.rpc.enhancement.beanprocessor; package com.tencent.cloud.rpc.enhancement.beanprocessor;
import com.tencent.cloud.rpc.enhancement.plugin.EnhancedPluginRunner; import com.tencent.cloud.rpc.enhancement.plugin.EnhancedPluginRunner;
import org.junit.jupiter.api.Assertions;
import org.junit.jupiter.api.BeforeEach; import org.junit.jupiter.api.BeforeEach;
import org.junit.jupiter.api.Test; import org.junit.jupiter.api.Test;
import org.mockito.Mock; import org.mockito.Mock;
@ -28,6 +27,7 @@ import org.springframework.beans.factory.BeanFactory;
import org.springframework.cloud.client.loadbalancer.LoadBalancerClient; import org.springframework.cloud.client.loadbalancer.LoadBalancerClient;
import org.springframework.cloud.client.loadbalancer.LoadBalancerRequestFactory; import org.springframework.cloud.client.loadbalancer.LoadBalancerRequestFactory;
import static org.assertj.core.api.Assertions.assertThat;
import static org.mockito.Mockito.when; import static org.mockito.Mockito.when;
/** /**
@ -73,7 +73,7 @@ class BlockingLoadBalancerClientBeanPostProcessorTest {
Object result = processor.postProcessBeforeInitialization(originalBean, beanName); Object result = processor.postProcessBeforeInitialization(originalBean, beanName);
// Assert // Assert
Assertions.assertSame(originalBean, result); assertThat(result).isSameAs(originalBean);
} }
@Test @Test
@ -82,6 +82,6 @@ class BlockingLoadBalancerClientBeanPostProcessorTest {
int order = processor.getOrder(); int order = processor.getOrder();
// Assert // Assert
Assertions.assertEquals(BlockingLoadBalancerClientBeanPostProcessor.ORDER, order); assertThat(order).isEqualTo(BlockingLoadBalancerClientBeanPostProcessor.ORDER);
} }
} }

@ -42,7 +42,6 @@ import com.tencent.polaris.client.api.SDKContext;
import org.jetbrains.annotations.NotNull; import org.jetbrains.annotations.NotNull;
import org.jetbrains.annotations.Nullable; import org.jetbrains.annotations.Nullable;
import org.junit.jupiter.api.AfterAll; import org.junit.jupiter.api.AfterAll;
import org.junit.jupiter.api.Assertions;
import org.junit.jupiter.api.BeforeAll; import org.junit.jupiter.api.BeforeAll;
import org.junit.jupiter.api.BeforeEach; import org.junit.jupiter.api.BeforeEach;
import org.junit.jupiter.api.Test; import org.junit.jupiter.api.Test;
@ -177,9 +176,8 @@ public class EnhancedGatewayGlobalFilterTest {
EnhancedGatewayGlobalFilter filter = new EnhancedGatewayGlobalFilter(pluginRunner); EnhancedGatewayGlobalFilter filter = new EnhancedGatewayGlobalFilter(pluginRunner);
// Act & Assert // Act & Assert
Assertions.assertThrows(CallAbortedException.class, () -> { assertThatThrownBy(() -> filter.filter(exchange, chain))
filter.filter(exchange, chain); .isExactlyInstanceOf(CallAbortedException.class);
});
} }
@Test @Test

@ -36,7 +36,6 @@ import com.tencent.polaris.api.pojo.CircuitBreakerStatus;
import com.tencent.polaris.circuitbreak.client.exception.CallAbortedException; import com.tencent.polaris.circuitbreak.client.exception.CallAbortedException;
import com.tencent.polaris.client.api.SDKContext; import com.tencent.polaris.client.api.SDKContext;
import org.junit.jupiter.api.AfterAll; import org.junit.jupiter.api.AfterAll;
import org.junit.jupiter.api.Assertions;
import org.junit.jupiter.api.BeforeAll; import org.junit.jupiter.api.BeforeAll;
import org.junit.jupiter.api.BeforeEach; import org.junit.jupiter.api.BeforeEach;
import org.junit.jupiter.api.Test; import org.junit.jupiter.api.Test;
@ -170,7 +169,7 @@ public class EnhancedWebClientExchangeFilterFunctionTest {
// Assert // Assert
StepVerifier.create(responseMono) StepVerifier.create(responseMono)
.expectNextMatches(response -> { .expectNextMatches(response -> {
Assertions.assertEquals(HttpStatus.SERVICE_UNAVAILABLE, response.statusCode()); assertThat(response.statusCode()).isEqualTo(HttpStatus.SERVICE_UNAVAILABLE);
assertThat(response.headers().asHttpHeaders().containsKey("header-key")).isTrue(); assertThat(response.headers().asHttpHeaders().containsKey("header-key")).isTrue();
return true; return true;
}) })

@ -20,13 +20,14 @@ package com.tencent.cloud.rpc.enhancement.plugin;
import java.util.ArrayList; import java.util.ArrayList;
import java.util.List; import java.util.List;
import org.junit.jupiter.api.Assertions;
import org.junit.jupiter.api.Test; import org.junit.jupiter.api.Test;
import org.junit.jupiter.api.extension.ExtendWith; import org.junit.jupiter.api.extension.ExtendWith;
import org.mockito.junit.jupiter.MockitoExtension; import org.mockito.junit.jupiter.MockitoExtension;
import org.springframework.cloud.client.serviceregistry.Registration; import org.springframework.cloud.client.serviceregistry.Registration;
import static org.assertj.core.api.Assertions.assertThat;
/** /**
* Tests for {@link DefaultEnhancedPluginRunner}. * Tests for {@link DefaultEnhancedPluginRunner}.
* *
@ -48,7 +49,7 @@ public class DefaultEnhancedPluginRunnerTest {
Registration result = DefaultEnhancedPluginRunner.getPolarisRegistration(registrations); Registration result = DefaultEnhancedPluginRunner.getPolarisRegistration(registrations);
// Assert // Assert
Assertions.assertSame(normalReg, result); assertThat(result).isSameAs(normalReg);
} }
// Helper method to create mock Registration objects // Helper method to create mock Registration objects

Loading…
Cancel
Save