fix compilation

ndr-brt · ndr-brt · commit 5b8e6062562f · 2025-05-29T14:06:17.000+02:00
diff --git a/basic/basic-01-basic-connector/README.md b/basic/basic-01-basic-connector/README.md
@@ -15,6 +15,7 @@ that contains the essential dependencies. We'll need at least the following thin
 ```kotlin
 dependencies {
     implementation(libs.edc.boot)
+    implementation(libs.edc.runtime.core)
     implementation(libs.edc.connector.core)
 }
 ```
diff --git a/basic/basic-01-basic-connector/build.gradle.kts b/basic/basic-01-basic-connector/build.gradle.kts
@@ -21,6 +21,7 @@ plugins {
 
 dependencies {
     implementation(libs.edc.boot)
+    implementation(libs.edc.runtime.core)
     implementation(libs.edc.connector.core)
     implementation(libs.edc.http)
 }
diff --git a/basic/basic-02-health-endpoint/build.gradle.kts b/basic/basic-02-health-endpoint/build.gradle.kts
@@ -21,6 +21,7 @@ plugins {
 
 dependencies {
     implementation(libs.edc.boot)
+    implementation(libs.edc.runtime.core)
     implementation(libs.edc.connector.core)
 
     implementation(libs.edc.http)
diff --git a/basic/basic-03-configuration/build.gradle.kts b/basic/basic-03-configuration/build.gradle.kts
@@ -22,6 +22,7 @@ plugins {
 
 dependencies {
     implementation(libs.edc.boot)
+    implementation(libs.edc.runtime.core)
     implementation(libs.edc.connector.core)
     
     implementation(libs.edc.http)
diff --git a/federated-catalog/fc-00-basic/fixed-node-resolver/src/main/java/org/eclipse/edc/sample/extension/fc/CatalogNodeDirectory.java b/federated-catalog/fc-00-basic/fixed-node-resolver/src/main/java/org/eclipse/edc/sample/extension/fc/CatalogNodeDirectory.java
@@ -17,19 +17,15 @@
 import org.eclipse.edc.crawler.spi.TargetNode;
 import org.eclipse.edc.crawler.spi.TargetNodeDirectory;
 
-import java.util.ArrayList;
 import java.util.List;
 
 public class CatalogNodeDirectory implements TargetNodeDirectory {
 
     @Override
     public List<TargetNode> getAll() {
-        List<String> protocolList = new ArrayList<>();
-        protocolList.add("dataspace-protocol-http");
-
-        TargetNode participantNode = new TargetNode("https://w3id.org/edc/v0.0.1/ns/",
+        var participantNode = new TargetNode("https://w3id.org/edc/v0.0.1/ns/",
                 "provider",
-                "http://localhost:19194/protocol", protocolList);
+                "http://localhost:19194/protocol", List.of("dataspace-protocol-http"));
 
         return List.of(participantNode);
     }
@@ -38,4 +34,9 @@ public List<TargetNode> getAll() {
     public void insert(TargetNode targetNode) {
 
     }
+
+    @Override
+    public TargetNode remove(String s) {
+        return null;
+    }
 }
diff --git a/federated-catalog/fc-01-embedded/fc-connector/build.gradle.kts b/federated-catalog/fc-01-embedded/fc-connector/build.gradle.kts
@@ -22,6 +22,7 @@ dependencies {
     runtimeOnly(project(":federated-catalog:fc-00-basic:federated-catalog-base"))
     runtimeOnly(project(":federated-catalog:fc-00-basic:fixed-node-resolver"))
 
+    implementation(libs.edc.runtime.core)
     implementation(libs.edc.connector.core)
     implementation(libs.edc.control.plane.core)
     implementation(libs.edc.configuration.filesystem)
diff --git a/federated-catalog/fc-02-standalone/standalone-fc/build.gradle.kts b/federated-catalog/fc-02-standalone/standalone-fc/build.gradle.kts
@@ -22,6 +22,7 @@ dependencies {
     runtimeOnly(project(":federated-catalog:fc-00-basic:federated-catalog-base"))
     runtimeOnly(project(":federated-catalog:fc-00-basic:fixed-node-resolver"))
 
+    implementation(libs.edc.runtime.core)
     implementation(libs.edc.connector.core)
     runtimeOnly(libs.edc.boot)
     runtimeOnly(libs.edc.control.plane.core)
diff --git a/federated-catalog/fc-03-static-node-directory/embedded-fc-with-node-resolver/build.gradle.kts b/federated-catalog/fc-03-static-node-directory/embedded-fc-with-node-resolver/build.gradle.kts
@@ -22,6 +22,7 @@ dependencies {
     runtimeOnly(project(":federated-catalog:fc-00-basic:federated-catalog-base"))
     runtimeOnly(project(":federated-catalog:fc-03-static-node-directory:target-node-resolver"))
 
+    implementation(libs.edc.runtime.core)
     implementation(libs.edc.connector.core)
     implementation(libs.edc.control.plane.core)
     implementation(libs.edc.configuration.filesystem)
diff --git a/federated-catalog/fc-03-static-node-directory/standalone-fc-with-node-resolver/build.gradle.kts b/federated-catalog/fc-03-static-node-directory/standalone-fc-with-node-resolver/build.gradle.kts
@@ -22,6 +22,7 @@ dependencies {
     runtimeOnly(project(":federated-catalog:fc-00-basic:federated-catalog-base"))
     runtimeOnly(project(":federated-catalog:fc-03-static-node-directory:target-node-resolver"))
 
+    implementation(libs.edc.runtime.core)
     implementation(libs.edc.connector.core)
     runtimeOnly(libs.edc.boot)
     runtimeOnly(libs.edc.control.plane.core)
diff --git a/federated-catalog/fc-03-static-node-directory/target-node-resolver/src/main/java/org/eclipse/edc/sample/extension/fc/CatalogNodeDirectory.java b/federated-catalog/fc-03-static-node-directory/target-node-resolver/src/main/java/org/eclipse/edc/sample/extension/fc/CatalogNodeDirectory.java
@@ -46,4 +46,9 @@ public List<TargetNode> getAll() {
     public void insert(TargetNode targetNode) {
 
     }
+
+    @Override
+    public TargetNode remove(String s) {
+        return null;
+    }
 }
diff --git a/gradle/libs.versions.toml b/gradle/libs.versions.toml
@@ -50,6 +50,7 @@ edc-junit = { module = "org.eclipse.edc:junit", version.ref = "edc" }
 edc-management-api = { module = "org.eclipse.edc:management-api", version.ref = "edc" }
 edc-management-api-test-fixtures = { module = "org.eclipse.edc:management-api-test-fixtures", version.ref = "edc" }
 edc-monitor-jdk-logger = { module = "org.eclipse.edc:monitor-jdk-logger", version.ref = "edc" }
+edc-runtime-core = { module = "org.eclipse.edc:runtime-core", version.ref = "edc" }
 edc-token-core = { module = "org.eclipse.edc:token-core", version.ref = "edc" }
 edc-transfer-data-plane-signaling = { module = "org.eclipse.edc:transfer-data-plane-signaling", version.ref = "edc" }
 edc-vault-hashicorp = { module = "org.eclipse.edc:vault-hashicorp", version.ref = "edc" }
diff --git a/policy/policy-01-policy-enforcement/policy-enforcement-consumer/build.gradle.kts b/policy/policy-01-policy-enforcement/policy-enforcement-consumer/build.gradle.kts
@@ -19,6 +19,7 @@ plugins {
 }
 
 dependencies {
+    implementation(libs.edc.runtime.core)
     implementation(libs.edc.connector.core)
     implementation(libs.edc.control.plane.core)
     implementation(libs.edc.edr.store.core)
diff --git a/policy/policy-01-policy-enforcement/policy-enforcement-provider/build.gradle.kts b/policy/policy-01-policy-enforcement/policy-enforcement-provider/build.gradle.kts
@@ -20,6 +20,7 @@ plugins {
 
 
 dependencies {
+    implementation(libs.edc.runtime.core)
     implementation(libs.edc.connector.core)
     implementation(libs.edc.control.plane.core)
     implementation(libs.edc.edr.store.core)
diff --git a/transfer/streaming/streaming-03-kafka-broker/streaming-03-runtime/src/main/java/org/eclipse/edc/samples/streaming/KafkaToKafkaDataFlowController.java b/transfer/streaming/streaming-03-kafka-broker/streaming-03-runtime/src/main/java/org/eclipse/edc/samples/streaming/KafkaToKafkaDataFlowController.java
@@ -36,6 +36,12 @@ public boolean canHandle(TransferProcess transferProcess) {
         return KAFKA_TYPE.equals(transferProcess.getContentDataAddress().getType()) && "KafkaBroker-PULL".equals(transferProcess.getTransferType());
     }
 
+    @Override
+    public StatusResult<DataFlowResponse> provision(TransferProcess transferProcess, Policy policy) {
+        // here the flow can be provisioned, not something covered in this sample
+        return StatusResult.success(null);
+    }
+
     @Override
     public @NotNull StatusResult<DataFlowResponse> start(TransferProcess transferProcess, Policy policy) {
         // static credentials, in a production case these should be created dynamically and an ACLs entry should be added

Original file line number	Diff line number	Diff line change
`@@ -15,6 +15,7 @@ that contains the essential dependencies. We'll need at least the following thin`
`15`	`15`	```kotlin
`16`	`16`	`dependencies {`
`17`	`17`	`implementation(libs.edc.boot)`
	`18`	`+ implementation(libs.edc.runtime.core)`
`18`	`19`	`implementation(libs.edc.connector.core)`
`19`	`20`	`}`
`20`	`21`	```
Original file line number	Diff line number	Diff line change
`@@ -21,6 +21,7 @@ plugins {`
`21`	`21`
`22`	`22`	`dependencies {`
`23`	`23`	`implementation(libs.edc.boot)`
	`24`	`+ implementation(libs.edc.runtime.core)`
`24`	`25`	`implementation(libs.edc.connector.core)`
`25`	`26`	`implementation(libs.edc.http)`
`26`	`27`	`}`
Original file line number	Diff line number	Diff line change
`@@ -46,4 +46,9 @@ public List<TargetNode> getAll() {`
`46`	`46`	`public void insert(TargetNode targetNode) {`
`47`	`47`
`48`	`48`	`}`
	`49`	`+`
	`50`	`+ @Override`
	`51`	`+ public TargetNode remove(String s) {`
	`52`	`+ return null;`
	`53`	`+ }`
`49`	`54`	`}`