fix(aws): update close if aws auth provider is nil (#3607)

Signed-off-by: Samantha Coyle <sam@diagrid.io>
Co-authored-by: Yaron Schneider <schneider.yaron@live.com>

bindings/aws/dynamodb/dynamodb.go

@@ -122,5 +122,8 @@ func (d *DynamoDB) GetComponentMetadata() (metadataInfo metadata.MetadataMap) {
 }
 
 func (d *DynamoDB) Close() error {
+	if d.authProvider != nil {
 		return d.authProvider.Close()
+	}
+	return nil
 }

bindings/aws/kinesis/kinesis.go

@@ -266,7 +266,10 @@ func (a *AWSKinesis) Close() error {
 		close(a.closeCh)
 	}
 	a.wg.Wait()
+	if a.authProvider != nil {
 		return a.authProvider.Close()
+	}
+	return nil
 }
 
 func (a *AWSKinesis) ensureConsumer(ctx context.Context, streamARN *string) (*string, error) {

bindings/aws/s3/s3.go

@@ -153,7 +153,10 @@ func (s *AWSS3) Init(ctx context.Context, metadata bindings.Metadata) error {
 }
 
 func (s *AWSS3) Close() error {
+	if s.authProvider != nil {
 		return s.authProvider.Close()
+	}
+	return nil
 }
 
 func (s *AWSS3) Operations() []bindings.OperationKind {

bindings/aws/ses/ses.go

@@ -176,5 +176,8 @@ func (a *AWSSES) GetComponentMetadata() (metadataInfo contribMetadata.MetadataMa
 }
 
 func (a *AWSSES) Close() error {
+	if a.authProvider != nil {
 		return a.authProvider.Close()
+	}
+	return nil
 }

bindings/aws/sns/sns.go

@@ -128,5 +128,8 @@ func (a *AWSSNS) GetComponentMetadata() (metadataInfo metadata.MetadataMap) {
 }
 
 func (a *AWSSNS) Close() error {
+	if a.authProvider != nil {
 		return a.authProvider.Close()
+	}
+	return nil
 }

bindings/aws/sqs/sqs.go

@@ -173,7 +173,10 @@ func (a *AWSSQS) Close() error {
 		close(a.closeCh)
 	}
 	a.wg.Wait()
+	if a.authProvider != nil {
 		return a.authProvider.Close()
+	}
+	return nil
 }
 
 func (a *AWSSQS) parseSQSMetadata(meta bindings.Metadata) (*sqsMetadata, error) {

pubsub/aws/snssqs/snssqs.go

@@ -875,7 +875,10 @@ func (s *snsSqs) Close() error {
 		s.subscriptionManager.Close()
 	}
 
+	if s.authProvider != nil {
 		return s.authProvider.Close()
+	}
+	return nil
 }
 
 func (s *snsSqs) Features() []pubsub.Feature {

secretstores/aws/parameterstore/parameterstore.go

@@ -182,5 +182,8 @@ func (s *ssmSecretStore) GetComponentMetadata() (metadataInfo metadata.MetadataM
 }
 
 func (s *ssmSecretStore) Close() error {
+	if s.authProvider != nil {
 		return s.authProvider.Close()
+	}
+	return nil
 }

secretstores/aws/secretmanager/secretmanager.go

@@ -170,5 +170,8 @@ func (s *smSecretStore) GetComponentMetadata() (metadataInfo metadata.MetadataMa
 }
 
 func (s *smSecretStore) Close() error {
+	if s.authProvider != nil {
 		return s.authProvider.Close()
+	}
+	return nil
 }

state/aws/dynamodb/dynamodb.go

@@ -275,7 +275,10 @@ func (d *StateStore) GetComponentMetadata() (metadataInfo metadata.MetadataMap)
 }
 
 func (d *StateStore) Close() error {
+	if d.authProvider != nil {
 		return d.authProvider.Close()
+	}
+	return nil
 }
 
 func (d *StateStore) getDynamoDBMetadata(meta state.Metadata) (*dynamoDBMetadata, error) {