mirror of
https://github.com/InsanusMokrassar/krontab.git
synced 2025-12-25 14:25:47 +00:00
Compare commits
23 Commits
v2.5.1
...
renovate/k
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
1d9b6eaae2 | ||
| 2cce483dc8 | |||
| fe5cdbefe8 | |||
| 4379635174 | |||
| d0c3bae000 | |||
| dfedd58b76 | |||
| b59c325641 | |||
| de64a4d806 | |||
| 409ca3770f | |||
| 08ef7281e5 | |||
| c28bf17335 | |||
| bd590c3e3e | |||
| 9c11c0c7fc | |||
| 79375f21e3 | |||
| 0b4dc1b328 | |||
| 4afebd8b7e | |||
| c76ca1798e | |||
| 58917c6458 | |||
| 5ef6134d9f | |||
| b9237e13c9 | |||
| 17971ed8fb | |||
| 505108d2dd | |||
| 094284562d |
25
CHANGELOG.md
25
CHANGELOG.md
@@ -1,5 +1,30 @@
|
|||||||
# Changelog
|
# Changelog
|
||||||
|
|
||||||
|
## 2.7.2
|
||||||
|
|
||||||
|
* `Version`:
|
||||||
|
* `Kotlin`: `2.1.10`
|
||||||
|
* `Serialization`: `1.8.0`
|
||||||
|
|
||||||
|
## 2.7.1
|
||||||
|
|
||||||
|
* Fixes in parser and checker
|
||||||
|
|
||||||
|
## 2.7.0
|
||||||
|
|
||||||
|
* `Version`:
|
||||||
|
* `Kotlin`: `2.1.0`
|
||||||
|
* `Coroutines`: `1.10.1`
|
||||||
|
* Add WASM support (solution of [#137](https://github.com/InsanusMokrassar/krontab/issues/137))
|
||||||
|
|
||||||
|
## 2.6.1
|
||||||
|
|
||||||
|
* Fixes in parsing of string parts
|
||||||
|
|
||||||
|
## 2.6.0
|
||||||
|
|
||||||
|
* Fix of `doOnceTz` behaviour: now it will use local time as utc time to get next waking up time
|
||||||
|
|
||||||
## 2.5.1
|
## 2.5.1
|
||||||
|
|
||||||
* Add cleaning up of incoming template, which must remove all malformed parts from string template (fix of [#126](https://github.com/InsanusMokrassar/krontab/issues/126))
|
* Add cleaning up of incoming template, which must remove all malformed parts from string template (fix of [#126](https://github.com/InsanusMokrassar/krontab/issues/126))
|
||||||
|
|||||||
@@ -8,6 +8,7 @@
|
|||||||

|

|
||||||

|

|
||||||

|

|
||||||
|

|
||||||
|
|
||||||
[](https://insanusmokrassar.github.io/krontab/)
|
[](https://insanusmokrassar.github.io/krontab/)
|
||||||
[](https://docs.inmo.dev/krontab/index.html)
|
[](https://docs.inmo.dev/krontab/index.html)
|
||||||
|
|||||||
@@ -62,6 +62,11 @@ kotlin {
|
|||||||
linuxX64()
|
linuxX64()
|
||||||
mingwX64()
|
mingwX64()
|
||||||
linuxArm64()
|
linuxArm64()
|
||||||
|
wasm {
|
||||||
|
browser()
|
||||||
|
nodejs()
|
||||||
|
d8()
|
||||||
|
}
|
||||||
|
|
||||||
|
|
||||||
sourceSets {
|
sourceSets {
|
||||||
@@ -85,6 +90,7 @@ kotlin {
|
|||||||
dependencies {
|
dependencies {
|
||||||
implementation kotlin('test-common')
|
implementation kotlin('test-common')
|
||||||
implementation kotlin('test-annotations-common')
|
implementation kotlin('test-annotations-common')
|
||||||
|
implementation kotlin('test')
|
||||||
implementation "org.jetbrains.kotlinx:kotlinx-coroutines-test:$kotlin_coroutines_version"
|
implementation "org.jetbrains.kotlinx:kotlinx-coroutines-test:$kotlin_coroutines_version"
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -11,12 +11,20 @@ private String getCurrentVersionChangelog(String version) {
|
|||||||
return changelogDataOS.toString().trim()
|
return changelogDataOS.toString().trim()
|
||||||
}
|
}
|
||||||
|
|
||||||
if (new File(projectDir, "secret.gradle").exists()) {
|
|
||||||
apply from: './secret.gradle'
|
def githubTokenVariableName = "GITHUB_RELEASE_TOKEN"
|
||||||
|
def githubTokenVariableFromEnv = System.getenv(githubTokenVariableName)
|
||||||
|
|
||||||
|
def secretFile = new File(projectDir, "secret.gradle")
|
||||||
|
if (secretFile.exists() || project.hasProperty(githubTokenVariableName) || (githubTokenVariableFromEnv != "" && githubTokenVariableFromEnv != null)) {
|
||||||
|
if (secretFile.exists()) {
|
||||||
|
apply from: './secret.gradle'
|
||||||
|
}
|
||||||
apply plugin: "com.github.breadmoirai.github-release"
|
apply plugin: "com.github.breadmoirai.github-release"
|
||||||
|
def githubReleaseToken = project.hasProperty(githubTokenVariableName) ? project.property(githubTokenVariableName).toString() : githubTokenVariableFromEnv
|
||||||
|
|
||||||
githubRelease {
|
githubRelease {
|
||||||
token "${project.property('GITHUB_RELEASE_TOKEN')}"
|
token githubReleaseToken
|
||||||
|
|
||||||
owner = "InsanusMokrassar"
|
owner = "InsanusMokrassar"
|
||||||
repo = "${rootProject.name}"
|
repo = "${rootProject.name}"
|
||||||
|
|||||||
@@ -9,11 +9,11 @@ android.useAndroidX=true
|
|||||||
android.enableJetifier=false
|
android.enableJetifier=false
|
||||||
|
|
||||||
|
|
||||||
kotlin_version=2.0.21
|
kotlin_version=2.1.10
|
||||||
kotlin_coroutines_version=1.9.0
|
kotlin_coroutines_version=1.10.1
|
||||||
kotlin_serialization_version=1.7.3
|
kotlin_serialization_version=1.9.0
|
||||||
|
|
||||||
dokka_version=1.9.20
|
dokka_version=2.0.0
|
||||||
|
|
||||||
klockVersion=5.4.0
|
klockVersion=5.4.0
|
||||||
|
|
||||||
@@ -23,7 +23,7 @@ github_release_plugin_version=2.5.2
|
|||||||
|
|
||||||
## Android
|
## Android
|
||||||
|
|
||||||
android_gradle_version=8.2.2
|
android_gradle_version=8.7.2
|
||||||
android_minSdkVersion=21
|
android_minSdkVersion=21
|
||||||
android_compileSdkVersion=35
|
android_compileSdkVersion=35
|
||||||
android_buildToolsVersion=35.0.0
|
android_buildToolsVersion=35.0.0
|
||||||
@@ -36,5 +36,5 @@ androidx_work_version=2.10.0
|
|||||||
|
|
||||||
## Common
|
## Common
|
||||||
|
|
||||||
version=2.5.1
|
version=2.7.2
|
||||||
android_code_version=43
|
android_code_version=48
|
||||||
|
|||||||
2
gradle/wrapper/gradle-wrapper.properties
vendored
2
gradle/wrapper/gradle-wrapper.properties
vendored
@@ -3,4 +3,4 @@ distributionBase=GRADLE_USER_HOME
|
|||||||
distributionPath=wrapper/dists
|
distributionPath=wrapper/dists
|
||||||
zipStoreBase=GRADLE_USER_HOME
|
zipStoreBase=GRADLE_USER_HOME
|
||||||
zipStorePath=wrapper/dists
|
zipStorePath=wrapper/dists
|
||||||
distributionUrl=https\://services.gradle.org/distributions/gradle-8.10.2-bin.zip
|
distributionUrl=https\://services.gradle.org/distributions/gradle-8.12.1-bin.zip
|
||||||
|
|||||||
@@ -35,6 +35,8 @@ suspend inline fun <T> KronScheduler.doOnceLocal(block: (DateTime) -> T): T = do
|
|||||||
/**
|
/**
|
||||||
* Execute [block] once at the [KronScheduler.next] time and return result of [block] calculation.
|
* Execute [block] once at the [KronScheduler.next] time and return result of [block] calculation.
|
||||||
*
|
*
|
||||||
|
* WARNING!!! This method will use local time instead of utc
|
||||||
|
*
|
||||||
* WARNING!!! If you want to launch it in parallel, you must do this explicitly.
|
* WARNING!!! If you want to launch it in parallel, you must do this explicitly.
|
||||||
*
|
*
|
||||||
* WARNING!!! In case if [KronScheduler.next] of [this] instance will return null, [block] will be called immediatelly
|
* WARNING!!! In case if [KronScheduler.next] of [this] instance will return null, [block] will be called immediatelly
|
||||||
@@ -42,7 +44,7 @@ suspend inline fun <T> KronScheduler.doOnceLocal(block: (DateTime) -> T): T = do
|
|||||||
suspend inline fun <T> KronScheduler.doOnceTz(noinline block: suspend (DateTimeTz) -> T): T {
|
suspend inline fun <T> KronScheduler.doOnceTz(noinline block: suspend (DateTimeTz) -> T): T {
|
||||||
val time = when (this) {
|
val time = when (this) {
|
||||||
is KronSchedulerTz -> nextOrNowWithOffset()
|
is KronSchedulerTz -> nextOrNowWithOffset()
|
||||||
else -> nextOrNow().local
|
else -> nextTimeZoned() ?: DateTimeTz.nowLocal()
|
||||||
}
|
}
|
||||||
delay((time - DateTimeTz.nowLocal()).millisecondsLong)
|
delay((time - DateTimeTz.nowLocal()).millisecondsLong)
|
||||||
return block(time)
|
return block(time)
|
||||||
|
|||||||
@@ -41,53 +41,83 @@ private fun <T> createSimpleScheduler(from: String, dataRange: IntRange, dataCon
|
|||||||
* FSM for parsing of incoming data. If at the end of parsing it have non-null state and string is not empty, data passed check
|
* FSM for parsing of incoming data. If at the end of parsing it have non-null state and string is not empty, data passed check
|
||||||
*
|
*
|
||||||
* 1.
|
* 1.
|
||||||
* * \\d -> 1
|
* * "\\d" -> 2
|
||||||
* * \\* -> 2
|
* * "\\*" -> 4
|
||||||
* * \\- -> 5
|
* * "F" -> 7
|
||||||
* * , -> 1
|
* * "f" -> 7
|
||||||
* * m -> 6
|
* * "L" -> 7
|
||||||
* * o -> 7
|
* * "l" -> 7
|
||||||
* * w -> 7
|
* * "/" -> 6
|
||||||
* 2.
|
* 2.
|
||||||
* * / -> 3
|
* * "\\d" -> 2
|
||||||
|
* * "/" -> 6
|
||||||
|
* * "," -> 1
|
||||||
|
* * "-" -> 3
|
||||||
|
* * "m" -> 9
|
||||||
|
* * "o" -> 10
|
||||||
|
* * "w" -> 10
|
||||||
* 3.
|
* 3.
|
||||||
* * \\d -> 3
|
* * "L" -> 7
|
||||||
* * \\* -> 4
|
* * "l" -> 7
|
||||||
|
* * "\\d" -> 8
|
||||||
* 4.
|
* 4.
|
||||||
* * , -> 1
|
* * "/" -> 6
|
||||||
|
* * "," -> 1
|
||||||
* 5.
|
* 5.
|
||||||
* * \\d -> 5
|
* * "/" -> 6
|
||||||
* * , -> 1
|
|
||||||
* 6.
|
* 6.
|
||||||
* * s -> 7
|
* * "\\d" -> 8
|
||||||
* 7. Empty, end of parse
|
* * "\\*" -> 7
|
||||||
|
* 7.
|
||||||
|
* * "," -> 1
|
||||||
|
* 8.
|
||||||
|
* * "\\d" -> 8
|
||||||
|
* * "," -> 1
|
||||||
|
* 9.
|
||||||
|
* * "s" -> 10 // end of ms
|
||||||
|
* 10. Empty, end of parse
|
||||||
*/
|
*/
|
||||||
private val checkIncomingPartTransitionsMap = listOf(
|
private val checkIncomingPartTransitionsMap = listOf(
|
||||||
listOf(
|
listOf( // 0
|
||||||
Regex("\\d") to 0,
|
Regex("\\d") to 1,
|
||||||
Regex("\\*") to 1,
|
|
||||||
Regex("-") to 4,
|
|
||||||
Regex(",") to 0,
|
|
||||||
Regex("m") to 5,
|
|
||||||
Regex("o") to 6,
|
|
||||||
Regex("w") to 6,
|
|
||||||
),
|
|
||||||
listOf(
|
|
||||||
Regex("/") to 2,
|
|
||||||
),
|
|
||||||
listOf(
|
|
||||||
Regex("\\d") to 2,
|
|
||||||
Regex("\\*") to 3,
|
Regex("\\*") to 3,
|
||||||
|
Regex("[Ff]") to 6,
|
||||||
|
Regex("[Ll]") to 6,
|
||||||
|
Regex("/") to 5,
|
||||||
),
|
),
|
||||||
listOf(
|
listOf( // 1
|
||||||
|
Regex("\\d") to 1,
|
||||||
|
Regex("/") to 5,
|
||||||
|
Regex(",") to 0,
|
||||||
|
Regex("-") to 2,
|
||||||
|
Regex("m") to 8,
|
||||||
|
Regex("o") to 9,
|
||||||
|
Regex("w") to 9,
|
||||||
|
),
|
||||||
|
listOf( // 2
|
||||||
|
Regex("[Ll]") to 6,
|
||||||
|
Regex("\\d") to 7,
|
||||||
|
),
|
||||||
|
listOf( // 3
|
||||||
|
Regex("/") to 5,
|
||||||
Regex(",") to 0,
|
Regex(",") to 0,
|
||||||
),
|
),
|
||||||
listOf(
|
listOf( // 4
|
||||||
Regex("\\d") to 4,
|
Regex("/") to 5,
|
||||||
|
),
|
||||||
|
listOf( // 5
|
||||||
|
Regex("\\d") to 7,
|
||||||
|
Regex("\\*") to 6,
|
||||||
|
),
|
||||||
|
listOf( // 6
|
||||||
Regex(",") to 0,
|
Regex(",") to 0,
|
||||||
),
|
),
|
||||||
listOf(
|
listOf( // 7
|
||||||
Regex("s") to 6, // end of ms
|
Regex("\\d") to 7,
|
||||||
|
Regex(",") to 0,
|
||||||
|
),
|
||||||
|
listOf( // 8
|
||||||
|
Regex("s") to 9, // end of ms
|
||||||
),
|
),
|
||||||
listOf(), // empty state, end of parsing
|
listOf(), // empty state, end of parsing
|
||||||
)
|
)
|
||||||
|
|||||||
@@ -2,6 +2,7 @@ package dev.inmo.krontab.utils
|
|||||||
|
|
||||||
import korlibs.time.*
|
import korlibs.time.*
|
||||||
import dev.inmo.krontab.KronSchedulerTz
|
import dev.inmo.krontab.KronSchedulerTz
|
||||||
|
import dev.inmo.krontab.KrontabTemplate
|
||||||
import dev.inmo.krontab.buildSchedule
|
import dev.inmo.krontab.buildSchedule
|
||||||
import kotlinx.coroutines.*
|
import kotlinx.coroutines.*
|
||||||
import kotlinx.coroutines.flow.takeWhile
|
import kotlinx.coroutines.flow.takeWhile
|
||||||
@@ -11,73 +12,51 @@ import kotlin.test.*
|
|||||||
@ExperimentalCoroutinesApi
|
@ExperimentalCoroutinesApi
|
||||||
@FlowPreview
|
@FlowPreview
|
||||||
class StringParseTest {
|
class StringParseTest {
|
||||||
@Test
|
private fun makeSimpleEverySecondTest(template: KrontabTemplate) {
|
||||||
fun testThatFlowIsCorrectlyWorkEverySecondBuiltOnString() {
|
val kronScheduler = buildSchedule(template)
|
||||||
val kronScheduler = buildSchedule("*/1 * * * *")
|
|
||||||
|
|
||||||
val flow = kronScheduler.asFlowWithoutDelays()
|
val flow = kronScheduler.asFlowWithoutDelays()
|
||||||
|
|
||||||
runTest {
|
runTest {
|
||||||
val mustBeCollected = 10
|
val mustBeCollected = 10
|
||||||
var collected = 0
|
var collected = 0
|
||||||
|
var previousTime: DateTime? = null
|
||||||
flow.takeWhile {
|
flow.takeWhile {
|
||||||
collected < mustBeCollected
|
collected < mustBeCollected
|
||||||
}.collect {
|
}.collect {
|
||||||
|
previousTime ?.let { previousTime ->
|
||||||
|
assertEquals(previousTime + 1.seconds, it)
|
||||||
|
}
|
||||||
|
previousTime = it
|
||||||
collected++
|
collected++
|
||||||
}
|
}
|
||||||
assertEquals(mustBeCollected, collected)
|
assertEquals(mustBeCollected, collected)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@Test
|
||||||
|
fun testThatFlowIsCorrectlyWorkEverySecondBuiltOnString() {
|
||||||
|
makeSimpleEverySecondTest("*/1 * * * *")
|
||||||
|
}
|
||||||
@Test
|
@Test
|
||||||
fun testThatFlowIsCorrectlyWorkEverySecondBuiltOnStringWithWrongAmountOfSpaces() {
|
fun testThatFlowIsCorrectlyWorkEverySecondBuiltOnStringWithWrongAmountOfSpaces() {
|
||||||
val kronScheduler = buildSchedule("*/1 * * * * ")
|
val templatesFirstReplacers = listOf(
|
||||||
|
"*/1",
|
||||||
val flow = kronScheduler.asFlowWithoutDelays()
|
"*",
|
||||||
|
"/1",
|
||||||
runTest {
|
"f,/1",
|
||||||
val mustBeCollected = 10
|
)
|
||||||
var collected = 0
|
templatesFirstReplacers.forEach { replacer ->
|
||||||
flow.takeWhile {
|
makeSimpleEverySecondTest("$replacer * * * * ")
|
||||||
collected < mustBeCollected
|
|
||||||
}.collect {
|
|
||||||
collected++
|
|
||||||
}
|
|
||||||
assertEquals(mustBeCollected, collected)
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
@Test
|
@Test
|
||||||
fun testThatFlowIsCorrectlyWorkEverySecondBuiltOnStringWithGarbageInTemplate() {
|
fun testThatFlowIsCorrectlyWorkEverySecondBuiltOnStringWithGarbageInTemplate() {
|
||||||
val kronScheduler = buildSchedule(" sdf */1 * * * oo * ")
|
makeSimpleEverySecondTest(" sdf */1 * * * oo * ")
|
||||||
|
|
||||||
val flow = kronScheduler.asFlowWithoutDelays()
|
|
||||||
|
|
||||||
runTest {
|
|
||||||
val mustBeCollected = 10
|
|
||||||
var collected = 0
|
|
||||||
flow.takeWhile {
|
|
||||||
collected < mustBeCollected
|
|
||||||
}.collect {
|
|
||||||
collected++
|
|
||||||
}
|
|
||||||
assertEquals(mustBeCollected, collected)
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
@Test
|
@Test
|
||||||
fun testThatFlowIsCorrectlyWorkEverySecondBuiltOnStringWithInsufficientArgsInTemplate() {
|
fun testThatFlowIsCorrectlyWorkEverySecondBuiltOnStringWithInsufficientArgsInTemplate() {
|
||||||
val kronScheduler = buildSchedule(" sdf */1 ")
|
makeSimpleEverySecondTest(" sdf */1 ")
|
||||||
|
|
||||||
val flow = kronScheduler.asFlowWithoutDelays()
|
|
||||||
|
|
||||||
runTest {
|
|
||||||
val mustBeCollected = 10
|
|
||||||
var collected = 0
|
|
||||||
flow.takeWhile {
|
|
||||||
collected < mustBeCollected
|
|
||||||
}.collect {
|
|
||||||
collected++
|
|
||||||
}
|
|
||||||
assertEquals(mustBeCollected, collected)
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
@Test
|
@Test
|
||||||
fun testThatFlowIsCorrectlyWorkEverySecondWhenMillisIsHalfOfSecondBuiltOnString() {
|
fun testThatFlowIsCorrectlyWorkEverySecondWhenMillisIsHalfOfSecondBuiltOnString() {
|
||||||
@@ -88,9 +67,14 @@ class StringParseTest {
|
|||||||
runTest {
|
runTest {
|
||||||
val mustBeCollected = 10
|
val mustBeCollected = 10
|
||||||
var collected = 0
|
var collected = 0
|
||||||
|
var previousTime: DateTime? = null
|
||||||
flow.takeWhile {
|
flow.takeWhile {
|
||||||
collected < mustBeCollected
|
collected < mustBeCollected
|
||||||
}.collect {
|
}.collect {
|
||||||
|
previousTime ?.let { previousTime ->
|
||||||
|
assertEquals(previousTime.copy(milliseconds = 500) + 1.seconds, it)
|
||||||
|
}
|
||||||
|
previousTime = it
|
||||||
collected++
|
collected++
|
||||||
}
|
}
|
||||||
assertEquals(mustBeCollected, collected)
|
assertEquals(mustBeCollected, collected)
|
||||||
|
|||||||
Reference in New Issue
Block a user