#196: Implemented BloodPressure storage to elastic

src/main/java/io/redlink/more/data/controller/GarminApiV1Controller.java

@@ -73,7 +73,14 @@ public ResponseEntity<Void> submitSummaries(String userAgent, String garminClien
                                 .collect(Collectors.toMap(
                                         entry -> GarminSummaryType.fromLabel(entry.getKey()),
                                         entry -> ((List<?>) entry.getValue()).stream()
-                                                .map(item -> MapperUtils.convertValue(item, GarminDataPoint.class))
+                                                .map(item -> MapperUtils.convertValueWithAliases(
+                                                        item,
+                                                        GarminDataPoint.class,
+                                                        Map.of(
+                                                                "startTimeInSeconds", "measurementTimeInSeconds",
+                                                                "startTimeOffsetInSeconds", "measurementTimeOffsetInSeconds"
+                                                        )
+                                                ))
                                                 .collect(Collectors.toList())
                                 ));
                 garminService.storeData(requestDataPoints);

src/main/java/io/redlink/more/data/model/DataType.java

@@ -7,7 +7,8 @@ public enum DataType {
     SLEEP_START("sleep_start"),
     SLEEP_END("sleep_end"),
     DAILY_STEPS("daily_steps"),
-    EPOCH_STEPS("epoch_steps");
+    EPOCH_STEPS("epoch_steps"),
+    BLOOD_PRESSURE("blood_pressure");
 
     public final String dataType;
 

src/main/java/io/redlink/more/data/model/garmin/GarminSummaryType.java

@@ -9,7 +9,8 @@ public enum GarminSummaryType {
     STRESSDETAILS,
     PULSEOX,
     SLEEPS,
-    HRV;
+    HRV,
+    BLOODPRESSURES;
 
     public final String label;
 

src/main/java/io/redlink/more/data/model/garmin/transformation/GarminBloodPressure.java

@@ -0,0 +1,29 @@
+package io.redlink.more.data.model.garmin.transformation;
+
+import com.fasterxml.jackson.annotation.JsonIgnoreProperties;
+
+/**
+ * Represents a blood pressure record in the Garmin ecosystem.
+ * This record encapsulates systolic and diastolic blood pressure readings,
+ * pulse information, and the source from which the data was obtained.
+ * <p>
+ * The {@link SourceType} enum defines the possible origins of the measurement,
+ * which can either be entered manually or recorded by a device.
+ *
+ * @param systolic   The systolic blood pressure value measured in mmHg.
+ * @param diastolic  The diastolic blood pressure value measured in mmHg.
+ * @param pulse      The pulse rate measured in beats per minute (BPM).
+ * @param sourceType The origin of the blood pressure record (manual entry or device).
+ */
+@JsonIgnoreProperties(ignoreUnknown = true)
+public record GarminBloodPressure(
+        Integer systolic,
+        Integer diastolic,
+        Integer pulse,
+        SourceType sourceType
+) {
+    public enum SourceType {
+        MANUAL,
+        DEVICE
+    }
+}

src/main/java/io/redlink/more/data/transformers/garmin/AbstractGarminTransformer.java

@@ -7,11 +7,11 @@
 import io.redlink.more.data.model.garmin.GarminSummaryType;
 import io.redlink.more.data.model.garmin.transformation.GarminTimeData;
 import io.redlink.more.data.schedule.SchedulerUtils;
+import io.redlink.more.data.util.DateTimeUtils;
 import org.apache.commons.lang3.Range;
 
 import java.time.Instant;
 import java.time.OffsetDateTime;
-import java.time.ZoneOffset;
 import java.util.Collections;
 import java.util.List;
 import java.util.UUID;
@@ -58,16 +58,12 @@ protected List<DataPoint> transformGarminTimeDataToDataPoint(List<Observation> o
     }
 
     protected OffsetDateTime recordingTimestamp(GarminDataPoint garminDataPoint) {
-        Instant unixTimestamp = Instant.ofEpochSecond(garminDataPoint.getStartTimeInSeconds());
-        ZoneOffset offset = ZoneOffset.ofTotalSeconds(garminDataPoint.getStartTimeOffsetInSeconds());
-        return unixTimestamp.atOffset(offset);
+        return DateTimeUtils.offsetDateTimeFromEpochSeconds(garminDataPoint.getStartTimeInSeconds(), garminDataPoint.getStartTimeOffsetInSeconds());
     }
 
     protected OffsetDateTime endDateTime(GarminDataPoint garminDataPoint) {
         int endTimestamp = garminDataPoint.getStartTimeInSeconds() + garminDataPoint.getDurationInSeconds();
-        Instant unixTimestamp = Instant.ofEpochSecond(endTimestamp);
-        ZoneOffset offset = ZoneOffset.ofTotalSeconds(garminDataPoint.getStartTimeOffsetInSeconds());
-        return unixTimestamp.atOffset(offset);
+        return DateTimeUtils.offsetDateTimeFromEpochSeconds(endTimestamp, garminDataPoint.getStartTimeOffsetInSeconds());
     }
 
     protected Range<Instant> getGarminDataPointTimeRange(GarminDataPoint garminDataPoint) {

src/main/java/io/redlink/more/data/transformers/garmin/BloodPressureTransformer.java

@@ -0,0 +1,40 @@
+package io.redlink.more.data.transformers.garmin;
+
+import io.redlink.more.data.custom.model.GarminDataPoint;
+import io.redlink.more.data.model.DataPoint;
+import io.redlink.more.data.model.DataType;
+import io.redlink.more.data.model.Observation;
+import io.redlink.more.data.model.garmin.GarminSummaryType;
+import io.redlink.more.data.model.garmin.transformation.GarminBloodPressure;
+import io.redlink.more.data.model.garmin.transformation.GarminTimeData;
+import io.redlink.more.data.util.MapperUtils;
+import org.apache.commons.lang3.Range;
+import org.springframework.stereotype.Component;
+
+import java.time.Instant;
+import java.util.List;
+
+@Component
+public class BloodPressureTransformer extends AbstractGarminTransformer {
+    @Override
+    public GarminSummaryType getSupportedType() {
+        return GarminSummaryType.BLOODPRESSURES;
+    }
+
+    @Override
+    protected List<DataPoint> transformToDataPoint(List<Observation> observations, GarminDataPoint garminDataPoint) {
+        var data = extractBloodPressure(garminDataPoint);
+        return super.transformGarminTimeDataToDataPoint(observations, garminDataPoint.getSummaryId(), DataType.BLOOD_PRESSURE, data);
+    }
+
+    @Override
+    protected List<DataPoint> filterDataPointByTimeRange(List<Range<Instant>> validTimeRanges, List<DataPoint> dataBulk) {
+        return dataBulk;
+    }
+
+    private GarminTimeData<GarminBloodPressure> extractBloodPressure(GarminDataPoint garminDataPoint) {
+        GarminBloodPressure data = MapperUtils.convertValue(garminDataPoint, GarminBloodPressure.class);
+        var measurementTime = super.recordingTimestamp(garminDataPoint);
+        return new GarminTimeData<>(measurementTime.toInstant(), data);
+    }
+}

src/main/java/io/redlink/more/data/util/DateTimeUtils.java

@@ -0,0 +1,13 @@
+package io.redlink.more.data.util;
+
+import java.time.Instant;
+import java.time.OffsetDateTime;
+import java.time.ZoneOffset;
+
+public class DateTimeUtils {
+    public static OffsetDateTime offsetDateTimeFromEpochSeconds(long epochSecond, int offset) {
+        Instant unixTimestamp = Instant.ofEpochSecond(epochSecond);
+        ZoneOffset zoneOffset = ZoneOffset.ofTotalSeconds(offset);
+        return unixTimestamp.atOffset(zoneOffset);
+    }
+}

src/main/java/io/redlink/more/data/util/MapperUtils.java

@@ -5,6 +5,9 @@
 import com.fasterxml.jackson.datatype.jsr310.JavaTimeModule;
 import io.redlink.more.data.exception.BadRequestException;
 
+import java.util.HashMap;
+import java.util.Map;
+
 public class MapperUtils {
     public static final ObjectMapper MAPPER = new ObjectMapper().registerModule(new JavaTimeModule());
 
@@ -29,6 +32,21 @@ public static <T> T convertValue(Object o, Class<T> c) {
         return MAPPER.convertValue(o, c);
     }
 
+    public static <T> T convertValueWithAliases(Object o, Class<T> targetClass, Map<String, String> aliases) {
+        if (o == null) return null;
+
+        Map<String, Object> sourceMap = convertValue(o, Map.class);
+        Map<String, Object> mappedData = new HashMap<>(sourceMap);
+
+        aliases.forEach((targetKey, sourceKey) -> {
+            if (!mappedData.containsKey(targetKey) && mappedData.containsKey(sourceKey)) {
+                mappedData.put(targetKey, mappedData.get(sourceKey));
+            }
+        });
+
+        return convertValue(mappedData, targetClass);
+    }
+
     public static boolean isPrimitiveLike(Object value) {
         return value instanceof String
                 || value instanceof Number

src/main/resources/openapi/CustomModelAPI.yaml

@@ -123,6 +123,26 @@ components:
         stepsGoal:
           type: integer
           description: Daily steps goal
+        systolic:
+          type: integer
+          format: int32
+          description: The systolic value of the blood pressure reading.
+        diastolic:
+          type: integer
+          format: int32
+          description: The diastolic value of the blood pressure reading.
+        pulse:
+          type: integer
+          format: int32
+          description: Pulse rate at the time the blood pressure reading
+        sourceType:
+          type: string
+          enum: [ MANUAL, DEVICE ]
+          default: "MANUAL"
+          description: |
+            This field is used to determine if blood pressure data was entered manually or synced from aGarmin Device. Possible values:
+            MANUAL: The user entered blood pressure information manually through a web form.
+            DEVICE: The user used a Garmin device to perform a blood pressure reading.
       required:
         - userId
         - summaryId