Merge pull request #55 from RADAR-base/new_garmin_data

Add backfill impl for new data types

src/main/kotlin/org/radarbase/push/integration/garmin/backfill/GarminRequestGenerator.kt

@@ -68,6 +68,18 @@ class GarminRequestGenerator(
             config.pushIntegration.garmin.consumerKey,
             userRepository
         ),
+        GarminHealthSnapshotRoute(
+            config.pushIntegration.garmin.consumerKey,
+            userRepository
+        ),
+        GarminHrvRoute(
+            config.pushIntegration.garmin.consumerKey,
+            userRepository
+        ),
+        GarminBloodPressureRoute(
+            config.pushIntegration.garmin.consumerKey,
+            userRepository
+        ),
     )
 
     private val userNextRequest: MutableMap<String, Instant> = mutableMapOf()

src/main/kotlin/org/radarbase/push/integration/garmin/backfill/route/GarminBloodPressureRoute.kt

@@ -0,0 +1,13 @@
+package org.radarbase.push.integration.garmin.backfill.route
+
+import org.radarbase.push.integration.garmin.user.GarminUserRepository
+
+class GarminBloodPressureRoute(
+    consumerKey: String,
+    userRepository: GarminUserRepository
+) : GarminRoute(consumerKey, userRepository) {
+
+    override fun subPath(): String = "bloodPressures"
+
+    override fun toString(): String = "garmin_blood_pressures"
+}

src/main/kotlin/org/radarbase/push/integration/garmin/backfill/route/GarminHealthSnapshotRoute.kt

@@ -0,0 +1,13 @@
+package org.radarbase.push.integration.garmin.backfill.route
+
+import org.radarbase.push.integration.garmin.user.GarminUserRepository
+
+class GarminHealthSnapshotRoute(
+    consumerKey: String,
+    userRepository: GarminUserRepository
+) : GarminRoute(consumerKey, userRepository) {
+
+    override fun subPath(): String = "healthSnapshot"
+
+    override fun toString(): String = "garmin_health_snapshot"
+}

src/main/kotlin/org/radarbase/push/integration/garmin/backfill/route/GarminHrvRoute.kt

@@ -0,0 +1,13 @@
+package org.radarbase.push.integration.garmin.backfill.route
+
+import org.radarbase.push.integration.garmin.user.GarminUserRepository
+
+class GarminHrvRoute(
+    consumerKey: String,
+    userRepository: GarminUserRepository
+) : GarminRoute(consumerKey, userRepository) {
+
+    override fun subPath(): String = "hrv"
+
+    override fun toString(): String = "garmin_hrv"
+}

src/main/kotlin/org/radarbase/push/integration/garmin/converter/BloodPressureGarminAvroConverter.kt

@@ -35,6 +35,6 @@ class BloodPressureGarminAvroConverter(topic: String = "push_integration_garmin_
     }
 
     companion object {
-        const val ROOT = "bloodPressure"
+        const val ROOT = "bloodPressures"
     }
 }