diff --git a/core/approvals/src/main/kotlin/com/correx/core/approvals/DefaultApprovalReducer.kt b/core/approvals/src/main/kotlin/com/correx/core/approvals/DefaultApprovalReducer.kt index f3148d49..fa931292 100644 --- a/core/approvals/src/main/kotlin/com/correx/core/approvals/DefaultApprovalReducer.kt +++ b/core/approvals/src/main/kotlin/com/correx/core/approvals/DefaultApprovalReducer.kt @@ -3,9 +3,9 @@ package com.correx.core.approvals import com.correx.core.approvals.model.ApprovalContext import com.correx.core.approvals.model.ApprovalDecision import com.correx.core.approvals.model.ApprovalGrant -import com.correx.core.approvals.model.DomainApprovalRequest import com.correx.core.approvals.model.ApprovalScopeIdentity import com.correx.core.approvals.model.ApprovalState +import com.correx.core.approvals.model.DomainApprovalRequest import com.correx.core.events.events.ApprovalDecisionResolvedEvent import com.correx.core.events.events.ApprovalGrantCreatedEvent import com.correx.core.events.events.ApprovalGrantExpiredEvent diff --git a/core/approvals/src/main/kotlin/com/correx/core/approvals/domain/DefaultApprovalEngine.kt b/core/approvals/src/main/kotlin/com/correx/core/approvals/domain/DefaultApprovalEngine.kt index de785227..c6c75459 100644 --- a/core/approvals/src/main/kotlin/com/correx/core/approvals/domain/DefaultApprovalEngine.kt +++ b/core/approvals/src/main/kotlin/com/correx/core/approvals/domain/DefaultApprovalEngine.kt @@ -1,14 +1,14 @@ package com.correx.core.approvals.domain +import com.correx.core.approvals.ApprovalOutcome +import com.correx.core.approvals.ApprovalStatus +import com.correx.core.approvals.GrantScope import com.correx.core.approvals.Tier import com.correx.core.approvals.isAtMost import com.correx.core.approvals.model.ApprovalContext import com.correx.core.approvals.model.ApprovalDecision import com.correx.core.approvals.model.ApprovalGrant -import com.correx.core.approvals.ApprovalOutcome import com.correx.core.approvals.model.DomainApprovalRequest -import com.correx.core.approvals.ApprovalStatus -import com.correx.core.approvals.GrantScope import com.correx.core.events.types.ApprovalDecisionId import com.correx.core.sessions.ApprovalMode import kotlinx.datetime.Instant diff --git a/core/approvals/src/main/kotlin/com/correx/core/approvals/model/ApprovalScopeIdentity.kt b/core/approvals/src/main/kotlin/com/correx/core/approvals/model/ApprovalScopeIdentity.kt index 65d41bed..0b9f8fae 100644 --- a/core/approvals/src/main/kotlin/com/correx/core/approvals/model/ApprovalScopeIdentity.kt +++ b/core/approvals/src/main/kotlin/com/correx/core/approvals/model/ApprovalScopeIdentity.kt @@ -1,8 +1,8 @@ package com.correx.core.approvals.model import com.correx.core.events.types.ProjectId -import com.correx.core.events.types.StageId import com.correx.core.events.types.SessionId +import com.correx.core.events.types.StageId import kotlinx.serialization.Serializable @Serializable diff --git a/core/approvals/src/test/kotlin/com/correx/core/approvals/DefaultApprovalReducerTest.kt b/core/approvals/src/test/kotlin/com/correx/core/approvals/DefaultApprovalReducerTest.kt index 6fafd371..5d65bc49 100644 --- a/core/approvals/src/test/kotlin/com/correx/core/approvals/DefaultApprovalReducerTest.kt +++ b/core/approvals/src/test/kotlin/com/correx/core/approvals/DefaultApprovalReducerTest.kt @@ -10,8 +10,6 @@ import com.correx.core.events.events.StoredEvent import com.correx.core.events.events.ToolInvokedEvent import com.correx.core.events.types.ApprovalDecisionId import com.correx.core.events.types.ApprovalRequestId -import com.correx.core.approvals.ApprovalOutcome -import com.correx.core.approvals.ApprovalStatus import com.correx.core.events.types.EventId import com.correx.core.events.types.GrantId import com.correx.core.events.types.SessionId diff --git a/core/artifacts/src/main/kotlin/com/correx/core/artifacts/ArtifactProjector.kt b/core/artifacts/src/main/kotlin/com/correx/core/artifacts/ArtifactProjector.kt index 6b8fdeff..980c3ac2 100644 --- a/core/artifacts/src/main/kotlin/com/correx/core/artifacts/ArtifactProjector.kt +++ b/core/artifacts/src/main/kotlin/com/correx/core/artifacts/ArtifactProjector.kt @@ -2,7 +2,7 @@ package com.correx.core.artifacts import com.correx.core.events.events.StoredEvent import com.correx.core.sessions.projections.Projection -import java.util.logging.Logger +import java.util.logging.* class ArtifactProjector(private val reducer: ArtifactReducer) : Projection { diff --git a/core/events/src/main/kotlin/com/correx/core/events/EventDispatcher.kt b/core/events/src/main/kotlin/com/correx/core/events/EventDispatcher.kt index 0a7c5420..c933d38c 100644 --- a/core/events/src/main/kotlin/com/correx/core/events/EventDispatcher.kt +++ b/core/events/src/main/kotlin/com/correx/core/events/EventDispatcher.kt @@ -9,7 +9,7 @@ import com.correx.core.events.types.CorrelationId import com.correx.core.events.types.EventId import com.correx.core.events.types.SessionId import kotlinx.datetime.Clock -import java.util.UUID +import java.util.* class EventDispatcher(private val eventStore: EventStore) { suspend fun emit( diff --git a/core/events/src/main/kotlin/com/correx/core/events/serialization/Serialization.kt b/core/events/src/main/kotlin/com/correx/core/events/serialization/Serialization.kt index 3489bb64..db2f1df3 100644 --- a/core/events/src/main/kotlin/com/correx/core/events/serialization/Serialization.kt +++ b/core/events/src/main/kotlin/com/correx/core/events/serialization/Serialization.kt @@ -21,9 +21,9 @@ import com.correx.core.events.events.InferenceCompletedEvent import com.correx.core.events.events.InferenceFailedEvent import com.correx.core.events.events.InferenceStartedEvent import com.correx.core.events.events.InferenceTimeoutEvent +import com.correx.core.events.events.LayerTruncatedEvent import com.correx.core.events.events.ModelLoadedEvent import com.correx.core.events.events.ModelUnloadedEvent -import com.correx.core.events.events.LayerTruncatedEvent import com.correx.core.events.events.OrchestrationPausedEvent import com.correx.core.events.events.OrchestrationResumedEvent import com.correx.core.events.events.RetryAttemptedEvent @@ -40,8 +40,8 @@ import com.correx.core.events.events.ToolExecutionCompletedEvent import com.correx.core.events.events.ToolExecutionFailedEvent import com.correx.core.events.events.ToolExecutionRejectedEvent import com.correx.core.events.events.ToolExecutionStartedEvent -import com.correx.core.events.events.ToolInvokedEvent import com.correx.core.events.events.ToolInvocationRequestedEvent +import com.correx.core.events.events.ToolInvokedEvent import com.correx.core.events.events.TransitionExecutedEvent import com.correx.core.events.events.WorkflowCompletedEvent import com.correx.core.events.events.WorkflowFailedEvent diff --git a/core/inference/src/main/kotlin/com/correx/core/inference/InferenceReducer.kt b/core/inference/src/main/kotlin/com/correx/core/inference/InferenceReducer.kt index aa7a68dc..ddff3a79 100644 --- a/core/inference/src/main/kotlin/com/correx/core/inference/InferenceReducer.kt +++ b/core/inference/src/main/kotlin/com/correx/core/inference/InferenceReducer.kt @@ -1,7 +1,6 @@ package com.correx.core.inference import com.correx.core.events.events.StoredEvent -import com.correx.core.inference.InferenceState interface InferenceReducer { fun reduce(state: InferenceState, event: StoredEvent): InferenceState diff --git a/core/kernel/src/main/kotlin/com/correx/core/kernel/orchestration/ReplayOrchestrator.kt b/core/kernel/src/main/kotlin/com/correx/core/kernel/orchestration/ReplayOrchestrator.kt index 62d7287d..459b56fb 100644 --- a/core/kernel/src/main/kotlin/com/correx/core/kernel/orchestration/ReplayOrchestrator.kt +++ b/core/kernel/src/main/kotlin/com/correx/core/kernel/orchestration/ReplayOrchestrator.kt @@ -4,11 +4,13 @@ import com.correx.core.approvals.domain.NoOpApprovalEngine import com.correx.core.context.model.ContextPack import com.correx.core.events.events.ArtifactValidatedEvent import com.correx.core.events.events.ArtifactValidatingEvent -import com.correx.core.events.stores.EventStore import com.correx.core.events.types.InferenceRequestId +import com.correx.core.events.types.SessionId +import com.correx.core.events.types.StageId import com.correx.core.inference.GenerationConfig import com.correx.core.inference.InferenceRequest import com.correx.core.kernel.execution.ReplayStrategy +import com.correx.core.kernel.execution.WorkflowResult import com.correx.core.kernel.replay.ReplayInferenceProvider import com.correx.core.kernel.retry.exception.ReplayArtifactMissingException import com.correx.core.risk.NoOpRiskAssessor @@ -16,13 +18,10 @@ import com.correx.core.transitions.execution.StageExecutionResult import com.correx.core.transitions.graph.StageConfig import com.correx.core.transitions.graph.WorkflowGraph import com.correx.core.transitions.resolution.TransitionDecision -import com.correx.core.events.types.SessionId -import com.correx.core.events.types.StageId -import com.correx.core.kernel.execution.WorkflowResult import com.correx.core.validation.model.ValidationContext -import java.util.UUID -import java.util.concurrent.ConcurrentHashMap -import java.util.concurrent.atomic.AtomicBoolean +import java.util.* +import java.util.concurrent.* +import java.util.concurrent.atomic.* private data class ReplayContext( val graph: WorkflowGraph, diff --git a/core/kernel/src/main/kotlin/com/correx/core/kernel/retry/DefaultRetryCoordinator.kt b/core/kernel/src/main/kotlin/com/correx/core/kernel/retry/DefaultRetryCoordinator.kt index f50de8c8..b39394be 100644 --- a/core/kernel/src/main/kotlin/com/correx/core/kernel/retry/DefaultRetryCoordinator.kt +++ b/core/kernel/src/main/kotlin/com/correx/core/kernel/retry/DefaultRetryCoordinator.kt @@ -1,19 +1,16 @@ package com.correx.core.kernel.retry +import com.correx.core.events.events.EventMetadata import com.correx.core.events.events.NewEvent -import com.correx.core.events.execution.RetryPolicy import com.correx.core.events.events.RetryAttemptedEvent -import com.correx.core.events.events.StoredEvent +import com.correx.core.events.execution.RetryPolicy import com.correx.core.events.stores.EventStore import com.correx.core.events.types.EventId import com.correx.core.events.types.SessionId import com.correx.core.events.types.StageId -import com.correx.core.events.events.EventMetadata -import kotlinx.datetime.Clock import kotlinx.coroutines.delay -import java.util.UUID -import kotlin.time.Duration.Companion.milliseconds -import kotlin.coroutines.cancellation.CancellationException +import kotlinx.datetime.Clock +import java.util.* class DefaultRetryCoordinator( private val eventStore: EventStore, diff --git a/core/transitions/src/main/kotlin/com/correx/core/transitions/analysis/DeterministicAdjacencyBuilder.kt b/core/transitions/src/main/kotlin/com/correx/core/transitions/analysis/DeterministicAdjacencyBuilder.kt index 3720a66b..39b267c1 100644 --- a/core/transitions/src/main/kotlin/com/correx/core/transitions/analysis/DeterministicAdjacencyBuilder.kt +++ b/core/transitions/src/main/kotlin/com/correx/core/transitions/analysis/DeterministicAdjacencyBuilder.kt @@ -1,8 +1,8 @@ package com.correx.core.transitions.analysis +import com.correx.core.events.types.StageId import com.correx.core.transitions.graph.TransitionEdge import com.correx.core.transitions.graph.WorkflowGraph -import com.correx.core.events.types.StageId internal class DeterministicAdjacencyBuilder { fun build(graph: WorkflowGraph): Map> { diff --git a/core/transitions/src/main/kotlin/com/correx/core/transitions/execution/StageExecutionRequest.kt b/core/transitions/src/main/kotlin/com/correx/core/transitions/execution/StageExecutionRequest.kt index cd9b175a..85dc7294 100644 --- a/core/transitions/src/main/kotlin/com/correx/core/transitions/execution/StageExecutionRequest.kt +++ b/core/transitions/src/main/kotlin/com/correx/core/transitions/execution/StageExecutionRequest.kt @@ -1,8 +1,8 @@ package com.correx.core.transitions.execution -import com.correx.core.transitions.evaluation.EvaluationContext import com.correx.core.events.types.StageId import com.correx.core.events.types.TransitionId +import com.correx.core.transitions.evaluation.EvaluationContext data class StageExecutionRequest( val sessionId: String, diff --git a/core/transitions/src/main/kotlin/com/correx/core/transitions/mapper/DefaultStageExecutionEventMapper.kt b/core/transitions/src/main/kotlin/com/correx/core/transitions/mapper/DefaultStageExecutionEventMapper.kt index 82dd3e8b..4bab35fb 100644 --- a/core/transitions/src/main/kotlin/com/correx/core/transitions/mapper/DefaultStageExecutionEventMapper.kt +++ b/core/transitions/src/main/kotlin/com/correx/core/transitions/mapper/DefaultStageExecutionEventMapper.kt @@ -4,9 +4,9 @@ import com.correx.core.events.events.EventPayload import com.correx.core.events.events.StageCompletedEvent import com.correx.core.events.events.StageFailedEvent import com.correx.core.events.events.TransitionExecutedEvent +import com.correx.core.events.types.SessionId import com.correx.core.transitions.execution.StageExecutionRequest import com.correx.core.transitions.execution.StageExecutionResult -import com.correx.core.events.types.SessionId class DefaultStageExecutionEventMapper : StageExecutionEventMapper { diff --git a/core/transitions/src/main/kotlin/com/correx/core/transitions/policy/CycleSignature.kt b/core/transitions/src/main/kotlin/com/correx/core/transitions/policy/CycleSignature.kt index f7b10f9b..584542f4 100644 --- a/core/transitions/src/main/kotlin/com/correx/core/transitions/policy/CycleSignature.kt +++ b/core/transitions/src/main/kotlin/com/correx/core/transitions/policy/CycleSignature.kt @@ -1,7 +1,7 @@ package com.correx.core.transitions.policy import com.correx.core.events.types.StageId -import java.util.SortedSet +import java.util.* data class CycleSignature( val nodes: SortedSet, diff --git a/core/transitions/src/main/kotlin/com/correx/core/transitions/policy/CycleSignatureFactory.kt b/core/transitions/src/main/kotlin/com/correx/core/transitions/policy/CycleSignatureFactory.kt index c5314c77..f1b14ce1 100644 --- a/core/transitions/src/main/kotlin/com/correx/core/transitions/policy/CycleSignatureFactory.kt +++ b/core/transitions/src/main/kotlin/com/correx/core/transitions/policy/CycleSignatureFactory.kt @@ -2,7 +2,7 @@ package com.correx.core.transitions.policy import com.correx.core.events.types.StageId import com.correx.core.transitions.graph.TransitionEdge -import java.util.TreeSet +import java.util.* object CycleSignatureFactory { fun from(nodes: List, edges: List): CycleSignature { diff --git a/core/transitions/src/main/kotlin/com/correx/core/transitions/state/CycleDfs.kt b/core/transitions/src/main/kotlin/com/correx/core/transitions/state/CycleDfs.kt index 569f73e0..3184bcee 100644 --- a/core/transitions/src/main/kotlin/com/correx/core/transitions/state/CycleDfs.kt +++ b/core/transitions/src/main/kotlin/com/correx/core/transitions/state/CycleDfs.kt @@ -1,8 +1,8 @@ package com.correx.core.transitions.state +import com.correx.core.events.types.StageId import com.correx.core.transitions.analysis.DetectedCycle import com.correx.core.transitions.graph.TransitionEdge -import com.correx.core.events.types.StageId internal class CycleDfs { fun dfs( diff --git a/core/validation/src/main/kotlin/com/correx/core/validation/semantic/rules/CyclePolicyBindingRule.kt b/core/validation/src/main/kotlin/com/correx/core/validation/semantic/rules/CyclePolicyBindingRule.kt index 6d10b8f0..6f93bdc6 100644 --- a/core/validation/src/main/kotlin/com/correx/core/validation/semantic/rules/CyclePolicyBindingRule.kt +++ b/core/validation/src/main/kotlin/com/correx/core/validation/semantic/rules/CyclePolicyBindingRule.kt @@ -1,6 +1,5 @@ package com.correx.core.validation.semantic.rules -import com.correx.core.transitions.policy.CycleSignature import com.correx.core.transitions.policy.CycleSignatureFactory import com.correx.core.validation.model.ValidationContext import com.correx.core.validation.model.ValidationIssue diff --git a/infrastructure/inference/commons/src/main/kotlin/com/correx/infrastructure/inference/commons/ManagedInferenceProvider.kt b/infrastructure/inference/commons/src/main/kotlin/com/correx/infrastructure/inference/commons/ManagedInferenceProvider.kt index 04cc52cf..0839ffd6 100644 --- a/infrastructure/inference/commons/src/main/kotlin/com/correx/infrastructure/inference/commons/ManagedInferenceProvider.kt +++ b/infrastructure/inference/commons/src/main/kotlin/com/correx/infrastructure/inference/commons/ManagedInferenceProvider.kt @@ -1,8 +1,6 @@ package com.correx.infrastructure.inference.commons -import com.correx.core.events.types.ProviderId import com.correx.core.inference.InferenceProvider -import com.correx.core.inference.Tokenizer /** * A wrapper around [InferenceProvider] that tracks model lifecycle. diff --git a/infrastructure/inference/src/main/kotlin/com/correx/infrastructure/inference/DefaultProviderRegistry.kt b/infrastructure/inference/src/main/kotlin/com/correx/infrastructure/inference/DefaultProviderRegistry.kt index 4207b4eb..888309b1 100644 --- a/infrastructure/inference/src/main/kotlin/com/correx/infrastructure/inference/DefaultProviderRegistry.kt +++ b/infrastructure/inference/src/main/kotlin/com/correx/infrastructure/inference/DefaultProviderRegistry.kt @@ -5,7 +5,7 @@ import com.correx.core.inference.InferenceProvider import com.correx.core.inference.ModelCapability import com.correx.core.inference.ProviderHealth import com.correx.core.inference.ProviderRegistry -import java.util.concurrent.CopyOnWriteArrayList +import java.util.concurrent.* /** * In-memory [ProviderRegistry] backed by a [CopyOnWriteArrayList] for safe concurrent reads. diff --git a/infrastructure/inference/src/main/kotlin/com/correx/infrastructure/inference/FirstAvailableRoutingStrategy.kt b/infrastructure/inference/src/main/kotlin/com/correx/infrastructure/inference/FirstAvailableRoutingStrategy.kt index c1ee5552..4cffb7e9 100644 --- a/infrastructure/inference/src/main/kotlin/com/correx/infrastructure/inference/FirstAvailableRoutingStrategy.kt +++ b/infrastructure/inference/src/main/kotlin/com/correx/infrastructure/inference/FirstAvailableRoutingStrategy.kt @@ -1,10 +1,10 @@ package com.correx.infrastructure.inference +import com.correx.core.events.types.StageId import com.correx.core.inference.InferenceProvider import com.correx.core.inference.ModelCapability import com.correx.core.inference.NoEligibleProviderException import com.correx.core.inference.RoutingStrategy -import com.correx.core.events.types.StageId /** * Selects the first [InferenceProvider] from [candidates] whose declared capabilities diff --git a/infrastructure/inference/src/test/kotlin/com/correx/infrastructure/inference/DefaultProviderRegistryTest.kt b/infrastructure/inference/src/test/kotlin/com/correx/infrastructure/inference/DefaultProviderRegistryTest.kt index 468a32c6..a5bafed1 100644 --- a/infrastructure/inference/src/test/kotlin/com/correx/infrastructure/inference/DefaultProviderRegistryTest.kt +++ b/infrastructure/inference/src/test/kotlin/com/correx/infrastructure/inference/DefaultProviderRegistryTest.kt @@ -7,8 +7,8 @@ import com.correx.core.inference.InferenceRequest import com.correx.core.inference.InferenceResponse import com.correx.core.inference.ModelCapability import com.correx.core.inference.ProviderHealth -import com.correx.core.inference.Tokenizer import com.correx.core.inference.Token +import com.correx.core.inference.Tokenizer import com.correx.core.utils.TypeId import kotlinx.coroutines.test.runTest import org.junit.jupiter.api.Assertions.assertEquals diff --git a/infrastructure/persistence/src/test/kotlin/com/correx/infrastructure/persistence/InMemoryEventStoreTest.kt b/infrastructure/persistence/src/test/kotlin/com/correx/infrastructure/persistence/InMemoryEventStoreTest.kt index ce965321..b9d13142 100644 --- a/infrastructure/persistence/src/test/kotlin/com/correx/infrastructure/persistence/InMemoryEventStoreTest.kt +++ b/infrastructure/persistence/src/test/kotlin/com/correx/infrastructure/persistence/InMemoryEventStoreTest.kt @@ -1,7 +1,7 @@ package com.correx.infrastructure.persistence -import com.correx.testing.contracts.fixtures.events.store.EventStoreContractTest import com.correx.core.events.stores.EventStore +import com.correx.testing.contracts.fixtures.events.store.EventStoreContractTest class InMemoryEventStoreTest : EventStoreContractTest() { override fun store(): EventStore = InMemoryEventStore() diff --git a/infrastructure/persistence/src/test/kotlin/com/correx/infrastructure/persistence/InMemoryReplayTest.kt b/infrastructure/persistence/src/test/kotlin/com/correx/infrastructure/persistence/InMemoryReplayTest.kt index 120d8c96..b63a46a6 100644 --- a/infrastructure/persistence/src/test/kotlin/com/correx/infrastructure/persistence/InMemoryReplayTest.kt +++ b/infrastructure/persistence/src/test/kotlin/com/correx/infrastructure/persistence/InMemoryReplayTest.kt @@ -1,10 +1,10 @@ package com.correx.infrastructure.persistence import com.correx.core.events.stores.EventStore -import com.correx.core.sessions.projections.replay.DefaultEventReplayer -import com.correx.core.sessions.projections.replay.EventReplayer import com.correx.core.sessions.SessionCounterProjection import com.correx.core.sessions.SessionCounterState +import com.correx.core.sessions.projections.replay.DefaultEventReplayer +import com.correx.core.sessions.projections.replay.EventReplayer import com.correx.testing.contracts.fixtures.projections.SessionReplayContractTest class InMemoryReplayTest : SessionReplayContractTest() { diff --git a/infrastructure/persistence/src/test/kotlin/com/correx/infrastructure/persistence/SqliteEventStoreTest.kt b/infrastructure/persistence/src/test/kotlin/com/correx/infrastructure/persistence/SqliteEventStoreTest.kt index 92fbd0ec..3058b3ee 100644 --- a/infrastructure/persistence/src/test/kotlin/com/correx/infrastructure/persistence/SqliteEventStoreTest.kt +++ b/infrastructure/persistence/src/test/kotlin/com/correx/infrastructure/persistence/SqliteEventStoreTest.kt @@ -1,7 +1,7 @@ package com.correx.infrastructure.persistence -import com.correx.testing.contracts.fixtures.events.store.EventStoreContractTest import com.correx.core.events.stores.EventStore +import com.correx.testing.contracts.fixtures.events.store.EventStoreContractTest import java.sql.DriverManager class SqliteEventStoreTest : EventStoreContractTest() { diff --git a/infrastructure/persistence/src/test/kotlin/com/correx/infrastructure/persistence/SqliteReplayTest.kt b/infrastructure/persistence/src/test/kotlin/com/correx/infrastructure/persistence/SqliteReplayTest.kt index 14a584f2..f8a02b2e 100644 --- a/infrastructure/persistence/src/test/kotlin/com/correx/infrastructure/persistence/SqliteReplayTest.kt +++ b/infrastructure/persistence/src/test/kotlin/com/correx/infrastructure/persistence/SqliteReplayTest.kt @@ -1,10 +1,10 @@ package com.correx.infrastructure.persistence import com.correx.core.events.stores.EventStore -import com.correx.core.sessions.projections.replay.DefaultEventReplayer -import com.correx.core.sessions.projections.replay.EventReplayer import com.correx.core.sessions.SessionCounterProjection import com.correx.core.sessions.SessionCounterState +import com.correx.core.sessions.projections.replay.DefaultEventReplayer +import com.correx.core.sessions.projections.replay.EventReplayer import com.correx.testing.contracts.fixtures.projections.SessionReplayContractTest import java.sql.DriverManager diff --git a/infrastructure/src/main/kotlin/com/correx/infrastructure/InfrastructureModule.kt b/infrastructure/src/main/kotlin/com/correx/infrastructure/InfrastructureModule.kt index 17236ed1..951289e4 100644 --- a/infrastructure/src/main/kotlin/com/correx/infrastructure/InfrastructureModule.kt +++ b/infrastructure/src/main/kotlin/com/correx/infrastructure/InfrastructureModule.kt @@ -8,10 +8,10 @@ import com.correx.core.inference.InferenceProvider import com.correx.core.inference.InferenceRouter import com.correx.core.inference.ProviderRegistry import com.correx.core.inference.RoutingStrategy -import com.correx.infrastructure.inference.DefaultProviderRegistry -import com.correx.infrastructure.inference.FirstAvailableRoutingStrategy import com.correx.core.tools.contract.ToolExecutor import com.correx.core.tools.registry.ToolRegistry +import com.correx.infrastructure.inference.DefaultProviderRegistry +import com.correx.infrastructure.inference.FirstAvailableRoutingStrategy import com.correx.infrastructure.inference.commons.ModelManager import com.correx.infrastructure.inference.llama.cpp.DefaultModelManager import com.correx.infrastructure.persistence.SqliteEventStore @@ -20,10 +20,6 @@ import com.correx.infrastructure.tools.DispatchingToolExecutor import com.correx.infrastructure.tools.SandboxedToolExecutor import com.correx.infrastructure.tools.ToolConfig import com.correx.infrastructure.tools.buildTools -import com.correx.infrastructure.tools.filesystem.FileEditTool -import com.correx.infrastructure.tools.filesystem.FileReadTool -import com.correx.infrastructure.tools.filesystem.FileWriteTool -import com.correx.infrastructure.tools.shell.ShellTool import io.ktor.client.HttpClient import java.nio.file.Path import java.sql.DriverManager diff --git a/infrastructure/tools/filesystem/src/test/kotlin/com/correx/infrastructure/tools/filesystem/FileEditToolTest.kt b/infrastructure/tools/filesystem/src/test/kotlin/com/correx/infrastructure/tools/filesystem/FileEditToolTest.kt index b04a9a2a..7733a8f0 100644 --- a/infrastructure/tools/filesystem/src/test/kotlin/com/correx/infrastructure/tools/filesystem/FileEditToolTest.kt +++ b/infrastructure/tools/filesystem/src/test/kotlin/com/correx/infrastructure/tools/filesystem/FileEditToolTest.kt @@ -1,19 +1,17 @@ package com.correx.infrastructure.tools.filesystem +import com.correx.core.events.events.ToolRequest import com.correx.core.events.types.SessionId import com.correx.core.events.types.StageId import com.correx.core.events.types.ToolInvocationId -import com.correx.core.events.events.ToolRequest import com.correx.core.tools.contract.ToolResult import com.correx.core.tools.contract.ValidationResult import kotlinx.coroutines.runBlocking import org.junit.jupiter.api.Assertions.assertEquals -import org.junit.jupiter.api.Assertions.assertFalse import org.junit.jupiter.api.Assertions.assertTrue import org.junit.jupiter.api.Test import java.nio.file.Files -import java.nio.file.Path -import java.util.UUID +import java.util.* class FileEditToolTest { diff --git a/infrastructure/tools/filesystem/src/test/kotlin/com/correx/infrastructure/tools/filesystem/FileReadToolTest.kt b/infrastructure/tools/filesystem/src/test/kotlin/com/correx/infrastructure/tools/filesystem/FileReadToolTest.kt index a9522644..34fa39ee 100644 --- a/infrastructure/tools/filesystem/src/test/kotlin/com/correx/infrastructure/tools/filesystem/FileReadToolTest.kt +++ b/infrastructure/tools/filesystem/src/test/kotlin/com/correx/infrastructure/tools/filesystem/FileReadToolTest.kt @@ -1,18 +1,18 @@ package com.correx.infrastructure.tools.filesystem +import com.correx.core.events.events.ToolRequest import com.correx.core.events.types.SessionId import com.correx.core.events.types.StageId import com.correx.core.events.types.ToolInvocationId import com.correx.core.tools.contract.ToolResult import com.correx.core.tools.contract.ValidationResult -import com.correx.core.events.events.ToolRequest import kotlinx.coroutines.runBlocking import org.junit.jupiter.api.Assertions.assertEquals import org.junit.jupiter.api.Assertions.assertFalse import org.junit.jupiter.api.Assertions.assertTrue import org.junit.jupiter.api.Test import java.nio.file.Files -import java.util.UUID +import java.util.* class FileReadToolTest { diff --git a/infrastructure/tools/filesystem/src/test/kotlin/com/correx/infrastructure/tools/filesystem/FileWriteToolTest.kt b/infrastructure/tools/filesystem/src/test/kotlin/com/correx/infrastructure/tools/filesystem/FileWriteToolTest.kt index bc101616..f3ac8b91 100644 --- a/infrastructure/tools/filesystem/src/test/kotlin/com/correx/infrastructure/tools/filesystem/FileWriteToolTest.kt +++ b/infrastructure/tools/filesystem/src/test/kotlin/com/correx/infrastructure/tools/filesystem/FileWriteToolTest.kt @@ -1,19 +1,18 @@ package com.correx.infrastructure.tools.filesystem +import com.correx.core.events.events.ToolRequest import com.correx.core.events.types.SessionId import com.correx.core.events.types.StageId import com.correx.core.events.types.ToolInvocationId import com.correx.core.tools.contract.ToolResult import com.correx.core.tools.contract.ValidationResult -import com.correx.core.events.events.ToolRequest import kotlinx.coroutines.runBlocking import org.junit.jupiter.api.Assertions.assertEquals import org.junit.jupiter.api.Assertions.assertFalse import org.junit.jupiter.api.Assertions.assertTrue import org.junit.jupiter.api.Test import java.nio.file.Files -import java.nio.file.Path -import java.util.UUID +import java.util.* class FileWriteToolTest { diff --git a/infrastructure/tools/src/test/kotlin/com/correx/infrastructure/tools/shell/ShellToolTest.kt b/infrastructure/tools/src/test/kotlin/com/correx/infrastructure/tools/shell/ShellToolTest.kt index 3a5cf90f..1c8f456b 100644 --- a/infrastructure/tools/src/test/kotlin/com/correx/infrastructure/tools/shell/ShellToolTest.kt +++ b/infrastructure/tools/src/test/kotlin/com/correx/infrastructure/tools/shell/ShellToolTest.kt @@ -11,7 +11,7 @@ import org.junit.jupiter.api.Assertions.assertEquals import org.junit.jupiter.api.Assertions.assertFalse import org.junit.jupiter.api.Assertions.assertTrue import org.junit.jupiter.api.Test -import java.util.UUID +import java.util.* class ShellToolTest { diff --git a/testing/approvals/src/test/kotlin/ApprovalEngineEdgeCasesTest.kt b/testing/approvals/src/test/kotlin/ApprovalEngineEdgeCasesTest.kt index 08d98a27..80a22c5a 100644 --- a/testing/approvals/src/test/kotlin/ApprovalEngineEdgeCasesTest.kt +++ b/testing/approvals/src/test/kotlin/ApprovalEngineEdgeCasesTest.kt @@ -1,10 +1,10 @@ +import com.correx.core.approvals.ApprovalStatus +import com.correx.core.approvals.GrantScope import com.correx.core.approvals.Tier import com.correx.core.approvals.domain.DefaultApprovalEngine import com.correx.core.approvals.model.ApprovalContext import com.correx.core.approvals.model.ApprovalGrant import com.correx.core.approvals.model.ApprovalScopeIdentity -import com.correx.core.approvals.ApprovalStatus -import com.correx.core.approvals.GrantScope import com.correx.core.events.types.GrantId import com.correx.core.events.types.ProjectId import com.correx.core.events.types.SessionId diff --git a/testing/approvals/src/test/kotlin/GrantSemanticsTest.kt b/testing/approvals/src/test/kotlin/GrantSemanticsTest.kt index 77ed9d17..f1664982 100644 --- a/testing/approvals/src/test/kotlin/GrantSemanticsTest.kt +++ b/testing/approvals/src/test/kotlin/GrantSemanticsTest.kt @@ -1,11 +1,11 @@ +import com.correx.core.approvals.ApprovalOutcome +import com.correx.core.approvals.ApprovalStatus +import com.correx.core.approvals.GrantScope import com.correx.core.approvals.Tier import com.correx.core.approvals.domain.DefaultApprovalEngine import com.correx.core.approvals.model.ApprovalContext import com.correx.core.approvals.model.ApprovalGrant -import com.correx.core.approvals.ApprovalOutcome import com.correx.core.approvals.model.ApprovalScopeIdentity -import com.correx.core.approvals.ApprovalStatus -import com.correx.core.approvals.GrantScope import com.correx.core.events.types.GrantId import com.correx.core.events.types.SessionId import com.correx.core.sessions.ApprovalMode diff --git a/testing/approvals/src/test/kotlin/ModeApprovalTest.kt b/testing/approvals/src/test/kotlin/ModeApprovalTest.kt index 091661a1..5999d810 100644 --- a/testing/approvals/src/test/kotlin/ModeApprovalTest.kt +++ b/testing/approvals/src/test/kotlin/ModeApprovalTest.kt @@ -1,9 +1,9 @@ +import com.correx.core.approvals.ApprovalOutcome +import com.correx.core.approvals.ApprovalStatus import com.correx.core.approvals.Tier import com.correx.core.approvals.domain.DefaultApprovalEngine import com.correx.core.approvals.model.ApprovalContext -import com.correx.core.approvals.ApprovalOutcome import com.correx.core.approvals.model.ApprovalScopeIdentity -import com.correx.core.approvals.ApprovalStatus import com.correx.core.events.types.SessionId import com.correx.core.sessions.ApprovalMode import com.correx.testing.fixtures.request diff --git a/testing/approvals/src/test/kotlin/NoExecutionCouplingTest.kt b/testing/approvals/src/test/kotlin/NoExecutionCouplingTest.kt index 7879e345..c71f3c81 100644 --- a/testing/approvals/src/test/kotlin/NoExecutionCouplingTest.kt +++ b/testing/approvals/src/test/kotlin/NoExecutionCouplingTest.kt @@ -1,9 +1,9 @@ +import com.correx.core.approvals.GrantScope import com.correx.core.approvals.Tier import com.correx.core.approvals.domain.DefaultApprovalEngine import com.correx.core.approvals.model.ApprovalContext import com.correx.core.approvals.model.ApprovalGrant import com.correx.core.approvals.model.ApprovalScopeIdentity -import com.correx.core.approvals.GrantScope import com.correx.core.events.types.GrantId import com.correx.core.events.types.SessionId import com.correx.core.sessions.ApprovalMode diff --git a/testing/approvals/src/test/kotlin/TierImmutabilityTest.kt b/testing/approvals/src/test/kotlin/TierImmutabilityTest.kt index 4de660f7..f34e3e09 100644 --- a/testing/approvals/src/test/kotlin/TierImmutabilityTest.kt +++ b/testing/approvals/src/test/kotlin/TierImmutabilityTest.kt @@ -1,12 +1,12 @@ +import com.correx.core.approvals.GrantScope import com.correx.core.approvals.Tier import com.correx.core.approvals.domain.DefaultApprovalEngine import com.correx.core.approvals.model.ApprovalContext import com.correx.core.approvals.model.ApprovalGrant import com.correx.core.approvals.model.ApprovalScopeIdentity -import com.correx.core.approvals.GrantScope -import com.correx.core.sessions.ApprovalMode import com.correx.core.events.types.GrantId import com.correx.core.events.types.SessionId +import com.correx.core.sessions.ApprovalMode import com.correx.testing.fixtures.request import kotlinx.datetime.Instant import org.junit.jupiter.api.Assertions diff --git a/testing/contracts/src/main/kotlin/com/correx/testing/contracts/utils/ConcurrencyRunner.kt b/testing/contracts/src/main/kotlin/com/correx/testing/contracts/utils/ConcurrencyRunner.kt index b233fbd8..3b6d0205 100644 --- a/testing/contracts/src/main/kotlin/com/correx/testing/contracts/utils/ConcurrencyRunner.kt +++ b/testing/contracts/src/main/kotlin/com/correx/testing/contracts/utils/ConcurrencyRunner.kt @@ -1,7 +1,6 @@ package com.correx.testing.contracts.utils -import java.util.concurrent.CountDownLatch -import java.util.concurrent.Executors +import java.util.concurrent.* object ConcurrencyRunner { diff --git a/testing/contracts/src/main/kotlin/com/correx/testing/contracts/utils/DeterministicBarrier.kt b/testing/contracts/src/main/kotlin/com/correx/testing/contracts/utils/DeterministicBarrier.kt index 9d4c3d8c..d73f6ba9 100644 --- a/testing/contracts/src/main/kotlin/com/correx/testing/contracts/utils/DeterministicBarrier.kt +++ b/testing/contracts/src/main/kotlin/com/correx/testing/contracts/utils/DeterministicBarrier.kt @@ -1,6 +1,6 @@ package com.correx.testing.contracts.utils -import java.util.concurrent.CyclicBarrier +import java.util.concurrent.* class DeterministicBarrier(parties: Int) { diff --git a/testing/contracts/src/test/kotlin/com/correx/testing/contracts/model/ContextSnapshotTest.kt b/testing/contracts/src/test/kotlin/com/correx/testing/contracts/model/ContextSnapshotTest.kt index c26bbce4..29c4b219 100644 --- a/testing/contracts/src/test/kotlin/com/correx/testing/contracts/model/ContextSnapshotTest.kt +++ b/testing/contracts/src/test/kotlin/com/correx/testing/contracts/model/ContextSnapshotTest.kt @@ -4,9 +4,9 @@ import com.correx.core.approvals.Tier import com.correx.core.approvals.domain.DefaultApprovalEngine import com.correx.core.approvals.model.ApprovalContext import com.correx.core.approvals.model.ApprovalScopeIdentity +import com.correx.core.events.types.ProjectId import com.correx.core.events.types.SessionId import com.correx.core.events.types.StageId -import com.correx.core.events.types.ProjectId import com.correx.core.sessions.ApprovalMode import com.correx.testing.fixtures.request import kotlinx.datetime.Instant diff --git a/testing/contracts/src/test/kotlin/com/correx/testing/contracts/model/inference/DefaultInferenceRouterTest.kt b/testing/contracts/src/test/kotlin/com/correx/testing/contracts/model/inference/DefaultInferenceRouterTest.kt index 9cef682c..809915f2 100644 --- a/testing/contracts/src/test/kotlin/com/correx/testing/contracts/model/inference/DefaultInferenceRouterTest.kt +++ b/testing/contracts/src/test/kotlin/com/correx/testing/contracts/model/inference/DefaultInferenceRouterTest.kt @@ -7,8 +7,8 @@ import com.correx.core.inference.DefaultInferenceRouter import com.correx.core.inference.InferenceProvider import com.correx.core.inference.ModelCapability import com.correx.core.inference.NoEligibleProviderException -import com.correx.core.inference.ProviderRegistry import com.correx.core.inference.ProviderHealth +import com.correx.core.inference.ProviderRegistry import com.correx.core.inference.RoutingStrategy import com.correx.testing.fixtures.inference.MockInferenceProvider import kotlinx.coroutines.runBlocking diff --git a/testing/contracts/src/testFixtures/kotlin/com/correx/testing/contracts/fixtures/projections/CountingProjectionContractTest.kt b/testing/contracts/src/testFixtures/kotlin/com/correx/testing/contracts/fixtures/projections/CountingProjectionContractTest.kt index b3b42e14..3db66ec2 100644 --- a/testing/contracts/src/testFixtures/kotlin/com/correx/testing/contracts/fixtures/projections/CountingProjectionContractTest.kt +++ b/testing/contracts/src/testFixtures/kotlin/com/correx/testing/contracts/fixtures/projections/CountingProjectionContractTest.kt @@ -2,9 +2,9 @@ package com.correx.testing.contracts.fixtures.projections import com.correx.core.events.types.EventId import com.correx.core.events.types.SessionId -import com.correx.core.sessions.projections.DefaultStateBuilder import com.correx.core.sessions.SessionCounterProjection import com.correx.core.sessions.SessionCounterState +import com.correx.core.sessions.projections.DefaultStateBuilder import com.correx.testing.fixtures.EventFixtures.stored import org.junit.jupiter.api.Assertions.assertEquals import org.junit.jupiter.api.Test diff --git a/testing/contracts/src/testFixtures/kotlin/com/correx/testing/contracts/fixtures/projections/SessionReplayContractTest.kt b/testing/contracts/src/testFixtures/kotlin/com/correx/testing/contracts/fixtures/projections/SessionReplayContractTest.kt index 7164d5e9..9d0c45d0 100644 --- a/testing/contracts/src/testFixtures/kotlin/com/correx/testing/contracts/fixtures/projections/SessionReplayContractTest.kt +++ b/testing/contracts/src/testFixtures/kotlin/com/correx/testing/contracts/fixtures/projections/SessionReplayContractTest.kt @@ -3,8 +3,8 @@ package com.correx.testing.contracts.fixtures.projections import com.correx.core.events.stores.EventStore import com.correx.core.events.types.EventId import com.correx.core.events.types.SessionId -import com.correx.core.sessions.projections.replay.EventReplayer import com.correx.core.sessions.SessionCounterState +import com.correx.core.sessions.projections.replay.EventReplayer import com.correx.testing.fixtures.EventFixtures.newEvent import org.junit.jupiter.api.Assertions.assertEquals import org.junit.jupiter.api.Test diff --git a/testing/deterministic/src/test/kotlin/ValidationPipelineShortCircuitTest.kt b/testing/deterministic/src/test/kotlin/ValidationPipelineShortCircuitTest.kt index 862079ce..a5b4dcaa 100644 --- a/testing/deterministic/src/test/kotlin/ValidationPipelineShortCircuitTest.kt +++ b/testing/deterministic/src/test/kotlin/ValidationPipelineShortCircuitTest.kt @@ -8,7 +8,6 @@ import com.correx.core.validation.pipeline.Validator import com.correx.testing.fixtures.WorkflowFixtures import org.junit.jupiter.api.Assertions.assertEquals import org.junit.jupiter.api.Assertions.assertFalse -import org.junit.jupiter.api.Assertions.assertInstanceOf import org.junit.jupiter.api.Test class ValidationPipelineShortCircuitTest { diff --git a/testing/fixtures/src/main/kotlin/com/correx/testing/fixtures/ApprovalFixtures.kt b/testing/fixtures/src/main/kotlin/com/correx/testing/fixtures/ApprovalFixtures.kt index 9bbeca37..8ee20bd4 100644 --- a/testing/fixtures/src/main/kotlin/com/correx/testing/fixtures/ApprovalFixtures.kt +++ b/testing/fixtures/src/main/kotlin/com/correx/testing/fixtures/ApprovalFixtures.kt @@ -5,7 +5,6 @@ import com.correx.core.approvals.model.DomainApprovalRequest import com.correx.core.events.types.ApprovalRequestId import com.correx.core.events.types.RiskSummaryId import com.correx.core.events.types.ValidationReportId -import com.correx.core.validation.model.ValidationContext import com.correx.core.validation.model.ValidationIssue import com.correx.core.validation.model.ValidationSection import com.correx.core.validation.model.ValidationSeverity diff --git a/testing/fixtures/src/main/kotlin/com/correx/testing/fixtures/context/ContextFixtures.kt b/testing/fixtures/src/main/kotlin/com/correx/testing/fixtures/context/ContextFixtures.kt index df97843b..090b20f1 100644 --- a/testing/fixtures/src/main/kotlin/com/correx/testing/fixtures/context/ContextFixtures.kt +++ b/testing/fixtures/src/main/kotlin/com/correx/testing/fixtures/context/ContextFixtures.kt @@ -1,8 +1,8 @@ package com.correx.testing.fixtures.context import com.correx.core.context.builder.DefaultContextPackBuilder -import com.correx.core.context.compression.ContextCompressor import com.correx.core.context.compression.CompressionStrategy +import com.correx.core.context.compression.ContextCompressor import com.correx.core.context.model.ContextEntry import com.correx.core.context.model.TokenBudget diff --git a/testing/kernel/src/test/kotlin/DefaultRetryCoordinatorTest.kt b/testing/kernel/src/test/kotlin/DefaultRetryCoordinatorTest.kt index 9dd6e254..66d5fbf6 100644 --- a/testing/kernel/src/test/kotlin/DefaultRetryCoordinatorTest.kt +++ b/testing/kernel/src/test/kotlin/DefaultRetryCoordinatorTest.kt @@ -1,8 +1,8 @@ import com.correx.core.events.events.RetryAttemptedEvent +import com.correx.core.events.execution.RetryPolicy import com.correx.core.events.stores.EventStore import com.correx.core.events.types.SessionId import com.correx.core.events.types.StageId -import com.correx.core.events.execution.RetryPolicy import com.correx.core.kernel.retry.DefaultRetryCoordinator import com.correx.infrastructure.persistence.InMemoryEventStore import kotlinx.coroutines.ExperimentalCoroutinesApi diff --git a/testing/projections/src/test/kotlin/ArtifactReducerTest.kt b/testing/projections/src/test/kotlin/ArtifactReducerTest.kt index a613e759..618da909 100644 --- a/testing/projections/src/test/kotlin/ArtifactReducerTest.kt +++ b/testing/projections/src/test/kotlin/ArtifactReducerTest.kt @@ -1,7 +1,6 @@ import com.correx.core.artifacts.ArtifactState import com.correx.core.artifacts.DefaultArtifactReducer import com.correx.core.events.events.ArtifactArchivedEvent -import com.correx.core.events.events.ArtifactCreatedEvent import com.correx.core.events.events.ArtifactRejectedEvent import com.correx.core.events.events.ArtifactRelationshipAddedEvent import com.correx.core.events.events.ArtifactSupersededEvent diff --git a/testing/projections/src/test/kotlin/DefaultSessionReducerTest.kt b/testing/projections/src/test/kotlin/DefaultSessionReducerTest.kt index e921118e..366ed784 100644 --- a/testing/projections/src/test/kotlin/DefaultSessionReducerTest.kt +++ b/testing/projections/src/test/kotlin/DefaultSessionReducerTest.kt @@ -8,11 +8,11 @@ import com.correx.core.events.events.StageFailedEvent import com.correx.core.events.events.StageStartedEvent import com.correx.core.events.events.TransitionExecutedEvent import com.correx.core.events.types.SessionId +import com.correx.core.events.types.StageId +import com.correx.core.events.types.TransitionId import com.correx.core.sessions.DefaultSessionReducer import com.correx.core.sessions.SessionState import com.correx.core.sessions.SessionStatus -import com.correx.core.events.types.StageId -import com.correx.core.events.types.TransitionId import com.correx.testing.fixtures.EventFixtures.stored import kotlinx.datetime.Instant import org.junit.jupiter.api.Assertions.assertEquals diff --git a/testing/projections/src/test/kotlin/OrchestrationProjectorTest.kt b/testing/projections/src/test/kotlin/OrchestrationProjectorTest.kt index fef1c364..6e40ef16 100644 --- a/testing/projections/src/test/kotlin/OrchestrationProjectorTest.kt +++ b/testing/projections/src/test/kotlin/OrchestrationProjectorTest.kt @@ -4,9 +4,9 @@ import com.correx.core.events.events.RetryAttemptedEvent import com.correx.core.events.events.WorkflowCompletedEvent import com.correx.core.events.events.WorkflowFailedEvent import com.correx.core.events.events.WorkflowStartedEvent +import com.correx.core.events.orchestration.OrchestrationStatus import com.correx.core.events.types.SessionId import com.correx.core.events.types.StageId -import com.correx.core.events.orchestration.OrchestrationStatus import com.correx.core.kernel.orchestration.DefaultOrchestrationReducer import com.correx.core.kernel.orchestration.OrchestrationProjector import com.correx.testing.fixtures.EventFixtures.stored diff --git a/testing/projections/src/test/kotlin/OrchestrationReducerTest.kt b/testing/projections/src/test/kotlin/OrchestrationReducerTest.kt index b57c6343..88f5680b 100644 --- a/testing/projections/src/test/kotlin/OrchestrationReducerTest.kt +++ b/testing/projections/src/test/kotlin/OrchestrationReducerTest.kt @@ -4,10 +4,10 @@ import com.correx.core.events.events.RetryAttemptedEvent import com.correx.core.events.events.WorkflowCompletedEvent import com.correx.core.events.events.WorkflowFailedEvent import com.correx.core.events.events.WorkflowStartedEvent -import com.correx.core.events.types.SessionId -import com.correx.core.events.types.StageId import com.correx.core.events.orchestration.OrchestrationState import com.correx.core.events.orchestration.OrchestrationStatus +import com.correx.core.events.types.SessionId +import com.correx.core.events.types.StageId import com.correx.core.kernel.orchestration.DefaultOrchestrationReducer import com.correx.testing.fixtures.EventFixtures.stored import org.junit.jupiter.api.Assertions.assertEquals diff --git a/testing/replay/src/test/kotlin/ApprovalReplayTest.kt b/testing/replay/src/test/kotlin/ApprovalReplayTest.kt index 79b4a1a3..0720ed80 100644 --- a/testing/replay/src/test/kotlin/ApprovalReplayTest.kt +++ b/testing/replay/src/test/kotlin/ApprovalReplayTest.kt @@ -1,9 +1,9 @@ +import com.correx.core.approvals.GrantScope import com.correx.core.approvals.Tier import com.correx.core.approvals.domain.DefaultApprovalEngine import com.correx.core.approvals.model.ApprovalContext import com.correx.core.approvals.model.ApprovalGrant import com.correx.core.approvals.model.ApprovalScopeIdentity -import com.correx.core.approvals.GrantScope import com.correx.core.events.types.ApprovalDecisionId import com.correx.core.events.types.GrantId import com.correx.core.events.types.SessionId