feat(eventing-service): init

Author: simonhir

ticketing-eventing/eventing-service/pom.xml

@@ -98,7 +98,7 @@
 
     <dependencies>
 
-        <!-- Spring Boot -->
+        <!-- Spring -->
         <dependency>
             <groupId>org.springframework.boot</groupId>
             <artifactId>spring-boot-starter-web</artifactId>
@@ -111,12 +111,14 @@
             <groupId>org.springframework.boot</groupId>
             <artifactId>spring-boot-starter-validation</artifactId>
         </dependency>
-
-        <!-- Spring Security -->
         <dependency>
             <groupId>org.springframework.boot</groupId>
             <artifactId>spring-boot-starter-security</artifactId>
         </dependency>
+        <dependency>
+            <groupId>org.springframework.cloud</groupId>
+            <artifactId>spring-cloud-starter-stream-kafka</artifactId>
+        </dependency>
 
         <!-- Other -->
         <dependency>

ticketing-eventing/eventing-service/src/main/java/de/muenchen/oss/dbs/ticketing/eventing/service/adapter/in/rest/EventDTO.java

@@ -0,0 +1,11 @@
+package de.muenchen.oss.dbs.ticketing.eventing.service.adapter.in.rest;
+
+public record EventDTO(
+        String ticket,
+        String status,
+        String status_id,
+        String anliegenart,
+        String lhmExtId
+// TODO additional payload or everything/partial as map?
+) {
+}

ticketing-eventing/eventing-service/src/main/java/de/muenchen/oss/dbs/ticketing/eventing/service/adapter/in/rest/EventMapper.java

@@ -0,0 +1,9 @@
+package de.muenchen.oss.dbs.ticketing.eventing.service.adapter.in.rest;
+
+import de.muenchen.oss.dbs.ticketing.eventing.service.domain.model.Event;
+import org.mapstruct.Mapper;
+
+@Mapper
+interface EventMapper {
+    Event fromDto(String action, EventDTO dto);
+}

ticketing-eventing/eventing-service/src/main/java/de/muenchen/oss/dbs/ticketing/eventing/service/adapter/in/rest/RestAdapter.java

@@ -1,19 +1,43 @@
 package de.muenchen.oss.dbs.ticketing.eventing.service.adapter.in.rest;
 
+import de.muenchen.oss.dbs.ticketing.eventing.service.configuration.DbsEventingProperties;
 import de.muenchen.oss.dbs.ticketing.eventing.service.core.port.in.HandleEventInPort;
+import de.muenchen.oss.dbs.ticketing.eventing.service.domain.model.Event;
 import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.http.HttpStatus;
 import org.springframework.stereotype.Service;
 import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestBody;
+import org.springframework.web.bind.annotation.RequestHeader;
 import org.springframework.web.bind.annotation.RestController;
+import org.springframework.web.server.ResponseStatusException;
 
 @Service
 @RestController("/api/")
 @RequiredArgsConstructor
+@Slf4j
 public class RestAdapter {
+    private static final String TRIGGER_HEADER = "X-Zammad-Trigger";
+    private static final String ID_HEADER = "X-Zammad-Delivery";
+
+    private final DbsEventingProperties dbsEventingProperties;
     private final HandleEventInPort handleEventInPort;
+    private final EventMapper eventMapper;
 
     @PostMapping("event")
-    void event() {
-
+    public void event(
+            @RequestHeader(TRIGGER_HEADER) final String trigger,
+            @RequestHeader(ID_HEADER) final String deliveryId,
+            @RequestBody final EventDTO eventDto) {
+        log.info("Received event {} from trigger {}: {}", deliveryId, trigger, eventDto);
+        final String action = dbsEventingProperties.getTriggerMapping().get(trigger);
+        if (action == null) {
+            throw new ResponseStatusException(HttpStatus.BAD_REQUEST, "No mapping for trigger %s".formatted(trigger));
+        }
+        final Event event = eventMapper.fromDto(action, eventDto);
+        log.debug("Mapped trigger {} and payload to event {}", trigger, event);
+        handleEventInPort.handleEvent(event);
+        log.debug("Handled event successfully");
     }
 }

ticketing-eventing/eventing-service/src/main/java/de/muenchen/oss/dbs/ticketing/eventing/service/adapter/out/streaming/StreamingAdapter.java

@@ -0,0 +1,31 @@
+package de.muenchen.oss.dbs.ticketing.eventing.service.adapter.out.streaming;
+
+import de.muenchen.oss.dbs.ticketing.eventing.service.core.port.out.SendEventOutPort;
+import de.muenchen.oss.dbs.ticketing.eventing.service.domain.exception.MessageOutException;
+import de.muenchen.oss.dbs.ticketing.eventing.service.domain.model.Event;
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.cloud.stream.function.StreamBridge;
+import org.springframework.stereotype.Service;
+
+@Service
+@RequiredArgsConstructor
+@Slf4j
+public class StreamingAdapter implements SendEventOutPort {
+    private static final String BINDING_NAME = "event-out";
+
+    private final StreamBridge streamBridge;
+
+    @Override
+    public void sendEvent(final Event event) {
+        final boolean successful;
+        try {
+            successful = streamBridge.send(BINDING_NAME, event);
+        } catch (final RuntimeException e) {
+            throw new MessageOutException("Exception while sending event %s".formatted(event), e);
+        }
+        if (!successful) {
+            throw new MessageOutException("Event couldn't be send %s".formatted(event));
+        }
+    }
+}

ticketing-eventing/eventing-service/src/main/java/de/muenchen/oss/dbs/ticketing/eventing/service/configuration/DbsEventingProperties.java

@@ -0,0 +1,16 @@
+package de.muenchen.oss.dbs.ticketing.eventing.service.configuration;
+
+import jakarta.validation.constraints.NotNull;
+import java.util.Map;
+import lombok.Getter;
+import lombok.Setter;
+import org.springframework.boot.context.properties.ConfigurationProperties;
+import org.springframework.context.annotation.Configuration;
+
+@Configuration
+@ConfigurationProperties("dbs.eventing")
+@Getter
+@Setter
+public class DbsEventingProperties {
+    @NotNull private Map<String, String> triggerMapping;
+}