Update creating of requests in spo2 route

mpgxvii · mpgxvii · commit 835101d580b5 · 2024-03-07T12:50:20.000Z
diff --git a/kafka-connect-fitbit-source/src/main/java/org/radarbase/connect/rest/fitbit/route/FitbitIntradaySpo2Route.java b/kafka-connect-fitbit-source/src/main/java/org/radarbase/connect/rest/fitbit/route/FitbitIntradaySpo2Route.java
@@ -47,7 +47,7 @@ protected String getUrlFormat(String baseUrl) {
   protected Stream<FitbitRestRequest> createRequests(User user) {
     return startDateGenerator(getOffset(user).plus(ONE_SECOND).truncatedTo(SECONDS))
         .map(dateRange -> newRequest(user, dateRange,
-            user.getExternalUserId(), DATE_FORMAT.format(dateRange.start())));
+            user.getExternalUserId(), DATE_FORMAT.format(dateRange.start()), DATE_FORMAT.format(dateRange.end())));
   }
 
   /** Limit range to 30 days as documented here: https://dev.fitbit.com/build/reference/web-api/intraday/get-spo2-intraday-by-interval/ */

Original file line number	Diff line number	Diff line change
`@@ -47,7 +47,7 @@ protected String getUrlFormat(String baseUrl) {`
`47`	`47`	`protected Stream<FitbitRestRequest> createRequests(User user) {`
`48`	`48`	`return startDateGenerator(getOffset(user).plus(ONE_SECOND).truncatedTo(SECONDS))`
`49`	`49`	`.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())));`
`51`	`51`	`}`
`52`	`52`
`53`	`53`	`/** Limit range to 30 days as documented here: https://dev.fitbit.com/build/reference/web-api/intraday/get-spo2-intraday-by-interval/ */`