Update EventStoreDBRepository to use a consistent stream name format and bump kcqrs-core/test versions to 0.2.10-SNAPSHOT

Author: abaddon

gradle/libs.versions.toml

@@ -6,8 +6,8 @@
 kotlin = "2.1.20"
 kotlinxCoroutines = "1.10.2"
 
-kcqrs-core = "0.2.9"
-kcqrs-test = "0.2.9"
+kcqrs-core = "0.2.10-SNAPSHOT"
+kcqrs-test = "0.2.10-SNAPSHOT"
 
 kurrentdb-client = "1.0.3"
 jacksonModuleKotlin = "2.16.1"

src/main/kotlin/io/github/abaddon/kcqrs/eventstoredb/eventstore/EventStoreDBRepository.kt

@@ -6,7 +6,12 @@ import io.github.abaddon.kcqrs.core.IIdentity
 import io.github.abaddon.kcqrs.core.domain.messages.events.IDomainEvent
 import io.github.abaddon.kcqrs.core.helpers.KcqrsLoggerFactory.log
 import io.github.abaddon.kcqrs.core.persistence.EventStoreRepository
-import io.kurrent.dbclient.*
+import io.kurrent.dbclient.AppendToStreamOptions
+import io.kurrent.dbclient.KurrentDBClient
+import io.kurrent.dbclient.ReadStreamOptions
+import io.kurrent.dbclient.ResolvedEvent
+import io.kurrent.dbclient.StreamNotFoundException
+import io.kurrent.dbclient.StreamState
 import kotlinx.coroutines.flow.Flow
 import kotlinx.coroutines.flow.asFlow
 import java.security.InvalidParameterException
@@ -100,7 +105,7 @@ class EventStoreDBRepository<TAggregate : IAggregate>(
 
     override fun aggregateIdStreamName(aggregateId: IIdentity): String {
         check(streamName.isNotEmpty()) { throw InvalidParameterException("Cannot get streamName empty") }
-        return streamName
+        return "$streamName.${aggregateId.valueAsString()}"
     }
 
     override suspend fun persist(

src/test/kotlin/io/github/abaddon/kcqrs/eventstoredb/eventstore/EventStoreDBRepositoryTest.kt

@@ -17,7 +17,7 @@ import kotlin.test.assertEquals
 @ExperimentalCoroutinesApi
 internal class EventStoreDBRepositoryTest : WithEventStoreDBContainer() {
     companion object {
-        private const val STREAM_NAME_PREFIX = "CounterAggregateRoot"
+        private const val STREAM_NAME = "CounterAggregateRoot"
     }
 
     private val testDispatcher = UnconfinedTestDispatcher()
@@ -29,10 +29,8 @@ internal class EventStoreDBRepositoryTest : WithEventStoreDBContainer() {
 
     @BeforeEach
     fun setUp() {
-        // Use a unique stream name for each test to prevent event pollution
-        val uniqueStreamName = "$STREAM_NAME_PREFIX-${UUID.randomUUID()}"
         val connectionString = "kurrentdb://127.0.0.1:${container.getMappedPort(2113)}?tls=false&tlsVerifyCert=false"
-        repositoryConfig = EventStoreDBRepositoryConfig(EventStoreDBConfig(connectionString), uniqueStreamName, 500, 500)
+        repositoryConfig = EventStoreDBRepositoryConfig(EventStoreDBConfig(connectionString), STREAM_NAME, 500, 500)
         repository = EventStoreDBRepository(
             repositoryConfig,
             { CounterAggregateRoot(it as CounterAggregateId) }
@@ -143,8 +141,7 @@ internal class EventStoreDBRepositoryTest : WithEventStoreDBContainer() {
             val streamName = repository.aggregateIdStreamName(aggregateId)
 
             // Then
-            // Stream name should not contain the aggregate ID
-            assertEquals(repositoryConfig.streamName, streamName)
+            assertEquals("$STREAM_NAME.${aggregateId.valueAsString()}", streamName)
         }
 
     @Test