SubscriptionCommand moved to api file

rodolfodpk · Jan 15, 2025 · 44e4026 · 44e4026
1 parent 584cb1a
commit 44e4026
Show file tree

Hide file tree

Showing 9 changed files with 13 additions and 18 deletions.
diff --git a/src/main/kotlin/crablet/query/CrabletQueryApi.kt b/src/main/kotlin/crablet/query/CrabletQueryApi.kt
@@ -1,7 +1,6 @@
 package crablet.query
 
 import crablet.EventName
-import crablet.query.impl.SubscriptionCommand
 import io.vertx.core.Future
 import io.vertx.core.json.JsonObject
 import io.vertx.sqlclient.SqlConnection
@@ -69,3 +68,10 @@ interface SubscriptionsContainer {
         command: SubscriptionCommand,
     ): JsonObject
 }
+
+enum class SubscriptionCommand {
+    TRY_PERFORM_NOW,
+    PAUSE,
+    RESUME,
+    SHOW_STATUS,
+}
diff --git a/src/main/kotlin/crablet/query/impl/CrabletSubscriptionsContainer.kt b/src/main/kotlin/crablet/query/impl/CrabletSubscriptionsContainer.kt
@@ -1,6 +1,7 @@
 package crablet.query.impl
 
 import crablet.query.IntervalConfig
+import crablet.query.SubscriptionCommand
 import crablet.query.SubscriptionConfig
 import crablet.query.SubscriptionsContainer
 import io.vertx.core.DeploymentOptions

diff --git a/src/main/kotlin/crablet/query/impl/SubscriptionCommand.kt b/src/main/kotlin/crablet/query/impl/SubscriptionCommand.kt
diff --git a/src/main/kotlin/crablet/query/impl/SubscriptionVerticle.kt b/src/main/kotlin/crablet/query/impl/SubscriptionVerticle.kt
@@ -1,11 +1,12 @@
 package crablet.query.impl
 
 import crablet.query.IntervalConfig
+import crablet.query.SubscriptionCommand
+import crablet.query.SubscriptionCommand.PAUSE
+import crablet.query.SubscriptionCommand.RESUME
+import crablet.query.SubscriptionCommand.SHOW_STATUS
+import crablet.query.SubscriptionCommand.TRY_PERFORM_NOW
 import crablet.query.SubscriptionConfig
-import crablet.query.impl.SubscriptionCommand.PAUSE
-import crablet.query.impl.SubscriptionCommand.RESUME
-import crablet.query.impl.SubscriptionCommand.SHOW_STATUS
-import crablet.query.impl.SubscriptionCommand.TRY_PERFORM_NOW
 import io.vertx.core.AbstractVerticle
 import io.vertx.core.Future
 import io.vertx.core.eventbus.Message

diff --git a/src/test/kotlin/crablet/query/AccountsPgBatchSinkIT.kt b/src/test/kotlin/crablet/query/AccountsPgBatchSinkIT.kt
@@ -13,7 +13,6 @@ import crablet.command.TransactionContext
 import crablet.command.impl.CrabletEventsAppender
 import crablet.command.impl.CrabletStateBuilder
 import crablet.query.impl.CrabletSubscriptionsContainer
-import crablet.query.impl.SubscriptionCommand
 import crablet.query.sinks.AccountsPostgresBatchEventSink
 import io.kotest.matchers.ints.shouldBeExactly
 import io.kotest.matchers.longs.shouldBeExactly

diff --git a/src/test/kotlin/crablet/query/AccountsPgSingleSinkIT.kt b/src/test/kotlin/crablet/query/AccountsPgSingleSinkIT.kt
@@ -13,7 +13,6 @@ import crablet.command.TransactionContext
 import crablet.command.impl.CrabletEventsAppender
 import crablet.command.impl.CrabletStateBuilder
 import crablet.query.impl.CrabletSubscriptionsContainer
-import crablet.query.impl.SubscriptionCommand
 import crablet.query.sinks.AccountsPostgresSingleEventSink
 import io.kotest.matchers.ints.shouldBeExactly
 import io.kotest.matchers.longs.shouldBeExactly

diff --git a/src/test/kotlin/crablet/query/AccountsSingleSinkIT.kt b/src/test/kotlin/crablet/query/AccountsSingleSinkIT.kt
@@ -13,7 +13,6 @@ import crablet.command.TransactionContext
 import crablet.command.impl.CrabletEventsAppender
 import crablet.command.impl.CrabletStateBuilder
 import crablet.query.impl.CrabletSubscriptionsContainer
-import crablet.query.impl.SubscriptionCommand
 import io.kotest.matchers.ints.shouldBeExactly
 import io.kotest.matchers.longs.shouldBeExactly
 import io.kotest.matchers.shouldBe

diff --git a/src/test/kotlin/crablet/query/AccountsViewProjectionTest.kt b/src/test/kotlin/crablet/query/AccountsViewProjectionTest.kt
@@ -13,7 +13,6 @@ import crablet.command.TransactionContext
 import crablet.command.impl.CrabletEventsAppender
 import crablet.command.impl.CrabletStateBuilder
 import crablet.query.impl.CrabletSubscriptionsContainer
-import crablet.query.impl.SubscriptionCommand
 import crablet.query.sinks.AccountsPostgresSingleEventSink
 import io.kotest.matchers.ints.shouldBeExactly
 import io.kotest.matchers.longs.shouldBeExactly

diff --git a/src/test/kotlin/crablet/query/SubscriptionLifecycleIT.kt b/src/test/kotlin/crablet/query/SubscriptionLifecycleIT.kt
@@ -9,7 +9,6 @@ import crablet.command.AppendCondition
 import crablet.command.impl.CrabletEventsAppender
 import crablet.command.impl.CrabletStateBuilder
 import crablet.query.impl.CrabletSubscriptionsContainer
-import crablet.query.impl.SubscriptionCommand
 import io.kotest.matchers.ints.shouldBeExactly
 import io.kotest.matchers.longs.shouldBeExactly
 import io.kotest.matchers.nulls.shouldNotBeNull