Merge pull request eclipse-tractusx#547 from FraunhoferISST/feat/asse…

…t_registration_messages feat: added handling for 409 responses on asset registration
FraunhoferISST · Aug 20, 2024 · c7191fd · c7191fd
2 parents 3f60787 + 16595bf
commit c7191fd
Showing 1 changed file with 8 additions and 0 deletions.
diff --git a/...n/java/org/eclipse/tractusx/puris/backend/common/edc/logic/service/EdcAdapterService.java b/...n/java/org/eclipse/tractusx/puris/backend/common/edc/logic/service/EdcAdapterService.java
@@ -263,6 +263,10 @@ private boolean createContractPolicy() {
         var body = edcRequestBodyBuilder.buildFrameworkPolicy();
         try (var response = sendPostRequest(body, List.of("v3", "policydefinitions"))) {
             if (!response.isSuccessful()) {
+                if (response.code() == 409) {
+                    log.info("Framework agreement policy definition already existed");
+                    return true;
+                }
                 log.warn("Framework Policy Registration failed");
                 if (response.body() != null) {
                     log.warn("Response: \n" + response.body().string());
@@ -300,6 +304,10 @@ private boolean registerNotificationAsset(String assetId, String endpoint) {
     private boolean sendAssetRegistrationRequest(JsonNode body, String assetId) {
         try (var response = sendPostRequest(body, List.of("v3", "assets"))) {
             if (!response.isSuccessful()) {
+                if (response.code() == 409) {
+                    log.info("Asset {} already existed", assetId);
+                    return true;
+                }
                 log.warn("Asset registration failed for {}", assetId);
                 if (response.body() != null) {
                     log.warn("Response: \n" + response.body().string());