Merge pull request #12 from firebase/hkj-fcm

FCM Implementation (Part 1)

Author: hiranya911

FirebaseAdmin/FirebaseAdmin.IntegrationTests/FirebaseMessagingTest.cs

@@ -0,0 +1,53 @@
+// Copyright 2018, Google Inc. All rights reserved.
+//
+// Licensed under the Apache License, Version 2.0 (the "License");
+// you may not use this file except in compliance with the License.
+// You may obtain a copy of the License at
+//
+//     http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing, software
+// distributed under the License is distributed on an "AS IS" BASIS,
+// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+// See the License for the specific language governing permissions and
+// limitations under the License.
+
+using System;
+using System.Text.RegularExpressions;
+using System.Threading.Tasks;
+using FirebaseAdmin.Messaging;
+using Xunit;
+
+namespace FirebaseAdmin.IntegrationTests
+{
+    public class FirebaseMessagingTest
+    {
+        public FirebaseMessagingTest()
+        {
+            IntegrationTestUtils.EnsureDefaultApp();
+        }
+
+        [Fact]
+        public async Task Send()
+        {
+            var message = new Message()
+            {
+                Topic = "foo-bar",
+                Notification = new Notification()
+                {
+                    Title = "Title",
+                    Body = "Body",
+                },
+                Android = new AndroidConfig()
+                {
+                    Priority = Priority.Normal,
+                    TimeToLive = TimeSpan.FromHours(1),
+                    RestrictedPackageName = "com.google.firebase.testing",
+                },
+            };
+            var id = await FirebaseMessaging.DefaultInstance.SendAsync(message, dryRun: true);
+            Assert.True(!string.IsNullOrEmpty(id));
+            Assert.Matches(new Regex("^projects/.*/messages/.*$"), id);
+        }
+    }
+}

FirebaseAdmin/FirebaseAdmin.Tests/Messaging/FirebaseMessagingClientTest.cs

@@ -0,0 +1,116 @@
+// Copyright 2018, Google Inc. All rights reserved.
+//
+// Licensed under the Apache License, Version 2.0 (the "License");
+// you may not use this file except in compliance with the License.
+// You may obtain a copy of the License at
+//
+//     http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing, software
+// distributed under the License is distributed on an "AS IS" BASIS,
+// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+// See the License for the specific language governing permissions and
+// limitations under the License.
+
+using System;
+using System.Net;
+using System.Threading;
+using System.Threading.Tasks;
+using FirebaseAdmin.Tests;
+using Google.Apis.Auth.OAuth2;
+using Google.Apis.Http;
+using Newtonsoft.Json;
+using Xunit;
+
+namespace FirebaseAdmin.Messaging.Tests
+{
+    public class FirebaseMessagingClientTest
+    {
+        private static readonly GoogleCredential MockCredential =
+            GoogleCredential.FromAccessToken("test-token");
+
+        [Fact]
+        public void NoProjectId()
+        {
+            var clientFactory = new HttpClientFactory();
+            Assert.Throws<FirebaseException>(
+                () => new FirebaseMessagingClient(clientFactory, MockCredential, null));
+            Assert.Throws<FirebaseException>(
+                () => new FirebaseMessagingClient(clientFactory, MockCredential, string.Empty));
+        }
+
+        [Fact]
+        public void NoCredential()
+        {
+            var clientFactory = new HttpClientFactory();
+            Assert.Throws<ArgumentNullException>(
+                () => new FirebaseMessagingClient(clientFactory, null, "test-project"));
+        }
+
+        [Fact]
+        public void NoClientFactory()
+        {
+            var clientFactory = new HttpClientFactory();
+            Assert.Throws<ArgumentNullException>(
+                () => new FirebaseMessagingClient(null, MockCredential, "test-project"));
+        }
+
+        [Fact]
+        public async Task SendAsync()
+        {
+            var handler = new MockMessageHandler()
+            {
+                Response = new FirebaseMessagingClient.SendResponse()
+                {
+                    Name = "test-response",
+                },
+            };
+            var factory = new MockHttpClientFactory(handler);
+            var client = new FirebaseMessagingClient(factory, MockCredential, "test-project");
+            var message = new Message()
+            {
+                Topic = "test-topic",
+            };
+            var response = await client.SendAsync(message);
+            Assert.Equal("test-response", response);
+            var req = JsonConvert.DeserializeObject<FirebaseMessagingClient.SendRequest>(
+                handler.Request);
+            Assert.Equal("test-topic", req.Message.Topic);
+            Assert.False(req.ValidateOnly);
+            Assert.Equal(1, handler.Calls);
+
+            // Send in dryRun mode.
+            response = await client.SendAsync(message, dryRun: true);
+            Assert.Equal("test-response", response);
+            req = JsonConvert.DeserializeObject<FirebaseMessagingClient.SendRequest>(
+                handler.Request);
+            Assert.Equal("test-topic", req.Message.Topic);
+            Assert.True(req.ValidateOnly);
+            Assert.Equal(2, handler.Calls);
+        }
+
+        [Fact]
+        public async Task HttpErrorAsync()
+        {
+            var handler = new MockMessageHandler()
+            {
+                StatusCode = HttpStatusCode.InternalServerError,
+                Response = "not json",
+            };
+            var factory = new MockHttpClientFactory(handler);
+            var client = new FirebaseMessagingClient(factory, MockCredential, "test-project");
+            var message = new Message()
+            {
+                Topic = "test-topic",
+            };
+            var ex = await Assert.ThrowsAsync<FirebaseException>(
+                async () => await client.SendAsync(message));
+            Assert.Contains("not json", ex.Message);
+            var req = JsonConvert.DeserializeObject<FirebaseMessagingClient.SendRequest>(
+                handler.Request);
+            Assert.Equal("test-topic", req.Message.Topic);
+            Assert.False(req.ValidateOnly);
+            Assert.Equal(1, handler.Calls);
+        }
+    }
+}

FirebaseAdmin/FirebaseAdmin.Tests/Messaging/FirebaseMessagingTest.cs

@@ -0,0 +1,84 @@
+// Copyright 2018, Google Inc. All rights reserved.
+//
+// Licensed under the Apache License, Version 2.0 (the "License");
+// you may not use this file except in compliance with the License.
+// You may obtain a copy of the License at
+//
+//     http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing, software
+// distributed under the License is distributed on an "AS IS" BASIS,
+// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+// See the License for the specific language governing permissions and
+// limitations under the License.
+
+using System;
+using System.Threading;
+using System.Threading.Tasks;
+using FirebaseAdmin.Tests;
+using Google.Apis.Auth.OAuth2;
+using Xunit;
+
+namespace FirebaseAdmin.Messaging.Tests
+{
+    public class FirebaseMessagingTest : IDisposable
+    {
+        private static readonly GoogleCredential MockCredential =
+            GoogleCredential.FromFile("./resources/service_account.json");
+
+        [Fact]
+        public void GetMessagingWithoutApp()
+        {
+            Assert.Null(FirebaseMessaging.DefaultInstance);
+        }
+
+        [Fact]
+        public void GetDefaultMessaging()
+        {
+            var app = FirebaseApp.Create(new AppOptions() { Credential = MockCredential });
+            FirebaseMessaging messaging = FirebaseMessaging.DefaultInstance;
+            Assert.NotNull(messaging);
+            Assert.Same(messaging, FirebaseMessaging.DefaultInstance);
+            app.Delete();
+            Assert.Null(FirebaseMessaging.DefaultInstance);
+        }
+
+        [Fact]
+        public void GetMessaging()
+        {
+            var app = FirebaseApp.Create(new AppOptions() { Credential = MockCredential }, "MyApp");
+            FirebaseMessaging messaging = FirebaseMessaging.GetMessaging(app);
+            Assert.NotNull(messaging);
+            Assert.Same(messaging, FirebaseMessaging.GetMessaging(app));
+            app.Delete();
+            Assert.Throws<InvalidOperationException>(() => FirebaseMessaging.GetMessaging(app));
+        }
+
+        [Fact]
+        public async Task UseAfterDelete()
+        {
+            var app = FirebaseApp.Create(new AppOptions() { Credential = MockCredential });
+            FirebaseMessaging messaging = FirebaseMessaging.DefaultInstance;
+            app.Delete();
+            await Assert.ThrowsAsync<ObjectDisposedException>(
+                async () => await messaging.SendAsync(new Message() { Topic = "test-topic" }));
+        }
+
+        [Fact]
+        public async Task SendMessageCancel()
+        {
+            var cred = GoogleCredential.FromFile("./resources/service_account.json");
+            FirebaseApp.Create(new AppOptions() { Credential = cred });
+            var canceller = new CancellationTokenSource();
+            canceller.Cancel();
+            await Assert.ThrowsAsync<OperationCanceledException>(
+                async () => await FirebaseMessaging.DefaultInstance.SendAsync(
+                    new Message() { Topic = "test-topic" }, canceller.Token));
+        }
+
+        public void Dispose()
+        {
+            FirebaseApp.DeleteAll();
+        }
+    }
+}