Repository invitations changes

Octokit.Reactive/Clients/IObservableRepoCollaboratorsClient.cs

@@ -40,6 +40,15 @@ public interface IObservableRepoCollaboratorsClient
         /// <returns></returns>
         IObservable<Unit> Add(string owner, string repo, string user);
 
+        /// <summary>
+        /// Invites a user as a collaborator to a repository.
+        /// </summary>
+        /// <param name="owner">The owner of the repository</param>
+        /// <param name="repo">The name of the repository</param>
+        /// <param name="user">Username of the prospective collaborator</param>
+        /// <returns></returns>
+        IObservable<RepositoryInvitation> Invite(string owner, string repo, string user);
+
         /// <summary>
         /// Removes a user as a collaborator for a repository.
         /// </summary>

Octokit.Reactive/Clients/IObservableRepositoriesClient.cs

@@ -597,12 +597,21 @@ public interface IObservableRepositoriesClient
         /// See the <a href="https://developer.github.com/v3/repos/keys/">Repository Deploy Keys API documentation</a> for more information.
         /// </remarks>
         IObservableRepositoryDeployKeysClient DeployKeys { get; }
+
         /// <summary>
         /// A client for GitHub's Repository Pages API.
         /// </summary>
         /// <remarks>
         /// See the <a href="https://developer.github.com/v3/repos/pages/">Repository Pages API documentation</a> for more information.
         /// </remarks>
         IObservableRepositoryPagesClient Page { get; }
+
+        /// <summary>
+        /// A client for GitHub's Repository Invitations API.
+        /// </summary>
+        /// <remarks>
+        /// See the <a href="https://developer.github.com/v3/repos/invitations/">Repository Invitations API documentation</a> for more information.
+        /// </remarks>
+        IObservableRepositoryInvitationsClient Invitation { get; }
     }
 }

Octokit.Reactive/Clients/IObservableRepositoryInvitationsClient.cs

@@ -0,0 +1,66 @@
+using System;
+using System.Diagnostics.CodeAnalysis;
+using System.Reactive;
+
+namespace Octokit.Reactive
+{
+    public interface IObservableRepositoryInvitationsClient
+    {
+        /// <summary>
+        /// Accept a repository invitation.
+        /// </summary>
+        /// <remarks>
+        /// See the <a href="https://developer.github.com/v3/repos/invitations/#accept-a-repository-invitation">API documentation</a> for more information.
+        /// </remarks>        
+        /// <param name="id">The id of the invitation</param>        
+        IObservable<Unit> Accept(int id);
+
+        /// <summary>
+        /// Decline a repository invitation.
+        /// </summary>
+        /// <remarks>
+        /// See the <a href="https://developer.github.com/v3/repos/invitations/#decline-a-repository-invitation">API documentation</a> for more information.
+        /// </remarks>        
+        /// <param name="id">The id of the invitation</param>        
+        IObservable<Unit> Decline(int id);
+
+        /// <summary>
+        /// Deletes a repository invitation.
+        /// </summary>
+        /// <remarks>
+        /// See the <a href="https://developer.github.com/v3/repos/invitations/#delete-a-repository-invitation">API documentation</a> for more information.
+        /// </remarks>
+        /// <param name="repositoryId">The id ot the repository</param>
+        /// <param name="invitationId">The id of the invitation</param>        
+        IObservable<Unit> Delete(int repositoryId, int invitationId);
+
+        /// <summary>
+        /// Gets all invitations for the current user.
+        /// </summary>
+        /// <remarks>
+        /// See the <a href="https://developer.github.com/v3/repos/invitations/#list-a-users-repository-invitations">API documentation</a> for more information.
+        /// </remarks>       
+        [SuppressMessage("Microsoft.Design", "CA1024:UsePropertiesWhereAppropriate")]
+        IObservable<RepositoryInvitation> GetAllForCurrent();
+
+        /// <summary>
+        /// Gets all the invitations on a repository.
+        /// </summary>
+        /// <remarks>
+        /// See the <a href="https://developer.github.com/v3/repos/invitations/#list-invitations-for-a-repository">API documentation</a> for more information.
+        /// </remarks>        
+        /// <param name="id">The id of the repository</param>        
+        IObservable<RepositoryInvitation> GetAllForRepository(int id);
+
+        /// <summary>
+        /// Updates a repository invitation.
+        /// </summary>
+        /// <remarks>
+        /// See the <a href="https://developer.github.com/v3/repos/invitations/#update-a-repository-invitation">API documentation</a> for more information.
+        /// </remarks>
+        /// <param name="repositoryId">The id ot the repository</param>
+        /// <param name="invitationId">The id of the invitation</param>   
+        /// <param name="permissions">The permission for the collsborator</param>
+        IObservable<RepositoryInvitation> Edit(int repositoryId, int invitationId, InvitationUpdate permissions);
+    }
+}

Octokit.Reactive/Clients/ObservableRepoCollaboratorsClient.cs

@@ -44,7 +44,7 @@ public IObservable<User> GetAll(string owner, string repo, ApiOptions options)
             Ensure.ArgumentNotNullOrEmptyString(owner, "owner");
             Ensure.ArgumentNotNullOrEmptyString(repo, "repo");
             Ensure.ArgumentNotNull(options, "options");
-            
+
             return _connection.GetAndFlattenAllPages<User>(ApiUrls.RepoCollaborators(owner, repo), options);
         }
 
@@ -72,6 +72,22 @@ public IObservable<Unit> Add(string owner, string repo, string user)
             return _client.Add(owner, repo, user).ToObservable();
         }
 
+        /// <summary>
+        /// Invites a user as a collaborator to a repository.
+        /// </summary>
+        /// <param name="owner">The owner of the repository</param>
+        /// <param name="repo">The name of the repository</param>
+        /// <param name="user">Username of the prospective collaborator</param>
+        /// <returns></returns>
+        public IObservable<RepositoryInvitation> Invite(string owner, string repo, string user)
+        {
+            Ensure.ArgumentNotNullOrEmptyString(owner, "owner");
+            Ensure.ArgumentNotNullOrEmptyString(repo, "repo");
+            Ensure.ArgumentNotNullOrEmptyString(user, "user");
+
+            return _client.Invite(owner, repo, user).ToObservable();
+        }
+
         /// <summary>
         /// Removes a user as a collaborator for a repository.
         /// </summary>

Octokit.Reactive/Clients/ObservableRepositoriesClient.cs

@@ -42,6 +42,7 @@ public ObservableRepositoriesClient(IGitHubClient client)
             Content = new ObservableRepositoryContentsClient(client);
             Merging = new ObservableMergingClient(client);
             Page = new ObservableRepositoryPagesClient(client);
+            Invitation = new ObservableRepositoryInvitationsClient(client);
         }
 
         /// <summary>
@@ -900,5 +901,13 @@ public IObservable<CompareResult> Compare(string owner, string name, string @bas
         /// See the <a href="https://developer.github.com/v3/repos/pages/">Repository Pages API documentation</a> for more information.
         /// </remarks>
         public IObservableRepositoryPagesClient Page { get; private set; }
+
+        /// <summary>
+        /// A client for GitHub's Repository Invitations API.
+        /// </summary>
+        /// <remarks>
+        /// See the <a href="https://developer.github.com/v3/repos/invitations/">Repository Invitations API documentation</a> for more information.
+        /// </remarks>
+        public IObservableRepositoryInvitationsClient Invitation { get; private set; }        
     }
 }

Octokit.Reactive/Clients/ObservableRepositoryInvitationsClient.cs

@@ -0,0 +1,95 @@
+using Octokit.Reactive.Internal;
+using System;
+using System.Reactive;
+using System.Reactive.Threading.Tasks;
+
+namespace Octokit.Reactive
+{
+    public class ObservableRepositoryInvitationsClient : IObservableRepositoryInvitationsClient
+    {
+        readonly IRepositoryInvitationsClient _client;
+        readonly IConnection _connection;
+
+        public ObservableRepositoryInvitationsClient(IGitHubClient client)
+        {
+            Ensure.ArgumentNotNull(client, "client");
+
+            _client = client.Repository.Invitation;
+            _connection = client.Connection;
+        }
+
+        /// <summary>
+        /// Accept a repository invitation.
+        /// </summary>
+        /// <remarks>
+        /// See the <a href="https://developer.github.com/v3/repos/invitations/#accept-a-repository-invitation">API documentation</a> for more information.
+        /// </remarks>        
+        /// <param name="id">The id of the invitation</param>   
+        public IObservable<Unit> Accept(int id)
+        {
+            return _client.Accept(id).ToObservable();
+        }
+
+        /// <summary>
+        /// Decline a repository invitation.
+        /// </summary>
+        /// <remarks>
+        /// See the <a href="https://developer.github.com/v3/repos/invitations/#decline-a-repository-invitation">API documentation</a> for more information.
+        /// </remarks>        
+        /// <param name="id">The id of the invitation</param>   
+        public IObservable<Unit> Decline(int id)
+        {
+            return _client.Decline(id).ToObservable();
+        }
+
+        /// <summary>
+        /// Deletes a repository invitation.
+        /// </summary>
+        /// <remarks>
+        /// See the <a href="https://developer.github.com/v3/repos/invitations/#delete-a-repository-invitation">API documentation</a> for more information.
+        /// </remarks>
+        /// <param name="repositoryId">The id ot the repository</param>
+        /// <param name="invitationId">The id of the invitation</param>        
+        public IObservable<Unit> Delete(int repositoryId, int invitationId)
+        {
+            return _client.Delete(repositoryId, invitationId).ToObservable();
+        }
+
+        /// <summary>
+        /// Updates a repository invitation.
+        /// </summary>
+        /// <remarks>
+        /// See the <a href="https://developer.github.com/v3/repos/invitations/#update-a-repository-invitation">API documentation</a> for more information.
+        /// </remarks>
+        /// <param name="repositoryId">The id ot the repository</param>
+        /// <param name="invitationId">The id of the invitation</param>   
+        /// <param name="permissions">The permission for the collsborator</param>
+        public IObservable<RepositoryInvitation> Edit(int repositoryId, int invitationId, InvitationUpdate permissions)
+        {
+            return _client.Edit(repositoryId, invitationId, permissions).ToObservable();
+        }
+
+        /// <summary>
+        /// Gets all invitations for the current user.
+        /// </summary>
+        /// <remarks>
+        /// See the <a href="https://developer.github.com/v3/repos/invitations/#list-a-users-repository-invitations">API documentation</a> for more information.
+        /// </remarks>        
+        public IObservable<RepositoryInvitation> GetAllForCurrent()
+        {
+            return _connection.GetAndFlattenAllPages<RepositoryInvitation>(ApiUrls.UserInvitations(), null, AcceptHeaders.InvitationsApiPreview, null);
+        }
+
+        /// <summary>
+        /// Gets all the invitations on a repository.
+        /// </summary>
+        /// <remarks>
+        /// See the <a href="https://developer.github.com/v3/repos/invitations/#list-invitations-for-a-repository">API documentation</a> for more information.
+        /// </remarks>        
+        /// <param name="id">The id of the repository</param>  
+        public IObservable<RepositoryInvitation> GetAllForRepository(int id)
+        {
+            return _connection.GetAndFlattenAllPages<RepositoryInvitation>(ApiUrls.RepositoryInvitations(id), null, AcceptHeaders.InvitationsApiPreview, null);
+        }
+    }
+}

Octokit.Reactive/Octokit.Reactive-Mono.csproj

@@ -192,6 +192,8 @@
     <Compile Include="Clients\ObservablePullRequestReviewCommentReactionsClient.cs" />
     <Compile Include="Clients\IObservableUserGpgKeysClient.cs" />
     <Compile Include="Clients\ObservableUserGpgKeysClient.cs" />
+    <Compile Include="Clients\IObservableRepositoryInvitationsClient.cs" />
+    <Compile Include="Clients\ObservableRepositoryInvitationsClient.cs" />
   </ItemGroup>
   <Import Project="$(MSBuildBinPath)\Microsoft.CSharp.targets" />
   <ItemGroup>

Octokit.Reactive/Octokit.Reactive-MonoAndroid.csproj

@@ -208,6 +208,8 @@
     <Compile Include="Clients\ObservablePullRequestReviewCommentReactionsClient.cs" />
     <Compile Include="Clients\IObservableUserGpgKeysClient.cs" />
     <Compile Include="Clients\ObservableUserGpgKeysClient.cs" />
+    <Compile Include="Clients\IObservableRepositoryInvitationsClient.cs" />
+    <Compile Include="Clients\ObservableRepositoryInvitationsClient.cs" />
   </ItemGroup>
   <Import Project="$(MSBuildExtensionsPath)\Novell\Novell.MonoDroid.CSharp.targets" />
   <ItemGroup>

Octokit.Reactive/Octokit.Reactive-Monotouch.csproj

@@ -204,6 +204,8 @@
     <Compile Include="Clients\ObservablePullRequestReviewCommentReactionsClient.cs" />
     <Compile Include="Clients\IObservableUserGpgKeysClient.cs" />
     <Compile Include="Clients\ObservableUserGpgKeysClient.cs" />
+    <Compile Include="Clients\IObservableRepositoryInvitationsClient.cs" />
+    <Compile Include="Clients\ObservableRepositoryInvitationsClient.cs" />
   </ItemGroup>
   <Import Project="$(MSBuildBinPath)\Microsoft.CSharp.targets" />
   <ItemGroup>

Octokit.Reactive/Octokit.Reactive.csproj

@@ -100,6 +100,7 @@
     <Compile Include="Clients\IObservablePullRequestReviewCommentReactionsClient.cs" />
     <Compile Include="Clients\IObservableRepositoryCommitsClients.cs" />
     <Compile Include="Clients\IObservableRepositoryDeployKeysClient.cs" />
+    <Compile Include="Clients\IObservableRepositoryInvitationsClient.cs" />
     <Compile Include="Clients\IObservableRepositoryPagesClient.cs" />
     <Compile Include="Clients\IObservableUserAdministrationClient.cs" />
     <Compile Include="Clients\IObservableUserGpgKeysClient.cs" />
@@ -134,6 +135,7 @@
     <Compile Include="Clients\ObservableIssuesLabelsClient.cs" />
     <Compile Include="Clients\ObservableRepositoryCommitsClients.cs" />
     <Compile Include="Clients\ObservableRepositoryContentsClient.cs" />
+    <Compile Include="Clients\ObservableRepositoryInvitationsClient.cs" />
     <Compile Include="Clients\ObservableRepositoryPagesClient.cs" />
     <Compile Include="Clients\ObservableSearchClient.cs" />
     <Compile Include="Clients\IObservableBlobsClient.cs" />

Octokit.Tests.Integration/Clients/RepositoryCollaboratorClientTests.cs

@@ -136,4 +136,24 @@ public async Task ReturnsTrueIfUserIsCollaborator()
             }
         }
     }
+
+    public class TheInviteNewCollaboratorMethod
+    {
+        [IntegrationTest]
+        public async Task CanInviteNewCollaborator()
+        {
+            var github = Helper.GetAuthenticatedClient();
+            var repoName = Helper.MakeNameWithTimestamp("public-repo");
+
+            using (var context = await github.CreateRepositoryContext(new NewRepository(repoName)))
+            {
+                var fixture = github.Repository.Collaborator;
+
+                // invite a collaborator
+                var response = await fixture.Invite(context.RepositoryOwner, context.RepositoryName, "maddin2016");
+
+                Assert.Equal("maddin2016", response.Invitee.Login);
+            }
+        }
+    }
 }

Octokit.Tests/Clients/RepoCollaboratorsClientTests.cs

@@ -146,6 +146,32 @@ public async Task EnsuresNonNullArguments()
             }
         }
 
+        public class TheInviteMethod
+        {
+            [Fact]
+            public void RequestsCorrectUrl()
+            {
+                var connection = Substitute.For<IApiConnection>();
+                var client = new RepoCollaboratorsClient(connection);
+
+                client.Invite("owner", "test", "user1");
+                connection.Received().Put<RepositoryInvitation>(Arg.Is<Uri>(u => u.ToString() == "repos/owner/test/collaborators/user1"), Arg.Any<object>(), Arg.Any<string>(), Arg.Is<string>("application/vnd.github.swamp-thing-preview+json"));
+            }
+
+            [Fact]
+            public async Task EnsuresNonNullArguments()
+            {
+                var client = new RepoCollaboratorsClient(Substitute.For<IApiConnection>());
+
+                await Assert.ThrowsAsync<ArgumentNullException>(() => client.Invite(null, "test", "user1"));
+                await Assert.ThrowsAsync<ArgumentException>(() => client.Invite("", "test", "user1"));
+                await Assert.ThrowsAsync<ArgumentNullException>(() => client.Invite("owner", null, "user1"));
+                await Assert.ThrowsAsync<ArgumentException>(() => client.Invite("owner", "", "user1"));
+                await Assert.ThrowsAsync<ArgumentException>(() => client.Invite("owner", "test", ""));
+                await Assert.ThrowsAsync<ArgumentNullException>(() => client.Invite("owner", "test", null));
+            }
+        }
+
         public class TheDeleteMethod
         {
             [Fact]