customizations_test.go 2.4 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990
  1. // +build !integration
  2. package glacier_test
  3. import (
  4. "bytes"
  5. "testing"
  6. "github.com/stretchr/testify/assert"
  7. "github.com/aws/aws-sdk-go/aws"
  8. "github.com/aws/aws-sdk-go/aws/awsutil"
  9. "github.com/aws/aws-sdk-go/awstesting/unit"
  10. "github.com/aws/aws-sdk-go/service/glacier"
  11. )
  12. var (
  13. payloadBuf = func() *bytes.Reader {
  14. buf := make([]byte, 5767168) // 5.5MB buffer
  15. for i := range buf {
  16. buf[i] = '0' // Fill with zero characters
  17. }
  18. return bytes.NewReader(buf)
  19. }()
  20. svc = glacier.New(unit.Session)
  21. )
  22. func TestCustomizations(t *testing.T) {
  23. req, _ := svc.UploadArchiveRequest(&glacier.UploadArchiveInput{
  24. VaultName: aws.String("vault"),
  25. Body: payloadBuf,
  26. })
  27. err := req.Build()
  28. assert.NoError(t, err)
  29. // Sets API version
  30. assert.Equal(t, req.ClientInfo.APIVersion, req.HTTPRequest.Header.Get("x-amz-glacier-version"))
  31. // Sets Account ID
  32. v, _ := awsutil.ValuesAtPath(req.Params, "AccountId")
  33. assert.Equal(t, "-", *(v[0].(*string)))
  34. // Computes checksums
  35. linear := "68aff0c5a91aa0491752bfb96e3fef33eb74953804f6a2f7b708d5bcefa8ff6b"
  36. tree := "154e26c78fd74d0c2c9b3cc4644191619dc4f2cd539ae2a74d5fd07957a3ee6a"
  37. assert.Equal(t, linear, req.HTTPRequest.Header.Get("x-amz-content-sha256"))
  38. assert.Equal(t, tree, req.HTTPRequest.Header.Get("x-amz-sha256-tree-hash"))
  39. }
  40. func TestShortcircuitTreehash(t *testing.T) {
  41. req, _ := svc.UploadArchiveRequest(&glacier.UploadArchiveInput{
  42. VaultName: aws.String("vault"),
  43. Body: payloadBuf,
  44. Checksum: aws.String("000"),
  45. })
  46. err := req.Build()
  47. assert.NoError(t, err)
  48. assert.Equal(t, "000", req.HTTPRequest.Header.Get("x-amz-sha256-tree-hash"))
  49. }
  50. func TestFillAccountIDWithNilStruct(t *testing.T) {
  51. req, _ := svc.ListVaultsRequest(nil)
  52. err := req.Build()
  53. assert.NoError(t, err)
  54. empty := "e3b0c44298fc1c149afbf4c8996fb92427ae41e4649b934ca495991b7852b855"
  55. // Sets Account ID
  56. v, _ := awsutil.ValuesAtPath(req.Params, "AccountId")
  57. assert.Equal(t, "-", *(v[0].(*string)))
  58. // Does not set tree hash
  59. assert.Equal(t, empty, req.HTTPRequest.Header.Get("x-amz-content-sha256"))
  60. assert.Equal(t, "", req.HTTPRequest.Header.Get("x-amz-sha256-tree-hash"))
  61. }
  62. func TestHashOnce(t *testing.T) {
  63. req, _ := svc.UploadArchiveRequest(&glacier.UploadArchiveInput{
  64. VaultName: aws.String("vault"),
  65. Body: payloadBuf,
  66. })
  67. req.HTTPRequest.Header.Set("X-Amz-Sha256-Tree-Hash", "0")
  68. err := req.Build()
  69. assert.NoError(t, err)
  70. assert.Equal(t, "0", req.HTTPRequest.Header.Get("x-amz-sha256-tree-hash"))
  71. }