InsanusMokrassar/MicroUtils
1
0
Fork 0
mirror of https://github.com/InsanusMokrassar/MicroUtils.git synced 2026-09-13 11:44:20 +00:00
Code Issues Packages Projects Releases Wiki Activity

Merge d325cfd298 into 89ce3c9f82

Browse Source
This commit is contained in:
Bodya
2024-08-06 14:08:43 +06:00
committed by GitHub
parent 89ce3c9f82 d325cfd298
commit d8d52ce528
4 changed files with 275 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

1
repos/common/src/commonMain/kotlin/dev/inmo/micro_utils/repos/StandartCRUDRepo.kt
View File

@@ -39,6 +39,7 @@ interface WriteCRUDRepo<ObjectType, IdType, InputValueType> : Repo {
suspend fun update(id: IdType, value: InputValueType): ObjectType?
suspend fun update(values: List<UpdatedValuePair<IdType, InputValueType>>): List<ObjectType>
suspend fun deleteById(ids: List<IdType>)
suspend fun deleteById(vararg ids: IdType) = deleteById(ids.toList())
}
typealias WriteStandardCRUDRepo<ObjectType, IdType, InputValueType> = WriteCRUDRepo<ObjectType, IdType, InputValueType>

266
repos/inmemory/src/commonTest/kotlin/MapCRUDRepoTest.kt Normal file
View File

@@ -0,0 +1,266 @@
import dev.inmo.micro_utils.repos.MapCRUDRepo
import dev.inmo.micro_utils.repos.create
import kotlinx.coroutines.Dispatchers
import kotlinx.coroutines.delay
import kotlinx.coroutines.launch
import kotlinx.coroutines.test.runTest
import kotlin.test.Test
import kotlin.test.assertEquals
data class TestModel(
val testery: String,
val isTestery: Boolean,
val testeryAmount: Int
)
class MapCRUDRepoTest {
/**
* A utility function used for generating non-intersecting ranges in cyclic environment, like [repeat]
* or for-loops
*/
private fun getIdRange(start: Int, base: Int) = (start * base)..(start * base + (base - 1))
@Test
fun mapCrudRepoTest() = runTest {
val base = 4 // define a bigger number to increase test intensity
val targetMap = mutableMapOf<Int, TestModel>()
// filling the map
val jobs = List(base) { jobId ->
launch(Dispatchers.Default) { // to make delays work
println("launching job $jobId")
delay((1..5).random().toLong())
val idsList = getIdRange(jobId, base).toMutableList()
println("created ids list $idsList")
val mapCRUDRepo = MapCRUDRepo<TestModel, Int, TestModel>(
targetMap,
createCallback = { new ->
val newObject = idsList.first() to new
idsList.remove(newObject.first)
println("created $newObject in map")
newObject
},
updateCallback = { new, id, old ->
println("updated object at $id from $old to $new")
new
}
)
for (id in getIdRange(jobId, base)) {
val newModel = TestModel(
testery = "testery$id",
isTestery = id % 2 == 0,
testeryAmount = id
)
mapCRUDRepo.create(newModel)
}
}
}
jobs.forEach {
println("joining job ${it.hashCode()}")
it.join()
}
// validating the map
val validationJobs = List(base) { id ->
launch {
val idsList = getIdRange(id, base).toMutableList()
val mapCRUDRepo = MapCRUDRepo<TestModel, Int, TestModel>(
targetMap,
// these will not be used
createCallback = { new ->
val newObject = idsList.first() to new
idsList.remove(newObject.first)
println("created $newObject in map")
newObject
},
updateCallback = { new, id, old ->
println("updated object at $id from $old to $new")
new
}
)
for (i in getIdRange(id, base)) {
val newModel = TestModel(
testery = "testery$i",
isTestery = i % 2 == 0,
testeryAmount = i
)
val oldModel = mapCRUDRepo.getById(i)
assertEquals(newModel, oldModel)
}
}
}
validationJobs.forEach {
println("joining validation job ${it.hashCode()}")
it.join()
}
}
@Test
fun updateMapCrudRepoTest() = runTest {
val base = 10 // define a bigger number to increase test intensity
val targetMap = mutableMapOf<Int, TestModel>()
// fill the map using stdlib method
repeat(base * base) { num ->
targetMap[num] = TestModel(
testery = "testery$num",
isTestery = num % 2 == 0,
testeryAmount = num
)
}
// update the map using MapCRUDRepo
val jobs = List(base) { jobId ->
launch {
println("launching job $jobId")
val idsList = getIdRange(jobId, base).toMutableList()
val mapCRUDRepo = MapCRUDRepo<TestModel, Int, TestModel>(
targetMap,
updateCallback = { new, id, old ->
println("updated object at $id from $old to $new")
new
},
createCallback = { new ->
val newObject = idsList.first() to new
idsList.remove(newObject.first)
println("created $newObject in map")
newObject
}
)
for (id in getIdRange(jobId, base)) {
val newModel = TestModel(
testery = "testery${id}new",
isTestery = id % 2 == 0,
testeryAmount = id
)
mapCRUDRepo.update(id, newModel)
}
}
}
jobs.forEach {
println("joining job ${it.hashCode()}")
it.join()
}
// validating the map
val validationJobs = List(base) { jobId ->
launch {
val idsList = getIdRange(jobId, base).toMutableList()
val mapCRUDRepo = MapCRUDRepo<TestModel, Int, TestModel>(
targetMap,
updateCallback = { new, id, old ->
println("updated object at $id from $old to $new")
new
},
createCallback = { new ->
val newObject = idsList.first() to new
idsList.remove(newObject.first)
println("created $newObject in map")
newObject
}
)
for (i in getIdRange(jobId, base)) {
val newModel = TestModel(
testery = "testery${i}new",
isTestery = i % 2 == 0,
testeryAmount = i
)
val oldModel = mapCRUDRepo.getById(i)
assertEquals(newModel, oldModel)
}
}
}
validationJobs.forEach {
println("joining validation job ${it.hashCode()}")
it.join()
}
}
@Test
fun deleteMapCrudRepoTest() = runTest {
val base = 10 // define a bigger number to increase test intensity
val targetMap = mutableMapOf<Int, TestModel>()
// fill the map using stdlib methods
repeat(base * base) { num ->
targetMap[num] = TestModel(
testery = "testery$num",
isTestery = num % 2 == 0,
testeryAmount = num
)
}
// delete every even element from the map
val jobs = List(base) { jobId ->
launch {
val idsList = getIdRange(jobId, base).toMutableList()
println("idsList: $idsList")
val mapCRUDRepo = MapCRUDRepo<TestModel, Int, TestModel>(
targetMap,
// these will not be used
createCallback = { new ->
val newObject = idsList.first() to new
idsList.remove(newObject.first)
println("created $newObject in map")
newObject
},
updateCallback = { new, id, old ->
println("updated object at $id from $old to $new")
new
}
)
for (id in getIdRange(jobId, base)) {
if (id % 2 == 0 /* testery.isTestery */) {
println("deleting $id")
mapCRUDRepo.deleteById(id)
}
}
}
}
jobs.forEach {
println("joining job ${it.hashCode()}")
it.join()
}
// validating the map
val validationJobs = List(base) { id ->
launch {
val idsList = getIdRange(id, base).toMutableList()
val mapCRUDRepo = MapCRUDRepo<TestModel, Int, TestModel>(
targetMap,
// these will not be used
createCallback = { new ->
val newObject = idsList.first() to new
idsList.remove(newObject.first)
println("created $newObject in map")
newObject
},
updateCallback = { new, id, old ->
println("updated object at $id from $old to $new")
new
}
)
for (id in getIdRange(id, base)) {
val newModel = TestModel(
testery = "testery${id}",
isTestery = id % 2 == 0,
testeryAmount = id
)
val oldModel = mapCRUDRepo.getById(id)
assertEquals(if (newModel.isTestery) null else newModel, oldModel)
}
}
}
validationJobs.forEach {
println("joining validation job ${it.hashCode()}")
it.join()
}
}
}