diff options
Diffstat (limited to 'vendor/github.com/goamz/goamz/exp/sns/sns_test.go')
| -rw-r--r-- | vendor/github.com/goamz/goamz/exp/sns/sns_test.go | 455 |
1 files changed, 455 insertions, 0 deletions
diff --git a/vendor/github.com/goamz/goamz/exp/sns/sns_test.go b/vendor/github.com/goamz/goamz/exp/sns/sns_test.go new file mode 100644 index 000000000..054db13d3 --- /dev/null +++ b/vendor/github.com/goamz/goamz/exp/sns/sns_test.go @@ -0,0 +1,455 @@ +package sns_test + +import ( + "testing" + + "github.com/goamz/goamz/aws" + "github.com/goamz/goamz/exp/sns" + "github.com/goamz/goamz/testutil" + . "gopkg.in/check.v1" +) + +func Test(t *testing.T) { + TestingT(t) +} + +var _ = Suite(&S{}) + +type S struct { + sns *sns.SNS +} + +var testServer = testutil.NewHTTPServer() + +func (s *S) SetUpSuite(c *C) { + testServer.Start() + auth := aws.Auth{AccessKey: "abc", SecretKey: "123"} + s.sns = sns.New(auth, aws.Region{SNSEndpoint: testServer.URL}) +} + +func (s *S) TearDownTest(c *C) { + testServer.Flush() +} + +func (s *S) TestListTopicsOK(c *C) { + testServer.Response(200, nil, TestListTopicsXmlOK) + + resp, err := s.sns.ListTopics(nil) + req := testServer.WaitRequest() + + c.Assert(req.Method, Equals, "GET") + c.Assert(req.URL.Path, Equals, "/") + c.Assert(req.Header["Date"], Not(Equals), "") + + c.Assert(resp.Topics[0].SNS, Equals, s.sns) + c.Assert(resp.ResponseMetadata.RequestId, Equals, "bd10b26c-e30e-11e0-ba29-93c3aca2f103") + c.Assert(err, IsNil) +} + +func (s *S) TestCreateTopic(c *C) { + testServer.Response(200, nil, TestCreateTopicXmlOK) + + resp, err := s.sns.CreateTopic("My-Topic") + req := testServer.WaitRequest() + + c.Assert(req.Method, Equals, "GET") + c.Assert(req.URL.Path, Equals, "/") + c.Assert(req.Header["Date"], Not(Equals), "") + + c.Assert(resp.Topic.SNS, Equals, s.sns) + c.Assert(resp.Topic.TopicArn, Equals, "arn:aws:sns:us-east-1:123456789012:My-Topic") + c.Assert(resp.ResponseMetadata.RequestId, Equals, "a8dec8b3-33a4-11df-8963-01868b7c937a") + c.Assert(err, IsNil) +} + +func (s *S) TestDeleteTopic(c *C) { + testServer.Response(200, nil, TestDeleteTopicXmlOK) + + t := sns.Topic{s.sns, "arn:aws:sns:us-east-1:123456789012:My-Topic"} + resp, err := t.Delete() + req := testServer.WaitRequest() + + c.Assert(req.Method, Equals, "GET") + c.Assert(req.URL.Path, Equals, "/") + c.Assert(req.Header["Date"], Not(Equals), "") + + c.Assert(resp.ResponseMetadata.RequestId, Equals, "f3aa9ac9-3c3d-11df-8235-9dab105e9c32") + c.Assert(err, IsNil) +} + +func (s *S) TestListSubscriptions(c *C) { + testServer.Response(200, nil, TestListSubscriptionsXmlOK) + + resp, err := s.sns.ListSubscriptions(nil) + req := testServer.WaitRequest() + + c.Assert(req.Method, Equals, "GET") + c.Assert(req.URL.Path, Equals, "/") + c.Assert(req.Header["Date"], Not(Equals), "") + + c.Assert(len(resp.Subscriptions), Not(Equals), 0) + c.Assert(resp.Subscriptions[0].Protocol, Equals, "email") + c.Assert(resp.Subscriptions[0].Endpoint, Equals, "example@amazon.com") + c.Assert(resp.Subscriptions[0].SubscriptionArn, Equals, "arn:aws:sns:us-east-1:123456789012:My-Topic:80289ba6-0fd4-4079-afb4-ce8c8260f0ca") + c.Assert(resp.Subscriptions[0].TopicArn, Equals, "arn:aws:sns:us-east-1:698519295917:My-Topic") + c.Assert(resp.Subscriptions[0].Owner, Equals, "123456789012") + c.Assert(err, IsNil) +} + +func (s *S) TestGetTopicAttributes(c *C) { + testServer.Response(200, nil, TestGetTopicAttributesXmlOK) + + resp, err := s.sns.GetTopicAttributes("arn:aws:sns:us-east-1:123456789012:My-Topic") + req := testServer.WaitRequest() + + c.Assert(req.Method, Equals, "GET") + c.Assert(req.URL.Path, Equals, "/") + c.Assert(req.Header["Date"], Not(Equals), "") + + c.Assert(len(resp.Attributes), Not(Equals), 0) + c.Assert(resp.Attributes[0].Key, Equals, "Owner") + c.Assert(resp.Attributes[0].Value, Equals, "123456789012") + c.Assert(resp.Attributes[1].Key, Equals, "Policy") + c.Assert(resp.Attributes[1].Value, Equals, `{"Version":"2008-10-17","Id":"us-east-1/698519295917/test__default_policy_ID","Statement" : [{"Effect":"Allow","Sid":"us-east-1/698519295917/test__default_statement_ID","Principal" : {"AWS": "*"},"Action":["SNS:GetTopicAttributes","SNS:SetTopicAttributes","SNS:AddPermission","SNS:RemovePermission","SNS:DeleteTopic","SNS:Subscribe","SNS:ListSubscriptionsByTopic","SNS:Publish","SNS:Receive"],"Resource":"arn:aws:sns:us-east-1:698519295917:test","Condition" : {"StringLike" : {"AWS:SourceArn": "arn:aws:*:*:698519295917:*"}}}]}`) + c.Assert(resp.ResponseMetadata.RequestId, Equals, "057f074c-33a7-11df-9540-99d0768312d3") + c.Assert(err, IsNil) +} + +func (s *S) TestPublish(c *C) { + testServer.Response(200, nil, TestPublishXmlOK) + + pubOpt := &sns.PublishOpt{"foobar", "", "subject", "arn:aws:sns:us-east-1:123456789012:My-Topic"} + resp, err := s.sns.Publish(pubOpt) + req := testServer.WaitRequest() + + c.Assert(req.Method, Equals, "GET") + c.Assert(req.URL.Path, Equals, "/") + c.Assert(req.Header["Date"], Not(Equals), "") + + c.Assert(resp.MessageId, Equals, "94f20ce6-13c5-43a0-9a9e-ca52d816e90b") + c.Assert(resp.ResponseMetadata.RequestId, Equals, "f187a3c1-376f-11df-8963-01868b7c937a") + c.Assert(err, IsNil) +} + +func (s *S) TestSetTopicAttributes(c *C) { + testServer.Response(200, nil, TestSetTopicAttributesXmlOK) + + resp, err := s.sns.SetTopicAttributes("DisplayName", "MyTopicName", "arn:aws:sns:us-east-1:123456789012:My-Topic") + req := testServer.WaitRequest() + + c.Assert(req.Method, Equals, "GET") + c.Assert(req.URL.Path, Equals, "/") + c.Assert(req.Header["Date"], Not(Equals), "") + + c.Assert(resp.ResponseMetadata.RequestId, Equals, "a8763b99-33a7-11df-a9b7-05d48da6f042") + c.Assert(err, IsNil) +} + +func (s *S) TestSubscribe(c *C) { + testServer.Response(200, nil, TestSubscribeXmlOK) + + resp, err := s.sns.Subscribe("example@amazon.com", "email", "arn:aws:sns:us-east-1:123456789012:My-Topic") + req := testServer.WaitRequest() + + c.Assert(req.Method, Equals, "GET") + c.Assert(req.URL.Path, Equals, "/") + c.Assert(req.Header["Date"], Not(Equals), "") + + c.Assert(resp.SubscriptionArn, Equals, "pending confirmation") + c.Assert(resp.ResponseMetadata.RequestId, Equals, "a169c740-3766-11df-8963-01868b7c937a") + c.Assert(err, IsNil) +} + +func (s *S) TestUnsubscribe(c *C) { + testServer.Response(200, nil, TestUnsubscribeXmlOK) + + resp, err := s.sns.Unsubscribe("arn:aws:sns:us-east-1:123456789012:My-Topic:a169c740-3766-11df-8963-01868b7c937a") + req := testServer.WaitRequest() + + c.Assert(req.Method, Equals, "GET") + c.Assert(req.URL.Path, Equals, "/") + c.Assert(req.Header["Date"], Not(Equals), "") + + c.Assert(resp.ResponseMetadata.RequestId, Equals, "18e0ac39-3776-11df-84c0-b93cc1666b84") + c.Assert(err, IsNil) +} + +func (s *S) TestConfirmSubscription(c *C) { + testServer.Response(200, nil, TestConfirmSubscriptionXmlOK) + + opt := &sns.ConfirmSubscriptionOpt{"", "51b2ff3edb475b7d91550e0ab6edf0c1de2a34e6ebaf6", "arn:aws:sns:us-east-1:123456789012:My-Topic"} + resp, err := s.sns.ConfirmSubscription(opt) + req := testServer.WaitRequest() + + c.Assert(req.Method, Equals, "GET") + c.Assert(req.URL.Path, Equals, "/") + c.Assert(req.Header["Date"], Not(Equals), "") + + c.Assert(resp.SubscriptionArn, Equals, "arn:aws:sns:us-east-1:123456789012:My-Topic:80289ba6-0fd4-4079-afb4-ce8c8260f0ca") + c.Assert(resp.ResponseMetadata.RequestId, Equals, "7a50221f-3774-11df-a9b7-05d48da6f042") + c.Assert(err, IsNil) +} + +func (s *S) TestAddPermission(c *C) { + testServer.Response(200, nil, TestAddPermissionXmlOK) + perm := make([]sns.Permission, 2) + perm[0].ActionName = "Publish" + perm[1].ActionName = "GetTopicAttributes" + perm[0].AccountId = "987654321000" + perm[1].AccountId = "876543210000" + + resp, err := s.sns.AddPermission(perm, "NewPermission", "arn:aws:sns:us-east-1:123456789012:My-Topic") + req := testServer.WaitRequest() + + c.Assert(req.Method, Equals, "GET") + c.Assert(req.URL.Path, Equals, "/") + c.Assert(req.Header["Date"], Not(Equals), "") + + c.Assert(resp.RequestId, Equals, "6a213e4e-33a8-11df-9540-99d0768312d3") + c.Assert(err, IsNil) +} + +func (s *S) TestRemovePermission(c *C) { + testServer.Response(200, nil, TestRemovePermissionXmlOK) + + resp, err := s.sns.RemovePermission("NewPermission", "arn:aws:sns:us-east-1:123456789012:My-Topic") + req := testServer.WaitRequest() + + c.Assert(req.Method, Equals, "GET") + c.Assert(req.URL.Path, Equals, "/") + c.Assert(req.Header["Date"], Not(Equals), "") + + c.Assert(resp.RequestId, Equals, "d170b150-33a8-11df-995a-2d6fbe836cc1") + c.Assert(err, IsNil) +} + +func (s *S) TestListSubscriptionByTopic(c *C) { + testServer.Response(200, nil, TestListSubscriptionsByTopicXmlOK) + + opt := &sns.ListSubscriptionByTopicOpt{"", "arn:aws:sns:us-east-1:123456789012:My-Topic"} + resp, err := s.sns.ListSubscriptionByTopic(opt) + req := testServer.WaitRequest() + + c.Assert(req.Method, Equals, "GET") + c.Assert(req.URL.Path, Equals, "/") + c.Assert(req.Header["Date"], Not(Equals), "") + + c.Assert(len(resp.Subscriptions), Not(Equals), 0) + c.Assert(resp.Subscriptions[0].TopicArn, Equals, "arn:aws:sns:us-east-1:123456789012:My-Topic") + c.Assert(resp.Subscriptions[0].SubscriptionArn, Equals, "arn:aws:sns:us-east-1:123456789012:My-Topic:80289ba6-0fd4-4079-afb4-ce8c8260f0ca") + c.Assert(resp.Subscriptions[0].Owner, Equals, "123456789012") + c.Assert(resp.Subscriptions[0].Endpoint, Equals, "example@amazon.com") + c.Assert(resp.Subscriptions[0].Protocol, Equals, "email") + c.Assert(err, IsNil) +} + +func (s *S) TestCreatePlatformApplication(c *C) { + testServer.Response(200, nil, TestCreatePlatformApplicationXmlOK) + + attrs := []sns.AttributeEntry{ + sns.AttributeEntry{Key: "PlatformCredential", Value: "AIzaSyClE2lcV2zEKTLYYo645zfk2jhQPFeyxDo"}, + sns.AttributeEntry{Key: "PlatformPrincipal", Value: "There is no principal for GCM"}, + } + opt := &sns.PlatformApplicationOpt{Name: "gcmpushapp", Platform: "GCM", Attributes: attrs} + resp, err := s.sns.CreatePlatformApplication(opt) + req := testServer.WaitRequest() + + c.Assert(req.Method, Equals, "GET") + c.Assert(req.URL.Path, Equals, "/") + c.Assert(req.Header["Date"], Not(Equals), "") + + c.Assert(resp.PlatformApplicationArn, Equals, "arn:aws:sns:us-west-2:123456789012:app/GCM/gcmpushapp") + c.Assert(resp.RequestId, Equals, "b6f0e78b-e9d4-5a0e-b973-adc04e8a4ff9") + + c.Assert(err, IsNil) +} + +func (s *S) TestCreatePlatformEndpoint(c *C) { + testServer.Response(200, nil, TestCreatePlatformEndpointXmlOK) + + opt := &sns.PlatformEndpointOpt{PlatformApplicationArn: "arn:aws:sns:us-west-2:123456789012:app/GCM/gcmpushapp", + CustomUserData: "UserId=27576823", Token: "APA91bGi7fFachkC1xjlqT66VYEucGHochmf1VQAr9k...jsM0PKPxKhddCzx6paEsyay9Zn3D4wNUJb8m6HZrBEXAMPLE"} + + resp, err := s.sns.CreatePlatformEndpoint(opt) + req := testServer.WaitRequest() + + c.Assert(req.Method, Equals, "GET") + c.Assert(req.URL.Path, Equals, "/") + c.Assert(req.Header["Date"], Not(Equals), "") + + c.Assert(resp.EndpointArn, Equals, "arn:aws:sns:us-west-2:123456789012:endpoint/GCM/gcmpushapp/5e3e9847-3183-3f18-a7e8-671c3a57d4b3") + c.Assert(resp.RequestId, Equals, "6613341d-3e15-53f7-bf3c-7e56994ba278") + + c.Assert(err, IsNil) +} + +func (s *S) TestDeleteEndpoint(c *C) { + testServer.Response(200, nil, DeleteEndpointXmlOK) + + resp, err := s.sns.DeleteEndpoint("arn:aws:sns:us-west-2:123456789012:endpoint/GCM%/gcmpushapp/5e3e9847-3183-3f18-a7e8-671c3a57d4b3") + req := testServer.WaitRequest() + + c.Assert(req.Method, Equals, "GET") + c.Assert(req.URL.Path, Equals, "/") + c.Assert(req.Header["Date"], Not(Equals), "") + + c.Assert(resp.RequestId, Equals, "c1d2b191-353c-5a5f-8969-fbdd3900afa8") + + c.Assert(err, IsNil) +} + +func (s *S) TestDeletePlatformApplication(c *C) { + testServer.Response(200, nil, TestDeletePlatformApplicationXmlOK) + + resp, err := s.sns.DeletePlatformApplication("arn:aws:sns:us-west-2:123456789012:app/GCM/gcmpushapp") + req := testServer.WaitRequest() + + c.Assert(req.Method, Equals, "GET") + c.Assert(req.URL.Path, Equals, "/") + c.Assert(req.Header["Date"], Not(Equals), "") + + c.Assert(resp.RequestId, Equals, "097dac18-7a77-5823-a8dd-e65476dcb037") + + c.Assert(err, IsNil) +} + +func (s *S) TestGetEndpointAttributes(c *C) { + testServer.Response(200, nil, TestGetEndpointAttributesXmlOK) + + resp, err := s.sns.GetEndpointAttributes("arn:aws:sns:us-west-2:123456789012:endpoint/GCM/gcmpushapp/5e3e9847-3183-3f18-a7e8-671c3a57d4b3") + req := testServer.WaitRequest() + + c.Assert(req.Method, Equals, "GET") + c.Assert(req.URL.Path, Equals, "/") + c.Assert(req.Header["Date"], Not(Equals), "") + + c.Assert(len(resp.Attributes), Equals, 3) + c.Assert(resp.Attributes[0].Key, Equals, "Enabled") + c.Assert(resp.Attributes[0].Value, Equals, "true") + + c.Assert(resp.Attributes[1].Key, Equals, "CustomUserData") + c.Assert(resp.Attributes[1].Value, Equals, "UserId=01234567") + + c.Assert(resp.Attributes[2].Key, Equals, "Token") + c.Assert(resp.Attributes[2].Value, Equals, "APA91bGi7fFachkC1xjlqT66VYEucGHochmf1VQAr9k...jsM0PKPxKhddCzx6paEsyay9Zn3D4wNUJb8m6HZrBEXAMPLE") + + c.Assert(resp.RequestId, Equals, "6c725a19-a142-5b77-94f9-1055a9ea04e7") + + c.Assert(err, IsNil) +} + +func (s *S) TestGetPlatformApplicationAttributes(c *C) { + testServer.Response(200, nil, TestGetPlatformApplicationAttributesXmlOK) + + resp, err := s.sns.GetPlatformApplicationAttributes("arn:aws:sns:us-west-2:123456789012:app/GCM/gcmpushapp", "") + req := testServer.WaitRequest() + + c.Assert(req.Method, Equals, "GET") + c.Assert(req.URL.Path, Equals, "/") + c.Assert(req.Header["Date"], Not(Equals), "") + + c.Assert(len(resp.Attributes), Not(Equals), 0) + c.Assert(resp.Attributes[0].Key, Equals, "AllowEndpointPolicies") + c.Assert(resp.Attributes[0].Value, Equals, "false") + c.Assert(resp.RequestId, Equals, "74848df2-87f6-55ed-890c-c7be80442462") + + c.Assert(err, IsNil) +} + +func (s *S) TestListEndpointsByPlatformApplication(c *C) { + testServer.Response(200, nil, TestListEndpointsByPlatformApplicationXmlOK) + + resp, err := s.sns.ListEndpointsByPlatformApplication("arn:aws:sns:us-west-2:123456789012:app/GCM/gcmpushapp", "") + req := testServer.WaitRequest() + + c.Assert(req.Method, Equals, "GET") + c.Assert(req.URL.Path, Equals, "/") + c.Assert(req.Header["Date"], Not(Equals), "") + + c.Assert(len(resp.Endpoints), Not(Equals), 0) + c.Assert(resp.Endpoints[0].EndpointArn, Equals, "arn:aws:sns:us-west-2:123456789012:endpoint/GCM/gcmpushapp/5e3e9847-3183-3f18-a7e8-671c3a57d4b3") + c.Assert(len(resp.Endpoints[0].Attributes), Equals, 3) + c.Assert(resp.Endpoints[0].Attributes[0].Key, Equals, "Enabled") + c.Assert(resp.Endpoints[0].Attributes[0].Value, Equals, "true") + c.Assert(resp.Endpoints[0].Attributes[1].Key, Equals, "CustomUserData") + c.Assert(resp.Endpoints[0].Attributes[1].Value, Equals, "UserId=27576823") + c.Assert(resp.Endpoints[0].Attributes[2].Key, Equals, "Token") + c.Assert(resp.Endpoints[0].Attributes[2].Value, Equals, "APA91bGi7fFachkC1xjlqT66VYEucGHochmf1VQAr9k...jsM0PKPxKhddCzx6paEsyay9Zn3D4wNUJb8m6HZrBEXAMPLE") + + c.Assert(resp.RequestId, Equals, "9a48768c-dac8-5a60-aec0-3cc27ea08d96") + + c.Assert(err, IsNil) +} + +func (s *S) TestListPlatformApplications(c *C) { + testServer.Response(200, nil, TestListPlatformApplicationsXmlOK) + + resp, err := s.sns.ListPlatformApplications("") + req := testServer.WaitRequest() + + c.Assert(req.Method, Equals, "GET") + c.Assert(req.URL.Path, Equals, "/") + c.Assert(req.Header["Date"], Not(Equals), "") + + c.Assert(len(resp.PlatformApplications), Not(Equals), 0) + + c.Assert(resp.PlatformApplications[0].PlatformApplicationArn, Equals, "arn:aws:sns:us-west-2:123456789012:app/APNS_SANDBOX/apnspushapp") + c.Assert(len(resp.PlatformApplications[0].Attributes), Equals, 1) + c.Assert(resp.PlatformApplications[0].Attributes[0].Key, Equals, "AllowEndpointPolicies") + c.Assert(resp.PlatformApplications[0].Attributes[0].Value, Equals, "false") + + c.Assert(resp.PlatformApplications[1].PlatformApplicationArn, Equals, "arn:aws:sns:us-west-2:123456789012:app/GCM/gcmpushapp") + c.Assert(len(resp.PlatformApplications[1].Attributes), Equals, 1) + c.Assert(resp.PlatformApplications[1].Attributes[0].Key, Equals, "AllowEndpointPolicies") + c.Assert(resp.PlatformApplications[1].Attributes[0].Value, Equals, "false") + + c.Assert(resp.RequestId, Equals, "315a335e-85d8-52df-9349-791283cbb529") + + c.Assert(err, IsNil) +} + +func (s *S) TestSetEndpointAttributes(c *C) { + testServer.Response(200, nil, TestSetEndpointAttributesXmlOK) + + attrs := []sns.AttributeEntry{ + sns.AttributeEntry{Key: "CustomUserData", Value: "My custom userdata"}, + } + + opts := &sns.SetEndpointAttributesOpt{ + EndpointArn: "arn:aws:sns:us-west-2:123456789012:endpoint/GCM/gcmpushapp/5e3e9847-3183-3f18-a7e8-671c3a57d4b3", + Attributes: attrs} + + resp, err := s.sns.SetEndpointAttributes(opts) + req := testServer.WaitRequest() + + c.Assert(req.Method, Equals, "GET") + c.Assert(req.URL.Path, Equals, "/") + c.Assert(req.Header["Date"], Not(Equals), "") + + c.Assert(resp.RequestId, Equals, "2fe0bfc7-3e85-5ee5-a9e2-f58b35e85f6a") + + c.Assert(err, IsNil) +} + +func (s *S) TestSetPlatformApplicationAttributes(c *C) { + testServer.Response(200, nil, TestSetPlatformApplicationAttributesXmlOK) + + attrs := []sns.AttributeEntry{ + sns.AttributeEntry{Key: "EventEndpointCreated", Value: "arn:aws:sns:us-west-2:123456789012:topicarn"}, + } + + opts := &sns.SetPlatformApplicationAttributesOpt{ + PlatformApplicationArn: "arn:aws:sns:us-west-2:123456789012:app/GCM/gcmpushapp", + Attributes: attrs} + + resp, err := s.sns.SetPlatformApplicationAttributes(opts) + req := testServer.WaitRequest() + + c.Assert(req.Method, Equals, "GET") + c.Assert(req.URL.Path, Equals, "/") + c.Assert(req.Header["Date"], Not(Equals), "") + + c.Assert(resp.RequestId, Equals, "cf577bcc-b3dc-5463-88f1-3180b9412395") + + c.Assert(err, IsNil) +} |