Add Reactive implementation and unit/integration tests

2026-06-08 20:45:51 +00:00 · 2016-02-17 22:20:55 +10:00
parent 047a78361a
commit 8c8c637065
7 changed files with 272 additions and 4 deletions
@@ -0,0 +1,87 @@
+using System.Linq;
+using System.Threading.Tasks;
+using Octokit.Reactive;
+using Octokit.Tests.Integration.Helpers;
+using Xunit;
+using System.Reactive.Linq;
+
+namespace Octokit.Tests.Integration.Clients
+{
+    public class ObservableUserKeysClientTests
+    {
+        readonly IObservableGitHubClient _github;
+
+        public ObservableUserKeysClientTests()
+        {
+            _github = new ObservableGitHubClient(Helper.GetAuthenticatedClient());
+        }
+
+        [IntegrationTest]
+        public async Task CanGetAllForCurrentUser()
+        {
+            using (var context = await _github.CreatePublicKeyContext())
+            {
+                var observable = _github.User.Keys.GetAll();
+                var keys = await (observable.ToList());
+
+                Assert.NotEmpty(keys);
+
+                var first = keys[0];
+                Assert.NotNull(first.Id);
+                Assert.NotNull(first.Key);
+                Assert.NotNull(first.Title);
+                Assert.NotNull(first.Url);
+            }
+        }
+
+        [IntegrationTest]
+        public async Task CanGetAllForGivenUser()
+        {
+            var observable = _github.User.Keys.GetAll("shiftkey");
+            var keys = await (observable.ToList());
+
+            Assert.NotEmpty(keys);
+
+            var first = keys[0];
+            Assert.NotNull(first.Id);
+            Assert.NotNull(first.Key);
+            Assert.Null(first.Title);
+            Assert.Null(first.Url);
+        }
+
+        [IntegrationTest]
+        public async Task CanGetKeyById()
+        {
+            using (var context = await _github.CreatePublicKeyContext())
+            {
+                var observable = _github.User.Keys.Get(context.KeyId);
+                var key = await observable;
+
+                Assert.Equal(key.Title, context.KeyTitle);
+                Assert.Equal(key.Key, context.KeyData);
+            }
+        }
+
+        [IntegrationTest]
+        public async Task CanCreateAndDeleteKey()
+        {
+            // Create a key
+            string keyTitle = "title";
+            string keyData = "ssh-rsa AAAAB3NzaC1yc2EAAAABJQAAAQEAjo4DqFKg8dOxiz/yjypmN1A4itU5QOStyYrfOFuTinesU/2zm9hqxJ5BctIhgtSHJ5foxkhsiBji0qrUg73Q25BThgNg8YFE8njr4EwjmqSqW13akx/zLV0GFFU0SdJ2F6rBldhi93lMnl0ex9swBqa3eLTY8C+HQGBI6MQUMw+BKp0oFkz87Kv+Pfp6lt/Uo32ejSxML1PT5hTH5n+fyl0ied+sRmPGZWmWoHB5Bc9mox7lB6I6A/ZgjtBqbEEn4HQ2/6vp4ojKfSgA4Mm7XMu0bZzX0itKjH1QWD9Lr5apV1cmZsj49Xf8SHucTtH+bq98hb8OOXEGFzplwsX2MQ==";
+            
+            var observable = _github.User.Keys.Create(new NewPublicKey(keyTitle, keyData));
+            var key = await observable;
+
+            Assert.NotNull(key);
+            Assert.Equal(key.Title, "title");
+            Assert.Equal(key.Key, keyData);
+
+            // Delete key
+            await _github.User.Keys.Delete(key.Id);
+
+            // Verify key no longer exists
+            var keys = await (_github.User.Keys.GetAll().ToList());
+            Assert.False(keys.Any(k => k.Title == keyTitle && k.Key == keyData));
+        }
+    }
+}