Fix bug: AWS_SESSION_TOKEN never passed (#173)

antoninodimaggio · Tony DiMaggio · web-flow · commit 62b5f634d756 · 2025-01-15T10:51:05.000+05:30
* Fix bug: AWS_SESSION_TOKEN never passed

* Bump version files

---------

Co-authored-by: Tony DiMaggio &lt;tonydimaggio@Tonys-MacBook-Pro.local&gt;
diff --git a/aws-kinesis-http-connector/version b/aws-kinesis-http-connector/version
@@ -1 +1 @@
-v0.15
+v0.16
diff --git a/aws-sqs-http-connector/version b/aws-sqs-http-connector/version
@@ -1 +1 @@
-v0.16
+v0.17
diff --git a/common/util.go b/common/util.go
@@ -133,7 +133,7 @@ func GetAwsConfig() (*aws.Config, error) {
 	}
 	if os.Getenv("AWS_ACCESS_KEY_ID") != "" && os.Getenv("AWS_SECRET_ACCESS_KEY") != "" {
 		config.Credentials = credentials.NewStaticCredentials(os.Getenv("AWS_ACCESS_KEY_ID"),
-			os.Getenv("AWS_SECRET_ACCESS_KEY"), "")
+			os.Getenv("AWS_SECRET_ACCESS_KEY"), os.Getenv("AWS_SESSION_TOKEN"))
 		return config, nil
 	}
 	if os.Getenv("AWS_CRED_PATH") != "" && os.Getenv("AWS_CRED_PROFILE") != "" {

Original file line number	Diff line number	Diff line change
`@@ -133,7 +133,7 @@ func GetAwsConfig() (*aws.Config, error) {`
`133`	`133`	`}`
`134`	`134`	`if os.Getenv("AWS_ACCESS_KEY_ID") != "" && os.Getenv("AWS_SECRET_ACCESS_KEY") != "" {`
`135`	`135`	`config.Credentials = credentials.NewStaticCredentials(os.Getenv("AWS_ACCESS_KEY_ID"),`
`136`		`- os.Getenv("AWS_SECRET_ACCESS_KEY"), "")`
	`136`	`+ os.Getenv("AWS_SECRET_ACCESS_KEY"), os.Getenv("AWS_SESSION_TOKEN"))`
`137`	`137`	`return config, nil`
`138`	`138`	`}`
`139`	`139`	`if os.Getenv("AWS_CRED_PATH") != "" && os.Getenv("AWS_CRED_PROFILE") != "" {`