iktdev/eventi
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases 40 Wiki Activity

Adjusted test classes

Browse Source
This commit is contained in:
Brage Skjønborg 2026-01-31 17:39:51 +01:00
parent dd40f7f726
commit f5cc32487f
5 changed files with 4 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
src/test/kotlin/no/iktdev/eventi/events/RunSimulationTest.kt
View File

@ -234,7 +234,6 @@ class RunSimulationTestTest {
""")
fun pollerProcessesEventsArrivingWhileQueueBusy() = runTest(testDispatcher) {
val ref = UUID.randomUUID()
val t1 = Instant.parse("2026-01-22T12:00:00Z")
persistEvent(ref)

5
src/test/kotlin/no/iktdev/eventi/events/poller/PollerStartLoopTest.kt
View File

@ -102,7 +102,6 @@ class PollerStartLoopTest : TestBase() {
""")
fun `poller resets backoff when events appear`() = runTest {
poller.startFor(iterations = 5)
val before = poller.backoff
val ref = UUID.randomUUID()
persistAt(ref, MyTime.utcNow())
@ -406,7 +405,7 @@ class PollerStartLoopTest : TestBase() {
// Fake EventStore som alltid returnerer samme event
val fakeStore = object : EventStore {
override fun getPersistedEventsAfter(ts: Instant): List<PersistedEvent> {
override fun getPersistedEventsAfter(timestamp: Instant): List<PersistedEvent> {
// Alltid returner én event som ligger før watermark
return listOf(
PersistedEvent(
@ -420,7 +419,7 @@ class PollerStartLoopTest : TestBase() {
)
}
override fun getPersistedEventsFor(ref: UUID): List<PersistedEvent> = emptyList()
override fun getPersistedEventsFor(referenceId: UUID): List<PersistedEvent> = emptyList()
override fun persist(event: Event) = Unit
}

3
src/test/kotlin/no/iktdev/eventi/events/poller/TestablePoller.kt
View File

@ -2,13 +2,12 @@ package no.iktdev.eventi.events.poller
import kotlinx.coroutines.ExperimentalCoroutinesApi
import kotlinx.coroutines.test.TestScope
import kotlinx.coroutines.test.advanceTimeBy
import no.iktdev.eventi.events.EventDispatcher
import no.iktdev.eventi.events.EventPollerImplementation
import no.iktdev.eventi.events.SequenceDispatchQueue
import no.iktdev.eventi.stores.EventStore
import java.time.Instant
import java.util.UUID
import java.util.*
@ExperimentalCoroutinesApi
class TestablePoller(

2
src/test/kotlin/no/iktdev/eventi/testUtil/TaskListenerRegistryUtil.kt
View File

@ -1,7 +1,5 @@
package no.iktdev.eventi.testUtil
import no.iktdev.eventi.events.EventListener
import no.iktdev.eventi.events.EventListenerRegistry
import no.iktdev.eventi.tasks.TaskListener
import no.iktdev.eventi.tasks.TaskListenerRegistry
import org.assertj.core.api.Assertions.assertThat

3
src/test/kotlin/no/iktdev/eventi/testUtil/TaskTypeRegistryUtil.kt
View File

@ -1,12 +1,11 @@
package no.iktdev.eventi.testUtil
import no.iktdev.eventi.events.EventTypeRegistry
import no.iktdev.eventi.models.Event
import no.iktdev.eventi.models.Task
import no.iktdev.eventi.tasks.TaskTypeRegistry
import org.junit.jupiter.api.Assertions.assertNull
import java.lang.reflect.Field
@Suppress("UNUSED_RECEIVER_PARAMETER")
fun TaskTypeRegistry.wipe() {
val field: Field = TaskTypeRegistry::class.java
.superclass