NowChess/NowChessSystems
4
0
Fork 0
Code Issues Pull Requests 2 Packages Projects Releases Wiki Activity

feat(api): define shared EventEnvelope and EventType for Redis EventBus #61

Merged
Janis merged 2 commits from worktree-feat+NCS-90-shared-event-envelope into main 2026-06-05 12:11:14 +02:00
Conversation 0 Commits 2 Files Changed 7
+5 -1
1 changed files with 5 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files
Showing only changes of commit f87b99f749 - Show all commits
modules/account/src/main/scala/de/nowchess/account/service/EventPublisher.scala
+5 -1
View File
@@ -37,7 +37,11 @@ class EventPublisher:
payload.put("gameId", gameId) payload.put("gameId", gameId)
publish(s"${redisConfig.prefix}:user:$challengerId:events", EventType.ChallengeAccepted, payload) publish(s"${redisConfig.prefix}:user:$challengerId:events", EventType.ChallengeAccepted, payload)
private def publish(channel: String, eventType: EventType, payload: com.fasterxml.jackson.databind.node.ObjectNode): Unit = private def publish(
channel: String,
eventType: EventType,
payload: com.fasterxml.jackson.databind.node.ObjectNode,
): Unit =
val envelope = EventEnvelope.of(eventType, payload) val envelope = EventEnvelope.of(eventType, payload)
redis.pubsub(classOf[String]).publish(channel, objectMapper.writeValueAsString(envelope)) redis.pubsub(classOf[String]).publish(channel, objectMapper.writeValueAsString(envelope))
() ()