From ba14dd452ac71dcdd4c08121b4aca0a78442a77a Mon Sep 17 00:00:00 2001 From: ndr_brt Date: Thu, 27 Aug 2026 16:24:28 +0200 Subject: [PATCH] feat: support DPS 1.0-RC4 --- .../src/main/java/org/eclipse/dataplane/Dataplane.java | 4 ++-- .../dataplane/domain/dataflow/DataFlowPrepareMessage.java | 2 +- .../dataplane/domain/dataflow/DataFlowStartMessage.java | 2 +- gradle/libs.versions.toml | 2 +- 4 files changed, 5 insertions(+), 5 deletions(-) diff --git a/dataplane-sdk-core/src/main/java/org/eclipse/dataplane/Dataplane.java b/dataplane-sdk-core/src/main/java/org/eclipse/dataplane/Dataplane.java index 725a5bb..ec55c81 100644 --- a/dataplane-sdk-core/src/main/java/org/eclipse/dataplane/Dataplane.java +++ b/dataplane-sdk-core/src/main/java/org/eclipse/dataplane/Dataplane.java @@ -111,7 +111,7 @@ public Result status(String dataFlowId) { public Result prepare(String controlplaneId, DataFlowPrepareMessage message) { return getControlPlane(controlplaneId) .map(controlPlane -> DataFlow.newInstance() - .id(message.processId()) + .id(message.dataFlowId()) .state(DataFlow.State.INITIATING) .labels(message.labels()) .metadata(message.metadata()) @@ -146,7 +146,7 @@ public Result prepare(String controlplaneId, DataFlowPrep public Result start(String controlplaneId, DataFlowStartMessage message) { return getControlPlane(controlplaneId) .map(controlPlane -> DataFlow.newInstance() - .id(message.processId()) + .id(message.dataFlowId()) .state(DataFlow.State.INITIATING) .dataAddress(message.dataAddress()) .callbackAddress(controlPlane.getEndpoint()) diff --git a/dataplane-sdk-core/src/main/java/org/eclipse/dataplane/domain/dataflow/DataFlowPrepareMessage.java b/dataplane-sdk-core/src/main/java/org/eclipse/dataplane/domain/dataflow/DataFlowPrepareMessage.java index 9b05e46..bf15553 100644 --- a/dataplane-sdk-core/src/main/java/org/eclipse/dataplane/domain/dataflow/DataFlowPrepareMessage.java +++ b/dataplane-sdk-core/src/main/java/org/eclipse/dataplane/domain/dataflow/DataFlowPrepareMessage.java @@ -22,7 +22,7 @@ public record DataFlowPrepareMessage( String participantId, String counterPartyId, String dataspaceContext, - String processId, + String dataFlowId, String agreementId, String datasetId, String profile, diff --git a/dataplane-sdk-core/src/main/java/org/eclipse/dataplane/domain/dataflow/DataFlowStartMessage.java b/dataplane-sdk-core/src/main/java/org/eclipse/dataplane/domain/dataflow/DataFlowStartMessage.java index cd2e604..8ad0fca 100644 --- a/dataplane-sdk-core/src/main/java/org/eclipse/dataplane/domain/dataflow/DataFlowStartMessage.java +++ b/dataplane-sdk-core/src/main/java/org/eclipse/dataplane/domain/dataflow/DataFlowStartMessage.java @@ -24,7 +24,7 @@ public record DataFlowStartMessage( String participantId, String counterPartyId, String dataspaceContext, - String processId, + String dataFlowId, String agreementId, String datasetId, String profile, diff --git a/gradle/libs.versions.toml b/gradle/libs.versions.toml index 165152b..cc94b84 100644 --- a/gradle/libs.versions.toml +++ b/gradle/libs.versions.toml @@ -14,7 +14,7 @@ nimbusJoseJwt = "10.9.1" postgresql = "42.7.12" restAssured = "6.0.0" slf4j = "2.0.18" -tck-dps = "1.2.0" +tck-dps = "1.3.0" testcontainers = "2.0.5" wiremock = "3.13.2"