...

app/src/main/java/com/base/pdfviewerscannerwhite/fcm/FCMManager.kt

-package com.base.pdfviewerscannerwhite.fcm;
+package com.base.pdfviewerscannerwhite.fcm
 
-import android.content.Context;
-import android.util.Log;
+import android.content.Context
+import android.util.Log
+import com.base.pdfviewerscannerwhite.helper.EventUtils
+import com.base.pdfviewerscannerwhite.helper.EventUtils.event
+import com.base.pdfviewerscannerwhite.utils.AppPreferences
+import com.google.android.gms.tasks.OnCompleteListener
+import com.google.android.gms.tasks.Task
+import com.google.firebase.FirebaseApp
+import com.google.firebase.messaging.FirebaseMessaging
+import org.json.JSONObject
 
-import androidx.annotation.NonNull;
-
-import com.base.pdfviewerscannerwhite.helper.EventUtils;
-import com.google.android.gms.tasks.OnCompleteListener;
-import com.google.android.gms.tasks.Task;
-import com.google.firebase.FirebaseApp;
-import com.google.firebase.messaging.FirebaseMessaging;
-
-public class FCMManager {
-
-    public static void initFirebase(Context context) {
-        FirebaseApp.initializeApp(context);
+object FCMManager {
+    fun initFirebase(context: Context?) {
+        FirebaseApp.initializeApp(context!!)
     }
 
-    public static void subscribeToTopic(String topic) {
+    fun subscribeToTopic(topic: String) {
         FirebaseMessaging.getInstance().subscribeToTopic(topic)
-                .addOnCompleteListener(new OnCompleteListener<Void>() {
-                    @Override
-                    public void onComplete(@NonNull Task<Void> task) {
-                        if (task.isSuccessful()) {
-                            Log.d("FCMUtil", "suc:" + topic);
-                            EventUtils.INSTANCE.event("FCM_Topic_" + topic, null, null, false);
-                        } else {
-                            Log.d("FCMUtil", "fail");
-                        }
-                    }
-                });
+            .addOnCompleteListener { task ->
+                if (task.isSuccessful) {
+                    Log.d("FCMUtil", "suc:$topic")
+                    event("FCM_Topic_$topic", null, null, false)
+                    getToken()
+                } else {
+                    Log.d("FCMUtil", "fail")
+                }
+            }
     }
 
-    public static void unsubscribeFromTopic(String topic) {
-        FirebaseMessaging.getInstance().unsubscribeFromTopic(topic)
-                .addOnCompleteListener(new OnCompleteListener<Void>() {
-                    @Override
-                    public void onComplete(@NonNull Task<Void> task) {
-                        if (task.isSuccessful()) {
-                        } else {
-                        }
-                    }
-                });
+    fun unsubscribeFromTopic(topic: String?) {
+        FirebaseMessaging.getInstance().unsubscribeFromTopic(topic!!)
+            .addOnCompleteListener { task ->
+                if (task.isSuccessful) {
+                } else {
+                }
+            }
     }
 
+    private fun getToken() {
+        FirebaseMessaging.getInstance().token
+            .addOnCompleteListener(object : OnCompleteListener<String> {
+                override fun onComplete(task: Task<String>) {
+                    if (!task.isSuccessful) {
+                        Log.d("FCM", "Fetching FCM registration token failed", task.exception)
+                        return
+                    }
+                    // Get new FCM registration token
+                    val token: String = task.result
+                    val json = JSONObject()
+                    json.put("token", token)
+                    EventUtils.event("fcm_message_received", ext = json)
+
+                    AppPreferences.getInstance().put("token", token)
+
+                    // Handle new token
+                    Log.d("FCM", "FCM Registration Token: $token")
+                }
+            })
+    }
 }