mirror of
https://github.com/InsanusMokrassar/MicroUtils.git
synced 2025-12-12 09:15:50 +00:00
Compare commits
22 Commits
0.26.1
...
cb56bf9793
| Author | SHA1 | Date | |
|---|---|---|---|
| cb56bf9793 | |||
| b152986b4e | |||
| fce47897d5 | |||
| 0b701a3e99 | |||
| 9dad353957 | |||
| 89e16b7bdb | |||
| c2965da341 | |||
| ffb072dc5f | |||
| a247dbcb02 | |||
| 1dd71175f4 | |||
| bbe62c0e7b | |||
| 9822ff321b | |||
| b485d485ef | |||
| 0b3d445109 | |||
| d7e48940bc | |||
| 1049eb0fe7 | |||
| c871ef5635 | |||
| 7edfcb20c4 | |||
| 7a1438a2c0 | |||
| 2af8cba8cd | |||
| 27d74c0a62 | |||
| f86d1bfe06 |
39
CHANGELOG.md
39
CHANGELOG.md
@@ -1,5 +1,44 @@
|
||||
# Changelog
|
||||
|
||||
## 0.26.7
|
||||
|
||||
## 0.26.6
|
||||
|
||||
* `Versions`:
|
||||
* `Ktor`: `3.3.0` -> `3.3.1`
|
||||
* `Okio`: `3.16.0` -> `3.16.2`
|
||||
|
||||
## 0.26.5
|
||||
|
||||
* `Versions`:
|
||||
* `Kotlin`: `2.2.10` -> `2.2.20`
|
||||
* `KSLog`: `1.5.0` -> `1.5.1`
|
||||
* `Ktor`: `3.2.3` -> `3.3.0`
|
||||
* `KotlinX Browser`: `0.3` -> `0.5.0`
|
||||
* `Koin`: `4.1.0` -> `4.1.1`
|
||||
|
||||
## 0.26.4
|
||||
|
||||
* `Common`:
|
||||
* Add expect/actual `MPPFilePathSeparator`
|
||||
* Fix `FileName` realization to take care about system file path separator
|
||||
|
||||
## 0.26.3
|
||||
|
||||
* `Versions`:
|
||||
* `Kotlin`: `2.2.0` -> `2.2.10`
|
||||
* `KSP`: `2.2.0-2.0.2` -> `2.2.10-2.0.2`
|
||||
* `Android CoreKTX`: `1.16.0` -> `1.17.0`
|
||||
* `Android Fragment`: `1.8.8` -> `1.8.9`
|
||||
|
||||
## 0.26.2
|
||||
|
||||
* `Versions`:
|
||||
* `Ktor`: `3.2.2` -> `3.2.3`
|
||||
* `Okio`: `3.15.0` -> `3.16.0`
|
||||
* `Coroutines`:
|
||||
* Rename `SpecialMutableStateFlow` to `MutableRedeliverStateFlow`
|
||||
|
||||
## 0.26.1
|
||||
|
||||
* `Versions`:
|
||||
|
||||
@@ -2,11 +2,9 @@ import androidx.compose.runtime.remember
|
||||
import androidx.compose.ui.test.ExperimentalTestApi
|
||||
import androidx.compose.ui.test.runComposeUiTest
|
||||
import dev.inmo.micro_utils.common.compose.LoadableComponent
|
||||
import dev.inmo.micro_utils.coroutines.SpecialMutableStateFlow
|
||||
import kotlinx.coroutines.flow.MutableSharedFlow
|
||||
import dev.inmo.micro_utils.coroutines.MutableRedeliverStateFlow
|
||||
import kotlinx.coroutines.flow.filter
|
||||
import kotlinx.coroutines.flow.first
|
||||
import kotlinx.coroutines.flow.firstOrNull
|
||||
import org.jetbrains.annotations.TestOnly
|
||||
import kotlin.test.Test
|
||||
import kotlin.test.assertTrue
|
||||
@@ -16,8 +14,8 @@ class LoadableComponentTests {
|
||||
@Test
|
||||
@TestOnly
|
||||
fun testSimpleLoad() = runComposeUiTest {
|
||||
val loadingFlow = SpecialMutableStateFlow<Int>(0)
|
||||
val loadedFlow = SpecialMutableStateFlow<Int>(0)
|
||||
val loadingFlow = MutableRedeliverStateFlow<Int>(0)
|
||||
val loadedFlow = MutableRedeliverStateFlow<Int>(0)
|
||||
setContent {
|
||||
LoadableComponent<Int>({
|
||||
loadingFlow.filter { it == 1 }.first()
|
||||
|
||||
@@ -7,7 +7,7 @@ import kotlin.jvm.JvmInline
|
||||
@JvmInline
|
||||
value class FileName(val string: String) {
|
||||
val name: String
|
||||
get() = withoutSlashAtTheEnd.takeLastWhile { it != '/' }
|
||||
get() = withoutSlashAtTheEnd.takeLastWhile { it != MPPFilePathSeparator }
|
||||
val extension: String
|
||||
get() = name.takeLastWhile { it != '.' }
|
||||
val nameWithoutExtension: String
|
||||
@@ -18,7 +18,7 @@ value class FileName(val string: String) {
|
||||
} ?: filename
|
||||
}
|
||||
val withoutSlashAtTheEnd: String
|
||||
get() = string.dropLastWhile { it == '/' }
|
||||
get() = string.dropLastWhile { it == MPPFilePathSeparator }
|
||||
override fun toString(): String = string
|
||||
}
|
||||
|
||||
@@ -26,6 +26,7 @@ value class FileName(val string: String) {
|
||||
expect class MPPFile
|
||||
|
||||
expect val MPPFile.filename: FileName
|
||||
expect val MPPFilePathSeparator: Char
|
||||
expect val MPPFile.filesize: Long
|
||||
expect val MPPFile.bytesAllocatorSync: ByteArrayAllocator
|
||||
expect val MPPFile.bytesAllocator: SuspendByteArrayAllocator
|
||||
|
||||
@@ -35,6 +35,10 @@ private suspend fun MPPFile.dirtyReadBytes(): ByteArray = readBytesPromise().awa
|
||||
*/
|
||||
actual val MPPFile.filename: FileName
|
||||
get() = FileName(name)
|
||||
|
||||
actual val MPPFilePathSeparator: Char
|
||||
get() = '/'
|
||||
|
||||
/**
|
||||
* @suppress
|
||||
*/
|
||||
|
||||
@@ -14,6 +14,10 @@ actual typealias MPPFile = File
|
||||
*/
|
||||
actual val MPPFile.filename: FileName
|
||||
get() = FileName(name)
|
||||
|
||||
actual val MPPFilePathSeparator: Char
|
||||
get() = File.separatorChar
|
||||
|
||||
/**
|
||||
* @suppress
|
||||
*/
|
||||
|
||||
@@ -11,6 +11,10 @@ actual typealias MPPFile = Path
|
||||
*/
|
||||
actual val MPPFile.filename: FileName
|
||||
get() = FileName(toString())
|
||||
|
||||
|
||||
actual val MPPFilePathSeparator: Char = Path.DIRECTORY_SEPARATOR.first()
|
||||
|
||||
/**
|
||||
* @suppress
|
||||
*/
|
||||
|
||||
@@ -37,6 +37,10 @@ private suspend fun MPPFile.dirtyReadBytes(): ByteArray = readBytesPromise().awa
|
||||
*/
|
||||
actual val MPPFile.filename: FileName
|
||||
get() = FileName(name)
|
||||
|
||||
actual val MPPFilePathSeparator: Char
|
||||
get() = '/'
|
||||
|
||||
/**
|
||||
* @suppress
|
||||
*/
|
||||
|
||||
@@ -3,7 +3,7 @@ package dev.inmo.micro_utils.coroutines.compose
|
||||
import androidx.compose.runtime.Composable
|
||||
import androidx.compose.runtime.collectAsState
|
||||
import androidx.compose.runtime.remember
|
||||
import dev.inmo.micro_utils.coroutines.SpecialMutableStateFlow
|
||||
import dev.inmo.micro_utils.coroutines.MutableRedeliverStateFlow
|
||||
import kotlinx.coroutines.flow.StateFlow
|
||||
import kotlinx.coroutines.flow.asStateFlow
|
||||
import kotlinx.coroutines.flow.debounce
|
||||
@@ -16,7 +16,7 @@ import org.jetbrains.compose.web.css.StyleSheet
|
||||
* to add `Style(stylesheet)` on every compose function call
|
||||
*/
|
||||
object StyleSheetsAggregator {
|
||||
private val _stylesFlow = SpecialMutableStateFlow<Set<CSSRulesHolder>>(emptySet())
|
||||
private val _stylesFlow = MutableRedeliverStateFlow<Set<CSSRulesHolder>>(emptySet())
|
||||
val stylesFlow: StateFlow<Set<CSSRulesHolder>> = _stylesFlow.asStateFlow()
|
||||
|
||||
@Composable
|
||||
|
||||
@@ -2,7 +2,7 @@ import androidx.compose.material.Button
|
||||
import androidx.compose.material.Text
|
||||
import androidx.compose.runtime.collectAsState
|
||||
import androidx.compose.ui.test.*
|
||||
import dev.inmo.micro_utils.coroutines.SpecialMutableStateFlow
|
||||
import dev.inmo.micro_utils.coroutines.MutableRedeliverStateFlow
|
||||
import org.jetbrains.annotations.TestOnly
|
||||
import kotlin.test.Test
|
||||
|
||||
@@ -11,7 +11,7 @@ class FlowStateTests {
|
||||
@Test
|
||||
@TestOnly
|
||||
fun simpleTest() = runComposeUiTest {
|
||||
val flowState = SpecialMutableStateFlow(0)
|
||||
val flowState = MutableRedeliverStateFlow(0)
|
||||
setContent {
|
||||
Button({ flowState.value++ }) { Text("Click") }
|
||||
Text(flowState.collectAsState().value.toString())
|
||||
|
||||
@@ -1,7 +1,5 @@
|
||||
package dev.inmo.micro_utils.coroutines
|
||||
|
||||
import kotlinx.coroutines.CoroutineScope
|
||||
import kotlinx.coroutines.Dispatchers
|
||||
import kotlinx.coroutines.ExperimentalCoroutinesApi
|
||||
import kotlinx.coroutines.InternalCoroutinesApi
|
||||
import kotlinx.coroutines.channels.BufferOverflow
|
||||
@@ -11,13 +9,12 @@ import kotlinx.coroutines.flow.MutableStateFlow
|
||||
import kotlinx.coroutines.flow.StateFlow
|
||||
import kotlinx.coroutines.internal.SynchronizedObject
|
||||
import kotlinx.coroutines.internal.synchronized
|
||||
import kotlin.coroutines.CoroutineContext
|
||||
|
||||
/**
|
||||
* Works like [StateFlow], but guarantee that latest value update will always be delivered to
|
||||
* each active subscriber
|
||||
*/
|
||||
open class SpecialMutableStateFlow<T>(
|
||||
open class MutableRedeliverStateFlow<T>(
|
||||
initialValue: T
|
||||
) : MutableStateFlow<T>, FlowCollector<T>, MutableSharedFlow<T> {
|
||||
@OptIn(InternalCoroutinesApi::class)
|
||||
@@ -68,3 +65,6 @@ open class SpecialMutableStateFlow<T>(
|
||||
|
||||
override suspend fun collect(collector: FlowCollector<T>) = sharingFlow.collect(collector)
|
||||
}
|
||||
|
||||
@Deprecated("Renamed to MutableRedeliverStateFlow", ReplaceWith("MutableRedeliverStateFlow<T>"))
|
||||
typealias SpecialMutableStateFlow<T> = MutableRedeliverStateFlow<T>
|
||||
@@ -1,7 +1,6 @@
|
||||
package dev.inmo.micro_utils.coroutines
|
||||
|
||||
import kotlinx.coroutines.currentCoroutineContext
|
||||
import kotlinx.coroutines.flow.MutableStateFlow
|
||||
import kotlinx.coroutines.flow.StateFlow
|
||||
import kotlinx.coroutines.flow.asStateFlow
|
||||
import kotlinx.coroutines.flow.first
|
||||
@@ -44,7 +43,7 @@ sealed interface SmartMutex {
|
||||
* @param locked Preset state of [isLocked] and its internal [_lockStateFlow]
|
||||
*/
|
||||
class Mutable(locked: Boolean = false) : SmartMutex {
|
||||
private val _lockStateFlow = SpecialMutableStateFlow<Boolean>(locked)
|
||||
private val _lockStateFlow = MutableRedeliverStateFlow<Boolean>(locked)
|
||||
override val lockStateFlow: StateFlow<Boolean> = _lockStateFlow.asStateFlow()
|
||||
|
||||
private val internalChangesMutex = Mutex()
|
||||
|
||||
@@ -1,7 +1,6 @@
|
||||
package dev.inmo.micro_utils.coroutines
|
||||
|
||||
import kotlinx.coroutines.currentCoroutineContext
|
||||
import kotlinx.coroutines.flow.MutableStateFlow
|
||||
import kotlinx.coroutines.flow.StateFlow
|
||||
import kotlinx.coroutines.flow.asStateFlow
|
||||
import kotlinx.coroutines.flow.first
|
||||
@@ -47,7 +46,7 @@ sealed interface SmartSemaphore {
|
||||
*/
|
||||
class Mutable(permits: Int, acquiredPermits: Int = 0) : SmartSemaphore {
|
||||
override val maxPermits: Int = permits
|
||||
private val _freePermitsStateFlow = SpecialMutableStateFlow<Int>(permits - acquiredPermits)
|
||||
private val _freePermitsStateFlow = MutableRedeliverStateFlow<Int>(permits - acquiredPermits)
|
||||
override val permitsStateFlow: StateFlow<Int> = _freePermitsStateFlow.asStateFlow()
|
||||
|
||||
private val internalChangesMutex = Mutex(false)
|
||||
@@ -73,7 +72,7 @@ sealed interface SmartSemaphore {
|
||||
acquiredPermits != checkedPermits
|
||||
}
|
||||
if (shouldContinue) {
|
||||
waitRelease()
|
||||
waitRelease(checkedPermits - acquiredPermits)
|
||||
}
|
||||
} while (shouldContinue && currentCoroutineContext().isActive)
|
||||
} catch (e: Throwable) {
|
||||
|
||||
@@ -4,6 +4,7 @@ import kotlinx.coroutines.flow.first
|
||||
import kotlinx.coroutines.sync.Mutex
|
||||
import kotlinx.coroutines.sync.withLock
|
||||
import kotlinx.coroutines.test.runTest
|
||||
import kotlin.test.BeforeTest
|
||||
import kotlin.test.Test
|
||||
import kotlin.test.assertEquals
|
||||
import kotlin.test.assertFails
|
||||
@@ -13,184 +14,517 @@ import kotlin.time.Duration.Companion.milliseconds
|
||||
import kotlin.time.Duration.Companion.seconds
|
||||
|
||||
class SmartKeyRWLockerTests {
|
||||
@Test
|
||||
fun writeLockKeyFailedOnGlobalWriteLockTest() = runTest {
|
||||
val locker = SmartKeyRWLocker<String>()
|
||||
val testKey = "test"
|
||||
locker.lockWrite()
|
||||
private lateinit var locker: SmartKeyRWLocker<String>
|
||||
|
||||
assertTrue { locker.isWriteLocked() }
|
||||
|
||||
assertFails {
|
||||
realWithTimeout(1.seconds) {
|
||||
locker.lockWrite(testKey)
|
||||
}
|
||||
}
|
||||
assertFalse { locker.isWriteLocked(testKey) }
|
||||
|
||||
locker.unlockWrite()
|
||||
assertFalse { locker.isWriteLocked() }
|
||||
|
||||
realWithTimeout(1.seconds) {
|
||||
locker.lockWrite(testKey)
|
||||
}
|
||||
assertTrue { locker.isWriteLocked(testKey) }
|
||||
assertTrue { locker.unlockWrite(testKey) }
|
||||
assertFalse { locker.isWriteLocked(testKey) }
|
||||
@BeforeTest
|
||||
fun setup() {
|
||||
locker = SmartKeyRWLocker()
|
||||
}
|
||||
|
||||
// ==================== Global Read Tests ====================
|
||||
|
||||
@Test
|
||||
fun writeLockKeyFailedOnGlobalReadLockTest() = runTest {
|
||||
val locker = SmartKeyRWLocker<String>()
|
||||
val testKey = "test"
|
||||
fun testGlobalReadAllowsMultipleConcurrentReads() = runTest {
|
||||
val results = mutableListOf<Boolean>()
|
||||
|
||||
locker.acquireRead()
|
||||
|
||||
assertEquals(Int.MAX_VALUE - 1, locker.readSemaphore().freePermits)
|
||||
|
||||
assertFails {
|
||||
realWithTimeout(1.seconds) {
|
||||
locker.lockWrite(testKey)
|
||||
val jobs = List(5) {
|
||||
launch {
|
||||
locker.acquireRead()
|
||||
delay(100.milliseconds)
|
||||
results.add(true)
|
||||
locker.releaseRead()
|
||||
}
|
||||
}
|
||||
assertFalse { locker.isWriteLocked(testKey) }
|
||||
|
||||
jobs.joinAll()
|
||||
locker.releaseRead()
|
||||
|
||||
assertEquals(5, results.size)
|
||||
}
|
||||
|
||||
@Test
|
||||
fun testGlobalReadBlocksGlobalWrite() = runTest {
|
||||
locker.acquireRead()
|
||||
|
||||
var writeAcquired = false
|
||||
val writeJob = launch {
|
||||
locker.lockWrite()
|
||||
writeAcquired = true
|
||||
locker.unlockWrite()
|
||||
}
|
||||
|
||||
delay(200.milliseconds)
|
||||
assertFalse(writeAcquired, "Write should be blocked by global read")
|
||||
|
||||
locker.releaseRead()
|
||||
assertEquals(Int.MAX_VALUE, locker.readSemaphore().freePermits)
|
||||
writeJob.join()
|
||||
|
||||
realWithTimeout(1.seconds) {
|
||||
locker.lockWrite(testKey)
|
||||
}
|
||||
assertTrue { locker.isWriteLocked(testKey) }
|
||||
assertTrue { locker.unlockWrite(testKey) }
|
||||
assertFalse { locker.isWriteLocked(testKey) }
|
||||
assertTrue(writeAcquired, "Write should succeed after read released")
|
||||
}
|
||||
|
||||
@Test
|
||||
fun readLockFailedOnWriteLockKeyTest() = runTest {
|
||||
val locker = SmartKeyRWLocker<String>()
|
||||
val testKey = "test"
|
||||
locker.lockWrite(testKey)
|
||||
fun testGlobalReadBlocksAllKeyWrites() = runTest {
|
||||
locker.acquireRead()
|
||||
|
||||
assertTrue { locker.isWriteLocked(testKey) }
|
||||
val writeFlags = mutableMapOf<String, Boolean>()
|
||||
val keys = listOf("key1", "key2", "key3")
|
||||
|
||||
assertFails {
|
||||
realWithTimeout(1.seconds) {
|
||||
val jobs = keys.map { key ->
|
||||
launch {
|
||||
locker.lockWrite(key)
|
||||
writeFlags[key] = true
|
||||
locker.unlockWrite(key)
|
||||
}
|
||||
}
|
||||
|
||||
delay(200.milliseconds)
|
||||
assertTrue(writeFlags.isEmpty(), "No writes should succeed while global read active")
|
||||
|
||||
locker.releaseRead()
|
||||
jobs.joinAll()
|
||||
|
||||
assertEquals(keys.size, writeFlags.size, "All writes should succeed after global read released")
|
||||
}
|
||||
|
||||
// ==================== Global Write Tests ====================
|
||||
|
||||
@Test
|
||||
fun testGlobalWriteBlocksAllOperations() = runTest {
|
||||
locker.lockWrite()
|
||||
|
||||
var globalReadAcquired = false
|
||||
var keyReadAcquired = false
|
||||
var keyWriteAcquired = false
|
||||
|
||||
val jobs = listOf(
|
||||
launch {
|
||||
locker.acquireRead()
|
||||
globalReadAcquired = true
|
||||
locker.releaseRead()
|
||||
},
|
||||
launch {
|
||||
locker.acquireRead("key1")
|
||||
keyReadAcquired = true
|
||||
locker.releaseRead("key1")
|
||||
},
|
||||
launch {
|
||||
locker.lockWrite("key2")
|
||||
keyWriteAcquired = true
|
||||
locker.unlockWrite("key2")
|
||||
}
|
||||
}
|
||||
assertEquals(locker.readSemaphore().maxPermits - 1, locker.readSemaphore().freePermits)
|
||||
)
|
||||
|
||||
locker.unlockWrite(testKey)
|
||||
assertFalse { locker.isWriteLocked(testKey) }
|
||||
delay(200.milliseconds)
|
||||
assertFalse(globalReadAcquired, "Global read should be blocked")
|
||||
assertFalse(keyReadAcquired, "Key read should be blocked")
|
||||
assertFalse(keyWriteAcquired, "Key write should be blocked")
|
||||
|
||||
realWithTimeout(1.seconds) {
|
||||
locker.acquireRead()
|
||||
}
|
||||
assertEquals(locker.readSemaphore().maxPermits - 1, locker.readSemaphore().freePermits)
|
||||
assertTrue { locker.releaseRead() }
|
||||
assertEquals(locker.readSemaphore().maxPermits, locker.readSemaphore().freePermits)
|
||||
locker.unlockWrite()
|
||||
jobs.joinAll()
|
||||
|
||||
assertTrue(globalReadAcquired)
|
||||
assertTrue(keyReadAcquired)
|
||||
assertTrue(keyWriteAcquired)
|
||||
}
|
||||
|
||||
@Test
|
||||
fun writeLockFailedOnWriteLockKeyTest() = runTest {
|
||||
val locker = SmartKeyRWLocker<String>()
|
||||
val testKey = "test"
|
||||
locker.lockWrite(testKey)
|
||||
fun testGlobalWriteIsExclusive() = runTest {
|
||||
locker.lockWrite()
|
||||
|
||||
assertTrue { locker.isWriteLocked(testKey) }
|
||||
|
||||
assertFails {
|
||||
realWithTimeout(1.seconds) {
|
||||
locker.lockWrite()
|
||||
}
|
||||
}
|
||||
assertFalse(locker.isWriteLocked())
|
||||
|
||||
locker.unlockWrite(testKey)
|
||||
assertFalse { locker.isWriteLocked(testKey) }
|
||||
|
||||
realWithTimeout(1.seconds) {
|
||||
var secondWriteAcquired = false
|
||||
val job = launch {
|
||||
locker.lockWrite()
|
||||
secondWriteAcquired = true
|
||||
locker.unlockWrite()
|
||||
}
|
||||
assertTrue(locker.isWriteLocked())
|
||||
assertTrue { locker.unlockWrite() }
|
||||
assertFalse(locker.isWriteLocked())
|
||||
|
||||
delay(200.milliseconds)
|
||||
assertFalse(secondWriteAcquired, "Second global write should be blocked")
|
||||
|
||||
locker.unlockWrite()
|
||||
job.join()
|
||||
|
||||
assertTrue(secondWriteAcquired)
|
||||
}
|
||||
|
||||
// ==================== Key Read Tests ====================
|
||||
|
||||
@Test
|
||||
fun readsBlockingGlobalWrite() = runTest {
|
||||
val locker = SmartKeyRWLocker<String>()
|
||||
fun testKeyReadAllowsMultipleConcurrentReadsForSameKey() = runTest {
|
||||
val key = "testKey"
|
||||
val results = mutableListOf<Boolean>()
|
||||
|
||||
val testKeys = (0 until 100).map { "test$it" }
|
||||
locker.acquireRead(key)
|
||||
|
||||
for (i in testKeys.indices) {
|
||||
val it = testKeys[i]
|
||||
locker.acquireRead(it)
|
||||
val previous = testKeys.take(i)
|
||||
val next = testKeys.drop(i + 1)
|
||||
|
||||
previous.forEach {
|
||||
assertTrue { locker.readSemaphoreOrNull(it) ?.freePermits == Int.MAX_VALUE - 1 }
|
||||
}
|
||||
next.forEach {
|
||||
assertTrue { locker.readSemaphoreOrNull(it) ?.freePermits == null }
|
||||
val jobs = List(5) {
|
||||
launch {
|
||||
locker.acquireRead(key)
|
||||
delay(50.milliseconds)
|
||||
results.add(true)
|
||||
locker.releaseRead(key)
|
||||
}
|
||||
}
|
||||
|
||||
for (i in testKeys.indices) {
|
||||
val it = testKeys[i]
|
||||
assertFails {
|
||||
realWithTimeout(13.milliseconds) { locker.lockWrite() }
|
||||
jobs.joinAll()
|
||||
locker.releaseRead(key)
|
||||
|
||||
assertEquals(5, results.size)
|
||||
}
|
||||
|
||||
@Test
|
||||
fun testKeyReadAllowsReadsForDifferentKeys() = runTest {
|
||||
val results = mutableMapOf<String, Boolean>()
|
||||
|
||||
locker.acquireRead("key1")
|
||||
|
||||
val jobs = listOf("key2", "key3", "key4").map { key ->
|
||||
launch {
|
||||
locker.acquireRead(key)
|
||||
delay(50.milliseconds)
|
||||
results[key] = true
|
||||
locker.releaseRead(key)
|
||||
}
|
||||
val readPermitsBeforeLock = locker.readSemaphore().freePermits
|
||||
realWithTimeout(1.seconds) { locker.acquireRead() }
|
||||
}
|
||||
|
||||
jobs.joinAll()
|
||||
locker.releaseRead("key1")
|
||||
|
||||
assertEquals(3, results.size)
|
||||
}
|
||||
|
||||
@Test
|
||||
fun testKeyReadBlocksWriteForSameKey() = runTest {
|
||||
val key = "testKey"
|
||||
locker.acquireRead(key)
|
||||
|
||||
var writeAcquired = false
|
||||
val job = launch {
|
||||
locker.lockWrite(key)
|
||||
writeAcquired = true
|
||||
locker.unlockWrite(key)
|
||||
}
|
||||
|
||||
delay(200.milliseconds)
|
||||
assertFalse(writeAcquired, "Write for same key should be blocked")
|
||||
|
||||
locker.releaseRead(key)
|
||||
job.join()
|
||||
|
||||
assertTrue(writeAcquired)
|
||||
}
|
||||
|
||||
@Test
|
||||
fun testKeyReadBlocksGlobalWrite() = runTest {
|
||||
locker.acquireRead("key1")
|
||||
|
||||
var globalWriteAcquired = false
|
||||
val job = launch {
|
||||
locker.lockWrite()
|
||||
globalWriteAcquired = true
|
||||
locker.unlockWrite()
|
||||
}
|
||||
|
||||
delay(200.milliseconds)
|
||||
assertFalse(globalWriteAcquired, "Global write should be blocked by key read")
|
||||
|
||||
locker.releaseRead("key1")
|
||||
job.join()
|
||||
|
||||
assertTrue(globalWriteAcquired)
|
||||
}
|
||||
|
||||
@Test
|
||||
fun testKeyReadAllowsWriteForDifferentKey() = runTest {
|
||||
locker.acquireRead("key1")
|
||||
|
||||
var writeAcquired = false
|
||||
val job = launch {
|
||||
locker.lockWrite("key2")
|
||||
writeAcquired = true
|
||||
locker.unlockWrite("key2")
|
||||
}
|
||||
|
||||
job.join()
|
||||
assertTrue(writeAcquired, "Write for different key should succeed")
|
||||
|
||||
locker.releaseRead("key1")
|
||||
}
|
||||
|
||||
// ==================== Key Write Tests ====================
|
||||
|
||||
@Test
|
||||
fun testKeyWriteBlocksReadForSameKey() = runTest {
|
||||
val key = "testKey"
|
||||
locker.lockWrite(key)
|
||||
|
||||
var readAcquired = false
|
||||
val job = launch {
|
||||
locker.acquireRead(key)
|
||||
readAcquired = true
|
||||
locker.releaseRead(key)
|
||||
}
|
||||
|
||||
delay(200.milliseconds)
|
||||
assertFalse(readAcquired, "Read for same key should be blocked")
|
||||
|
||||
locker.unlockWrite(key)
|
||||
job.join()
|
||||
|
||||
assertTrue(readAcquired)
|
||||
}
|
||||
|
||||
@Test
|
||||
fun testKeyWriteBlocksGlobalRead() = runTest {
|
||||
locker.lockWrite("key1")
|
||||
|
||||
var globalReadAcquired = false
|
||||
val job = launch {
|
||||
locker.acquireRead()
|
||||
globalReadAcquired = true
|
||||
locker.releaseRead()
|
||||
assertEquals(readPermitsBeforeLock, locker.readSemaphore().freePermits)
|
||||
|
||||
locker.releaseRead(it)
|
||||
}
|
||||
|
||||
assertTrue { locker.readSemaphore().freePermits == Int.MAX_VALUE }
|
||||
realWithTimeout(1.seconds) { locker.lockWrite() }
|
||||
assertFails {
|
||||
realWithTimeout(13.milliseconds) { locker.acquireRead() }
|
||||
}
|
||||
assertTrue { locker.unlockWrite() }
|
||||
assertTrue { locker.readSemaphore().freePermits == Int.MAX_VALUE }
|
||||
delay(200.milliseconds)
|
||||
assertFalse(globalReadAcquired, "Global read should be blocked by key write")
|
||||
|
||||
locker.unlockWrite("key1")
|
||||
job.join()
|
||||
|
||||
assertTrue(globalReadAcquired)
|
||||
}
|
||||
|
||||
@Test
|
||||
fun writesBlockingGlobalWrite() = runTest {
|
||||
val locker = SmartKeyRWLocker<String>()
|
||||
fun testKeyWriteIsExclusiveForSameKey() = runTest {
|
||||
val key = "testKey"
|
||||
locker.lockWrite(key)
|
||||
|
||||
val testKeys = (0 until 100).map { "test$it" }
|
||||
var secondWriteAcquired = false
|
||||
val job = launch {
|
||||
locker.lockWrite(key)
|
||||
secondWriteAcquired = true
|
||||
locker.unlockWrite(key)
|
||||
}
|
||||
|
||||
for (i in testKeys.indices) {
|
||||
val it = testKeys[i]
|
||||
locker.lockWrite(it)
|
||||
val previous = testKeys.take(i)
|
||||
val next = testKeys.drop(i + 1)
|
||||
delay(200.milliseconds)
|
||||
assertFalse(secondWriteAcquired, "Second write for same key should be blocked")
|
||||
|
||||
previous.forEach {
|
||||
assertTrue { locker.writeMutexOrNull(it) ?.isLocked == true }
|
||||
locker.unlockWrite(key)
|
||||
job.join()
|
||||
|
||||
assertTrue(secondWriteAcquired)
|
||||
}
|
||||
|
||||
@Test
|
||||
fun testKeyWriteAllowsOperationsOnDifferentKeys() = runTest {
|
||||
locker.lockWrite("key1")
|
||||
|
||||
val results = mutableMapOf<String, Boolean>()
|
||||
|
||||
val jobs = listOf(
|
||||
launch {
|
||||
locker.acquireRead("key2")
|
||||
results["read-key2"] = true
|
||||
locker.releaseRead("key2")
|
||||
},
|
||||
launch {
|
||||
locker.lockWrite("key3")
|
||||
results["write-key3"] = true
|
||||
locker.unlockWrite("key3")
|
||||
}
|
||||
next.forEach {
|
||||
assertTrue { locker.writeMutexOrNull(it) ?.isLocked != true }
|
||||
)
|
||||
|
||||
jobs.joinAll()
|
||||
assertEquals(2, results.size, "Operations on different keys should succeed")
|
||||
|
||||
locker.unlockWrite("key1")
|
||||
}
|
||||
|
||||
// ==================== Complex Scenarios ====================
|
||||
|
||||
@Test
|
||||
fun testMultipleReadersThenWriter() = runTest {
|
||||
val key = "testKey"
|
||||
val readCount = 5
|
||||
val readers = mutableListOf<Job>()
|
||||
|
||||
repeat(readCount) {
|
||||
readers.add(launch {
|
||||
locker.acquireRead(key)
|
||||
delay(100.milliseconds)
|
||||
locker.releaseRead(key)
|
||||
})
|
||||
}
|
||||
|
||||
delay(50.milliseconds) // Let readers acquire
|
||||
|
||||
var writerExecuted = false
|
||||
val writer = launch {
|
||||
locker.lockWrite(key)
|
||||
writerExecuted = true
|
||||
locker.unlockWrite(key)
|
||||
}
|
||||
|
||||
delay(50.milliseconds)
|
||||
assertFalse(writerExecuted, "Writer should wait for all readers")
|
||||
|
||||
readers.joinAll()
|
||||
writer.join()
|
||||
|
||||
assertTrue(writerExecuted, "Writer should execute after all readers done")
|
||||
}
|
||||
|
||||
@Test
|
||||
fun testWriterThenMultipleReaders() = runTest {
|
||||
val key = "testKey"
|
||||
|
||||
locker.lockWrite(key)
|
||||
|
||||
val readerFlags = mutableListOf<Boolean>()
|
||||
val readers = List(5) {
|
||||
launch {
|
||||
locker.acquireRead(key)
|
||||
readerFlags.add(true)
|
||||
locker.releaseRead(key)
|
||||
}
|
||||
}
|
||||
|
||||
for (i in testKeys.indices) {
|
||||
val it = testKeys[i]
|
||||
assertFails { realWithTimeout(13.milliseconds) { locker.lockWrite() } }
|
||||
delay(200.milliseconds)
|
||||
assertTrue(readerFlags.isEmpty(), "Readers should be blocked by writer")
|
||||
|
||||
val readPermitsBeforeLock = locker.readSemaphore().freePermits
|
||||
assertFails { realWithTimeout(13.milliseconds) { locker.acquireRead() } }
|
||||
assertEquals(readPermitsBeforeLock, locker.readSemaphore().freePermits)
|
||||
locker.unlockWrite(key)
|
||||
readers.joinAll()
|
||||
|
||||
locker.unlockWrite(it)
|
||||
assertEquals(5, readerFlags.size, "All readers should succeed after writer")
|
||||
}
|
||||
|
||||
@Test
|
||||
fun testCascadingLocksWithDifferentKeys() = runTest {
|
||||
val executed = mutableMapOf<String, Boolean>()
|
||||
|
||||
launch {
|
||||
locker.lockWrite("key1")
|
||||
executed["write-key1-start"] = true
|
||||
delay(100.milliseconds)
|
||||
locker.unlockWrite("key1")
|
||||
executed["write-key1-end"] = true
|
||||
}
|
||||
|
||||
assertTrue { locker.readSemaphore().freePermits == Int.MAX_VALUE }
|
||||
realWithTimeout(1.seconds) { locker.lockWrite() }
|
||||
assertFails {
|
||||
realWithTimeout(13.milliseconds) { locker.acquireRead() }
|
||||
delay(50.milliseconds)
|
||||
|
||||
launch {
|
||||
locker.acquireRead("key2")
|
||||
executed["read-key2"] = true
|
||||
delay(100.milliseconds)
|
||||
locker.releaseRead("key2")
|
||||
}
|
||||
assertTrue { locker.unlockWrite() }
|
||||
assertTrue { locker.readSemaphore().freePermits == Int.MAX_VALUE }
|
||||
|
||||
delay(200.milliseconds)
|
||||
|
||||
assertTrue(executed["write-key1-start"] == true)
|
||||
assertTrue(executed["read-key2"] == true)
|
||||
assertTrue(executed["write-key1-end"] == true)
|
||||
}
|
||||
|
||||
@Test
|
||||
fun testReleaseWithoutAcquireReturnsFalse() = runTest {
|
||||
assertFalse(locker.releaseRead(), "Release without acquire should return false")
|
||||
assertFalse(locker.releaseRead("key1"), "Release without acquire should return false")
|
||||
}
|
||||
|
||||
@Test
|
||||
fun testUnlockWithoutLockReturnsFalse() = runTest {
|
||||
assertFalse(locker.unlockWrite(), "Unlock without lock should return false")
|
||||
assertFalse(locker.unlockWrite("key1"), "Unlock without lock should return false")
|
||||
}
|
||||
|
||||
@Test
|
||||
fun testProperReleaseReturnsTrue() = runTest {
|
||||
locker.acquireRead()
|
||||
assertTrue(locker.releaseRead(), "Release after acquire should return true")
|
||||
|
||||
locker.acquireRead("key1")
|
||||
assertTrue(locker.releaseRead("key1"), "Release after acquire should return true")
|
||||
}
|
||||
|
||||
@Test
|
||||
fun testProperUnlockReturnsTrue() = runTest {
|
||||
locker.lockWrite()
|
||||
assertTrue(locker.unlockWrite(), "Unlock after lock should return true")
|
||||
|
||||
locker.lockWrite("key1")
|
||||
assertTrue(locker.unlockWrite("key1"), "Unlock after lock should return true")
|
||||
}
|
||||
|
||||
// ==================== Stress Tests ====================
|
||||
|
||||
@Test
|
||||
fun stressTestWithMixedOperations() = runTest(timeout = 10.seconds) {
|
||||
val operations = 100
|
||||
val keys = listOf("key1", "key2", "key3", "key4", "key5")
|
||||
val jobs = mutableListOf<Job>()
|
||||
|
||||
repeat(operations) { i ->
|
||||
val key = keys[i % keys.size]
|
||||
|
||||
when (i % 4) {
|
||||
0 -> jobs.add(launch {
|
||||
locker.acquireRead(key)
|
||||
delay(10.milliseconds)
|
||||
locker.releaseRead(key)
|
||||
})
|
||||
1 -> jobs.add(launch {
|
||||
locker.lockWrite(key)
|
||||
delay(10.milliseconds)
|
||||
locker.unlockWrite(key)
|
||||
})
|
||||
2 -> jobs.add(launch {
|
||||
locker.acquireRead()
|
||||
delay(10.milliseconds)
|
||||
locker.releaseRead()
|
||||
})
|
||||
3 -> jobs.add(launch {
|
||||
locker.lockWrite()
|
||||
delay(10.milliseconds)
|
||||
locker.unlockWrite()
|
||||
})
|
||||
}
|
||||
}
|
||||
|
||||
jobs.joinAll()
|
||||
// If we reach here without deadlock or exceptions, test passes
|
||||
}
|
||||
|
||||
@Test
|
||||
fun testFairnessReadersDontStarveWriters() = runTest(timeout = 5.seconds) {
|
||||
val key = "testKey"
|
||||
var writerExecuted = false
|
||||
|
||||
// Start continuous readers
|
||||
val readers = List(10) {
|
||||
launch {
|
||||
repeat(5) {
|
||||
locker.acquireRead(key)
|
||||
delay(50.milliseconds)
|
||||
locker.releaseRead(key)
|
||||
delay(10.milliseconds)
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
delay(100.milliseconds)
|
||||
|
||||
// Try to acquire write lock
|
||||
val writer = launch {
|
||||
locker.lockWrite(key)
|
||||
writerExecuted = true
|
||||
locker.unlockWrite(key)
|
||||
}
|
||||
|
||||
readers.joinAll()
|
||||
writer.join()
|
||||
|
||||
assertTrue(writerExecuted, "Writer should eventually execute")
|
||||
}
|
||||
}
|
||||
|
||||
@@ -1,33 +1,31 @@
|
||||
import dev.inmo.micro_utils.coroutines.SpecialMutableStateFlow
|
||||
import dev.inmo.micro_utils.coroutines.asDeferred
|
||||
import dev.inmo.micro_utils.coroutines.MutableRedeliverStateFlow
|
||||
import dev.inmo.micro_utils.coroutines.subscribe
|
||||
import kotlinx.coroutines.Job
|
||||
import kotlinx.coroutines.flow.first
|
||||
import kotlinx.coroutines.test.runTest
|
||||
import kotlin.test.Test
|
||||
import kotlin.test.assertEquals
|
||||
import kotlin.test.assertTrue
|
||||
|
||||
class SpecialMutableStateFlowTests {
|
||||
@Test
|
||||
fun simpleTest() = runTest {
|
||||
val specialMutableStateFlow = SpecialMutableStateFlow(0)
|
||||
specialMutableStateFlow.value = 1
|
||||
specialMutableStateFlow.first { it == 1 }
|
||||
assertEquals(1, specialMutableStateFlow.value)
|
||||
val mutableRedeliverStateFlow = MutableRedeliverStateFlow(0)
|
||||
mutableRedeliverStateFlow.value = 1
|
||||
mutableRedeliverStateFlow.first { it == 1 }
|
||||
assertEquals(1, mutableRedeliverStateFlow.value)
|
||||
}
|
||||
@Test
|
||||
fun specialTest() = runTest {
|
||||
val specialMutableStateFlow = SpecialMutableStateFlow(0)
|
||||
val mutableRedeliverStateFlow = MutableRedeliverStateFlow(0)
|
||||
lateinit var subscriberJob: Job
|
||||
subscriberJob = specialMutableStateFlow.subscribe(this) {
|
||||
subscriberJob = mutableRedeliverStateFlow.subscribe(this) {
|
||||
when (it) {
|
||||
1 -> specialMutableStateFlow.value = 2
|
||||
1 -> mutableRedeliverStateFlow.value = 2
|
||||
2 -> subscriberJob.cancel()
|
||||
}
|
||||
}
|
||||
specialMutableStateFlow.value = 1
|
||||
mutableRedeliverStateFlow.value = 1
|
||||
subscriberJob.join()
|
||||
assertEquals(2, specialMutableStateFlow.value)
|
||||
assertEquals(2, mutableRedeliverStateFlow.value)
|
||||
}
|
||||
}
|
||||
@@ -18,5 +18,5 @@ crypto_js_version=4.1.1
|
||||
# Project data
|
||||
|
||||
group=dev.inmo
|
||||
version=0.26.1
|
||||
android_code_version=300
|
||||
version=0.26.7
|
||||
android_code_version=306
|
||||
|
||||
@@ -1,45 +1,46 @@
|
||||
[versions]
|
||||
|
||||
kt = "2.2.0"
|
||||
kt = "2.2.20"
|
||||
kt-serialization = "1.9.0"
|
||||
kt-coroutines = "1.10.2"
|
||||
|
||||
kotlinx-browser = "0.3"
|
||||
kotlinx-browser = "0.5.0"
|
||||
|
||||
kslog = "1.5.0"
|
||||
kslog = "1.5.1"
|
||||
|
||||
jb-compose = "1.8.2"
|
||||
jb-exposed = "0.61.0"
|
||||
jb-dokka = "2.0.0"
|
||||
jb-dokka = "2.1.0"
|
||||
|
||||
# 3.50.3.0 contains bug https://github.com/InsanusMokrassar/MicroUtils/actions/runs/18138301958/job/51629588088
|
||||
sqlite = "3.50.1.0"
|
||||
|
||||
korlibs = "5.4.0"
|
||||
uuid = "0.8.4"
|
||||
|
||||
ktor = "3.2.2"
|
||||
ktor = "3.3.1"
|
||||
|
||||
gh-release = "2.5.2"
|
||||
|
||||
koin = "4.1.0"
|
||||
koin = "4.1.1"
|
||||
|
||||
okio = "3.15.0"
|
||||
okio = "3.16.2"
|
||||
|
||||
ksp = "2.2.0-2.0.2"
|
||||
ksp = "2.2.20-2.0.3"
|
||||
kotlin-poet = "2.2.0"
|
||||
|
||||
versions = "0.52.0"
|
||||
nmcp = "1.0.1"
|
||||
nmcp = "1.1.0"
|
||||
|
||||
android-gradle = "8.9.+"
|
||||
android-gradle = "8.10.+"
|
||||
dexcount = "4.0.0"
|
||||
|
||||
android-coreKtx = "1.16.0"
|
||||
android-coreKtx = "1.17.0"
|
||||
android-recyclerView = "1.4.0"
|
||||
android-appCompat = "1.7.1"
|
||||
android-fragment = "1.8.8"
|
||||
android-espresso = "3.6.1"
|
||||
android-test = "1.2.1"
|
||||
android-fragment = "1.8.9"
|
||||
android-espresso = "3.7.0"
|
||||
android-test = "1.3.0"
|
||||
|
||||
android-props-minSdk = "21"
|
||||
android-props-compileSdk = "36"
|
||||
|
||||
2
gradle/wrapper/gradle-wrapper.properties
vendored
2
gradle/wrapper/gradle-wrapper.properties
vendored
@@ -1,5 +1,5 @@
|
||||
distributionBase=GRADLE_USER_HOME
|
||||
distributionPath=wrapper/dists
|
||||
distributionUrl=https\://services.gradle.org/distributions/gradle-8.13-bin.zip
|
||||
distributionUrl=https\://services.gradle.org/distributions/gradle-8.14.3-bin.zip
|
||||
zipStoreBase=GRADLE_USER_HOME
|
||||
zipStorePath=wrapper/dists
|
||||
|
||||
@@ -1,9 +1,8 @@
|
||||
package dev.inmo.micro_utils.pagination.compose
|
||||
|
||||
import androidx.compose.runtime.*
|
||||
import dev.inmo.micro_utils.coroutines.SpecialMutableStateFlow
|
||||
import dev.inmo.micro_utils.coroutines.MutableRedeliverStateFlow
|
||||
import dev.inmo.micro_utils.coroutines.launchLoggingDropExceptions
|
||||
import dev.inmo.micro_utils.coroutines.runCatchingLogging
|
||||
import dev.inmo.micro_utils.pagination.*
|
||||
import kotlinx.coroutines.CoroutineScope
|
||||
import kotlinx.coroutines.Job
|
||||
@@ -27,8 +26,8 @@ class InfinityPagedComponentContext<T> internal constructor(
|
||||
private val loader: suspend InfinityPagedComponentContext<T>.(Pagination) -> PaginationResult<T>
|
||||
) {
|
||||
internal val startPage = SimplePagination(page, size)
|
||||
internal val latestLoadedPage = SpecialMutableStateFlow<PaginationResult<T>?>(null)
|
||||
internal val dataState = SpecialMutableStateFlow<List<T>?>(null)
|
||||
internal val latestLoadedPage = MutableRedeliverStateFlow<PaginationResult<T>?>(null)
|
||||
internal val dataState = MutableRedeliverStateFlow<List<T>?>(null)
|
||||
internal var loadingJob: Job? = null
|
||||
internal val loadingMutex = Mutex()
|
||||
|
||||
|
||||
@@ -1,7 +1,7 @@
|
||||
package dev.inmo.micro_utils.pagination.compose
|
||||
|
||||
import androidx.compose.runtime.*
|
||||
import dev.inmo.micro_utils.coroutines.SpecialMutableStateFlow
|
||||
import dev.inmo.micro_utils.coroutines.MutableRedeliverStateFlow
|
||||
import dev.inmo.micro_utils.coroutines.launchLoggingDropExceptions
|
||||
import dev.inmo.micro_utils.pagination.*
|
||||
import kotlinx.coroutines.CoroutineScope
|
||||
@@ -28,8 +28,8 @@ class PagedComponentContext<T> internal constructor(
|
||||
private val loader: suspend PagedComponentContext<T>.(Pagination) -> PaginationResult<T>
|
||||
) {
|
||||
internal val startPage = SimplePagination(initialPage, size)
|
||||
internal val latestLoadedPage = SpecialMutableStateFlow<PaginationResult<T>?>(null)
|
||||
internal val dataState = SpecialMutableStateFlow<PaginationResult<T>?>(null)
|
||||
internal val latestLoadedPage = MutableRedeliverStateFlow<PaginationResult<T>?>(null)
|
||||
internal val dataState = MutableRedeliverStateFlow<PaginationResult<T>?>(null)
|
||||
internal var loadingJob: Job? = null
|
||||
internal val loadingMutex = Mutex()
|
||||
|
||||
|
||||
@@ -1,10 +1,81 @@
|
||||
package dev.inmo.micro_utils.repos.exposed
|
||||
|
||||
import org.jetbrains.exposed.sql.*
|
||||
import org.jetbrains.exposed.sql.SchemaUtils.addMissingColumnsStatements
|
||||
import org.jetbrains.exposed.sql.SchemaUtils.checkMappingConsistence
|
||||
import org.jetbrains.exposed.sql.SchemaUtils.createStatements
|
||||
import org.jetbrains.exposed.sql.transactions.TransactionManager
|
||||
import org.jetbrains.exposed.sql.transactions.transaction
|
||||
|
||||
/**
|
||||
* Code in this function mostly duplicates Exposed [SchemaUtils.createMissingTablesAndColumns]. It made due to deprecation
|
||||
* status of the last one and potential lost of it in future updates.
|
||||
*
|
||||
* Code doing:
|
||||
*
|
||||
* * Creating missed tables
|
||||
* * Altering missed tables (where possible)
|
||||
* * Calculate problems with [checkMappingConsistence] and add them in execution too
|
||||
*
|
||||
* All changes made in [transaction] with [database] as its `db` argument
|
||||
*/
|
||||
fun initTablesInTransaction(vararg tables: Table, database: Database, inBatch: Boolean = false, withLogs: Boolean = true) {
|
||||
transaction(database) {
|
||||
fun <R> logTimeSpent(message: String, withLogs: Boolean, block: () -> R): R {
|
||||
return if (withLogs) {
|
||||
val start = System.currentTimeMillis()
|
||||
val answer = block()
|
||||
exposedLogger.info(message + " took " + (System.currentTimeMillis() - start) + "ms")
|
||||
answer
|
||||
} else {
|
||||
block()
|
||||
}
|
||||
}
|
||||
fun Transaction.execStatements(inBatch: Boolean, statements: List<String>) {
|
||||
if (inBatch) {
|
||||
execInBatch(statements)
|
||||
} else {
|
||||
for (statement in statements) {
|
||||
exec(statement)
|
||||
}
|
||||
}
|
||||
}
|
||||
with(TransactionManager.current()) {
|
||||
db.dialect.resetCaches()
|
||||
val createStatements = logTimeSpent("Preparing create tables statements", withLogs) {
|
||||
createStatements(*tables)
|
||||
}
|
||||
logTimeSpent("Executing create tables statements", withLogs) {
|
||||
execStatements(inBatch, createStatements)
|
||||
commit()
|
||||
}
|
||||
|
||||
val alterStatements = logTimeSpent("Preparing alter table statements", withLogs) {
|
||||
addMissingColumnsStatements(tables = tables, withLogs)
|
||||
}
|
||||
logTimeSpent("Executing alter table statements", withLogs) {
|
||||
execStatements(inBatch, alterStatements)
|
||||
commit()
|
||||
}
|
||||
val executedStatements = createStatements + alterStatements
|
||||
logTimeSpent("Checking mapping consistence", withLogs) {
|
||||
val modifyTablesStatements = checkMappingConsistence(
|
||||
tables = tables,
|
||||
withLogs
|
||||
).filter { it !in executedStatements }
|
||||
execStatements(inBatch, modifyTablesStatements)
|
||||
commit()
|
||||
}
|
||||
db.dialect.resetCaches()
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
fun Table.initTable(database: Database, inBatch: Boolean, withLogs: Boolean) {
|
||||
initTablesInTransaction(this, database = database, inBatch = inBatch, withLogs = withLogs)
|
||||
}
|
||||
fun Table.initTable(database: Database) {
|
||||
transaction(database) { SchemaUtils.createMissingTablesAndColumns(this@initTable) }
|
||||
initTable(database = database, inBatch = false, withLogs = true)
|
||||
}
|
||||
|
||||
fun <T> T.initTable() where T: ExposedRepo, T: Table = initTable(database)
|
||||
|
||||
Reference in New Issue
Block a user