Skip to content

Commit afc3e3f

Browse files
committed
Improve readbility
1 parent 9e2a3bf commit afc3e3f

File tree

2 files changed

+6
-4
lines changed

2 files changed

+6
-4
lines changed

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

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -91,8 +91,8 @@ public void initialize(OuraRestSourceConnectorConfig config, OffsetStorageReader
9191
ouraConfig.getOuraSleepTimeRecommendationEnabled()
9292
);
9393
this.offsetManager = new KafkaOffsetManager(offsetStorageReader);
94-
this.routes = OuraRouteFactory.getRoutes(this.userRepository, flags);
95-
this.ouraRequestGenerator = new OuraRequestGenerator(this.userRepository, Duration.ofDays(15), this.offsetManager, this.routes);
94+
this.ouraRequestGenerator = new OuraRequestGenerator(this.userRepository, this.offsetManager, flags);
95+
this.routes = this.ouraRequestGenerator.getRoutes();
9696
this.offsetManager.initialize(getPartitions());
9797
}
9898

oura-library/src/main/kotlin/org/radarbase/oura/request/OuraRequestGenerator.kt

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -7,6 +7,7 @@ import okhttp3.Response
77
import okhttp3.ResponseBody
88
import org.radarbase.oura.converter.TopicData
99
import org.radarbase.oura.route.OuraRouteFactory
10+
import org.radarbase.oura.route.OuraRouteFlags
1011
import org.radarbase.oura.route.Route
1112
import org.radarbase.oura.user.User
1213
import org.radarbase.oura.user.UserRepository
@@ -20,9 +21,10 @@ class OuraRequestGenerator
2021
@JvmOverloads
2122
constructor(
2223
private val userRepository: UserRepository,
23-
private val defaultQueryRange: Duration = Duration.ofDays(15),
2424
private val ouraOffsetManager: OuraOffsetManager,
25-
public val routes: List<Route> = OuraRouteFactory.getRoutes(userRepository),
25+
private val flags: OuraRouteFlags,
26+
public val routes: List<Route> = OuraRouteFactory.getRoutes(userRepository, flags),
27+
private val defaultQueryRange: Duration = Duration.ofDays(15),
2628
) : RequestGenerator {
2729
private val routeNextRequest: MutableMap<String, Instant> = mutableMapOf()
2830

0 commit comments

Comments
 (0)