feat: rpc add accept header

Author: kevinten10

capa-spi-aws-config/src/test/java/group/rxcloud/capa/spi/aws/config/AwsCapaConfigStoreTest.java

@@ -66,7 +66,6 @@ public void setUp() {
         Whitebox.setInternalState(ins, "appConfigAsyncClient", client);
         PowerMockito.when(client.getConfiguration(ArgumentMatchers.any(GetConfigurationRequest.class))).thenReturn(mockGetConfigurationRespV1());
 
-
         SerializerProcessor serializerProcessor = PowerMockito.mock(SerializerProcessor.class);
         Whitebox.setInternalState(ins, "serializerProcessor", serializerProcessor);
         User user = new User();

capa-spi-aws-mesh/src/test/java/group/rxcloud/capa/spi/aws/mesh/env/AwsRpcEnvironmentTest.java

@@ -37,6 +37,6 @@ public void testGetSerializer_SuccessWhenDefault() {
     @Test
     public void testGetNamespace_SuccessWhenDefault() {
         String namespace = AwsCapaRpcProperties.AppMeshProperties.Settings.getRpcAwsAppMeshNamespace();
-        Assertions.assertNotNull(namespace);
+        Assertions.assertNull(namespace);
     }
 }

capa-spi-aws-mesh/src/test/java/group/rxcloud/capa/spi/aws/mesh/http/AwsCapaHttpTest.java

@@ -50,18 +50,21 @@ public void setUp() {
     @Test
     public void testInvokeSpiApi_Success() {
         AwsSpiOptionsLoader awsSpiOptionsLoader = new AwsSpiOptionsLoader();
-        AwsRpcServiceOptions awsRpcServiceOptions = awsSpiOptionsLoader.loadRpcServiceOptions("appId");
 
-        CompletableFuture<HttpResponse<String>> responseCompletableFuture = awsCapaHttp.invokeSpiApi("appId",
-                "method",
-                "requestData",
-                "POST",
-                new HashMap<>(),
-                new HashMap<>(),
-                TypeRef.STRING,
-                awsRpcServiceOptions);
+        Assertions.assertThrows(NullPointerException.class, () -> {
+            AwsRpcServiceOptions awsRpcServiceOptions = awsSpiOptionsLoader.loadRpcServiceOptions("appId");
 
-        responseCompletableFuture.cancel(true);
+            CompletableFuture<HttpResponse<String>> responseCompletableFuture = awsCapaHttp.invokeSpiApi("appId",
+                    "method",
+                    "requestData",
+                    "POST",
+                    new HashMap<>(),
+                    new HashMap<>(),
+                    TypeRef.STRING,
+                    awsRpcServiceOptions);
+
+            responseCompletableFuture.cancel(true);
+        });
     }
 
     @Test

capa-spi-aws-mesh/src/test/java/group/rxcloud/capa/spi/aws/mesh/http/config/AwsSpiOptionsLoaderTest.java

@@ -35,7 +35,7 @@ public void testLoadRpcServiceOptions_Success() {
 
         Assertions.assertEquals("appId", awsToAwsServiceOptions.getServiceId());
         Assertions.assertEquals(8080, awsToAwsServiceOptions.getServicePort());
-        Assertions.assertNotNull(awsToAwsServiceOptions.getNamespace());
         Assertions.assertNotNull(awsToAwsServiceOptions.getServiceEnv());
+        Assertions.assertNull(awsToAwsServiceOptions.getNamespace());
     }
 }