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>