all topics

dancier · Dec 27, 2023 · 571c502 · 571c502
1 parent dfe0889
commit 571c502
Show file tree

Hide file tree

Showing 3 changed files with 20 additions and 7 deletions.
diff --git a/src/main/java/net/dancier/dancer/core/events/ApplicationEventListener.java b/src/main/java/net/dancier/dancer/core/events/ApplicationEventListener.java
@@ -34,10 +34,10 @@ public void handle(ProfileUpdatedEvent profileUpdatedEvent) {
                 eventCreator.createEventlog(
                         "profile-updated",
                         profileUpdatedEvent.getDancer()));
-            scheduleMessagePort.schedule(
-                    profileUpdatedEvent,
-                    profileUpdatedEvent.getDancer().getId().toString(),
-                    BACKEND_SOURCE,
-                    "profile-updated");
+        scheduleMessagePort.schedule(
+                profileUpdatedEvent,
+                profileUpdatedEvent.getDancer().getId().toString(),
+                BACKEND_SOURCE,
+                "profile-updated");
     }
 }
diff --git a/src/main/java/net/dancier/dancer/eventlog/service/EventlogService.java b/src/main/java/net/dancier/dancer/eventlog/service/EventlogService.java
@@ -4,7 +4,6 @@
 import lombok.AllArgsConstructor;
 import lombok.Getter;
 import lombok.RequiredArgsConstructor;
-import net.dancier.dancer.authentication.model.Role;
 import net.dancier.dancer.core.ScheduleMessagePort;
 import net.dancier.dancer.core.exception.ApplicationException;
 import net.dancier.dancer.core.exception.BusinessException;
@@ -39,6 +38,11 @@ public class EventlogService {
             EventlogConfig.of("navigated_to_page", NO_SPECIAL_ROLE_NEEDED),
             EventlogConfig.of("human_session_created", AT_LEAST_HUMAN),
             EventlogConfig.of("contact_message_sent", AT_LEAST_HUMAN),
+
+            EventlogConfig.of("app-instance-id-created", NO_SPECIAL_ROLE_NEEDED),
+            EventlogConfig.of("navigated-to-page", NO_SPECIAL_ROLE_NEEDED),
+            EventlogConfig.of("human-session-created", AT_LEAST_HUMAN),
+            EventlogConfig.of("contact-message-sent", AT_LEAST_HUMAN),
             EventlogConfig.of("profile-updated", DEFAULT_AUTHENTICATED) // will not go over the eventlog stuff in the future...
     );
 

diff --git a/src/main/java/net/dancier/dancer/messaging/TopicConfiguration.java b/src/main/java/net/dancier/dancer/messaging/TopicConfiguration.java
@@ -10,10 +10,19 @@
 public class TopicConfiguration {
     @Bean
     public KafkaAdmin.NewTopics createTopics() {
+
         NewTopic profileUpdated = new NewTopic("profile-updated", 1, (short) 1);
         NewTopic appInstanceIdCreated = new NewTopic("app-instance-id-created", 1, (short) 1);
+        NewTopic navigatedToPage = new NewTopic("navigated-to-page", 1, (short) 1);
+        NewTopic humanSessionCreated = new NewTopic("human-session-created", 1, (short) 1);
+        NewTopic contactMessageSent = new NewTopic("contact-message-sent", 1, (short) 1);
 
-        return new KafkaAdmin.NewTopics(profileUpdated, appInstanceIdCreated);
+        return new KafkaAdmin.NewTopics(
+                profileUpdated,
+                appInstanceIdCreated,
+                navigatedToPage,
+                humanSessionCreated,
+                contactMessageSent);
     }
 
 }