chore(ticketing-eai/handler-core): add attachment download

Author: simonhir

ticketing-eventing/handler-core/src/main/java/de/muenchen/oss/dbs/ticketing/eventing/handlercore/adapter/out/zammad/ZammadAdapter.java

@@ -1,23 +1,40 @@
 package de.muenchen.oss.dbs.ticketing.eventing.handlercore.adapter.out.zammad;
 
+import de.muenchen.oss.dbs.ticketing.eai.client.api.AttachmentsApi;
 import de.muenchen.oss.dbs.ticketing.eai.client.api.TicketsApi;
 import de.muenchen.oss.dbs.ticketing.eai.client.model.TicketInternal;
 import de.muenchen.oss.dbs.ticketing.eventing.handlercore.application.port.out.TicketingOutPort;
+import java.io.InputStream;
 import lombok.RequiredArgsConstructor;
+import org.springframework.core.io.buffer.DataBuffer;
 import org.springframework.stereotype.Service;
 import org.springframework.web.reactive.function.client.WebClientResponseException;
 
 @Service
 @RequiredArgsConstructor
 public class ZammadAdapter implements TicketingOutPort {
     private final TicketsApi ticketsApi;
+    private final AttachmentsApi attachmentsApi;
 
     @Override
     public TicketInternal getTicket(final String ticketId) {
         try {
             return ticketsApi.getTicketByIdWithUser(ticketId, null, null, null).block();
         } catch (final WebClientResponseException e) {
-            throw new ZammadApiException("Getting ticket with id %s failed".formatted(ticketId), e);
+            throw new ZammadApiException("Getting ticket with id %s failed: %s"
+                    .formatted(ticketId, e.getResponseBodyAsString()), e);
+        }
+    }
+
+    @Override
+    public InputStream getAttachmentContent(final String ticketId, final String articleId, final String attachmentId) {
+        try {
+            final DataBuffer response = attachmentsApi.getAttachmentWithResponseSpec(ticketId, articleId, attachmentId).bodyToMono(DataBuffer.class).block();
+            assert response != null;
+            return response.asInputStream();
+        } catch (final WebClientResponseException e) {
+            throw new ZammadApiException("Getting attachment with id %s failed: %s"
+                    .formatted(attachmentId, e.getResponseBodyAsString()), e);
         }
     }
 }

ticketing-eventing/handler-core/src/main/java/de/muenchen/oss/dbs/ticketing/eventing/handlercore/application/port/out/TicketingOutPort.java

@@ -1,7 +1,10 @@
 package de.muenchen.oss.dbs.ticketing.eventing.handlercore.application.port.out;
 
 import de.muenchen.oss.dbs.ticketing.eai.client.model.TicketInternal;
+import java.io.InputStream;
 
 public interface TicketingOutPort {
     TicketInternal getTicket(String ticketId);
+
+    InputStream getAttachmentContent(String ticketId, String articleId, String attachmentId);
 }