renamed to ViewProjector

rodolfodpk · Jan 10, 2025 · 9c07a0e · 9c07a0e
1 parent 4ac2431
commit 9c07a0e
Show file tree

Hide file tree

Showing 3 changed files with 5 additions and 5 deletions.
diff --git a/src/main/kotlin/crablet/query/CrabletQueryApi.kt b/src/main/kotlin/crablet/query/CrabletQueryApi.kt
@@ -11,7 +11,7 @@ data class SubscriptionSource(
     val maxNumberOfRowsToPull: Int = 250,
 )
 
-interface EventViewProjector {
+interface ViewProjector {
     fun project(
         sqlConnection: SqlConnection,
         eventAsJson: JsonObject,
@@ -20,7 +20,7 @@ interface EventViewProjector {
 
 class SubscriptionConfig(
     val source: SubscriptionSource,
-    val eventViewProjector: EventViewProjector,
+    val viewProjector: ViewProjector,
     val callback: (() -> Unit)? = null,
 )
 

diff --git a/src/main/kotlin/crablet/query/impl/SubscriptionComponent.kt b/src/main/kotlin/crablet/query/impl/SubscriptionComponent.kt
@@ -30,7 +30,7 @@ class SubscriptionComponent(
                     }.flatMap { jsonList: List<JsonObject> ->
                         jsonList
                             .fold(Future.succeededFuture<Void>()) { future, eventJson ->
-                                future.compose { subscriptionConfig.eventViewProjector.project(tx, eventJson) }
+                                future.compose { subscriptionConfig.viewProjector.project(tx, eventJson) }
                             }.map { jsonList }
                     }.compose { jsonList: List<JsonObject> ->
                         if (jsonList.isNotEmpty()) {

diff --git a/src/test/kotlin/crablet/query/AccountsViewProjectionTest.kt b/src/test/kotlin/crablet/query/AccountsViewProjectionTest.kt
@@ -193,7 +193,7 @@ class AccountsViewProjectionTest : AbstractCrabletTest() {
 
             val source = SubscriptionSource(name = "accounts-view", eventTypes = eventTypes)
 
-            class AccountsViewProjector : EventViewProjector {
+            class AccountsViewProjector : ViewProjector {
                 override fun project(sqlConnection: SqlConnection, eventAsJson: JsonObject): Future<Void> {
                     val eventPayload = eventAsJson.getJsonObject("event_payload")
 
@@ -231,7 +231,7 @@ class AccountsViewProjectionTest : AbstractCrabletTest() {
 
             val subscriptionConfig = SubscriptionConfig(
                 source = source,
-                eventViewProjector = AccountsViewProjector(),
+                viewProjector = AccountsViewProjector(),
                 callback = { latch.countDown() })
             container.addSubscription(
                 subscriptionConfig = subscriptionConfig,