chore(deps): bump the go group across 5 directories with 3 updates (#5876)

Bumps the go group with 2 updates in the / directory: [github.com/grpc-ecosystem/grpc-gateway/v2](https://github.com/grpc-ecosystem/grpc-gateway) and [github.com/hashicorp/go-retryablehttp](https://github.com/hashicorp/go-retryablehttp).
Bumps the go group with 1 update in the /api directory: [github.com/hashicorp/go-retryablehttp](https://github.com/hashicorp/go-retryablehttp).
Bumps the go group with 1 update in the /plugins/boundary/mains/azure directory: [github.com/hashicorp/go-retryablehttp](https://github.com/hashicorp/go-retryablehttp).
Bumps the go group with 1 update in the /plugins/kms/mains/transit directory: [github.com/hashicorp/go-retryablehttp](https://github.com/hashicorp/go-retryablehttp).
Bumps the go group with 1 update in the /sdk directory: [github.com/grpc-ecosystem/grpc-gateway/v2](https://github.com/grpc-ecosystem/grpc-gateway).

Updates `github.com/grpc-ecosystem/grpc-gateway/v2` from 2.26.3 to 2.27.0
- [Release notes](https://github.com/grpc-ecosystem/grpc-gateway/releases)
- [Changelog](https://github.com/grpc-ecosystem/grpc-gateway/blob/main/.goreleaser.yml)
- [Commits](https://github.com/grpc-ecosystem/grpc-gateway/compare/v2.26.3...v2.27.0)

Updates `github.com/hashicorp/go-retryablehttp` from 0.7.7 to 0.7.8
- [Changelog](https://github.com/hashicorp/go-retryablehttp/blob/main/CHANGELOG.md)
- [Commits](https://github.com/hashicorp/go-retryablehttp/compare/v0.7.7...v0.7.8)

Updates `google.golang.org/genproto/googleapis/api` from 0.0.0-20250324211829-b45e905df463 to 0.0.0-20250603155806-513f23925822
- [Commits](https://github.com/googleapis/go-genproto/commits)

Updates `github.com/hashicorp/go-retryablehttp` from 0.7.7 to 0.7.8
- [Changelog](https://github.com/hashicorp/go-retryablehttp/blob/main/CHANGELOG.md)
- [Commits](https://github.com/hashicorp/go-retryablehttp/compare/v0.7.7...v0.7.8)

Updates `github.com/hashicorp/go-retryablehttp` from 0.7.7 to 0.7.8
- [Changelog](https://github.com/hashicorp/go-retryablehttp/blob/main/CHANGELOG.md)
- [Commits](https://github.com/hashicorp/go-retryablehttp/compare/v0.7.7...v0.7.8)

Updates `github.com/hashicorp/go-retryablehttp` from 0.7.7 to 0.7.8
- [Changelog](https://github.com/hashicorp/go-retryablehttp/blob/main/CHANGELOG.md)
- [Commits](https://github.com/hashicorp/go-retryablehttp/compare/v0.7.7...v0.7.8)

Updates `github.com/grpc-ecosystem/grpc-gateway/v2` from 2.26.3 to 2.27.0
- [Release notes](https://github.com/grpc-ecosystem/grpc-gateway/releases)
- [Changelog](https://github.com/grpc-ecosystem/grpc-gateway/blob/main/.goreleaser.yml)
- [Commits](https://github.com/grpc-ecosystem/grpc-gateway/compare/v2.26.3...v2.27.0)

Updates `google.golang.org/genproto/googleapis/api` from 0.0.0-20250324211829-b45e905df463 to 0.0.0-20250603155806-513f23925822
- [Commits](https://github.com/googleapis/go-genproto/commits)

---
updated-dependencies:
- dependency-name: github.com/grpc-ecosystem/grpc-gateway/v2
  dependency-version: 2.27.0
  dependency-type: direct:production
  update-type: version-update:semver-minor
  dependency-group: go
- dependency-name: github.com/hashicorp/go-retryablehttp
  dependency-version: 0.7.8
  dependency-type: direct:production
  update-type: version-update:semver-patch
  dependency-group: go
- dependency-name: google.golang.org/genproto/googleapis/api
  dependency-version: 0.0.0-20250603155806-513f23925822
  dependency-type: direct:production
  update-type: version-update:semver-patch
  dependency-group: go
- dependency-name: github.com/hashicorp/go-retryablehttp
  dependency-version: 0.7.8
  dependency-type: direct:production
  update-type: version-update:semver-patch
  dependency-group: go
- dependency-name: github.com/hashicorp/go-retryablehttp
  dependency-version: 0.7.8
  dependency-type: indirect
  update-type: version-update:semver-patch
  dependency-group: go
- dependency-name: github.com/hashicorp/go-retryablehttp
  dependency-version: 0.7.8
  dependency-type: indirect
  update-type: version-update:semver-patch
  dependency-group: go
- dependency-name: github.com/grpc-ecosystem/grpc-gateway/v2
  dependency-version: 2.27.0
  dependency-type: direct:production
  update-type: version-update:semver-minor
  dependency-group: go
- dependency-name: google.golang.org/genproto/googleapis/api
  dependency-version: 0.0.0-20250603155806-513f23925822
  dependency-type: direct:production
  update-type: version-update:semver-patch
  dependency-group: go
...

Signed-off-by: dependabot[bot] <support@github.com>
Co-authored-by: dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com>

internal/gen/controller/api/services/account_service.pb.gw.go

@@ -41,7 +41,9 @@ func request_AccountService_GetAccount_0(ctx context.Context, marshaler runtime.
 		metadata runtime.ServerMetadata
 		err      error
 	)
-	io.Copy(io.Discard, req.Body)
+	if req.Body != nil {
+		_, _ = io.Copy(io.Discard, req.Body)
+	}
 	val, ok := pathParams["id"]
 	if !ok {
 		return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "id")
@@ -79,7 +81,9 @@ func request_AccountService_ListAccounts_0(ctx context.Context, marshaler runtim
 		protoReq ListAccountsRequest
 		metadata runtime.ServerMetadata
 	)
-	io.Copy(io.Discard, req.Body)
+	if req.Body != nil {
+		_, _ = io.Copy(io.Discard, req.Body)
+	}
 	if err := req.ParseForm(); err != nil {
 		return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
 	}
@@ -113,6 +117,9 @@ func request_AccountService_CreateAccount_0(ctx context.Context, marshaler runti
 	if err := marshaler.NewDecoder(req.Body).Decode(&protoReq.Item); err != nil && !errors.Is(err, io.EOF) {
 		return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
 	}
+	if req.Body != nil {
+		_, _ = io.Copy(io.Discard, req.Body)
+	}
 	msg, err := client.CreateAccount(ctx, &protoReq, grpc.Header(&metadata.HeaderMD), grpc.Trailer(&metadata.TrailerMD))
 	return msg, metadata, err
 }
@@ -144,6 +151,9 @@ func request_AccountService_UpdateAccount_0(ctx context.Context, marshaler runti
 	if err := marshaler.NewDecoder(newReader()).Decode(&protoReq.Item); err != nil && !errors.Is(err, io.EOF) {
 		return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
 	}
+	if req.Body != nil {
+		_, _ = io.Copy(io.Discard, req.Body)
+	}
 	if protoReq.UpdateMask == nil || len(protoReq.UpdateMask.GetPaths()) == 0 {
 		if fieldMask, err := runtime.FieldMaskFromRequestBody(newReader(), protoReq.Item); err != nil {
 			return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
@@ -213,7 +223,9 @@ func request_AccountService_DeleteAccount_0(ctx context.Context, marshaler runti
 		metadata runtime.ServerMetadata
 		err      error
 	)
-	io.Copy(io.Discard, req.Body)
+	if req.Body != nil {
+		_, _ = io.Copy(io.Discard, req.Body)
+	}
 	val, ok := pathParams["id"]
 	if !ok {
 		return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "id")
@@ -253,6 +265,9 @@ func request_AccountService_SetPassword_0(ctx context.Context, marshaler runtime
 	if err := marshaler.NewDecoder(req.Body).Decode(&protoReq); err != nil && !errors.Is(err, io.EOF) {
 		return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
 	}
+	if req.Body != nil {
+		_, _ = io.Copy(io.Discard, req.Body)
+	}
 	val, ok := pathParams["id"]
 	if !ok {
 		return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "id")
@@ -295,6 +310,9 @@ func request_AccountService_ChangePassword_0(ctx context.Context, marshaler runt
 	if err := marshaler.NewDecoder(req.Body).Decode(&protoReq); err != nil && !errors.Is(err, io.EOF) {
 		return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
 	}
+	if req.Body != nil {
+		_, _ = io.Copy(io.Discard, req.Body)
+	}
 	val, ok := pathParams["id"]
 	if !ok {
 		return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "id")
@@ -641,7 +659,8 @@ type response_AccountService_GetAccount_0 struct {
 }
 
 func (m response_AccountService_GetAccount_0) XXX_ResponseBody() interface{} {
-	return m.Item
+	response := m.GetAccountResponse
+	return response.Item
 }
 
 type response_AccountService_CreateAccount_0 struct {
@@ -649,7 +668,8 @@ type response_AccountService_CreateAccount_0 struct {
 }
 
 func (m response_AccountService_CreateAccount_0) XXX_ResponseBody() interface{} {
-	return m.Item
+	response := m.CreateAccountResponse
+	return response.Item
 }
 
 type response_AccountService_UpdateAccount_0 struct {
@@ -657,7 +677,8 @@ type response_AccountService_UpdateAccount_0 struct {
 }
 
 func (m response_AccountService_UpdateAccount_0) XXX_ResponseBody() interface{} {
-	return m.Item
+	response := m.UpdateAccountResponse
+	return response.Item
 }
 
 type response_AccountService_SetPassword_0 struct {
@@ -665,7 +686,8 @@ type response_AccountService_SetPassword_0 struct {
 }
 
 func (m response_AccountService_SetPassword_0) XXX_ResponseBody() interface{} {
-	return m.Item
+	response := m.SetPasswordResponse
+	return response.Item
 }
 
 type response_AccountService_ChangePassword_0 struct {
@@ -673,7 +695,8 @@ type response_AccountService_ChangePassword_0 struct {
 }
 
 func (m response_AccountService_ChangePassword_0) XXX_ResponseBody() interface{} {
-	return m.Item
+	response := m.ChangePasswordResponse
+	return response.Item
 }
 
 var (

internal/gen/controller/api/services/alias_service.pb.gw.go

@@ -41,7 +41,9 @@ func request_AliasService_GetAlias_0(ctx context.Context, marshaler runtime.Mars
 		metadata runtime.ServerMetadata
 		err      error
 	)
-	io.Copy(io.Discard, req.Body)
+	if req.Body != nil {
+		_, _ = io.Copy(io.Discard, req.Body)
+	}
 	val, ok := pathParams["id"]
 	if !ok {
 		return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "id")
@@ -79,7 +81,9 @@ func request_AliasService_ListAliases_0(ctx context.Context, marshaler runtime.M
 		protoReq ListAliasesRequest
 		metadata runtime.ServerMetadata
 	)
-	io.Copy(io.Discard, req.Body)
+	if req.Body != nil {
+		_, _ = io.Copy(io.Discard, req.Body)
+	}
 	if err := req.ParseForm(); err != nil {
 		return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
 	}
@@ -113,6 +117,9 @@ func request_AliasService_CreateAlias_0(ctx context.Context, marshaler runtime.M
 	if err := marshaler.NewDecoder(req.Body).Decode(&protoReq.Item); err != nil && !errors.Is(err, io.EOF) {
 		return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
 	}
+	if req.Body != nil {
+		_, _ = io.Copy(io.Discard, req.Body)
+	}
 	msg, err := client.CreateAlias(ctx, &protoReq, grpc.Header(&metadata.HeaderMD), grpc.Trailer(&metadata.TrailerMD))
 	return msg, metadata, err
 }
@@ -144,6 +151,9 @@ func request_AliasService_UpdateAlias_0(ctx context.Context, marshaler runtime.M
 	if err := marshaler.NewDecoder(newReader()).Decode(&protoReq.Item); err != nil && !errors.Is(err, io.EOF) {
 		return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
 	}
+	if req.Body != nil {
+		_, _ = io.Copy(io.Discard, req.Body)
+	}
 	if protoReq.UpdateMask == nil || len(protoReq.UpdateMask.GetPaths()) == 0 {
 		if fieldMask, err := runtime.FieldMaskFromRequestBody(newReader(), protoReq.Item); err != nil {
 			return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
@@ -213,7 +223,9 @@ func request_AliasService_DeleteAlias_0(ctx context.Context, marshaler runtime.M
 		metadata runtime.ServerMetadata
 		err      error
 	)
-	io.Copy(io.Discard, req.Body)
+	if req.Body != nil {
+		_, _ = io.Copy(io.Discard, req.Body)
+	}
 	val, ok := pathParams["id"]
 	if !ok {
 		return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "id")
@@ -483,7 +495,8 @@ type response_AliasService_GetAlias_0 struct {
 }
 
 func (m response_AliasService_GetAlias_0) XXX_ResponseBody() interface{} {
-	return m.Item
+	response := m.GetAliasResponse
+	return response.Item
 }
 
 type response_AliasService_CreateAlias_0 struct {
@@ -491,7 +504,8 @@ type response_AliasService_CreateAlias_0 struct {
 }
 
 func (m response_AliasService_CreateAlias_0) XXX_ResponseBody() interface{} {
-	return m.Item
+	response := m.CreateAliasResponse
+	return response.Item
 }
 
 type response_AliasService_UpdateAlias_0 struct {
@@ -499,7 +513,8 @@ type response_AliasService_UpdateAlias_0 struct {
 }
 
 func (m response_AliasService_UpdateAlias_0) XXX_ResponseBody() interface{} {
-	return m.Item
+	response := m.UpdateAliasResponse
+	return response.Item
 }
 
 var (

internal/gen/controller/api/services/auth_method_service.pb.gw.go

@@ -41,7 +41,9 @@ func request_AuthMethodService_GetAuthMethod_0(ctx context.Context, marshaler ru
 		metadata runtime.ServerMetadata
 		err      error
 	)
-	io.Copy(io.Discard, req.Body)
+	if req.Body != nil {
+		_, _ = io.Copy(io.Discard, req.Body)
+	}
 	val, ok := pathParams["id"]
 	if !ok {
 		return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "id")
@@ -79,7 +81,9 @@ func request_AuthMethodService_ListAuthMethods_0(ctx context.Context, marshaler
 		protoReq ListAuthMethodsRequest
 		metadata runtime.ServerMetadata
 	)
-	io.Copy(io.Discard, req.Body)
+	if req.Body != nil {
+		_, _ = io.Copy(io.Discard, req.Body)
+	}
 	if err := req.ParseForm(); err != nil {
 		return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
 	}
@@ -113,6 +117,9 @@ func request_AuthMethodService_CreateAuthMethod_0(ctx context.Context, marshaler
 	if err := marshaler.NewDecoder(req.Body).Decode(&protoReq.Item); err != nil && !errors.Is(err, io.EOF) {
 		return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
 	}
+	if req.Body != nil {
+		_, _ = io.Copy(io.Discard, req.Body)
+	}
 	msg, err := client.CreateAuthMethod(ctx, &protoReq, grpc.Header(&metadata.HeaderMD), grpc.Trailer(&metadata.TrailerMD))
 	return msg, metadata, err
 }
@@ -144,6 +151,9 @@ func request_AuthMethodService_UpdateAuthMethod_0(ctx context.Context, marshaler
 	if err := marshaler.NewDecoder(newReader()).Decode(&protoReq.Item); err != nil && !errors.Is(err, io.EOF) {
 		return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
 	}
+	if req.Body != nil {
+		_, _ = io.Copy(io.Discard, req.Body)
+	}
 	if protoReq.UpdateMask == nil || len(protoReq.UpdateMask.GetPaths()) == 0 {
 		if fieldMask, err := runtime.FieldMaskFromRequestBody(newReader(), protoReq.Item); err != nil {
 			return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
@@ -213,7 +223,9 @@ func request_AuthMethodService_DeleteAuthMethod_0(ctx context.Context, marshaler
 		metadata runtime.ServerMetadata
 		err      error
 	)
-	io.Copy(io.Discard, req.Body)
+	if req.Body != nil {
+		_, _ = io.Copy(io.Discard, req.Body)
+	}
 	val, ok := pathParams["id"]
 	if !ok {
 		return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "id")
@@ -253,6 +265,9 @@ func request_AuthMethodService_ChangeState_0(ctx context.Context, marshaler runt
 	if err := marshaler.NewDecoder(req.Body).Decode(&protoReq); err != nil && !errors.Is(err, io.EOF) {
 		return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
 	}
+	if req.Body != nil {
+		_, _ = io.Copy(io.Discard, req.Body)
+	}
 	val, ok := pathParams["id"]
 	if !ok {
 		return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "id")
@@ -295,6 +310,9 @@ func request_AuthMethodService_Authenticate_0(ctx context.Context, marshaler run
 	if err := marshaler.NewDecoder(req.Body).Decode(&protoReq); err != nil && !errors.Is(err, io.EOF) {
 		return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
 	}
+	if req.Body != nil {
+		_, _ = io.Copy(io.Discard, req.Body)
+	}
 	val, ok := pathParams["auth_method_id"]
 	if !ok {
 		return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "auth_method_id")
@@ -641,7 +659,8 @@ type response_AuthMethodService_GetAuthMethod_0 struct {
 }
 
 func (m response_AuthMethodService_GetAuthMethod_0) XXX_ResponseBody() interface{} {
-	return m.Item
+	response := m.GetAuthMethodResponse
+	return response.Item
 }
 
 type response_AuthMethodService_CreateAuthMethod_0 struct {
@@ -649,7 +668,8 @@ type response_AuthMethodService_CreateAuthMethod_0 struct {
 }
 
 func (m response_AuthMethodService_CreateAuthMethod_0) XXX_ResponseBody() interface{} {
-	return m.Item
+	response := m.CreateAuthMethodResponse
+	return response.Item
 }
 
 type response_AuthMethodService_UpdateAuthMethod_0 struct {
@@ -657,7 +677,8 @@ type response_AuthMethodService_UpdateAuthMethod_0 struct {
 }
 
 func (m response_AuthMethodService_UpdateAuthMethod_0) XXX_ResponseBody() interface{} {
-	return m.Item
+	response := m.UpdateAuthMethodResponse
+	return response.Item
 }
 
 type response_AuthMethodService_ChangeState_0 struct {
@@ -665,7 +686,8 @@ type response_AuthMethodService_ChangeState_0 struct {
 }
 
 func (m response_AuthMethodService_ChangeState_0) XXX_ResponseBody() interface{} {
-	return m.Item
+	response := m.ChangeStateResponse
+	return response.Item
 }
 
 var (

internal/gen/controller/api/services/authtokens_service.pb.gw.go

@@ -41,7 +41,9 @@ func request_AuthTokenService_GetAuthToken_0(ctx context.Context, marshaler runt
 		metadata runtime.ServerMetadata
 		err      error
 	)
-	io.Copy(io.Discard, req.Body)
+	if req.Body != nil {
+		_, _ = io.Copy(io.Discard, req.Body)
+	}
 	val, ok := pathParams["id"]
 	if !ok {
 		return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "id")
@@ -79,7 +81,9 @@ func request_AuthTokenService_ListAuthTokens_0(ctx context.Context, marshaler ru
 		protoReq ListAuthTokensRequest
 		metadata runtime.ServerMetadata
 	)
-	io.Copy(io.Discard, req.Body)
+	if req.Body != nil {
+		_, _ = io.Copy(io.Discard, req.Body)
+	}
 	if err := req.ParseForm(); err != nil {
 		return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
 	}
@@ -111,7 +115,9 @@ func request_AuthTokenService_DeleteAuthToken_0(ctx context.Context, marshaler r
 		metadata runtime.ServerMetadata
 		err      error
 	)
-	io.Copy(io.Discard, req.Body)
+	if req.Body != nil {
+		_, _ = io.Copy(io.Discard, req.Body)
+	}
 	val, ok := pathParams["id"]
 	if !ok {
 		return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "id")
@@ -307,7 +313,8 @@ type response_AuthTokenService_GetAuthToken_0 struct {
 }
 
 func (m response_AuthTokenService_GetAuthToken_0) XXX_ResponseBody() interface{} {
-	return m.Item
+	response := m.GetAuthTokenResponse
+	return response.Item
 }
 
 var (

internal/gen/controller/api/services/billing_service.pb.gw.go

@@ -42,7 +42,9 @@ func request_BillingService_MonthlyActiveUsers_0(ctx context.Context, marshaler
 		protoReq MonthlyActiveUsersRequest
 		metadata runtime.ServerMetadata
 	)
-	io.Copy(io.Discard, req.Body)
+	if req.Body != nil {
+		_, _ = io.Copy(io.Discard, req.Body)
+	}
 	if err := req.ParseForm(); err != nil {
 		return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
 	}

internal/gen/controller/api/services/credential_library_service.pb.gw.go

@@ -41,7 +41,9 @@ func request_CredentialLibraryService_GetCredentialLibrary_0(ctx context.Context
 		metadata runtime.ServerMetadata
 		err      error
 	)
-	io.Copy(io.Discard, req.Body)
+	if req.Body != nil {
+		_, _ = io.Copy(io.Discard, req.Body)
+	}
 	val, ok := pathParams["id"]
 	if !ok {
 		return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "id")
@@ -79,7 +81,9 @@ func request_CredentialLibraryService_ListCredentialLibraries_0(ctx context.Cont
 		protoReq ListCredentialLibrariesRequest
 		metadata runtime.ServerMetadata
 	)
-	io.Copy(io.Discard, req.Body)
+	if req.Body != nil {
+		_, _ = io.Copy(io.Discard, req.Body)
+	}
 	if err := req.ParseForm(); err != nil {
 		return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
 	}
@@ -113,6 +117,9 @@ func request_CredentialLibraryService_CreateCredentialLibrary_0(ctx context.Cont
 	if err := marshaler.NewDecoder(req.Body).Decode(&protoReq.Item); err != nil && !errors.Is(err, io.EOF) {
 		return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
 	}
+	if req.Body != nil {
+		_, _ = io.Copy(io.Discard, req.Body)
+	}
 	msg, err := client.CreateCredentialLibrary(ctx, &protoReq, grpc.Header(&metadata.HeaderMD), grpc.Trailer(&metadata.TrailerMD))
 	return msg, metadata, err
 }
@@ -144,6 +151,9 @@ func request_CredentialLibraryService_UpdateCredentialLibrary_0(ctx context.Cont
 	if err := marshaler.NewDecoder(newReader()).Decode(&protoReq.Item); err != nil && !errors.Is(err, io.EOF) {
 		return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
 	}
+	if req.Body != nil {
+		_, _ = io.Copy(io.Discard, req.Body)
+	}
 	if protoReq.UpdateMask == nil || len(protoReq.UpdateMask.GetPaths()) == 0 {
 		if fieldMask, err := runtime.FieldMaskFromRequestBody(newReader(), protoReq.Item); err != nil {
 			return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
@@ -213,7 +223,9 @@ func request_CredentialLibraryService_DeleteCredentialLibrary_0(ctx context.Cont
 		metadata runtime.ServerMetadata
 		err      error
 	)
-	io.Copy(io.Discard, req.Body)
+	if req.Body != nil {
+		_, _ = io.Copy(io.Discard, req.Body)
+	}
 	val, ok := pathParams["id"]
 	if !ok {
 		return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "id")
@@ -483,7 +495,8 @@ type response_CredentialLibraryService_GetCredentialLibrary_0 struct {
 }
 
 func (m response_CredentialLibraryService_GetCredentialLibrary_0) XXX_ResponseBody() interface{} {
-	return m.Item
+	response := m.GetCredentialLibraryResponse
+	return response.Item
 }
 
 type response_CredentialLibraryService_CreateCredentialLibrary_0 struct {
@@ -491,7 +504,8 @@ type response_CredentialLibraryService_CreateCredentialLibrary_0 struct {
 }
 
 func (m response_CredentialLibraryService_CreateCredentialLibrary_0) XXX_ResponseBody() interface{} {
-	return m.Item
+	response := m.CreateCredentialLibraryResponse
+	return response.Item
 }
 
 type response_CredentialLibraryService_UpdateCredentialLibrary_0 struct {
@@ -499,7 +513,8 @@ type response_CredentialLibraryService_UpdateCredentialLibrary_0 struct {
 }
 
 func (m response_CredentialLibraryService_UpdateCredentialLibrary_0) XXX_ResponseBody() interface{} {
-	return m.Item
+	response := m.UpdateCredentialLibraryResponse
+	return response.Item
 }
 
 var (

internal/gen/controller/api/services/credential_service.pb.gw.go

@@ -41,7 +41,9 @@ func request_CredentialService_GetCredential_0(ctx context.Context, marshaler ru
 		metadata runtime.ServerMetadata
 		err      error
 	)
-	io.Copy(io.Discard, req.Body)
+	if req.Body != nil {
+		_, _ = io.Copy(io.Discard, req.Body)
+	}
 	val, ok := pathParams["id"]
 	if !ok {
 		return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "id")
@@ -79,7 +81,9 @@ func request_CredentialService_ListCredentials_0(ctx context.Context, marshaler
 		protoReq ListCredentialsRequest
 		metadata runtime.ServerMetadata
 	)
-	io.Copy(io.Discard, req.Body)
+	if req.Body != nil {
+		_, _ = io.Copy(io.Discard, req.Body)
+	}
 	if err := req.ParseForm(); err != nil {
 		return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
 	}
@@ -113,6 +117,9 @@ func request_CredentialService_CreateCredential_0(ctx context.Context, marshaler
 	if err := marshaler.NewDecoder(req.Body).Decode(&protoReq.Item); err != nil && !errors.Is(err, io.EOF) {
 		return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
 	}
+	if req.Body != nil {
+		_, _ = io.Copy(io.Discard, req.Body)
+	}
 	msg, err := client.CreateCredential(ctx, &protoReq, grpc.Header(&metadata.HeaderMD), grpc.Trailer(&metadata.TrailerMD))
 	return msg, metadata, err
 }
@@ -144,6 +151,9 @@ func request_CredentialService_UpdateCredential_0(ctx context.Context, marshaler
 	if err := marshaler.NewDecoder(newReader()).Decode(&protoReq.Item); err != nil && !errors.Is(err, io.EOF) {
 		return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
 	}
+	if req.Body != nil {
+		_, _ = io.Copy(io.Discard, req.Body)
+	}
 	if protoReq.UpdateMask == nil || len(protoReq.UpdateMask.GetPaths()) == 0 {
 		if fieldMask, err := runtime.FieldMaskFromRequestBody(newReader(), protoReq.Item); err != nil {
 			return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
@@ -213,7 +223,9 @@ func request_CredentialService_DeleteCredential_0(ctx context.Context, marshaler
 		metadata runtime.ServerMetadata
 		err      error
 	)
-	io.Copy(io.Discard, req.Body)
+	if req.Body != nil {
+		_, _ = io.Copy(io.Discard, req.Body)
+	}
 	val, ok := pathParams["id"]
 	if !ok {
 		return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "id")
@@ -483,7 +495,8 @@ type response_CredentialService_GetCredential_0 struct {
 }
 
 func (m response_CredentialService_GetCredential_0) XXX_ResponseBody() interface{} {
-	return m.Item
+	response := m.GetCredentialResponse
+	return response.Item
 }
 
 type response_CredentialService_CreateCredential_0 struct {
@@ -491,7 +504,8 @@ type response_CredentialService_CreateCredential_0 struct {
 }
 
 func (m response_CredentialService_CreateCredential_0) XXX_ResponseBody() interface{} {
-	return m.Item
+	response := m.CreateCredentialResponse
+	return response.Item
 }
 
 type response_CredentialService_UpdateCredential_0 struct {
@@ -499,7 +513,8 @@ type response_CredentialService_UpdateCredential_0 struct {
 }
 
 func (m response_CredentialService_UpdateCredential_0) XXX_ResponseBody() interface{} {
-	return m.Item
+	response := m.UpdateCredentialResponse
+	return response.Item
 }
 
 var (

internal/gen/controller/api/services/credential_store_service.pb.gw.go

@@ -41,7 +41,9 @@ func request_CredentialStoreService_GetCredentialStore_0(ctx context.Context, ma
 		metadata runtime.ServerMetadata
 		err      error
 	)
-	io.Copy(io.Discard, req.Body)
+	if req.Body != nil {
+		_, _ = io.Copy(io.Discard, req.Body)
+	}
 	val, ok := pathParams["id"]
 	if !ok {
 		return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "id")
@@ -79,7 +81,9 @@ func request_CredentialStoreService_ListCredentialStores_0(ctx context.Context,
 		protoReq ListCredentialStoresRequest
 		metadata runtime.ServerMetadata
 	)
-	io.Copy(io.Discard, req.Body)
+	if req.Body != nil {
+		_, _ = io.Copy(io.Discard, req.Body)
+	}
 	if err := req.ParseForm(); err != nil {
 		return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
 	}
@@ -113,6 +117,9 @@ func request_CredentialStoreService_CreateCredentialStore_0(ctx context.Context,
 	if err := marshaler.NewDecoder(req.Body).Decode(&protoReq.Item); err != nil && !errors.Is(err, io.EOF) {
 		return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
 	}
+	if req.Body != nil {
+		_, _ = io.Copy(io.Discard, req.Body)
+	}
 	msg, err := client.CreateCredentialStore(ctx, &protoReq, grpc.Header(&metadata.HeaderMD), grpc.Trailer(&metadata.TrailerMD))
 	return msg, metadata, err
 }
@@ -144,6 +151,9 @@ func request_CredentialStoreService_UpdateCredentialStore_0(ctx context.Context,
 	if err := marshaler.NewDecoder(newReader()).Decode(&protoReq.Item); err != nil && !errors.Is(err, io.EOF) {
 		return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
 	}
+	if req.Body != nil {
+		_, _ = io.Copy(io.Discard, req.Body)
+	}
 	if protoReq.UpdateMask == nil || len(protoReq.UpdateMask.GetPaths()) == 0 {
 		if fieldMask, err := runtime.FieldMaskFromRequestBody(newReader(), protoReq.Item); err != nil {
 			return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
@@ -213,7 +223,9 @@ func request_CredentialStoreService_DeleteCredentialStore_0(ctx context.Context,
 		metadata runtime.ServerMetadata
 		err      error
 	)
-	io.Copy(io.Discard, req.Body)
+	if req.Body != nil {
+		_, _ = io.Copy(io.Discard, req.Body)
+	}
 	val, ok := pathParams["id"]
 	if !ok {
 		return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "id")
@@ -483,7 +495,8 @@ type response_CredentialStoreService_GetCredentialStore_0 struct {
 }
 
 func (m response_CredentialStoreService_GetCredentialStore_0) XXX_ResponseBody() interface{} {
-	return m.Item
+	response := m.GetCredentialStoreResponse
+	return response.Item
 }
 
 type response_CredentialStoreService_CreateCredentialStore_0 struct {
@@ -491,7 +504,8 @@ type response_CredentialStoreService_CreateCredentialStore_0 struct {
 }
 
 func (m response_CredentialStoreService_CreateCredentialStore_0) XXX_ResponseBody() interface{} {
-	return m.Item
+	response := m.CreateCredentialStoreResponse
+	return response.Item
 }
 
 type response_CredentialStoreService_UpdateCredentialStore_0 struct {
@@ -499,7 +513,8 @@ type response_CredentialStoreService_UpdateCredentialStore_0 struct {
 }
 
 func (m response_CredentialStoreService_UpdateCredentialStore_0) XXX_ResponseBody() interface{} {
-	return m.Item
+	response := m.UpdateCredentialStoreResponse
+	return response.Item
 }
 
 var (

internal/gen/controller/api/services/group_service.pb.gw.go

@@ -41,7 +41,9 @@ func request_GroupService_GetGroup_0(ctx context.Context, marshaler runtime.Mars
 		metadata runtime.ServerMetadata
 		err      error
 	)
-	io.Copy(io.Discard, req.Body)
+	if req.Body != nil {
+		_, _ = io.Copy(io.Discard, req.Body)
+	}
 	val, ok := pathParams["id"]
 	if !ok {
 		return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "id")
@@ -79,7 +81,9 @@ func request_GroupService_ListGroups_0(ctx context.Context, marshaler runtime.Ma
 		protoReq ListGroupsRequest
 		metadata runtime.ServerMetadata
 	)
-	io.Copy(io.Discard, req.Body)
+	if req.Body != nil {
+		_, _ = io.Copy(io.Discard, req.Body)
+	}
 	if err := req.ParseForm(); err != nil {
 		return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
 	}
@@ -113,6 +117,9 @@ func request_GroupService_CreateGroup_0(ctx context.Context, marshaler runtime.M
 	if err := marshaler.NewDecoder(req.Body).Decode(&protoReq.Item); err != nil && !errors.Is(err, io.EOF) {
 		return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
 	}
+	if req.Body != nil {
+		_, _ = io.Copy(io.Discard, req.Body)
+	}
 	msg, err := client.CreateGroup(ctx, &protoReq, grpc.Header(&metadata.HeaderMD), grpc.Trailer(&metadata.TrailerMD))
 	return msg, metadata, err
 }
@@ -144,6 +151,9 @@ func request_GroupService_UpdateGroup_0(ctx context.Context, marshaler runtime.M
 	if err := marshaler.NewDecoder(newReader()).Decode(&protoReq.Item); err != nil && !errors.Is(err, io.EOF) {
 		return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
 	}
+	if req.Body != nil {
+		_, _ = io.Copy(io.Discard, req.Body)
+	}
 	if protoReq.UpdateMask == nil || len(protoReq.UpdateMask.GetPaths()) == 0 {
 		if fieldMask, err := runtime.FieldMaskFromRequestBody(newReader(), protoReq.Item); err != nil {
 			return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
@@ -213,7 +223,9 @@ func request_GroupService_DeleteGroup_0(ctx context.Context, marshaler runtime.M
 		metadata runtime.ServerMetadata
 		err      error
 	)
-	io.Copy(io.Discard, req.Body)
+	if req.Body != nil {
+		_, _ = io.Copy(io.Discard, req.Body)
+	}
 	val, ok := pathParams["id"]
 	if !ok {
 		return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "id")
@@ -253,6 +265,9 @@ func request_GroupService_AddGroupMembers_0(ctx context.Context, marshaler runti
 	if err := marshaler.NewDecoder(req.Body).Decode(&protoReq); err != nil && !errors.Is(err, io.EOF) {
 		return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
 	}
+	if req.Body != nil {
+		_, _ = io.Copy(io.Discard, req.Body)
+	}
 	val, ok := pathParams["id"]
 	if !ok {
 		return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "id")
@@ -295,6 +310,9 @@ func request_GroupService_SetGroupMembers_0(ctx context.Context, marshaler runti
 	if err := marshaler.NewDecoder(req.Body).Decode(&protoReq); err != nil && !errors.Is(err, io.EOF) {
 		return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
 	}
+	if req.Body != nil {
+		_, _ = io.Copy(io.Discard, req.Body)
+	}
 	val, ok := pathParams["id"]
 	if !ok {
 		return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "id")
@@ -337,6 +355,9 @@ func request_GroupService_RemoveGroupMembers_0(ctx context.Context, marshaler ru
 	if err := marshaler.NewDecoder(req.Body).Decode(&protoReq); err != nil && !errors.Is(err, io.EOF) {
 		return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
 	}
+	if req.Body != nil {
+		_, _ = io.Copy(io.Discard, req.Body)
+	}
 	val, ok := pathParams["id"]
 	if !ok {
 		return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "id")
@@ -720,7 +741,8 @@ type response_GroupService_GetGroup_0 struct {
 }
 
 func (m response_GroupService_GetGroup_0) XXX_ResponseBody() interface{} {
-	return m.Item
+	response := m.GetGroupResponse
+	return response.Item
 }
 
 type response_GroupService_CreateGroup_0 struct {
@@ -728,7 +750,8 @@ type response_GroupService_CreateGroup_0 struct {
 }
 
 func (m response_GroupService_CreateGroup_0) XXX_ResponseBody() interface{} {
-	return m.Item
+	response := m.CreateGroupResponse
+	return response.Item
 }
 
 type response_GroupService_UpdateGroup_0 struct {
@@ -736,7 +759,8 @@ type response_GroupService_UpdateGroup_0 struct {
 }
 
 func (m response_GroupService_UpdateGroup_0) XXX_ResponseBody() interface{} {
-	return m.Item
+	response := m.UpdateGroupResponse
+	return response.Item
 }
 
 type response_GroupService_AddGroupMembers_0 struct {
@@ -744,7 +768,8 @@ type response_GroupService_AddGroupMembers_0 struct {
 }
 
 func (m response_GroupService_AddGroupMembers_0) XXX_ResponseBody() interface{} {
-	return m.Item
+	response := m.AddGroupMembersResponse
+	return response.Item
 }
 
 type response_GroupService_SetGroupMembers_0 struct {
@@ -752,7 +777,8 @@ type response_GroupService_SetGroupMembers_0 struct {
 }
 
 func (m response_GroupService_SetGroupMembers_0) XXX_ResponseBody() interface{} {
-	return m.Item
+	response := m.SetGroupMembersResponse
+	return response.Item
 }
 
 type response_GroupService_RemoveGroupMembers_0 struct {
@@ -760,7 +786,8 @@ type response_GroupService_RemoveGroupMembers_0 struct {
 }
 
 func (m response_GroupService_RemoveGroupMembers_0) XXX_ResponseBody() interface{} {
-	return m.Item
+	response := m.RemoveGroupMembersResponse
+	return response.Item
 }
 
 var (

internal/gen/controller/api/services/host_catalog_service.pb.gw.go

@@ -41,7 +41,9 @@ func request_HostCatalogService_GetHostCatalog_0(ctx context.Context, marshaler
 		metadata runtime.ServerMetadata
 		err      error
 	)
-	io.Copy(io.Discard, req.Body)
+	if req.Body != nil {
+		_, _ = io.Copy(io.Discard, req.Body)
+	}
 	val, ok := pathParams["id"]
 	if !ok {
 		return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "id")
@@ -79,7 +81,9 @@ func request_HostCatalogService_ListHostCatalogs_0(ctx context.Context, marshale
 		protoReq ListHostCatalogsRequest
 		metadata runtime.ServerMetadata
 	)
-	io.Copy(io.Discard, req.Body)
+	if req.Body != nil {
+		_, _ = io.Copy(io.Discard, req.Body)
+	}
 	if err := req.ParseForm(); err != nil {
 		return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
 	}
@@ -115,6 +119,9 @@ func request_HostCatalogService_CreateHostCatalog_0(ctx context.Context, marshal
 	if err := marshaler.NewDecoder(req.Body).Decode(&protoReq.Item); err != nil && !errors.Is(err, io.EOF) {
 		return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
 	}
+	if req.Body != nil {
+		_, _ = io.Copy(io.Discard, req.Body)
+	}
 	if err := req.ParseForm(); err != nil {
 		return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
 	}
@@ -158,6 +165,9 @@ func request_HostCatalogService_UpdateHostCatalog_0(ctx context.Context, marshal
 	if err := marshaler.NewDecoder(newReader()).Decode(&protoReq.Item); err != nil && !errors.Is(err, io.EOF) {
 		return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
 	}
+	if req.Body != nil {
+		_, _ = io.Copy(io.Discard, req.Body)
+	}
 	if protoReq.UpdateMask == nil || len(protoReq.UpdateMask.GetPaths()) == 0 {
 		if fieldMask, err := runtime.FieldMaskFromRequestBody(newReader(), protoReq.Item); err != nil {
 			return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
@@ -227,7 +237,9 @@ func request_HostCatalogService_DeleteHostCatalog_0(ctx context.Context, marshal
 		metadata runtime.ServerMetadata
 		err      error
 	)
-	io.Copy(io.Discard, req.Body)
+	if req.Body != nil {
+		_, _ = io.Copy(io.Discard, req.Body)
+	}
 	val, ok := pathParams["id"]
 	if !ok {
 		return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "id")
@@ -497,7 +509,8 @@ type response_HostCatalogService_GetHostCatalog_0 struct {
 }
 
 func (m response_HostCatalogService_GetHostCatalog_0) XXX_ResponseBody() interface{} {
-	return m.Item
+	response := m.GetHostCatalogResponse
+	return response.Item
 }
 
 type response_HostCatalogService_CreateHostCatalog_0 struct {
@@ -505,7 +518,8 @@ type response_HostCatalogService_CreateHostCatalog_0 struct {
 }
 
 func (m response_HostCatalogService_CreateHostCatalog_0) XXX_ResponseBody() interface{} {
-	return m.Item
+	response := m.CreateHostCatalogResponse
+	return response.Item
 }
 
 type response_HostCatalogService_UpdateHostCatalog_0 struct {
@@ -513,7 +527,8 @@ type response_HostCatalogService_UpdateHostCatalog_0 struct {
 }
 
 func (m response_HostCatalogService_UpdateHostCatalog_0) XXX_ResponseBody() interface{} {
-	return m.Item
+	response := m.UpdateHostCatalogResponse
+	return response.Item
 }
 
 var (

internal/gen/controller/api/services/host_service.pb.gw.go

@@ -41,7 +41,9 @@ func request_HostService_GetHost_0(ctx context.Context, marshaler runtime.Marsha
 		metadata runtime.ServerMetadata
 		err      error
 	)
-	io.Copy(io.Discard, req.Body)
+	if req.Body != nil {
+		_, _ = io.Copy(io.Discard, req.Body)
+	}
 	val, ok := pathParams["id"]
 	if !ok {
 		return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "id")
@@ -79,7 +81,9 @@ func request_HostService_ListHosts_0(ctx context.Context, marshaler runtime.Mars
 		protoReq ListHostsRequest
 		metadata runtime.ServerMetadata
 	)
-	io.Copy(io.Discard, req.Body)
+	if req.Body != nil {
+		_, _ = io.Copy(io.Discard, req.Body)
+	}
 	if err := req.ParseForm(); err != nil {
 		return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
 	}
@@ -113,6 +117,9 @@ func request_HostService_CreateHost_0(ctx context.Context, marshaler runtime.Mar
 	if err := marshaler.NewDecoder(req.Body).Decode(&protoReq.Item); err != nil && !errors.Is(err, io.EOF) {
 		return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
 	}
+	if req.Body != nil {
+		_, _ = io.Copy(io.Discard, req.Body)
+	}
 	msg, err := client.CreateHost(ctx, &protoReq, grpc.Header(&metadata.HeaderMD), grpc.Trailer(&metadata.TrailerMD))
 	return msg, metadata, err
 }
@@ -144,6 +151,9 @@ func request_HostService_UpdateHost_0(ctx context.Context, marshaler runtime.Mar
 	if err := marshaler.NewDecoder(newReader()).Decode(&protoReq.Item); err != nil && !errors.Is(err, io.EOF) {
 		return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
 	}
+	if req.Body != nil {
+		_, _ = io.Copy(io.Discard, req.Body)
+	}
 	if protoReq.UpdateMask == nil || len(protoReq.UpdateMask.GetPaths()) == 0 {
 		if fieldMask, err := runtime.FieldMaskFromRequestBody(newReader(), protoReq.Item); err != nil {
 			return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
@@ -213,7 +223,9 @@ func request_HostService_DeleteHost_0(ctx context.Context, marshaler runtime.Mar
 		metadata runtime.ServerMetadata
 		err      error
 	)
-	io.Copy(io.Discard, req.Body)
+	if req.Body != nil {
+		_, _ = io.Copy(io.Discard, req.Body)
+	}
 	val, ok := pathParams["id"]
 	if !ok {
 		return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "id")
@@ -483,7 +495,8 @@ type response_HostService_GetHost_0 struct {
 }
 
 func (m response_HostService_GetHost_0) XXX_ResponseBody() interface{} {
-	return m.Item
+	response := m.GetHostResponse
+	return response.Item
 }
 
 type response_HostService_CreateHost_0 struct {
@@ -491,7 +504,8 @@ type response_HostService_CreateHost_0 struct {
 }
 
 func (m response_HostService_CreateHost_0) XXX_ResponseBody() interface{} {
-	return m.Item
+	response := m.CreateHostResponse
+	return response.Item
 }
 
 type response_HostService_UpdateHost_0 struct {
@@ -499,7 +513,8 @@ type response_HostService_UpdateHost_0 struct {
 }
 
 func (m response_HostService_UpdateHost_0) XXX_ResponseBody() interface{} {
-	return m.Item
+	response := m.UpdateHostResponse
+	return response.Item
 }
 
 var (

internal/gen/controller/api/services/host_set_service.pb.gw.go

@@ -41,7 +41,9 @@ func request_HostSetService_GetHostSet_0(ctx context.Context, marshaler runtime.
 		metadata runtime.ServerMetadata
 		err      error
 	)
-	io.Copy(io.Discard, req.Body)
+	if req.Body != nil {
+		_, _ = io.Copy(io.Discard, req.Body)
+	}
 	val, ok := pathParams["id"]
 	if !ok {
 		return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "id")
@@ -79,7 +81,9 @@ func request_HostSetService_ListHostSets_0(ctx context.Context, marshaler runtim
 		protoReq ListHostSetsRequest
 		metadata runtime.ServerMetadata
 	)
-	io.Copy(io.Discard, req.Body)
+	if req.Body != nil {
+		_, _ = io.Copy(io.Discard, req.Body)
+	}
 	if err := req.ParseForm(); err != nil {
 		return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
 	}
@@ -113,6 +117,9 @@ func request_HostSetService_CreateHostSet_0(ctx context.Context, marshaler runti
 	if err := marshaler.NewDecoder(req.Body).Decode(&protoReq.Item); err != nil && !errors.Is(err, io.EOF) {
 		return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
 	}
+	if req.Body != nil {
+		_, _ = io.Copy(io.Discard, req.Body)
+	}
 	msg, err := client.CreateHostSet(ctx, &protoReq, grpc.Header(&metadata.HeaderMD), grpc.Trailer(&metadata.TrailerMD))
 	return msg, metadata, err
 }
@@ -144,6 +151,9 @@ func request_HostSetService_UpdateHostSet_0(ctx context.Context, marshaler runti
 	if err := marshaler.NewDecoder(newReader()).Decode(&protoReq.Item); err != nil && !errors.Is(err, io.EOF) {
 		return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
 	}
+	if req.Body != nil {
+		_, _ = io.Copy(io.Discard, req.Body)
+	}
 	if protoReq.UpdateMask == nil || len(protoReq.UpdateMask.GetPaths()) == 0 {
 		if fieldMask, err := runtime.FieldMaskFromRequestBody(newReader(), protoReq.Item); err != nil {
 			return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
@@ -213,7 +223,9 @@ func request_HostSetService_DeleteHostSet_0(ctx context.Context, marshaler runti
 		metadata runtime.ServerMetadata
 		err      error
 	)
-	io.Copy(io.Discard, req.Body)
+	if req.Body != nil {
+		_, _ = io.Copy(io.Discard, req.Body)
+	}
 	val, ok := pathParams["id"]
 	if !ok {
 		return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "id")
@@ -253,6 +265,9 @@ func request_HostSetService_AddHostSetHosts_0(ctx context.Context, marshaler run
 	if err := marshaler.NewDecoder(req.Body).Decode(&protoReq); err != nil && !errors.Is(err, io.EOF) {
 		return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
 	}
+	if req.Body != nil {
+		_, _ = io.Copy(io.Discard, req.Body)
+	}
 	val, ok := pathParams["id"]
 	if !ok {
 		return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "id")
@@ -295,6 +310,9 @@ func request_HostSetService_SetHostSetHosts_0(ctx context.Context, marshaler run
 	if err := marshaler.NewDecoder(req.Body).Decode(&protoReq); err != nil && !errors.Is(err, io.EOF) {
 		return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
 	}
+	if req.Body != nil {
+		_, _ = io.Copy(io.Discard, req.Body)
+	}
 	val, ok := pathParams["id"]
 	if !ok {
 		return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "id")
@@ -337,6 +355,9 @@ func request_HostSetService_RemoveHostSetHosts_0(ctx context.Context, marshaler
 	if err := marshaler.NewDecoder(req.Body).Decode(&protoReq); err != nil && !errors.Is(err, io.EOF) {
 		return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
 	}
+	if req.Body != nil {
+		_, _ = io.Copy(io.Discard, req.Body)
+	}
 	val, ok := pathParams["id"]
 	if !ok {
 		return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "id")
@@ -720,7 +741,8 @@ type response_HostSetService_GetHostSet_0 struct {
 }
 
 func (m response_HostSetService_GetHostSet_0) XXX_ResponseBody() interface{} {
-	return m.Item
+	response := m.GetHostSetResponse
+	return response.Item
 }
 
 type response_HostSetService_CreateHostSet_0 struct {
@@ -728,7 +750,8 @@ type response_HostSetService_CreateHostSet_0 struct {
 }
 
 func (m response_HostSetService_CreateHostSet_0) XXX_ResponseBody() interface{} {
-	return m.Item
+	response := m.CreateHostSetResponse
+	return response.Item
 }
 
 type response_HostSetService_UpdateHostSet_0 struct {
@@ -736,7 +759,8 @@ type response_HostSetService_UpdateHostSet_0 struct {
 }
 
 func (m response_HostSetService_UpdateHostSet_0) XXX_ResponseBody() interface{} {
-	return m.Item
+	response := m.UpdateHostSetResponse
+	return response.Item
 }
 
 type response_HostSetService_AddHostSetHosts_0 struct {
@@ -744,7 +768,8 @@ type response_HostSetService_AddHostSetHosts_0 struct {
 }
 
 func (m response_HostSetService_AddHostSetHosts_0) XXX_ResponseBody() interface{} {
-	return m.Item
+	response := m.AddHostSetHostsResponse
+	return response.Item
 }
 
 type response_HostSetService_SetHostSetHosts_0 struct {
@@ -752,7 +777,8 @@ type response_HostSetService_SetHostSetHosts_0 struct {
 }
 
 func (m response_HostSetService_SetHostSetHosts_0) XXX_ResponseBody() interface{} {
-	return m.Item
+	response := m.SetHostSetHostsResponse
+	return response.Item
 }
 
 type response_HostSetService_RemoveHostSetHosts_0 struct {
@@ -760,7 +786,8 @@ type response_HostSetService_RemoveHostSetHosts_0 struct {
 }
 
 func (m response_HostSetService_RemoveHostSetHosts_0) XXX_ResponseBody() interface{} {
-	return m.Item
+	response := m.RemoveHostSetHostsResponse
+	return response.Item
 }
 
 var (

internal/gen/controller/api/services/managed_group_service.pb.gw.go

@@ -41,7 +41,9 @@ func request_ManagedGroupService_GetManagedGroup_0(ctx context.Context, marshale
 		metadata runtime.ServerMetadata
 		err      error
 	)
-	io.Copy(io.Discard, req.Body)
+	if req.Body != nil {
+		_, _ = io.Copy(io.Discard, req.Body)
+	}
 	val, ok := pathParams["id"]
 	if !ok {
 		return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "id")
@@ -79,7 +81,9 @@ func request_ManagedGroupService_ListManagedGroups_0(ctx context.Context, marsha
 		protoReq ListManagedGroupsRequest
 		metadata runtime.ServerMetadata
 	)
-	io.Copy(io.Discard, req.Body)
+	if req.Body != nil {
+		_, _ = io.Copy(io.Discard, req.Body)
+	}
 	if err := req.ParseForm(); err != nil {
 		return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
 	}
@@ -113,6 +117,9 @@ func request_ManagedGroupService_CreateManagedGroup_0(ctx context.Context, marsh
 	if err := marshaler.NewDecoder(req.Body).Decode(&protoReq.Item); err != nil && !errors.Is(err, io.EOF) {
 		return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
 	}
+	if req.Body != nil {
+		_, _ = io.Copy(io.Discard, req.Body)
+	}
 	msg, err := client.CreateManagedGroup(ctx, &protoReq, grpc.Header(&metadata.HeaderMD), grpc.Trailer(&metadata.TrailerMD))
 	return msg, metadata, err
 }
@@ -144,6 +151,9 @@ func request_ManagedGroupService_UpdateManagedGroup_0(ctx context.Context, marsh
 	if err := marshaler.NewDecoder(newReader()).Decode(&protoReq.Item); err != nil && !errors.Is(err, io.EOF) {
 		return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
 	}
+	if req.Body != nil {
+		_, _ = io.Copy(io.Discard, req.Body)
+	}
 	if protoReq.UpdateMask == nil || len(protoReq.UpdateMask.GetPaths()) == 0 {
 		if fieldMask, err := runtime.FieldMaskFromRequestBody(newReader(), protoReq.Item); err != nil {
 			return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
@@ -213,7 +223,9 @@ func request_ManagedGroupService_DeleteManagedGroup_0(ctx context.Context, marsh
 		metadata runtime.ServerMetadata
 		err      error
 	)
-	io.Copy(io.Discard, req.Body)
+	if req.Body != nil {
+		_, _ = io.Copy(io.Discard, req.Body)
+	}
 	val, ok := pathParams["id"]
 	if !ok {
 		return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "id")
@@ -483,7 +495,8 @@ type response_ManagedGroupService_GetManagedGroup_0 struct {
 }
 
 func (m response_ManagedGroupService_GetManagedGroup_0) XXX_ResponseBody() interface{} {
-	return m.Item
+	response := m.GetManagedGroupResponse
+	return response.Item
 }
 
 type response_ManagedGroupService_CreateManagedGroup_0 struct {
@@ -491,7 +504,8 @@ type response_ManagedGroupService_CreateManagedGroup_0 struct {
 }
 
 func (m response_ManagedGroupService_CreateManagedGroup_0) XXX_ResponseBody() interface{} {
-	return m.Item
+	response := m.CreateManagedGroupResponse
+	return response.Item
 }
 
 type response_ManagedGroupService_UpdateManagedGroup_0 struct {
@@ -499,7 +513,8 @@ type response_ManagedGroupService_UpdateManagedGroup_0 struct {
 }
 
 func (m response_ManagedGroupService_UpdateManagedGroup_0) XXX_ResponseBody() interface{} {
-	return m.Item
+	response := m.UpdateManagedGroupResponse
+	return response.Item
 }
 
 var (

internal/gen/controller/api/services/policy_service.pb.gw.go

@@ -41,7 +41,9 @@ func request_PolicyService_GetPolicy_0(ctx context.Context, marshaler runtime.Ma
 		metadata runtime.ServerMetadata
 		err      error
 	)
-	io.Copy(io.Discard, req.Body)
+	if req.Body != nil {
+		_, _ = io.Copy(io.Discard, req.Body)
+	}
 	val, ok := pathParams["id"]
 	if !ok {
 		return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "id")
@@ -79,7 +81,9 @@ func request_PolicyService_ListPolicies_0(ctx context.Context, marshaler runtime
 		protoReq ListPoliciesRequest
 		metadata runtime.ServerMetadata
 	)
-	io.Copy(io.Discard, req.Body)
+	if req.Body != nil {
+		_, _ = io.Copy(io.Discard, req.Body)
+	}
 	if err := req.ParseForm(); err != nil {
 		return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
 	}
@@ -113,6 +117,9 @@ func request_PolicyService_CreatePolicy_0(ctx context.Context, marshaler runtime
 	if err := marshaler.NewDecoder(req.Body).Decode(&protoReq.Item); err != nil && !errors.Is(err, io.EOF) {
 		return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
 	}
+	if req.Body != nil {
+		_, _ = io.Copy(io.Discard, req.Body)
+	}
 	msg, err := client.CreatePolicy(ctx, &protoReq, grpc.Header(&metadata.HeaderMD), grpc.Trailer(&metadata.TrailerMD))
 	return msg, metadata, err
 }
@@ -144,6 +151,9 @@ func request_PolicyService_UpdatePolicy_0(ctx context.Context, marshaler runtime
 	if err := marshaler.NewDecoder(newReader()).Decode(&protoReq.Item); err != nil && !errors.Is(err, io.EOF) {
 		return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
 	}
+	if req.Body != nil {
+		_, _ = io.Copy(io.Discard, req.Body)
+	}
 	if protoReq.UpdateMask == nil || len(protoReq.UpdateMask.GetPaths()) == 0 {
 		if fieldMask, err := runtime.FieldMaskFromRequestBody(newReader(), protoReq.Item); err != nil {
 			return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
@@ -213,7 +223,9 @@ func request_PolicyService_DeletePolicy_0(ctx context.Context, marshaler runtime
 		metadata runtime.ServerMetadata
 		err      error
 	)
-	io.Copy(io.Discard, req.Body)
+	if req.Body != nil {
+		_, _ = io.Copy(io.Discard, req.Body)
+	}
 	val, ok := pathParams["id"]
 	if !ok {
 		return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "id")
@@ -483,7 +495,8 @@ type response_PolicyService_GetPolicy_0 struct {
 }
 
 func (m response_PolicyService_GetPolicy_0) XXX_ResponseBody() interface{} {
-	return m.Item
+	response := m.GetPolicyResponse
+	return response.Item
 }
 
 type response_PolicyService_CreatePolicy_0 struct {
@@ -491,7 +504,8 @@ type response_PolicyService_CreatePolicy_0 struct {
 }
 
 func (m response_PolicyService_CreatePolicy_0) XXX_ResponseBody() interface{} {
-	return m.Item
+	response := m.CreatePolicyResponse
+	return response.Item
 }
 
 type response_PolicyService_UpdatePolicy_0 struct {
@@ -499,7 +513,8 @@ type response_PolicyService_UpdatePolicy_0 struct {
 }
 
 func (m response_PolicyService_UpdatePolicy_0) XXX_ResponseBody() interface{} {
-	return m.Item
+	response := m.UpdatePolicyResponse
+	return response.Item
 }
 
 var (

internal/gen/controller/api/services/role_service.pb.gw.go

@@ -41,7 +41,9 @@ func request_RoleService_GetRole_0(ctx context.Context, marshaler runtime.Marsha
 		metadata runtime.ServerMetadata
 		err      error
 	)
-	io.Copy(io.Discard, req.Body)
+	if req.Body != nil {
+		_, _ = io.Copy(io.Discard, req.Body)
+	}
 	val, ok := pathParams["id"]
 	if !ok {
 		return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "id")
@@ -79,7 +81,9 @@ func request_RoleService_ListRoles_0(ctx context.Context, marshaler runtime.Mars
 		protoReq ListRolesRequest
 		metadata runtime.ServerMetadata
 	)
-	io.Copy(io.Discard, req.Body)
+	if req.Body != nil {
+		_, _ = io.Copy(io.Discard, req.Body)
+	}
 	if err := req.ParseForm(); err != nil {
 		return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
 	}
@@ -113,6 +117,9 @@ func request_RoleService_CreateRole_0(ctx context.Context, marshaler runtime.Mar
 	if err := marshaler.NewDecoder(req.Body).Decode(&protoReq.Item); err != nil && !errors.Is(err, io.EOF) {
 		return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
 	}
+	if req.Body != nil {
+		_, _ = io.Copy(io.Discard, req.Body)
+	}
 	msg, err := client.CreateRole(ctx, &protoReq, grpc.Header(&metadata.HeaderMD), grpc.Trailer(&metadata.TrailerMD))
 	return msg, metadata, err
 }
@@ -144,6 +151,9 @@ func request_RoleService_UpdateRole_0(ctx context.Context, marshaler runtime.Mar
 	if err := marshaler.NewDecoder(newReader()).Decode(&protoReq.Item); err != nil && !errors.Is(err, io.EOF) {
 		return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
 	}
+	if req.Body != nil {
+		_, _ = io.Copy(io.Discard, req.Body)
+	}
 	if protoReq.UpdateMask == nil || len(protoReq.UpdateMask.GetPaths()) == 0 {
 		if fieldMask, err := runtime.FieldMaskFromRequestBody(newReader(), protoReq.Item); err != nil {
 			return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
@@ -213,7 +223,9 @@ func request_RoleService_DeleteRole_0(ctx context.Context, marshaler runtime.Mar
 		metadata runtime.ServerMetadata
 		err      error
 	)
-	io.Copy(io.Discard, req.Body)
+	if req.Body != nil {
+		_, _ = io.Copy(io.Discard, req.Body)
+	}
 	val, ok := pathParams["id"]
 	if !ok {
 		return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "id")
@@ -253,6 +265,9 @@ func request_RoleService_AddRolePrincipals_0(ctx context.Context, marshaler runt
 	if err := marshaler.NewDecoder(req.Body).Decode(&protoReq); err != nil && !errors.Is(err, io.EOF) {
 		return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
 	}
+	if req.Body != nil {
+		_, _ = io.Copy(io.Discard, req.Body)
+	}
 	val, ok := pathParams["id"]
 	if !ok {
 		return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "id")
@@ -295,6 +310,9 @@ func request_RoleService_SetRolePrincipals_0(ctx context.Context, marshaler runt
 	if err := marshaler.NewDecoder(req.Body).Decode(&protoReq); err != nil && !errors.Is(err, io.EOF) {
 		return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
 	}
+	if req.Body != nil {
+		_, _ = io.Copy(io.Discard, req.Body)
+	}
 	val, ok := pathParams["id"]
 	if !ok {
 		return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "id")
@@ -337,6 +355,9 @@ func request_RoleService_RemoveRolePrincipals_0(ctx context.Context, marshaler r
 	if err := marshaler.NewDecoder(req.Body).Decode(&protoReq); err != nil && !errors.Is(err, io.EOF) {
 		return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
 	}
+	if req.Body != nil {
+		_, _ = io.Copy(io.Discard, req.Body)
+	}
 	val, ok := pathParams["id"]
 	if !ok {
 		return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "id")
@@ -379,6 +400,9 @@ func request_RoleService_AddRoleGrants_0(ctx context.Context, marshaler runtime.
 	if err := marshaler.NewDecoder(req.Body).Decode(&protoReq); err != nil && !errors.Is(err, io.EOF) {
 		return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
 	}
+	if req.Body != nil {
+		_, _ = io.Copy(io.Discard, req.Body)
+	}
 	val, ok := pathParams["id"]
 	if !ok {
 		return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "id")
@@ -421,6 +445,9 @@ func request_RoleService_SetRoleGrants_0(ctx context.Context, marshaler runtime.
 	if err := marshaler.NewDecoder(req.Body).Decode(&protoReq); err != nil && !errors.Is(err, io.EOF) {
 		return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
 	}
+	if req.Body != nil {
+		_, _ = io.Copy(io.Discard, req.Body)
+	}
 	val, ok := pathParams["id"]
 	if !ok {
 		return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "id")
@@ -463,6 +490,9 @@ func request_RoleService_RemoveRoleGrants_0(ctx context.Context, marshaler runti
 	if err := marshaler.NewDecoder(req.Body).Decode(&protoReq); err != nil && !errors.Is(err, io.EOF) {
 		return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
 	}
+	if req.Body != nil {
+		_, _ = io.Copy(io.Discard, req.Body)
+	}
 	val, ok := pathParams["id"]
 	if !ok {
 		return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "id")
@@ -505,6 +535,9 @@ func request_RoleService_AddRoleGrantScopes_0(ctx context.Context, marshaler run
 	if err := marshaler.NewDecoder(req.Body).Decode(&protoReq); err != nil && !errors.Is(err, io.EOF) {
 		return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
 	}
+	if req.Body != nil {
+		_, _ = io.Copy(io.Discard, req.Body)
+	}
 	val, ok := pathParams["id"]
 	if !ok {
 		return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "id")
@@ -547,6 +580,9 @@ func request_RoleService_SetRoleGrantScopes_0(ctx context.Context, marshaler run
 	if err := marshaler.NewDecoder(req.Body).Decode(&protoReq); err != nil && !errors.Is(err, io.EOF) {
 		return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
 	}
+	if req.Body != nil {
+		_, _ = io.Copy(io.Discard, req.Body)
+	}
 	val, ok := pathParams["id"]
 	if !ok {
 		return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "id")
@@ -589,6 +625,9 @@ func request_RoleService_RemoveRoleGrantScopes_0(ctx context.Context, marshaler
 	if err := marshaler.NewDecoder(req.Body).Decode(&protoReq); err != nil && !errors.Is(err, io.EOF) {
 		return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
 	}
+	if req.Body != nil {
+		_, _ = io.Copy(io.Discard, req.Body)
+	}
 	val, ok := pathParams["id"]
 	if !ok {
 		return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "id")
@@ -1194,7 +1233,8 @@ type response_RoleService_GetRole_0 struct {
 }
 
 func (m response_RoleService_GetRole_0) XXX_ResponseBody() interface{} {
-	return m.Item
+	response := m.GetRoleResponse
+	return response.Item
 }
 
 type response_RoleService_CreateRole_0 struct {
@@ -1202,7 +1242,8 @@ type response_RoleService_CreateRole_0 struct {
 }
 
 func (m response_RoleService_CreateRole_0) XXX_ResponseBody() interface{} {
-	return m.Item
+	response := m.CreateRoleResponse
+	return response.Item
 }
 
 type response_RoleService_UpdateRole_0 struct {
@@ -1210,7 +1251,8 @@ type response_RoleService_UpdateRole_0 struct {
 }
 
 func (m response_RoleService_UpdateRole_0) XXX_ResponseBody() interface{} {
-	return m.Item
+	response := m.UpdateRoleResponse
+	return response.Item
 }
 
 type response_RoleService_AddRolePrincipals_0 struct {
@@ -1218,7 +1260,8 @@ type response_RoleService_AddRolePrincipals_0 struct {
 }
 
 func (m response_RoleService_AddRolePrincipals_0) XXX_ResponseBody() interface{} {
-	return m.Item
+	response := m.AddRolePrincipalsResponse
+	return response.Item
 }
 
 type response_RoleService_SetRolePrincipals_0 struct {
@@ -1226,7 +1269,8 @@ type response_RoleService_SetRolePrincipals_0 struct {
 }
 
 func (m response_RoleService_SetRolePrincipals_0) XXX_ResponseBody() interface{} {
-	return m.Item
+	response := m.SetRolePrincipalsResponse
+	return response.Item
 }
 
 type response_RoleService_RemoveRolePrincipals_0 struct {
@@ -1234,7 +1278,8 @@ type response_RoleService_RemoveRolePrincipals_0 struct {
 }
 
 func (m response_RoleService_RemoveRolePrincipals_0) XXX_ResponseBody() interface{} {
-	return m.Item
+	response := m.RemoveRolePrincipalsResponse
+	return response.Item
 }
 
 type response_RoleService_AddRoleGrants_0 struct {
@@ -1242,7 +1287,8 @@ type response_RoleService_AddRoleGrants_0 struct {
 }
 
 func (m response_RoleService_AddRoleGrants_0) XXX_ResponseBody() interface{} {
-	return m.Item
+	response := m.AddRoleGrantsResponse
+	return response.Item
 }
 
 type response_RoleService_SetRoleGrants_0 struct {
@@ -1250,7 +1296,8 @@ type response_RoleService_SetRoleGrants_0 struct {
 }
 
 func (m response_RoleService_SetRoleGrants_0) XXX_ResponseBody() interface{} {
-	return m.Item
+	response := m.SetRoleGrantsResponse
+	return response.Item
 }
 
 type response_RoleService_RemoveRoleGrants_0 struct {
@@ -1258,7 +1305,8 @@ type response_RoleService_RemoveRoleGrants_0 struct {
 }
 
 func (m response_RoleService_RemoveRoleGrants_0) XXX_ResponseBody() interface{} {
-	return m.Item
+	response := m.RemoveRoleGrantsResponse
+	return response.Item
 }
 
 type response_RoleService_AddRoleGrantScopes_0 struct {
@@ -1266,7 +1314,8 @@ type response_RoleService_AddRoleGrantScopes_0 struct {
 }
 
 func (m response_RoleService_AddRoleGrantScopes_0) XXX_ResponseBody() interface{} {
-	return m.Item
+	response := m.AddRoleGrantScopesResponse
+	return response.Item
 }
 
 type response_RoleService_SetRoleGrantScopes_0 struct {
@@ -1274,7 +1323,8 @@ type response_RoleService_SetRoleGrantScopes_0 struct {
 }
 
 func (m response_RoleService_SetRoleGrantScopes_0) XXX_ResponseBody() interface{} {
-	return m.Item
+	response := m.SetRoleGrantScopesResponse
+	return response.Item
 }
 
 type response_RoleService_RemoveRoleGrantScopes_0 struct {
@@ -1282,7 +1332,8 @@ type response_RoleService_RemoveRoleGrantScopes_0 struct {
 }
 
 func (m response_RoleService_RemoveRoleGrantScopes_0) XXX_ResponseBody() interface{} {
-	return m.Item
+	response := m.RemoveRoleGrantScopesResponse
+	return response.Item
 }
 
 var (

internal/gen/controller/api/services/scope_service.pb.gw.go

@@ -41,7 +41,9 @@ func request_ScopeService_GetScope_0(ctx context.Context, marshaler runtime.Mars
 		metadata runtime.ServerMetadata
 		err      error
 	)
-	io.Copy(io.Discard, req.Body)
+	if req.Body != nil {
+		_, _ = io.Copy(io.Discard, req.Body)
+	}
 	val, ok := pathParams["id"]
 	if !ok {
 		return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "id")
@@ -79,7 +81,9 @@ func request_ScopeService_ListScopes_0(ctx context.Context, marshaler runtime.Ma
 		protoReq ListScopesRequest
 		metadata runtime.ServerMetadata
 	)
-	io.Copy(io.Discard, req.Body)
+	if req.Body != nil {
+		_, _ = io.Copy(io.Discard, req.Body)
+	}
 	if err := req.ParseForm(); err != nil {
 		return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
 	}
@@ -115,6 +119,9 @@ func request_ScopeService_CreateScope_0(ctx context.Context, marshaler runtime.M
 	if err := marshaler.NewDecoder(req.Body).Decode(&protoReq.Item); err != nil && !errors.Is(err, io.EOF) {
 		return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
 	}
+	if req.Body != nil {
+		_, _ = io.Copy(io.Discard, req.Body)
+	}
 	if err := req.ParseForm(); err != nil {
 		return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
 	}
@@ -158,6 +165,9 @@ func request_ScopeService_UpdateScope_0(ctx context.Context, marshaler runtime.M
 	if err := marshaler.NewDecoder(newReader()).Decode(&protoReq.Item); err != nil && !errors.Is(err, io.EOF) {
 		return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
 	}
+	if req.Body != nil {
+		_, _ = io.Copy(io.Discard, req.Body)
+	}
 	if protoReq.UpdateMask == nil || len(protoReq.UpdateMask.GetPaths()) == 0 {
 		if fieldMask, err := runtime.FieldMaskFromRequestBody(newReader(), protoReq.Item); err != nil {
 			return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
@@ -227,7 +237,9 @@ func request_ScopeService_DeleteScope_0(ctx context.Context, marshaler runtime.M
 		metadata runtime.ServerMetadata
 		err      error
 	)
-	io.Copy(io.Discard, req.Body)
+	if req.Body != nil {
+		_, _ = io.Copy(io.Discard, req.Body)
+	}
 	val, ok := pathParams["id"]
 	if !ok {
 		return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "id")
@@ -264,7 +276,9 @@ func request_ScopeService_ListKeys_0(ctx context.Context, marshaler runtime.Mars
 		metadata runtime.ServerMetadata
 		err      error
 	)
-	io.Copy(io.Discard, req.Body)
+	if req.Body != nil {
+		_, _ = io.Copy(io.Discard, req.Body)
+	}
 	val, ok := pathParams["id"]
 	if !ok {
 		return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "id")
@@ -303,6 +317,9 @@ func request_ScopeService_RotateKeys_0(ctx context.Context, marshaler runtime.Ma
 	if err := marshaler.NewDecoder(req.Body).Decode(&protoReq); err != nil && !errors.Is(err, io.EOF) {
 		return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
 	}
+	if req.Body != nil {
+		_, _ = io.Copy(io.Discard, req.Body)
+	}
 	msg, err := client.RotateKeys(ctx, &protoReq, grpc.Header(&metadata.HeaderMD), grpc.Trailer(&metadata.TrailerMD))
 	return msg, metadata, err
 }
@@ -325,7 +342,9 @@ func request_ScopeService_ListKeyVersionDestructionJobs_0(ctx context.Context, m
 		metadata runtime.ServerMetadata
 		err      error
 	)
-	io.Copy(io.Discard, req.Body)
+	if req.Body != nil {
+		_, _ = io.Copy(io.Discard, req.Body)
+	}
 	val, ok := pathParams["scope_id"]
 	if !ok {
 		return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "scope_id")
@@ -364,6 +383,9 @@ func request_ScopeService_DestroyKeyVersion_0(ctx context.Context, marshaler run
 	if err := marshaler.NewDecoder(req.Body).Decode(&protoReq); err != nil && !errors.Is(err, io.EOF) {
 		return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
 	}
+	if req.Body != nil {
+		_, _ = io.Copy(io.Discard, req.Body)
+	}
 	msg, err := client.DestroyKeyVersion(ctx, &protoReq, grpc.Header(&metadata.HeaderMD), grpc.Trailer(&metadata.TrailerMD))
 	return msg, metadata, err
 }
@@ -389,6 +411,9 @@ func request_ScopeService_AttachStoragePolicy_0(ctx context.Context, marshaler r
 	if err := marshaler.NewDecoder(req.Body).Decode(&protoReq); err != nil && !errors.Is(err, io.EOF) {
 		return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
 	}
+	if req.Body != nil {
+		_, _ = io.Copy(io.Discard, req.Body)
+	}
 	val, ok := pathParams["id"]
 	if !ok {
 		return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "id")
@@ -431,6 +456,9 @@ func request_ScopeService_DetachStoragePolicy_0(ctx context.Context, marshaler r
 	if err := marshaler.NewDecoder(req.Body).Decode(&protoReq); err != nil && !errors.Is(err, io.EOF) {
 		return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
 	}
+	if req.Body != nil {
+		_, _ = io.Copy(io.Discard, req.Body)
+	}
 	val, ok := pathParams["id"]
 	if !ok {
 		return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "id")
@@ -925,7 +953,8 @@ type response_ScopeService_GetScope_0 struct {
 }
 
 func (m response_ScopeService_GetScope_0) XXX_ResponseBody() interface{} {
-	return m.Item
+	response := m.GetScopeResponse
+	return response.Item
 }
 
 type response_ScopeService_CreateScope_0 struct {
@@ -933,7 +962,8 @@ type response_ScopeService_CreateScope_0 struct {
 }
 
 func (m response_ScopeService_CreateScope_0) XXX_ResponseBody() interface{} {
-	return m.Item
+	response := m.CreateScopeResponse
+	return response.Item
 }
 
 type response_ScopeService_UpdateScope_0 struct {
@@ -941,7 +971,8 @@ type response_ScopeService_UpdateScope_0 struct {
 }
 
 func (m response_ScopeService_UpdateScope_0) XXX_ResponseBody() interface{} {
-	return m.Item
+	response := m.UpdateScopeResponse
+	return response.Item
 }
 
 type response_ScopeService_AttachStoragePolicy_0 struct {
@@ -949,7 +980,8 @@ type response_ScopeService_AttachStoragePolicy_0 struct {
 }
 
 func (m response_ScopeService_AttachStoragePolicy_0) XXX_ResponseBody() interface{} {
-	return m.Item
+	response := m.AttachStoragePolicyResponse
+	return response.Item
 }
 
 type response_ScopeService_DetachStoragePolicy_0 struct {
@@ -957,7 +989,8 @@ type response_ScopeService_DetachStoragePolicy_0 struct {
 }
 
 func (m response_ScopeService_DetachStoragePolicy_0) XXX_ResponseBody() interface{} {
-	return m.Item
+	response := m.DetachStoragePolicyResponse
+	return response.Item
 }
 
 var (

internal/gen/controller/api/services/session_recording_service.pb.gw.go

@@ -41,7 +41,9 @@ func request_SessionRecordingService_GetSessionRecording_0(ctx context.Context,
 		metadata runtime.ServerMetadata
 		err      error
 	)
-	io.Copy(io.Discard, req.Body)
+	if req.Body != nil {
+		_, _ = io.Copy(io.Discard, req.Body)
+	}
 	val, ok := pathParams["id"]
 	if !ok {
 		return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "id")
@@ -79,7 +81,9 @@ func request_SessionRecordingService_ListSessionRecordings_0(ctx context.Context
 		protoReq ListSessionRecordingsRequest
 		metadata runtime.ServerMetadata
 	)
-	io.Copy(io.Discard, req.Body)
+	if req.Body != nil {
+		_, _ = io.Copy(io.Discard, req.Body)
+	}
 	if err := req.ParseForm(); err != nil {
 		return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
 	}
@@ -113,7 +117,9 @@ func request_SessionRecordingService_Download_0(ctx context.Context, marshaler r
 		metadata runtime.ServerMetadata
 		err      error
 	)
-	io.Copy(io.Discard, req.Body)
+	if req.Body != nil {
+		_, _ = io.Copy(io.Discard, req.Body)
+	}
 	val, ok := pathParams["id"]
 	if !ok {
 		return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "id")
@@ -146,7 +152,9 @@ func request_SessionRecordingService_ReApplyStoragePolicy_0(ctx context.Context,
 		metadata runtime.ServerMetadata
 		err      error
 	)
-	io.Copy(io.Discard, req.Body)
+	if req.Body != nil {
+		_, _ = io.Copy(io.Discard, req.Body)
+	}
 	val, ok := pathParams["id"]
 	if !ok {
 		return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "id")
@@ -183,7 +191,9 @@ func request_SessionRecordingService_DeleteSessionRecording_0(ctx context.Contex
 		metadata runtime.ServerMetadata
 		err      error
 	)
-	io.Copy(io.Discard, req.Body)
+	if req.Body != nil {
+		_, _ = io.Copy(io.Discard, req.Body)
+	}
 	val, ok := pathParams["id"]
 	if !ok {
 		return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "id")
@@ -440,7 +450,8 @@ type response_SessionRecordingService_GetSessionRecording_0 struct {
 }
 
 func (m response_SessionRecordingService_GetSessionRecording_0) XXX_ResponseBody() interface{} {
-	return m.Item
+	response := m.GetSessionRecordingResponse
+	return response.Item
 }
 
 type response_SessionRecordingService_ReApplyStoragePolicy_0 struct {
@@ -448,7 +459,8 @@ type response_SessionRecordingService_ReApplyStoragePolicy_0 struct {
 }
 
 func (m response_SessionRecordingService_ReApplyStoragePolicy_0) XXX_ResponseBody() interface{} {
-	return m.Item
+	response := m.ReApplyStoragePolicyResponse
+	return response.Item
 }
 
 var (

internal/gen/controller/api/services/session_service.pb.gw.go

@@ -41,7 +41,9 @@ func request_SessionService_GetSession_0(ctx context.Context, marshaler runtime.
 		metadata runtime.ServerMetadata
 		err      error
 	)
-	io.Copy(io.Discard, req.Body)
+	if req.Body != nil {
+		_, _ = io.Copy(io.Discard, req.Body)
+	}
 	val, ok := pathParams["id"]
 	if !ok {
 		return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "id")
@@ -79,7 +81,9 @@ func request_SessionService_ListSessions_0(ctx context.Context, marshaler runtim
 		protoReq ListSessionsRequest
 		metadata runtime.ServerMetadata
 	)
-	io.Copy(io.Discard, req.Body)
+	if req.Body != nil {
+		_, _ = io.Copy(io.Discard, req.Body)
+	}
 	if err := req.ParseForm(); err != nil {
 		return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
 	}
@@ -114,6 +118,9 @@ func request_SessionService_CancelSession_0(ctx context.Context, marshaler runti
 	if err := marshaler.NewDecoder(req.Body).Decode(&protoReq); err != nil && !errors.Is(err, io.EOF) {
 		return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
 	}
+	if req.Body != nil {
+		_, _ = io.Copy(io.Discard, req.Body)
+	}
 	val, ok := pathParams["id"]
 	if !ok {
 		return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "id")
@@ -312,7 +319,8 @@ type response_SessionService_GetSession_0 struct {
 }
 
 func (m response_SessionService_GetSession_0) XXX_ResponseBody() interface{} {
-	return m.Item
+	response := m.GetSessionResponse
+	return response.Item
 }
 
 type response_SessionService_CancelSession_0 struct {
@@ -320,7 +328,8 @@ type response_SessionService_CancelSession_0 struct {
 }
 
 func (m response_SessionService_CancelSession_0) XXX_ResponseBody() interface{} {
-	return m.Item
+	response := m.CancelSessionResponse
+	return response.Item
 }
 
 var (

internal/gen/controller/api/services/storage_bucket_service.pb.gw.go

@@ -41,7 +41,9 @@ func request_StorageBucketService_GetStorageBucket_0(ctx context.Context, marsha
 		metadata runtime.ServerMetadata
 		err      error
 	)
-	io.Copy(io.Discard, req.Body)
+	if req.Body != nil {
+		_, _ = io.Copy(io.Discard, req.Body)
+	}
 	val, ok := pathParams["id"]
 	if !ok {
 		return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "id")
@@ -79,7 +81,9 @@ func request_StorageBucketService_ListStorageBuckets_0(ctx context.Context, mars
 		protoReq ListStorageBucketsRequest
 		metadata runtime.ServerMetadata
 	)
-	io.Copy(io.Discard, req.Body)
+	if req.Body != nil {
+		_, _ = io.Copy(io.Discard, req.Body)
+	}
 	if err := req.ParseForm(); err != nil {
 		return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
 	}
@@ -115,6 +119,9 @@ func request_StorageBucketService_CreateStorageBucket_0(ctx context.Context, mar
 	if err := marshaler.NewDecoder(req.Body).Decode(&protoReq.Item); err != nil && !errors.Is(err, io.EOF) {
 		return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
 	}
+	if req.Body != nil {
+		_, _ = io.Copy(io.Discard, req.Body)
+	}
 	if err := req.ParseForm(); err != nil {
 		return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
 	}
@@ -158,6 +165,9 @@ func request_StorageBucketService_UpdateStorageBucket_0(ctx context.Context, mar
 	if err := marshaler.NewDecoder(newReader()).Decode(&protoReq.Item); err != nil && !errors.Is(err, io.EOF) {
 		return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
 	}
+	if req.Body != nil {
+		_, _ = io.Copy(io.Discard, req.Body)
+	}
 	if protoReq.UpdateMask == nil || len(protoReq.UpdateMask.GetPaths()) == 0 {
 		if fieldMask, err := runtime.FieldMaskFromRequestBody(newReader(), protoReq.Item); err != nil {
 			return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
@@ -227,7 +237,9 @@ func request_StorageBucketService_DeleteStorageBucket_0(ctx context.Context, mar
 		metadata runtime.ServerMetadata
 		err      error
 	)
-	io.Copy(io.Discard, req.Body)
+	if req.Body != nil {
+		_, _ = io.Copy(io.Discard, req.Body)
+	}
 	val, ok := pathParams["id"]
 	if !ok {
 		return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "id")
@@ -497,7 +509,8 @@ type response_StorageBucketService_GetStorageBucket_0 struct {
 }
 
 func (m response_StorageBucketService_GetStorageBucket_0) XXX_ResponseBody() interface{} {
-	return m.Item
+	response := m.GetStorageBucketResponse
+	return response.Item
 }
 
 type response_StorageBucketService_CreateStorageBucket_0 struct {
@@ -505,7 +518,8 @@ type response_StorageBucketService_CreateStorageBucket_0 struct {
 }
 
 func (m response_StorageBucketService_CreateStorageBucket_0) XXX_ResponseBody() interface{} {
-	return m.Item
+	response := m.CreateStorageBucketResponse
+	return response.Item
 }
 
 type response_StorageBucketService_UpdateStorageBucket_0 struct {
@@ -513,7 +527,8 @@ type response_StorageBucketService_UpdateStorageBucket_0 struct {
 }
 
 func (m response_StorageBucketService_UpdateStorageBucket_0) XXX_ResponseBody() interface{} {
-	return m.Item
+	response := m.UpdateStorageBucketResponse
+	return response.Item
 }
 
 var (

internal/gen/controller/api/services/target_service.pb.gw.go

@@ -41,7 +41,9 @@ func request_TargetService_GetTarget_0(ctx context.Context, marshaler runtime.Ma
 		metadata runtime.ServerMetadata
 		err      error
 	)
-	io.Copy(io.Discard, req.Body)
+	if req.Body != nil {
+		_, _ = io.Copy(io.Discard, req.Body)
+	}
 	val, ok := pathParams["id"]
 	if !ok {
 		return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "id")
@@ -79,7 +81,9 @@ func request_TargetService_ListTargets_0(ctx context.Context, marshaler runtime.
 		protoReq ListTargetsRequest
 		metadata runtime.ServerMetadata
 	)
-	io.Copy(io.Discard, req.Body)
+	if req.Body != nil {
+		_, _ = io.Copy(io.Discard, req.Body)
+	}
 	if err := req.ParseForm(); err != nil {
 		return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
 	}
@@ -113,6 +117,9 @@ func request_TargetService_CreateTarget_0(ctx context.Context, marshaler runtime
 	if err := marshaler.NewDecoder(req.Body).Decode(&protoReq.Item); err != nil && !errors.Is(err, io.EOF) {
 		return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
 	}
+	if req.Body != nil {
+		_, _ = io.Copy(io.Discard, req.Body)
+	}
 	msg, err := client.CreateTarget(ctx, &protoReq, grpc.Header(&metadata.HeaderMD), grpc.Trailer(&metadata.TrailerMD))
 	return msg, metadata, err
 }
@@ -144,6 +151,9 @@ func request_TargetService_UpdateTarget_0(ctx context.Context, marshaler runtime
 	if err := marshaler.NewDecoder(newReader()).Decode(&protoReq.Item); err != nil && !errors.Is(err, io.EOF) {
 		return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
 	}
+	if req.Body != nil {
+		_, _ = io.Copy(io.Discard, req.Body)
+	}
 	if protoReq.UpdateMask == nil || len(protoReq.UpdateMask.GetPaths()) == 0 {
 		if fieldMask, err := runtime.FieldMaskFromRequestBody(newReader(), protoReq.Item); err != nil {
 			return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
@@ -213,7 +223,9 @@ func request_TargetService_DeleteTarget_0(ctx context.Context, marshaler runtime
 		metadata runtime.ServerMetadata
 		err      error
 	)
-	io.Copy(io.Discard, req.Body)
+	if req.Body != nil {
+		_, _ = io.Copy(io.Discard, req.Body)
+	}
 	val, ok := pathParams["id"]
 	if !ok {
 		return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "id")
@@ -253,6 +265,9 @@ func request_TargetService_AuthorizeSession_0(ctx context.Context, marshaler run
 	if err := marshaler.NewDecoder(req.Body).Decode(&protoReq); err != nil && !errors.Is(err, io.EOF) {
 		return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
 	}
+	if req.Body != nil {
+		_, _ = io.Copy(io.Discard, req.Body)
+	}
 	val, ok := pathParams["id"]
 	if !ok {
 		return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "id")
@@ -295,6 +310,9 @@ func request_TargetService_AddTargetHostSources_0(ctx context.Context, marshaler
 	if err := marshaler.NewDecoder(req.Body).Decode(&protoReq); err != nil && !errors.Is(err, io.EOF) {
 		return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
 	}
+	if req.Body != nil {
+		_, _ = io.Copy(io.Discard, req.Body)
+	}
 	val, ok := pathParams["id"]
 	if !ok {
 		return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "id")
@@ -337,6 +355,9 @@ func request_TargetService_SetTargetHostSources_0(ctx context.Context, marshaler
 	if err := marshaler.NewDecoder(req.Body).Decode(&protoReq); err != nil && !errors.Is(err, io.EOF) {
 		return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
 	}
+	if req.Body != nil {
+		_, _ = io.Copy(io.Discard, req.Body)
+	}
 	val, ok := pathParams["id"]
 	if !ok {
 		return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "id")
@@ -379,6 +400,9 @@ func request_TargetService_RemoveTargetHostSources_0(ctx context.Context, marsha
 	if err := marshaler.NewDecoder(req.Body).Decode(&protoReq); err != nil && !errors.Is(err, io.EOF) {
 		return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
 	}
+	if req.Body != nil {
+		_, _ = io.Copy(io.Discard, req.Body)
+	}
 	val, ok := pathParams["id"]
 	if !ok {
 		return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "id")
@@ -421,6 +445,9 @@ func request_TargetService_AddTargetCredentialSources_0(ctx context.Context, mar
 	if err := marshaler.NewDecoder(req.Body).Decode(&protoReq); err != nil && !errors.Is(err, io.EOF) {
 		return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
 	}
+	if req.Body != nil {
+		_, _ = io.Copy(io.Discard, req.Body)
+	}
 	val, ok := pathParams["id"]
 	if !ok {
 		return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "id")
@@ -463,6 +490,9 @@ func request_TargetService_SetTargetCredentialSources_0(ctx context.Context, mar
 	if err := marshaler.NewDecoder(req.Body).Decode(&protoReq); err != nil && !errors.Is(err, io.EOF) {
 		return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
 	}
+	if req.Body != nil {
+		_, _ = io.Copy(io.Discard, req.Body)
+	}
 	val, ok := pathParams["id"]
 	if !ok {
 		return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "id")
@@ -505,6 +535,9 @@ func request_TargetService_RemoveTargetCredentialSources_0(ctx context.Context,
 	if err := marshaler.NewDecoder(req.Body).Decode(&protoReq); err != nil && !errors.Is(err, io.EOF) {
 		return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
 	}
+	if req.Body != nil {
+		_, _ = io.Copy(io.Discard, req.Body)
+	}
 	val, ok := pathParams["id"]
 	if !ok {
 		return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "id")
@@ -1036,7 +1069,8 @@ type response_TargetService_GetTarget_0 struct {
 }
 
 func (m response_TargetService_GetTarget_0) XXX_ResponseBody() interface{} {
-	return m.Item
+	response := m.GetTargetResponse
+	return response.Item
 }
 
 type response_TargetService_CreateTarget_0 struct {
@@ -1044,7 +1078,8 @@ type response_TargetService_CreateTarget_0 struct {
 }
 
 func (m response_TargetService_CreateTarget_0) XXX_ResponseBody() interface{} {
-	return m.Item
+	response := m.CreateTargetResponse
+	return response.Item
 }
 
 type response_TargetService_UpdateTarget_0 struct {
@@ -1052,7 +1087,8 @@ type response_TargetService_UpdateTarget_0 struct {
 }
 
 func (m response_TargetService_UpdateTarget_0) XXX_ResponseBody() interface{} {
-	return m.Item
+	response := m.UpdateTargetResponse
+	return response.Item
 }
 
 type response_TargetService_AuthorizeSession_0 struct {
@@ -1060,7 +1096,8 @@ type response_TargetService_AuthorizeSession_0 struct {
 }
 
 func (m response_TargetService_AuthorizeSession_0) XXX_ResponseBody() interface{} {
-	return m.Item
+	response := m.AuthorizeSessionResponse
+	return response.Item
 }
 
 type response_TargetService_AddTargetHostSources_0 struct {
@@ -1068,7 +1105,8 @@ type response_TargetService_AddTargetHostSources_0 struct {
 }
 
 func (m response_TargetService_AddTargetHostSources_0) XXX_ResponseBody() interface{} {
-	return m.Item
+	response := m.AddTargetHostSourcesResponse
+	return response.Item
 }
 
 type response_TargetService_SetTargetHostSources_0 struct {
@@ -1076,7 +1114,8 @@ type response_TargetService_SetTargetHostSources_0 struct {
 }
 
 func (m response_TargetService_SetTargetHostSources_0) XXX_ResponseBody() interface{} {
-	return m.Item
+	response := m.SetTargetHostSourcesResponse
+	return response.Item
 }
 
 type response_TargetService_RemoveTargetHostSources_0 struct {
@@ -1084,7 +1123,8 @@ type response_TargetService_RemoveTargetHostSources_0 struct {
 }
 
 func (m response_TargetService_RemoveTargetHostSources_0) XXX_ResponseBody() interface{} {
-	return m.Item
+	response := m.RemoveTargetHostSourcesResponse
+	return response.Item
 }
 
 type response_TargetService_AddTargetCredentialSources_0 struct {
@@ -1092,7 +1132,8 @@ type response_TargetService_AddTargetCredentialSources_0 struct {
 }
 
 func (m response_TargetService_AddTargetCredentialSources_0) XXX_ResponseBody() interface{} {
-	return m.Item
+	response := m.AddTargetCredentialSourcesResponse
+	return response.Item
 }
 
 type response_TargetService_SetTargetCredentialSources_0 struct {
@@ -1100,7 +1141,8 @@ type response_TargetService_SetTargetCredentialSources_0 struct {
 }
 
 func (m response_TargetService_SetTargetCredentialSources_0) XXX_ResponseBody() interface{} {
-	return m.Item
+	response := m.SetTargetCredentialSourcesResponse
+	return response.Item
 }
 
 type response_TargetService_RemoveTargetCredentialSources_0 struct {
@@ -1108,7 +1150,8 @@ type response_TargetService_RemoveTargetCredentialSources_0 struct {
 }
 
 func (m response_TargetService_RemoveTargetCredentialSources_0) XXX_ResponseBody() interface{} {
-	return m.Item
+	response := m.RemoveTargetCredentialSourcesResponse
+	return response.Item
 }
 
 var (

internal/gen/controller/api/services/user_service.pb.gw.go

@@ -41,7 +41,9 @@ func request_UserService_GetUser_0(ctx context.Context, marshaler runtime.Marsha
 		metadata runtime.ServerMetadata
 		err      error
 	)
-	io.Copy(io.Discard, req.Body)
+	if req.Body != nil {
+		_, _ = io.Copy(io.Discard, req.Body)
+	}
 	val, ok := pathParams["id"]
 	if !ok {
 		return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "id")
@@ -79,7 +81,9 @@ func request_UserService_ListUsers_0(ctx context.Context, marshaler runtime.Mars
 		protoReq ListUsersRequest
 		metadata runtime.ServerMetadata
 	)
-	io.Copy(io.Discard, req.Body)
+	if req.Body != nil {
+		_, _ = io.Copy(io.Discard, req.Body)
+	}
 	if err := req.ParseForm(); err != nil {
 		return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
 	}
@@ -113,6 +117,9 @@ func request_UserService_CreateUser_0(ctx context.Context, marshaler runtime.Mar
 	if err := marshaler.NewDecoder(req.Body).Decode(&protoReq.Item); err != nil && !errors.Is(err, io.EOF) {
 		return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
 	}
+	if req.Body != nil {
+		_, _ = io.Copy(io.Discard, req.Body)
+	}
 	msg, err := client.CreateUser(ctx, &protoReq, grpc.Header(&metadata.HeaderMD), grpc.Trailer(&metadata.TrailerMD))
 	return msg, metadata, err
 }
@@ -144,6 +151,9 @@ func request_UserService_UpdateUser_0(ctx context.Context, marshaler runtime.Mar
 	if err := marshaler.NewDecoder(newReader()).Decode(&protoReq.Item); err != nil && !errors.Is(err, io.EOF) {
 		return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
 	}
+	if req.Body != nil {
+		_, _ = io.Copy(io.Discard, req.Body)
+	}
 	if protoReq.UpdateMask == nil || len(protoReq.UpdateMask.GetPaths()) == 0 {
 		if fieldMask, err := runtime.FieldMaskFromRequestBody(newReader(), protoReq.Item); err != nil {
 			return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
@@ -213,7 +223,9 @@ func request_UserService_DeleteUser_0(ctx context.Context, marshaler runtime.Mar
 		metadata runtime.ServerMetadata
 		err      error
 	)
-	io.Copy(io.Discard, req.Body)
+	if req.Body != nil {
+		_, _ = io.Copy(io.Discard, req.Body)
+	}
 	val, ok := pathParams["id"]
 	if !ok {
 		return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "id")
@@ -253,6 +265,9 @@ func request_UserService_AddUserAccounts_0(ctx context.Context, marshaler runtim
 	if err := marshaler.NewDecoder(req.Body).Decode(&protoReq); err != nil && !errors.Is(err, io.EOF) {
 		return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
 	}
+	if req.Body != nil {
+		_, _ = io.Copy(io.Discard, req.Body)
+	}
 	val, ok := pathParams["id"]
 	if !ok {
 		return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "id")
@@ -295,6 +310,9 @@ func request_UserService_SetUserAccounts_0(ctx context.Context, marshaler runtim
 	if err := marshaler.NewDecoder(req.Body).Decode(&protoReq); err != nil && !errors.Is(err, io.EOF) {
 		return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
 	}
+	if req.Body != nil {
+		_, _ = io.Copy(io.Discard, req.Body)
+	}
 	val, ok := pathParams["id"]
 	if !ok {
 		return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "id")
@@ -337,6 +355,9 @@ func request_UserService_RemoveUserAccounts_0(ctx context.Context, marshaler run
 	if err := marshaler.NewDecoder(req.Body).Decode(&protoReq); err != nil && !errors.Is(err, io.EOF) {
 		return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
 	}
+	if req.Body != nil {
+		_, _ = io.Copy(io.Discard, req.Body)
+	}
 	val, ok := pathParams["id"]
 	if !ok {
 		return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "id")
@@ -378,7 +399,9 @@ func request_UserService_ListResolvableAliases_0(ctx context.Context, marshaler
 		metadata runtime.ServerMetadata
 		err      error
 	)
-	io.Copy(io.Discard, req.Body)
+	if req.Body != nil {
+		_, _ = io.Copy(io.Discard, req.Body)
+	}
 	val, ok := pathParams["id"]
 	if !ok {
 		return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "id")
@@ -808,7 +831,8 @@ type response_UserService_GetUser_0 struct {
 }
 
 func (m response_UserService_GetUser_0) XXX_ResponseBody() interface{} {
-	return m.Item
+	response := m.GetUserResponse
+	return response.Item
 }
 
 type response_UserService_CreateUser_0 struct {
@@ -816,7 +840,8 @@ type response_UserService_CreateUser_0 struct {
 }
 
 func (m response_UserService_CreateUser_0) XXX_ResponseBody() interface{} {
-	return m.Item
+	response := m.CreateUserResponse
+	return response.Item
 }
 
 type response_UserService_UpdateUser_0 struct {
@@ -824,7 +849,8 @@ type response_UserService_UpdateUser_0 struct {
 }
 
 func (m response_UserService_UpdateUser_0) XXX_ResponseBody() interface{} {
-	return m.Item
+	response := m.UpdateUserResponse
+	return response.Item
 }
 
 type response_UserService_AddUserAccounts_0 struct {
@@ -832,7 +858,8 @@ type response_UserService_AddUserAccounts_0 struct {
 }
 
 func (m response_UserService_AddUserAccounts_0) XXX_ResponseBody() interface{} {
-	return m.Item
+	response := m.AddUserAccountsResponse
+	return response.Item
 }
 
 type response_UserService_SetUserAccounts_0 struct {
@@ -840,7 +867,8 @@ type response_UserService_SetUserAccounts_0 struct {
 }
 
 func (m response_UserService_SetUserAccounts_0) XXX_ResponseBody() interface{} {
-	return m.Item
+	response := m.SetUserAccountsResponse
+	return response.Item
 }
 
 type response_UserService_RemoveUserAccounts_0 struct {
@@ -848,7 +876,8 @@ type response_UserService_RemoveUserAccounts_0 struct {
 }
 
 func (m response_UserService_RemoveUserAccounts_0) XXX_ResponseBody() interface{} {
-	return m.Item
+	response := m.RemoveUserAccountsResponse
+	return response.Item
 }
 
 var (

internal/gen/controller/api/services/worker_service.pb.gw.go

@@ -41,7 +41,9 @@ func request_WorkerService_GetWorker_0(ctx context.Context, marshaler runtime.Ma
 		metadata runtime.ServerMetadata
 		err      error
 	)
-	io.Copy(io.Discard, req.Body)
+	if req.Body != nil {
+		_, _ = io.Copy(io.Discard, req.Body)
+	}
 	val, ok := pathParams["id"]
 	if !ok {
 		return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "id")
@@ -79,7 +81,9 @@ func request_WorkerService_ListWorkers_0(ctx context.Context, marshaler runtime.
 		protoReq ListWorkersRequest
 		metadata runtime.ServerMetadata
 	)
-	io.Copy(io.Discard, req.Body)
+	if req.Body != nil {
+		_, _ = io.Copy(io.Discard, req.Body)
+	}
 	if err := req.ParseForm(); err != nil {
 		return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
 	}
@@ -113,6 +117,9 @@ func request_WorkerService_CreateWorkerLed_0(ctx context.Context, marshaler runt
 	if err := marshaler.NewDecoder(req.Body).Decode(&protoReq.Item); err != nil && !errors.Is(err, io.EOF) {
 		return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
 	}
+	if req.Body != nil {
+		_, _ = io.Copy(io.Discard, req.Body)
+	}
 	msg, err := client.CreateWorkerLed(ctx, &protoReq, grpc.Header(&metadata.HeaderMD), grpc.Trailer(&metadata.TrailerMD))
 	return msg, metadata, err
 }
@@ -137,6 +144,9 @@ func request_WorkerService_CreateControllerLed_0(ctx context.Context, marshaler
 	if err := marshaler.NewDecoder(req.Body).Decode(&protoReq.Item); err != nil && !errors.Is(err, io.EOF) {
 		return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
 	}
+	if req.Body != nil {
+		_, _ = io.Copy(io.Discard, req.Body)
+	}
 	msg, err := client.CreateControllerLed(ctx, &protoReq, grpc.Header(&metadata.HeaderMD), grpc.Trailer(&metadata.TrailerMD))
 	return msg, metadata, err
 }
@@ -168,6 +178,9 @@ func request_WorkerService_UpdateWorker_0(ctx context.Context, marshaler runtime
 	if err := marshaler.NewDecoder(newReader()).Decode(&protoReq.Item); err != nil && !errors.Is(err, io.EOF) {
 		return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
 	}
+	if req.Body != nil {
+		_, _ = io.Copy(io.Discard, req.Body)
+	}
 	if protoReq.UpdateMask == nil || len(protoReq.UpdateMask.GetPaths()) == 0 {
 		if fieldMask, err := runtime.FieldMaskFromRequestBody(newReader(), protoReq.Item); err != nil {
 			return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
@@ -237,7 +250,9 @@ func request_WorkerService_DeleteWorker_0(ctx context.Context, marshaler runtime
 		metadata runtime.ServerMetadata
 		err      error
 	)
-	io.Copy(io.Discard, req.Body)
+	if req.Body != nil {
+		_, _ = io.Copy(io.Discard, req.Body)
+	}
 	val, ok := pathParams["id"]
 	if !ok {
 		return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "id")
@@ -277,6 +292,9 @@ func request_WorkerService_AddWorkerTags_0(ctx context.Context, marshaler runtim
 	if err := marshaler.NewDecoder(req.Body).Decode(&protoReq); err != nil && !errors.Is(err, io.EOF) {
 		return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
 	}
+	if req.Body != nil {
+		_, _ = io.Copy(io.Discard, req.Body)
+	}
 	val, ok := pathParams["id"]
 	if !ok {
 		return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "id")
@@ -319,6 +337,9 @@ func request_WorkerService_SetWorkerTags_0(ctx context.Context, marshaler runtim
 	if err := marshaler.NewDecoder(req.Body).Decode(&protoReq); err != nil && !errors.Is(err, io.EOF) {
 		return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
 	}
+	if req.Body != nil {
+		_, _ = io.Copy(io.Discard, req.Body)
+	}
 	val, ok := pathParams["id"]
 	if !ok {
 		return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "id")
@@ -361,6 +382,9 @@ func request_WorkerService_RemoveWorkerTags_0(ctx context.Context, marshaler run
 	if err := marshaler.NewDecoder(req.Body).Decode(&protoReq); err != nil && !errors.Is(err, io.EOF) {
 		return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
 	}
+	if req.Body != nil {
+		_, _ = io.Copy(io.Discard, req.Body)
+	}
 	val, ok := pathParams["id"]
 	if !ok {
 		return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "id")
@@ -401,7 +425,9 @@ func request_WorkerService_ReadCertificateAuthority_0(ctx context.Context, marsh
 		protoReq ReadCertificateAuthorityRequest
 		metadata runtime.ServerMetadata
 	)
-	io.Copy(io.Discard, req.Body)
+	if req.Body != nil {
+		_, _ = io.Copy(io.Discard, req.Body)
+	}
 	if err := req.ParseForm(); err != nil {
 		return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
 	}
@@ -434,7 +460,9 @@ func request_WorkerService_ReinitializeCertificateAuthority_0(ctx context.Contex
 		protoReq ReinitializeCertificateAuthorityRequest
 		metadata runtime.ServerMetadata
 	)
-	io.Copy(io.Discard, req.Body)
+	if req.Body != nil {
+		_, _ = io.Copy(io.Discard, req.Body)
+	}
 	if err := req.ParseForm(); err != nil {
 		return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
 	}
@@ -921,7 +949,8 @@ type response_WorkerService_GetWorker_0 struct {
 }
 
 func (m response_WorkerService_GetWorker_0) XXX_ResponseBody() interface{} {
-	return m.Item
+	response := m.GetWorkerResponse
+	return response.Item
 }
 
 type response_WorkerService_CreateWorkerLed_0 struct {
@@ -929,7 +958,8 @@ type response_WorkerService_CreateWorkerLed_0 struct {
 }
 
 func (m response_WorkerService_CreateWorkerLed_0) XXX_ResponseBody() interface{} {
-	return m.Item
+	response := m.CreateWorkerLedResponse
+	return response.Item
 }
 
 type response_WorkerService_CreateControllerLed_0 struct {
@@ -937,7 +967,8 @@ type response_WorkerService_CreateControllerLed_0 struct {
 }
 
 func (m response_WorkerService_CreateControllerLed_0) XXX_ResponseBody() interface{} {
-	return m.Item
+	response := m.CreateControllerLedResponse
+	return response.Item
 }
 
 type response_WorkerService_UpdateWorker_0 struct {
@@ -945,7 +976,8 @@ type response_WorkerService_UpdateWorker_0 struct {
 }
 
 func (m response_WorkerService_UpdateWorker_0) XXX_ResponseBody() interface{} {
-	return m.Item
+	response := m.UpdateWorkerResponse
+	return response.Item
 }
 
 type response_WorkerService_AddWorkerTags_0 struct {
@@ -953,7 +985,8 @@ type response_WorkerService_AddWorkerTags_0 struct {
 }
 
 func (m response_WorkerService_AddWorkerTags_0) XXX_ResponseBody() interface{} {
-	return m.Item
+	response := m.AddWorkerTagsResponse
+	return response.Item
 }
 
 type response_WorkerService_SetWorkerTags_0 struct {
@@ -961,7 +994,8 @@ type response_WorkerService_SetWorkerTags_0 struct {
 }
 
 func (m response_WorkerService_SetWorkerTags_0) XXX_ResponseBody() interface{} {
-	return m.Item
+	response := m.SetWorkerTagsResponse
+	return response.Item
 }
 
 type response_WorkerService_RemoveWorkerTags_0 struct {
@@ -969,7 +1003,8 @@ type response_WorkerService_RemoveWorkerTags_0 struct {
 }
 
 func (m response_WorkerService_RemoveWorkerTags_0) XXX_ResponseBody() interface{} {
-	return m.Item
+	response := m.RemoveWorkerTagsResponse
+	return response.Item
 }
 
 type response_WorkerService_ReadCertificateAuthority_0 struct {
@@ -977,7 +1012,8 @@ type response_WorkerService_ReadCertificateAuthority_0 struct {
 }
 
 func (m response_WorkerService_ReadCertificateAuthority_0) XXX_ResponseBody() interface{} {
-	return m.Item
+	response := m.ReadCertificateAuthorityResponse
+	return response.Item
 }
 
 type response_WorkerService_ReinitializeCertificateAuthority_0 struct {
@@ -985,7 +1021,8 @@ type response_WorkerService_ReinitializeCertificateAuthority_0 struct {
 }
 
 func (m response_WorkerService_ReinitializeCertificateAuthority_0) XXX_ResponseBody() interface{} {
-	return m.Item
+	response := m.ReinitializeCertificateAuthorityResponse
+	return response.Item
 }
 
 var (