credentials_adapter.go

 1package smithy
 2
 3import (
 4	"context"
 5	"fmt"
 6	"time"
 7
 8	"github.com/aws/aws-sdk-go-v2/aws"
 9	"github.com/aws/smithy-go"
10	"github.com/aws/smithy-go/auth"
11)
12
13// CredentialsAdapter adapts aws.Credentials to auth.Identity.
14type CredentialsAdapter struct {
15	Credentials aws.Credentials
16}
17
18var _ auth.Identity = (*CredentialsAdapter)(nil)
19
20// Expiration returns the time of expiration for the credentials.
21func (v *CredentialsAdapter) Expiration() time.Time {
22	return v.Credentials.Expires
23}
24
25// CredentialsProviderAdapter adapts aws.CredentialsProvider to auth.IdentityResolver.
26type CredentialsProviderAdapter struct {
27	Provider aws.CredentialsProvider
28}
29
30var _ (auth.IdentityResolver) = (*CredentialsProviderAdapter)(nil)
31
32// GetIdentity retrieves AWS credentials using the underlying provider.
33func (v *CredentialsProviderAdapter) GetIdentity(ctx context.Context, _ smithy.Properties) (
34	auth.Identity, error,
35) {
36	if v.Provider == nil {
37		return &CredentialsAdapter{Credentials: aws.Credentials{}}, nil
38	}
39
40	creds, err := v.Provider.Retrieve(ctx)
41	if err != nil {
42		return nil, fmt.Errorf("get credentials: %w", err)
43	}
44
45	return &CredentialsAdapter{Credentials: creds}, nil
46}