InsanusMokrassar/MicroUtils
1
0
Fork 0
mirror of https://github.com/InsanusMokrassar/MicroUtils.git synced 2024-11-22 16:23:50 +00:00
Code Issues Packages Projects Releases Wiki Activity

added deletion test

Browse Source
This commit is contained in:
bpavuk 2024-08-03 11:58:19 +03:00
parent 0865faa1d8
commit d325cfd298
1 changed files with 101 additions and 18 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

119
repos/inmemory/src/commonTest/kotlin/MapCRUDRepoTest.kt
View File

@ -26,12 +26,12 @@ class MapCRUDRepoTest {
val targetMap = mutableMapOf<Int, TestModel>()
// filling the map
val jobs = List(base) { id ->
val jobs = List(base) { jobId ->
launch(Dispatchers.Default) { // to make delays work
println("launching job $id")
println("launching job $jobId")
delay((1..5).random().toLong())
val idsList = getIdRange(id, base).toMutableList()
val idsList = getIdRange(jobId, base).toMutableList()
println("created ids list $idsList")
val mapCRUDRepo = MapCRUDRepo<TestModel, Int, TestModel>(
targetMap,
@ -46,11 +46,11 @@ class MapCRUDRepoTest {
new
}
)
for (i in getIdRange(id, base)) {
for (id in getIdRange(jobId, base)) {
val newModel = TestModel(
testery = "testery$i",
isTestery = i % 2 == 0,
testeryAmount = i
testery = "testery$id",
isTestery = id % 2 == 0,
testeryAmount = id
)
mapCRUDRepo.create(newModel)
}
@ -113,10 +113,10 @@ class MapCRUDRepoTest {
}
// update the map using MapCRUDRepo
val jobs = List(base) { id ->
val jobs = List(base) { jobId ->
launch {
println("launching job $id")
val idsList = getIdRange(id, base).toMutableList()
println("launching job $jobId")
val idsList = getIdRange(jobId, base).toMutableList()
val mapCRUDRepo = MapCRUDRepo<TestModel, Int, TestModel>(
targetMap,
updateCallback = { new, id, old ->
@ -130,13 +130,13 @@ class MapCRUDRepoTest {
newObject
}
)
for (i in getIdRange(id, base)) {
for (id in getIdRange(jobId, base)) {
val newModel = TestModel(
testery = "testery${i}new",
isTestery = i % 2 == 0,
testeryAmount = i
testery = "testery${id}new",
isTestery = id % 2 == 0,
testeryAmount = id
)
mapCRUDRepo.update(i, newModel)
mapCRUDRepo.update(id, newModel)
}
}
}
@ -147,9 +147,9 @@ class MapCRUDRepoTest {
}
// validating the map
val validationJobs = List(base) { id ->
val validationJobs = List(base) { jobId ->
launch {
val idsList = getIdRange(id, base).toMutableList()
val idsList = getIdRange(jobId, base).toMutableList()
val mapCRUDRepo = MapCRUDRepo<TestModel, Int, TestModel>(
targetMap,
updateCallback = { new, id, old ->
@ -163,7 +163,7 @@ class MapCRUDRepoTest {
newObject
}
)
for (i in getIdRange(id, base)) {
for (i in getIdRange(jobId, base)) {
val newModel = TestModel(
testery = "testery${i}new",
isTestery = i % 2 == 0,
@ -180,4 +180,87 @@ class MapCRUDRepoTest {
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()
}
}
}