Sync user with device token on app launch

Author: antoniomika

apk/src/main/AndroidManifest.xml

@@ -47,6 +47,11 @@
             </intent-filter>
         </service>
 
+        <meta-data android:name="com.google.firebase.messaging.default_notification_icon"
+            android:resource="@mipmap/ic_launcher" />
+        <meta-data
+            android:name="com.google.firebase.messaging.default_notification_channel_id"
+            android:value="MHacks Group" />
     </application>
 
 </manifest>

base/src/main/java/com/mhacks/app/data/network/fcm/FCMMessageHandler.kt

@@ -7,6 +7,7 @@ import androidx.core.app.NotificationCompat
 import androidx.core.app.NotificationManagerCompat
 import com.google.firebase.messaging.FirebaseMessagingService
 import com.google.firebase.messaging.RemoteMessage
+import android.R
 import timber.log.Timber
 
 /**
@@ -24,6 +25,7 @@ class FCMMessageHandler : FirebaseMessagingService() {
 
     private fun createNotification(notification: RemoteMessage.Notification) {
         val builder = NotificationCompat.Builder(baseContext, mhacksGroup)
+                .setSmallIcon(R.mipmap.sym_def_app_icon)
                 .setDefaults(Notification.DEFAULT_ALL)
                 .setContentTitle(notification.title)
                 .setContentText(notification.body)

base/src/main/java/com/mhacks/app/data/network/fcm/RegistrationIntentService.kt

@@ -37,6 +37,10 @@ class RegistrationIntentService : IntentService(TAG) {
                 .instanceId.addOnSuccessListener {
             if (it != null) {
                 Timber.d("Register to service")
+                sharedPreferences
+                        .edit()
+                        .putString(PUSH_TOKEN, it.token)
+                        .apply()
                 sendRegistrationToServer(it.token)
             } else {
                 Timber.d("Save to Shared Prefs that our value is false")
@@ -52,7 +56,7 @@ class RegistrationIntentService : IntentService(TAG) {
 
     private fun sendRegistrationToServer(token: String) {
         Timber.e(token)
-        mhacksService.postFireBaseToken(token)
+        mhacksService.postFireBaseToken(token, "")
                 .subscribeOn(Schedulers.io())
                 .observeOn(AndroidSchedulers.mainThread())
                 .subscribe(
@@ -63,6 +67,8 @@ class RegistrationIntentService : IntentService(TAG) {
 
     companion object {
         private const val TAG = "RegIntentService"
-        private const val SENT_TOKEN_TO_SERVER = "sentTokenToServer"
+        const val SENT_TOKEN_TO_SERVER = "sentTokenToServer"
+        const val PUSH_TOKEN = "pushToken"
+        const val AUTH_TOKEN= "authToken"
     }
 }

base/src/main/java/com/mhacks/app/data/network/services/FireBaseService.kt

@@ -12,6 +12,6 @@ interface FireBaseService {
 
     @FormUrlEncoded
     @POST("device")
-    fun postFireBaseToken(@Field("push_id") pushId: String): Single<FcmDevice>
+    fun postFireBaseToken(@Field("push_id") pushId: String, @Header("Authorization") authToken: String): Single<FcmDevice>
 
 }

ui/src/main/java/com/mhacks/app/MHacksApplication.kt

@@ -4,22 +4,43 @@ import android.app.Notification
 import android.app.NotificationChannel
 import android.app.NotificationManager
 import android.content.Context
+import android.content.SharedPreferences
 import android.graphics.Color
 import android.os.Build
+import android.preference.PreferenceManager
 import com.facebook.stetho.Stetho
 import com.jakewharton.threetenabp.AndroidThreeTen
+import com.mhacks.app.data.network.fcm.RegistrationIntentService
+import com.mhacks.app.data.network.services.FireBaseService
 import com.mhacks.app.di.component.*
 import com.mhacks.app.di.module.AuthModule
 import com.mhacks.app.di.module.RetrofitModule
 import com.mhacks.app.di.module.RoomModule
 import dagger.android.AndroidInjector
 import dagger.android.support.DaggerApplication
+import io.reactivex.android.schedulers.AndroidSchedulers
+import io.reactivex.schedulers.Schedulers
+import retrofit2.Retrofit
+import retrofit2.adapter.rxjava2.RxJava2CallAdapterFactory
+import retrofit2.converter.moshi.MoshiConverterFactory
 import timber.log.Timber
 
 class MHacksApplication : DaggerApplication() {
 
     private lateinit var appComponent: AppComponent
 
+    private val retrofit = Retrofit.Builder()
+            .baseUrl(BuildConfig.API_URL)
+            .addCallAdapterFactory(RxJava2CallAdapterFactory.create())
+            .addConverterFactory(MoshiConverterFactory.create())
+            .build()
+
+    private val mhacksService = retrofit.create(FireBaseService::class.java)
+
+    private val sharedPreferences: SharedPreferences by lazy {
+        PreferenceManager.getDefaultSharedPreferences(this)
+    }
+
     override fun onCreate() {
         super.onCreate()
         AndroidThreeTen.init(this)
@@ -41,6 +62,18 @@ class MHacksApplication : DaggerApplication() {
 
             notificationManager.createNotificationChannel(notificationChannel)
         }
+
+        val pushToken = sharedPreferences.getString(RegistrationIntentService.PUSH_TOKEN, "")
+        if (pushToken.length > 0) {
+            val authToken = sharedPreferences.getString(RegistrationIntentService.AUTH_TOKEN, "")
+            mhacksService.postFireBaseToken(pushToken, "Bearer ${authToken}")
+                    .subscribeOn(Schedulers.io())
+                    .observeOn(AndroidSchedulers.mainThread())
+                    .subscribe(
+                            { sharedPreferences.edit().putBoolean(RegistrationIntentService.SENT_TOKEN_TO_SERVER, true).apply() },
+                            { Timber.e(it) }
+                    )
+        }
     }
 
     override fun applicationInjector(): AndroidInjector<out DaggerApplication> {

ui/src/main/java/com/mhacks/app/data/repository/UserRepository.kt

@@ -1,7 +1,11 @@
 package com.mhacks.app.data.repository
 
+import android.content.Context
+import android.content.SharedPreferences
+import android.preference.PreferenceManager
 import com.mhacks.app.data.models.Login
 import com.mhacks.app.data.models.User
+import com.mhacks.app.data.network.fcm.RegistrationIntentService
 import com.mhacks.app.data.room.dao.LoginDao
 import com.mhacks.app.data.room.dao.UserDao
 import com.mhacks.app.data.service.UserService
@@ -11,7 +15,12 @@ import javax.inject.Inject
 class UserRepository @Inject constructor(
         private val userService: UserService,
         private val loginDao: LoginDao,
-        private val userDao: UserDao) {
+        private val userDao: UserDao,
+        private val appContext: Context) {
+
+    private val sharedPreferences: SharedPreferences by lazy {
+        PreferenceManager.getDefaultSharedPreferences(appContext)
+    }
 
     fun getLoginCache() = loginDao.getLogin()
 
@@ -34,6 +43,10 @@ class UserRepository @Inject constructor(
     fun updateLoginCache(login: Login) =
             Single.fromCallable {
                 loginDao.insertLogin(login)
+                sharedPreferences
+                        .edit()
+                        .putString(RegistrationIntentService.AUTH_TOKEN, login.token)
+                        .apply()
                 return@fromCallable login
             }!!