Rename KrescentEventsTable to KrescentEventLogTable and update references throughout the codebase and update constructor signature to match the publisher

Author: helightdev

krescent-exposed/src/main/kotlin/dev/helight/krescent/exposed/ExposedEventPublisher.kt

@@ -10,7 +10,7 @@ import kotlin.time.ExperimentalTime
 class ExposedEventPublisher(
     val database: Database,
     val streamId: String,
-    val table: KrescentEventsTable = KrescentEventsTable(),
+    val table: KrescentEventLogTable = KrescentEventLogTable(),
 ) : EventPublisher {
     @OptIn(ExperimentalTime::class)
     override suspend fun publish(event: EventMessage) {

krescent-exposed/src/main/kotlin/dev/helight/krescent/exposed/ExposedEventSource.kt

@@ -16,8 +16,8 @@ import kotlin.time.ExperimentalTime
 @OptIn(ExperimentalTime::class)
 class ExposedEventSource(
     val database: Database,
-    val table: KrescentEventsTable = KrescentEventsTable(),
     val streamId: String? = null,
+    val table: KrescentEventLogTable = KrescentEventLogTable(),
     val streamIdMatcher: StreamIdMatcher = StreamIdMatcher.EQ,
     val eventFilter: StreamEventFilter? = null,
     val batchSize: Int = 20,

krescent-exposed/src/main/kotlin/dev/helight/krescent/exposed/ExposedStreamingToken.kt

@@ -32,7 +32,7 @@ sealed class ExposedStreamingToken : StreamingToken<ExposedStreamingToken> {
     class HeadToken : ExposedStreamingToken()
     data class PositionToken(val pos: Long) : ExposedStreamingToken()
 
-    fun begin(table: KrescentEventsTable): Query {
+    fun begin(table: KrescentEventLogTable): Query {
         val query = table.selectAll()
         return when (this) {
             is HeadToken -> query.orderBy(table.id)

…/krescent/exposed/KrescentEventsTable.kt …rescent/exposed/KrescentEventLogTable.ktkrescent-exposed/src/main/kotlin/dev/helight/krescent/exposed/KrescentEventsTable.kt renamed to krescent-exposed/src/main/kotlin/dev/helight/krescent/exposed/KrescentEventLogTable.kt krescent-exposed/src/main/kotlin/dev/helight/krescent/exposed/KrescentEventsTable.kt renamed to krescent-exposed/src/main/kotlin/dev/helight/krescent/exposed/KrescentEventLogTable.kt

@@ -15,7 +15,7 @@ import org.jetbrains.exposed.sql.upsert
 import kotlin.time.ExperimentalTime
 
 @OptIn(ExperimentalTime::class)
-class KrescentEventsTable(tableName: String = "krescent") : LongIdTable(tableName) {
+class KrescentEventLogTable(tableName: String = "krescent") : LongIdTable(tableName) {
     val uid = uuid("uuid").uniqueIndex()
     val streamId = text("streamId").index()
     val type = text("type").index()
@@ -28,11 +28,11 @@ class KrescentEventsTable(tableName: String = "krescent") : LongIdTable(tableNam
     })
 
     suspend fun create(database: Database) {
-        jdbcSuspendTransaction(database) { SchemaUtils.create(this@KrescentEventsTable) }
+        jdbcSuspendTransaction(database) { SchemaUtils.create(this@KrescentEventLogTable) }
     }
 
     suspend fun drop(database: Database) {
-        jdbcSuspendTransaction(database) { SchemaUtils.drop(this@KrescentEventsTable) }
+        jdbcSuspendTransaction(database) { SchemaUtils.drop(this@KrescentEventLogTable) }
     }
 }
 

krescent-exposed/src/test/kotlin/dev/helight/krescent/exposed/ExposedTableProjectorTest.kt

@@ -51,11 +51,11 @@ class ExposedTableProjectorTest {
         )
     }
 
-    fun execWithTable(block: suspend CoroutineScope.(Database, KrescentEventsTable) -> Unit) = runBlocking {
+    fun execWithTable(block: suspend CoroutineScope.(Database, KrescentEventLogTable) -> Unit) = runBlocking {
         mutex.withLock {
             val db = connect()
             val tableName = "krescent_${UUID.randomUUID()}"
-            val table = KrescentEventsTable(tableName)
+            val table = KrescentEventLogTable(tableName)
             table.create(db)
             try {
                 this.block(db, table)

krescent-exposed/src/test/kotlin/dev/helight/krescent/exposed/PostgresStreamingSource.kt

@@ -45,10 +45,10 @@ class PostgresStreamingSource : StreamingEventSourceContract {
         )
     }
 
-    fun execWithTable(block: suspend CoroutineScope.(Database, KrescentEventsTable) -> Unit) = runBlocking {
+    fun execWithTable(block: suspend CoroutineScope.(Database, KrescentEventLogTable) -> Unit) = runBlocking {
         val db = connect()
         val tableName = "krescent_${UUID.randomUUID()}"
-        val table = KrescentEventsTable(tableName)
+        val table = KrescentEventLogTable(tableName)
         table.create(db)
         try {
             this.block(db, table)
@@ -60,7 +60,7 @@ class PostgresStreamingSource : StreamingEventSourceContract {
 
     override fun execWithStreamingSource(block: suspend CoroutineScope.(StreamingEventSource, EventPublisher) -> Unit) =
         execWithTable { db, table ->
-            val source = ExposedEventSource(db, table).polling()
+            val source = ExposedEventSource(db, table = table).polling()
             val publisher = ExposedEventPublisher(db, "default", table)
             this.block(source, publisher)
         }
@@ -77,9 +77,9 @@ class PostgresStreamingSource : StreamingEventSourceContract {
         ExposedEventPublisher(db, "user-ALICE-conversation-2", table)
             .publish(EventMessage(type = "created", payload = buildJsonObject { put("number", 3) }))
 
-        val aliceEvents = ExposedEventSource(db, table, "user-ALICE-conversation-%", StreamIdMatcher.LIKE)
+        val aliceEvents = ExposedEventSource(db, "user-ALICE-conversation-%", table, StreamIdMatcher.LIKE)
             .fetchEventsAfter().toList()
-        val bobEvents = ExposedEventSource(db, table, "user-BOB-conversation-%", StreamIdMatcher.LIKE)
+        val bobEvents = ExposedEventSource(db, "user-BOB-conversation-%", table, StreamIdMatcher.LIKE)
             .fetchEventsAfter().toList()
 
         assertEquals(2, aliceEvents.size)
@@ -97,9 +97,9 @@ class PostgresStreamingSource : StreamingEventSourceContract {
         ExposedEventPublisher(db, "user-ALICE-conversation-2", table)
             .publish(EventMessage(type = "created", payload = buildJsonObject { put("number", 3) }))
 
-        val aliceEvents = ExposedEventSource(db, table, "^user-ALICE-conversation-.*", StreamIdMatcher.REGEX)
+        val aliceEvents = ExposedEventSource(db, "^user-ALICE-conversation-.*", table, StreamIdMatcher.REGEX)
             .fetchEventsAfter().toList()
-        val bobEvents = ExposedEventSource(db, table, "^user-BOB-conversation-.*", StreamIdMatcher.REGEX)
+        val bobEvents = ExposedEventSource(db, "^user-BOB-conversation-.*", table, StreamIdMatcher.REGEX)
             .fetchEventsAfter().toList()
 
         assertEquals(2, aliceEvents.size)
@@ -115,13 +115,13 @@ class PostgresStreamingSource : StreamingEventSourceContract {
         publisher.publish(exampleCatalog.create(EventC(4)))
 
         val regexReceived = ExposedEventSource(
-            db, table, "event-stream",
+            db, "event-stream", table,
             eventFilter = StreamEventFilter.fromRegex(exampleCatalog, "^main.*$".toRegex())
         ).fetchEventsAfter().toList()
         assertEquals(2, regexReceived.count())
 
         val listReceived = ExposedEventSource(
-            db, table, "event-stream",
+            db, "event-stream", table,
             eventFilter = StreamEventFilter.fromTypes(exampleCatalog, EventB::class, EventC::class),
         ).fetchEventsAfter().toList()
         assertEquals(3, listReceived.count())