http://git-wip-us.apache.org/repos/asf/usergrid-dotnet/blob/94c0483c/Usergrid.Sdk.Tests/ConnectionManagerTests.cs ---------------------------------------------------------------------- diff --git a/Usergrid.Sdk.Tests/ConnectionManagerTests.cs b/Usergrid.Sdk.Tests/ConnectionManagerTests.cs new file mode 100644 index 0000000..cbe536e --- /dev/null +++ b/Usergrid.Sdk.Tests/ConnectionManagerTests.cs @@ -0,0 +1,240 @@ +// Licensed to the Apache Software Foundation (ASF) under one or more +// contributor license agreements. See the NOTICE file distributed with +// this work for additional information regarding copyright ownership. +// The ASF licenses this file to You under the Apache License, Version 2.0 +// (the "License"); you may not use this file except in compliance with +// the License. You may obtain a copy of the License at +// +// http://www.apache.org/licenses/LICENSE-2.0 +// +// Unless required by applicable law or agreed to in writing, software +// distributed under the License is distributed on an "AS IS" BASIS, +// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. +// See the License for the specific language governing permissions and +// limitations under the License. + + +using System.Collections.Generic; +using System.Net; +using NSubstitute; +using NUnit.Framework; +using RestSharp; +using Usergrid.Sdk.Manager; +using Usergrid.Sdk.Model; +using Usergrid.Sdk.Payload; + +namespace Usergrid.Sdk.Tests +{ + [TestFixture] + public class ConnectionManagerTests + { + [SetUp] + public void Setup() + { + _request = Substitute.For<IUsergridRequest>(); + _connectionManager = new ConnectionManager(_request); + } + + private IUsergridRequest _request; + private ConnectionManager _connectionManager; + + [Test] + public void CreateConnectionShouldPostToCorrectEndpoint() { + var connection = new Connection + { + ConnectorCollectionName = "users", + ConnectorIdentifier = "userName", + ConnecteeCollectionName = "devices", + ConnecteeIdentifier = "deviceName", + ConnectionName = "has" + }; + IRestResponse restResponse = Helpers.SetUpRestResponse(HttpStatusCode.OK); + + _request + .ExecuteJsonRequest(Arg.Any<string>(), Arg.Any<Method>(), Arg.Any<object>()) + .Returns(restResponse); + + _connectionManager.CreateConnection(connection); + + _request + .Received(1) + .ExecuteJsonRequest( + "/users/userName/has/devices/deviceName", + Method.POST); + } + + [Test] + public void CreateConnectionShouldThrowUsergridExceptionWhenBadResponse() { + var connection = new Connection(); + var restResponseContent = new UsergridError {Description = "Exception message", Error = "error code"}; + IRestResponse<LoginResponse> restResponseWithBadRequest = Helpers.SetUpRestResponseWithContent<LoginResponse>(HttpStatusCode.BadRequest, restResponseContent); + + _request + .ExecuteJsonRequest(Arg.Any<string>(), Arg.Any<Method>(), Arg.Any<object>()) + .Returns(restResponseWithBadRequest); + + try + { + _connectionManager.CreateConnection(connection); + new AssertionException("UserGridException was expected to be thrown here"); + } + catch (UsergridException e) + { + Assert.AreEqual("error code", e.ErrorCode); + Assert.AreEqual("Exception message", e.Message); + } + } + + [Test] + public void GetConnectionsReturnsConnectionsAsList() + { + var connection = new Connection + { + ConnectorCollectionName = "users", + ConnectorIdentifier = "userName", + ConnectionName = "has" + }; + + var expectedEntities = new List<UsergridEntity>(); + var responseData = new UsergridGetResponse<UsergridEntity>() {Entities = expectedEntities}; + IRestResponse restResponse = Helpers.SetUpRestResponseWithContent<UsergridGetResponse<UsergridEntity>>(HttpStatusCode.OK, responseData); + + _request + .ExecuteJsonRequest(Arg.Any<string>(), Arg.Any<Method>(), Arg.Any<object>()) + .Returns(restResponse); + + var returnedEntities = _connectionManager.GetConnections(connection); + + _request + .Received(1) + .ExecuteJsonRequest("/users/userName/has",Method.GET); + Assert.AreEqual(expectedEntities, returnedEntities); + } + + [Test] + public void GetConnectionsReturnsNullWhenConnectionIsNotFound() + { + var connection = new Connection + { + ConnectorCollectionName = "users", + ConnectorIdentifier = "userName", + ConnectionName = "has" + }; + IRestResponse restResponse = Helpers.SetUpRestResponse(HttpStatusCode.NotFound); + + _request + .ExecuteJsonRequest(Arg.Any<string>(), Arg.Any<Method>(), Arg.Any<object>()) + .Returns(restResponse); + + var returnedEntities = _connectionManager.GetConnections(connection); + + _request + .Received(1) + .ExecuteJsonRequest("/users/userName/has",Method.GET); + + Assert.IsNull(returnedEntities); + } + + [Test] + public void GetConnectionsOfSpecificTypeReturnsConnectionsAsListOfConnecteeType() + { + var connection = new Connection + { + ConnectorCollectionName = "users", + ConnectorIdentifier = "userName", + ConnecteeCollectionName = "devices", + ConnectionName = "has" + }; + var expectedEntities = new List<UsergridDevice>(); + var responseData = new UsergridGetResponse<UsergridDevice>() { Entities = expectedEntities }; + IRestResponse restResponse = Helpers.SetUpRestResponseWithContent<UsergridGetResponse<UsergridDevice>>(HttpStatusCode.OK, responseData); + + _request + .ExecuteJsonRequest(Arg.Any<string>(), Arg.Any<Method>(), Arg.Any<object>()) + .Returns(restResponse); + + var returnedEntities = _connectionManager.GetConnections<UsergridDevice>(connection); + + _request + .Received(1) + .ExecuteJsonRequest("/users/userName/has/devices", Method.GET); + Assert.AreEqual(expectedEntities, returnedEntities); + } + + [Test] + public void GetConnectionsOfSpecificTypeReturnsNullWhenConnectionIsNotFound() + { + var connection = new Connection + { + ConnectorCollectionName = "users", + ConnectorIdentifier = "userName", + ConnecteeCollectionName = "devices", + ConnectionName = "has" + }; + IRestResponse restResponse = Helpers.SetUpRestResponse(HttpStatusCode.NotFound); + + _request + .ExecuteJsonRequest(Arg.Any<string>(), Arg.Any<Method>(), Arg.Any<object>()) + .Returns(restResponse); + + var returnedEntities = _connectionManager.GetConnections<UsergridDevice>(connection); + + _request + .Received(1) + .ExecuteJsonRequest("/users/userName/has/devices",Method.GET); + + Assert.IsNull(returnedEntities); + } + + + [Test] + public void DeleteConnectionShouldDeleteToCorrectEndpoint() + { + var connection = new Connection + { + ConnectorCollectionName = "users", + ConnectorIdentifier = "userName", + ConnecteeCollectionName = "devices", + ConnecteeIdentifier = "deviceName", + ConnectionName = "has" + }; + IRestResponse restResponse = Helpers.SetUpRestResponse(HttpStatusCode.OK); + + _request + .ExecuteJsonRequest(Arg.Any<string>(), Arg.Any<Method>(), Arg.Any<object>()) + .Returns(restResponse); + + _connectionManager.DeleteConnection(connection); + + _request + .Received(1) + .ExecuteJsonRequest( + "/users/userName/has/devices/deviceName", + Method.DELETE); + } + + [Test] + public void DeleteConnectionShouldThrowUsergridExceptionWhenBadResponse() + { + var connection = new Connection(); + var restResponseContent = new UsergridError { Description = "Exception message", Error = "error code" }; + IRestResponse<LoginResponse> restResponseWithBadRequest = Helpers.SetUpRestResponseWithContent<LoginResponse>(HttpStatusCode.BadRequest, restResponseContent); + + _request + .ExecuteJsonRequest(Arg.Any<string>(), Arg.Any<Method>(), Arg.Any<object>()) + .Returns(restResponseWithBadRequest); + + try + { + _connectionManager.DeleteConnection(connection); + new AssertionException("UserGridException was expected to be thrown here"); + } + catch (UsergridException e) + { + Assert.AreEqual("error code", e.ErrorCode); + Assert.AreEqual("Exception message", e.Message); + } + } + + } +}
http://git-wip-us.apache.org/repos/asf/usergrid-dotnet/blob/94c0483c/Usergrid.Sdk.Tests/EntityManagerTests.cs ---------------------------------------------------------------------- diff --git a/Usergrid.Sdk.Tests/EntityManagerTests.cs b/Usergrid.Sdk.Tests/EntityManagerTests.cs new file mode 100644 index 0000000..4d3456b --- /dev/null +++ b/Usergrid.Sdk.Tests/EntityManagerTests.cs @@ -0,0 +1,440 @@ +// Licensed to the Apache Software Foundation (ASF) under one or more +// contributor license agreements. See the NOTICE file distributed with +// this work for additional information regarding copyright ownership. +// The ASF licenses this file to You under the Apache License, Version 2.0 +// (the "License"); you may not use this file except in compliance with +// the License. You may obtain a copy of the License at +// +// http://www.apache.org/licenses/LICENSE-2.0 +// +// Unless required by applicable law or agreed to in writing, software +// distributed under the License is distributed on an "AS IS" BASIS, +// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. +// See the License for the specific language governing permissions and +// limitations under the License. + + +using System; +using System.Collections.Generic; +using System.Net; +using NSubstitute; +using NUnit.Framework; +using RestSharp; +using Usergrid.Sdk.Manager; +using Usergrid.Sdk.Model; +using Usergrid.Sdk.Payload; + +namespace Usergrid.Sdk.Tests +{ + [TestFixture] + public class EntityManagerTests + { + + [SetUp] + public void Setup() + { + _request = Substitute.For<IUsergridRequest>(); + _entityManager = new EntityManager(_request); + } + + private IUsergridRequest _request; + private EntityManager _entityManager; + + [Test] + public void CreateEntityShouldPostToCorrectEndPoint() + { + const string collectionName = "collection"; + var entityToPost = new Friend {Name = "name1", Age = 1}; + var restResponseContent = new UsergridGetResponse<Friend> {Entities = new List<Friend> {entityToPost}, Cursor = "cursor"}; + IRestResponse<UsergridGetResponse<Friend>> restResponse = Helpers.SetUpRestResponseWithContent<UsergridGetResponse<Friend>>(HttpStatusCode.OK, restResponseContent); + _request + .ExecuteJsonRequest(Arg.Any<string>(), Arg.Any<Method>(), Arg.Any<object>()) + .Returns(restResponse); + + Friend returnedEntity = _entityManager.CreateEntity(collectionName, entityToPost); + + _request.Received(1).ExecuteJsonRequest( + Arg.Is(string.Format("/{0}", collectionName)), + Arg.Is(Method.POST), + Arg.Is(entityToPost)); + + Assert.AreEqual(entityToPost.Age, returnedEntity.Age); + Assert.AreEqual(entityToPost.Name, returnedEntity.Name); + } + + [Test] + public void CreateEntityShouldTranslateToUserGridErrorAndThrowWhenServiceReturnsBadRequest() + { + var restResponseContent = new UsergridError + { + Description = "Subject does not have permission", + Error = "unauthorized" + }; + const string collectionName = "collection"; + IRestResponse<UsergridError> restResponse = Helpers.SetUpRestResponseWithContent<UsergridError>(HttpStatusCode.BadRequest, restResponseContent); + + _request + .ExecuteJsonRequest(Arg.Any<string>(), Arg.Any<Method>(), Arg.Any<object>()) + .Returns(restResponse); + + try + { + _entityManager.CreateEntity(collectionName, new object()); + new AssertionException("UserGridException was expected to be thrown here"); + } + catch (UsergridException e) + { + Assert.AreEqual("unauthorized", e.ErrorCode); + Assert.AreEqual("Subject does not have permission", e.Message); + } + } + + + [Test] + public void DeleteEntityShouldSendDeleteToCorrectEndPoint() + { + const string collection = "collection"; + const string identifier = "identifier"; + + IRestResponse restResponse = Helpers.SetUpRestResponse(HttpStatusCode.OK); + + _request + .ExecuteJsonRequest(Arg.Any<string>(), Arg.Any<Method>(), Arg.Any<object>()) + .Returns(restResponse); + + _entityManager.DeleteEntity(collection, identifier); + + _request.Received(1).ExecuteJsonRequest( + Arg.Is(string.Format("/{0}/{1}", collection, identifier)), + Arg.Is(Method.DELETE), + Arg.Any<object>()); + } + + [Test] + public void DeleteEntityShouldTranslateToUserGridErrorAndThrowWhenServiceReturnsNotFound() + { + var restResponseContent = new UsergridError + { + Description = "Service resource not found", + Error = "service_resource_not_found" + }; + const string collection = "collection"; + const string identifier = "identifier"; + + IRestResponse<UsergridError> restResponse = Helpers.SetUpRestResponseWithContent<UsergridError>(HttpStatusCode.NotFound, restResponseContent); + + _request + .ExecuteJsonRequest(Arg.Any<string>(), Arg.Any<Method>(), Arg.Any<object>()) + .Returns(restResponse); + + try + { + _entityManager.DeleteEntity(collection, identifier); + throw new AssertionException("UserGridException was expected to be thrown here"); + } + catch (UsergridException e) + { + Assert.AreEqual("service_resource_not_found", e.ErrorCode); + Assert.AreEqual("Service resource not found", e.Message); + } + } + + [Test] + public void GetEntityShouldGetToCorrectEndPoint() + { + var restResponseContent = new UsergridGetResponse<Friend> {Entities = new List<Friend>(), Cursor = ""}; + IRestResponse<UsergridGetResponse<Friend>> restResponse = Helpers.SetUpRestResponseWithContent<UsergridGetResponse<Friend>>(HttpStatusCode.OK, restResponseContent); + + _request + .ExecuteJsonRequest(Arg.Any<string>(), Arg.Any<Method>(), Arg.Any<object>()) + .Returns(restResponse); + + const string collectionName = "collection"; + const string identifer = "identifier"; + + _entityManager.GetEntity<Friend>(collectionName, identifer); + + _request.Received(1).ExecuteJsonRequest( + Arg.Is(string.Format("/{0}/{1}", collectionName, identifer)), + Arg.Is(Method.GET), + Arg.Any<object>()); + } + + [Test] + public void GetEntityShouldReturnEntityCorrectly() + { + var friend = new Friend {Name = "name", Age = 1}; + + const string restResponseContent = "{\"entities\": [" + + "{" + + "\"uuid\": \"bcb343ba-d6d1-11e2-a295-7b4b45081d3b\"," + + "\"type\": \"friend\"," + + "\"name\": \"name\"," + + "\"age\": 1," + + "\"created\": 1371420707691," + + "\"modified\": 1371420707691," + + "\"metadata\": {" + + " \"path\": \"/friends/bcb343ba-d6d1-11e2-a295-7b4b45081d3b\"" + + "}," + + "}" + + "]}"; + IRestResponse<UsergridGetResponse<Friend>> restResponse = Helpers.SetUpRestResponseWithContent<UsergridGetResponse<Friend>>(HttpStatusCode.OK, restResponseContent); + + _request + .ExecuteJsonRequest(Arg.Any<string>(), Arg.Any<Method>(), Arg.Any<object>()) + .Returns(restResponse); + + const string collectionName = "collection"; + const string identifier = "identifier"; + + Friend returnedFriend = _entityManager.GetEntity<Friend>(collectionName, identifier); + + Assert.IsNotNull(returnedFriend); + Assert.AreEqual(friend.Name, returnedFriend.Name); + Assert.AreEqual(friend.Age, returnedFriend.Age); + } + + + [Test] + public void GetEntityShouldReturnFirstEntityInListCorrectly() + { + var friend1 = new Friend {Name = "name1", Age = 1}; + var friend2 = new Friend {Name = "name2", Age = 2}; + + var entities = new List<Friend> {friend1, friend2}; + var restResponseContent = new UsergridGetResponse<Friend> {Entities = entities, Cursor = "cursor"}; + IRestResponse<UsergridGetResponse<Friend>> restResponse = Helpers.SetUpRestResponseWithContent<UsergridGetResponse<Friend>>(HttpStatusCode.OK, restResponseContent); + + _request + .ExecuteJsonRequest(Arg.Any<string>(), Arg.Any<Method>(), Arg.Any<object>()) + .Returns(restResponse); + + const string collectionName = "collection"; + const string identifier = "identifier"; + + Friend returnedFriend = _entityManager.GetEntity<Friend>(collectionName, identifier); + + Assert.IsNotNull(returnedFriend); + Assert.AreEqual(friend1.Name, returnedFriend.Name); + Assert.AreEqual(friend1.Age, returnedFriend.Age); + } + + + [Test] + public void UpdateEntityShouldPutToCorrectEndPoint() + { + const string collectionName = "collection"; + const string identifier = "identifier"; + var entityToPost = new {FirstName = "first", LastName = "last"}; + + IRestResponse restResponse = Helpers.SetUpRestResponse(HttpStatusCode.OK); + + _request + .ExecuteJsonRequest(Arg.Any<string>(), Arg.Any<Method>(), Arg.Any<object>()) + .Returns(restResponse); + + _entityManager.UpdateEntity(collectionName, identifier, entityToPost); + + _request.Received(1).ExecuteJsonRequest( + Arg.Is(string.Format("/{0}/{1}", collectionName, identifier)), + Arg.Is(Method.PUT), + Arg.Is(entityToPost)); + } + + [Test] + public void UpdateEntityShouldTranslateToUserGridErrorAndThrowWhenServiceReturnsNotFound() + { + var restResponseContent = new UsergridError + { + Description = "Service resource not found", + Error = "service_resource_not_found" + }; + + const string collectionName = "collection"; + const string identifier = "identifier"; + var entityToPost = new {FirstName = "first", LastName = "last"}; + + IRestResponse<UsergridError> restResponse = Helpers.SetUpRestResponseWithContent<UsergridError>(HttpStatusCode.NotFound, restResponseContent); + + _request + .ExecuteJsonRequest(Arg.Any<string>(), Arg.Any<Method>(), Arg.Any<object>()) + .Returns(restResponse); + + try + { + _entityManager.UpdateEntity(collectionName, identifier, entityToPost); + new AssertionException("UserGridException was expected to be thrown here"); + } + catch (UsergridException e) + { + Assert.AreEqual("service_resource_not_found", e.ErrorCode); + Assert.AreEqual("Service resource not found", e.Message); + } + } + + [Test] + public void GetEntitiesShouldGetToCorrectEndPointWithDefaultLimitAndQuery() + { + var restResponseContent = new UsergridGetResponse<Friend> { Entities = new List<Friend>(), Cursor = "" }; + var restResponse = Helpers.SetUpRestResponseWithContent<UsergridGetResponse<Friend>>(HttpStatusCode.OK, restResponseContent); + + _request + .ExecuteJsonRequest(Arg.Any<string>(), Arg.Any<Method>(), Arg.Any<object>()) + .Returns(restResponse); + + const string collectionName = "collection"; + + _entityManager.GetEntities<Friend>(collectionName); + + _request.Received(1).ExecuteJsonRequest( + Arg.Is(string.Format("/{0}?limit=10", collectionName)), + Arg.Is(Method.GET), + Arg.Is<object>(x=> x == null)); + } + + [Test] + public void GetEntitiesShouldReturnListCorrectly() + { + var friend1 = new Friend { Name = "name1", Age = 1 }; + var friend2 = new Friend { Name = "name2", Age = 2 }; + var entities = new List<Friend> { friend1, friend2 }; + var restResponseContent = new UsergridGetResponse<Friend> { Entities = entities, Cursor = "cursor" }; + var restResponse = Helpers.SetUpRestResponseWithContent<UsergridGetResponse<Friend>>(HttpStatusCode.OK, restResponseContent); + + _request + .ExecuteJsonRequest(Arg.Any<string>(), Arg.Any<Method>(), Arg.Any<object>()) + .Returns(restResponse); + + var friends = _entityManager.GetEntities<Friend>("collection"); + + Assert.IsNotNull(friends); + Assert.AreEqual(entities.Count, friends.Count); + Assert.AreEqual(friend1.Name, friends[0].Name); + Assert.AreEqual(friend1.Age, friends[0].Age); + Assert.AreEqual(friend2.Name, friends[1].Name); + Assert.AreEqual(friend2.Age, friends[1].Age); + } + + [Test] + public void GetNextEntitiesShouldReturnEmptyListIfCalledBeforeGetEntities() + { + var friends = _entityManager.GetNextEntities<Friend>("collection"); + + CollectionAssert.IsEmpty(friends); + } + + [Test] + public void GetNextEntitiesShouldGetToCorrectEndPointWithCorrectCursorState() + { + var friend1 = new Friend { Name = "name1", Age = 1 }; + var friend2 = new Friend { Name = "name2", Age = 2 }; + var friend3 = new Friend { Name = "name3", Age = 3 }; + var friend4 = new Friend { Name = "name4", Age = 4 }; + var friend5 = new Friend { Name = "name5", Age = 5 }; + var friend6 = new Friend { Name = "name6", Age = 6 }; + var entities1 = new List<Friend> { friend1, friend2 }; + var entities2 = new List<Friend> { friend3, friend4 }; + var entities3 = new List<Friend> { friend5, friend6 }; + var restResponseContent1 = new UsergridGetResponse<Friend> { Entities = entities1, Cursor = "cursor1" }; + var restResponse1 = Helpers.SetUpRestResponseWithContent<UsergridGetResponse<Friend>>(HttpStatusCode.OK, restResponseContent1); + var restResponseContent2 = new UsergridGetResponse<Friend> { Entities = entities2, Cursor = "cursor2" }; + var restResponse2 = Helpers.SetUpRestResponseWithContent<UsergridGetResponse<Friend>>(HttpStatusCode.OK, restResponseContent2); + var restResponseContent3 = new UsergridGetResponse<Friend> { Entities = entities3 }; + var restResponse3 = Helpers.SetUpRestResponseWithContent<UsergridGetResponse<Friend>>(HttpStatusCode.OK, restResponseContent3); + + _request + .ExecuteJsonRequest("/collection?limit=10", Method.GET, Arg.Is<object>(x => x == null)) + .Returns(restResponse1); + _request + .ExecuteJsonRequest("/collection?cursor=cursor1&limit=10", Method.GET, Arg.Is<object>(x => x == null)) + .Returns(restResponse2); + _request + .ExecuteJsonRequest("/collection?cursor=cursor2&limit=10", Method.GET, Arg.Is<object>(x => x == null)) + .Returns(restResponse3); + + UsergridCollection<Friend> list1 = _entityManager.GetEntities<Friend>("collection"); + UsergridCollection<Friend> list2 = _entityManager.GetNextEntities<Friend>("collection"); + UsergridCollection<Friend> list3 = _entityManager.GetNextEntities<Friend>("collection"); + + Assert.AreEqual(entities1[0].Name,list1[0].Name); + Assert.AreEqual(entities1[1].Age,list1[1].Age); + Assert.IsTrue(list1.HasNext); + Assert.IsFalse(list1.HasPrevious); + Assert.AreEqual(entities2[0].Name,list2[0].Name); + Assert.AreEqual(entities2[1].Age,list2[1].Age); + Assert.IsTrue(list2.HasNext); + Assert.IsTrue(list2.HasPrevious); + Assert.AreEqual(entities3[0].Name,list3[0].Name); + Assert.AreEqual(entities3[1].Age,list3[1].Age); + Assert.IsFalse(list3.HasNext); + Assert.IsTrue(list3.HasPrevious); + } + + [Test] + public void GetPreviousEntitiesShouldGetToCorrectEndPointWithCorrectCursorState() + { + var friend1 = new Friend { Name = "name1", Age = 1 }; + var friend2 = new Friend { Name = "name2", Age = 2 }; + var friend3 = new Friend { Name = "name3", Age = 3 }; + var friend4 = new Friend { Name = "name4", Age = 4 }; + var friend5 = new Friend { Name = "name5", Age = 5 }; + var friend6 = new Friend { Name = "name6", Age = 6 }; + var entities1 = new List<Friend> { friend1, friend2 }; + var entities2 = new List<Friend> { friend3, friend4 }; + var entities3 = new List<Friend> { friend5, friend6 }; + var restResponseContent1 = new UsergridGetResponse<Friend> { Entities = entities1, Cursor = "cursor1" }; + var restResponse1 = Helpers.SetUpRestResponseWithContent<UsergridGetResponse<Friend>>(HttpStatusCode.OK, restResponseContent1); + var restResponseContent2 = new UsergridGetResponse<Friend> { Entities = entities2, Cursor = "cursor2" }; + var restResponse2 = Helpers.SetUpRestResponseWithContent<UsergridGetResponse<Friend>>(HttpStatusCode.OK, restResponseContent2); + var restResponseContent3 = new UsergridGetResponse<Friend> { Entities = entities3 }; + var restResponse3 = Helpers.SetUpRestResponseWithContent<UsergridGetResponse<Friend>>(HttpStatusCode.OK, restResponseContent3); + + _request + .ExecuteJsonRequest("/collection?limit=10", Method.GET, Arg.Is<object>(x => x == null)) + .Returns(restResponse1); + _request + .ExecuteJsonRequest("/collection?cursor=cursor1&limit=10", Method.GET, Arg.Is<object>(x => x == null)) + .Returns(restResponse2); + _request + .ExecuteJsonRequest("/collection?cursor=cursor2&limit=10", Method.GET, Arg.Is<object>(x => x == null)) + .Returns(restResponse3); + _request + .ExecuteJsonRequest("/collection?cursor=cursor1&limit=10", Method.GET, Arg.Is<object>(x => x == null)) + .Returns(restResponse2); + _request + .ExecuteJsonRequest("/collection?&limit=10", Method.GET, Arg.Is<object>(x => x == null)) + .Returns(restResponse1); + + UsergridCollection<Friend> list1 = _entityManager.GetEntities<Friend>("collection"); + UsergridCollection<Friend> list2 = _entityManager.GetNextEntities<Friend>("collection"); + UsergridCollection<Friend> list3 = _entityManager.GetNextEntities<Friend>("collection"); + UsergridCollection<Friend> list4 = _entityManager.GetPreviousEntities<Friend>("collection"); + UsergridCollection<Friend> list5 = _entityManager.GetPreviousEntities<Friend>("collection"); + + Assert.AreEqual(entities1[0].Name,list1[0].Name); + Assert.AreEqual(entities1[1].Age,list1[1].Age); + Assert.IsTrue(list1.HasNext); + Assert.IsFalse(list1.HasPrevious); + + Assert.AreEqual(entities2[0].Name,list2[0].Name); + Assert.AreEqual(entities2[1].Age,list2[1].Age); + Assert.IsTrue(list2.HasNext); + Assert.IsTrue(list2.HasPrevious); + + Assert.AreEqual(entities3[0].Name,list3[0].Name); + Assert.AreEqual(entities3[1].Age,list3[1].Age); + Assert.IsFalse(list3.HasNext); + Assert.IsTrue(list3.HasPrevious); + + Assert.AreEqual(entities2[0].Name, list4[0].Name); + Assert.AreEqual(entities2[1].Age, list4[1].Age); + Assert.IsTrue(list4.HasNext); + Assert.IsTrue(list4.HasPrevious); + + Assert.AreEqual(entities1[0].Name, list5[0].Name); + Assert.AreEqual(entities1[1].Age, list5[1].Age); + Assert.IsTrue(list5.HasNext); + Assert.IsFalse(list5.HasPrevious); + } + } +} http://git-wip-us.apache.org/repos/asf/usergrid-dotnet/blob/94c0483c/Usergrid.Sdk.Tests/Friend.cs ---------------------------------------------------------------------- diff --git a/Usergrid.Sdk.Tests/Friend.cs b/Usergrid.Sdk.Tests/Friend.cs new file mode 100644 index 0000000..ea6cc32 --- /dev/null +++ b/Usergrid.Sdk.Tests/Friend.cs @@ -0,0 +1,35 @@ +// Licensed to the Apache Software Foundation (ASF) under one or more +// contributor license agreements. See the NOTICE file distributed with +// this work for additional information regarding copyright ownership. +// The ASF licenses this file to You under the Apache License, Version 2.0 +// (the "License"); you may not use this file except in compliance with +// the License. You may obtain a copy of the License at +// +// http://www.apache.org/licenses/LICENSE-2.0 +// +// Unless required by applicable law or agreed to in writing, software +// distributed under the License is distributed on an "AS IS" BASIS, +// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. +// See the License for the specific language governing permissions and +// limitations under the License. + + +using System.Collections.Generic; +using System.Net; +using NSubstitute; +using NUnit.Framework; +using RestSharp; +using Usergrid.Sdk.Model; +using Usergrid.Sdk.Payload; + +namespace Usergrid.Sdk.Tests +{ + + public class Friend + { + public string Name { get; set; } + public int Age { get; set; } + } + + +} http://git-wip-us.apache.org/repos/asf/usergrid-dotnet/blob/94c0483c/Usergrid.Sdk.Tests/Helpers.cs ---------------------------------------------------------------------- diff --git a/Usergrid.Sdk.Tests/Helpers.cs b/Usergrid.Sdk.Tests/Helpers.cs new file mode 100644 index 0000000..6188d16 --- /dev/null +++ b/Usergrid.Sdk.Tests/Helpers.cs @@ -0,0 +1,94 @@ +// Licensed to the Apache Software Foundation (ASF) under one or more +// contributor license agreements. See the NOTICE file distributed with +// this work for additional information regarding copyright ownership. +// The ASF licenses this file to You under the Apache License, Version 2.0 +// (the "License"); you may not use this file except in compliance with +// the License. You may obtain a copy of the License at +// +// http://www.apache.org/licenses/LICENSE-2.0 +// +// Unless required by applicable law or agreed to in writing, software +// distributed under the License is distributed on an "AS IS" BASIS, +// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. +// See the License for the specific language governing permissions and +// limitations under the License. + + +using System.Net; +using System.Reflection; +using NSubstitute; +using Newtonsoft.Json; +using RestSharp; +using Usergrid.Sdk.Model; +using Usergrid.Sdk.Payload; + +namespace Usergrid.Sdk.Tests +{ + internal static class Helpers + { + internal static string Serialize(this object obj) + { + return JsonConvert.SerializeObject(obj); + } + + internal static IRestResponse<T> SetUpRestResponseWithContent<T>(HttpStatusCode httpStatusCode, object responseContent) + { + return SetUpRestResponseWithContent<T>(httpStatusCode, responseContent.Serialize()); + } + + internal static IRestResponse<T> SetUpRestResponseWithContent<T>(HttpStatusCode httpStatusCode, string responseContent) + { + var restResponse = Substitute.For<IRestResponse<T>>(); + restResponse.StatusCode.Returns(httpStatusCode); + restResponse.Content.Returns(responseContent); + return restResponse; + } + + internal static IRestResponse SetUpRestResponse(HttpStatusCode httpStatusCode) + { + var restResponse = Substitute.For<IRestResponse>(); + restResponse.StatusCode.Returns(httpStatusCode); + return restResponse; + } + + internal static IRestResponse<T> SetUpRestResponseWithData<T>(HttpStatusCode httpStatusCode, T responseData) + { + var restResponse = Substitute.For<IRestResponse<T>>(); + restResponse.StatusCode.Returns(httpStatusCode); + restResponse.Data.Returns(responseData); + return restResponse; + } + + internal static IUsergridRequest SetUpUsergridRequestWithRestResponse<T>(IRestResponse<T> restResponse) where T : new() + { + var request = Substitute.For<IUsergridRequest>(); + request + .ExecuteJsonRequest<T>(Arg.Any<string>(), Arg.Any<Method>(), Arg.Any<object>()) + .Returns(restResponse); + + return request; + } + + internal static IUsergridRequest InitializeUserGridRequestWithAccessToken(string accessToken) + { + IRestResponse<LoginResponse> loginResponse = SetUpRestResponseWithData(HttpStatusCode.OK, new LoginResponse {AccessToken = accessToken}); + + var request = Substitute.For<IUsergridRequest>(); + request + .ExecuteJsonRequest<LoginResponse>(Arg.Any<string>(), Arg.Any<Method>(), Arg.Any<object>()) + .Returns(loginResponse); + + return request; + } + + public static object GetReflectedProperty(this object obj, string propertyName) + { + PropertyInfo property = obj.GetType().GetProperty(propertyName); + + if (property == null) + return null; + + return property.GetValue(obj, null); + } + } +} http://git-wip-us.apache.org/repos/asf/usergrid-dotnet/blob/94c0483c/Usergrid.Sdk.Tests/Model/NotificationRecipientsTests.cs ---------------------------------------------------------------------- diff --git a/Usergrid.Sdk.Tests/Model/NotificationRecipientsTests.cs b/Usergrid.Sdk.Tests/Model/NotificationRecipientsTests.cs new file mode 100644 index 0000000..032e733 --- /dev/null +++ b/Usergrid.Sdk.Tests/Model/NotificationRecipientsTests.cs @@ -0,0 +1,147 @@ +// Licensed to the Apache Software Foundation (ASF) under one or more +// contributor license agreements. See the NOTICE file distributed with +// this work for additional information regarding copyright ownership. +// The ASF licenses this file to You under the Apache License, Version 2.0 +// (the "License"); you may not use this file except in compliance with +// the License. You may obtain a copy of the License at +// +// http://www.apache.org/licenses/LICENSE-2.0 +// +// Unless required by applicable law or agreed to in writing, software +// distributed under the License is distributed on an "AS IS" BASIS, +// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. +// See the License for the specific language governing permissions and +// limitations under the License. + + +using System; +using NSubstitute.Core; +using NUnit.Framework; +using Usergrid.Sdk.Model; + +namespace Usergrid.Sdk.Tests.Model +{ + [TestFixture] + public class NotificationRecipientsTests + { + [Test] + public void NotificationRecipientsBuildsQuery1() + { + var query = new NotificationRecipients() + .AddDeviceWithName("d") + .AddGroupWithPath("p") + .AddUserWithName("u") + .BuildQuery(); + + Assert.AreEqual("/groups/p/users/u/devices/d/notifications", query); + } + + [Test] + public void NotificationRecipientsBuildsQuery2() + { + var query = new NotificationRecipients() + .AddDeviceWithName("d") + .AddGroupWithPath("p") + .AddUserWithUuid("u") + .BuildQuery(); + + Assert.AreEqual("/groups/p/users/u/devices/d/notifications", query); + } + + [Test] + public void NotificationRecipientsBuildsQuery3() + { + var query = new NotificationRecipients() + .AddDeviceWithQuery("d") + .AddGroupWithQuery("p") + .AddUserWithQuery("u") + .BuildQuery(); + + Assert.AreEqual("/groups;ql=p/users;ql=u/devices;ql=d/notifications", query); + } + [Test] + public void NotificationRecipientsBuildsQuery4() + { + var query = new NotificationRecipients() + .AddDeviceWithQuery(string.Empty) + .AddGroupWithQuery(string.Empty) + .AddUserWithQuery(string.Empty) + .BuildQuery(); + + Assert.AreEqual("/groups;ql=/users;ql=/devices;ql=/notifications", query); + } + + [Test] + [ExpectedException(typeof(ArgumentException), ExpectedMessage = "User name and uuid can not be added at the same time.")] + public void UserNameAndUuidCannotBeAddedAtTheSameTime() + { + new NotificationRecipients() + .AddUserWithName("u") + .AddUserWithUuid("i"); + } + + [Test] + [ExpectedException(typeof(ArgumentException), ExpectedMessage = "User name and uuid can not be added at the same time.")] + public void UserUuidAndNameCannotBeAddedAtTheSameTime() + { + new NotificationRecipients() + .AddUserWithUuid("i") + .AddUserWithName("u"); + } + + [Test] + [ExpectedException(typeof(ArgumentException), ExpectedMessage = "User query can not be added together with user name or uuid.")] + public void UserUuidAndQueryCannotBeAddedAtTheSameTime() + { + new NotificationRecipients() + .AddUserWithUuid("i") + .AddUserWithQuery("u"); + } + + [Test] + [ExpectedException(typeof(ArgumentException), ExpectedMessage = "User query can not be added together with user name or uuid.")] + public void UserNameAndQueryCannotBeAddedAtTheSameTime() + { + new NotificationRecipients() + .AddUserWithName("i") + .AddUserWithQuery("u"); + } + + [Test] + [ExpectedException(typeof(ArgumentException), ExpectedMessage = "Group path and query can not be added at the same time.")] + public void GroupPathAndQueryCannotBeAddedAtTheSameTime() + { + new NotificationRecipients() + .AddGroupWithPath("u") + .AddGroupWithQuery("i"); + } + + [Test] + [ExpectedException(typeof(ArgumentException), ExpectedMessage = "Group path and query can not be added at the same time.")] + public void GroupQueryAndPathCannotBeAddedAtTheSameTime() + { + new NotificationRecipients() + .AddGroupWithQuery("i") + .AddGroupWithPath("u"); + } + + [Test] + [ExpectedException(typeof(ArgumentException), ExpectedMessage = "Device name and query can not be added at the same time.")] + public void DeviceQueryAndNameCannotBeAddedAtTheSameTime() + { + new NotificationRecipients() + .AddDeviceWithQuery("i") + .AddDeviceWithName("u"); + } + + [Test] + [ExpectedException(typeof(ArgumentException), ExpectedMessage = "Device name and query can not be added at the same time.")] + public void DeviceNameAndQueryCannotBeAddedAtTheSameTime() + { + new NotificationRecipients() + .AddDeviceWithName("i") + .AddDeviceWithQuery("u"); + } + + } +} http://git-wip-us.apache.org/repos/asf/usergrid-dotnet/blob/94c0483c/Usergrid.Sdk.Tests/Model/NotificationTests.cs ---------------------------------------------------------------------- diff --git a/Usergrid.Sdk.Tests/Model/NotificationTests.cs b/Usergrid.Sdk.Tests/Model/NotificationTests.cs new file mode 100644 index 0000000..2bea74c --- /dev/null +++ b/Usergrid.Sdk.Tests/Model/NotificationTests.cs @@ -0,0 +1,55 @@ +// Licensed to the Apache Software Foundation (ASF) under one or more +// contributor license agreements. See the NOTICE file distributed with +// this work for additional information regarding copyright ownership. +// The ASF licenses this file to You under the Apache License, Version 2.0 +// (the "License"); you may not use this file except in compliance with +// the License. You may obtain a copy of the License at +// +// http://www.apache.org/licenses/LICENSE-2.0 +// +// Unless required by applicable law or agreed to in writing, software +// distributed under the License is distributed on an "AS IS" BASIS, +// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. +// See the License for the specific language governing permissions and +// limitations under the License. + + +using NUnit.Framework; +using Usergrid.Sdk.Model; + +namespace Usergrid.Sdk.Tests.Model +{ + [TestFixture] + public class NotificationTests + { + [Test] + public void AndroidNotificationShouldReturnCorrectPayload() + { + var notification = new AndroidNotification("notifierName", "notification message"); + var payload = notification.GetPayload(); + + Assert.AreEqual("notification message", payload.GetReflectedProperty("data")); + } + + [Test] + public void GoogleNotificationShouldReturnCorrectPayloadWithSound() + { + var notification = new AppleNotification("notifierName", "notification message", "chime"); + var payload = notification.GetPayload(); + + var aps = payload.GetReflectedProperty("aps"); + Assert.IsNotNull(aps); + Assert.AreEqual("notification message", aps.GetReflectedProperty("alert")); + Assert.AreEqual("chime", aps.GetReflectedProperty("sound")); + } + + [Test] + public void GoogleNotificationShouldReturnCorrectPayloadWithoutSound() + { + var notification = new AppleNotification("notifierName", "notification message"); + var payload = notification.GetPayload(); + + Assert.AreEqual("notification message", payload); + } + } +} http://git-wip-us.apache.org/repos/asf/usergrid-dotnet/blob/94c0483c/Usergrid.Sdk.Tests/NotificationsManagerTests.cs ---------------------------------------------------------------------- diff --git a/Usergrid.Sdk.Tests/NotificationsManagerTests.cs b/Usergrid.Sdk.Tests/NotificationsManagerTests.cs new file mode 100644 index 0000000..ae5135a --- /dev/null +++ b/Usergrid.Sdk.Tests/NotificationsManagerTests.cs @@ -0,0 +1,118 @@ +// Licensed to the Apache Software Foundation (ASF) under one or more +// contributor license agreements. See the NOTICE file distributed with +// this work for additional information regarding copyright ownership. +// The ASF licenses this file to You under the Apache License, Version 2.0 +// (the "License"); you may not use this file except in compliance with +// the License. You may obtain a copy of the License at +// +// http://www.apache.org/licenses/LICENSE-2.0 +// +// Unless required by applicable law or agreed to in writing, software +// distributed under the License is distributed on an "AS IS" BASIS, +// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. +// See the License for the specific language governing permissions and +// limitations under the License. + + +using System; +using System.Collections.Generic; +using System.Net; +using NSubstitute; +using NUnit.Framework; +using RestSharp; +using Usergrid.Sdk.Manager; +using Usergrid.Sdk.Model; +using Usergrid.Sdk.Payload; + +namespace Usergrid.Sdk.Tests +{ + [TestFixture] + public class NotificationsManagerTests + { + private IUsergridRequest _request; + private NotificationsManager _notificationsManager; + + [SetUp] + public void Setup() + { + _request = Substitute.For<IUsergridRequest>(); + _notificationsManager = new NotificationsManager(_request); + } + + + [Test] + public void CreateNotifierForAppleExecutesMultipartFormDataRequestWithCorrectParameters() + { + IRestResponse restResponse = Helpers.SetUpRestResponse(HttpStatusCode.OK); + _request.ExecuteMultipartFormDataRequest(Arg.Any<string>(), Arg.Any<Method>(), Arg.Any<IDictionary<string, object>>(), Arg.Any<IDictionary<string, string>>()) + .Returns(restResponse); + + _notificationsManager.CreateNotifierForApple("notifierName", "development", @"C:\filePath"); + + _request.Received(1).ExecuteMultipartFormDataRequest( + "/notifiers", + Method.POST, + Arg.Is<IDictionary<string, object>>(d => (string) d["name"] == "notifierName" && (string) d["provider"] == "apple" && (string) d["environment"] == "development"), + Arg.Is<IDictionary<string, string>>(d => d["p12Certificate"] == @"C:\filePath")); + } + + [Test] + public void CreateNotifierForAndroidExecutesMultipartFormDataRequestWithCorrectParameters() + { + IRestResponse restResponse = Helpers.SetUpRestResponse(HttpStatusCode.OK); + _request.ExecuteJsonRequest(Arg.Any<string>(), Arg.Any<Method>(), Arg.Any<object>()) + .Returns(restResponse); + + _notificationsManager.CreateNotifierForAndroid("notifierName", "apiKey"); + + _request.Received(1).ExecuteJsonRequest( + "/notifiers", + Method.POST, + Arg.Is<AndroidNotifierPayload>(p => p.ApiKey == "apiKey" && p.Name == "notifierName" && p.Provider == "google")); + } + + [Test] + public void PublishNotificationPostsByBuildingQueryAndPayload() + { + IRestResponse restResponse = Helpers.SetUpRestResponse(HttpStatusCode.OK); + _request.ExecuteJsonRequest(Arg.Any<string>(), Arg.Any<Method>(), Arg.Any<object>()) + .Returns(restResponse); + + var recipients = Substitute.For<INotificationRecipients>(); + recipients.BuildQuery().Returns("query"); + + var appleNotification = new AppleNotification("appleNotifierName", "appleTestMessge", "chime"); + var googleNotification = new AndroidNotification("googleNotifierName", "androidTestMessage"); + + var deliverAt = DateTime.Now.AddDays(1); + var expireAt = DateTime.Now.AddDays(2); + + var schedulerSettings = new NotificationSchedulerSettings {DeliverAt = deliverAt, ExpireAt = expireAt}; + + //call PublishNotification + _notificationsManager.PublishNotification(new Notification[] {appleNotification, googleNotification}, recipients, schedulerSettings); + + //assert + recipients.Received(1).BuildQuery(); + + Func<NotificationPayload, bool> validatePayload = p => + { + bool isValid = true; + isValid &= p.DeliverAt == deliverAt.ToUnixTime(); + isValid &= p.ExpireAt == expireAt.ToUnixTime(); + + var applePayload = p.Payloads["appleNotifierName"].GetReflectedProperty("aps"); + isValid &= (string) applePayload.GetReflectedProperty("alert") == "appleTestMessge"; + isValid &= (string) applePayload.GetReflectedProperty("sound") == "chime"; + + var googlePayload = p.Payloads["googleNotifierName"].GetReflectedProperty("data"); + isValid &= (string) googlePayload == "androidTestMessage"; + + return isValid; + }; + _request.Received(1).ExecuteJsonRequest("query", Method.POST, + Arg.Is<NotificationPayload>( + p => validatePayload(p))); + } + } +} http://git-wip-us.apache.org/repos/asf/usergrid-dotnet/blob/94c0483c/Usergrid.Sdk.Tests/Properties/AssemblyInfo.cs ---------------------------------------------------------------------- diff --git a/Usergrid.Sdk.Tests/Properties/AssemblyInfo.cs b/Usergrid.Sdk.Tests/Properties/AssemblyInfo.cs new file mode 100644 index 0000000..eae3356 --- /dev/null +++ b/Usergrid.Sdk.Tests/Properties/AssemblyInfo.cs @@ -0,0 +1,57 @@ +// Licensed to the Apache Software Foundation (ASF) under one or more +// contributor license agreements. See the NOTICE file distributed with +// this work for additional information regarding copyright ownership. +// The ASF licenses this file to You under the Apache License, Version 2.0 +// (the "License"); you may not use this file except in compliance with +// the License. You may obtain a copy of the License at +// +// http://www.apache.org/licenses/LICENSE-2.0 +// +// Unless required by applicable law or agreed to in writing, software +// distributed under the License is distributed on an "AS IS" BASIS, +// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. +// See the License for the specific language governing permissions and +// limitations under the License. + +using System.Reflection; +using System.Runtime.CompilerServices; +using System.Runtime.InteropServices; + +// General Information about an assembly is controlled through the following +// set of attributes. Change these attribute values to modify the information +// associated with an assembly. + +[assembly: AssemblyTitle("Usergrid.Sdk.Tests")] +[assembly: AssemblyDescription("")] +[assembly: AssemblyConfiguration("")] +[assembly: AssemblyCompany("Microsoft")] +[assembly: AssemblyProduct("Usergrid.Sdk.Tests")] +[assembly: AssemblyCopyright("Copyright © Microsoft 2013")] +[assembly: AssemblyTrademark("")] +[assembly: AssemblyCulture("")] + +// Setting ComVisible to false makes the types in this assembly not visible +// to COM components. If you need to access a type in this assembly from +// COM, set the ComVisible attribute to true on that type. + +[assembly: ComVisible(false)] + +// The following GUID is for the ID of the typelib if this project is exposed to COM + +[assembly: Guid("7f12bc68-97ae-41c8-bc55-87ef2ecfb2f7")] + +// Version information for an assembly consists of the following four values: +// +// Major Version +// Minor Version +// Build Number +// Revision +// +// You can specify all the values or you can default the Build and Revision Numbers +// by using the '*' as shown below: +// [assembly: AssemblyVersion("1.0.*")] + +[assembly: AssemblyVersion("0.1.0.0")] +[assembly: AssemblyFileVersion("0.1.0.0")] + +[assembly: InternalsVisibleTo("DynamicProxyGenAssembly2")] http://git-wip-us.apache.org/repos/asf/usergrid-dotnet/blob/94c0483c/Usergrid.Sdk.Tests/Usergrid.Sdk.Tests.csproj ---------------------------------------------------------------------- diff --git a/Usergrid.Sdk.Tests/Usergrid.Sdk.Tests.csproj b/Usergrid.Sdk.Tests/Usergrid.Sdk.Tests.csproj new file mode 100644 index 0000000..a3aff04 --- /dev/null +++ b/Usergrid.Sdk.Tests/Usergrid.Sdk.Tests.csproj @@ -0,0 +1,110 @@ +<?xml version="1.0" encoding="utf-8"?> +<!-- + Licensed to the Apache Software Foundation (ASF) under one or more + contributor license agreements. See the NOTICE file distributed with + this work for additional information regarding copyright ownership. + The ASF licenses this file to You under the Apache License, Version 2.0 + (the "License"); you may not use this file except in compliance with + the License. You may obtain a copy of the License at + + http://www.apache.org/licenses/LICENSE-2.0 + + Unless required by applicable law or agreed to in writing, software + distributed under the License is distributed on an "AS IS" BASIS, + WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + See the License for the specific language governing permissions and + limitations under the License. +--> + +<Project ToolsVersion="4.0" DefaultTargets="Build" xmlns="http://schemas.microsoft.com/developer/msbuild/2003";> + <PropertyGroup> + <Configuration Condition=" '$(Configuration)' == '' ">Debug</Configuration> + <Platform Condition=" '$(Platform)' == '' ">AnyCPU</Platform> + <ProductVersion>8.0.30703</ProductVersion> + <SchemaVersion>2.0</SchemaVersion> + <ProjectGuid>{9C25CFBA-1F57-4DF3-B0A1-52D1F90F24E6}</ProjectGuid> + <OutputType>Library</OutputType> + <AppDesignerFolder>Properties</AppDesignerFolder> + <RootNamespace>Usergrid.Sdk.Tests</RootNamespace> + <AssemblyName>Usergrid.Sdk.Tests</AssemblyName> + <TargetFrameworkVersion>v4.0</TargetFrameworkVersion> + <FileAlignment>512</FileAlignment> + </PropertyGroup> + <PropertyGroup Condition=" '$(Configuration)|$(Platform)' == 'Debug|AnyCPU' "> + <DebugSymbols>true</DebugSymbols> + <DebugType>full</DebugType> + <Optimize>false</Optimize> + <OutputPath>bin\Debug\</OutputPath> + <DefineConstants>DEBUG;TRACE</DefineConstants> + <ErrorReport>prompt</ErrorReport> + <WarningLevel>4</WarningLevel> + </PropertyGroup> + <PropertyGroup Condition=" '$(Configuration)|$(Platform)' == 'Release|AnyCPU' "> + <DebugType>pdbonly</DebugType> + <Optimize>true</Optimize> + <OutputPath>bin\Release\</OutputPath> + <DefineConstants>TRACE</DefineConstants> + <ErrorReport>prompt</ErrorReport> + <WarningLevel>4</WarningLevel> + </PropertyGroup> + <ItemGroup> + <Reference Include="nunit.framework"> + <HintPath>..\packages\NUnit.2.6.2\lib\nunit.framework.dll</HintPath> + </Reference> + <Reference Include="System" /> + <Reference Include="System.Core" /> + <Reference Include="System.Xml.Linq" /> + <Reference Include="System.Data.DataSetExtensions" /> + <Reference Include="Microsoft.CSharp" /> + <Reference Include="System.Data" /> + <Reference Include="System.Xml" /> + <Reference Include="NSubstitute"> + <HintPath>..\packages\NSubstitute.1.6.0.0\lib\NET40\NSubstitute.dll</HintPath> + </Reference> + <Reference Include="Newtonsoft.Json"> + <HintPath>..\packages\Newtonsoft.Json.4.5.11\lib\net40\Newtonsoft.Json.dll</HintPath> + </Reference> + <Reference Include="RestSharp"> + <HintPath>..\packages\RestSharp.104.1\lib\net4\RestSharp.dll</HintPath> + </Reference> + </ItemGroup> + <ItemGroup> + <Compile Include="ClientTests\ConnectionTests.cs" /> + <Compile Include="ClientTests\ActivityTests.cs" /> + <Compile Include="ClientTests\FeedTests.cs" /> + <Compile Include="ClientTests\NotificationTests.cs" /> + <Compile Include="ClientTests\DeviceTests.cs" /> + <Compile Include="ClientTests\GroupTests.cs" /> + <Compile Include="ClientTests\UserTests.cs" /> + <Compile Include="ClientTests\EntityTests.cs" /> + <Compile Include="ClientTests\LoginTests.cs" /> + <Compile Include="ConnectionManagerTests.cs" /> + <Compile Include="UsergridRequestTests.cs" /> + <Compile Include="Model\NotificationRecipientsTests.cs" /> + <Compile Include="Model\NotificationTests.cs" /> + <Compile Include="NotificationsManagerTests.cs" /> + <Compile Include="EntityManagerTests.cs" /> + <Compile Include="Helpers.cs" /> + <Compile Include="AuthenticationManagerTests.cs" /> + <Compile Include="Properties\AssemblyInfo.cs" /> + <Compile Include="Friend.cs" /> + </ItemGroup> + <ItemGroup> + <None Include="packages.config" /> + </ItemGroup> + <ItemGroup> + <ProjectReference Include="..\Usergrid.Sdk\Usergrid.Sdk.csproj"> + <Project>{437D108F-528C-4B2A-B399-06CF02DEB08B}</Project> + <Name>Usergrid.Sdk</Name> + </ProjectReference> + </ItemGroup> + <ItemGroup /> + <Import Project="$(MSBuildToolsPath)\Microsoft.CSharp.targets" /> + <!-- To modify your build process, add your task inside one of the targets below and uncomment it. + Other similar extension points exist, see Microsoft.Common.targets. + <Target Name="BeforeBuild"> + </Target> + <Target Name="AfterBuild"> + </Target> + --> +</Project> http://git-wip-us.apache.org/repos/asf/usergrid-dotnet/blob/94c0483c/Usergrid.Sdk.Tests/UsergridRequestTests.cs ---------------------------------------------------------------------- diff --git a/Usergrid.Sdk.Tests/UsergridRequestTests.cs b/Usergrid.Sdk.Tests/UsergridRequestTests.cs new file mode 100644 index 0000000..b5fb7f1 --- /dev/null +++ b/Usergrid.Sdk.Tests/UsergridRequestTests.cs @@ -0,0 +1,140 @@ +// Licensed to the Apache Software Foundation (ASF) under one or more +// contributor license agreements. See the NOTICE file distributed with +// this work for additional information regarding copyright ownership. +// The ASF licenses this file to You under the Apache License, Version 2.0 +// (the "License"); you may not use this file except in compliance with +// the License. You may obtain a copy of the License at +// +// http://www.apache.org/licenses/LICENSE-2.0 +// +// Unless required by applicable law or agreed to in writing, software +// distributed under the License is distributed on an "AS IS" BASIS, +// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. +// See the License for the specific language governing permissions and +// limitations under the License. + + +using System; +using System.Collections.Generic; +using NSubstitute; +using NUnit.Framework; +using RestSharp; +using RestSharp.Serializers; + +namespace Usergrid.Sdk.Tests +{ + [TestFixture] + public class UsergridRequestTests + { + [Test] + public void ExecuteJsonRequestAddsAuthorizationHeader() + { + var restClient = Substitute.For<IRestClient>(); + var usergridRequest = new UsergridRequest("http://usergrid.com";, "org", "app", restClient); + usergridRequest.AccessToken = "accessToken"; + + usergridRequest.ExecuteJsonRequest("/resource", Method.POST); + + + Func<RestRequest, bool> ValidateRequest = r => r.Parameters[0].Name == "Authorization" && + (string)r.Parameters[0].Value == "Bearer accessToken" && + r.Parameters[0].Type == ParameterType.HttpHeader && + r.Method == Method.POST; + restClient.Received(1).Execute(Arg.Is<RestRequest>(r=>ValidateRequest(r))); + } + + [Test] + public void GenericExecuteJsonRequestAddsAuthorizationHeader() + { + var restClient = Substitute.For<IRestClient>(); + var usergridRequest = new UsergridRequest("http://usergrid.com";, "org", "app", restClient); + usergridRequest.AccessToken = "accessToken"; + + usergridRequest.ExecuteJsonRequest<object>("/resource", Method.POST); + + + Func<RestRequest, bool> ValidateRequest = r => r.Parameters[0].Name == "Authorization" && + (string)r.Parameters[0].Value == "Bearer accessToken" && + r.Parameters[0].Type == ParameterType.HttpHeader && + r.Method == Method.POST; + restClient.Received(1).Execute<object>(Arg.Is<RestRequest>(r=>ValidateRequest(r))); + } + + [Test] + public void ExecuteJsonRequestAddsBodyAsJsonAndSetsSerializer() + { + var restClient = Substitute.For<IRestClient>(); + var body = new {data="test"}; + var usergridRequest = new UsergridRequest("http://usergrid.com";, "org", "app", restClient); + + usergridRequest.ExecuteJsonRequest("/resource", Method.POST, body); + + + Func<RestRequest, bool> ValidateRequest = r => + (string)r.Parameters[0].Value == "{\"data\":\"test\"}"&& + r.RequestFormat == DataFormat.Json && + r.JsonSerializer is RestSharpJsonSerializer; + restClient.Received(1).Execute(Arg.Is<RestRequest>(r => ValidateRequest(r))); + } + + [Test] + public void GenericExecuteJsonRequestAddsBodyAsJsonAndSetsSerializer() + { + var restClient = Substitute.For<IRestClient>(); + var body = new {data="test"}; + var usergridRequest = new UsergridRequest("http://usergrid.com";, "org", "app", restClient); + + usergridRequest.ExecuteJsonRequest<object>("/resource", Method.POST, body); + + + Func<RestRequest, bool> ValidateRequest = r => + (string)r.Parameters[0].Value == "{\"data\":\"test\"}"&& + r.RequestFormat == DataFormat.Json && + r.JsonSerializer is RestSharpJsonSerializer; + restClient.Received(1).Execute<object>(Arg.Is<RestRequest>(r => ValidateRequest(r))); + } + + [Test] + public void ExecuteMultipartFormDataRequestAddsFormsParametersAndFileParameters() + { + var restClient = Substitute.For<IRestClient>(); + var usergridRequest = new UsergridRequest("http://usergrid.com";, "org", "app", restClient); + + IDictionary<string, object> formParameters = new Dictionary<string, object>() + { + {"param1", "value1"}, + {"param2", "value2"} + }; + + IDictionary<string, string> fileParameters = new Dictionary<string, string>() + { + {"fileParam1", "filePath1"} + }; + + usergridRequest.ExecuteMultipartFormDataRequest("/resource", Method.POST, formParameters, fileParameters); + + + Func<RestRequest, bool> ValidateRequest = r => + { + bool isValid = true; + isValid &= r.Parameters[0].Name == "param1"; + isValid &= (string)r.Parameters[0].Value == "value1"; + isValid &= r.Parameters[0].Type == ParameterType.GetOrPost; + + isValid &= r.Parameters[1].Name == "param2"; + isValid &= (string)r.Parameters[1].Value == "value2"; + isValid &= r.Parameters[1].Type == ParameterType.GetOrPost; + + isValid &= r.Files[0].Name == "fileParam1"; + isValid &= r.Files[0].FileName == "filePath1"; + + return isValid; + }; + + + restClient.Received(1).Execute(Arg.Is<RestRequest>(r => ValidateRequest(r))); + + + } + } +} http://git-wip-us.apache.org/repos/asf/usergrid-dotnet/blob/94c0483c/Usergrid.Sdk.Tests/packages.config ---------------------------------------------------------------------- diff --git a/Usergrid.Sdk.Tests/packages.config b/Usergrid.Sdk.Tests/packages.config new file mode 100644 index 0000000..f3b5dc9 --- /dev/null +++ b/Usergrid.Sdk.Tests/packages.config @@ -0,0 +1,24 @@ +<?xml version="1.0" encoding="utf-8"?> +<!-- + Licensed to the Apache Software Foundation (ASF) under one or more + contributor license agreements. See the NOTICE file distributed with + this work for additional information regarding copyright ownership. + The ASF licenses this file to You under the Apache License, Version 2.0 + (the "License"); you may not use this file except in compliance with + the License. You may obtain a copy of the License at + + http://www.apache.org/licenses/LICENSE-2.0 + + Unless required by applicable law or agreed to in writing, software + distributed under the License is distributed on an "AS IS" BASIS, + WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + See the License for the specific language governing permissions and + limitations under the License. +--> + +<packages> + <package id="Newtonsoft.Json" version="4.5.11" targetFramework="net40" /> + <package id="NSubstitute" version="1.6.0.0" targetFramework="net40" /> + <package id="NUnit" version="2.6.2" targetFramework="net40" /> + <package id="RestSharp" version="104.1" targetFramework="net40" /> +</packages> http://git-wip-us.apache.org/repos/asf/usergrid-dotnet/blob/94c0483c/Usergrid.Sdk/Client.cs ---------------------------------------------------------------------- diff --git a/Usergrid.Sdk/Client.cs b/Usergrid.Sdk/Client.cs new file mode 100644 index 0000000..9870c33 --- /dev/null +++ b/Usergrid.Sdk/Client.cs @@ -0,0 +1,262 @@ +// Licensed to the Apache Software Foundation (ASF) under one or more +// contributor license agreements. See the NOTICE file distributed with +// this work for additional information regarding copyright ownership. +// The ASF licenses this file to You under the Apache License, Version 2.0 +// (the "License"); you may not use this file except in compliance with +// the License. You may obtain a copy of the License at +// +// http://www.apache.org/licenses/LICENSE-2.0 +// +// Unless required by applicable law or agreed to in writing, software +// distributed under the License is distributed on an "AS IS" BASIS, +// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. +// See the License for the specific language governing permissions and +// limitations under the License. + +using System.Collections.Generic; +using System.Net; +using Newtonsoft.Json; +using RestSharp; +using Usergrid.Sdk.Manager; +using Usergrid.Sdk.Model; +using Usergrid.Sdk.Payload; +using AuthenticationManager = Usergrid.Sdk.Manager.AuthenticationManager; + +namespace Usergrid.Sdk { + public class Client : IClient { + private const string UserGridEndPoint = "http://api.usergrid.com";; + private readonly IUsergridRequest _request; + + private IAuthenticationManager _authenticationManager; + private IConnectionManager _connectionManager; + private IEntityManager _entityManager; + private INotificationsManager _notificationsManager; + + public Client(string organization, string application) + : this(organization, application, UserGridEndPoint, new UsergridRequest(UserGridEndPoint, organization, application)) {} + + public Client(string organization, string application, string uri = UserGridEndPoint) + : this(organization, application, uri, new UsergridRequest(uri, organization, application)) {} + + internal Client(string organization, string application, string uri = UserGridEndPoint, IUsergridRequest request = null) { + _request = request ?? new UsergridRequest(uri, organization, application); + } + + internal IAuthenticationManager AuthenticationManager { + get { return _authenticationManager ?? (_authenticationManager = new AuthenticationManager(_request)); } + set { _authenticationManager = value; } + } + + internal IEntityManager EntityManager { + get { return _entityManager ?? (_entityManager = new EntityManager(_request)); } + set { _entityManager = value; } + } + + internal IConnectionManager ConnectionManager { + get { return _connectionManager ?? (_connectionManager = new ConnectionManager(_request)); } + set { _connectionManager = value; } + } + + internal INotificationsManager NotificationsManager { + get { return _notificationsManager ?? (_notificationsManager = new NotificationsManager(_request)); } + set { _notificationsManager = value; } + } + + public void Login(string loginId, string secret, AuthType authType) { + AuthenticationManager.Login(loginId, secret, authType); + } + + public T CreateEntity<T>(string collection, T entity) { + return EntityManager.CreateEntity(collection, entity); + } + + public void DeleteEntity(string collection, string name) { + EntityManager.DeleteEntity(collection, name); + } + + public void UpdateEntity<T>(string collection, string identifier, T entity) { + EntityManager.UpdateEntity(collection, identifier, entity); + } + + public T GetEntity<T>(string collectionName, string entityIdentifier) { + return EntityManager.GetEntity<T>(collectionName, entityIdentifier); + } + + public T GetUser<T>(string identifer /*username or uuid or email*/) where T : UsergridUser { + var user = GetEntity<T>("users", identifer); + if (user == null) + return null; + + return user; + } + + public void CreateUser<T>(T user) where T : UsergridUser { + CreateEntity("users", user); + } + + public void UpdateUser<T>(T user) where T : UsergridUser { + UpdateEntity("users", user.UserName, user); + } + + public void DeleteUser(string identifer /*username or uuid or email*/) { + DeleteEntity("users", identifer); + } + + public void ChangePassword(string identifer /*username or uuid or email*/, string oldPassword, string newPassword) { + AuthenticationManager.ChangePassword(identifer, oldPassword, newPassword); + } + + public void CreateGroup<T>(T group) where T : UsergridGroup { + CreateEntity("groups", group); + } + + public void DeleteGroup(string path) { + DeleteEntity("groups", path); + } + + public T GetGroup<T>(string identifer /*uuid or path*/) where T : UsergridGroup { + var usergridGroup = EntityManager.GetEntity<T>("groups", identifer); + if (usergridGroup == null) + return null; + + return usergridGroup; + } + + public void UpdateGroup<T>(T group) where T : UsergridGroup { + UpdateEntity("groups", group.Path, group); + } + + public void AddUserToGroup(string groupIdentifier, string userName) { + EntityManager.CreateEntity<object>(string.Format("/groups/{0}/users/{1}", groupIdentifier, userName), null); + } + + public void DeleteUserFromGroup(string groupIdentifier, string userIdentifier) { + DeleteEntity("/groups/" + groupIdentifier + "/users", userIdentifier); + } + + public IList<T> GetAllUsersInGroup<T>(string groupName) where T : UsergridUser { + IRestResponse response = _request.ExecuteJsonRequest(string.Format("/groups/{0}/users", groupName), Method.GET); + ValidateResponse(response); + + var responseObject = JsonConvert.DeserializeObject<UsergridGetResponse<T>>(response.Content); + return responseObject.Entities; + } + + public UsergridCollection<T> GetEntities<T>(string collection, int limit = 10, string query = null) { + return EntityManager.GetEntities<T>(collection, limit, query); + } + + public UsergridCollection<T> GetNextEntities<T>(string collection, string query = null) { + return EntityManager.GetNextEntities<T>(collection, query); + } + + public UsergridCollection<T> GetPreviousEntities<T>(string collection, string query = null) { + return EntityManager.GetPreviousEntities<T>(collection, query); + } + + public void CreateConnection(Connection connection) { + ConnectionManager.CreateConnection(connection); + } + public IList<UsergridEntity> GetConnections(Connection connection) { + return ConnectionManager.GetConnections(connection); + } + public IList<TConnectee> GetConnections<TConnectee>(Connection connection) { + return ConnectionManager.GetConnections<TConnectee>(connection); + } + public void DeleteConnection(Connection connection) { + ConnectionManager.DeleteConnection(connection); + } + + public void PostActivity<T>(string userIdentifier, T activity) where T : UsergridActivity { + string collection = string.Format("/users/{0}/activities", userIdentifier); + EntityManager.CreateEntity(collection, activity); + } + + public void PostActivityToGroup<T>(string groupIdentifier, T activity) where T : UsergridActivity { + string collection = string.Format("/groups/{0}/activities", groupIdentifier); + EntityManager.CreateEntity(collection, activity); + } + + public void PostActivityToUsersFollowersInGroup<T>(string userIdentifier, string groupIdentifier, T activity) where T : UsergridActivity { + string collection = string.Format("/groups/{0}/users/{1}/activities", groupIdentifier, userIdentifier); + EntityManager.CreateEntity(collection, activity); + } + + public UsergridCollection<T> GetUserActivities<T>(string userIdentifier) where T : UsergridActivity { + string collection = string.Format("/users/{0}/activities", userIdentifier); + return EntityManager.GetEntities<T>(collection); + } + + public UsergridCollection<T> GetGroupActivities<T>(string groupIdentifier) where T : UsergridActivity { + string collection = string.Format("/groups/{0}/activities", groupIdentifier); + return EntityManager.GetEntities<T>(collection); + } + + public T GetDevice<T>(string identifer) where T : UsergridDevice { + var device = GetEntity<T>("devices", identifer); + if (device == null) + return null; + + return device; + } + + public void UpdateDevice<T>(T device) where T : UsergridDevice { + UpdateEntity("devices", device.Name, device); + } + + public void CreateDevice<T>(T device) where T : UsergridDevice { + CreateEntity("devices", device); + } + + public void DeleteDevice(string identifer) { + DeleteEntity("devices", identifer); + } + + public void CreateNotifierForApple(string notifierName, string environment, string p12CertificatePath) { + NotificationsManager.CreateNotifierForApple(notifierName, environment, p12CertificatePath); + } + + public void CreateNotifierForAndroid(string notifierName, string apiKey) { + NotificationsManager.CreateNotifierForAndroid(notifierName, apiKey); + } + + public T GetNotifier<T>(string identifer /*uuid or notifier name*/) where T : UsergridNotifier { + var usergridNotifier = EntityManager.GetEntity<T>("/notifiers", identifer); + if (usergridNotifier == null) + return null; + + return usergridNotifier; + } + + public void DeleteNotifier(string notifierName) { + EntityManager.DeleteEntity("/notifiers", notifierName); + } + + public void PublishNotification(IEnumerable<Notification> notifications, INotificationRecipients recipients, NotificationSchedulerSettings schedulerSettings = null) { + NotificationsManager.PublishNotification(notifications, recipients, schedulerSettings); + } + + public void CancelNotification(string notificationIdentifier) { + EntityManager.UpdateEntity("/notifications", notificationIdentifier, new CancelNotificationPayload {Canceled = true}); + } + + //TODO: IList? + public UsergridCollection<T> GetUserFeed<T>(string userIdentifier) where T : UsergridActivity { + string collection = string.Format("/users/{0}/feed", userIdentifier); + return EntityManager.GetEntities<T>(collection); + } + + public UsergridCollection<T> GetGroupFeed<T>(string groupIdentifier) where T : UsergridActivity { + string collection = string.Format("/groups/{0}/feed", groupIdentifier); + return EntityManager.GetEntities<T>(collection); + } + + + private static void ValidateResponse(IRestResponse response) { + if (response.StatusCode != HttpStatusCode.OK) { + var userGridError = JsonConvert.DeserializeObject<UsergridError>(response.Content); + throw new UsergridException(userGridError); + } + } + } +} http://git-wip-us.apache.org/repos/asf/usergrid-dotnet/blob/94c0483c/Usergrid.Sdk/IClient.cs ---------------------------------------------------------------------- diff --git a/Usergrid.Sdk/IClient.cs b/Usergrid.Sdk/IClient.cs new file mode 100644 index 0000000..b2fa827 --- /dev/null +++ b/Usergrid.Sdk/IClient.cs @@ -0,0 +1,73 @@ +// Licensed to the Apache Software Foundation (ASF) under one or more +// contributor license agreements. See the NOTICE file distributed with +// this work for additional information regarding copyright ownership. +// The ASF licenses this file to You under the Apache License, Version 2.0 +// (the "License"); you may not use this file except in compliance with +// the License. You may obtain a copy of the License at +// +// http://www.apache.org/licenses/LICENSE-2.0 +// +// Unless required by applicable law or agreed to in writing, software +// distributed under the License is distributed on an "AS IS" BASIS, +// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. +// See the License for the specific language governing permissions and +// limitations under the License. + +using System.Collections.Generic; +using Usergrid.Sdk.Model; + +namespace Usergrid.Sdk +{ + public interface IClient + { + void Login(string loginId, string secret, AuthType authType); + T CreateEntity<T>(string collection, T entity); + void DeleteEntity(string collection, string name); + void UpdateEntity<T>(string collection, string identifier, T entity); + T GetEntity<T>(string collectionName, string identifer); + + T GetUser<T>(string identifer /*username or uuid or email*/) where T : UsergridUser; + void CreateUser<T>(T user) where T : UsergridUser; + void UpdateUser<T>(T user) where T : UsergridUser; + void DeleteUser(string identifer /*username or uuid or email*/); + void ChangePassword(string identifer /*username or uuid or email*/, string oldPassword, string newPassword); + void CreateGroup<T>(T group) where T : UsergridGroup; + void DeleteGroup(string path); + T GetGroup<T>(string identifer /*uuid or path*/) where T : UsergridGroup; + void UpdateGroup<T>(T group) where T : UsergridGroup; + void AddUserToGroup(string groupIdentifier, string userName); + void DeleteUserFromGroup(string groupIdentifier, string userIdentifier); + IList<T> GetAllUsersInGroup<T>(string groupName) where T : UsergridUser; + + UsergridCollection<T> GetEntities<T>(string collection, int limit = 10, string query = null); + UsergridCollection<T> GetNextEntities<T>(string collection, string query = null); + UsergridCollection<T> GetPreviousEntities<T>(string collection, string query = null); + + void CreateConnection(Connection connection); + IList<UsergridEntity> GetConnections(Connection connection); + IList<TConnectee> GetConnections<TConnectee>(Connection connection); + void DeleteConnection(Connection connection); + + void PostActivity<T>(string userIdentifier, T activity) where T:UsergridActivity; + void PostActivityToGroup<T>(string groupIdentifier, T activity) where T:UsergridActivity; + void PostActivityToUsersFollowersInGroup<T>(string userIdentifier, string groupIdentifier, T activity) where T:UsergridActivity; + UsergridCollection<T> GetUserActivities<T>(string userIdentifier) where T:UsergridActivity; + UsergridCollection<T> GetGroupActivities<T>(string groupIdentifier) where T:UsergridActivity; + UsergridCollection<T> GetUserFeed<T>(string userIdentifier) where T : UsergridActivity; + UsergridCollection<T> GetGroupFeed<T>(string groupIdentifier) where T : UsergridActivity; + + + void CreateNotifierForApple(string notifierName, string environment, string p12CertificatePath); + void CreateNotifierForAndroid(string notifierName, string apiKey); + T GetNotifier<T>(string identifer/*uuid or notifier name*/) where T : UsergridNotifier; + void DeleteNotifier(string notifierName); + + + T GetDevice<T>(string identifer) where T : UsergridDevice; + void UpdateDevice<T>(T device) where T : UsergridDevice; + void CreateDevice<T>(T device) where T : UsergridDevice; + void DeleteDevice(string identifer); + void PublishNotification (IEnumerable<Notification> notifications, INotificationRecipients recipients, NotificationSchedulerSettings schedulerSettings = null ); + void CancelNotification(string notificationIdentifier); + } +} http://git-wip-us.apache.org/repos/asf/usergrid-dotnet/blob/94c0483c/Usergrid.Sdk/IUsergridRequest.cs ---------------------------------------------------------------------- diff --git a/Usergrid.Sdk/IUsergridRequest.cs b/Usergrid.Sdk/IUsergridRequest.cs new file mode 100644 index 0000000..66842b1 --- /dev/null +++ b/Usergrid.Sdk/IUsergridRequest.cs @@ -0,0 +1,28 @@ +// Licensed to the Apache Software Foundation (ASF) under one or more +// contributor license agreements. See the NOTICE file distributed with +// this work for additional information regarding copyright ownership. +// The ASF licenses this file to You under the Apache License, Version 2.0 +// (the "License"); you may not use this file except in compliance with +// the License. You may obtain a copy of the License at +// +// http://www.apache.org/licenses/LICENSE-2.0 +// +// Unless required by applicable law or agreed to in writing, software +// distributed under the License is distributed on an "AS IS" BASIS, +// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. +// See the License for the specific language governing permissions and +// limitations under the License. + +using System.Collections.Generic; +using RestSharp; + +namespace Usergrid.Sdk +{ + public interface IUsergridRequest + { + IRestResponse<T> ExecuteJsonRequest<T>(string resource, Method method, object body = null) where T : new(); + IRestResponse ExecuteJsonRequest(string resource, Method method, object body = null); + IRestResponse ExecuteMultipartFormDataRequest(string resource, Method method, IDictionary<string, object> formParameters, IDictionary<string, string> fileParameters); + string AccessToken { get; set; } + } +}
