listens to RequestUserSkillLevelEvent and sends UserHexadPlayerTypeSetEvent as response

Author: MP-DG

build.gradle

@@ -107,7 +107,7 @@ repositories {
 
 dependencies {
 
-	implementation 'de.unistuttgart.iste.meitrex:meitrex-common:1.4.4'
+	implementation 'de.unistuttgart.iste.meitrex:meitrex-common:1.4.12pre5'
 	implementation 'de.unistuttgart.iste.meitrex:content_service:1.5.0rc1'
 
 	implementation 'org.springframework.boot:spring-boot-starter-data-jpa'
@@ -127,7 +127,7 @@ dependencies {
 	runtimeOnly 'org.postgresql:postgresql'
 	annotationProcessor 'org.springframework.boot:spring-boot-configuration-processor'
 	annotationProcessor 'org.projectlombok:lombok'
-	testImplementation 'de.unistuttgart.iste.meitrex:meitrex-common-test:1.4.4'
+	testImplementation 'de.unistuttgart.iste.meitrex:meitrex-common-test:1.4.11'
 	testImplementation 'org.springframework.boot:spring-boot-starter-test'
 	testImplementation 'org.springframework:spring-webflux'
 	testImplementation 'org.springframework.graphql:spring-graphql-test'

src/main/java/de/unistuttgart/iste/meitrex/skilllevel_service/controller/SubscriptionController.java

@@ -3,6 +3,7 @@
 
 import de.unistuttgart.iste.meitrex.common.event.CourseChangeEvent;
 import de.unistuttgart.iste.meitrex.common.event.CrudOperation;
+import de.unistuttgart.iste.meitrex.common.event.RequestUserSkillLevelEvent;
 import de.unistuttgart.iste.meitrex.common.event.UserProgressUpdatedEvent;
 import de.unistuttgart.iste.meitrex.common.event.ItemChangeEvent;
 
@@ -83,4 +84,24 @@ public Mono<Void> onItemChanged(@RequestBody final CloudEvent<ItemChangeEvent> c
             }
         });
     }
+
+    /**
+     * Dapr topic subscription to handle requests for user skill levels.
+     * When a service requests skill levels for a user, this publishes UserSkillLevelChangedEvent for each skill level the user has.
+     */
+    @Topic(name = "request-user-skill-level", pubsubName = "meitrex")
+    @PostMapping(path = "/skilllevel-service/request-user-skill-level-pubsub")
+    public Mono<Void> onRequestUserSkillLevel(@RequestBody final CloudEvent<RequestUserSkillLevelEvent> cloudEvent) {
+        return Mono.fromRunnable(() -> {
+            try {
+                RequestUserSkillLevelEvent event = cloudEvent.getData();
+                
+                skillLevelService.publishAllSkillLevelsForUser(event.getUserId());
+            } catch (final Exception e) {
+                // we need to catch all exceptions because otherwise if some invalid data is in the message queue
+                // it will never get processed and instead the service will just crash forever
+                log.error("Error while processing request user skill level event", e);
+            }
+        });
+    }
 }

src/main/java/de/unistuttgart/iste/meitrex/skilllevel_service/persistence/repository/AllSkillLevelsRepository.java

@@ -14,4 +14,6 @@ public interface AllSkillLevelsRepository extends JpaRepository<AllSkillLevelsEn
 
     List<AllSkillLevelsEntity> findByIdSkillId(UUID skillId);
 
+    List<AllSkillLevelsEntity> findByIdUserId(UUID userId);
+
 }

src/main/java/de/unistuttgart/iste/meitrex/skilllevel_service/service/SkillLevelService.java

@@ -1,5 +1,7 @@
 package de.unistuttgart.iste.meitrex.skilllevel_service.service;
 
+import de.unistuttgart.iste.meitrex.common.dapr.TopicPublisher;
+import de.unistuttgart.iste.meitrex.common.event.skilllevels.UserSkillLevelChangedEvent;
 import de.unistuttgart.iste.meitrex.generated.dto.*;
 import de.unistuttgart.iste.meitrex.common.event.ItemResponse;
 import de.unistuttgart.iste.meitrex.skilllevel_service.persistence.entity.AllSkillLevelsEntity;
@@ -34,6 +36,8 @@ public class SkillLevelService {
     private final ItemDifficultyRepository itemDifficultyRepository;
 
     private final SkillsForCourseRepository skillsForCourseRepository;
+    
+    private final TopicPublisher topicPublisher;
 
     /**
      * Recalculates the skill levels for a given user and responses.
@@ -170,4 +174,41 @@ private SkillLevelEntity initializeSkillLevelEntity(final float initialValue) {
         skillLevelEntity.setLog(new ArrayList<>());
         return skillLevelEntity;
     }
+
+    /**
+     * Publishes UserSkillLevelChangedEvent for all skill levels of a given user.
+     * This is used to respond to RequestUserSkillLevelEvent.
+     *
+     * @param userId The ID of the user to publish skill levels for
+     */
+    public void publishAllSkillLevelsForUser(final UUID userId) {
+        List<AllSkillLevelsEntity> allSkillLevels = skillLevelsRepository.findByIdUserId(userId);
+        
+        for (AllSkillLevelsEntity skillLevelEntity : allSkillLevels) {
+            UUID skillId = skillLevelEntity.getId().getSkillId();
+            
+            publishSkillLevelEvent(userId, skillId, BloomLevel.REMEMBER, skillLevelEntity.getRemember().getValue());
+            publishSkillLevelEvent(userId, skillId, BloomLevel.UNDERSTAND, skillLevelEntity.getUnderstand().getValue());
+            publishSkillLevelEvent(userId, skillId, BloomLevel.APPLY, skillLevelEntity.getApply().getValue());
+            publishSkillLevelEvent(userId, skillId, BloomLevel.ANALYZE, skillLevelEntity.getAnalyze().getValue());
+            publishSkillLevelEvent(userId, skillId, BloomLevel.EVALUATE, skillLevelEntity.getEvaluate().getValue());
+            publishSkillLevelEvent(userId, skillId, BloomLevel.CREATE, skillLevelEntity.getCreate().getValue());
+        }
+    }
+
+    /**
+     * Method to publish a single UserSkillLevelChangedEvent.
+     * oldValue and newValue are set to the same value since this is just for publishing existing skill levels and not for indicating a change
+     */
+    private void publishSkillLevelEvent(UUID userId, UUID skillId, BloomLevel bloomLevel, float value) {
+        UserSkillLevelChangedEvent event = UserSkillLevelChangedEvent.builder()
+                .userId(userId)
+                .skillId(skillId)
+                .bloomLevel(bloomLevel)
+                .oldValue(value)
+                .newValue(value)
+                .build();
+        
+        topicPublisher.notifyUserSkillLevelChanged(event);
+    }
 }