Skip to content

Commit 44d8915

Browse files
chore:delete rds host
1 parent a337061 commit 44d8915

File tree

2 files changed

+6
-6
lines changed

2 files changed

+6
-6
lines changed

volcengine-java-sdk-core/src/main/java/com/volcengine/feature/rds/auth/ConnectUtils.java

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -70,8 +70,6 @@ public static String buildAuthToken(ApiClient apiClient, String dbUser, String i
7070

7171
RequestInterceptorContext reqCtx = context.getRequestContext();
7272
reqCtx.setPresigned(true);
73-
reqCtx.setSchema(schema);
74-
reqCtx.setHost(endpoint);
7573
reqCtx.setMethod("GET");
7674
reqCtx.setServiceInfo(new ServiceInfo(SERVICE_NAME, "GET"));
7775
reqCtx.setHeaderParams(new HashMap<>());
@@ -82,6 +80,7 @@ public static String buildAuthToken(ApiClient apiClient, String dbUser, String i
8280
queryParams.add(new Pair("X-Expires", String.valueOf(expires)));
8381
queryParams.add(new Pair("DBUser", dbUser));
8482
queryParams.add(new Pair("InstanceId", instanceId));
83+
queryParams.add(new Pair("X-Host", schema + "://" + endpoint));
8584
reqCtx.setQueryParams(queryParams);
8685

8786
// Execute sign interceptor for presigning

volcengine-java-sdk-core/src/main/java/com/volcengine/interceptor/SignRequestInterceptor.java

Lines changed: 5 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -28,7 +28,7 @@ public String name() {
2828
@Override
2929
public InterceptorContext intercept(InterceptorContext context) throws ApiException {
3030
String path = context.getRequestContext().getPath();
31-
String method=context.getRequestContext().getMethod();
31+
String method = context.getRequestContext().getMethod();
3232
Map<String, String> headerParams = context.getRequestContext().getHeaderParams();
3333
List<Pair> queryParams = context.getRequestContext().getQueryParams();
3434
ServiceInfo serviceInfo = context.getRequestContext().getServiceInfo();
@@ -75,8 +75,7 @@ public InterceptorContext intercept(InterceptorContext context) throws ApiExcept
7575
String host = context.getRequestContext().getHost();
7676
try {
7777
Map<String, String> presignedParams = volcengineSign.presign(queryParamsMap, host);
78-
String presignedUrl = buildPresignedUrl(
79-
context.getRequestContext().getSchema(), host, presignedParams);
78+
String presignedUrl = buildPresignedUrl(context.getRequestContext().getSchema(), host, presignedParams);
8079
context.getRequestContext().setPresignedUrl(presignedUrl);
8180
} catch (Exception e) {
8281
throw new ApiException(e);
@@ -125,7 +124,9 @@ public InterceptorContext intercept(InterceptorContext context) throws ApiExcept
125124

126125
private static String buildPresignedUrl(String scheme, String host, Map<String, String> presignedParams) {
127126
StringBuilder url = new StringBuilder();
128-
url.append(scheme).append("://").append(host).append("?");
127+
if (StringUtils.isNotEmpty(scheme) && StringUtils.isNotEmpty(host)) {
128+
url.append(scheme).append("://").append(host).append("?");
129+
}
129130

130131
List<String> keys = new ArrayList<>(presignedParams.keySet());
131132
Collections.sort(keys);

0 commit comments

Comments
 (0)