diff options
Diffstat (limited to 'client/lib/rendezvous_sqs.go')
| -rw-r--r-- | client/lib/rendezvous_sqs.go | 10 |
1 files changed, 8 insertions, 2 deletions
diff --git a/client/lib/rendezvous_sqs.go b/client/lib/rendezvous_sqs.go index 423545f..6b1c073 100644 --- a/client/lib/rendezvous_sqs.go +++ b/client/lib/rendezvous_sqs.go @@ -16,6 +16,7 @@ import ( "github.com/aws/aws-sdk-go-v2/service/sqs" "github.com/aws/aws-sdk-go-v2/service/sqs/types" "gitlab.torproject.org/tpo/anti-censorship/pluggable-transports/snowflake/v2/common/sqsclient" + sqscreds "gitlab.torproject.org/tpo/anti-censorship/pluggable-transports/snowflake/v2/common/sqscreds/lib" ) type sqsRendezvous struct { @@ -26,12 +27,17 @@ type sqsRendezvous struct { numRetries int } -func newSQSRendezvous(sqsQueue string, sqsAccessKeyId string, sqsSecretKey string, transport http.RoundTripper) (*sqsRendezvous, error) { +func newSQSRendezvous(sqsQueue string, sqsCredsStr string, transport http.RoundTripper) (*sqsRendezvous, error) { sqsURL, err := url.Parse(sqsQueue) if err != nil { return nil, err } + sqsCreds, err := sqscreds.AwsCredsFromBase64(sqsCredsStr) + if err != nil { + return nil, err + } + queueURL := sqsURL.String() hostName := sqsURL.Hostname() @@ -43,7 +49,7 @@ func newSQSRendezvous(sqsQueue string, sqsAccessKeyId string, sqsSecretKey strin region := res[1] cfg, err := config.LoadDefaultConfig(context.TODO(), config.WithCredentialsProvider( - credentials.NewStaticCredentialsProvider(sqsAccessKeyId, sqsSecretKey, ""), + credentials.NewStaticCredentialsProvider(sqsCreds.AwsAccessKeyId, sqsCreds.AwsSecretKey, ""), ), config.WithRegion(region), ) |