using System; using System.Collections.Generic; using System.Net; using System.Reactive.Linq; using System.Threading.Tasks; using NSubstitute; using Octokit; using Octokit.Internal; using Octokit.Reactive; using Xunit; using static Octokit.Internal.TestSetup; public class ObservableIssuesClientTests { public class TheGetMethod { [Fact] public void GetsFromClientIssueIssue() { var gitHubClient = Substitute.For(); var client = new ObservableIssuesClient(gitHubClient); client.Get("fake", "repo", 42); gitHubClient.Issue.Received().Get("fake", "repo", 42); } [Fact] public void GetsFromClientIssueIssueWithRepositoryId() { var gitHubClient = Substitute.For(); var client = new ObservableIssuesClient(gitHubClient); client.Get(1, 42); gitHubClient.Issue.Received().Get(1, 42); } [Fact] public void EnsuresNonNullArguments() { var client = new ObservableIssuesClient(Substitute.For()); Assert.Throws(() => client.Get(null, "name", 1)); Assert.Throws(() => client.Get("owner", null, 1)); Assert.Throws(() => client.Get("owner", "", 1)); Assert.Throws(() => client.Get("", "name", 1)); } } public class TheGetAllForRepositoryMethod { [Fact] public void EnsuresNonNullArguments() { var client = new ObservableIssuesClient(Substitute.For()); var options = new ApiOptions(); var request = new RepositoryIssueRequest(); Assert.Throws(() => client.GetAllForRepository(null, "name")); Assert.Throws(() => client.GetAllForRepository("owner", null)); Assert.Throws(() => client.GetAllForRepository(null, "name", options)); Assert.Throws(() => client.GetAllForRepository("owner", null, options)); Assert.Throws(() => client.GetAllForRepository("owner", "name", (ApiOptions)null)); Assert.Throws(() => client.GetAllForRepository(null, "name", request)); Assert.Throws(() => client.GetAllForRepository("owner", null, request)); Assert.Throws(() => client.GetAllForRepository("owner", "name", (RepositoryIssueRequest)null)); Assert.Throws(() => client.GetAllForRepository(null, "name", request, options)); Assert.Throws(() => client.GetAllForRepository("owner", null, request, options)); Assert.Throws(() => client.GetAllForRepository("owner", "name", null, options)); Assert.Throws(() => client.GetAllForRepository("owner", "name", request, null)); Assert.Throws(() => client.GetAllForRepository(1, (ApiOptions)null)); Assert.Throws(() => client.GetAllForRepository(1, (RepositoryIssueRequest)null)); Assert.Throws(() => client.GetAllForRepository(1, null, options)); Assert.Throws(() => client.GetAllForRepository(1, request, null)); Assert.Throws(() => client.GetAllForRepository("", "name")); Assert.Throws(() => client.GetAllForRepository("owner", "")); Assert.Throws(() => client.GetAllForRepository("", "name", options)); Assert.Throws(() => client.GetAllForRepository("owner", "", options)); Assert.Throws(() => client.GetAllForRepository("", "name", request)); Assert.Throws(() => client.GetAllForRepository("owner", "", request)); Assert.Throws(() => client.GetAllForRepository("", "name", request, options)); Assert.Throws(() => client.GetAllForRepository("owner", "", request, options)); } [Fact] public void RequestsCorrectUrl() { var gitHubClient = Substitute.For(); var client = new ObservableIssuesClient(gitHubClient); client.GetAllForRepository("fake", "repo"); gitHubClient.Connection.Received().Get>(Arg.Is(u => u.ToString() == "repos/fake/repo/issues"), Arg.Any>()); } [Fact] public void RequestsCorrectUrlWithRepositoryId() { var gitHubClient = Substitute.For(); var client = new ObservableIssuesClient(gitHubClient); client.GetAllForRepository(1); gitHubClient.Connection.Received().Get>(Arg.Is(u => u.ToString() == "repositories/1/issues"), Arg.Any>()); } [Fact] public void RequestsCorrectUrlWithApiOptions() { var gitHubClient = Substitute.For(); var client = new ObservableIssuesClient(gitHubClient); var options = new ApiOptions { PageCount = 1, StartPage = 1, PageSize = 1 }; client.GetAllForRepository("fake", "repo", options); gitHubClient.Connection.Received().Get>(Arg.Is(u => u.ToString() == "repos/fake/repo/issues"), Arg.Is>(d => d.Count == 6 && d["filter"] == "assigned" && d["state"] == "open" && d["sort"] == "created" && d["direction"] == "desc" && d["page"] == "1" && d["per_page"] == "1")); } [Fact] public void RequestsCorrectUrlWithRepositoryIdWithApiOptions() { var gitHubClient = Substitute.For(); var client = new ObservableIssuesClient(gitHubClient); var options = new ApiOptions { PageCount = 1, StartPage = 1, PageSize = 1 }; client.GetAllForRepository(1, options); gitHubClient.Connection.Received().Get>(Arg.Is(u => u.ToString() == "repositories/1/issues"), Arg.Is>(d => d.Count == 6 && d["filter"] == "assigned" && d["state"] == "open" && d["sort"] == "created" && d["direction"] == "desc" && d["page"] == "1" && d["per_page"] == "1")); } [Fact] public void SendsAppropriateParameters() { var gitHubClient = Substitute.For(); var client = new ObservableIssuesClient(gitHubClient); client.GetAllForRepository("fake", "repo", new RepositoryIssueRequest { SortDirection = SortDirection.Ascending }); gitHubClient.Connection.Received().Get>(Arg.Is(u => u.ToString() == "repos/fake/repo/issues"), Arg.Is>(d => d.Count == 4 && d["filter"] == "assigned" && d["state"] == "open" && d["sort"] == "created" && d["direction"] == "asc")); } [Fact] public void SendsAppropriateParametersWithRepositoryId() { var gitHubClient = Substitute.For(); var client = new ObservableIssuesClient(gitHubClient); client.GetAllForRepository(1, new RepositoryIssueRequest { SortDirection = SortDirection.Ascending }); gitHubClient.Connection.Received().Get>(Arg.Is(u => u.ToString() == "repositories/1/issues"), Arg.Is>(d => d.Count == 4 && d["filter"] == "assigned" && d["state"] == "open" && d["sort"] == "created" && d["direction"] == "asc")); } [Fact] public void SendsAppropriateParametersWithApiOptions() { var gitHubClient = Substitute.For(); var client = new ObservableIssuesClient(gitHubClient); var options = new ApiOptions { PageCount = 1, StartPage = 1, PageSize = 1 }; client.GetAllForRepository("fake", "repo", new RepositoryIssueRequest { SortDirection = SortDirection.Ascending }, options); gitHubClient.Connection.Received().Get>(Arg.Is(u => u.ToString() == "repos/fake/repo/issues"), Arg.Is>(d => d.Count == 6 && d["filter"] == "assigned" && d["state"] == "open" && d["sort"] == "created" && d["direction"] == "asc" && d["page"] == "1" && d["per_page"] == "1")); } [Fact] public void SendsAppropriateParametersWithRepositoryIdWithApiOptions() { var gitHubClient = Substitute.For(); var client = new ObservableIssuesClient(gitHubClient); var options = new ApiOptions { PageCount = 1, StartPage = 1, PageSize = 1 }; client.GetAllForRepository(1, new RepositoryIssueRequest { SortDirection = SortDirection.Ascending }, options); gitHubClient.Connection.Received().Get>(Arg.Is(u => u.ToString() == "repositories/1/issues"), Arg.Is>(d => d.Count == 6 && d["filter"] == "assigned" && d["state"] == "open" && d["sort"] == "created" && d["direction"] == "asc" && d["page"] == "1" && d["per_page"] == "1")); } [Fact] public async Task ReturnsEveryPageOfIssues() { var firstPageUrl = new Uri("repos/fake/repo/issues", UriKind.Relative); var secondPageUrl = new Uri("https://example.com/page/2"); var firstPageLinks = new Dictionary { { "next", secondPageUrl } }; var firstPageResponse = new ApiResponse> ( CreateResponseWithApiInfo(firstPageLinks), new List { CreateIssue(1), CreateIssue(2), CreateIssue(3) } ); var thirdPageUrl = new Uri("https://example.com/page/3"); var secondPageLinks = new Dictionary { { "next", thirdPageUrl } }; var secondPageResponse = new ApiResponse> ( CreateResponseWithApiInfo(secondPageLinks), new List { CreateIssue(4), CreateIssue(5), CreateIssue(6) } ); var lastPageResponse = new ApiResponse> ( CreateResponse(HttpStatusCode.OK), new List { CreateIssue(7) } ); var gitHubClient = Substitute.For(); gitHubClient.Connection.Get>(Arg.Is(firstPageUrl), Arg.Is>(d => d.Count == 4 && d["direction"] == "desc" && d["state"] == "open" && d["sort"] == "created" && d["filter"] == "assigned")) .Returns(Task.FromResult>>(firstPageResponse)); gitHubClient.Connection.Get>(secondPageUrl, Arg.Any>()) .Returns(Task.FromResult>>(secondPageResponse)); gitHubClient.Connection.Get>(thirdPageUrl, Arg.Any>()) .Returns(Task.FromResult>>(lastPageResponse)); var client = new ObservableIssuesClient(gitHubClient); var results = await client.GetAllForRepository("fake", "repo").ToArray(); Assert.Equal(7, results.Length); Assert.Equal(firstPageResponse.Body[0].Number, results[0].Number); Assert.Equal(secondPageResponse.Body[1].Number, results[4].Number); Assert.Equal(lastPageResponse.Body[0].Number, results[6].Number); } } public class TheGetAllForOwnedAndMemberRepositoriesMethod { [Fact] public void EnsuresNonNullArguments() { var client = new ObservableIssuesClient(Substitute.For()); Assert.Throws( () => client.GetAllForOwnedAndMemberRepositories((ApiOptions)null)); Assert.Throws( () => client.GetAllForOwnedAndMemberRepositories((IssueRequest)null)); Assert.Throws( () => client.GetAllForOwnedAndMemberRepositories(null, new ApiOptions())); Assert.Throws( () => client.GetAllForOwnedAndMemberRepositories(new IssueRequest(), null)); } [Fact] public async Task ReturnsEveryPageOfIssues() { var firstPageUrl = new Uri("user/issues", UriKind.Relative); var secondPageUrl = new Uri("https://example.com/page/2"); var firstPageLinks = new Dictionary { { "next", secondPageUrl } }; var firstPageResponse = new ApiResponse> ( CreateResponseWithApiInfo(firstPageLinks), new List { CreateIssue(1), CreateIssue(2), CreateIssue(3) } ); var thirdPageUrl = new Uri("https://example.com/page/3"); var secondPageLinks = new Dictionary { { "next", thirdPageUrl } }; var secondPageResponse = new ApiResponse> ( CreateResponseWithApiInfo(secondPageLinks), new List { CreateIssue(4), CreateIssue(5), CreateIssue(6) } ); var lastPageResponse = new ApiResponse> ( CreateResponse(HttpStatusCode.OK), new List { CreateIssue(7) } ); var gitHubClient = Substitute.For(); gitHubClient.Connection.Get>(Arg.Is(firstPageUrl), Arg.Is>(d => d.Count == 4 && d["direction"] == "desc" && d["state"] == "open" && d["sort"] == "created" && d["filter"] == "assigned")) .Returns(Task.FromResult>>(firstPageResponse)); gitHubClient.Connection.Get>(secondPageUrl, Arg.Any>()) .Returns(Task.FromResult>>(secondPageResponse)); gitHubClient.Connection.Get>(thirdPageUrl, Arg.Any>()) .Returns(Task.FromResult>>(lastPageResponse)); var client = new ObservableIssuesClient(gitHubClient); var results = await client.GetAllForOwnedAndMemberRepositories().ToArray(); Assert.Equal(7, results.Length); Assert.Equal(firstPageResponse.Body[0].Number, results[0].Number); Assert.Equal(secondPageResponse.Body[1].Number, results[4].Number); Assert.Equal(lastPageResponse.Body[0].Number, results[6].Number); } } public class TheGetAllForOrganizationMethod { [Fact] public void EnsuresNonNullArguments() { var client = new ObservableIssuesClient(Substitute.For()); var options = new ApiOptions(); var request = new RepositoryIssueRequest(); Assert.Throws(() => client.GetAllForOrganization(null)); Assert.Throws(() => client.GetAllForOrganization(null, options)); Assert.Throws(() => client.GetAllForOrganization(null, request)); Assert.Throws(() => client.GetAllForOrganization(null, request, options)); Assert.Throws(() => client.GetAllForOrganization("")); Assert.Throws(() => client.GetAllForOrganization("", options)); Assert.Throws(() => client.GetAllForOrganization("", request)); Assert.Throws(() => client.GetAllForOrganization("", request, options)); Assert.Throws(() => client.GetAllForOrganization("org", (ApiOptions)null)); Assert.Throws(() => client.GetAllForOrganization("org", (IssueRequest)null)); Assert.Throws(() => client.GetAllForOrganization("org", null, options)); Assert.Throws(() => client.GetAllForOrganization("org", request, null)); } [Fact] public async Task ReturnsEveryPageOfIssues() { var firstPageUrl = new Uri("orgs/test/issues", UriKind.Relative); var secondPageUrl = new Uri("https://example.com/page/2"); var firstPageLinks = new Dictionary { { "next", secondPageUrl } }; var firstPageResponse = new ApiResponse> ( CreateResponseWithApiInfo(firstPageLinks), new List { CreateIssue(1), CreateIssue(2), CreateIssue(3) } ); var thirdPageUrl = new Uri("https://example.com/page/3"); var secondPageLinks = new Dictionary { { "next", thirdPageUrl } }; var secondPageResponse = new ApiResponse> ( CreateResponseWithApiInfo(secondPageLinks), new List { CreateIssue(4), CreateIssue(5), CreateIssue(6) } ); var lastPageResponse = new ApiResponse> ( CreateResponse(HttpStatusCode.OK), new List { CreateIssue(7) } ); var gitHubClient = Substitute.For(); gitHubClient.Connection.Get>(Arg.Is(firstPageUrl), Arg.Is>(d => d.Count == 4 && d["direction"] == "desc" && d["state"] == "open" && d["sort"] == "created" && d["filter"] == "assigned")) .Returns(Task.FromResult>>(firstPageResponse)); gitHubClient.Connection.Get>(secondPageUrl, Arg.Any>()) .Returns(Task.FromResult>>(secondPageResponse)); gitHubClient.Connection.Get>(thirdPageUrl, Arg.Any>()) .Returns(Task.FromResult>>(lastPageResponse)); var client = new ObservableIssuesClient(gitHubClient); var results = await client.GetAllForOrganization("test").ToArray(); Assert.Equal(7, results.Length); Assert.Equal(firstPageResponse.Body[0].Number, results[0].Number); Assert.Equal(secondPageResponse.Body[1].Number, results[4].Number); Assert.Equal(lastPageResponse.Body[0].Number, results[6].Number); } } public class TheGetAllForCurrentMethod { [Fact] public void EnsuresNonNullArguments() { var client = new ObservableIssuesClient(Substitute.For()); Assert.Throws(() => client.GetAllForCurrent((ApiOptions)null)); Assert.Throws(() => client.GetAllForCurrent((IssueRequest)null)); Assert.Throws(() => client.GetAllForCurrent(null, new ApiOptions())); Assert.Throws(() => client.GetAllForCurrent(new IssueRequest(), null)); } [Fact] public async Task ReturnsEveryPageOfIssues() { var firstPageUrl = new Uri("issues", UriKind.Relative); var secondPageUrl = new Uri("https://example.com/page/2"); var firstPageLinks = new Dictionary { { "next", secondPageUrl } }; var firstPageResponse = new ApiResponse> ( CreateResponseWithApiInfo(firstPageLinks), new List { CreateIssue(1), CreateIssue(2), CreateIssue(3) } ); var thirdPageUrl = new Uri("https://example.com/page/3"); var secondPageLinks = new Dictionary { { "next", thirdPageUrl } }; var secondPageResponse = new ApiResponse> ( CreateResponseWithApiInfo(secondPageLinks), new List { CreateIssue(4), CreateIssue(5), CreateIssue(6) } ); var lastPageResponse = new ApiResponse> ( CreateResponse(HttpStatusCode.OK), new List { CreateIssue(7) } ); var gitHubClient = Substitute.For(); gitHubClient.Connection.Get>( Arg.Is(firstPageUrl), Arg.Is>(d => d.Count == 4 && d["direction"] == "desc" && d["state"] == "open" && d["sort"] == "created" && d["filter"] == "assigned")) .Returns(Task.FromResult>>(firstPageResponse)); gitHubClient.Connection.Get>(secondPageUrl, Arg.Any>()) .Returns(Task.FromResult>>(secondPageResponse)); gitHubClient.Connection.Get>(thirdPageUrl, Arg.Any>()) .Returns(Task.FromResult>>(lastPageResponse)); var client = new ObservableIssuesClient(gitHubClient); var results = await client.GetAllForCurrent().ToArray(); Assert.Equal(7, results.Length); Assert.Equal(firstPageResponse.Body[0].Number, results[0].Number); Assert.Equal(secondPageResponse.Body[1].Number, results[4].Number); Assert.Equal(lastPageResponse.Body[0].Number, results[6].Number); } } public class TheCreateMethod { [Fact] public void CreatesFromClientIssueIssue() { var newIssue = new NewIssue("some title"); var gitHubClient = Substitute.For(); var client = new ObservableIssuesClient(gitHubClient); client.Create("fake", "repo", newIssue); gitHubClient.Issue.Received().Create("fake", "repo", newIssue); } [Fact] public void CreatesFromClientIssueIssueWithRepositoryId() { var newIssue = new NewIssue("some title"); var gitHubClient = Substitute.For(); var client = new ObservableIssuesClient(gitHubClient); client.Create(1, newIssue); gitHubClient.Issue.Received().Create(1, newIssue); } [Fact] public void EnsuresNonNullArguments() { var gitHubClient = Substitute.For(); var client = new ObservableIssuesClient(gitHubClient); Assert.Throws(() => client.Create(null, "name", new NewIssue("x"))); Assert.Throws(() => client.Create("owner", null, new NewIssue("x"))); Assert.Throws(() => client.Create("owner", "name", null)); Assert.Throws(() => client.Create(1, null)); Assert.Throws(() => client.Create("", "name", new NewIssue("x"))); Assert.Throws(() => client.Create("owner", "", new NewIssue("x"))); } } public class TheUpdateMethod { [Fact] public void UpdatesClientIssueIssue() { var issueUpdate = new IssueUpdate(); var gitHubClient = Substitute.For(); var client = new ObservableIssuesClient(gitHubClient); client.Update("fake", "repo", 42, issueUpdate); gitHubClient.Issue.Received().Update("fake", "repo", 42, issueUpdate); } [Fact] public void UpdatesClientIssueIssueWithRepositoryId() { var issueUpdate = new IssueUpdate(); var gitHubClient = Substitute.For(); var client = new ObservableIssuesClient(gitHubClient); client.Update(1, 42, issueUpdate); gitHubClient.Issue.Received().Update(1, 42, issueUpdate); } [Fact] public void EnsuresNonNullArguments() { var gitHubClient = Substitute.For(); var client = new ObservableIssuesClient(gitHubClient); Assert.Throws(() => client.Update(null, "name", 42, new IssueUpdate())); Assert.Throws(() => client.Update("owner", null, 42, new IssueUpdate())); Assert.Throws(() => client.Update("owner", "name", 42, null)); Assert.Throws(() => client.Update(1, 42, null)); Assert.Throws(() => client.Update("", "name", 42, new IssueUpdate())); Assert.Throws(() => client.Update("owner", "", 42, new IssueUpdate())); } } public class TheLockMethod { [Fact] public void LocksIssue() { var gitHubClient = Substitute.For(); var client = new ObservableIssuesClient(gitHubClient); client.LockUnlock.Lock("fake", "repo", 42); gitHubClient.Issue.Received().LockUnlock.Lock("fake", "repo", 42); } [Fact] public void LocksIssueWithRepositoryId() { var gitHubClient = Substitute.For(); var client = new ObservableIssuesClient(gitHubClient); client.LockUnlock.Lock(1, 42); gitHubClient.Issue.Received().LockUnlock.Lock(1, 42); } [Fact] public void EnsuresNonNullArguments() { var gitHubClient = Substitute.For(); var client = new ObservableIssuesClient(gitHubClient); Assert.Throws(() => client.LockUnlock.Lock(null, "name", 42)); Assert.Throws(() => client.LockUnlock.Lock("owner", null, 42)); Assert.Throws(() => client.LockUnlock.Lock("", "name", 42)); Assert.Throws(() => client.LockUnlock.Lock("owner", "", 42)); } } public class TheUnlockMethod { [Fact] public void UnlocksIssue() { var gitHubClient = Substitute.For(); var client = new ObservableIssuesClient(gitHubClient); client.LockUnlock.Unlock("fake", "repo", 42); gitHubClient.Issue.Received().LockUnlock.Unlock("fake", "repo", 42); } [Fact] public void UnlocksIssueWithRepositoryId() { var gitHubClient = Substitute.For(); var client = new ObservableIssuesClient(gitHubClient); client.LockUnlock.Unlock(1, 42); gitHubClient.Issue.Received().LockUnlock.Unlock(1, 42); } [Fact] public void EnsuresNonNullArguments() { var gitHubClient = Substitute.For(); var client = new ObservableIssuesClient(gitHubClient); Assert.Throws(() => client.LockUnlock.Unlock(null, "name", 42)); Assert.Throws(() => client.LockUnlock.Unlock("owner", null, 42)); Assert.Throws(() => client.LockUnlock.Unlock("", "name", 42)); Assert.Throws(() => client.LockUnlock.Unlock("owner", "", 42)); } } public class TheCtor { [Fact] public void EnsuresNonNullArguments() { Assert.Throws(() => new IssuesClient(null)); } } static Issue CreateIssue(int issueNumber) { var serializer = new SimpleJsonSerializer(); return serializer.Deserialize(@"{""number"": """ + issueNumber + @"""}"); } static IResponse CreateResponseWithApiInfo(IDictionary links) { var apiInfo = new ApiInfo(links, new List(), new List(), "etag", new RateLimit(new Dictionary())); var response = Substitute.For(); response.ApiInfo.Returns(apiInfo); return response; } }