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
|
// ses_test
package ses_test
import (
"bytes"
"net/url"
"testing"
"github.com/goamz/goamz/aws"
"github.com/goamz/goamz/exp/ses"
"github.com/goamz/goamz/testutil"
. "gopkg.in/check.v1"
)
func Test(t *testing.T) {
TestingT(t)
}
type S struct {
ses *ses.SES
}
var _ = Suite(&S{})
var testServer = testutil.NewHTTPServer()
func (s *S) SetUpSuite(c *C) {
testServer.Start()
auth := aws.Auth{AccessKey: "abc", SecretKey: "123"}
s.ses = ses.NewSES(auth, aws.Region{Name: "faux-region-1", S3Endpoint: testServer.URL})
}
func (s *S) TearDownStrategy(c *C) {
}
func (s *S) SetUpTest(c *C) {
}
func (s *S) TearDownTest(c *C) {
testServer.Flush()
}
func (s *S) TestSendEmail(c *C) {
testServer.Response(200, nil, "")
email := ses.NewEmail()
email.AddTo("test@test.com")
email.AddSource("test@test.com")
email.SetSubject("test")
email.SetBodyHtml("test")
s.ses.SendEmail(email)
req := testServer.WaitRequest()
c.Assert(req.Method, Equals, "POST")
c.Assert(req.Header["Date"], Not(Equals), "")
buf := new(bytes.Buffer)
buf.ReadFrom(req.Body)
body, _ := url.ParseQuery(buf.String())
c.Assert(body, Not(IsNil))
c.Assert(body["Destination.ToAddresses.member.1"], Equals, "test@test.com")
c.Assert(body["Source"], Equals, "test@test.com")
c.Assert(body["Message.Subject.Data"], Equals, "test")
c.Assert(body["Message.Body.Html.Data"], Equals, "test")
}
|
