Description
After a new Event is saved (Kafka consumer), look up all current subscribers and publish a notification for each one via NotificationPublisherService.
EDIT: Send Daily Summary Notifications to All Subscribers via RabbitMQ
Tasks
Add createdAt timestamp to Event entity
Create a DailySummaryMessage model with subscriber email + event list
Add NotificationService.sendDailySummary(Subscriber, List)
Create a scheduled job (@scheduled) that runs daily at 8 PM
Query all events created today
Loop through all subscribers
Send one summary message per subscriber using RabbitMQ
Add logging throughout
Add unit test for the job logic
Optional: integration test to confirm message sent
Add logging for traceability
Testing
Unit test matching + iteration logic
Integration test end-to-end publish on new event
Description
After a new Event is saved (Kafka consumer), look up all current subscribers and publish a notification for each one via NotificationPublisherService.
EDIT: Send Daily Summary Notifications to All Subscribers via RabbitMQ
Tasks
Add createdAt timestamp to Event entity
Create a DailySummaryMessage model with subscriber email + event list
Add NotificationService.sendDailySummary(Subscriber, List)
Create a scheduled job (@scheduled) that runs daily at 8 PM
Query all events created today
Loop through all subscribers
Send one summary message per subscriber using RabbitMQ
Add logging throughout
Add unit test for the job logic
Optional: integration test to confirm message sent
Add logging for traceability
Testing
Unit test matching + iteration logic
Integration test end-to-end publish on new event