fix 1.0

DiSSCo · Dec 9, 2024 · ef5684b · ef5684b
1 parent 1f099dc
commit ef5684b
Show file tree

Hide file tree

Showing 3 changed files with 5 additions and 3 deletions.
diff --git a/src/main/java/eu/dissco/core/datacitepublisher/component/XmlLocReader.java b/src/main/java/eu/dissco/core/datacitepublisher/component/XmlLocReader.java
@@ -59,5 +59,6 @@ static class LocationXml {
     String href;
     String id;
     String weight;
+    String view;
   }
 }
diff --git a/src/main/java/eu/dissco/core/datacitepublisher/kafka/KafkaConsumerService.java b/src/main/java/eu/dissco/core/datacitepublisher/kafka/KafkaConsumerService.java
@@ -28,7 +28,7 @@ public class KafkaConsumerService {
   @Qualifier("objectMapper")
   private final ObjectMapper mapper;
   private final DataCitePublisherService service;
-  private static final String ERROR_MSG = "Unable to parse specimen event from the handle API";
+  private static final String ERROR_MSG = "Unable to parse {} event from the handle API";
 
   @RetryableTopic(
       attempts = "1",
@@ -39,7 +39,7 @@ public void getSpecimenMessages(@Payload String message) throws DataCiteApiExcep
       var event = mapper.readValue(message, DigitalSpecimenEvent.class);
       service.handleMessages(event);
     } catch (JsonProcessingException e) {
-      log.error(ERROR_MSG, e);
+      log.error(ERROR_MSG, "specimen", e);
       log.info("Message: {}", message);
       throw new InvalidRequestException();
     }
@@ -54,7 +54,7 @@ public void getMediaMessages(@Payload String message) throws DataCiteApiExceptio
       var event = mapper.readValue(message, DigitalMediaEvent.class);
       service.handleMessages(event);
     } catch (JsonProcessingException e) {
-      log.error(ERROR_MSG);
+      log.error(ERROR_MSG, "media", e);
       log.info("Message: {}", message);
       throw new InvalidRequestException();
     }

diff --git a/src/main/java/eu/dissco/core/datacitepublisher/service/DataCitePublisherService.java b/src/main/java/eu/dissco/core/datacitepublisher/service/DataCitePublisherService.java
@@ -181,6 +181,7 @@ private DcRequest buildDcRequest(String xmlLoc, String landingPage, String altId
                   .build()
           ).build();
     } catch (InvalidFdoProfileReceivedException e) {
+      log.error("Unable to parse Fdo Profile", e);
       throw new DataCiteMappingException();
     }
   }