Source file src/github.com/aws/aws-sdk-go-v2/internal/auth/smithy/v4signer_adapter.go

Documentation: github.com/aws/aws-sdk-go-v2/internal/auth/smithy

     1  package smithy
     2  
     3  import (
     4  	"context"
     5  	"fmt"
     6  
     7  	v4 "github.com/aws/aws-sdk-go-v2/aws/signer/v4"
     8  	"github.com/aws/aws-sdk-go-v2/internal/sdk"
     9  	"github.com/aws/smithy-go"
    10  	"github.com/aws/smithy-go/auth"
    11  	"github.com/aws/smithy-go/logging"
    12  	smithyhttp "github.com/aws/smithy-go/transport/http"
    13  )
    14  
    15  // V4SignerAdapter adapts v4.HTTPSigner to smithy http.Signer.
    16  type V4SignerAdapter struct {
    17  	Signer     v4.HTTPSigner
    18  	Logger     logging.Logger
    19  	LogSigning bool
    20  }
    21  
    22  var _ (smithyhttp.Signer) = (*V4SignerAdapter)(nil)
    23  
    24  // SignRequest signs the request with the provided identity.
    25  func (v *V4SignerAdapter) SignRequest(ctx context.Context, r *smithyhttp.Request, identity auth.Identity, props smithy.Properties) error {
    26  	ca, ok := identity.(*CredentialsAdapter)
    27  	if !ok {
    28  		return fmt.Errorf("unexpected identity type: %T", identity)
    29  	}
    30  
    31  	name, ok := smithyhttp.GetSigV4SigningName(&props)
    32  	if !ok {
    33  		return fmt.Errorf("sigv4 signing name is required")
    34  	}
    35  
    36  	region, ok := smithyhttp.GetSigV4SigningRegion(&props)
    37  	if !ok {
    38  		return fmt.Errorf("sigv4 signing region is required")
    39  	}
    40  
    41  	hash := v4.GetPayloadHash(ctx)
    42  	err := v.Signer.SignHTTP(ctx, ca.Credentials, r.Request, hash, name, region, sdk.NowTime(), func(o *v4.SignerOptions) {
    43  		o.DisableURIPathEscaping, _ = smithyhttp.GetDisableDoubleEncoding(&props)
    44  
    45  		o.Logger = v.Logger
    46  		o.LogSigning = v.LogSigning
    47  	})
    48  	if err != nil {
    49  		return fmt.Errorf("sign http: %w", err)
    50  	}
    51  
    52  	return nil
    53  }
    54  

View as plain text