Skip to content

Commit c05e5e9

Browse files
authored
fix: Event Streams tokenProvider needs to honor configuration for IAMEndpoint (#6239)
1 parent 601a399 commit c05e5e9

File tree

1 file changed

+7
-3
lines changed

1 file changed

+7
-3
lines changed

ibm/service/eventstreams/resource_ibm_event_streams_topic.go

Lines changed: 7 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -16,7 +16,6 @@ import (
1616
"github.com/IBM-Cloud/terraform-provider-ibm/ibm/flex"
1717
"github.com/IBM-Cloud/terraform-provider-ibm/version"
1818
"github.com/IBM/go-sdk-core/v5/core"
19-
iamidentity "github.com/IBM/platform-services-go-sdk/iamidentityv1"
2019
"github.com/IBM/sarama"
2120
"github.com/hashicorp/terraform-plugin-sdk/v2/diag"
2221
"github.com/hashicorp/terraform-plugin-sdk/v2/helper/schema"
@@ -366,14 +365,19 @@ type accessTokenProvider struct {
366365
}
367366

368367
func newAccessTokenProvider(sess *session.Session) (*accessTokenProvider, error) {
368+
iamEndpoint, err := sess.Config.EndpointLocator.IAMEndpoint()
369+
if err != nil {
370+
log.Printf("[DEBUG] newAccessTokenProvider.IAMEndpoint() error:%s", err)
371+
return nil, err
372+
}
369373
authenticator, err := core.NewIamAuthenticatorBuilder().
370-
SetURL(conns.EnvFallBack([]string{"IBMCLOUD_IAM_API_ENDPOINT"}, iamidentity.DefaultServiceURL)).
374+
SetURL(iamEndpoint).
371375
SetApiKey(sess.Config.BluemixAPIKey).
372376
SetRefreshToken(sess.Config.IAMRefreshToken).
373377
SetClientIDSecret("bx", "bx").
374378
Build()
375379
if err != nil {
376-
log.Printf("[DEBUG] newAccessTokenProvider() error:%s", err)
380+
log.Printf("[DEBUG] newAccessTokenProvider.NewIamAuthenticatorBuilder() error:%s", err)
377381
return nil, err
378382
}
379383
return &accessTokenProvider{authenticator}, nil

0 commit comments

Comments
 (0)