fix: isStale call to fitbit connector respects external cache configuration

pvannierop · pvannierop · commit 2b5b19620e1a · 2025-09-15T10:37:54.000+02:00
diff --git a/kafka-connect-fitbit-source/src/main/java/org/radarbase/connect/rest/fitbit/user/ServiceUserRepository.kt b/kafka-connect-fitbit-source/src/main/java/org/radarbase/connect/rest/fitbit/user/ServiceUserRepository.kt
@@ -61,7 +61,6 @@ import java.io.IOException
 import java.util.concurrent.ConcurrentHashMap
 import java.util.stream.Stream
 import kotlin.time.Duration.Companion.days
-import kotlin.time.Duration.Companion.hours
 import kotlin.time.Duration.Companion.minutes
 import kotlin.time.Duration.Companion.seconds
 import kotlin.time.toKotlinDuration
@@ -235,7 +234,7 @@ class ServiceUserRepository : UserRepository {
         }
 
     override fun hasPendingUpdates(): Boolean = runBlocking(Dispatchers.Default) {
-        userCache.isStale(1.hours)
+        userCache.isStale()
     }
 
     @Throws(IOException::class)

Original file line number	Diff line number	Diff line change
`@@ -61,7 +61,6 @@ import java.io.IOException`
`61`	`61`	`import java.util.concurrent.ConcurrentHashMap`
`62`	`62`	`import java.util.stream.Stream`
`63`	`63`	`import kotlin.time.Duration.Companion.days`
`64`		`-import kotlin.time.Duration.Companion.hours`
`65`	`64`	`import kotlin.time.Duration.Companion.minutes`
`66`	`65`	`import kotlin.time.Duration.Companion.seconds`
`67`	`66`	`import kotlin.time.toKotlinDuration`
`@@ -235,7 +234,7 @@ class ServiceUserRepository : UserRepository {`
`235`	`234`	`}`
`236`	`235`
`237`	`236`	`override fun hasPendingUpdates(): Boolean = runBlocking(Dispatchers.Default) {`
`238`		`- userCache.isStale(1.hours)`
	`237`	`+ userCache.isStale()`
`239`	`238`	`}`
`240`	`239`
`241`	`240`	`@Throws(IOException::class)`