Skip to content

Commit ac1df83

Browse files
committed
Merge branch 'dev' of https://github.com/RADAR-base/RADAR-REST-Connector into add-spo2
2 parents 6d0fdb4 + 3c81c18 commit ac1df83

File tree

4 files changed

+4
-4
lines changed

4 files changed

+4
-4
lines changed

kafka-connect-fitbit-source/src/main/java/org/radarbase/connect/rest/fitbit/converter/FitbitIntradayHeartRateVariabilityAvroConverter.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -73,7 +73,7 @@ private TopicData parseHrv(JsonNode minuteData, ZonedDateTime startDate, double
7373
}
7474
FitbitIntradayHeartRateVariability fitbitHrv = new FitbitIntradayHeartRateVariability(time.toEpochMilli() / 1000d,
7575
timeReceived,
76-
(float) value.get("dailyRmssd").asDouble(),
76+
(float) value.get("rmssd").asDouble(),
7777
(float) value.get("coverage").asDouble(),
7878
(float) value.get("hf").asDouble(),
7979
(float) value.get("lf").asDouble());

kafka-connect-fitbit-source/src/main/java/org/radarbase/connect/rest/fitbit/route/FitbitBreathingRateRoute.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -46,7 +46,7 @@ protected String getUrlFormat(String baseUrl) {
4646
protected Stream<FitbitRestRequest> createRequests(User user) {
4747
return startDateGenerator(getOffset(user).plus(ONE_SECOND).truncatedTo(SECONDS))
4848
.map(dateRange -> newRequest(user, dateRange,
49-
user.getExternalUserId(), DATE_FORMAT.format(dateRange.start())));
49+
user.getExternalUserId(), DATE_FORMAT.format(dateRange.start()), DATE_FORMAT.format(dateRange.end())));
5050
}
5151

5252
/** Limit range to 30 days as documented here: https://dev.fitbit.com/build/reference/web-api/intraday/get-br-intraday-by-interval/ */

kafka-connect-fitbit-source/src/main/java/org/radarbase/connect/rest/fitbit/route/FitbitIntradayHeartRateVariabilityRoute.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -47,7 +47,7 @@ protected String getUrlFormat(String baseUrl) {
4747
protected Stream<FitbitRestRequest> createRequests(User user) {
4848
return startDateGenerator(getOffset(user).plus(ONE_SECOND).truncatedTo(SECONDS))
4949
.map(dateRange -> newRequest(user, dateRange,
50-
user.getExternalUserId(), DATE_FORMAT.format(dateRange.start())));
50+
user.getExternalUserId(), DATE_FORMAT.format(dateRange.start()), DATE_FORMAT.format(dateRange.end())));
5151
}
5252

5353
/** Limit range to 30 days as documented here: https://dev.fitbit.com/build/reference/web-api/intraday/get-hrv-intraday-by-interval/ */

kafka-connect-fitbit-source/src/main/java/org/radarbase/connect/rest/fitbit/route/FitbitSkinTemperatureRoute.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -46,7 +46,7 @@ protected String getUrlFormat(String baseUrl) {
4646
protected Stream<FitbitRestRequest> createRequests(User user) {
4747
return startDateGenerator(getOffset(user).plus(ONE_SECOND).truncatedTo(SECONDS))
4848
.map(dateRange -> newRequest(user, dateRange,
49-
user.getExternalUserId(), DATE_FORMAT.format(dateRange.start())));
49+
user.getExternalUserId(), DATE_FORMAT.format(dateRange.start()), DATE_FORMAT.format(dateRange.end())));
5050
}
5151

5252
/** Limit range to 30 days as documented here: https://dev.fitbit.com/build/reference/web-api/temperature/get-temperature-skin-summary-by-interval */

0 commit comments

Comments
 (0)