Add Observable ActivitiesClient and interface

Octokit.Reactive/Clients/IObservableActivityClient.cs

@@ -0,0 +1,99 @@
+using System;
+
+namespace Octokit.Reactive
+{
+    public interface IObservableActivityClient
+    {
+        /// <summary>
+        /// Gets all the public events
+        /// </summary>
+        /// <remarks>
+        /// http://developer.github.com/v3/activity/events/#list-public-events
+        /// </remarks>
+        /// <returns>All the public <see cref="Activity"/>s for the particular user.</returns>
+        IObservable<Activity> GetAll();
+
+        /// <summary>
+        /// Gets all the events for a given repository
+        /// </summary>
+        /// <remarks>
+        /// http://developer.github.com/v3/activity/events/#list-issue-events-for-a-repository
+        /// </remarks>
+        /// <param name="owner">The owner of the repository</param>
+        /// <param name="name">The name of the repository</param>
+        /// <returns>All the <see cref="Activity"/>s for the particular repository.</returns>
+        IObservable<Activity> GetAllForRepository(string owner, string name);
+
+        /// <summary>
+        /// Gets all the events for a given repository network
+        /// </summary>
+        /// <remarks>
+        /// http://developer.github.com/v3/activity/events/#list-public-events-for-a-network-of-repositories
+        /// </remarks>
+        /// <param name="owner">The owner of the repository</param>
+        /// <param name="name">The name of the repository</param>
+        /// <returns>All the <see cref="Activity"/>s for the particular repository network.</returns>
+        IObservable<Activity> GetAllForRepositoryNetwork(string owner, string name);
+
+        /// <summary>
+        /// Gets all the events for a given organization
+        /// </summary>
+        /// <remarks>
+        /// http://developer.github.com/v3/activity/events/#list-public-events-for-an-organization
+        /// </remarks>
+        /// <param name="organization">The name of the organization</param>
+        /// <returns>All the <see cref="Activity"/>s for the particular organization.</returns>
+        IObservable<Activity> GetAllForOrganization(string organization);
+
+        /// <summary>
+        /// Gets all the events that have been received by a given user.
+        /// </summary>
+        /// <remarks>
+        /// http://developer.github.com/v3/activity/events/#list-events-that-a-user-has-received
+        /// </remarks>
+        /// <param name="user">The name of the user</param>
+        /// <returns>All the <see cref="Activity"/>s that a particular user has received.</returns>
+        IObservable<Activity> GetUserReceived(string user);
+
+        /// <summary>
+        /// Gets all the events that have been received by a given user.
+        /// </summary>
+        /// <remarks>
+        /// http://developer.github.com/v3/activity/events/#list-public-events-that-a-user-has-received
+        /// </remarks>
+        /// <param name="user">The name of the user</param>
+        /// <returns>All the <see cref="Activity"/>s that a particular user has received.</returns>
+        IObservable<Activity> GetUserReceivedPublic(string user);
+
+        /// <summary>
+        /// Gets all the events that have been performed by a given user.
+        /// </summary>
+        /// <remarks>
+        /// http://developer.github.com/v3/activity/events/#list-events-performed-by-a-user
+        /// </remarks>
+        /// <param name="user">The name of the user</param>
+        /// <returns>All the <see cref="Activity"/>s that a particular user has performed.</returns>
+        IObservable<Activity> GetUserPerformed(string user);
+
+        /// <summary>
+        /// Gets all the public events that have been performed by a given user.
+        /// </summary>
+        /// <remarks>
+        /// http://developer.github.com/v3/activity/events/#list-public-events-performed-by-a-user
+        /// </remarks>
+        /// <param name="user">The name of the user</param>
+        /// <returns>All the public <see cref="Activity"/>s that a particular user has performed.</returns>
+        IObservable<Activity> GetUserPerformedPublic(string user);
+
+        /// <summary>
+        /// Gets all the events that are associated with an organization.
+        /// </summary>
+        /// <remarks>
+        /// http://developer.github.com/v3/activity/events/#list-events-for-an-organization
+        /// </remarks>
+        /// <param name="user">The name of the user</param>
+        /// <param name="organization">The name of the organization</param>
+        /// <returns>All the public <see cref="Activity"/>s that are associated with an organization.</returns>
+        IObservable<Activity> GetForAnOrganization(string user, string organization);
+    }
+}

Octokit.Reactive/Clients/ObservableActivityClient.cs

@@ -0,0 +1,155 @@
+using System;
+using Octokit.Reactive.Internal;
+
+namespace Octokit.Reactive
+{
+    public class ObservableActivityClient : IObservableActivityClient
+    {
+        IConnection _connection;
+
+        public ObservableActivityClient(IGitHubClient client)
+        {
+            Ensure.ArgumentNotNull(client, "client");
+
+            _connection = client.Connection;
+        }
+
+        /// <summary>
+        /// Gets all the public events
+        /// </summary>
+        /// <remarks>
+        /// http://developer.github.com/v3/activity/events/#list-public-events
+        /// </remarks>
+        /// <returns>All the public <see cref="Activity"/>s for the particular user.</returns>
+        public IObservable<Activity> GetAll()
+        {
+            return _connection.GetAndFlattenAllPages<Activity>(ApiUrls.Events());
+        }
+
+        /// <summary>
+        /// Gets all the events for a given repository
+        /// </summary>
+        /// <remarks>
+        /// http://developer.github.com/v3/activity/events/#list-issue-events-for-a-repository
+        /// </remarks>
+        /// <param name="owner">The owner of the repository</param>
+        /// <param name="name">The name of the repository</param>
+        /// <returns>All the <see cref="Activity"/>s for the particular repository.</returns>
+        public IObservable<Activity> GetAllForRepository(string owner, string name)
+        {
+            Ensure.ArgumentNotNullOrEmptyString(owner, "owner");
+            Ensure.ArgumentNotNullOrEmptyString(name, "name");
+
+            return _connection.GetAndFlattenAllPages<Activity>(ApiUrls.IssuesEvents(owner, name));
+        }
+
+        /// <summary>
+        /// Gets all the events for a given repository network
+        /// </summary>
+        /// <remarks>
+        /// http://developer.github.com/v3/activity/events/#list-public-events-for-a-network-of-repositories
+        /// </remarks>
+        /// <param name="owner">The owner of the repository</param>
+        /// <param name="name">The name of the repository</param>
+        /// <returns>All the <see cref="Activity"/>s for the particular repository network.</returns>
+        public IObservable<Activity> GetAllForRepositoryNetwork(string owner, string name)
+        {
+            Ensure.ArgumentNotNullOrEmptyString(owner, "owner");
+            Ensure.ArgumentNotNullOrEmptyString(name, "name");
+
+            return _connection.GetAndFlattenAllPages<Activity>(ApiUrls.NetworkEvents(owner, name));
+        }
+
+        /// <summary>
+        /// Gets all the events for a given organization
+        /// </summary>
+        /// <remarks>
+        /// http://developer.github.com/v3/activity/events/#list-public-events-for-an-organization
+        /// </remarks>
+        /// <param name="organization">The name of the organization</param>
+        /// <returns>All the <see cref="Activity"/>s for the particular organization.</returns>
+        public IObservable<Activity> GetAllForOrganization(string organization)
+        {
+            Ensure.ArgumentNotNullOrEmptyString(organization, "organization");
+
+            return _connection.GetAndFlattenAllPages<Activity>(ApiUrls.OrganizationEvents(organization));
+        }
+
+        /// <summary>
+        /// Gets all the events that have been received by a given user.
+        /// </summary>
+        /// <remarks>
+        /// http://developer.github.com/v3/activity/events/#list-events-that-a-user-has-received
+        /// </remarks>
+        /// <param name="user">The name of the user</param>
+        /// <returns>All the <see cref="Activity"/>s that a particular user has received.</returns>
+        public IObservable<Activity> GetUserReceived(string user)
+        {
+            Ensure.ArgumentNotNullOrEmptyString(user, "user");
+
+            return _connection.GetAndFlattenAllPages<Activity>(ApiUrls.ReceivedEvents(user));
+        }
+
+        /// <summary>
+        /// Gets all the events that have been received by a given user.
+        /// </summary>
+        /// <remarks>
+        /// http://developer.github.com/v3/activity/events/#list-public-events-that-a-user-has-received
+        /// </remarks>
+        /// <param name="user">The name of the user</param>
+        /// <returns>All the <see cref="Activity"/>s that a particular user has received.</returns>
+        public IObservable<Activity> GetUserReceivedPublic(string user)
+        {
+            Ensure.ArgumentNotNullOrEmptyString(user, "user");
+
+            return _connection.GetAndFlattenAllPages<Activity>(ApiUrls.ReceivedEvents(user, true));
+        }
+
+        /// <summary>
+        /// Gets all the events that have been performed by a given user.
+        /// </summary>
+        /// <remarks>
+        /// http://developer.github.com/v3/activity/events/#list-events-performed-by-a-user
+        /// </remarks>
+        /// <param name="user">The name of the user</param>
+        /// <returns>All the <see cref="Activity"/>s that a particular user has performed.</returns>
+        public IObservable<Activity> GetUserPerformed(string user)
+        {
+            Ensure.ArgumentNotNullOrEmptyString(user, "user");
+
+            return _connection.GetAndFlattenAllPages<Activity>(ApiUrls.PerformedEvents(user));
+        }
+
+        /// <summary>
+        /// Gets all the public events that have been performed by a given user.
+        /// </summary>
+        /// <remarks>
+        /// http://developer.github.com/v3/activity/events/#list-public-events-performed-by-a-user
+        /// </remarks>
+        /// <param name="user">The name of the user</param>
+        /// <returns>All the public <see cref="Activity"/>s that a particular user has performed.</returns>
+        public IObservable<Activity> GetUserPerformedPublic(string user)
+        {
+            Ensure.ArgumentNotNullOrEmptyString(user, "user");
+
+            return _connection.GetAndFlattenAllPages<Activity>(ApiUrls.PerformedEvents(user, true));
+        }
+
+        /// <summary>
+        /// Gets all the events that are associated with an organization.
+        /// </summary>
+        /// <remarks>
+        /// http://developer.github.com/v3/activity/events/#list-events-for-an-organization
+        /// </remarks>
+        /// <param name="user">The name of the user</param>
+        /// <param name="organization">The name of the organization</param>
+        /// <returns>All the public <see cref="Activity"/>s that are associated with an organization.</returns>
+        public IObservable<Activity> GetForAnOrganization(string user, string organization)
+        {
+            Ensure.ArgumentNotNullOrEmptyString(user, "user");
+            Ensure.ArgumentNotNullOrEmptyString(organization, "organization");
+
+            return _connection.GetAndFlattenAllPages<Activity>(ApiUrls.OrganizationEvents(user, organization));
+        }
+    }
+}

Octokit.Reactive/Octokit.Reactive.csproj

@@ -73,6 +73,8 @@
     <Compile Include="..\SolutionInfo.cs">
       <Link>Properties\SolutionInfo.cs</Link>
     </Compile>
+    <Compile Include="Clients\IObservableActivityClient.cs" />
+    <Compile Include="Clients\ObservableActivityClient.cs" />
     <Compile Include="Clients\ObservableGitDatabaseClient.cs" />
     <Compile Include="Clients\IObservableGitDatabaseClient.cs" />
     <Compile Include="Clients\IObservableTagsClient.cs" />
@@ -135,4 +137,4 @@
   <Target Name="AfterBuild">
   </Target>
   -->
-</Project>
+</Project>

Octokit.Tests/Clients/ActivitiesClientTests.cs

@@ -1,6 +1,4 @@
-
-
-using System;
+using System;
 using System.Threading.Tasks;
 using NSubstitute;
 using Octokit.Tests.Helpers;

Octokit/Clients/ActivitiesClient.cs

@@ -1,5 +1,4 @@
-
-using System.Collections.Generic;
+using System.Collections.Generic;
 using System.Threading.Tasks;
 
 namespace Octokit

Octokit/Models/Response/Activity.cs

@@ -14,7 +14,7 @@ namespace Octokit
         /// Whether the activity event is public or not.
         /// </summary>
         public bool Public { get; set; }
-        
+
         /// <summary>
         /// The repository associated with the activity event.
         /// </summary>