improve createUser

integration/api_test.go

@@ -61,6 +61,7 @@ func Test_DeleteClusterWithROArequestWithJSONWithDelete(t *testing.T) {
 	assert.Contains(t, err.Error(), "ErrorClusterNotFound")
 }
 
+// 创建安全组
 func Test_CreateSecurityGroupWithRPCrequestWithJSONWithNestingparametersWithPOST(t *testing.T) {
 	client, err := ecs.NewClientWithAccessKey(os.Getenv("REGION_ID"), os.Getenv("ACCESS_KEY_ID"), os.Getenv("ACCESS_KEY_SECRET"))
 	assert.Nil(t, err)
@@ -79,6 +80,7 @@ func Test_CreateSecurityGroupWithRPCrequestWithJSONWithNestingparametersWithPOST
 	securityGroupId = response.SecurityGroupId
 }
 
+// 查询安全组
 func Test_ECS_DescribeSecurityGroupsWithRPCrequestWithJSONWithNestingparametersWithGET(t *testing.T) {
 	client, err := ecs.NewClientWithAccessKey(os.Getenv("REGION_ID"), os.Getenv("ACCESS_KEY_ID"), os.Getenv("ACCESS_KEY_SECRET"))
 	assert.Nil(t, err)
@@ -99,6 +101,7 @@ func Test_ECS_DescribeSecurityGroupsWithRPCrequestWithJSONWithNestingparametersW
 	flag = false
 }
 
+// 删除安全组
 func Test_ECS_DeleteSecurityGroupWithRPCrequestWithJSONWithPOST(t *testing.T) {
 	client, err := ecs.NewClientWithAccessKey(os.Getenv("REGION_ID"), os.Getenv("ACCESS_KEY_ID"), os.Getenv("ACCESS_KEY_SECRET"))
 	assert.Nil(t, err)
@@ -112,6 +115,7 @@ func Test_ECS_DeleteSecurityGroupWithRPCrequestWithJSONWithPOST(t *testing.T) {
 	securityGroupId = ""
 }
 
+// 查询 RDS
 func Test_RDS_DescribeDBInstancesWithRPCrequest(t *testing.T) {
 	client, err := rds.NewClientWithAccessKey(os.Getenv("REGION_ID"), os.Getenv("ACCESS_KEY_ID"), os.Getenv("ACCESS_KEY_SECRET"))
 	assert.Nil(t, err)
@@ -123,6 +127,7 @@ func Test_RDS_DescribeDBInstancesWithRPCrequest(t *testing.T) {
 	assert.NotNil(t, response)
 }
 
+// 查询 CDN 域名
 func Test_CDN_DescribeCdnDomainDetailWithRPCrequest(t *testing.T) {
 	client, err := cdn.NewClientWithAccessKey(os.Getenv("REGION_ID"), os.Getenv("ACCESS_KEY_ID"), os.Getenv("ACCESS_KEY_SECRET"))
 	assert.Nil(t, err)
@@ -134,6 +139,7 @@ func Test_CDN_DescribeCdnDomainDetailWithRPCrequest(t *testing.T) {
 	assert.Equal(t, 36, len(response.RequestId))
 }
 
+// 查询角色列表
 func Test_RAM_ListRolesWithRPCrequest(t *testing.T) {
 	client, err := ram.NewClientWithAccessKey(os.Getenv("REGION_ID"), os.Getenv("ACCESS_KEY_ID"), os.Getenv("ACCESS_KEY_SECRET"))
 	assert.Nil(t, err)
@@ -145,6 +151,7 @@ func Test_RAM_ListRolesWithRPCrequest(t *testing.T) {
 	assert.Equal(t, 36, len(response.RequestId))
 }
 
+// 查询 slb regions
 func Test_SLB_DescribeRegionsWithRPCrequest(t *testing.T) {
 	client, err := slb.NewClientWithAccessKey(os.Getenv("REGION_ID"), os.Getenv("ACCESS_KEY_ID"), os.Getenv("ACCESS_KEY_SECRET"))
 	assert.Nil(t, err)
@@ -156,6 +163,7 @@ func Test_SLB_DescribeRegionsWithRPCrequest(t *testing.T) {
 	assert.True(t, len(response.Regions.Region) > 0)
 }
 
+// 查询 vpc regions
 func Test_VPC_DescribeRegionsWithRPCrequest(t *testing.T) {
 	client, err := vpc.NewClientWithAccessKey(os.Getenv("REGION_ID"), os.Getenv("ACCESS_KEY_ID"), os.Getenv("ACCESS_KEY_SECRET"))
 	assert.Nil(t, err)

integration/base.go

@@ -1,6 +1,7 @@
 package integration
 
 import (
+	"github.com/aliyun/alibaba-cloud-sdk-go/sdk/errors"
 	"github.com/aliyun/alibaba-cloud-sdk-go/services/ram"
 	"github.com/aliyun/alibaba-cloud-sdk-go/services/sts"
 
@@ -64,21 +65,25 @@ func createRole(userid string) (name string, arn string, err error) {
 }
 
 func createUser() (err error) {
-	listRequest := ram.CreateListUsersRequest()
-	listRequest.Scheme = "HTTPS"
 	client, err := ram.NewClientWithAccessKey(os.Getenv("REGION_ID"), os.Getenv("ACCESS_KEY_ID"), os.Getenv("ACCESS_KEY_SECRET"))
 	if err != nil {
 		return
 	}
-	listResponse, err := client.ListUsers(listRequest)
-	if err != nil {
-		return
-	}
-	for _, user := range listResponse.Users.User {
-		if user.UserName == username {
-			return
+
+	getUserRequest := ram.CreateGetUserRequest()
+	getUserRequest.UserName = username
+	getUserRequest.Scheme = "HTTPS"
+	_, err = client.GetUser(getUserRequest)
+	if err != nil {
+		if se, ok := err.(*errors.ServerError); ok {
+			if se.ErrorCode() == "EntityNotExist.User" {
+				err = nil
+				return
+			}
 		}
+		return
 	}
+
 	createRequest := ram.CreateCreateUserRequest()
 	createRequest.Scheme = "HTTPS"
 	createRequest.UserName = username