Fix lint errors

Author: mpgxvii

kafka-connect-oura-source/src/main/java/org/radarbase/connect/rest/oura/OuraSourceTask.java

@@ -28,6 +28,7 @@
 import java.util.Map;
 import java.util.stream.Collectors;
 import java.util.stream.Stream;
+import java.time.Duration;
 
 import org.apache.kafka.connect.data.SchemaAndValue;
 import org.apache.kafka.connect.errors.ConnectException;
@@ -89,7 +90,7 @@ public void initialize(OuraRestSourceConnectorConfig config, OffsetStorageReader
     );
     this.offsetManager = new KafkaOffsetManager(offsetStorageReader);
     this.routes = OuraRouteFactory.getRoutes(this.userRepository, flags);
-    this.ouraRequestGenerator = new OuraRequestGenerator(this.userRepository, this.offsetManager, this.routes);
+    this.ouraRequestGenerator = new OuraRequestGenerator(this.userRepository, Duration.ofDays(15), this.offsetManager, this.routes);
     this.offsetManager.initialize(getPartitions());
   }
 

oura-library/src/main/kotlin/org/radarbase/oura/route/OuraRouteFactory.kt

@@ -4,24 +4,52 @@ import org.radarbase.oura.user.UserRepository
 
 object OuraRouteFactory {
 
-    fun getRoutes(userRepository: UserRepository): List<OuraRoute> =
+    @JvmStatic
+    fun getRoutes(userRepository: UserRepository): List<Route> =
         getRoutes(userRepository, OuraRouteFlags())
 
-    fun getRoutes(userRepository: UserRepository, flags: OuraRouteFlags): List<OuraRoute> {
-        val routes = mutableListOf<OuraRoute>()
-        if (flags.dailyActivityEnabled) routes.add(OuraDailyActivityRoute(userRepository))
-        if (flags.dailyReadinessEnabled) routes.add(OuraDailyReadinessRoute(userRepository))
-        if (flags.dailySleepEnabled) routes.add(OuraDailySleepRoute(userRepository))
-        if (flags.dailyOxygenSaturationEnabled) routes.add(OuraDailyOxygenSaturationRoute(userRepository))
-        if (flags.heartRateEnabled) routes.add(OuraHeartRateRoute(userRepository))
-        if (flags.personalInfoEnabled) routes.add(OuraPersonalInfoRoute(userRepository))
-        if (flags.sessionEnabled) routes.add(OuraSessionRoute(userRepository))
-        if (flags.sleepEnabled) routes.add(OuraSleepRoute(userRepository))
-        if (flags.tagEnabled) routes.add(OuraTagRoute(userRepository))
-        if (flags.workoutEnabled) routes.add(OuraWorkoutRoute(userRepository))
-        if (flags.ringConfigurationEnabled) routes.add(OuraRingConfigurationRoute(userRepository))
-        if (flags.restModePeriodEnabled) routes.add(OuraRestModePeriodRoute(userRepository))
-        if (flags.sleepTimeRecommendationEnabled) routes.add(OuraSleepTimeRecommendationRoute(userRepository))
+    @JvmStatic
+    fun getRoutes(userRepository: UserRepository, flags: OuraRouteFlags): List<Route> {
+        val routes = mutableListOf<Route>()
+        if (flags.dailyActivityEnabled) {
+            routes.add(OuraDailyActivityRoute(userRepository))
+        }
+        if (flags.dailyReadinessEnabled) {
+            routes.add(OuraDailyReadinessRoute(userRepository))
+        }
+        if (flags.dailySleepEnabled) {
+            routes.add(OuraDailySleepRoute(userRepository))
+        }
+        if (flags.dailyOxygenSaturationEnabled) {
+            routes.add(OuraDailyOxygenSaturationRoute(userRepository))
+        }
+        if (flags.heartRateEnabled) {
+            routes.add(OuraHeartRateRoute(userRepository))
+        }
+        if (flags.personalInfoEnabled) {
+            routes.add(OuraPersonalInfoRoute(userRepository))
+        }
+        if (flags.sessionEnabled) {
+            routes.add(OuraSessionRoute(userRepository))
+        }
+        if (flags.sleepEnabled) {
+            routes.add(OuraSleepRoute(userRepository))
+        }
+        if (flags.tagEnabled) {
+            routes.add(OuraTagRoute(userRepository))
+        }
+        if (flags.workoutEnabled) {
+            routes.add(OuraWorkoutRoute(userRepository))
+        }
+        if (flags.ringConfigurationEnabled) {
+            routes.add(OuraRingConfigurationRoute(userRepository))
+        }
+        if (flags.restModePeriodEnabled) {
+            routes.add(OuraRestModePeriodRoute(userRepository))
+        }
+        if (flags.sleepTimeRecommendationEnabled) {
+            routes.add(OuraSleepTimeRecommendationRoute(userRepository))
+        }
         return routes
     }
 }