Add SNTPClient.blockingEpochTime

tidal-music · Jul 4, 2024 · af99c84 · af99c84
1 parent 6436e6c
commit af99c84
Show file tree

Hide file tree

Showing 3 changed files with 17 additions and 0 deletions.
diff --git a/networktime/src/commonMain/kotlin/com/tidal/networktime/SNTPClient.kt b/networktime/src/commonMain/kotlin/com/tidal/networktime/SNTPClient.kt
@@ -38,6 +38,12 @@ class SNTPClient(
   @ObjCName(name = "epochTimeMs")
   val epochTime by delegate::epochTime
 
+  /**
+   * The calculated epoch time, blocking until it has been calculated at least once.
+   */
+  @ObjCName(name = "blockingEpochTimeMs")
+  suspend fun blockingEpochTime() = delegate.blockingEpochTime()
+
   /**
    * Starts periodic synchronization. If it's already started, it does nothing. Otherwise, it
    * requests an immediate dispatch of a synchronization and subsequent ones

diff --git a/networktime/src/commonMain/kotlin/com/tidal/networktime/internal/SNTPClientImpl.kt b/networktime/src/commonMain/kotlin/com/tidal/networktime/internal/SNTPClientImpl.kt
@@ -39,6 +39,13 @@ constructor(
       return synchronizedTime - synchronizedAt + referenceClock.referenceEpochTime
     }
 
+  suspend fun blockingEpochTime(): Duration {
+    epochTime?.let { return it }
+    synchronizationResultProcessor.firstSynchronizationLock
+      .lock()
+    return epochTime!!
+  }
+
   fun enableSynchronization() = operationCoordinator.dispatchStartSync()
 
   fun disableSynchronization() = operationCoordinator.dispatchStopSync()

diff --git a/...me/src/commonMain/kotlin/com/tidal/networktime/internal/SynchronizationResultProcessor.kt b/...me/src/commonMain/kotlin/com/tidal/networktime/internal/SynchronizationResultProcessor.kt
@@ -1,5 +1,6 @@
 package com.tidal.networktime.internal
 
+import kotlinx.coroutines.sync.Mutex
 import kotlinx.serialization.ExperimentalSerializationApi
 import kotlinx.serialization.json.Json
 import kotlinx.serialization.json.okio.decodeFromBufferedSource
@@ -30,6 +31,7 @@ internal class SynchronizationResultProcessor(
     }
     set(value) {
       mutableState.synchronizationResult = value
+      firstSynchronizationLock.unlock()
       if (backupFilePath != null && value != null) {
         try {
           fileSystem.write(backupFilePath) {
@@ -39,4 +41,6 @@ internal class SynchronizationResultProcessor(
         }
       }
     }
+
+  val firstSynchronizationLock = Mutex(locked = true)
 }