feat(ticketing-eventing): init handler-core

Author: simonhir

ticketing-eventing/handler-core/pom.xml

@@ -0,0 +1,12 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<FindBugsFilter>
+    <Match>
+        <Bug pattern="CRLF_INJECTION_LOGS"/>
+    </Match>
+    <Match>
+        <Bug pattern="EI_EXPOSE_REP"/>
+    </Match>
+    <Match>
+        <Bug pattern="EI_EXPOSE_REP2"/>
+    </Match>
+</FindBugsFilter>

ticketing-eventing/handler-core/spotbugs-exclude-rules.xml

@@ -0,0 +1,9 @@
+package de.muenchen.oss.dbs.ticketing.eventing.handlercore;
+
+import org.springframework.boot.autoconfigure.AutoConfiguration;
+import org.springframework.context.annotation.ComponentScan;
+
+@AutoConfiguration
+@ComponentScan
+public class HandlerCoreAutoConfiguration {
+}

ticketing-eventing/handler-core/src/main/java/de/muenchen/oss/dbs/ticketing/eventing/handlercore/HandlerCoreAutoConfiguration.java

@@ -0,0 +1,29 @@
+package de.muenchen.oss.dbs.ticketing.eventing.handlercore.adapter.in;
+
+import de.muenchen.oss.dbs.ticketing.eventing.handlercore.application.port.in.EventHandlerInPort;
+import de.muenchen.oss.dbs.ticketing.eventing.handlercore.domain.model.Event;
+import java.util.function.Consumer;
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.context.annotation.Bean;
+import org.springframework.messaging.Message;
+import org.springframework.stereotype.Service;
+
+@Service
+@RequiredArgsConstructor
+@Slf4j
+public class StreamingInAdapter {
+    private final EventHandlerInPort eventHandlerInPort;
+
+    /**
+     * Consumer for Zammad events sent via Kafka from the eventing-service.
+     *
+     * @return The consumer.
+     */
+    @Bean
+    public Consumer<Message<Event>> event() {
+        return message -> {
+            eventHandlerInPort.handleEvent(message.getPayload());
+        };
+    }
+}

ticketing-eventing/handler-core/src/main/java/de/muenchen/oss/dbs/ticketing/eventing/handlercore/adapter/in/StreamingInAdapter.java

@@ -0,0 +1,23 @@
+package de.muenchen.oss.dbs.ticketing.eventing.handlercore.adapter.out.zammad;
+
+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 lombok.RequiredArgsConstructor;
+import org.springframework.stereotype.Service;
+import org.springframework.web.reactive.function.client.WebClientResponseException;
+
+@Service
+@RequiredArgsConstructor
+public class ZammadAdapter implements TicketingOutPort {
+    private final TicketsApi ticketsApi;
+
+    @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);
+        }
+    }
+}

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

@@ -0,0 +1,8 @@
+package de.muenchen.oss.dbs.ticketing.eventing.handlercore.adapter.out.zammad;
+
+@SuppressWarnings("PMD.MissingSerialVersionUID")
+public class ZammadApiException extends RuntimeException {
+    public ZammadApiException(final String message, final Throwable cause) {
+        super(message, cause);
+    }
+}

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

@@ -0,0 +1,7 @@
+package de.muenchen.oss.dbs.ticketing.eventing.handlercore.application.port.in;
+
+import de.muenchen.oss.dbs.ticketing.eventing.handlercore.domain.model.Event;
+
+public interface EventHandlerInPort {
+    void handleEvent(Event event);
+}

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

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

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

@@ -0,0 +1,14 @@
+package de.muenchen.oss.dbs.ticketing.eventing.handlercore.domain.model;
+
+import jakarta.validation.constraints.NotBlank;
+
+public record Event(
+        @NotBlank String action,
+        @NotBlank String ticket,
+        String status,
+        String statusId,
+        String anliegenart,
+        String lhmExtId
+// TODO additional payload or everything/partial as map?
+) {
+}

ticketing-eventing/handler-core/src/main/java/de/muenchen/oss/dbs/ticketing/eventing/handlercore/domain/model/Event.java

@@ -0,0 +1 @@
+de.muenchen.oss.dbs.ticketing.eventing.handlercore.HandlerCoreAutoConfiguration