Update firebase alarm function & restrict alarm notifications to subscribed channel

Author: Haydart

app/src/main/java/pl/rmakowiecki/smartalarmcore/Activity.kt

@@ -18,12 +18,11 @@ class AlarmActivity : AppCompatActivity() {
 
         printWifiNetworkStatus()
         alarmController = initSystemController()
-        alarmController.observeAlarm()
     }
 
     private fun initSystemController() = AlarmController(
             BeamBreakDetectorPeripheryContract.create(),
-            AlarmBackendContract.create(),
+            AlarmBackendContract.create(this),
             UsbSetupProviderContract.create(this)
     )
 

app/src/main/java/pl/rmakowiecki/smartalarmcore/AlarmActivity.kt

@@ -19,17 +19,19 @@ class AlarmController(
 
     init {
         connectToBackend()
-        usbSetupProviderContract.registerBroadcastListener()
+        usbSetupProviderContract.registerBroadcastListener({ }, { })
     }
 
     private fun connectToBackend() {
         backendConnectionDisposable = backendInteractor
                 .signInToBackend()
                 .applyIoSchedulers()
-                .subscribe()
+                .subscribeBy(
+                        onSuccess = { observeAlarm() }
+                )
     }
 
-    fun observeAlarm() {
+    private fun observeAlarm() {
         alarmArmingDisposable = backendInteractor
                 .observeAlarmArmingState()
                 .applyIoSchedulers()

app/src/main/java/pl/rmakowiecki/smartalarmcore/AlarmController.kt

@@ -2,6 +2,7 @@ package pl.rmakowiecki.smartalarmcore.remote
 
 import io.reactivex.Observable
 import io.reactivex.Single
+import pl.rmakowiecki.smartalarmcore.AlarmActivity
 import pl.rmakowiecki.smartalarmcore.AlarmArmingState
 import pl.rmakowiecki.smartalarmcore.AlarmTriggerState
 
@@ -12,7 +13,7 @@ interface AlarmBackendContract {
     fun updateAlarmState(alarmState: AlarmTriggerState)
 
     companion object {
-        fun create() = AlarmBackendInteractor()
+        fun create(activity: AlarmActivity) = AlarmBackendInteractor(activity)
     }
 }
 

app/src/main/java/pl/rmakowiecki/smartalarmcore/remote/AlarmBackendContract.kt

@@ -1,35 +1,62 @@
 package pl.rmakowiecki.smartalarmcore.remote
 
+import android.provider.Settings
 import com.google.firebase.auth.FirebaseAuth
+import com.google.firebase.auth.FirebaseUser
 import com.google.firebase.database.DataSnapshot
 import com.google.firebase.database.DatabaseError
 import com.google.firebase.database.FirebaseDatabase
 import com.google.firebase.database.ValueEventListener
 import io.reactivex.Observable
 import io.reactivex.Single
+import io.reactivex.SingleEmitter
+import pl.rmakowiecki.smartalarmcore.AlarmActivity
 import pl.rmakowiecki.smartalarmcore.AlarmArmingState
 import pl.rmakowiecki.smartalarmcore.AlarmTriggerState
 import pl.rmakowiecki.smartalarmcore.extensions.logD
+import pl.rmakowiecki.smartalarmcore.extensions.printStackTrace
 import pl.rmakowiecki.smartalarmcore.toArmingState
 
-class AlarmBackendInteractor : AlarmBackendContract {
+class AlarmBackendInteractor(val activity: AlarmActivity) : AlarmBackendContract {
 
     private val databaseNode = FirebaseDatabase
             .getInstance()
             .reference
 
     override fun signInToBackend(): Single<Boolean> = Single.create { emitter ->
+
+        FirebaseAuth.getInstance().signOut()
+        logD(Settings.Secure.getString(activity.contentResolver, Settings.Secure.ANDROID_ID))
+
         getCurrentBackendUser()?.let {
             emitter.onSuccess(true)
         } ?: FirebaseAuth.getInstance()
                 .signInAnonymously()
-                .addOnCompleteListener { emitter.onSuccess(it.isSuccessful) }
+                .addOnSuccessListener { signUpAsAuthorizedUser(it.user, emitter) }
+    }
+
+    private fun signUpAsAuthorizedUser(firebaseUser: FirebaseUser, emitter: SingleEmitter<Boolean>) {
+        logD(firebaseUser.uid, "UID USERA")
+        FirebaseAuth.getInstance().createUserWithEmailAndPassword(
+                "${firebaseUser.uid}@smarthome.com",
+                Settings.Secure.getString(activity.contentResolver, Settings.Secure.ANDROID_ID)
+        ).addOnSuccessListener {
+            initializeCoreDeviceNoSqlModel(emitter)
+        }.addOnFailureListener { printStackTrace(it) }
     }
 
+    private fun initializeCoreDeviceNoSqlModel(emitter: SingleEmitter<Boolean>) = databaseNode
+            .child(getCurrentBackendUser()?.uid)
+            .setValue(RemoteAlarmStateModel(true, false))
+            .addOnSuccessListener { emitter.onSuccess(true) }
+
     override fun isLoggedInToBackend(): Single<Boolean> =
             Single.just(getCurrentBackendUser() != null)
 
-    private fun getCurrentBackendUser() = FirebaseAuth.getInstance().currentUser
+    private fun getCurrentBackendUser(): FirebaseUser? {
+        logD(FirebaseAuth.getInstance().currentUser, "GET UID")
+        return FirebaseAuth.getInstance().currentUser
+    }
 
     override fun observeAlarmArmingState(): Observable<AlarmArmingState> = Observable.create { emitter ->
         val valueListener = object : ValueEventListener {
@@ -38,19 +65,25 @@ class AlarmBackendInteractor : AlarmBackendContract {
             override fun onCancelled(databaseError: DatabaseError?) = emitter.onComplete()
         }
 
-        databaseNode.child(Nodes.ALARM_ARMING).addValueEventListener(valueListener)
+        val alarmArmingNode = databaseNode
+                .child(getCurrentBackendUser()?.uid)
+                .child(Nodes.ALARM_ARMING)
+
+        alarmArmingNode.addValueEventListener(valueListener)
 
         emitter.setCancellable {
-            databaseNode.child(Nodes.ALARM_ARMING).removeEventListener(valueListener)
+            alarmArmingNode.removeEventListener(valueListener)
         }
     }
 
     override fun updateAlarmState(alarmState: AlarmTriggerState) {
-        logD("Updating trigger value on server")
-        databaseNode.child(Nodes.ALARM_TRIGGER)
+        databaseNode.child(getCurrentBackendUser()?.uid)
+                .child(Nodes.ALARM_TRIGGER)
                 .setValue(alarmState.toBoolean())
                 .addOnCompleteListener { }
     }
 }
 
-private fun DataSnapshot.getArmingState() = (this.value as Boolean).toArmingState()
+private fun DataSnapshot.getArmingState() = (this.value as Boolean).toArmingState()
+
+class RemoteAlarmStateModel(val active: Boolean, val triggered: Boolean)

app/src/main/java/pl/rmakowiecki/smartalarmcore/remote/AlarmBackendInteractor.kt

@@ -1,6 +1,6 @@
 package pl.rmakowiecki.smartalarmcore.remote
 
 object Nodes {
-    const val ALARM_TRIGGER = "trigger"
+    const val ALARM_TRIGGER = "triggered"
     const val ALARM_ARMING = "active"
 }

app/src/main/java/pl/rmakowiecki/smartalarmcore/remote/Constants.kt

@@ -2,15 +2,17 @@ const functions = require('firebase-functions');
 const admin = require('firebase-admin');
 admin.initializeApp(functions.config().firebase)
 
-exports.sendAlarmNotification = functions.database.ref('/trigger').onWrite(event => {
+exports.sendAlarmNotification = functions.database.ref('/{currentCoreDeviceUid}/triggered').onWrite(event => {
     const data = event.data;
+    const coreUid = event.params.currentCoreDeviceUid
+
     console.log('Alarm state event triggered');
     if (!data.changed() || data.val() === false) {
         console.log('Initial conditions for launching the alarm were not met');
         return;
     }
 
-    const alarmArmingStatePromise = admin.database().ref('/active').once('value');
+    const alarmArmingStatePromise = admin.database().ref(`/${coreUid}/active`).once('value');
 
     return alarmArmingStatePromise.then(alarmArmingStateSnapshot => {
 
@@ -33,14 +35,14 @@ exports.sendAlarmNotification = functions.database.ref('/trigger').onWrite(event
         };
 
         console.log('Alarm triggered!');
-        return admin.messaging().sendToTopic("Alarm_Notifications", payload, options).then(response => {
+        return admin.messaging().sendToTopic(coreUid, payload, options).then(response => {
            // For each message check if there was an error.
            const tokensToRemove = [];
            response.results.forEach((result, index) => {
                const error = result.error;
                if (error) {
                   console.error('Failure sending notification to', tokens[index], error);
-                  // Cleanup the tokens who are not registered anymore.
+                  // Cleanup the tokens which are not registered anymore.
                   if (error.code === 'messaging/invalid-registration-token' || error.code === 'messaging/registration-token-not-registered') {
                       console.log("registration error occurred");
                   }