mirror of
				https://github.com/InsanusMokrassar/MicroUtils.git
				synced 2025-10-30 19:50:31 +00:00 
			
		
		
		
	Compare commits
	
		
			39 Commits
		
	
	
		
	
	| Author | SHA1 | Date | |
|---|---|---|---|
| 1d8330015d | |||
| e5017b0258 | |||
| cd412ca31b | |||
| d2b6473095 | |||
| ab42507275 | |||
| dcef844e20 | |||
| 3244708c1b | |||
| 73ac1f1741 | |||
| f104e9f352 | |||
| 393c9a7d06 | |||
| ea497ea488 | |||
|  | 5add89cad0 | ||
| 2db447d2ef | |||
| 31c83813e6 | |||
| 27483a282d | |||
| 48b816aa22 | |||
| 0065f94f52 | |||
| ccc0002eb2 | |||
| 15a2eee141 | |||
| b9faac71e5 | |||
| 0a4465de33 | |||
| f9dfd09628 | |||
| 8638d7afce | |||
| 8311793a43 | |||
| 0d552cfcd2 | |||
| 4b0f20dbd1 | |||
| cf531c949d | |||
| ba5c5f17d5 | |||
| 35825ad9b7 | |||
| b1eb26a89e | |||
| c9d04b6698 | |||
| 496133e014 | |||
| f2857ee2be | |||
| 22541f2d5e | |||
| e235c52b6c | |||
| e89b8c72dd | |||
| a374e53a3a | |||
| afb066c4ee | |||
| f05761d4a5 | 
							
								
								
									
										63
									
								
								CHANGELOG.md
									
									
									
									
									
								
							
							
						
						
									
										63
									
								
								CHANGELOG.md
									
									
									
									
									
								
							| @@ -1,5 +1,68 @@ | |||||||
| # Changelog | # Changelog | ||||||
|  |  | ||||||
|  | ## 0.20.40 | ||||||
|  |  | ||||||
|  | * `Versions`: | ||||||
|  |     * `KSLog`: `1.3.2` -> `1.3.3` | ||||||
|  |     * `Exposed`: `0.48.0` -> `0.49.0` | ||||||
|  |     * `UUID`: `0.8.2` -> `0.8.4` | ||||||
|  |  | ||||||
|  | ## 0.20.39 | ||||||
|  |  | ||||||
|  | * `Versions`: | ||||||
|  |     * `Kotlin`: `1.9.22` -> `1.9.23` | ||||||
|  |     * `Korlibs`: `5.3.2` -> `5.4.0` | ||||||
|  |     * `Okio`: `3.8.0` -> `3.9.0` | ||||||
|  |     * `Compose`: `1.6.0` -> `1.6.1` | ||||||
|  |     * `ComposeMaterial3`: `1.2.0` -> `1.2.1` | ||||||
|  |  | ||||||
|  | ## 0.20.38 | ||||||
|  |  | ||||||
|  | * `Versions`: | ||||||
|  |     * `Ktor`: `2.3.8` -> `2.3.9` | ||||||
|  |  | ||||||
|  | ## 0.20.37 | ||||||
|  |  | ||||||
|  | * `Versions`: | ||||||
|  |     * `Compose`: `1.5.12` -> `1.6.0` | ||||||
|  |     * `Exposed`: `0.47.0` -> `0.48.0` | ||||||
|  |  | ||||||
|  | ## 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 | ## 0.20.31 | ||||||
|  |  | ||||||
| * `Versions`: | * `Versions`: | ||||||
|   | |||||||
| @@ -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] | ||||||
|          * |          * | ||||||
|   | |||||||
| @@ -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)) | ||||||
|         } |         } | ||||||
|   | |||||||
| @@ -15,5 +15,5 @@ crypto_js_version=4.1.1 | |||||||
| # Project data | # Project data | ||||||
|  |  | ||||||
| group=dev.inmo | group=dev.inmo | ||||||
| version=0.20.31 | version=0.20.40 | ||||||
| android_code_version=237 | android_code_version=246 | ||||||
|   | |||||||
| @@ -1,32 +1,32 @@ | |||||||
| [versions] | [versions] | ||||||
|  |  | ||||||
| kt = "1.9.22" | kt = "1.9.23" | ||||||
| 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.3" | ||||||
|  |  | ||||||
| jb-compose = "1.5.12" | jb-compose = "1.6.1" | ||||||
| jb-exposed = "0.47.0" | jb-exposed = "0.49.0" | ||||||
| jb-dokka = "1.9.10" | jb-dokka = "1.9.20" | ||||||
|  |  | ||||||
| korlibs = "5.3.1" | korlibs = "5.4.0" | ||||||
| uuid = "0.8.2" | uuid = "0.8.4" | ||||||
|  |  | ||||||
| ktor = "2.3.8" | ktor = "2.3.9" | ||||||
|  |  | ||||||
| gh-release = "2.5.2" | gh-release = "2.5.2" | ||||||
|  |  | ||||||
| koin = "3.5.3" | koin = "3.5.3" | ||||||
|  |  | ||||||
| okio = "3.7.0" | okio = "3.9.0" | ||||||
|  |  | ||||||
| ksp = "1.9.22-1.0.17" | ksp = "1.9.23-1.0.19" | ||||||
| kotlin-poet = "1.16.0" | kotlin-poet = "1.16.0" | ||||||
|  |  | ||||||
| versions = "0.51.0" | versions = "0.51.0" | ||||||
|  |  | ||||||
| android-gradle = "8.2.2" | android-gradle = "8.3.1" | ||||||
| dexcount = "4.0.0" | dexcount = "4.0.0" | ||||||
|  |  | ||||||
| android-coreKtx = "1.12.0" | android-coreKtx = "1.12.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.1" | ||||||
|  |  | ||||||
| android-props-minSdk = "21" | android-props-minSdk = "21" | ||||||
| android-props-compileSdk = "34" | android-props-compileSdk = "34" | ||||||
|   | |||||||
							
								
								
									
										2
									
								
								gradle/wrapper/gradle-wrapper.properties
									
									
									
									
										vendored
									
									
								
							
							
						
						
									
										2
									
								
								gradle/wrapper/gradle-wrapper.properties
									
									
									
									
										vendored
									
									
								
							| @@ -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.7-bin.zip | ||||||
| zipStoreBase=GRADLE_USER_HOME | zipStoreBase=GRADLE_USER_HOME | ||||||
| zipStorePath=wrapper/dists | zipStorePath=wrapper/dists | ||||||
|   | |||||||
| @@ -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>, | ||||||
|   | |||||||
| @@ -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 | ||||||
|   | |||||||
| @@ -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 { | ||||||
|   | |||||||
| @@ -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( | ||||||
|   | |||||||
| @@ -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() | ||||||
|     } |     } | ||||||
|   | |||||||
| @@ -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() | ||||||
|     } |     } | ||||||
|   | |||||||
| @@ -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( | ||||||
|   | |||||||
| @@ -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() { | ||||||
|   | |||||||
| @@ -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) { | ||||||
|   | |||||||
| @@ -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) | ||||||
|  | } | ||||||
|  |  | ||||||
|  | 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() |         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() | ||||||
|     } |     } | ||||||
| } | } | ||||||
|   | |||||||
| @@ -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> | ||||||
|  |  | ||||||
|   | |||||||
| @@ -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() | ||||||
| } | } | ||||||
|   | |||||||
		Reference in New Issue
	
	Block a user