[oss gateway util] add go support for hcs-mgw, bump util v0.0.4, bump…

… tea v0.0.19
aliyun · Aug 19, 2024 · 8f65c85 · 8f65c85
1 parent 309c92e
commit 8f65c85
Show file tree

Hide file tree

Showing 6 changed files with 3,255 additions and 9 deletions.
diff --git a/alibabacloud-gateway-oss/Teafile b/alibabacloud-gateway-oss/Teafile
@@ -1,7 +1,7 @@
 {
   "scope": "alibabacloud",
   "name": "GatewayOSS",
-  "version": "0.0.18",
+  "version": "0.0.19",
   "main": "./main.tea",
   "maintainers": [
     {
@@ -26,9 +26,9 @@
   },
   "releases": {
     "ts": "@alicloud/gateway-oss:^0.0.8",
-    "go": "github.com/alibabacloud-go/alibabacloud-gateway-oss/client:v0.0.11",
+    "go": "github.com/alibabacloud-go/alibabacloud-gateway-oss/client:v0.0.12",
     "java": "com.aliyun:alibabacloud-gateway-oss:0.0.12",
-    "python": "alibabacloud_gateway_oss:0.0.9",
+    "python": "alibabacloud_gateway_oss:0.0.10",
     "python2": "alibabacloud_gateway_oss_py2:0.0.9",
     "csharp": "AlibabaCloud.GatewayOss:0.0.10",
     "php": "alibabacloud/gateway-oss:^0.0.9"

diff --git a/alibabacloud-gateway-oss/golang/client/client.go b/alibabacloud-gateway-oss/golang/client/client.go
@@ -140,7 +140,7 @@ func (client *Client) ModifyRequest(context *spi.InterceptorContext, attributeMa
 
 	}
 
-	host, _err := client.GetHost(config.EndpointType, bucketName, config.Endpoint)
+	host, _err := client.GetHost(config.EndpointType, bucketName, config.Endpoint, context)
 	if _err != nil {
 		return _err
 	}
@@ -389,7 +389,12 @@ func (client *Client) GetEndpoint(regionId *string, network *string, endpoint *s
 	return _result, _err
 }
 
-func (client *Client) GetHost(endpointType *string, bucketName *string, endpoint *string) (_result *string, _err error) {
+func (client *Client) GetHost(endpointType *string, bucketName *string, endpoint *string, context *spi.InterceptorContext) (_result *string, _err error) {
+	if tea.BoolValue(string_.Contains(endpoint, tea.String(".mgw.aliyuncs.com"))) && !tea.BoolValue(util.IsUnset(context.Request.HostMap["userid"])) {
+		_result = tea.String(tea.StringValue(context.Request.HostMap["userid"]) + "." + tea.StringValue(endpoint))
+		return _result, _err
+	}
+
 	if tea.BoolValue(util.Empty(bucketName)) {
 		_result = endpoint
 		return _result, _err

diff --git a/alibabacloud-gateway-oss/golang/go.mod b/alibabacloud-gateway-oss/golang/go.mod
@@ -3,7 +3,7 @@ module github.com/alibabacloud-go/alibabacloud-gateway-oss
 go 1.14
 
 require (
-	github.com/alibabacloud-go/alibabacloud-gateway-oss-util v0.0.3
+	github.com/alibabacloud-go/alibabacloud-gateway-oss-util v0.0.4
 	github.com/alibabacloud-go/alibabacloud-gateway-spi v0.0.4
 	github.com/alibabacloud-go/darabonba-array v0.1.0
 	github.com/alibabacloud-go/darabonba-encode-util v0.0.2

diff --git a/alibabacloud-gateway-oss/util/Teafile b/alibabacloud-gateway-oss/util/Teafile
@@ -1,7 +1,7 @@
 {
   "scope": "alibabacloud",
   "name": "GatewayOSS_Util",
-  "version": "0.0.4",
+  "version": "0.0.5",
   "main": "./main.tea",
   "maintainers": [
     {
@@ -12,8 +12,8 @@
   "libraries": {
   },
   "releases": {
-    "go": "github.com/alibabacloud-go/alibabacloud-gateway-oss-util/client:v0.0.3",
-    "java": "com.aliyun:alibabacloud-gateway-oss-util:0.0.3"
+    "go": "github.com/alibabacloud-go/alibabacloud-gateway-oss-util/client:v0.0.4",
+    "java": "com.aliyun:alibabacloud-gateway-oss-util:0.0.4"
   },
   "csharp": {
     "namespace": "AlibabaCloud.GatewayOss_Util",

diff --git a/alibabacloud-gateway-oss/util/golang/client/client.go b/alibabacloud-gateway-oss/util/golang/client/client.go
@@ -16,6 +16,7 @@ import (
 var typeRegistry = make(map[string]reflect.Type)
 
 func init() {
+	// for oss
 	typeRegistry["CompleteMultipartUpload"] = reflect.TypeOf(CompleteMultipartUploadResponseBody{})
 	typeRegistry["CopyObject"] = reflect.TypeOf(CopyObjectResponseBody{})
 	typeRegistry["CreateAccessPoint"] = reflect.TypeOf(CreateAccessPointResponseBody{})
@@ -85,6 +86,21 @@ func init() {
 	typeRegistry["ListStyle"] = reflect.TypeOf(ListStyleResponseBody{})
 	typeRegistry["PutLiveChannel"] = reflect.TypeOf(PutLiveChannelResponseBody{})
 	typeRegistry["UploadPartCopy"] = reflect.TypeOf(UploadPartCopyResponseBody{})
+
+	// for hcs-mgw
+	typeRegistry["GetAddress"] = reflect.TypeOf(GetAddressResponseBody{})
+	typeRegistry["GetAgent"] = reflect.TypeOf(GetAgentResponseBody{})
+	typeRegistry["GetAgentStatus"] = reflect.TypeOf(GetAgentStatusResponseBody{})
+	typeRegistry["GetJob"] = reflect.TypeOf(GetJobResponseBody{})
+	typeRegistry["GetJobResult"] = reflect.TypeOf(GetJobResultResponseBody{})
+	typeRegistry["GetReport"] = reflect.TypeOf(GetReportResponseBody{})
+	typeRegistry["GetTunnel"] = reflect.TypeOf(GetTunnelResponseBody{})
+	typeRegistry["ListAddress"] = reflect.TypeOf(ListAddressResponseBody{})
+	typeRegistry["ListAgent"] = reflect.TypeOf(ListAgentResponseBody{})
+	typeRegistry["ListJobResponse"] = reflect.TypeOf(ListJobResponseBody{})
+	typeRegistry["ListJobHistory"] = reflect.TypeOf(ListJobHistoryResponseBody{})
+	typeRegistry["ListTunnel"] = reflect.TypeOf(ListTunnelResponseBody{})
+	typeRegistry["VerifyAddress"] = reflect.TypeOf(VerifyAddressResponseBody{})
 }
 
 func ParseXml(bodyStr *string, apiName *string) (_result interface{}, _err error) {