-
-
Notifications
You must be signed in to change notification settings - Fork 461
/
source_body_test.go
78 lines (64 loc) · 1.63 KB
/
source_body_test.go
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
package main
import (
"io/ioutil"
"net/http"
"net/http/httptest"
"net/url"
"os"
"testing"
)
const fixtureFile = "testdata/large.jpg"
func TestSourceBodyMatch(t *testing.T) {
u, _ := url.Parse("http://foo")
req := &http.Request{Method: http.MethodPost, URL: u}
source := NewBodyImageSource(&SourceConfig{})
if !source.Matches(req) {
t.Error("Cannot match the request")
}
}
func TestBodyImageSource(t *testing.T) {
var body []byte
var err error
source := NewBodyImageSource(&SourceConfig{})
fakeHandler := func(w http.ResponseWriter, r *http.Request) {
if !source.Matches(r) {
t.Fatal("Cannot match the request")
}
body, err = source.GetImage(r)
if err != nil {
t.Fatalf("Error while reading the body: %s", err)
}
_, _ = w.Write(body)
}
file, _ := os.Open(fixtureFile)
r, _ := http.NewRequest(http.MethodPost, "http://foo/bar", file)
w := httptest.NewRecorder()
fakeHandler(w, r)
buf, _ := ioutil.ReadFile(fixtureFile)
if len(body) != len(buf) {
t.Error("Invalid response body")
}
}
func testReadBody(t *testing.T) {
var body []byte
var err error
source := NewBodyImageSource(&SourceConfig{})
fakeHandler := func(w http.ResponseWriter, r *http.Request) {
if !source.Matches(r) {
t.Fatal("Cannot match the request")
}
body, err = source.GetImage(r)
if err != nil {
t.Fatalf("Error while reading the body: %s", err)
}
_, _ = w.Write(body)
}
file, _ := os.Open(fixtureFile)
r, _ := http.NewRequest(http.MethodPost, "http://foo/bar", file)
w := httptest.NewRecorder()
fakeHandler(w, r)
buf, _ := ioutil.ReadFile(fixtureFile)
if len(body) != len(buf) {
t.Error("Invalid response body")
}
}