creating NetworkClock object

Author: softartdev

kronos/src/androidMain/kotlin/com/softartdev/kronos/NetworkClock.kt

@@ -0,0 +1,20 @@
+package com.softartdev.kronos
+
+import android.content.Context
+import com.lyft.kronos.AndroidClockFactory
+import com.lyft.kronos.KronosClock
+
+actual object NetworkClock {
+
+    lateinit var kronosClock: KronosClock
+
+    fun sync(applicationContext: Context) {
+        kronosClock = AndroidClockFactory.createKronosClock(applicationContext)
+        kronosClock.syncInBackground()
+    }
+
+    actual fun getCurrentNtpTimeMs(): Long? = when {
+        ::kronosClock.isInitialized -> kronosClock.getCurrentTimeMs()
+        else -> null
+    }
+}

kronos/src/commonMain/kotlin/com/softartdev/kronos/NetworkClock.kt

@@ -0,0 +1,8 @@
+package com.softartdev.kronos
+
+expect object NetworkClock {
+    /**
+     * @return the current time in milliseconds, or null if no ntp sync has occurred.
+     */
+    fun getCurrentNtpTimeMs(): Long?
+}

kronos/src/iosMain/kotlin/com/softartdev/kronos/NetworkClock.kt

@@ -0,0 +1,10 @@
+package com.softartdev.kronos
+
+actual object NetworkClock {
+
+    fun sync() {
+        //TODO "Not yet implemented"
+    }
+
+    actual fun getCurrentNtpTimeMs(): Long? = null
+}

kronos/src/jvmMain/kotlin/com/softartdev/kronos/JvmClockFactory.kt

@@ -0,0 +1,29 @@
+package com.softartdev.kronos
+
+import com.lyft.kronos.*
+
+object JvmClockFactory {
+
+    @JvmStatic
+    fun createDeviceClock(): Clock = JvmSystemClock()
+
+    @JvmStatic
+    @JvmOverloads
+    fun createKronosClock(
+        syncListener: SyncListener? = null,
+        ntpHosts: List<String> = DefaultParam.NTP_HOSTS,
+        requestTimeoutMs: Long = DefaultParam.TIMEOUT_MS,
+        minWaitTimeBetweenSyncMs: Long = DefaultParam.MIN_WAIT_TIME_BETWEEN_SYNC_MS,
+        cacheExpirationMs: Long = DefaultParam.CACHE_EXPIRATION_MS,
+        maxNtpResponseTimeMs: Long = DefaultParam.MAX_NTP_RESPONSE_TIME_MS
+    ): KronosClock = ClockFactory.createKronosClock(
+        localClock = createDeviceClock(),
+        syncResponseCache = JvmPreferenceSyncResponseCache(),
+        syncListener = syncListener,
+        ntpHosts = ntpHosts,
+        requestTimeoutMs = requestTimeoutMs,
+        minWaitTimeBetweenSyncMs = minWaitTimeBetweenSyncMs,
+        cacheExpirationMs = cacheExpirationMs,
+        maxNtpResponseTimeMs = maxNtpResponseTimeMs
+    )
+}

kronos/src/jvmMain/kotlin/com/softartdev/kronos/JvmPreferenceSyncResponseCache.kt

@@ -0,0 +1,27 @@
+package com.softartdev.kronos
+
+import com.lyft.kronos.SyncResponseCache
+import com.lyft.kronos.internal.Constants.TIME_UNAVAILABLE
+import java.util.prefs.Preferences
+
+class JvmPreferenceSyncResponseCache : SyncResponseCache {
+    private val preferences: Preferences = Preferences.userNodeForPackage(JvmPreferenceSyncResponseCache::class.java)
+
+    override var currentTime: Long
+        get() = preferences.getLong(KEY_CURRENT_TIME, TIME_UNAVAILABLE)
+        set(value) = preferences.putLong(KEY_CURRENT_TIME, value)
+    override var elapsedTime: Long
+        get() = preferences.getLong(KEY_ELAPSED_TIME, TIME_UNAVAILABLE)
+        set(value) = preferences.putLong(KEY_ELAPSED_TIME, value)
+    override var currentOffset: Long
+        get() = preferences.getLong(KEY_OFFSET, TIME_UNAVAILABLE)
+        set(value) = preferences.putLong(KEY_OFFSET, value)
+
+    override fun clear() = preferences.clear()
+
+    companion object {
+        internal const val KEY_CURRENT_TIME = "com.lyft.kronos.cached_current_time"
+        internal const val KEY_ELAPSED_TIME = "com.lyft.kronos.cached_elapsed_time"
+        internal const val KEY_OFFSET = "com.lyft.kronos.cached_offset"
+    }
+}

kronos/src/jvmMain/kotlin/com/softartdev/kronos/JvmSystemClock.kt

@@ -0,0 +1,10 @@
+package com.softartdev.kronos
+
+import com.lyft.kronos.Clock
+
+class JvmSystemClock : Clock {
+    override fun getCurrentTimeMs(): Long = System.currentTimeMillis()
+
+    // TODO: use SystemClock.elapsedRealtime()
+    override fun getElapsedTimeMs(): Long = System.currentTimeMillis()
+}

kronos/src/jvmMain/kotlin/com/softartdev/kronos/NetworkClock.kt

@@ -0,0 +1,18 @@
+package com.softartdev.kronos
+
+import com.lyft.kronos.KronosClock
+
+actual object NetworkClock {
+
+    lateinit var kronosClock: KronosClock
+
+    fun sync() {
+        kronosClock = JvmClockFactory.createKronosClock()
+        kronosClock.syncInBackground()
+    }
+
+    actual fun getCurrentNtpTimeMs(): Long? = when {
+        ::kronosClock.isInitialized -> kronosClock.getCurrentTimeMs()
+        else -> null
+    }
+}

sampleApp/build.gradle.kts

@@ -59,6 +59,7 @@ kotlin {
             dependencies {
                 implementation(compose.desktop.common)
                 implementation(compose.desktop.currentOs)
+                implementation(compose.preview)
             }
         }
 

sampleApp/src/androidMain/kotlin/com/softartdev/kronos/sample/App.android.kt

@@ -6,6 +6,7 @@ import android.net.Uri
 import android.os.Bundle
 import androidx.activity.ComponentActivity
 import androidx.activity.compose.setContent
+import com.softartdev.kronos.NetworkClock
 
 class AndroidApp : Application() {
     companion object {
@@ -15,6 +16,7 @@ class AndroidApp : Application() {
     override fun onCreate() {
         super.onCreate()
         INSTANCE = this
+        NetworkClock.sync(applicationContext)
     }
 }
 

sampleApp/src/commonMain/kotlin/com/softartdev/kronos/sample/App.kt

@@ -1,27 +1,35 @@
 package com.softartdev.kronos.sample
 
-import androidx.compose.foundation.layout.*
+import androidx.compose.foundation.layout.Arrangement
+import androidx.compose.foundation.layout.Column
+import androidx.compose.foundation.layout.fillMaxSize
 import androidx.compose.material.Button
 import androidx.compose.material.Text
-import androidx.compose.runtime.Composable
+import androidx.compose.runtime.*
 import androidx.compose.ui.Alignment
 import androidx.compose.ui.Modifier
-import androidx.compose.ui.unit.dp
 import com.softartdev.kronos.Greeting
+import com.softartdev.kronos.NetworkClock
 
 @Composable
 internal fun App() = AppTheme {
+    var ntpTimeMs by remember { mutableStateOf(NetworkClock.getCurrentNtpTimeMs()) }
     Column(
         modifier = Modifier.fillMaxSize(),
         horizontalAlignment = Alignment.CenterHorizontally,
-        verticalArrangement = Arrangement.Center
+        verticalArrangement = Arrangement.SpaceEvenly
     ) {
+        Text(text = "Network time millis: $ntpTimeMs")
         Button(
-            onClick = { openUrl("https://github.com/terrakok") }
+            onClick = { ntpTimeMs = NetworkClock.getCurrentNtpTimeMs() }
+        ) {
+            Text(text = "Refresh network time millis")
+        }
+        Button(
+            onClick = { openUrl("https://github.com/softartdev/Kronos-Multiplatform") }
         ) {
             Text("Open github")
         }
-        Spacer(modifier = Modifier.height(32.dp))
         Text(text = Greeting().greet())
     }
 }