feat: restructure core by component (eclipse-edc#1842)

* Move contract and transfer core modules into control-plane * PR remarks * Fix CI * Extract instance store provision to a specific extension * Rename federated-catalog-cache to federated-catalog-core
FraunhoferISST · Aug 23, 2022 · 44830e2 · 44830e2
1 parent d15ea23
commit 44830e2
Show file tree

Hide file tree

Showing 365 changed files with 591 additions and 747 deletions.
diff --git a/.github/workflows/verify.yaml b/.github/workflows/verify.yaml
@@ -371,7 +371,7 @@ jobs:
         uses: ./.github/actions/run-tests
         with:
           command: |
-            ./gradlew -p core/micrometer test -DincludeTags="OpenTelemetryIntegrationTest"
+            ./gradlew -p extensions/micrometer test -DincludeTags="OpenTelemetryIntegrationTest"
             ./gradlew -p system-tests/tests test -DincludeTags="OpenTelemetryIntegrationTest"
 
   Check-Cloud-Environments:

diff --git a/core/build.gradle.kts b/core/build.gradle.kts
diff --git a/core/base/README.md → core/common/base/README.md b/core/base/README.md → core/common/base/README.md
diff --git a/core/base/build.gradle.kts → core/common/base/build.gradle.kts b/core/base/build.gradle.kts → core/common/base/build.gradle.kts
@@ -28,8 +28,7 @@ dependencies {
     api(project(":spi:common:core-spi"))
     api(project(":spi:common:transaction-spi"))
     implementation(project(":common:util"))
-    implementation(project(":core:defaults"))
-    implementation(project(":core:policy:policy-engine"))
+    implementation(project(":core:common:policy-engine"))
     implementation(project(":extensions:dataloading"))
 
     api("com.squareup.okhttp3:okhttp:${okHttpVersion}")

diff --git a/...connector/core/CoreServicesExtension.java → ...connector/core/CoreServicesExtension.java b/...connector/core/CoreServicesExtension.java → ...connector/core/CoreServicesExtension.java
diff --git a/...core/base/CommandHandlerRegistryImpl.java → ...core/base/CommandHandlerRegistryImpl.java b/...core/base/CommandHandlerRegistryImpl.java → ...core/base/CommandHandlerRegistryImpl.java
diff --git a/...nector/core/base/OkHttpClientFactory.java → ...nector/core/base/OkHttpClientFactory.java b/...nector/core/base/OkHttpClientFactory.java → ...nector/core/base/OkHttpClientFactory.java
diff --git a/.../RemoteMessageDispatcherRegistryImpl.java → .../RemoteMessageDispatcherRegistryImpl.java b/.../RemoteMessageDispatcherRegistryImpl.java → .../RemoteMessageDispatcherRegistryImpl.java
diff --git a/...se/agent/ParticipantAgentServiceImpl.java → ...se/agent/ParticipantAgentServiceImpl.java b/...se/agent/ParticipantAgentServiceImpl.java → ...se/agent/ParticipantAgentServiceImpl.java
diff --git a/...r/core/base/policy/PolicyContextImpl.java → ...r/core/base/policy/PolicyContextImpl.java b/...r/core/base/policy/PolicyContextImpl.java → ...r/core/base/policy/PolicyContextImpl.java
diff --git a/...or/core/base/policy/PolicyEngineImpl.java → ...or/core/base/policy/PolicyEngineImpl.java b/...or/core/base/policy/PolicyEngineImpl.java → ...or/core/base/policy/PolicyEngineImpl.java
diff --git a/.../base/policy/RuleBindingRegistryImpl.java → .../base/policy/RuleBindingRegistryImpl.java b/.../base/policy/RuleBindingRegistryImpl.java → .../base/policy/RuleBindingRegistryImpl.java
diff --git a/...nnector/core/base/policy/ScopeFilter.java → ...nnector/core/base/policy/ScopeFilter.java b/...nnector/core/base/policy/ScopeFilter.java → ...nnector/core/base/policy/ScopeFilter.java
diff --git a/...re/defaults/DefaultServicesExtension.java → ...re/defaults/DefaultServicesExtension.java b/...re/defaults/DefaultServicesExtension.java → ...re/defaults/DefaultServicesExtension.java
@@ -17,34 +17,19 @@
 import dev.failsafe.RetryPolicy;
 import okhttp3.EventListener;
 import okhttp3.OkHttpClient;
-import org.eclipse.dataspaceconnector.common.concurrency.LockManager;
 import org.eclipse.dataspaceconnector.core.base.OkHttpClientFactory;
-import org.eclipse.dataspaceconnector.core.defaults.assetindex.InMemoryAssetIndex;
-import org.eclipse.dataspaceconnector.core.defaults.contractdefinition.InMemoryContractDefinitionStore;
-import org.eclipse.dataspaceconnector.core.defaults.negotiationstore.InMemoryContractNegotiationStore;
-import org.eclipse.dataspaceconnector.core.defaults.policystore.InMemoryPolicyDefinitionStore;
-import org.eclipse.dataspaceconnector.core.defaults.transferprocessstore.InMemoryTransferProcessStore;
-import org.eclipse.dataspaceconnector.dataloading.AssetLoader;
-import org.eclipse.dataspaceconnector.dataloading.ContractDefinitionLoader;
 import org.eclipse.dataspaceconnector.spi.EdcSetting;
-import org.eclipse.dataspaceconnector.spi.asset.AssetIndex;
-import org.eclipse.dataspaceconnector.spi.asset.DataAddressResolver;
-import org.eclipse.dataspaceconnector.spi.contract.negotiation.store.ContractNegotiationStore;
-import org.eclipse.dataspaceconnector.spi.contract.offer.store.ContractDefinitionStore;
-import org.eclipse.dataspaceconnector.spi.policy.store.PolicyDefinitionStore;
 import org.eclipse.dataspaceconnector.spi.system.Inject;
 import org.eclipse.dataspaceconnector.spi.system.Provider;
 import org.eclipse.dataspaceconnector.spi.system.ServiceExtension;
 import org.eclipse.dataspaceconnector.spi.system.ServiceExtensionContext;
 import org.eclipse.dataspaceconnector.spi.transaction.NoopTransactionContext;
 import org.eclipse.dataspaceconnector.spi.transaction.TransactionContext;
-import org.eclipse.dataspaceconnector.spi.transfer.store.TransferProcessStore;
 
 import java.time.temporal.ChronoUnit;
-import java.util.concurrent.locks.ReentrantReadWriteLock;
 
 /**
- * Provides (in-mem &amp; no-op) defaults for various stores, registries etc.
+ * Provides defaults for various services.
  * Provider methods are only invoked if no other implementation was found on the classpath.
  */
 public class DefaultServicesExtension implements ServiceExtension {
@@ -55,8 +40,6 @@ public class DefaultServicesExtension implements ServiceExtension {
     @EdcSetting(value = "Maximum number of milliseconds for exponential backoff. ")
     public static final String BACKOFF_MAX_MILLIS = "edc.core.retry.backoff.max";
 
-    private InMemoryAssetIndex assetIndex;
-    private InMemoryContractDefinitionStore contractDefinitionStore;
     /**
      * An optional OkHttp {@link EventListener} that can be used to instrument OkHttp client for collecting metrics.
      * Used by the optional {@code micrometer} module.
@@ -79,46 +62,6 @@ public RetryPolicy<?> retryPolicy(ServiceExtensionContext context) {
                 .build();
     }
 
-    @Provider(isDefault = true)
-    public AssetIndex defaultAssetIndex() {
-        return getAssetIndex();
-    }
-
-    @Provider(isDefault = true)
-    public DataAddressResolver defaultDataAddressResolver() {
-        return getAssetIndex();
-    }
-
-    @Provider(isDefault = true)
-    public AssetLoader defaultAssetLoader() {
-        return getAssetIndex();
-    }
-
-    @Provider(isDefault = true)
-    public ContractDefinitionStore defaultContractDefinitionStore() {
-        return getContractDefinitionStore();
-    }
-
-    @Provider(isDefault = true)
-    public ContractDefinitionLoader defaultContractDefinitionLoader() {
-        return getContractDefinitionStore()::save;
-    }
-
-    @Provider(isDefault = true)
-    public ContractNegotiationStore defaultContractNegotiationStore() {
-        return new InMemoryContractNegotiationStore();
-    }
-
-    @Provider(isDefault = true)
-    public TransferProcessStore defaultTransferProcessStore() {
-        return new InMemoryTransferProcessStore();
-    }
-
-    @Provider(isDefault = true)
-    public PolicyDefinitionStore defaultPolicyStore() {
-        return new InMemoryPolicyDefinitionStore(new LockManager(new ReentrantReadWriteLock(true)));
-    }
-
     @Provider(isDefault = true)
     public TransactionContext defaultTransactionContext(ServiceExtensionContext context) {
         context.getMonitor().warning("No TransactionContext registered, a no-op implementation will be used, not suitable for production environments");
@@ -130,18 +73,4 @@ public TransactionContext defaultTransactionContext(ServiceExtensionContext cont
     public OkHttpClient okHttpClient(ServiceExtensionContext context) {
         return OkHttpClientFactory.create(context, okHttpEventListener);
     }
-
-    private ContractDefinitionStore getContractDefinitionStore() {
-        if (contractDefinitionStore == null) {
-            contractDefinitionStore = new InMemoryContractDefinitionStore();
-        }
-        return contractDefinitionStore;
-    }
-
-    private InMemoryAssetIndex getAssetIndex() {
-        if (assetIndex == null) {
-            assetIndex = new InMemoryAssetIndex();
-        }
-        return assetIndex;
-    }
 }
diff --git a/.../event/EventExecutorServiceContainer.java → .../event/EventExecutorServiceContainer.java b/.../event/EventExecutorServiceContainer.java → .../event/EventExecutorServiceContainer.java
diff --git a/...connector/core/event/EventRouterImpl.java → ...connector/core/event/EventRouterImpl.java b/...connector/core/event/EventRouterImpl.java → ...connector/core/event/EventRouterImpl.java
diff --git a/...alth/HealthCheckServiceConfiguration.java → ...alth/HealthCheckServiceConfiguration.java b/...alth/HealthCheckServiceConfiguration.java → ...alth/HealthCheckServiceConfiguration.java
diff --git a/...r/core/health/HealthCheckServiceImpl.java → ...r/core/health/HealthCheckServiceImpl.java b/...r/core/health/HealthCheckServiceImpl.java → ...r/core/health/HealthCheckServiceImpl.java
diff --git a/...urity/DefaultPrivateKeyParseFunction.java → ...urity/DefaultPrivateKeyParseFunction.java b/...urity/DefaultPrivateKeyParseFunction.java → ...urity/DefaultPrivateKeyParseFunction.java
diff --git a/...paceconnector.spi.system.ServiceExtension → ...paceconnector.spi.system.ServiceExtension b/...paceconnector.spi.system.ServiceExtension → ...paceconnector.spi.system.ServiceExtension
diff --git a/...CoreServicesExtensionIntegrationTest.java → ...CoreServicesExtensionIntegrationTest.java b/...CoreServicesExtensionIntegrationTest.java → ...CoreServicesExtensionIntegrationTest.java
diff --git a/...ector/core/CoreServicesExtensionTest.java → ...ector/core/CoreServicesExtensionTest.java b/...ector/core/CoreServicesExtensionTest.java → ...ector/core/CoreServicesExtensionTest.java
diff --git a/...eManagerDependencyInjectionExtension.java → ...eManagerDependencyInjectionExtension.java b/...eManagerDependencyInjectionExtension.java → ...eManagerDependencyInjectionExtension.java
diff --git a/...or/core/base/OkHttpClientFactoryTest.java → ...or/core/base/OkHttpClientFactoryTest.java b/...or/core/base/OkHttpClientFactoryTest.java → ...or/core/base/OkHttpClientFactoryTest.java
diff --git a/...gent/ParticipantAgentServiceImplTest.java → ...gent/ParticipantAgentServiceImplTest.java b/...gent/ParticipantAgentServiceImplTest.java → ...gent/ParticipantAgentServiceImplTest.java
diff --git a/...policy/PolicyEngineImplScenariosTest.java → ...policy/PolicyEngineImplScenariosTest.java b/...policy/PolicyEngineImplScenariosTest.java → ...policy/PolicyEngineImplScenariosTest.java
diff --git a/...ore/base/policy/PolicyEngineImplTest.java → ...ore/base/policy/PolicyEngineImplTest.java b/...ore/base/policy/PolicyEngineImplTest.java → ...ore/base/policy/PolicyEngineImplTest.java
diff --git a/...e/policy/RuleBindingRegistryImplTest.java → ...e/policy/RuleBindingRegistryImplTest.java b/...e/policy/RuleBindingRegistryImplTest.java → ...e/policy/RuleBindingRegistryImplTest.java
diff --git a/...tor/core/base/policy/ScopeFilterTest.java → ...tor/core/base/policy/ScopeFilterTest.java b/...tor/core/base/policy/ScopeFilterTest.java → ...tor/core/base/policy/ScopeFilterTest.java
diff --git a/...ector/core/event/EventRouterImplTest.java → ...ector/core/event/EventRouterImplTest.java b/...ector/core/event/EventRouterImplTest.java → ...ector/core/event/EventRouterImplTest.java
diff --git a/...re/health/HealthCheckServiceImplTest.java → ...re/health/HealthCheckServiceImplTest.java b/...re/health/HealthCheckServiceImplTest.java → ...re/health/HealthCheckServiceImplTest.java
diff --git a/...y/DefaultPrivateKeyParseFunctionTest.java → ...y/DefaultPrivateKeyParseFunctionTest.java b/...y/DefaultPrivateKeyParseFunctionTest.java → ...y/DefaultPrivateKeyParseFunctionTest.java
diff --git a/...base/src/test/resources/ec-privatekey.pem → ...base/src/test/resources/ec-privatekey.pem b/...base/src/test/resources/ec-privatekey.pem → ...base/src/test/resources/ec-privatekey.pem
diff --git a/...ase/src/test/resources/rsa-privatekey.pem → ...ase/src/test/resources/rsa-privatekey.pem b/...ase/src/test/resources/rsa-privatekey.pem → ...ase/src/test/resources/rsa-privatekey.pem
diff --git a/core/boot/build.gradle.kts → core/common/boot/build.gradle.kts b/core/boot/build.gradle.kts → core/common/boot/build.gradle.kts
diff --git a/...nnector/boot/monitor/MonitorProvider.java → ...nnector/boot/monitor/MonitorProvider.java b/...nnector/boot/monitor/MonitorProvider.java → ...nnector/boot/monitor/MonitorProvider.java
diff --git a/...ystem/DefaultServiceExtensionContext.java → ...ystem/DefaultServiceExtensionContext.java b/...ystem/DefaultServiceExtensionContext.java → ...ystem/DefaultServiceExtensionContext.java
diff --git a/...onnector/boot/system/DependencyGraph.java → ...onnector/boot/system/DependencyGraph.java b/...onnector/boot/system/DependencyGraph.java → ...onnector/boot/system/DependencyGraph.java
diff --git a/...onnector/boot/system/ExtensionLoader.java → ...onnector/boot/system/ExtensionLoader.java b/...onnector/boot/system/ExtensionLoader.java → ...onnector/boot/system/ExtensionLoader.java
diff --git a/...connector/boot/system/ServiceLocator.java → ...connector/boot/system/ServiceLocator.java b/...connector/boot/system/ServiceLocator.java → ...connector/boot/system/ServiceLocator.java
diff --git a/...ector/boot/system/ServiceLocatorImpl.java → ...ector/boot/system/ServiceLocatorImpl.java b/...ector/boot/system/ServiceLocatorImpl.java → ...ector/boot/system/ServiceLocatorImpl.java
diff --git a/...r/boot/system/injection/InjectorImpl.java → ...r/boot/system/injection/InjectorImpl.java b/...r/boot/system/injection/InjectorImpl.java → ...r/boot/system/injection/InjectorImpl.java
diff --git a/...em/injection/ReflectiveObjectFactory.java → ...em/injection/ReflectiveObjectFactory.java b/...em/injection/ReflectiveObjectFactory.java → ...em/injection/ReflectiveObjectFactory.java
diff --git a/.../lifecycle/ExtensionLifecycleManager.java → .../lifecycle/ExtensionLifecycleManager.java b/.../lifecycle/ExtensionLifecycleManager.java → .../lifecycle/ExtensionLifecycleManager.java
diff --git a/.../injection/lifecycle/InitializePhase.java → .../injection/lifecycle/InitializePhase.java b/.../injection/lifecycle/InitializePhase.java → .../injection/lifecycle/InitializePhase.java
diff --git a/...oot/system/injection/lifecycle/Phase.java → ...oot/system/injection/lifecycle/Phase.java b/...oot/system/injection/lifecycle/Phase.java → ...oot/system/injection/lifecycle/Phase.java
diff --git a/...tem/injection/lifecycle/PreparePhase.java → ...tem/injection/lifecycle/PreparePhase.java b/...tem/injection/lifecycle/PreparePhase.java → ...tem/injection/lifecycle/PreparePhase.java
diff --git a/...njection/lifecycle/RegistrationPhase.java → ...njection/lifecycle/RegistrationPhase.java b/...njection/lifecycle/RegistrationPhase.java → ...njection/lifecycle/RegistrationPhase.java
diff --git a/...ystem/injection/lifecycle/StartPhase.java → ...ystem/injection/lifecycle/StartPhase.java b/...ystem/injection/lifecycle/StartPhase.java → ...ystem/injection/lifecycle/StartPhase.java
diff --git a/...ctor/boot/system/runtime/BaseRuntime.java → ...ctor/boot/system/runtime/BaseRuntime.java b/...ctor/boot/system/runtime/BaseRuntime.java → ...ctor/boot/system/runtime/BaseRuntime.java
diff --git a/.../boot/util/CyclicDependencyException.java → .../boot/util/CyclicDependencyException.java b/.../boot/util/CyclicDependencyException.java → .../boot/util/CyclicDependencyException.java
diff --git a/...econnector/boot/util/TopologicalSort.java → ...econnector/boot/util/TopologicalSort.java b/...econnector/boot/util/TopologicalSort.java → ...econnector/boot/util/TopologicalSort.java
diff --git a/...rvices/org.slf4j.spi.SLF4JServiceProvider → ...rvices/org.slf4j.spi.SLF4JServiceProvider b/...rvices/org.slf4j.spi.SLF4JServiceProvider → ...rvices/org.slf4j.spi.SLF4JServiceProvider
diff --git a/...m/DefaultServiceExtensionContextTest.java → ...m/DefaultServiceExtensionContextTest.java b/...m/DefaultServiceExtensionContextTest.java → ...m/DefaultServiceExtensionContextTest.java
diff --git a/...ctor/boot/system/DependencyGraphTest.java → ...ctor/boot/system/DependencyGraphTest.java b/...ctor/boot/system/DependencyGraphTest.java → ...ctor/boot/system/DependencyGraphTest.java
diff --git a/...ctor/boot/system/ExtensionLoaderTest.java → ...ctor/boot/system/ExtensionLoaderTest.java b/...ctor/boot/system/ExtensionLoaderTest.java → ...ctor/boot/system/ExtensionLoaderTest.java
diff --git a/...ceconnector/boot/system/InjectorTest.java → ...ceconnector/boot/system/InjectorTest.java b/...ceconnector/boot/system/InjectorTest.java → ...ceconnector/boot/system/InjectorTest.java
diff --git a/...t/system/ReflectiveObjectFactoryTest.java → ...t/system/ReflectiveObjectFactoryTest.java b/...t/system/ReflectiveObjectFactoryTest.java → ...t/system/ReflectiveObjectFactoryTest.java
diff --git a/...econnector/boot/system/TestFunctions.java → ...econnector/boot/system/TestFunctions.java b/...econnector/boot/system/TestFunctions.java → ...econnector/boot/system/TestFunctions.java
diff --git a/...paceconnector/boot/system/TestObject.java → ...paceconnector/boot/system/TestObject.java b/...paceconnector/boot/system/TestObject.java → ...paceconnector/boot/system/TestObject.java
diff --git a/...ection/lifecycle/InitializePhaseTest.java → ...ection/lifecycle/InitializePhaseTest.java b/...ection/lifecycle/InitializePhaseTest.java → ...ection/lifecycle/InitializePhaseTest.java
diff --git a/...system/injection/lifecycle/PhaseTest.java → ...system/injection/lifecycle/PhaseTest.java b/...system/injection/lifecycle/PhaseTest.java → ...system/injection/lifecycle/PhaseTest.java
diff --git a/...tion/lifecycle/RegistrationPhaseTest.java → ...tion/lifecycle/RegistrationPhaseTest.java b/...tion/lifecycle/RegistrationPhaseTest.java → ...tion/lifecycle/RegistrationPhaseTest.java
diff --git a/...m/injection/lifecycle/StartPhaseTest.java → ...m/injection/lifecycle/StartPhaseTest.java b/...m/injection/lifecycle/StartPhaseTest.java → ...m/injection/lifecycle/StartPhaseTest.java
diff --git a/.../system/testextensions/BaseExtension.java → .../system/testextensions/BaseExtension.java b/.../system/testextensions/BaseExtension.java → .../system/testextensions/BaseExtension.java
diff --git a/.../system/testextensions/CoreExtension.java → .../system/testextensions/CoreExtension.java b/.../system/testextensions/CoreExtension.java → .../system/testextensions/CoreExtension.java
diff --git a/...textensions/DefaultProviderExtension.java → ...textensions/DefaultProviderExtension.java b/...textensions/DefaultProviderExtension.java → ...textensions/DefaultProviderExtension.java
diff --git a/...em/testextensions/DependentExtension.java → ...em/testextensions/DependentExtension.java b/...em/testextensions/DependentExtension.java → ...em/testextensions/DependentExtension.java
diff --git a/...tem/testextensions/ProviderExtension.java → ...tem/testextensions/ProviderExtension.java b/...tem/testextensions/ProviderExtension.java → ...tem/testextensions/ProviderExtension.java
diff --git a/...xtensions/RequiredDependentExtension.java → ...xtensions/RequiredDependentExtension.java b/...xtensions/RequiredDependentExtension.java → ...xtensions/RequiredDependentExtension.java
diff --git a/...nector/boot/util/TopologicalSortTest.java → ...nector/boot/util/TopologicalSortTest.java b/...nector/boot/util/TopologicalSortTest.java → ...nector/boot/util/TopologicalSortTest.java
diff --git a/...-extensions/org.mockito.plugins.MockMaker → ...-extensions/org.mockito.plugins.MockMaker b/...-extensions/org.mockito.plugins.MockMaker → ...-extensions/org.mockito.plugins.MockMaker
diff --git a/core/policy/policy-engine/build.gradle.kts → core/common/policy-engine/build.gradle.kts b/core/policy/policy-engine/build.gradle.kts → core/common/policy-engine/build.gradle.kts
@@ -18,7 +18,7 @@ plugins {
 }
 
 dependencies {
-    api(project(":core:policy:policy-evaluator"))
+    api(project(":core:common:policy-evaluator"))
 }
 
 publishing {

diff --git a/...ctor/policy/engine/ConstraintProblem.java → ...ctor/policy/engine/ConstraintProblem.java b/...ctor/policy/engine/ConstraintProblem.java → ...ctor/policy/engine/ConstraintProblem.java
diff --git a/...policy/engine/PolicyEvaluationResult.java → ...policy/engine/PolicyEvaluationResult.java b/...policy/engine/PolicyEvaluationResult.java → ...policy/engine/PolicyEvaluationResult.java
diff --git a/...nector/policy/engine/PolicyEvaluator.java → ...nector/policy/engine/PolicyEvaluator.java b/...nector/policy/engine/PolicyEvaluator.java → ...nector/policy/engine/PolicyEvaluator.java
diff --git a/...econnector/policy/engine/RuleProblem.java → ...econnector/policy/engine/RuleProblem.java b/...econnector/policy/engine/RuleProblem.java → ...econnector/policy/engine/RuleProblem.java
diff --git a/...ne/model/PolicyEvaluatorScenarioTest.java → ...ne/model/PolicyEvaluatorScenarioTest.java b/...ne/model/PolicyEvaluatorScenarioTest.java → ...ne/model/PolicyEvaluatorScenarioTest.java
diff --git a/...icy/engine/model/PolicyEvaluatorTest.java → ...icy/engine/model/PolicyEvaluatorTest.java b/...icy/engine/model/PolicyEvaluatorTest.java → ...icy/engine/model/PolicyEvaluatorTest.java
diff --git a/...icy/engine/model/PolicyTestFunctions.java → ...icy/engine/model/PolicyTestFunctions.java b/...icy/engine/model/PolicyTestFunctions.java → ...icy/engine/model/PolicyTestFunctions.java
diff --git a/.../policy/policy-evaluator/build.gradle.kts → .../common/policy-evaluator/build.gradle.kts b/.../policy/policy-evaluator/build.gradle.kts → .../common/policy-evaluator/build.gradle.kts
diff --git a/...taspaceconnector/policy/model/Action.java → ...taspaceconnector/policy/model/Action.java b/...taspaceconnector/policy/model/Action.java → ...taspaceconnector/policy/model/Action.java
diff --git a/...connector/policy/model/AndConstraint.java → ...connector/policy/model/AndConstraint.java b/...connector/policy/model/AndConstraint.java → ...connector/policy/model/AndConstraint.java
diff --git a/...nector/policy/model/AtomicConstraint.java → ...nector/policy/model/AtomicConstraint.java b/...nector/policy/model/AtomicConstraint.java → ...nector/policy/model/AtomicConstraint.java
diff --git a/...olicy/model/AtomicConstraintFunction.java → ...olicy/model/AtomicConstraintFunction.java b/...olicy/model/AtomicConstraintFunction.java → ...olicy/model/AtomicConstraintFunction.java
diff --git a/...aceconnector/policy/model/Constraint.java → ...aceconnector/policy/model/Constraint.java b/...aceconnector/policy/model/Constraint.java → ...aceconnector/policy/model/Constraint.java
diff --git a/...dataspaceconnector/policy/model/Duty.java → ...dataspaceconnector/policy/model/Duty.java b/...dataspaceconnector/policy/model/Duty.java → ...dataspaceconnector/policy/model/Duty.java
diff --git a/...aceconnector/policy/model/Expression.java → ...aceconnector/policy/model/Expression.java b/...aceconnector/policy/model/Expression.java → ...aceconnector/policy/model/Expression.java
diff --git a/...econnector/policy/model/Identifiable.java → ...econnector/policy/model/Identifiable.java b/...econnector/policy/model/Identifiable.java → ...econnector/policy/model/Identifiable.java
diff --git a/...ector/policy/model/LiteralExpression.java → ...ector/policy/model/LiteralExpression.java b/...ector/policy/model/LiteralExpression.java → ...ector/policy/model/LiteralExpression.java
diff --git a/.../policy/model/MultiplicityConstraint.java → .../policy/model/MultiplicityConstraint.java b/.../policy/model/MultiplicityConstraint.java → .../policy/model/MultiplicityConstraint.java
diff --git a/...spaceconnector/policy/model/Operator.java → ...spaceconnector/policy/model/Operator.java b/...spaceconnector/policy/model/Operator.java → ...spaceconnector/policy/model/Operator.java
diff --git a/...econnector/policy/model/OrConstraint.java → ...econnector/policy/model/OrConstraint.java b/...econnector/policy/model/OrConstraint.java → ...econnector/policy/model/OrConstraint.java
diff --git a/...aceconnector/policy/model/Permission.java → ...aceconnector/policy/model/Permission.java b/...aceconnector/policy/model/Permission.java → ...aceconnector/policy/model/Permission.java
diff --git a/...taspaceconnector/policy/model/Policy.java → ...taspaceconnector/policy/model/Policy.java b/...taspaceconnector/policy/model/Policy.java → ...taspaceconnector/policy/model/Policy.java
diff --git a/...policy/model/PolicyRegistrationTypes.java → ...policy/model/PolicyRegistrationTypes.java b/...policy/model/PolicyRegistrationTypes.java → ...policy/model/PolicyRegistrationTypes.java
diff --git a/...aceconnector/policy/model/PolicyType.java → ...aceconnector/policy/model/PolicyType.java b/...aceconnector/policy/model/PolicyType.java → ...aceconnector/policy/model/PolicyType.java
diff --git a/...ceconnector/policy/model/Prohibition.java → ...ceconnector/policy/model/Prohibition.java b/...ceconnector/policy/model/Prohibition.java → ...ceconnector/policy/model/Prohibition.java
diff --git a/...dataspaceconnector/policy/model/Rule.java → ...dataspaceconnector/policy/model/Rule.java b/...dataspaceconnector/policy/model/Rule.java → ...dataspaceconnector/policy/model/Rule.java
diff --git a/...econnector/policy/model/RuleFunction.java → ...econnector/policy/model/RuleFunction.java b/...econnector/policy/model/RuleFunction.java → ...econnector/policy/model/RuleFunction.java
diff --git a/...onnector/policy/model/XoneConstraint.java → ...onnector/policy/model/XoneConstraint.java b/...onnector/policy/model/XoneConstraint.java → ...onnector/policy/model/XoneConstraint.java
diff --git a/...aceconnector/policy/model/ActionTest.java → ...aceconnector/policy/model/ActionTest.java b/...aceconnector/policy/model/ActionTest.java → ...aceconnector/policy/model/ActionTest.java
diff --git a/...ector/policy/model/AndConstraintTest.java → ...ector/policy/model/AndConstraintTest.java b/...ector/policy/model/AndConstraintTest.java → ...ector/policy/model/AndConstraintTest.java
diff --git a/...or/policy/model/AtomicConstraintTest.java → ...or/policy/model/AtomicConstraintTest.java b/...or/policy/model/AtomicConstraintTest.java → ...or/policy/model/AtomicConstraintTest.java
diff --git a/...spaceconnector/policy/model/DutyTest.java → ...spaceconnector/policy/model/DutyTest.java b/...spaceconnector/policy/model/DutyTest.java → ...spaceconnector/policy/model/DutyTest.java
diff --git a/...r/policy/model/LiteralExpressionTest.java → ...r/policy/model/LiteralExpressionTest.java b/...r/policy/model/LiteralExpressionTest.java → ...r/policy/model/LiteralExpressionTest.java
diff --git a/...nector/policy/model/OrConstraintTest.java → ...nector/policy/model/OrConstraintTest.java b/...nector/policy/model/OrConstraintTest.java → ...nector/policy/model/OrConstraintTest.java
diff --git a/...onnector/policy/model/PermissionTest.java → ...onnector/policy/model/PermissionTest.java b/...onnector/policy/model/PermissionTest.java → ...onnector/policy/model/PermissionTest.java
diff --git a/...aceconnector/policy/model/PolicyTest.java → ...aceconnector/policy/model/PolicyTest.java b/...aceconnector/policy/model/PolicyTest.java → ...aceconnector/policy/model/PolicyTest.java
diff --git a/...onnector/policy/model/PolicyTypeTest.java → ...onnector/policy/model/PolicyTypeTest.java b/...onnector/policy/model/PolicyTypeTest.java → ...onnector/policy/model/PolicyTypeTest.java
diff --git a/...nnector/policy/model/ProhibitionTest.java → ...nnector/policy/model/ProhibitionTest.java b/...nnector/policy/model/ProhibitionTest.java → ...nnector/policy/model/ProhibitionTest.java
diff --git a/...ctor/policy/model/XoneConstraintTest.java → ...ctor/policy/model/XoneConstraintTest.java b/...ctor/policy/model/XoneConstraintTest.java → ...ctor/policy/model/XoneConstraintTest.java
diff --git a/core/contract/README.md → core/control-plane/contract/README.md b/core/contract/README.md → core/control-plane/contract/README.md
diff --git a/core/contract/build.gradle.kts → core/control-plane/contract/build.gradle.kts b/core/contract/build.gradle.kts → core/control-plane/contract/build.gradle.kts
@@ -27,7 +27,7 @@ dependencies {
     implementation(project(":common:state-machine-lib"))
     implementation("io.opentelemetry:opentelemetry-extension-annotations:${openTelemetryVersion}")
 
-    testImplementation(project(":core:defaults"))
+    testImplementation(project(":core:control-plane:control-plane-core"))
     testImplementation(project(":extensions:junit"))
     testImplementation(testFixtures(project(":common:util")))
     testImplementation("org.awaitility:awaitility:${awaitility}")

diff --git a/.../ContractNegotiationCommandExtension.java → .../ContractNegotiationCommandExtension.java b/.../ContractNegotiationCommandExtension.java → .../ContractNegotiationCommandExtension.java
diff --git a/...or/contract/ContractServiceExtension.java → ...or/contract/ContractServiceExtension.java b/...or/contract/ContractServiceExtension.java → ...or/contract/ContractServiceExtension.java
diff --git a/...ner/ContractNegotiationEventListener.java → ...ner/ContractNegotiationEventListener.java b/...ner/ContractNegotiationEventListener.java → ...ner/ContractNegotiationEventListener.java
diff --git a/...n/AbstractContractNegotiationManager.java → ...n/AbstractContractNegotiationManager.java b/...n/AbstractContractNegotiationManager.java → ...n/AbstractContractNegotiationManager.java
diff --git a/...nsumerContractNegotiationManagerImpl.java → ...nsumerContractNegotiationManagerImpl.java b/...nsumerContractNegotiationManagerImpl.java → ...nsumerContractNegotiationManagerImpl.java
@@ -20,8 +20,8 @@
 import io.opentelemetry.extension.annotations.WithSpan;
 import org.eclipse.dataspaceconnector.common.statemachine.StateMachineManager;
 import org.eclipse.dataspaceconnector.common.statemachine.StateProcessorImpl;
-import org.eclipse.dataspaceconnector.contract.common.ContractId;
 import org.eclipse.dataspaceconnector.policy.model.Policy;
+import org.eclipse.dataspaceconnector.spi.contract.ContractId;
 import org.eclipse.dataspaceconnector.spi.contract.negotiation.ConsumerContractNegotiationManager;
 import org.eclipse.dataspaceconnector.spi.iam.ClaimToken;
 import org.eclipse.dataspaceconnector.spi.response.StatusResult;
@@ -44,8 +44,8 @@
 import java.util.function.Function;
 
 import static java.lang.String.format;
-import static org.eclipse.dataspaceconnector.contract.common.ContractId.DEFINITION_PART;
-import static org.eclipse.dataspaceconnector.contract.common.ContractId.parseContractId;
+import static org.eclipse.dataspaceconnector.spi.contract.ContractId.DEFINITION_PART;
+import static org.eclipse.dataspaceconnector.spi.contract.ContractId.parseContractId;
 import static org.eclipse.dataspaceconnector.spi.response.ResponseStatus.FATAL_ERROR;
 import static org.eclipse.dataspaceconnector.spi.types.domain.contract.negotiation.ContractNegotiation.Type.CONSUMER;
 import static org.eclipse.dataspaceconnector.spi.types.domain.contract.negotiation.ContractNegotiationStates.CONFIRMED;

diff --git a/...oviderContractNegotiationManagerImpl.java → ...oviderContractNegotiationManagerImpl.java b/...oviderContractNegotiationManagerImpl.java → ...oviderContractNegotiationManagerImpl.java
@@ -20,8 +20,8 @@
 import io.opentelemetry.extension.annotations.WithSpan;
 import org.eclipse.dataspaceconnector.common.statemachine.StateMachineManager;
 import org.eclipse.dataspaceconnector.common.statemachine.StateProcessorImpl;
-import org.eclipse.dataspaceconnector.contract.common.ContractId;
 import org.eclipse.dataspaceconnector.policy.model.Policy;
+import org.eclipse.dataspaceconnector.spi.contract.ContractId;
 import org.eclipse.dataspaceconnector.spi.contract.negotiation.ProviderContractNegotiationManager;
 import org.eclipse.dataspaceconnector.spi.iam.ClaimToken;
 import org.eclipse.dataspaceconnector.spi.response.StatusResult;
@@ -41,8 +41,8 @@
 import java.util.function.BiConsumer;
 import java.util.function.Function;
 
-import static org.eclipse.dataspaceconnector.contract.common.ContractId.DEFINITION_PART;
-import static org.eclipse.dataspaceconnector.contract.common.ContractId.parseContractId;
+import static org.eclipse.dataspaceconnector.spi.contract.ContractId.DEFINITION_PART;
+import static org.eclipse.dataspaceconnector.spi.contract.ContractId.parseContractId;
 import static org.eclipse.dataspaceconnector.spi.response.ResponseStatus.FATAL_ERROR;
 import static org.eclipse.dataspaceconnector.spi.types.domain.contract.negotiation.ContractNegotiation.Type.PROVIDER;
 import static org.eclipse.dataspaceconnector.spi.types.domain.contract.negotiation.ContractNegotiationStates.CONFIRMING;

diff --git a/...lers/CancelNegotiationCommandHandler.java → ...lers/CancelNegotiationCommandHandler.java b/...lers/CancelNegotiationCommandHandler.java → ...lers/CancelNegotiationCommandHandler.java
@@ -14,8 +14,8 @@
 
 package org.eclipse.dataspaceconnector.contract.negotiation.command.handlers;
 
-import org.eclipse.dataspaceconnector.contract.negotiation.command.commands.CancelNegotiationCommand;
 import org.eclipse.dataspaceconnector.spi.contract.negotiation.store.ContractNegotiationStore;
+import org.eclipse.dataspaceconnector.spi.types.domain.contract.command.CancelNegotiationCommand;
 import org.eclipse.dataspaceconnector.spi.types.domain.contract.negotiation.ContractNegotiation;
 
 /**

diff --git a/...gleContractNegotiationCommandHandler.java → ...gleContractNegotiationCommandHandler.java b/...gleContractNegotiationCommandHandler.java → ...gleContractNegotiationCommandHandler.java
@@ -14,10 +14,10 @@
 
 package org.eclipse.dataspaceconnector.contract.negotiation.command.handlers;
 
-import org.eclipse.dataspaceconnector.contract.negotiation.command.commands.SingleContractNegotiationCommand;
 import org.eclipse.dataspaceconnector.spi.EdcException;
 import org.eclipse.dataspaceconnector.spi.command.CommandHandler;
 import org.eclipse.dataspaceconnector.spi.contract.negotiation.store.ContractNegotiationStore;
+import org.eclipse.dataspaceconnector.spi.types.domain.contract.command.SingleContractNegotiationCommand;
 import org.eclipse.dataspaceconnector.spi.types.domain.contract.negotiation.ContractNegotiation;
 
 import static java.lang.String.format;

diff --git a/...ve/ContractNegotiationObservableImpl.java → ...ve/ContractNegotiationObservableImpl.java b/...ve/ContractNegotiationObservableImpl.java → ...ve/ContractNegotiationObservableImpl.java
diff --git a/.../offer/ContractDefinitionServiceImpl.java → .../offer/ContractDefinitionServiceImpl.java b/.../offer/ContractDefinitionServiceImpl.java → .../offer/ContractDefinitionServiceImpl.java
diff --git a/...tract/offer/ContractOfferServiceImpl.java → ...tract/offer/ContractOfferServiceImpl.java b/...tract/offer/ContractOfferServiceImpl.java → ...tract/offer/ContractOfferServiceImpl.java
@@ -17,10 +17,10 @@
 
 package org.eclipse.dataspaceconnector.contract.offer;
 
-import org.eclipse.dataspaceconnector.contract.common.ContractId;
 import org.eclipse.dataspaceconnector.policy.model.Policy;
 import org.eclipse.dataspaceconnector.spi.agent.ParticipantAgentService;
 import org.eclipse.dataspaceconnector.spi.asset.AssetIndex;
+import org.eclipse.dataspaceconnector.spi.contract.ContractId;
 import org.eclipse.dataspaceconnector.spi.contract.offer.ContractDefinitionService;
 import org.eclipse.dataspaceconnector.spi.contract.offer.ContractOfferQuery;
 import org.eclipse.dataspaceconnector.spi.contract.offer.ContractOfferService;

diff --git a/...or/contract/policy/PolicyArchiveImpl.java → ...or/contract/policy/PolicyArchiveImpl.java b/...or/contract/policy/PolicyArchiveImpl.java → ...or/contract/policy/PolicyArchiveImpl.java
diff --git a/...ector/contract/policy/PolicyEquality.java → ...ector/contract/policy/PolicyEquality.java b/...ector/contract/policy/PolicyEquality.java → ...ector/contract/policy/PolicyEquality.java
diff --git a/...dation/ContractValidationServiceImpl.java → ...dation/ContractValidationServiceImpl.java b/...dation/ContractValidationServiceImpl.java → ...dation/ContractValidationServiceImpl.java
@@ -32,8 +32,8 @@
 import java.time.Clock;
 
 import static java.lang.String.format;
-import static org.eclipse.dataspaceconnector.contract.common.ContractId.DEFINITION_PART;
-import static org.eclipse.dataspaceconnector.contract.common.ContractId.parseContractId;
+import static org.eclipse.dataspaceconnector.spi.contract.ContractId.DEFINITION_PART;
+import static org.eclipse.dataspaceconnector.spi.contract.ContractId.parseContractId;
 
 /**
  * Implementation of the {@link ContractValidationService}.

diff --git a/...paceconnector.spi.system.ServiceExtension → ...paceconnector.spi.system.ServiceExtension b/...paceconnector.spi.system.ServiceExtension → ...paceconnector.spi.system.ServiceExtension
diff --git a/...ontract/ContractServiceExtensionTest.java → ...ontract/ContractServiceExtensionTest.java b/...ontract/ContractServiceExtensionTest.java → ...ontract/ContractServiceExtensionTest.java
diff --git a/...ctContractNegotiationIntegrationTest.java → ...ctContractNegotiationIntegrationTest.java b/...ctContractNegotiationIntegrationTest.java → ...ctContractNegotiationIntegrationTest.java
@@ -15,15 +15,15 @@
 package org.eclipse.dataspaceconnector.contract.negotiation;
 
 import org.eclipse.dataspaceconnector.common.statemachine.retry.SendRetryManager;
-import org.eclipse.dataspaceconnector.contract.common.ContractId;
 import org.eclipse.dataspaceconnector.contract.observe.ContractNegotiationObservableImpl;
-import org.eclipse.dataspaceconnector.core.defaults.negotiationstore.InMemoryContractNegotiationStore;
+import org.eclipse.dataspaceconnector.core.controlplane.defaults.negotiationstore.InMemoryContractNegotiationStore;
 import org.eclipse.dataspaceconnector.policy.model.Action;
 import org.eclipse.dataspaceconnector.policy.model.Duty;
 import org.eclipse.dataspaceconnector.policy.model.Policy;
 import org.eclipse.dataspaceconnector.policy.model.PolicyType;
 import org.eclipse.dataspaceconnector.spi.command.CommandQueue;
 import org.eclipse.dataspaceconnector.spi.command.CommandRunner;
+import org.eclipse.dataspaceconnector.spi.contract.ContractId;
 import org.eclipse.dataspaceconnector.spi.contract.negotiation.observe.ContractNegotiationObservable;
 import org.eclipse.dataspaceconnector.spi.contract.validation.ContractValidationService;
 import org.eclipse.dataspaceconnector.spi.entity.StatefulEntity;

diff --git a/...erContractNegotiationManagerImplTest.java → ...erContractNegotiationManagerImplTest.java b/...erContractNegotiationManagerImplTest.java → ...erContractNegotiationManagerImplTest.java
diff --git a/...n/ContractNegotiationIntegrationTest.java → ...n/ContractNegotiationIntegrationTest.java b/...n/ContractNegotiationIntegrationTest.java → ...n/ContractNegotiationIntegrationTest.java
diff --git a/...erContractNegotiationManagerImplTest.java → ...erContractNegotiationManagerImplTest.java b/...erContractNegotiationManagerImplTest.java → ...erContractNegotiationManagerImplTest.java
@@ -16,12 +16,12 @@
 package org.eclipse.dataspaceconnector.contract.negotiation;
 
 import org.eclipse.dataspaceconnector.common.statemachine.retry.SendRetryManager;
-import org.eclipse.dataspaceconnector.contract.common.ContractId;
 import org.eclipse.dataspaceconnector.contract.observe.ContractNegotiationObservableImpl;
 import org.eclipse.dataspaceconnector.policy.model.Policy;
 import org.eclipse.dataspaceconnector.spi.EdcException;
 import org.eclipse.dataspaceconnector.spi.command.CommandQueue;
 import org.eclipse.dataspaceconnector.spi.command.CommandRunner;
+import org.eclipse.dataspaceconnector.spi.contract.ContractId;
 import org.eclipse.dataspaceconnector.spi.contract.negotiation.observe.ContractNegotiationListener;
 import org.eclipse.dataspaceconnector.spi.contract.negotiation.store.ContractNegotiationStore;
 import org.eclipse.dataspaceconnector.spi.contract.validation.ContractValidationService;

diff --git a/...gotiationCommandQueueIntegrationTest.java → ...gotiationCommandQueueIntegrationTest.java b/...gotiationCommandQueueIntegrationTest.java → ...gotiationCommandQueueIntegrationTest.java
@@ -17,7 +17,6 @@
 import org.eclipse.dataspaceconnector.common.statemachine.retry.SendRetryManager;
 import org.eclipse.dataspaceconnector.contract.negotiation.ConsumerContractNegotiationManagerImpl;
 import org.eclipse.dataspaceconnector.contract.negotiation.ProviderContractNegotiationManagerImpl;
-import org.eclipse.dataspaceconnector.contract.negotiation.command.commands.SingleContractNegotiationCommand;
 import org.eclipse.dataspaceconnector.contract.negotiation.command.handlers.SingleContractNegotiationCommandHandler;
 import org.eclipse.dataspaceconnector.spi.command.BoundedCommandQueue;
 import org.eclipse.dataspaceconnector.spi.command.CommandHandlerRegistry;
@@ -30,6 +29,7 @@
 import org.eclipse.dataspaceconnector.spi.message.RemoteMessageDispatcherRegistry;
 import org.eclipse.dataspaceconnector.spi.monitor.Monitor;
 import org.eclipse.dataspaceconnector.spi.policy.store.PolicyDefinitionStore;
+import org.eclipse.dataspaceconnector.spi.types.domain.contract.command.SingleContractNegotiationCommand;
 import org.eclipse.dataspaceconnector.spi.types.domain.contract.negotiation.ContractNegotiation;
 import org.eclipse.dataspaceconnector.spi.types.domain.contract.negotiation.ContractNegotiationStates;
 import org.eclipse.dataspaceconnector.spi.types.domain.contract.negotiation.command.ContractNegotiationCommand;

diff --git a/.../CancelNegotiationCommandHandlerTest.java → .../CancelNegotiationCommandHandlerTest.java b/.../CancelNegotiationCommandHandlerTest.java → .../CancelNegotiationCommandHandlerTest.java
@@ -14,9 +14,9 @@
 
 package org.eclipse.dataspaceconnector.contract.negotiation.command.handlers;
 
-import org.eclipse.dataspaceconnector.contract.negotiation.command.commands.CancelNegotiationCommand;
 import org.eclipse.dataspaceconnector.spi.EdcException;
 import org.eclipse.dataspaceconnector.spi.contract.negotiation.store.ContractNegotiationStore;
+import org.eclipse.dataspaceconnector.spi.types.domain.contract.command.CancelNegotiationCommand;
 import org.eclipse.dataspaceconnector.spi.types.domain.contract.negotiation.ContractNegotiation;
 import org.eclipse.dataspaceconnector.spi.types.domain.contract.negotiation.ContractNegotiationStates;
 import org.junit.jupiter.api.BeforeEach;

diff --git a/...er/ContractDefinitionServiceImplTest.java → ...er/ContractDefinitionServiceImplTest.java b/...er/ContractDefinitionServiceImplTest.java → ...er/ContractDefinitionServiceImplTest.java
diff --git a/...t/offer/ContractOfferServiceImplTest.java → ...t/offer/ContractOfferServiceImplTest.java b/...t/offer/ContractOfferServiceImplTest.java → ...t/offer/ContractOfferServiceImplTest.java
diff --git a/...ontract/policy/PolicyArchiveImplTest.java → ...ontract/policy/PolicyArchiveImplTest.java b/...ontract/policy/PolicyArchiveImplTest.java → ...ontract/policy/PolicyArchiveImplTest.java
diff --git a/...r/contract/policy/PolicyEqualityTest.java → ...r/contract/policy/PolicyEqualityTest.java b/...r/contract/policy/PolicyEqualityTest.java → ...r/contract/policy/PolicyEqualityTest.java
diff --git a/...on/ContractValidationServiceImplTest.java → ...on/ContractValidationServiceImplTest.java b/...on/ContractValidationServiceImplTest.java → ...on/ContractValidationServiceImplTest.java
diff --git a/core/control-plane/control-plane-core/build.gradle.kts b/core/control-plane/control-plane-core/build.gradle.kts
@@ -0,0 +1,37 @@
+/*
+ *  Copyright (c) 2022 Bayerische Motoren Werke Aktiengesellschaft (BMW AG)
+ *
+ *  This program and the accompanying materials are made available under the
+ *  terms of the Apache License, Version 2.0 which is available at
+ *  https://www.apache.org/licenses/LICENSE-2.0
+ *
+ *  SPDX-License-Identifier: Apache-2.0
+ *
+ *  Contributors:
+ *       Bayerische Motoren Werke Aktiengesellschaft (BMW AG) - initial API and implementation
+ *
+ */
+
+plugins {
+    `java-library`
+}
+
+
+dependencies {
+    api(project(":core:common:base"))
+    api(project(":core:common:boot"))
+    api(project(":core:common:policy-engine"))
+    api(project(":core:control-plane:contract"))
+    api(project(":core:control-plane:transfer"))
+    implementation(project(":common:util"))
+    implementation(project(":extensions:dataloading"))
+}
+
+publishing {
+    publications {
+        create<MavenPublication>("control-plane-core") {
+            artifactId = "control-plane-core"
+            from(components["java"])
+        }
+    }
+}