Compare commits

...

29 Commits

Author SHA1 Message Date
0065f94f52 update dependencies 2024-02-26 16:55:18 +06:00
ccc0002eb2 improve of actualize all 2024-02-21 00:05:57 +06:00
15a2eee141 start 0.20.36 2024-02-20 22:52:02 +06:00
b9faac71e5 Merge pull request #394 from InsanusMokrassar/0.20.35
0.20.35
2024-02-16 19:11:27 +06:00
0a4465de33 remove API dumps 2024-02-16 19:09:55 +06:00
f9dfd09628 update dependencies 2024-02-16 19:01:46 +06:00
8638d7afce start 0.20.35 2024-02-16 18:50:35 +06:00
8311793a43 Merge pull request #392 from InsanusMokrassar/0.20.34
0.20.34
2024-02-15 16:32:41 +06:00
0d552cfcd2 fix build 2024-02-15 16:18:31 +06:00
4b0f20dbd1 improve default 'set' of KeyValuesRepo 2024-02-15 15:36:32 +06:00
cf531c949d start 0.20.34 2024-02-15 15:14:38 +06:00
ba5c5f17d5 Merge pull request #391 from InsanusMokrassar/0.20.33
0.20.33
2024-02-12 14:42:31 +06:00
35825ad9b7 improve HEXAColorTests 2024-02-12 14:41:55 +06:00
b1eb26a89e fixes and testsAdditions in HEXAColor 2024-02-12 14:25:45 +06:00
c9d04b6698 add ahex to color 2024-02-12 13:58:06 +06:00
496133e014 start 0.20.33 2024-02-12 13:32:30 +06:00
f2857ee2be Merge pull request #388 from InsanusMokrassar/0.20.32
0.20.32
2024-02-10 17:14:04 +06:00
22541f2d5e Update CHANGELOG.md 2024-02-10 15:40:59 +06:00
e235c52b6c Update libs.versions.toml 2024-02-10 15:39:48 +06:00
e89b8c72dd Update gradle-wrapper.properties 2024-02-08 10:40:43 +06:00
a374e53a3a update StringResource 2024-02-06 19:56:44 +06:00
afb066c4ee start 0.20.32 2024-02-06 19:55:34 +06:00
f05761d4a5 Merge pull request #386 from InsanusMokrassar/0.20.31
0.20.31
2024-01-31 18:10:53 +06:00
76adc9ea33 update ktor 2024-01-31 17:37:27 +06:00
99dd291413 start 0.20.31 2024-01-31 17:36:30 +06:00
f904eb27e1 Merge pull request #384 from InsanusMokrassar/0.20.30
0.20.30
2024-01-31 17:27:17 +06:00
eeb8214812 update exposed 2024-01-31 17:05:43 +06:00
f7215b039e start 0.20.30 2024-01-31 17:04:38 +06:00
c07fe5a0f9 Merge pull request #382 from InsanusMokrassar/0.20.29
0.20.29
2024-01-30 23:03:30 +06:00
18 changed files with 376 additions and 86 deletions

View File

@@ -1,5 +1,51 @@
# Changelog # Changelog
## 0.20.36
* `Versions`:
* `Serialization`: `1.6.2` -> `1.6.3`
* `Korlibs`: `5.3.1` -> `5.3.2`
* `Repos`:
* `Cache`:
* Improve work and functionality of `actualizeAll` and subsequent functions
* All internal repos `invalidate`/`actualizeAll` now use common `actualizeAll` functions
## 0.20.35
* `Versions`:
* `Coroutines`: `1.7.3` -> `1.8.0`
* `Material3`: `1.1.2` -> `1.2.0`
## 0.20.34
* `Repos`:
* `Common`:
* Improve default `set` realization of `KeyValuesRepo`
## 0.20.33
* `Colors`
* `Common`:
* Add opportunity to use `HEXAColor` with `ahex` colors
## 0.20.32
* `Versions`:
* `Okio`: `3.7.0` -> `3.8.0`
* `Resources`:
* Make `StringResource` serializable
* Add several variants of builder usages
## 0.20.31
* `Versions`:
* `Ktor`: `2.3.7` -> `2.3.8`
## 0.20.30
* `Versions`:
* `Exposed`: `0.46.0` -> `0.47.0`
## 0.20.29 ## 0.20.29
* `Versions`: * `Versions`:

View File

@@ -12,16 +12,30 @@ import kotlin.math.floor
* * Red (0.5 capacity): `0xff000088u` * * Red (0.5 capacity): `0xff000088u`
* *
* Anyway it is recommended to use * Anyway it is recommended to use
*
* @param hexaUInt rgba [UInt] in format `0xFFEEBBAA` where FF - red, EE - green, BB - blue` and AA - alpha
*/ */
@Serializable @Serializable
@JvmInline @JvmInline
value class HEXAColor ( value class HEXAColor (
val uint: UInt val hexaUInt: UInt
) : Comparable<HEXAColor> { ) : Comparable<HEXAColor> {
/**
* @returns [hexaUInt] as a string with format `#FFEEBBAA` where FF - red, EE - green, BB - blue and AA - alpha
*/
val hexa: String val hexa: String
get() = "#${uint.toString(16).padStart(8, '0')}" get() = "#${hexaUInt.toString(16).padStart(8, '0')}"
/**
* @returns [hexaUInt] as a string with format `#FFEEBB` where FF - red, EE - green and BB - blue
*/
val hex: String val hex: String
get() = hexa.take(7) get() = hexa.take(7)
/**
* @returns [hexaUInt] as a string with format `#AAFFEEBB` where AA - alpha, FF - red, EE - green and BB - blue
*/
val ahex: String
get() = "#${a.toString(16).padStart(2, '2')}${hex.drop(1)}"
val rgba: String val rgba: String
get() = "rgba($r,$g,$b,${aOfOne.toString().take(5)})" get() = "rgba($r,$g,$b,${aOfOne.toString().take(5)})"
val rgb: String val rgb: String
@@ -30,21 +44,25 @@ value class HEXAColor (
get() = "#${r.shortPart()}${g.shortPart()}${b.shortPart()}" get() = "#${r.shortPart()}${g.shortPart()}${b.shortPart()}"
val shortHexa: String val shortHexa: String
get() = "$shortHex${a.shortPart()}" get() = "$shortHex${a.shortPart()}"
val rgbUInt: UInt
get() = (hexaUInt / 256u)
val rgbInt: Int val rgbInt: Int
get() = (uint shr 2).toInt() get() = rgbUInt.toInt()
val ahexUInt
get() = (a * 0x1000000).toUInt() + rgbUInt
val r: Int val r: Int
get() = ((uint and 0xff000000u) / 0x1000000u).toInt() get() = ((hexaUInt and 0xff000000u) / 0x1000000u).toInt()
val g: Int val g: Int
get() = ((uint and 0x00ff0000u) / 0x10000u).toInt() get() = ((hexaUInt and 0x00ff0000u) / 0x10000u).toInt()
val b: Int val b: Int
get() = ((uint and 0x0000ff00u) / 0x100u).toInt() get() = ((hexaUInt and 0x0000ff00u) / 0x100u).toInt()
val a: Int val a: Int
get() = ((uint and 0x000000ffu)).toInt() get() = ((hexaUInt and 0x000000ffu)).toInt()
val aOfOne: Float val aOfOne: Float
get() = a.toFloat() / (0xff) get() = a.toFloat() / (0xff)
init { init {
require(uint in 0u ..0xffffffffu) require(hexaUInt in 0u ..0xffffffffu)
} }
constructor(r: Int, g: Int, b: Int, a: Int) : this( constructor(r: Int, g: Int, b: Int, a: Int) : this(
@@ -64,7 +82,7 @@ value class HEXAColor (
return hexa return hexa
} }
override fun compareTo(other: HEXAColor): Int = (uint - other.uint).coerceIn(Int.MIN_VALUE.toUInt(), Int.MAX_VALUE.toLong().toUInt()).toInt() override fun compareTo(other: HEXAColor): Int = (hexaUInt - other.hexaUInt).coerceIn(Int.MIN_VALUE.toUInt(), Int.MAX_VALUE.toLong().toUInt()).toInt()
fun copy( fun copy(
r: Int = this.r, r: Int = this.r,
@@ -121,6 +139,21 @@ value class HEXAColor (
else -> color else -> color
}.lowercase().toUInt(16).let(::HEXAColor) }.lowercase().toUInt(16).let(::HEXAColor)
/**
* Creates [HEXAColor] from [uint] presume it is in format `0xFFEEBBAA` where FF - red, EE - green, BB - blue` and AA - alpha
*/
fun fromHexa(uint: UInt) = HEXAColor(uint)
/**
* Creates [HEXAColor] from [uint] presume it is in format `0xAAFFEEBB` where AA - alpha, FF - red, EE - green and BB - blue`
*/
fun fromAhex(uint: UInt) = HEXAColor(
a = ((uint and 0xff000000u) / 0x1000000u).toInt(),
r = ((uint and 0x00ff0000u) / 0x10000u).toInt(),
g = ((uint and 0x0000ff00u) / 0x100u).toInt(),
b = ((uint and 0x000000ffu)).toInt()
)
/** /**
* Parsing color from [color] * Parsing color from [color]
* *

View File

@@ -13,6 +13,9 @@ class HexColorTests {
val shortHexa: String, val shortHexa: String,
val hex: String, val hex: String,
val hexa: String, val hexa: String,
val ahex: String,
val ahexUInt: UInt,
val rgbUInt: UInt,
val rgb: String, val rgb: String,
val rgba: String, val rgba: String,
val r: Int, val r: Int,
@@ -24,11 +27,14 @@ class HexColorTests {
val testColors: List<TestColor> val testColors: List<TestColor>
get() = listOf( get() = listOf(
TestColor( TestColor(
color = HEXAColor(uint = 0xff0000ffu), color = HEXAColor(hexaUInt = 0xff0000ffu),
shortHex = "#f00", shortHex = "#f00",
shortHexa = "#f00f", shortHexa = "#f00f",
hex = "#ff0000", hex = "#ff0000",
hexa = "#ff0000ff", hexa = "#ff0000ff",
ahex = "#ffff0000",
ahexUInt = 0xffff0000u,
rgbUInt = 0xff0000u,
rgb = "rgb(255,0,0)", rgb = "rgb(255,0,0)",
rgba = "rgba(255,0,0,1.0)", rgba = "rgba(255,0,0,1.0)",
r = 0xff, r = 0xff,
@@ -38,11 +44,14 @@ class HexColorTests {
"rgba(255,0,0,1)", "rgba(255,0,0,1)",
), ),
TestColor( TestColor(
color = HEXAColor(uint = 0x00ff00ffu), color = HEXAColor(hexaUInt = 0x00ff00ffu),
shortHex = "#0f0", shortHex = "#0f0",
shortHexa = "#0f0f", shortHexa = "#0f0f",
hex = "#00ff00", hex = "#00ff00",
hexa = "#00ff00ff", hexa = "#00ff00ff",
ahex = "#ff00ff00",
ahexUInt = 0xff00ff00u,
rgbUInt = 0x00ff00u,
rgb = "rgb(0,255,0)", rgb = "rgb(0,255,0)",
rgba = "rgba(0,255,0,1.0)", rgba = "rgba(0,255,0,1.0)",
r = 0x00, r = 0x00,
@@ -57,6 +66,9 @@ class HexColorTests {
shortHexa = "#00ff", shortHexa = "#00ff",
hex = "#0000ff", hex = "#0000ff",
hexa = "#0000ffff", hexa = "#0000ffff",
ahex = "#ff0000ff",
ahexUInt = 0xff0000ffu,
rgbUInt = 0x0000ffu,
rgb = "rgb(0,0,255)", rgb = "rgb(0,0,255)",
rgba = "rgba(0,0,255,1.0)", rgba = "rgba(0,0,255,1.0)",
r = 0x00, r = 0x00,
@@ -71,6 +83,9 @@ class HexColorTests {
shortHexa = "#f008", shortHexa = "#f008",
hex = "#ff0000", hex = "#ff0000",
hexa = "#ff000088", hexa = "#ff000088",
ahex = "#88ff0000",
ahexUInt = 0x88ff0000u,
rgbUInt = 0xff0000u,
rgb = "rgb(255,0,0)", rgb = "rgb(255,0,0)",
rgba = "rgba(255,0,0,0.533)", rgba = "rgba(255,0,0,0.533)",
r = 0xff, r = 0xff,
@@ -84,6 +99,9 @@ class HexColorTests {
shortHexa = "#0f08", shortHexa = "#0f08",
hex = "#00ff00", hex = "#00ff00",
hexa = "#00ff0088", hexa = "#00ff0088",
ahex = "#8800ff00",
ahexUInt = 0x8800ff00u,
rgbUInt = 0x00ff00u,
rgb = "rgb(0,255,0)", rgb = "rgb(0,255,0)",
rgba = "rgba(0,255,0,0.533)", rgba = "rgba(0,255,0,0.533)",
r = 0x00, r = 0x00,
@@ -97,6 +115,9 @@ class HexColorTests {
shortHexa = "#00f8", shortHexa = "#00f8",
hex = "#0000ff", hex = "#0000ff",
hexa = "#0000ff88", hexa = "#0000ff88",
ahex = "#880000ff",
ahexUInt = 0x880000ffu,
rgbUInt = 0x0000ffu,
rgb = "rgb(0,0,255)", rgb = "rgb(0,0,255)",
rgba = "rgba(0,0,255,0.533)", rgba = "rgba(0,0,255,0.533)",
r = 0x00, r = 0x00,
@@ -110,6 +131,9 @@ class HexColorTests {
shortHexa = "#f002", shortHexa = "#f002",
hex = "#ff0000", hex = "#ff0000",
hexa = "#ff000022", hexa = "#ff000022",
ahex = "#22ff0000",
ahexUInt = 0x22ff0000u,
rgbUInt = 0xff0000u,
rgb = "rgb(255,0,0)", rgb = "rgb(255,0,0)",
rgba = "rgba(255,0,0,0.133)", rgba = "rgba(255,0,0,0.133)",
r = 0xff, r = 0xff,
@@ -123,6 +147,9 @@ class HexColorTests {
shortHexa = "#0f02", shortHexa = "#0f02",
hex = "#00ff00", hex = "#00ff00",
hexa = "#00ff0022", hexa = "#00ff0022",
ahex = "#2200ff00",
ahexUInt = 0x2200ff00u,
rgbUInt = 0x00ff00u,
rgb = "rgb(0,255,0)", rgb = "rgb(0,255,0)",
rgba = "rgba(0,255,0,0.133)", rgba = "rgba(0,255,0,0.133)",
r = 0x00, r = 0x00,
@@ -136,6 +163,9 @@ class HexColorTests {
shortHexa = "#00f2", shortHexa = "#00f2",
hex = "#0000ff", hex = "#0000ff",
hexa = "#0000ff22", hexa = "#0000ff22",
ahex = "#220000ff",
ahexUInt = 0x220000ffu,
rgbUInt = 0x0000ffu,
rgb = "rgb(0,0,255)", rgb = "rgb(0,0,255)",
rgba = "rgba(0,0,255,0.133)", rgba = "rgba(0,0,255,0.133)",
r = 0x00, r = 0x00,
@@ -150,6 +180,9 @@ class HexColorTests {
testColors.forEach { testColors.forEach {
assertEquals(it.hex, it.color.hex) assertEquals(it.hex, it.color.hex)
assertEquals(it.hexa, it.color.hexa) assertEquals(it.hexa, it.color.hexa)
assertEquals(it.ahex, it.color.ahex)
assertEquals(it.rgbUInt, it.color.rgbUInt)
assertEquals(it.ahexUInt, it.color.ahexUInt)
assertEquals(it.shortHex, it.color.shortHex) assertEquals(it.shortHex, it.color.shortHex)
assertEquals(it.shortHexa, it.color.shortHexa) assertEquals(it.shortHexa, it.color.shortHexa)
assertEquals(it.rgb, it.color.rgb) assertEquals(it.rgb, it.color.rgb)
@@ -158,6 +191,7 @@ class HexColorTests {
assertEquals(it.g, it.color.g) assertEquals(it.g, it.color.g)
assertEquals(it.b, it.color.b) assertEquals(it.b, it.color.b)
assertEquals(it.a, it.color.a) assertEquals(it.a, it.color.a)
assertEquals(it.color, HEXAColor.fromAhex(it.ahexUInt))
} }
} }
@@ -167,7 +201,7 @@ class HexColorTests {
assertEquals(it.color.copy(aOfOne = 1f), HEXAColor.parseStringColor(it.hex)) assertEquals(it.color.copy(aOfOne = 1f), HEXAColor.parseStringColor(it.hex))
assertEquals(it.color, HEXAColor.parseStringColor(it.hexa)) assertEquals(it.color, HEXAColor.parseStringColor(it.hexa))
assertEquals(it.color.copy(aOfOne = 1f), HEXAColor.parseStringColor(it.rgb)) assertEquals(it.color.copy(aOfOne = 1f), HEXAColor.parseStringColor(it.rgb))
assertTrue(it.color.uint.toInt() - HEXAColor.parseStringColor(it.rgba).uint.toInt() in -0x1 .. 0x1, ) assertTrue(it.color.hexaUInt.toInt() - HEXAColor.parseStringColor(it.rgba).hexaUInt.toInt() in -0x1 .. 0x1, )
assertEquals(it.color.copy(aOfOne = 1f), HEXAColor.parseStringColor(it.shortHex)) assertEquals(it.color.copy(aOfOne = 1f), HEXAColor.parseStringColor(it.shortHex))
assertEquals(it.color.copy(a = floor(it.color.a.toFloat() / 16).toInt() * 0x10), HEXAColor.parseStringColor(it.shortHexa)) assertEquals(it.color.copy(a = floor(it.color.a.toFloat() / 16).toInt() * 0x10), HEXAColor.parseStringColor(it.shortHexa))
} }

View File

@@ -15,5 +15,5 @@ crypto_js_version=4.1.1
# Project data # Project data
group=dev.inmo group=dev.inmo
version=0.20.29 version=0.20.36
android_code_version=235 android_code_version=242

View File

@@ -1,25 +1,25 @@
[versions] [versions]
kt = "1.9.22" kt = "1.9.22"
kt-serialization = "1.6.2" kt-serialization = "1.6.3"
kt-coroutines = "1.7.3" kt-coroutines = "1.8.0"
kslog = "1.3.2" kslog = "1.3.2"
jb-compose = "1.5.12" jb-compose = "1.5.12"
jb-exposed = "0.46.0" jb-exposed = "0.47.0"
jb-dokka = "1.9.10" jb-dokka = "1.9.10"
korlibs = "5.3.1" korlibs = "5.3.2"
uuid = "0.8.2" uuid = "0.8.2"
ktor = "2.3.7" ktor = "2.3.8"
gh-release = "2.5.2" gh-release = "2.5.2"
koin = "3.5.3" koin = "3.5.3"
okio = "3.7.0" okio = "3.8.0"
ksp = "1.9.22-1.0.17" ksp = "1.9.22-1.0.17"
kotlin-poet = "1.16.0" kotlin-poet = "1.16.0"
@@ -35,7 +35,7 @@ android-appCompat = "1.6.1"
android-fragment = "1.6.2" android-fragment = "1.6.2"
android-espresso = "3.5.1" android-espresso = "3.5.1"
android-test = "1.1.5" android-test = "1.1.5"
android-compose-material3 = "1.1.2" android-compose-material3 = "1.2.0"
android-props-minSdk = "21" android-props-minSdk = "21"
android-props-compileSdk = "34" android-props-compileSdk = "34"

View File

@@ -1,5 +1,5 @@
distributionBase=GRADLE_USER_HOME distributionBase=GRADLE_USER_HOME
distributionPath=wrapper/dists distributionPath=wrapper/dists
distributionUrl=https\://services.gradle.org/distributions/gradle-8.5-bin.zip distributionUrl=https\://services.gradle.org/distributions/gradle-8.6-bin.zip
zipStoreBase=GRADLE_USER_HOME zipStoreBase=GRADLE_USER_HOME
zipStorePath=wrapper/dists zipStorePath=wrapper/dists

View File

@@ -5,6 +5,7 @@ import dev.inmo.micro_utils.coroutines.withReadAcquire
import dev.inmo.micro_utils.coroutines.withWriteLock import dev.inmo.micro_utils.coroutines.withWriteLock
import dev.inmo.micro_utils.repos.* import dev.inmo.micro_utils.repos.*
import dev.inmo.micro_utils.repos.cache.cache.KVCache import dev.inmo.micro_utils.repos.cache.cache.KVCache
import dev.inmo.micro_utils.repos.cache.util.ActualizeAllClearMode
import dev.inmo.micro_utils.repos.cache.util.actualizeAll import dev.inmo.micro_utils.repos.cache.util.actualizeAll
import kotlinx.coroutines.CoroutineScope import kotlinx.coroutines.CoroutineScope
import kotlinx.coroutines.Dispatchers import kotlinx.coroutines.Dispatchers
@@ -29,7 +30,7 @@ open class ReadCRUDCacheRepo<ObjectType, IdType>(
kvCache.getAll() kvCache.getAll()
}.takeIf { it.size.toLong() == count() } ?: parentRepo.getAll().also { }.takeIf { it.size.toLong() == count() } ?: parentRepo.getAll().also {
locker.withWriteLock { locker.withWriteLock {
kvCache.actualizeAll(true) { it } kvCache.actualizeAll(clearMode = ActualizeAllClearMode.BeforeSet) { it }
} }
} }
} }
@@ -148,7 +149,9 @@ open class CRUDCacheRepo<ObjectType, IdType, InputValueType>(
locker, locker,
idGetter idGetter
), ),
CRUDRepo<ObjectType, IdType, InputValueType> CRUDRepo<ObjectType, IdType, InputValueType> {
override suspend fun invalidate() = kvCache.actualizeAll(parentRepo, locker = locker)
}
fun <ObjectType, IdType, InputType> CRUDRepo<ObjectType, IdType, InputType>.cached( fun <ObjectType, IdType, InputType> CRUDRepo<ObjectType, IdType, InputType>.cached(
kvCache: KVCache<IdType, ObjectType>, kvCache: KVCache<IdType, ObjectType>,

View File

@@ -1,5 +1,11 @@
package dev.inmo.micro_utils.repos.cache package dev.inmo.micro_utils.repos.cache
interface CacheRepo { interface InvalidatableRepo {
/**
* Invalidates its internal data. It __may__ lead to autoreload of data. In case when repo makes autoreload,
* it must do loading of data __before__ clear
*/
suspend fun invalidate() suspend fun invalidate()
} }
typealias CacheRepo = InvalidatableRepo

View File

@@ -6,6 +6,7 @@ import dev.inmo.micro_utils.coroutines.withWriteLock
import dev.inmo.micro_utils.pagination.* import dev.inmo.micro_utils.pagination.*
import dev.inmo.micro_utils.repos.* import dev.inmo.micro_utils.repos.*
import dev.inmo.micro_utils.repos.cache.cache.KVCache import dev.inmo.micro_utils.repos.cache.cache.KVCache
import dev.inmo.micro_utils.repos.cache.util.actualizeAll
import kotlinx.coroutines.CoroutineScope import kotlinx.coroutines.CoroutineScope
import kotlinx.coroutines.Dispatchers import kotlinx.coroutines.Dispatchers
import kotlinx.coroutines.flow.* import kotlinx.coroutines.flow.*
@@ -48,9 +49,7 @@ open class ReadKeyValueCacheRepo<Key,Value>(
} }
} }
override suspend fun invalidate() = locker.withWriteLock { override suspend fun invalidate() = kvCache.actualizeAll(parentRepo, locker = locker)
kvCache.clear()
}
} }
fun <Key, Value> ReadKeyValueRepo<Key, Value>.cached( fun <Key, Value> ReadKeyValueRepo<Key, Value>.cached(
@@ -75,10 +74,6 @@ open class KeyValueCacheRepo<Key,Value>(
} }
}.launchIn(scope) }.launchIn(scope)
override suspend fun invalidate() = locker.withWriteLock {
kvCache.clear()
}
override suspend fun clear() { override suspend fun clear() {
parentRepo.clear() parentRepo.clear()
locker.withWriteLock { locker.withWriteLock {

View File

@@ -7,6 +7,7 @@ import dev.inmo.micro_utils.pagination.*
import dev.inmo.micro_utils.pagination.utils.* import dev.inmo.micro_utils.pagination.utils.*
import dev.inmo.micro_utils.repos.* import dev.inmo.micro_utils.repos.*
import dev.inmo.micro_utils.repos.cache.cache.KVCache import dev.inmo.micro_utils.repos.cache.cache.KVCache
import dev.inmo.micro_utils.repos.cache.util.actualizeAll
import kotlinx.coroutines.CoroutineScope import kotlinx.coroutines.CoroutineScope
import kotlinx.coroutines.Dispatchers import kotlinx.coroutines.Dispatchers
import kotlinx.coroutines.flow.* import kotlinx.coroutines.flow.*
@@ -47,9 +48,7 @@ open class ReadKeyValuesCacheRepo<Key,Value>(
kvCache.contains(k) kvCache.contains(k)
} || parentRepo.contains(k) } || parentRepo.contains(k)
override suspend fun invalidate() = locker.withWriteLock { override suspend fun invalidate() = kvCache.actualizeAll(parentRepo, locker = locker)
kvCache.clear()
}
} }
fun <Key, Value> ReadKeyValuesRepo<Key, Value>.cached( fun <Key, Value> ReadKeyValuesRepo<Key, Value>.cached(
@@ -84,10 +83,6 @@ open class KeyValuesCacheRepo<Key,Value>(
kvCache.unset(it) kvCache.unset(it)
} }
}.launchIn(scope) }.launchIn(scope)
override suspend fun invalidate() = locker.withWriteLock {
kvCache.clear()
}
} }
fun <Key, Value> KeyValuesRepo<Key, Value>.cached( fun <Key, Value> KeyValuesRepo<Key, Value>.cached(

View File

@@ -9,6 +9,7 @@ import dev.inmo.micro_utils.repos.ReadCRUDRepo
import dev.inmo.micro_utils.repos.cache.fallback.ActionWrapper import dev.inmo.micro_utils.repos.cache.fallback.ActionWrapper
import dev.inmo.micro_utils.repos.cache.util.actualizeAll import dev.inmo.micro_utils.repos.cache.util.actualizeAll
import dev.inmo.micro_utils.repos.cache.FallbackCacheRepo import dev.inmo.micro_utils.repos.cache.FallbackCacheRepo
import dev.inmo.micro_utils.repos.cache.util.ActualizeAllClearMode
import dev.inmo.micro_utils.repos.set import dev.inmo.micro_utils.repos.set
import kotlinx.coroutines.CoroutineScope import kotlinx.coroutines.CoroutineScope
import kotlinx.coroutines.delay import kotlinx.coroutines.delay
@@ -56,7 +57,7 @@ open class AutoRecacheReadCRUDRepo<RegisteredObject, Id>(
override suspend fun getAll(): Map<Id, RegisteredObject> = actionWrapper.wrap { override suspend fun getAll(): Map<Id, RegisteredObject> = actionWrapper.wrap {
originalRepo.getAll() originalRepo.getAll()
}.onSuccess { }.onSuccess {
kvCache.actualizeAll(clear = true) { it } kvCache.actualizeAll(clearMode = ActualizeAllClearMode.BeforeSet) { it }
}.getOrElse { }.getOrElse {
kvCache.getAll() kvCache.getAll()
} }

View File

@@ -9,6 +9,7 @@ import dev.inmo.micro_utils.repos.ReadKeyValueRepo
import dev.inmo.micro_utils.repos.cache.fallback.ActionWrapper import dev.inmo.micro_utils.repos.cache.fallback.ActionWrapper
import dev.inmo.micro_utils.repos.cache.util.actualizeAll import dev.inmo.micro_utils.repos.cache.util.actualizeAll
import dev.inmo.micro_utils.repos.cache.FallbackCacheRepo import dev.inmo.micro_utils.repos.cache.FallbackCacheRepo
import dev.inmo.micro_utils.repos.cache.util.ActualizeAllClearMode
import dev.inmo.micro_utils.repos.set import dev.inmo.micro_utils.repos.set
import kotlinx.coroutines.CoroutineScope import kotlinx.coroutines.CoroutineScope
import kotlinx.coroutines.delay import kotlinx.coroutines.delay
@@ -56,7 +57,7 @@ open class AutoRecacheReadKeyValueRepo<Id, RegisteredObject>(
override suspend fun getAll(): Map<Id, RegisteredObject> = actionWrapper.wrap { override suspend fun getAll(): Map<Id, RegisteredObject> = actionWrapper.wrap {
originalRepo.getAll() originalRepo.getAll()
}.onSuccess { }.onSuccess {
kvCache.actualizeAll(clear = true) { it } kvCache.actualizeAll(clearMode = ActualizeAllClearMode.BeforeSet) { it }
}.getOrElse { }.getOrElse {
kvCache.getAll() kvCache.getAll()
} }

View File

@@ -9,6 +9,7 @@ import dev.inmo.micro_utils.pagination.Pagination
import dev.inmo.micro_utils.pagination.PaginationResult import dev.inmo.micro_utils.pagination.PaginationResult
import dev.inmo.micro_utils.repos.* import dev.inmo.micro_utils.repos.*
import dev.inmo.micro_utils.repos.cache.* import dev.inmo.micro_utils.repos.cache.*
import dev.inmo.micro_utils.repos.cache.util.ActualizeAllClearMode
import dev.inmo.micro_utils.repos.cache.util.actualizeAll import dev.inmo.micro_utils.repos.cache.util.actualizeAll
import kotlinx.coroutines.CoroutineScope import kotlinx.coroutines.CoroutineScope
import kotlinx.coroutines.Dispatchers import kotlinx.coroutines.Dispatchers
@@ -42,7 +43,7 @@ open class FullReadCRUDCacheRepo<ObjectType, IdType>(
) )
protected open suspend fun actualizeAll() { protected open suspend fun actualizeAll() {
locker.withWriteLock { kvCache.actualizeAll(parentRepo) } kvCache.actualizeAll(parentRepo, locker = locker)
} }
override suspend fun getByPagination(pagination: Pagination): PaginationResult<ObjectType> = doOrTakeAndActualize( override suspend fun getByPagination(pagination: Pagination): PaginationResult<ObjectType> = doOrTakeAndActualize(
@@ -72,7 +73,7 @@ open class FullReadCRUDCacheRepo<ObjectType, IdType>(
override suspend fun getAll(): Map<IdType, ObjectType> = doOrTakeAndActualizeWithWriteLock( override suspend fun getAll(): Map<IdType, ObjectType> = doOrTakeAndActualizeWithWriteLock(
{ getAll().takeIf { it.isNotEmpty() }.optionalOrAbsentIfNull }, { getAll().takeIf { it.isNotEmpty() }.optionalOrAbsentIfNull },
{ getAll() }, { getAll() },
{ kvCache.actualizeAll(clear = true) { it } } { kvCache.actualizeAll(clearMode = ActualizeAllClearMode.BeforeSet) { it } }
) )
override suspend fun getById(id: IdType): ObjectType? = doOrTakeAndActualizeWithWriteLock( override suspend fun getById(id: IdType): ObjectType? = doOrTakeAndActualizeWithWriteLock(

View File

@@ -8,8 +8,8 @@ import dev.inmo.micro_utils.coroutines.withWriteLock
import dev.inmo.micro_utils.pagination.Pagination import dev.inmo.micro_utils.pagination.Pagination
import dev.inmo.micro_utils.pagination.PaginationResult import dev.inmo.micro_utils.pagination.PaginationResult
import dev.inmo.micro_utils.repos.* import dev.inmo.micro_utils.repos.*
import dev.inmo.micro_utils.repos.cache.util.ActualizeAllClearMode
import dev.inmo.micro_utils.repos.cache.util.actualizeAll import dev.inmo.micro_utils.repos.cache.util.actualizeAll
import dev.inmo.micro_utils.repos.pagination.getAll
import kotlinx.coroutines.CoroutineScope import kotlinx.coroutines.CoroutineScope
import kotlinx.coroutines.Dispatchers import kotlinx.coroutines.Dispatchers
import kotlinx.coroutines.flow.* import kotlinx.coroutines.flow.*
@@ -41,10 +41,7 @@ open class FullReadKeyValueCacheRepo<Key,Value>(
actualize = { locker.withWriteLock { actualize(it) } } actualize = { locker.withWriteLock { actualize(it) } }
) )
protected open suspend fun actualizeAll() { protected open suspend fun actualizeAll() {
locker.withWriteLock { kvCache.actualizeAll(parentRepo, locker)
kvCache.clear()
kvCache.set(parentRepo.getAll())
}
} }
override suspend fun get(k: Key): Value? = doOrTakeAndActualizeWithWriteLock( override suspend fun get(k: Key): Value? = doOrTakeAndActualizeWithWriteLock(
@@ -74,7 +71,7 @@ open class FullReadKeyValueCacheRepo<Key,Value>(
override suspend fun getAll(): Map<Key, Value> = doOrTakeAndActualizeWithWriteLock( override suspend fun getAll(): Map<Key, Value> = doOrTakeAndActualizeWithWriteLock(
{ getAll().takeIf { it.isNotEmpty() }.optionalOrAbsentIfNull }, { getAll().takeIf { it.isNotEmpty() }.optionalOrAbsentIfNull },
{ getAll() }, { getAll() },
{ kvCache.actualizeAll(clear = true) { it } } { kvCache.actualizeAll(clearMode = ActualizeAllClearMode.BeforeSet) { it } }
) )
override suspend fun keys(pagination: Pagination, reversed: Boolean): PaginationResult<Key> = doOrTakeAndActualize( override suspend fun keys(pagination: Pagination, reversed: Boolean): PaginationResult<Key> = doOrTakeAndActualize(
@@ -150,9 +147,7 @@ open class FullKeyValueCacheRepo<Key,Value>(
override suspend fun unsetWithValues(toUnset: List<Value>) = parentRepo.unsetWithValues(toUnset) override suspend fun unsetWithValues(toUnset: List<Value>) = parentRepo.unsetWithValues(toUnset)
override suspend fun invalidate() { override suspend fun invalidate() {
locker.withWriteLock { kvCache.actualizeAll(parentRepo, locker)
kvCache.actualizeAll(parentRepo)
}
} }
override suspend fun clear() { override suspend fun clear() {

View File

@@ -8,6 +8,7 @@ import dev.inmo.micro_utils.coroutines.withWriteLock
import dev.inmo.micro_utils.pagination.* import dev.inmo.micro_utils.pagination.*
import dev.inmo.micro_utils.pagination.utils.* import dev.inmo.micro_utils.pagination.utils.*
import dev.inmo.micro_utils.repos.* import dev.inmo.micro_utils.repos.*
import dev.inmo.micro_utils.repos.cache.util.ActualizeAllClearMode
import dev.inmo.micro_utils.repos.cache.util.actualizeAll import dev.inmo.micro_utils.repos.cache.util.actualizeAll
import kotlinx.coroutines.CoroutineScope import kotlinx.coroutines.CoroutineScope
import kotlinx.coroutines.Dispatchers import kotlinx.coroutines.Dispatchers
@@ -41,15 +42,13 @@ open class FullReadKeyValuesCacheRepo<Key,Value>(
) )
protected open suspend fun actualizeKey(k: Key) { protected open suspend fun actualizeKey(k: Key) {
locker.withWriteLock { kvCache.actualizeAll(locker = locker, clearMode = ActualizeAllClearMode.Never) {
kvCache.set(k, parentRepo.getAll(k)) mapOf(k to parentRepo.getAll(k))
} }
} }
protected open suspend fun actualizeAll() { protected open suspend fun actualizeAll() {
locker.withWriteLock { kvCache.actualizeAll(parentRepo, locker = locker)
kvCache.actualizeAll(parentRepo)
}
} }
override suspend fun get(k: Key, pagination: Pagination, reversed: Boolean): PaginationResult<Value> { override suspend fun get(k: Key, pagination: Pagination, reversed: Boolean): PaginationResult<Value> {
@@ -187,9 +186,11 @@ open class FullKeyValuesCacheRepo<Key,Value>(
} }
override suspend fun invalidate() { override suspend fun invalidate() {
locker.withWriteLock { kvCache.actualizeAll(parentRepo, locker = locker)
kvCache.actualizeAll(parentRepo) }
}
override suspend fun set(toSet: Map<Key, List<Value>>) {
super<KeyValuesRepo>.set(toSet)
} }
override suspend fun removeWithValue(v: Value) { override suspend fun removeWithValue(v: Value) {

View File

@@ -1,43 +1,169 @@
package dev.inmo.micro_utils.repos.cache.util package dev.inmo.micro_utils.repos.cache.util
import dev.inmo.micro_utils.coroutines.SmartRWLocker
import dev.inmo.micro_utils.coroutines.withWriteLock
import dev.inmo.micro_utils.repos.* import dev.inmo.micro_utils.repos.*
import kotlinx.serialization.Serializable
import kotlin.js.JsName
import kotlin.jvm.JvmName
suspend inline fun <K, V> KeyValueRepo<K, V>.actualizeAll( /**
clear: Boolean = true, * `invalidate`/`actualizeAll` clearing mode. Declare when data in original repo will be cleared
*/
@Serializable
sealed interface ActualizeAllClearMode {
/**
* Instruct user of this mode to clear internal data __before load__ of external data
*/
@Serializable
data object BeforeLoad : ActualizeAllClearMode
/**
* Instruct user of this mode to clear internal data __after load__ of external data and __before set__ of internal data
*/
@Serializable
data object BeforeSet : ActualizeAllClearMode
/**
* Instruct user of this mode to never clear internal data
*/
@Serializable
data object Never : ActualizeAllClearMode
}
suspend inline fun <K, V> KeyValueRepo<K, V>.actualizeAllWithClearBeforeLoad(
getAll: () -> Map<K, V> getAll: () -> Map<K, V>
) { ) {
set( clear()
getAll().also { val newData = getAll()
if (clear) { set(newData)
clear() }
}
} suspend inline fun <K, V> KeyValueRepo<K, V>.actualizeAllWithClearBeforeSet(
) getAll: () -> Map<K, V>
) {
val newData = getAll()
clear()
set(newData)
}
suspend inline fun <K, V> KeyValueRepo<K, V>.actualizeAllWithoutClear(
getAll: () -> Map<K, V>
) {
val newData = getAll()
set(newData)
}
@JvmName("actualizeAllWithClearBeforeLoadWithLocker")
@JsName("actualizeAllWithClearBeforeLoadWithLocker")
suspend inline fun <K, V> KeyValueRepo<K, V>.actualizeAllWithClearBeforeLoad(
locker: SmartRWLocker,
getAll: () -> Map<K, V>
) {
locker.withWriteLock {
clear()
}
val newData = getAll()
locker.withWriteLock {
set(newData)
}
}
@JvmName("actualizeAllWithClearBeforeSetWithLocker")
@JsName("actualizeAllWithClearBeforeSetWithLocker")
suspend inline fun <K, V> KeyValueRepo<K, V>.actualizeAllWithClearBeforeSet(
locker: SmartRWLocker,
getAll: () -> Map<K, V>
) {
val newData = getAll()
locker.withWriteLock {
clear()
set(newData)
}
}
@JvmName("actualizeAllWithoutClearWithLocker")
@JsName("actualizeAllWithoutClearWithLocker")
suspend inline fun <K, V> KeyValueRepo<K, V>.actualizeAllWithoutClear(
locker: SmartRWLocker,
getAll: () -> Map<K, V>
) {
val newData = getAll()
locker.withWriteLock {
set(newData)
}
}
suspend inline fun <K, V> KeyValueRepo<K, V>.actualizeAllWithClearBeforeLoad(
locker: SmartRWLocker? = null,
getAll: () -> Map<K, V>
) {
locker ?.let {
actualizeAllWithClearBeforeLoad(locker = locker, getAll)
} ?: actualizeAllWithClearBeforeLoad(getAll)
}
suspend inline fun <K, V> KeyValueRepo<K, V>.actualizeAllWithClearBeforeSet(
locker: SmartRWLocker? = null,
getAll: () -> Map<K, V>
) {
locker ?.let {
actualizeAllWithClearBeforeSet(locker = locker, getAll)
} ?: actualizeAllWithClearBeforeSet(getAll)
}
suspend inline fun <K, V> KeyValueRepo<K, V>.actualizeAllWithoutClear(
locker: SmartRWLocker? = null,
getAll: () -> Map<K, V>
) {
locker ?.let {
actualizeAllWithoutClear(locker = locker, getAll)
} ?: actualizeAllWithoutClear(getAll)
} }
suspend inline fun <K, V> KeyValueRepo<K, V>.actualizeAll( suspend inline fun <K, V> KeyValueRepo<K, V>.actualizeAll(
repo: ReadKeyValueRepo<K, V>, locker: SmartRWLocker? = null,
clear: Boolean = true, clearMode: ActualizeAllClearMode = ActualizeAllClearMode.BeforeSet,
getAll: () -> Map<K, V>
) { ) {
actualizeAll(clear) { when (clearMode) {
repo.getAll() ActualizeAllClearMode.BeforeLoad -> locker ?.let {
actualizeAllWithClearBeforeLoad(locker = locker, getAll)
} ?: actualizeAllWithClearBeforeLoad(getAll)
ActualizeAllClearMode.BeforeSet -> locker ?.let {
actualizeAllWithClearBeforeSet(locker = locker, getAll)
} ?: actualizeAllWithClearBeforeSet(getAll)
ActualizeAllClearMode.Never -> locker ?.let {
actualizeAllWithoutClear(locker = locker, getAll)
} ?: actualizeAllWithoutClear(getAll)
}
}
suspend inline fun <K, V> KeyValueRepo<K, V>.actualizeAll(
parentRepo: ReadKeyValueRepo<K, V>,
locker: SmartRWLocker? = null,
clearMode: ActualizeAllClearMode = ActualizeAllClearMode.BeforeSet,
) {
actualizeAll(locker, clearMode) {
parentRepo.getAll()
} }
} }
suspend inline fun <K, V> KeyValueRepo<K, List<V>>.actualizeAll( suspend inline fun <K, V> KeyValueRepo<K, List<V>>.actualizeAll(
repo: ReadKeyValuesRepo<K, V>, parentRepo: ReadKeyValuesRepo<K, V>,
clear: Boolean = true, locker: SmartRWLocker? = null,
clearMode: ActualizeAllClearMode = ActualizeAllClearMode.BeforeSet,
) { ) {
actualizeAll(clear) { actualizeAll(locker, clearMode) {
repo.getAll() parentRepo.getAll()
} }
} }
suspend inline fun <K, V> KeyValueRepo<K, V>.actualizeAll( suspend inline fun <K, V> KeyValueRepo<K, V>.actualizeAll(
repo: ReadCRUDRepo<V, K>, parentRepo: ReadCRUDRepo<V, K>,
clear: Boolean = true, locker: SmartRWLocker? = null,
clearMode: ActualizeAllClearMode = ActualizeAllClearMode.BeforeSet,
) { ) {
actualizeAll(clear) { actualizeAll(locker, clearMode) {
repo.getAll() parentRepo.getAll()
} }
} }

View File

@@ -1,5 +1,6 @@
package dev.inmo.micro_utils.repos package dev.inmo.micro_utils.repos
import dev.inmo.micro_utils.common.diff
import dev.inmo.micro_utils.pagination.* import dev.inmo.micro_utils.pagination.*
import dev.inmo.micro_utils.pagination.utils.doForAllWithNextPaging import dev.inmo.micro_utils.pagination.utils.doForAllWithNextPaging
import dev.inmo.micro_utils.pagination.utils.getAllWithNextPaging import dev.inmo.micro_utils.pagination.utils.getAllWithNextPaging
@@ -130,6 +131,14 @@ interface KeyValuesRepo<Key, Value> : ReadKeyValuesRepo<Key, Value>, WriteKeyVal
remove(toRemove) remove(toRemove)
} }
override suspend fun set(toSet: Map<Key, List<Value>>) {
toSet.forEach { (k, v) ->
val diff = getAll(k).diff(v)
remove(k, diff.removed.map { it.value })
add(k, diff.added.map { it.value })
}
}
} }
typealias OneToManyKeyValueRepo<Key,Value> = KeyValuesRepo<Key, Value> typealias OneToManyKeyValueRepo<Key,Value> = KeyValuesRepo<Key, Value>

View File

@@ -1,6 +1,11 @@
package dev.inmo.micro_utils.strings package dev.inmo.micro_utils.strings
import dev.inmo.micro_utils.language_codes.IetfLang import dev.inmo.micro_utils.language_codes.IetfLang
import kotlinx.serialization.KSerializer
import kotlinx.serialization.Serializable
import kotlinx.serialization.descriptors.SerialDescriptor
import kotlinx.serialization.encoding.Decoder
import kotlinx.serialization.encoding.Encoder
/** /**
* Use this class as a type of your strings object fields. For example: * Use this class as a type of your strings object fields. For example:
@@ -15,9 +20,10 @@ import dev.inmo.micro_utils.language_codes.IetfLang
* *
* @see buildStringResource * @see buildStringResource
*/ */
class StringResource( @Serializable(StringResource.Companion::class)
data class StringResource(
val default: String, val default: String,
val map: Map<IetfLang, Lazy<String>> val translations: Map<IetfLang, Lazy<String>>
) { ) {
class Builder( class Builder(
var default: String var default: String
@@ -31,11 +37,18 @@ class StringResource(
infix fun IetfLang.variant(value: () -> String) = this variant lazy(value) infix fun IetfLang.variant(value: () -> String) = this variant lazy(value)
infix fun IetfLang.variant(value: String) = this variant lazyOf(value) infix fun IetfLang.variant(value: String) = this variant lazyOf(value)
operator fun IetfLang.invoke(value: () -> String) = this variant value
operator fun IetfLang.invoke(value: String) = this variant value
infix fun String.variant(value: Lazy<String>) = IetfLang(this) variant value infix fun String.variant(value: Lazy<String>) = IetfLang(this) variant value
infix fun String.variant(value: () -> String) = IetfLang(this) variant lazy(value) infix fun String.variant(value: () -> String) = IetfLang(this) variant lazy(value)
infix fun String.variant(value: String) = this variant lazyOf(value) infix fun String.variant(value: String) = this variant lazyOf(value)
operator fun String.invoke(value: () -> String) = this variant value
operator fun String.invoke(value: String) = this variant value
fun build() = StringResource(default, map.toMap()) fun build() = StringResource(default, map.toMap())
} }
@@ -43,17 +56,48 @@ class StringResource(
if (languageCode == null) { if (languageCode == null) {
return default return default
} }
map[languageCode] ?.let { return it.value } translations[languageCode] ?.let { return it.value }
return languageCode.parentLang ?.let { return languageCode.parentLang ?.let {
map[it] ?.value translations[it] ?.value
} ?: default } ?: default
} }
companion object : KSerializer<StringResource> {
@Serializable
private class Surrogate(
val default: String,
val translations: Map<String, String>
)
override val descriptor: SerialDescriptor
get() = Surrogate.serializer().descriptor
override fun deserialize(decoder: Decoder): StringResource {
val surrogate = Surrogate.serializer().deserialize(decoder)
return StringResource(
surrogate.default,
surrogate.translations.map { IetfLang(it.key) to lazyOf(it.value) }.toMap()
)
}
override fun serialize(encoder: Encoder, value: StringResource) {
Surrogate.serializer().serialize(
encoder,
Surrogate(
value.default,
value.translations.map {
it.key.code to it.value.value
}.toMap()
)
)
}
}
} }
inline fun buildStringResource( inline fun buildStringResource(
default: String, default: String,
builder: StringResource.Builder.() -> Unit builder: StringResource.Builder.() -> Unit = {}
): StringResource { ): StringResource {
return StringResource.Builder(default).apply(builder).build() return StringResource.Builder(default).apply(builder).build()
} }