From 41d9402516dc14feff97afb6cbc6ba38ad2a5113 Mon Sep 17 00:00:00 2001
From: Azalea Gui <me@hydev.org>
Date: Mon, 23 Jan 2023 21:39:59 -0500
Subject: [PATCH] [+] Submit heart rate data

---
 app/src/main/java/org/hydev/wearsync/MainActivity.kt   |  1 +
 .../wearsync/bles/decoders/HeartRateMeasurement.kt     | 10 +++++++++-
 2 files changed, 10 insertions(+), 1 deletion(-)

diff --git a/app/src/main/java/org/hydev/wearsync/MainActivity.kt b/app/src/main/java/org/hydev/wearsync/MainActivity.kt
index d6492a9..7ff218a 100644
--- a/app/src/main/java/org/hydev/wearsync/MainActivity.kt
+++ b/app/src/main/java/org/hydev/wearsync/MainActivity.kt
@@ -119,6 +119,7 @@ class MainActivity : AppCompatActivity()
                 withContext(Dispatchers.Main) {
                     binding.content.tvValue.text = String.format(Locale.ENGLISH, "%d bpm", it.pulse)
                 }
+                influx add it
             }
         }
     }
diff --git a/app/src/main/java/org/hydev/wearsync/bles/decoders/HeartRateMeasurement.kt b/app/src/main/java/org/hydev/wearsync/bles/decoders/HeartRateMeasurement.kt
index 7857336..156850b 100644
--- a/app/src/main/java/org/hydev/wearsync/bles/decoders/HeartRateMeasurement.kt
+++ b/app/src/main/java/org/hydev/wearsync/bles/decoders/HeartRateMeasurement.kt
@@ -1,18 +1,26 @@
 package org.hydev.wearsync.bles.decoders
 
+import com.influxdb.annotations.Column
+import com.influxdb.annotations.Measurement
 import com.welie.blessed.BluetoothBytesParser
 import com.welie.blessed.BluetoothBytesParser.Companion.FORMAT_UINT16
 import com.welie.blessed.BluetoothBytesParser.Companion.FORMAT_UINT8
 import org.hydev.wearsync.bles.SensorContactFeature
 import java.nio.ByteOrder
+import java.time.Instant
 import java.util.*
 
+@Measurement(name = "heart_rate")
 data class HeartRateMeasurement(
+    @Column
     val pulse: Int,
+
     val energyExpended: Int?,
     val rrIntervals: IntArray,
     val sensorContactStatus: SensorContactFeature,
-    val createdAt: Date = Calendar.getInstance().time
+
+    @Column(timestamp = true)
+    val createdAt: Instant = Instant.now(),
 )
 
 class HeartRateDecoder : IDecoder<HeartRateMeasurement>