Alarm siren

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

@@ -8,6 +8,7 @@ import android.util.Log
 import pl.rmakowiecki.smartalarmcore.peripheral.beam.BeamBreakDetectorPeriphery
 import pl.rmakowiecki.smartalarmcore.peripheral.camera.CameraPeripheryContract
 import pl.rmakowiecki.smartalarmcore.peripheral.motion.MotionSensorPeriphery
+import pl.rmakowiecki.smartalarmcore.peripheral.soundalarm.SoundAlarmPeriphery
 import pl.rmakowiecki.smartalarmcore.remote.AlarmBackendContract
 import pl.rmakowiecki.smartalarmcore.setup.UsbSetupProviderContract
 
@@ -17,14 +18,14 @@ class AlarmActivity : AppCompatActivity() {
 
     override fun onCreate(savedInstanceState: Bundle?) {
         super.onCreate(savedInstanceState)
-//        printWifiNetworkStatus() test
         alarmController = initSystemController()
     }
 
     private fun initSystemController() = AlarmController(
             BeamBreakDetectorPeriphery(),
             MotionSensorPeriphery(),
             CameraPeripheryContract.create(this),
+            SoundAlarmPeriphery(),
             AlarmBackendContract.create(this),
             UsbSetupProviderContract.create(this)
     )

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

@@ -7,6 +7,7 @@ import pl.rmakowiecki.smartalarmcore.extensions.applyIoSchedulers
 import pl.rmakowiecki.smartalarmcore.extensions.logD
 import pl.rmakowiecki.smartalarmcore.peripheral.AlarmTriggerPeripheralDevice
 import pl.rmakowiecki.smartalarmcore.peripheral.camera.CameraPeripheryContract
+import pl.rmakowiecki.smartalarmcore.peripheral.soundalarm.SoundAlarmPeriphery
 import pl.rmakowiecki.smartalarmcore.remote.AlarmBackendContract
 import pl.rmakowiecki.smartalarmcore.remote.models.AlarmTriggerReason
 import pl.rmakowiecki.smartalarmcore.remote.models.SecurityIncident
@@ -16,6 +17,7 @@ class AlarmController(
         private val beamBreakDetector: AlarmTriggerPeripheralDevice,
         private val motionSensor: AlarmTriggerPeripheralDevice,
         private val camera: CameraPeripheryContract,
+        private val soundAlarmPeriphery: SoundAlarmPeriphery,
         private val backendInteractor: AlarmBackendContract,
         private val usbSetupProvider: UsbSetupProviderContract
 ) {
@@ -71,7 +73,8 @@ class AlarmController(
                                 updateAlarmTriggerState(it)
                                 if (it == TRIGGERED) {
                                     reportAlarmIncident(AlarmTriggerReason.BEAM_BREAK_DETECTOR)
-                                }
+                                    soundAlarmPeriphery.startSiren()
+                                } else soundAlarmPeriphery.stopSiren()
                             }
                     )
         }
@@ -84,10 +87,12 @@ class AlarmController(
                     .applyIoSchedulers()
                     .subscribeBy(
                             onNext = {
-                                updateAlarmTriggerState(it)
+                                //                                updateAlarmTriggerState(it)
                                 if (it == TRIGGERED) {
-                                    reportAlarmIncident(AlarmTriggerReason.MOTION_SENSOR)
-                                }
+//                                    reportAlarmIncident(AlarmTriggerReason.MOTION_SENSOR)
+                                    logD("motion sensor triggered")
+                                    soundAlarmPeriphery.startSiren()
+                                } else soundAlarmPeriphery.stopSiren()
                             }
                     )
         }

app/src/main/java/pl/rmakowiecki/smartalarmcore/peripheral/soundalarm/SoundAlarmPeriphery.kt

@@ -0,0 +1,38 @@
+package pl.rmakowiecki.smartalarmcore.peripheral.soundalarm
+
+import com.google.android.things.pio.Gpio
+import com.google.android.things.pio.PeripheralManagerService
+import pl.rmakowiecki.smartalarmcore.extensions.logE
+
+private const val PIN_NAME = "BCM21"
+
+class SoundAlarmPeriphery {
+
+    private lateinit var alarmSirenGpio: Gpio
+
+    init {
+        initAndRegisterGpioCallback()
+    }
+
+    private fun initAndRegisterGpioCallback() {
+        val service = PeripheralManagerService()
+        try {
+            alarmSirenGpio = service.openGpio(PIN_NAME)
+            alarmSirenGpio.apply {
+                setDirection(Gpio.DIRECTION_OUT_INITIALLY_LOW)
+            }
+
+        } catch (ex: Exception) {
+            ex.printStackTrace()
+            logE("GPIO exception")
+        }
+    }
+
+    fun startSiren() {
+        alarmSirenGpio.value = true
+    }
+
+    fun stopSiren() {
+        alarmSirenGpio.value = false
+    }
+}

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

@@ -133,12 +133,22 @@ class AlarmBackendInteractor(private val activity: AlarmActivity) : AlarmBackend
     }
 
     override fun uploadIncidentPhoto(photoBytes: ByteArray, uniqueIncidentId: String, photoNumber: Int): Single<Boolean> = Single.create { emitter ->
+        val photoFileName = "$uniqueIncidentId#$photoNumber.jpg"
+
         storageNode.child(CORE_DEVICE_DIRECTORY)
                 .child(IMAGES_DIRECTORY)
                 .child(getCurrentBackendUser()?.uid ?: "non_assignable_incidents")
-                .child("$uniqueIncidentId#$photoNumber.jpg")
+                .child(photoFileName)
                 .putBytes(photoBytes)
-                .addOnCompleteListener { emitter.onSuccess(it.isSuccessful) }
+                .addOnCompleteListener {
+                    databaseNode
+                            .child(getCurrentBackendUser()?.uid)
+                            .child("incidents")
+                            .child(uniqueIncidentId)
+                            .child("photos")
+                            .child("$photoNumber")
+                            .setValue(it.isSuccessful)
+                }
     }
 }