set singular on reaction clients

2026-06-01 18:35:35 +00:00 · 2016-06-01 08:50:42 +02:00
parent 18946fb03f
commit c9fdb45114
24 changed files with 68 additions and 56 deletions
@@ -0,0 +1,54 @@
+using System;
+using System.Reactive.Threading.Tasks;
+using Octokit.Reactive.Internal;
+
+namespace Octokit.Reactive
+{
+    public class ObservableCommitCommentReactionsClient : IObservableCommitCommentReactionsClient
+    {
+        readonly ICommitCommentReactionsClient _client;
+        readonly IConnection _connection;
+
+        public ObservableCommitCommentReactionsClient(IGitHubClient client)
+        {
+            Ensure.ArgumentNotNull(client, "client");
+
+            _client = client.Reaction.CommitComment;
+            _connection = client.Connection;
+        }
+
+        /// <summary>
+        /// Creates a reaction for a specified Commit Comment
+        /// </summary>
+        /// <remarks>http://developer.github.com/v3/repos/comments/#create-reaction-for-a-commit-comment</remarks>
+        /// <param name="owner">The owner of the repository</param>
+        /// <param name="name">The name of the repository</param>
+        /// <param name="number">The comment id</param>
+        /// <param name="reaction">The reaction to create</param>
+        /// <returns></returns>
+        public IObservable<Reaction> CreateReaction(string owner, string name, int number, NewReaction reaction)
+        {
+            Ensure.ArgumentNotNullOrEmptyString(owner, "owner");
+            Ensure.ArgumentNotNullOrEmptyString(name, "name");
+            Ensure.ArgumentNotNull(reaction, "reaction");
+
+            return _client.CreateReaction(owner, name, number, reaction).ToObservable();
+        }
+
+        /// <summary>
+        /// List reactions for a specified Commit Comment
+        /// </summary>
+        /// <remarks>http://developer.github.com/v3/repos/comments/#list-reactions-for-a-commit-comment</remarks>
+        /// <param name="owner">The owner of the repository</param>
+        /// <param name="name">The name of the repository</param>
+        /// <param name="number">The comment id</param>        
+        /// <returns></returns>
+        public IObservable<Reaction> GetAll(string owner, string name, int number)
+        {
+            Ensure.ArgumentNotNullOrEmptyString(owner, "owner");
+            Ensure.ArgumentNotNullOrEmptyString(name, "name");
+
+            return _connection.GetAndFlattenAllPages<Reaction>(ApiUrls.CommitCommentReactions(owner, name, number));
+        }
+    }
+}