listens to RequestHexadPlayerTypeEvent. Once recieved, sends UserHexadPlayerTypeSetEvent for the given user

Author: MP-DG

build.gradle

@@ -119,7 +119,7 @@ repositories {
 
 dependencies {
 
-    implementation 'de.unistuttgart.iste.meitrex:meitrex-common:1.4.12pre2'
+    implementation 'de.unistuttgart.iste.meitrex:meitrex-common:1.4.12pre4'
     implementation 'de.unistuttgart.iste.meitrex:content_service:1.6.0'
     implementation 'de.unistuttgart.iste.meitrex:course_service:1.1.0rc2'
     implementation 'de.unistuttgart.iste.meitrex:user_service:1.0.0rc1'

src/main/java/de/unistuttgart/iste/meitrex/gamification_service/dapr/RequestHexadPlayerTypeEventListener.java

@@ -0,0 +1,49 @@
+package de.unistuttgart.iste.meitrex.gamification_service.dapr;
+
+import de.unistuttgart.iste.meitrex.common.dapr.TopicPublisher;
+import de.unistuttgart.iste.meitrex.common.event.RequestHexadPlayerTypeEvent;
+import de.unistuttgart.iste.meitrex.gamification_service.service.IPlayerHexadScoreService;
+import io.dapr.Topic;
+import io.dapr.client.domain.CloudEvent;
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestBody;
+import org.springframework.web.bind.annotation.RestController;
+
+/**
+ * Listener for RequestHexadPlayerTypeEvent.
+ * When a request is received, it fetches the user's hexad player type 
+ * and publishes a UserHexadPlayerTypeSetEvent in response.
+ */
+@Slf4j
+@RestController
+@RequiredArgsConstructor
+public class RequestHexadPlayerTypeEventListener {
+
+    private final IPlayerHexadScoreService playerHexadScoreService;
+    private final TopicPublisher topicPublisher;
+
+    @Topic(name = "request-hexad-player-type", pubsubName = "meitrex")
+    @PostMapping(path = "/request-hexad-player-type-pubsub")
+    public void onRequestHexadPlayerTypeEvent(@RequestBody CloudEvent<RequestHexadPlayerTypeEvent> cloudEvent) {
+        RequestHexadPlayerTypeEvent event = cloudEvent.getData();
+        
+        log.info("Received RequestHexadPlayerTypeEvent for user: {}", event.getUserId());
+        
+        try {
+            // Fetch the player hexad score for the user
+            var playerHexadScore = playerHexadScoreService.getById(event.getUserId());
+            
+            if (playerHexadScore != null) {
+                log.info("Publishing UserHexadPlayerTypeSetEvent for user: {}", event.getUserId());
+                playerHexadScoreService.sendUserHexadPlayerTypeSetEvent(event.getUserId(), playerHexadScore);
+            } else {
+                log.warn("No hexad player type found for user: {}", event.getUserId());
+            }
+        } catch (Exception e) {
+            log.error("Error handling RequestHexadPlayerTypeEvent for user {}: {}", 
+                    event.getUserId(), e.getMessage(), e);
+        }
+    }
+}

src/main/java/de/unistuttgart/iste/meitrex/gamification_service/service/IPlayerHexadScoreService.java

@@ -51,4 +51,11 @@ public interface IPlayerHexadScoreService {
      * @return true if a hexad score exists otherwise false
      */
     Boolean hasHexadScore(UUID userId);
+
+    /**
+     * Publishes an UserHexadPlayerTypeSetEvent
+     * @param userId the ID of the user
+     * @param playerHexadScore the player hexad score of the user
+     */
+    void sendUserHexadPlayerTypeSetEvent(UUID userId, PlayerHexadScore playerHexadScore);
 }

src/main/java/de/unistuttgart/iste/meitrex/gamification_service/service/PlayerHexadScoreService.java

@@ -181,7 +181,7 @@ public Boolean hasHexadScore(UUID userId) {
      * @param userId the ID of the user
      * @param playerHexadScore the updated player hexad score
      */
-    private void sendUserHexadPlayerTypeSetEvent(UUID userId, PlayerHexadScore playerHexadScore) {
+    public void sendUserHexadPlayerTypeSetEvent(UUID userId, PlayerHexadScore playerHexadScore) {
         HexadPlayerType primaryPlayerType = null;
         Map<HexadPlayerType, Double> scoresMap = new HashMap<>();