Merge 649fe78873 into 1ce654fa06

.github/workflows/publishing_packages.yml

@@ -14,6 +14,11 @@ jobs:
           sed -i -e "s/^version=\([0-9\.]*\)/version=\1-branch_$branch-build${{ github.run_number }}/" gradle.properties
       - name: prebuild
         run: ./gradlew clean build
+      - name: Publish to Gitea
+        continue-on-error: true
+        run: ./gradlew publishAllPublicationsToGiteaRepository
+        env:
+          GITEA_TOKEN: ${{ secrets.GITEA_TOKEN }}
       - name: Publish package
         continue-on-error: true
         run: ./gradlew --no-parallel publishAllPublicationsToGithubPackagesRepository

.gitignore

@@ -1,5 +1,4 @@
 .idea
-.kotlin
 out/*
 *.iml
 target

CHANGELOG.md

@@ -1,71 +1,5 @@
 # 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
-
-* 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 support of insufficient amount of arguments (fix of [#126](https://github.com/InsanusMokrassar/krontab/issues/126))
-* `Version`:
-  * `Kotlin`: `2.0.21`
-  * `AndroidXWork`: `2.10.0`
-
-## 2.5.0
-
-* `Version`:
-  * `Kotlin`: `2.0.20`
-  * `Coroutines`: `1.9.0`
-  * `Serialization`: `1.7.3`
-
-## 2.4.0
-
-* `Version`:
-  * `Kotlin`: `2.0.10`
-  * `Coroutines`: `1.8.1`
-  * `Serialization`: `1.7.1`
-  * `Klock`: `5.4.0`
-  * `AndroidXWork`: `2.9.1`
-
-## 2.3.0
-
-* `doWhile` now will guarantee that it will not call `doOnce` more than once for time
-
-## 2.2.9
-
-* `Version`:
-  * `Kotlin`: `1.9.23`
-  * `Serialization`: `1.6.3`
-  * `Klock`: `5.3.2`
-* Fixes in build-in schedulers
-
-## 2.2.8
-
-* `Version`:
-  * `Coroutines`: `1.8.0`
-
 ## 2.2.7
 
 * `Version`:

README.md

@@ -8,7 +8,6 @@
 ![Android](https://img.shields.io/badge/Android-green?style=for-the-badge&logo=android&logoColor=white)
 ![Js](https://img.shields.io/badge/JavaScript-323330?style=for-the-badge&logo=javascript&logoColor=F7DF1E)
 ![Linux x64](https://img.shields.io/badge/Linux%20x64-white?style=for-the-badge&logo=linux&logoColor=black)
-![WASM](https://img.shields.io/badge/WASM-654FF0?style=for-the-badge&logo=webassembly&logoColor=white)
 
 [![KDocs](https://img.shields.io/badge/KDocs-323330?style=for-the-badge&logo=Kotlin&logoColor=7F52FF)](https://insanusmokrassar.github.io/krontab/)
 [![Tutorials](https://img.shields.io/badge/Tutorials-0288D1?style=for-the-badge&logo=mkdocs&logoColor=white)](https://docs.inmo.dev/krontab/index.html)

build.gradle

@@ -62,11 +62,6 @@ kotlin {
     linuxX64()
     mingwX64()
     linuxArm64()
-    wasm {
-        browser()
-        nodejs()
-        d8()
-    }
 
 
     sourceSets {
@@ -90,7 +85,6 @@ kotlin {
             dependencies {
                 implementation kotlin('test-common')
                 implementation kotlin('test-annotations-common')
-                implementation kotlin('test')
                 implementation "org.jetbrains.kotlinx:kotlinx-coroutines-test:$kotlin_coroutines_version"
             }
         }

github_release.gradle

@@ -11,28 +11,20 @@ private String getCurrentVersionChangelog(String version) {
     return changelogDataOS.toString().trim()
 }
 
-
-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'
-    }
+if (new File(projectDir, "secret.gradle").exists()) {
+    apply from: './secret.gradle'
     apply plugin: "com.github.breadmoirai.github-release"
-    def githubReleaseToken = project.hasProperty(githubTokenVariableName) ? project.property(githubTokenVariableName).toString() : githubTokenVariableFromEnv
 
     githubRelease {
-        token githubReleaseToken
+        token "${project.property('GITHUB_RELEASE_TOKEN')}"
 
-        owner = "InsanusMokrassar"
-        repo = "${rootProject.name}"
+        owner "InsanusMokrassar"
+        repo "${rootProject.name}"
 
-        tagName = "v${project.version}"
-        releaseName = "${project.version}"
-        targetCommitish = "${project.version}"
+        tagName "v${project.version}"
+        releaseName "${project.version}"
+        targetCommitish "${project.version}"
 
-        body = getCurrentVersionChangelog("${project.version}")
+        body getCurrentVersionChangelog("${project.version}")
     }
 }

gradle.properties

@@ -9,32 +9,32 @@ android.useAndroidX=true
 android.enableJetifier=false
 
 
-kotlin_version=2.1.10
-kotlin_coroutines_version=1.10.1
-kotlin_serialization_version=1.8.0
+kotlin_version=1.9.22
+kotlin_coroutines_version=1.7.3
+kotlin_serialization_version=1.6.2
 
-dokka_version=2.0.0
+dokka_version=1.9.10
 
-klockVersion=5.4.0
+klockVersion=5.3.1
 
 ## Github reease
 
-github_release_plugin_version=2.5.2
+github_release_plugin_version=2.4.1
 
 ## Android
 
-android_gradle_version=8.7.2
+android_gradle_version=8.1.4
 android_minSdkVersion=21
-android_compileSdkVersion=35
-android_buildToolsVersion=35.0.0
+android_compileSdkVersion=34
+android_buildToolsVersion=34.0.0
 dexcount_version=4.0.0
 junit_version=4.12
 test_ext_junit_version=1.1.3
 espresso_core=3.4.0
 
-androidx_work_version=2.10.0
+androidx_work_version=2.9.0
 
 ## Common
 
-version=2.7.2
-android_code_version=48
+version=2.2.7
+android_code_version=37

gradle/wrapper/gradle-wrapper.properties

@@ -1,6 +1,6 @@
 distributionBase=GRADLE_USER_HOME
 distributionPath=wrapper/dists
-distributionUrl=https\://services.gradle.org/distributions/gradle-8.14.3-bin.zip
+distributionUrl=https\://services.gradle.org/distributions/gradle-8.6-bin.zip
 networkTimeout=10000
 validateDistributionUrl=true
 zipStoreBase=GRADLE_USER_HOME

gradlew

@@ -15,8 +15,6 @@
 # See the License for the specific language governing permissions and
 # limitations under the License.
 #
-# SPDX-License-Identifier: Apache-2.0
-#
 
 ##############################################################################
 #
@@ -57,7 +55,7 @@
 #       Darwin, MinGW, and NonStop.
 #
 #   (3) This script is generated from the Groovy template
-#       https://github.com/gradle/gradle/blob/HEAD/platforms/jvm/plugins-application/src/main/resources/org/gradle/api/internal/plugins/unixStartScript.txt
+#       https://github.com/gradle/gradle/blob/HEAD/subprojects/plugins/src/main/resources/org/gradle/api/internal/plugins/unixStartScript.txt
 #       within the Gradle project.
 #
 #       You can find Gradle at https://github.com/gradle/gradle/.
@@ -86,7 +84,7 @@ done
 # shellcheck disable=SC2034
 APP_BASE_NAME=${0##*/}
 # Discard cd standard output in case $CDPATH is set (https://github.com/gradle/gradle/issues/25036)
-APP_HOME=$( cd -P "${APP_HOME:-./}" > /dev/null && printf '%s\n' "$PWD" ) || exit
+APP_HOME=$( cd "${APP_HOME:-./}" > /dev/null && pwd -P ) || exit
 
 # Use the maximum available, or set MAX_FD != -1 to use that value.
 MAX_FD=maximum
@@ -114,7 +112,7 @@ case "$( uname )" in                #(
   NONSTOP* )        nonstop=true ;;
 esac
 
-CLASSPATH="\\\"\\\""
+CLASSPATH=$APP_HOME/gradle/wrapper/gradle-wrapper.jar
 
 
 # Determine the Java command to use to start the JVM.
@@ -205,7 +203,7 @@ fi
 DEFAULT_JVM_OPTS='"-Xmx64m" "-Xms64m"'
 
 # Collect all arguments for the java command:
-#   * DEFAULT_JVM_OPTS, JAVA_OPTS, and optsEnvironmentVar are not allowed to contain shell fragments,
+#   * DEFAULT_JVM_OPTS, JAVA_OPTS, JAVA_OPTS, and optsEnvironmentVar are not allowed to contain shell fragments,
 #     and any embedded shellness will be escaped.
 #   * For example: A user cannot expect ${Hostname} to be expanded, as it is an environment variable and will be
 #     treated as '${Hostname}' itself on the command line.
@@ -213,7 +211,7 @@ DEFAULT_JVM_OPTS='"-Xmx64m" "-Xms64m"'
 set -- \
         "-Dorg.gradle.appname=$APP_BASE_NAME" \
         -classpath "$CLASSPATH" \
-        -jar "$APP_HOME/gradle/wrapper/gradle-wrapper.jar" \
+        org.gradle.wrapper.GradleWrapperMain \
         "$@"
 
 # Stop when "xargs" is not available.

gradlew.bat

@@ -13,8 +13,6 @@
 @rem See the License for the specific language governing permissions and
 @rem limitations under the License.
 @rem
-@rem SPDX-License-Identifier: Apache-2.0
-@rem
 
 @if "%DEBUG%"=="" @echo off
 @rem ##########################################################################
@@ -70,11 +68,11 @@ goto fail
 :execute
 @rem Setup the command line
 
-set CLASSPATH=
+set CLASSPATH=%APP_HOME%\gradle\wrapper\gradle-wrapper.jar
 
 
 @rem Execute Gradle
-"%JAVA_EXE%" %DEFAULT_JVM_OPTS% %JAVA_OPTS% %GRADLE_OPTS% "-Dorg.gradle.appname=%APP_BASE_NAME%" -classpath "%CLASSPATH%" -jar "%APP_HOME%\gradle\wrapper\gradle-wrapper.jar" %*
+"%JAVA_EXE%" %DEFAULT_JVM_OPTS% %JAVA_OPTS% %GRADLE_OPTS% "-Dorg.gradle.appname=%APP_BASE_NAME%" -classpath "%CLASSPATH%" org.gradle.wrapper.GradleWrapperMain %*
 
 :end
 @rem End local scope for the variables with windows NT shell

src/androidMain/kotlin/KronSchedulerWork.kt

@@ -139,14 +139,10 @@ abstract class KronSchedulerWork(
             }
             throw e
         }
-        result.checkResults(
-            onFailure = {
-                if (prolongOnFailure) prolong()
-            },
-            onSuccess = {
-                if (prolongOnSuccess) prolong()
-            }
-        )
+        when (result) {
+            is Result.Failure -> if (prolongOnFailure) prolong()
+            is Result.Success -> if (prolongOnSuccess) prolong()
+        }
         return result
     }
 }

src/androidMain/kotlin/ResultChecker.kt

@@ -1,15 +0,0 @@
-package dev.inmo.krontab
-
-import android.annotation.SuppressLint
-import androidx.work.ListenableWorker
-
-@SuppressLint("RestrictedApi")
-internal inline fun ListenableWorker.Result.checkResults(
-    onFailure: () -> Unit,
-    onSuccess: () -> Unit
-) {
-    when (this) {
-        is ListenableWorker.Result.Failure -> onFailure()
-        is ListenableWorker.Result.Success -> onSuccess()
-    }
-}

src/commonMain/kotlin/Executes.kt

@@ -35,8 +35,6 @@ 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.
  *
- * 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!!! In case if [KronScheduler.next] of [this] instance will return null, [block] will be called immediatelly
@@ -44,7 +42,7 @@ suspend inline fun <T> KronScheduler.doOnceLocal(block: (DateTime) -> T): T = do
 suspend inline fun <T> KronScheduler.doOnceTz(noinline block: suspend (DateTimeTz) -> T): T {
     val time = when (this) {
         is KronSchedulerTz -> nextOrNowWithOffset()
-        else -> nextTimeZoned() ?: DateTimeTz.nowLocal()
+        else -> nextOrNow().local
     }
     delay((time - DateTimeTz.nowLocal()).millisecondsLong)
     return block(time)
@@ -73,18 +71,9 @@ suspend inline fun <T> doOnceTz(
  * Will execute [block] while it will return true as a result of its calculation
  */
 suspend inline fun KronScheduler.doWhile(block: (DateTime) -> Boolean) {
-    var latest: DateTime? = null
     do {
         delay(1L)
-        val result = doOnce {
-            if (latest != it) {
-                latest = it
-                block(it)
-            } else {
-                null
-            }
-        }
-    } while (result == null || result)
+    } while (doOnce(block))
 }
 /**
  * Will execute [block] while it will return true as a result of its calculation
@@ -96,18 +85,9 @@ suspend inline fun KronScheduler.doWhileLocal(block: (DateTime) -> Boolean) = do
  * Will execute [block] while it will return true as a result of its calculation
  */
 suspend inline fun KronScheduler.doWhileTz(noinline block: suspend (DateTimeTz) -> Boolean) {
-    var latest: DateTimeTz? = null
     do {
         delay(1L)
-        val result = doOnceTz {
-            if (latest != it) {
-                latest = it
-                block(it)
-            } else {
-                null
-            }
-        }
-    } while (result == null || result)
+    } while (doOnceTz(block))
 }
 
 /**

src/commonMain/kotlin/KrontabConfig.kt

@@ -1,6 +1,5 @@
 package dev.inmo.krontab
 
-import dev.inmo.krontab.internal.*
 import dev.inmo.krontab.internal.CronDateTimeScheduler
 import dev.inmo.krontab.internal.CronDateTimeSchedulerTz
 import dev.inmo.krontab.internal.createKronScheduler
@@ -95,37 +94,27 @@ value class KrontabConfig(
         var dayOfWeekParsed: Array<Byte>? = null
         var yearParsed: Array<Int>? = null
         var millisecondsParsed: Array<Short>? = null
-        val (secondsSource, minutesSource, hoursSource, dayOfMonthSource, monthSource) = template
-            .split(" ")
-            .filter { checkIncomingPart(it) } // filter garbage from string
-            .let {
-                if (it.size < 5) { // reconstruction in case of insufficient arguments; 5 is amount of required arguments out of latest also code
-                    it + (it.size until 5).map { "*" }
-                } else {
-                    it
-                }
-            }
-            .also {
-                listOfNotNull(
-                    it.getOrNull(5),
-                    it.getOrNull(6),
-                    it.getOrNull(7),
-                    it.getOrNull(8)
-                ).forEach {
-                    val offsetFromString = parseOffset(it)
-                    val dayOfWeekFromString = parseWeekDay(it)
-                    val millisecondsFromString = parseMilliseconds(it)
-                    offsetParsed = offsetParsed ?: offsetFromString
-                    dayOfWeekParsed = dayOfWeekParsed ?: dayOfWeekFromString
-                    millisecondsParsed = millisecondsParsed ?: millisecondsFromString
-                    when {
-                        dayOfWeekFromString != null || offsetFromString != null || millisecondsFromString != null -> return@forEach
-                        yearParsed == null -> {
-                            yearParsed = parseYears(it)
-                        }
+        val (secondsSource, minutesSource, hoursSource, dayOfMonthSource, monthSource) = template.split(" ").also {
+            listOfNotNull(
+                it.getOrNull(5),
+                it.getOrNull(6),
+                it.getOrNull(7),
+                it.getOrNull(8)
+            ).forEach {
+                val offsetFromString = parseOffset(it)
+                val dayOfWeekFromString = parseWeekDay(it)
+                val millisecondsFromString = parseMilliseconds(it)
+                offsetParsed = offsetParsed ?: offsetFromString
+                dayOfWeekParsed = dayOfWeekParsed ?: dayOfWeekFromString
+                millisecondsParsed = millisecondsParsed ?: millisecondsFromString
+                when {
+                    dayOfWeekFromString != null || offsetFromString != null || millisecondsFromString != null -> return@forEach
+                    yearParsed == null -> {
+                        yearParsed = parseYears(it)
                     }
                 }
             }
+        }
 
         val secondsParsed = parseSeconds(secondsSource)
         val minutesParsed = parseMinutes(minutesSource)

src/commonMain/kotlin/SchedulerShortcuts.kt

@@ -34,60 +34,35 @@ val EverySecondScheduler: KronScheduler by lazy {
  * [KronScheduler.next] will always return [korlibs.time.DateTime.now] + one minute
  */
 val EveryMinuteScheduler: KronScheduler by lazy {
-    buildSchedule {
-        seconds { at(0) }
-        minutes { 0 every 1 }
-    }
+    buildSchedule { minutes { 0 every 1 } }
 }
 
 /**
  * [KronScheduler.next] will always return [korlibs.time.DateTime.now] + one hour
  */
 val EveryHourScheduler: KronScheduler by lazy {
-    buildSchedule {
-        seconds { at(0) }
-        minutes { at(0) }
-        hours { 0 every 1 }
-    }
+    buildSchedule { hours { 0 every 1 } }
 }
 
 /**
  * [KronScheduler.next] will always return [korlibs.time.DateTime.now] + one day
  */
 val EveryDayOfMonthScheduler: KronScheduler by lazy {
-    buildSchedule {
-        seconds { at(0) }
-        minutes { at(0) }
-        hours { at(0) }
-        dayOfMonth { 0 every 1 }
-    }
+    buildSchedule { dayOfMonth { 0 every 1 } }
 }
 
 /**
  * [KronScheduler.next] will always return [korlibs.time.DateTime.now] + one month
  */
 val EveryMonthScheduler: KronScheduler by lazy {
-    buildSchedule {
-        seconds { at(0) }
-        minutes { at(0) }
-        hours { at(0) }
-        dayOfMonth { at(0) }
-        months { 0 every 1 }
-    }
+    buildSchedule { months { 0 every 1 } }
 }
 
 /**
  * [KronScheduler.next] will always return [korlibs.time.DateTime.now] + one year
  */
 val EveryYearScheduler: KronScheduler by lazy {
-    buildSchedule {
-        seconds { at(0) }
-        minutes { at(0) }
-        hours { at(0) }
-        dayOfMonth { at(0) }
-        months { at(0) }
-        years { 0 every 1 }
-    }
+    buildSchedule { years { 0 every 1 } }
 }
 
 /**

src/commonMain/kotlin/builder/SchedulerBuilder.kt

@@ -182,24 +182,15 @@ class SchedulerBuilder(
      */
     fun build(): KronScheduler = offset ?.let {
         createKronSchedulerWithOffset(
-            seconds = seconds,
-            minutes = minutes,
-            hours = hours,
-            dayOfMonth = dayOfMonth,
-            month = month,
-            years = year,
-            weekDays = dayOfWeek,
-            offset = TimezoneOffset(it.minutes),
-            milliseconds = milliseconds ?: millisecondsArrayDefault
+            seconds,
+            minutes,
+            hours,
+            dayOfMonth,
+            month,
+            year,
+            dayOfWeek,
+            TimezoneOffset(it.minutes),
+            milliseconds ?: millisecondsArrayDefault
         )
-    } ?: createKronScheduler(
-        seconds = seconds,
-        minutes = minutes,
-        hours = hours,
-        dayOfMonth = dayOfMonth,
-        month = month,
-        years = year,
-        weekDays = dayOfWeek,
-        milliseconds = milliseconds ?: millisecondsArrayDefault
-    )
+    } ?: createKronScheduler(seconds, minutes, hours, dayOfMonth, month, year, dayOfWeek, milliseconds ?: millisecondsArrayDefault)
 }

src/commonMain/kotlin/internal/Parser.kt

@@ -37,106 +37,6 @@ private fun <T> createSimpleScheduler(from: String, dataRange: IntRange, dataCon
     return results.map(dataConverter)
 }
 
-/**
- * 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.
- *     * "\\d" -> 2
- *     * "\\*" -> 4
- *     * "F" -> 7
- *     * "f" -> 7
- *     * "L" -> 7
- *     * "l" -> 7
- *     * "/" -> 6
- * 2.
- *     * "\\d" -> 2
- *     * "/" -> 6
- *     * "," -> 1
- *     * "-" -> 3
- *     * "m" -> 9
- *     * "o" -> 10
- *     * "w" -> 10
- * 3.
- *     * "L" -> 7
- *     * "l" -> 7
- *     * "\\d" -> 8
- * 4.
- *     * "/" -> 6
- *     * "," -> 1
- * 5.
- *     * "/" -> 6
- * 6.
- *     * "\\d" -> 8
- *     * "\\*" -> 7
- * 7.
- *     * "," -> 1
- * 8.
- *     * "\\d" -> 8
- *     * "," -> 1
- * 9.
- *     * "s" -> 10 // end of ms
- * 10. Empty, end of parse
- */
-private val checkIncomingPartTransitionsMap = listOf(
-    listOf( // 0
-        Regex("\\d") to 1,
-        Regex("\\*") to 3,
-        Regex("[Ff]") to 6,
-        Regex("[Ll]") to 6,
-        Regex("/") to 5,
-    ),
-    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,
-    ),
-    listOf( // 4
-        Regex("/") to 5,
-    ),
-    listOf( // 5
-        Regex("\\d") to 7,
-        Regex("\\*") to 6,
-    ),
-    listOf( // 6
-        Regex(",") to 0,
-    ),
-    listOf( // 7
-        Regex("\\d") to 7,
-        Regex(",") to 0,
-    ),
-    listOf( // 8
-        Regex("s") to 9, // end of ms
-    ),
-    listOf(), // empty state, end of parsing
-)
-internal fun checkIncomingPart(part: String): Boolean {
-    var i = 0
-    var state = checkIncomingPartTransitionsMap[0]
-    while (i < part.length) {
-        val char = part[i]
-        val nextState = state.firstNotNullOfOrNull {
-            it.second.takeIf { _ -> it.first.matches("$char") }
-        }
-        if (nextState == null) return false
-        state = checkIncomingPartTransitionsMap[nextState]
-        i++
-    }
-
-    return part.isNotEmpty()
-}
-
 internal fun parseWeekDay(from: String?) = from ?.let { if (it.endsWith("w")) createSimpleScheduler(it.removeSuffix("w"), dayOfWeekRange, intToByteConverter) ?.toTypedArray() else null }
 internal fun parseOffset(from: String?) = from ?.let { if (it.endsWith("o")) it.removeSuffix("o").toIntOrNull() else null }
 internal fun parseYears(from: String?) = from ?.let { createSimpleScheduler(from, yearRange, intToIntConverter) ?.toTypedArray() }

src/commonTest/kotlin/BuildersTest.kt

@@ -1,38 +0,0 @@
-package dev.inmo.krontab.utils
-
-import dev.inmo.krontab.*
-import korlibs.time.*
-import kotlinx.coroutines.test.runTest
-import kotlin.test.Test
-import kotlin.test.assertEquals
-import kotlin.time.Duration.Companion.milliseconds
-import kotlin.time.Duration.Companion.minutes
-import kotlin.time.Duration.Companion.seconds
-
-class BuildersTest {
-    @Test
-    fun presetsWorksCorrectly() {
-        val data = mapOf(
-            EverySecondScheduler to { it: DateTime -> if (it.milliseconds > 0 ) it + 1.seconds - it.milliseconds.milliseconds else it },
-            EveryMinuteScheduler to { it: DateTime -> if (it.seconds > 0 || it.milliseconds > 0 ) it + 1.minutes - it.seconds.seconds - it.milliseconds.milliseconds else it },
-            EveryHourScheduler to { it: DateTime -> if (it.minutes > 0 || it.seconds > 0 || it.milliseconds > 0 ) it + 1.hours - it.minutes.minutes - it.seconds.seconds - it.milliseconds.milliseconds else it },
-            EveryDayOfMonthScheduler to { it: DateTime -> if (it.hours > 0 || it.minutes > 0 || it.seconds > 0 || it.milliseconds > 0 ) it + 1.days - it.hours.hours - it.minutes.minutes - it.seconds.seconds - it.milliseconds.milliseconds else it },
-            EveryMonthScheduler to { it: DateTime -> if (it.dayOfMonth > 1 || it.hours > 0 || it.minutes > 0 || it.seconds > 0 || it.milliseconds > 0 ) (it + 1.months).copy(dayOfMonth = 1, hour = 0, minute = 0, second = 0, milliseconds = 0) else it },
-        )
-        val samples = 10000
-
-        runTest {
-            var now = DateTime.now()
-            for (i in 0 until samples) {
-                data.forEach { (scheduler, expectCalculator) ->
-                    val expectValue = expectCalculator(now)
-                    val newNow = scheduler.nextOrRelative(now)
-
-                    assertEquals(expectValue, newNow, "For time ${now.toStringDefault()} calculated wrong value: ${newNow.toStringDefault()} is not equal to ${expectValue.toStringDefault()}")
-
-                    now = newNow
-                }
-            }
-        }
-    }
-}

src/commonTest/kotlin/StringParseTest.kt

@@ -2,7 +2,6 @@ package dev.inmo.krontab.utils
 
 import korlibs.time.*
 import dev.inmo.krontab.KronSchedulerTz
-import dev.inmo.krontab.KrontabTemplate
 import dev.inmo.krontab.buildSchedule
 import kotlinx.coroutines.*
 import kotlinx.coroutines.flow.takeWhile
@@ -12,52 +11,23 @@ import kotlin.test.*
 @ExperimentalCoroutinesApi
 @FlowPreview
 class StringParseTest {
-    private fun makeSimpleEverySecondTest(template: KrontabTemplate) {
-        val kronScheduler = buildSchedule(template)
+    @Test
+    fun testThatFlowIsCorrectlyWorkEverySecondBuiltOnString() {
+        val kronScheduler = buildSchedule("*/1 * * * *")
 
         val flow = kronScheduler.asFlowWithoutDelays()
 
         runTest {
             val mustBeCollected = 10
             var collected = 0
-            var previousTime: DateTime? = null
             flow.takeWhile {
                 collected < mustBeCollected
             }.collect {
-                previousTime ?.let { previousTime ->
-                    assertEquals(previousTime + 1.seconds, it)
-                }
-                previousTime = it
                 collected++
             }
             assertEquals(mustBeCollected, collected)
         }
     }
-
-    @Test
-    fun testThatFlowIsCorrectlyWorkEverySecondBuiltOnString() {
-        makeSimpleEverySecondTest("*/1 * * * *")
-    }
-    @Test
-    fun testThatFlowIsCorrectlyWorkEverySecondBuiltOnStringWithWrongAmountOfSpaces() {
-        val templatesFirstReplacers = listOf(
-            "*/1",
-            "*",
-            "/1",
-            "f,/1",
-        )
-        templatesFirstReplacers.forEach { replacer ->
-            makeSimpleEverySecondTest("$replacer  *  * *  * ")
-        }
-    }
-    @Test
-    fun testThatFlowIsCorrectlyWorkEverySecondBuiltOnStringWithGarbageInTemplate() {
-        makeSimpleEverySecondTest(" sdf */1  *  * *  oo * ")
-    }
-    @Test
-    fun testThatFlowIsCorrectlyWorkEverySecondBuiltOnStringWithInsufficientArgsInTemplate() {
-        makeSimpleEverySecondTest(" sdf */1  ")
-    }
     @Test
     fun testThatFlowIsCorrectlyWorkEverySecondWhenMillisIsHalfOfSecondBuiltOnString() {
         val kronScheduler = buildSchedule("*/1 * * * * 500ms")
@@ -67,14 +37,9 @@ class StringParseTest {
         runTest {
             val mustBeCollected = 10
             var collected = 0
-            var previousTime: DateTime? = null
             flow.takeWhile {
                 collected < mustBeCollected
             }.collect {
-                previousTime ?.let { previousTime ->
-                    assertEquals(previousTime.copy(milliseconds = 500) + 1.seconds, it)
-                }
-                previousTime = it
                 collected++
             }
             assertEquals(mustBeCollected, collected)