Merge pull request #262 from markosko/master

Adding ability to (un/)subscribe to topics at firebase

firebase.android.js

@@ -1491,6 +1491,51 @@ firebase.deleteFile = function (arg) {
   });
 };
 
+firebase.subscribeToTopic = function(topicName){
+  return new Promise(function (resolve, reject) {
+    try{
+
+      if (typeof(com.google.firebase.messaging) === "undefined") {
+        reject("Uncomment firebase-messaging in the plugin's include.gradle first");
+        return;
+      }
+
+      if (firebase.instance === null) {
+        reject("Can be run only after init");
+        return;
+      }
+
+      com.google.firebase.messaging.FirebaseMessaging.getInstance().subscribeToTopic(topicName);
+
+    } catch(ex){
+      console.log("Error in firebase.subscribeToTopic: " + ex);
+      reject(ex);
+    }
+  });
+};
+
+firebase.unsubscribeFromTopic = function(topicName){
+  return new Promise(function (resolve, reject) {
+    try{
+
+      if (typeof(com.google.firebase.messaging) === "undefined") {
+        reject("Uncomment firebase-messaging in the plugin's include.gradle first");
+        return;
+      }
+
+      if (firebase.instance === null) {
+        reject("Can be run only after init");
+        return;
+      }
+
+      com.google.firebase.messaging.FirebaseMessaging.getInstance().unsubscribeFromTopic(topicName);
+
+    } catch(ex){
+      console.log("Error in firebase.unsubscribeFromTopic: " + ex);
+      reject(ex);
+    }
+  }); 
+}
 /*
 firebase.sendCrashLog = function (arg) {
   return new Promise(function (resolve, reject) {

index.d.ts

@@ -569,5 +569,8 @@ export function getDownloadUrl(options: GetDownloadUrlOptions): Promise<string>;
 
 export function deleteFile(options: DeleteFileOptions): Promise<any>;
 
+export function subscribeToTopic(topicName): Promise<any>;
+
+export function unsubscribeFromTopic(topicName): Promise<any>;
 // crash logging
 // export function sendCrashLog(options: SendCrashLogOptions): Promise<any>;