From 7065556ee29d4e478ed5b12359c905b522c0316e Mon Sep 17 00:00:00 2001
From: Enrico Risa <enrico.risa@gmail.com>
Date: Fri, 17 Apr 2026 11:25:09 +0200
Subject: [PATCH] refactor: use upstream dataplane reg api

---
 .../management/ManagementApiClientImpl.java   |  4 ++--
 .../management/dto/DataplaneRegistration.java | 24 +++++++++----------
 .../ManagementApiClientIntegrationTest.java   |  2 +-
 3 files changed, 15 insertions(+), 15 deletions(-)

diff --git a/src/main/java/com/metaformsystems/redline/infrastructure/client/management/ManagementApiClientImpl.java b/src/main/java/com/metaformsystems/redline/infrastructure/client/management/ManagementApiClientImpl.java
index 7f2dbf0..5624e65 100644
--- a/src/main/java/com/metaformsystems/redline/infrastructure/client/management/ManagementApiClientImpl.java
+++ b/src/main/java/com/metaformsystems/redline/infrastructure/client/management/ManagementApiClientImpl.java
@@ -287,8 +287,8 @@ public Catalog getCatalog(String participantContextId, String counterPartyDid) {
 
     @Override
     public void prepareDataplane(String participantContextId, DataplaneRegistration dataplaneRegistration) {
-        controlPlaneWebClient.post()
-                .uri("/v5beta/dataplanes/%s".formatted(participantContextId))
+        controlPlaneWebClient.put()
+                .uri("/v5beta/participants/%s/dataplanes".formatted(participantContextId))
                 .header("Authorization", "Bearer %s".formatted(getToken(participantContextId)))
                 .bodyValue(dataplaneRegistration)
                 .retrieve()
diff --git a/src/main/java/com/metaformsystems/redline/infrastructure/client/management/dto/DataplaneRegistration.java b/src/main/java/com/metaformsystems/redline/infrastructure/client/management/dto/DataplaneRegistration.java
index f3a902a..4ae1c9e 100644
--- a/src/main/java/com/metaformsystems/redline/infrastructure/client/management/dto/DataplaneRegistration.java
+++ b/src/main/java/com/metaformsystems/redline/infrastructure/client/management/dto/DataplaneRegistration.java
@@ -18,29 +18,29 @@
 
 public class DataplaneRegistration {
     private String id;
-    private List<String> allowedTransferTypes;
-    private String url;
+    private List<String> transferTypes;
+    private String endpoint;
     private List<String> labels;
 
 
-    public List<String> getAllowedTransferTypes() {
-        return allowedTransferTypes;
+    public List<String> getTransferTypes() {
+        return transferTypes;
     }
 
-    public void setAllowedTransferTypes(List<String> allowedTransferTypes) {
-        this.allowedTransferTypes = allowedTransferTypes;
+    public void setTransferTypes(List<String> transferTypes) {
+        this.transferTypes = transferTypes;
     }
 
     public String getId() {
         return id;
     }
 
-    public String getUrl() {
-        return url;
+    public String getEndpoint() {
+        return endpoint;
     }
 
-    public void setUrl(String url) {
-        this.url = url;
+    public void setEndpoint(String endpoint) {
+        this.endpoint = endpoint;
     }
 
     public List<String> getLabels() {
@@ -69,12 +69,12 @@ public Builder labels(List<String> labels) {
         }
 
         public Builder allowedTransferTypes(List<String> allowedTransferTypes) {
-            dataplaneRegistration.setAllowedTransferTypes(allowedTransferTypes);
+            dataplaneRegistration.setTransferTypes(allowedTransferTypes);
             return this;
         }
 
         public Builder url(String url) {
-            dataplaneRegistration.setUrl(url);
+            dataplaneRegistration.setEndpoint(url);
             return this;
         }
 
diff --git a/src/test/java/com/metaformsystems/redline/infrastructure/client/management/ManagementApiClientIntegrationTest.java b/src/test/java/com/metaformsystems/redline/infrastructure/client/management/ManagementApiClientIntegrationTest.java
index 98e3f9b..6562e5f 100644
--- a/src/test/java/com/metaformsystems/redline/infrastructure/client/management/ManagementApiClientIntegrationTest.java
+++ b/src/test/java/com/metaformsystems/redline/infrastructure/client/management/ManagementApiClientIntegrationTest.java
@@ -461,7 +461,7 @@ void shouldPrepareDataplane() throws InterruptedException {
 
         // Assert
         var dataplaneRequest = mockWebServer.takeRequest();
-        assertThat(dataplaneRequest.getPath()).isEqualTo("/v5beta/dataplanes/" + participantContextId);
+        assertThat(dataplaneRequest.getPath()).isEqualTo("/v5beta/participants/%s/dataplanes".formatted(participantContextId));
         assertThat(dataplaneRequest.getHeader("Authorization")).isEqualTo("Bearer test-token");
     }