periodic.kt

import kotlinx.coroutines.CoroutineScope
import kotlinx.coroutines.Job
import kotlinx.coroutines.launch
import kotlinx.coroutines.time.delay
import mu.KotlinLogging
import java.time.Duration

private val log = KotlinLogging.logger { }

data class PeriodicJob(
    val initialDelay: () -> Duration = { Duration.ZERO },
    val work: suspend () -> Duration
)

fun CoroutineScope.launch(job: PeriodicJob): Job =
    launch {
        delay(job.initialDelay())

        while (true) {
            val next = try {
                job.work()
            } catch (e: Exception) {
                log.error { e }
                Duration.ZERO
            }

            delay(next)
        }
    }