File: checksum_middleware_test.go

package info (click to toggle)
golang-github-aws-smithy-go 1.20.3-1
  • links: PTS, VCS
  • area: main
  • in suites: forky, sid, trixie
  • size: 3,116 kB
  • sloc: java: 19,678; xml: 166; sh: 131; makefile: 70
file content (85 lines) | stat: -rw-r--r-- 2,089 bytes parent folder | download | duplicates (3)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
package http

import (
	"bytes"
	"context"
	"io"
	"strings"
	"testing"

	smithyio "github.com/aws/smithy-go/io"
	"github.com/aws/smithy-go/middleware"
)

func TestChecksumMiddleware(t *testing.T) {
	cases := map[string]struct {
		payload               io.Reader
		expectedPayloadLength int64
		expectedMD5Checksum   string
		expectError           string
	}{
		"empty body": {
			payload: smithyio.ReadSeekNopCloser{
				ReadSeeker: bytes.NewReader([]byte(``)),
			},
			expectedPayloadLength: 0,
			expectedMD5Checksum:   "1B2M2Y8AsgTpgAmY7PhCfg==",
		},
		"standard req body": {
			payload: smithyio.ReadSeekNopCloser{
				ReadSeeker: bytes.NewReader([]byte(`abc`)),
			},
			expectedPayloadLength: 3,
			expectedMD5Checksum:   "kAFQmDzST7DWlj99KOF/cg==",
		},
		"nil body": {},
		"unseekable payload": {
			payload:     bytes.NewBuffer([]byte(`xyz`)),
			expectError: "unseekable stream is not supported",
		},
	}

	for name, c := range cases {
		t.Run(name, func(t *testing.T) {
			var err error
			req := NewStackRequest().(*Request)

			req, err = req.SetStream(c.payload)
			if err != nil {
				t.Fatalf("error setting request stream")
			}
			m := contentMD5Checksum{}
			_, _, err = m.HandleBuild(context.Background(),
				middleware.BuildInput{Request: req},
				nopBuildHandler,
			)

			if len(c.expectError) != 0 {
				if err == nil {
					t.Fatalf("expect error, got none")
				}
				if e, a := c.expectError, err.Error(); !strings.Contains(a, e) {
					t.Fatalf("expect error to contain %q, got %v", e, a)
				}
				return
			} else if err != nil {
				t.Fatalf("expect no error, got %v", err)
			}

			if e, a := c.expectedMD5Checksum, req.Header.Get(contentMD5Header); e != a {
				t.Errorf("expect md5 checksum : %v, got %v", e, a)
			}

			size, ok, err := req.StreamLength()
			if err != nil {
				t.Fatalf("error fetching request stream length")
			}
			if !ok {
				t.Fatalf("request stream is not seekable")
			}
			if e, a := c.expectedPayloadLength, size; e != a {
				t.Fatalf("expected request stream content length to be %v, got length %v", e, a)
			}
		})
	}
}