sending push to multiple tokens is single call added

Author: Gowtham

.idea/compiler.xml

@@ -23,8 +23,9 @@ class MainActivity : AppCompatActivity(), FCMSender.ResponseListener {
         data.put("message", "Click to view..")
         data.put("type", "new_logged_in")
         val push = FCMSender.Builder()
-            .serverKey("Server key")
-            .to("topic/testTopic") //either topic or user registration token
+            .serverKey("Your server key")
+            .toTokenOrTopic("topic/TestTopic") //either topic or user registration token
+//          .toMultipleTokens(listOfToken)
             .responseListener(this)
 //          .setTimeToLive(30) // 0 to 2,419,200 seconds (4 weeks)
 //          .setDryRun(false)  //test a request without actually sending a message.
@@ -38,8 +39,8 @@ class MainActivity : AppCompatActivity(), FCMSender.ResponseListener {
         Toast.makeText(this, "onSuccess", Toast.LENGTH_SHORT).show()
     }
 
-    override fun onFailure(errorCode: Int) {
-        Log.d("onFailure","s$errorCode")
+    override fun onFailure(errorCode: Int,message: String) {
+        Log.d("onFailure","$errorCode $message")
         Toast.makeText(this, "onFailure", Toast.LENGTH_SHORT).show()
     }
 

.idea/gradle.xml

@@ -9,6 +9,7 @@ import kotlinx.coroutines.launch
 import okhttp3.*
 import okhttp3.MediaType.Companion.toMediaTypeOrNull
 import okhttp3.RequestBody.Companion.toRequestBody
+import org.json.JSONArray
 import org.json.JSONObject
 import java.io.IOException
 import java.util.concurrent.TimeUnit
@@ -19,26 +20,29 @@ internal class ApiCall(val context: Context) {
 
     private var responseListener: FCMSender.ResponseListener? = null
 
-    private var to: String? = null
+    private var toTokenOrTopic: String? = null
 
     private var timeToLive: Long?=null
 
     private var dryRun: Boolean?=null
 
+    private var toMultipleToken: ArrayList<String>?=null
+
     private var customData: JSONObject? = null
 
     constructor(
         context: Context,
         serverKey: String,
         responseListener: FCMSender.ResponseListener,
-        to: String?,
+        toTokenOrTopic: String?,
+        toMultipleToken: ArrayList<String>?,
         timeToLive: Long?,
         dryRun: Boolean?,
-        customData: JSONObject?
-    ) : this(context) {
+        customData: JSONObject?) : this(context) {
         this.serverKey = serverKey
         this.responseListener = responseListener
-        this.to = to
+        this.toTokenOrTopic = toTokenOrTopic
+        this.toMultipleToken = toMultipleToken
         this.timeToLive = timeToLive
         this.dryRun = dryRun
         this.customData = customData
@@ -47,7 +51,10 @@ internal class ApiCall(val context: Context) {
     fun sendPush() {
         try {
             val jsonObject = JSONObject()
-            jsonObject.put("to", to)
+            if (toTokenOrTopic!=null)
+                jsonObject.put("to", toTokenOrTopic)
+            else
+                jsonObject.put("registration_ids", JSONArray(toMultipleToken))
             jsonObject.put("priority","high")
             timeToLive?.let { jsonObject.put("time_to_live",it) }
             dryRun?.let { jsonObject.put("dry_run",it) }
@@ -76,7 +83,7 @@ internal class ApiCall(val context: Context) {
                 override fun onFailure(call: Call, e: IOException) {
                     e.printStackTrace()
                     GlobalScope.launch(Dispatchers.Main) {
-                        responseListener?.onFailure(188)
+                        responseListener?.onFailure(188,e.message.toString())
                     }
                 }
 
@@ -85,7 +92,7 @@ internal class ApiCall(val context: Context) {
                         if(response.code==200)
                             responseListener?.onSuccess(response.body?.string().toString())
                         else
-                            responseListener?.onFailure(response.code)
+                            responseListener?.onFailure(response.code,response.body?.string().toString())
                     }
                 }
             })

.idea/misc.xml

@@ -5,16 +5,16 @@ import org.json.JSONObject
 
 class FCMSender(
     private val serverKey: String?,
-    private val to: String?,
+    private val toTokenOrTopic: String?,
+    private val toMultipleToken: ArrayList<String>?,
     private val timeToLive: Long?,
     private val dryRun: Boolean?,
     private val customData: JSONObject?,
-    private val listener: ResponseListener?
-) {
+    private val listener: ResponseListener?) {
 
     interface ResponseListener {
         fun onSuccess(response: String)
-        fun onFailure(errorCode: Int)
+        fun onFailure(errorCode: Int,message: String)
     }
 
     fun sendPush(context: Context) {
@@ -24,12 +24,14 @@ class FCMSender(
                     throw NullPointerException("Serverkey is null")
                 }
                 listener == null -> throw NullPointerException("Response Listener is null")
-                to == null -> throw NullPointerException("to is null")
+                toTokenOrTopic == null && toMultipleToken==null -> throw NullPointerException("toTokenOrTopic and toMultipleToken is null.You can use either one")
+                toTokenOrTopic != null && toMultipleToken!=null -> throw IllegalArgumentException("You've passed toTokenOrTopic and toMultipleToken.You can use either one")
+                toMultipleToken != null && toMultipleToken.isEmpty() -> throw IllegalArgumentException("You've passed a empty list for toMultipleToken")
                 customData == null -> throw NullPointerException("data is null")
                 else -> {
                     val apiCall = ApiCall(
                         context, serverKey, listener,
-                        to, timeToLive, dryRun, customData
+                        toTokenOrTopic,toMultipleToken, timeToLive, dryRun, customData
                     )
                     apiCall.sendPush()
                 }
@@ -42,18 +44,20 @@ class FCMSender(
     data class Builder(
         private var serverKey: String? = null,
         private var listener: ResponseListener? = null,
-        private var to: String? = null,
+        private var toTokenOrTopic: String? = null,
+        private var toMultipleTokens: ArrayList<String>?=null,
         private var timeToLive: Long? = null,
         private var dryRun: Boolean=false,
-        private var customData: JSONObject? = null
-    ) {
+        private var customData: JSONObject? = null) {
+
         fun serverKey(serverKey: String) = apply { this.serverKey = serverKey }
-        fun to(to: String) = apply { this.to = to }
+        fun toTokenOrTopic(to: String) = apply { this.toTokenOrTopic = to }
+        fun toMultipleTokens(tokens: ArrayList<String>) = apply { this.toMultipleTokens = tokens }
         fun setTimeToLive(timeToLive: Long) = apply { this.timeToLive = timeToLive }
         fun setDryRun(enable: Boolean) = apply { this.dryRun = enable }
         fun setData(data: JSONObject) = apply { this.customData = data }
         fun responseListener(listener: ResponseListener?) = apply { this.listener = listener }
         fun build() =
-            FCMSender(serverKey, to, timeToLive, dryRun, customData, listener)
+            FCMSender(serverKey, toTokenOrTopic,toMultipleTokens, timeToLive, dryRun, customData, listener)
     }
 }