feat: contract negotiation and transfer process task executor (#5617)

Author: wolf4ood

core/common/task-core/src/main/java/org/eclipse/edc/controlplane/tasks/TaskTypes.java

@@ -14,10 +14,8 @@
 
 package org.eclipse.edc.controlplane.tasks;
 
-import org.eclipse.edc.controlplane.contract.spi.negotiation.tasks.AcceptNegotiation;
 import org.eclipse.edc.controlplane.contract.spi.negotiation.tasks.AgreeNegotiation;
 import org.eclipse.edc.controlplane.contract.spi.negotiation.tasks.FinalizeNegotiation;
-import org.eclipse.edc.controlplane.contract.spi.negotiation.tasks.OfferNegotiation;
 import org.eclipse.edc.controlplane.contract.spi.negotiation.tasks.RequestNegotiation;
 import org.eclipse.edc.controlplane.contract.spi.negotiation.tasks.SendAccept;
 import org.eclipse.edc.controlplane.contract.spi.negotiation.tasks.SendAgreement;
@@ -47,10 +45,8 @@ public class TaskTypes {
     public static final List<Class<?>> TYPES = List.of(
             RequestNegotiation.class,
             SendRequestNegotiation.class,
-            AcceptNegotiation.class,
             SendAccept.class,
             AgreeNegotiation.class,
-            OfferNegotiation.class,
             SendAgreement.class,
             SendOffer.class,
             SendTerminateNegotiation.class,

core/control-plane/control-plane-contract-task-executor/build.gradle.kts

@@ -0,0 +1,28 @@
+/*
+ *  Copyright (c) 2025 Metaform Systems, Inc.
+ *
+ *  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:
+ *       Metaform Systems, Inc. - initial API and implementation
+ *
+ */
+
+plugins {
+    `java-library`
+}
+
+dependencies {
+    api(project(":spi:common:task-spi"))
+    api(project(":spi:common:transaction-spi"))
+    api(project(":spi:control-plane:contract-spi"))
+    implementation(libs.opentelemetry.instrumentation.annotations)
+    testImplementation(project(":core:control-plane:control-plane-contract"))
+    testImplementation(project(":core:common:lib:state-machine-lib"))
+
+}
+

core/control-plane/control-plane-contract-task-executor/src/main/java/org/eclipse/edc/controlplane/contract/negotiation/tasks/ContractNegotiationTaskExtension.java

@@ -0,0 +1,76 @@
+/*
+ *  Copyright (c) 2026 Metaform Systems, Inc.
+ *
+ *  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:
+ *       Metaform Systems, Inc. - initial API and implementation
+ *
+ */
+
+package org.eclipse.edc.controlplane.contract.negotiation.tasks;
+
+import org.eclipse.edc.connector.controlplane.contract.spi.negotiation.ContractNegotiationPendingGuard;
+import org.eclipse.edc.connector.controlplane.contract.spi.negotiation.NegotiationProcessors;
+import org.eclipse.edc.connector.controlplane.contract.spi.negotiation.observe.ContractNegotiationObservable;
+import org.eclipse.edc.connector.controlplane.contract.spi.negotiation.store.ContractNegotiationStore;
+import org.eclipse.edc.controlplane.contract.negotiation.tasks.executor.ContractNegotiationTaskExecutorImpl;
+import org.eclipse.edc.controlplane.contract.negotiation.tasks.listener.ContractNegotiationStateListener;
+import org.eclipse.edc.controlplane.contract.spi.negotiation.ContractNegotiationTaskExecutor;
+import org.eclipse.edc.controlplane.tasks.TaskService;
+import org.eclipse.edc.runtime.metamodel.annotation.Extension;
+import org.eclipse.edc.runtime.metamodel.annotation.Inject;
+import org.eclipse.edc.runtime.metamodel.annotation.Provider;
+import org.eclipse.edc.spi.monitor.Monitor;
+import org.eclipse.edc.spi.system.ServiceExtension;
+import org.eclipse.edc.spi.system.ServiceExtensionContext;
+import org.eclipse.edc.transaction.spi.TransactionContext;
+
+import java.time.Clock;
+
+import static org.eclipse.edc.controlplane.contract.negotiation.tasks.ContractNegotiationTaskExtension.NAME;
+
+@Extension(NAME)
+public class ContractNegotiationTaskExtension implements ServiceExtension {
+
+    public static final String NAME = "Contract Negotiation Task Extension";
+    @Inject
+    private ContractNegotiationStore contractNegotiationStore;
+    @Inject
+    private TransactionContext transactionContext;
+    @Inject
+    private ContractNegotiationPendingGuard pendingGuard;
+    @Inject
+    private Monitor monitor;
+    @Inject
+    private TaskService taskService;
+    @Inject
+    private NegotiationProcessors negotiationProcessors;
+    @Inject
+    private Clock clock;
+    @Inject
+    private ContractNegotiationObservable contractNegotiationObservable;
+
+
+    @Override
+    public void initialize(ServiceExtensionContext context) {
+        contractNegotiationObservable.registerListener(new ContractNegotiationStateListener(taskService, clock));
+    }
+
+    @Provider
+    public ContractNegotiationTaskExecutor contractNegotiationTaskExecutor() {
+        return ContractNegotiationTaskExecutorImpl.Builder.newInstance()
+                .taskService(taskService)
+                .negotiationProcessors(negotiationProcessors)
+                .clock(clock)
+                .store(contractNegotiationStore)
+                .transactionContext(transactionContext)
+                .pendingGuard(pendingGuard)
+                .monitor(monitor)
+                .build();
+    }
+}