Notification events

db/migrations/00019_event_notifications_log.sql

@@ -0,0 +1,22 @@
+-- +goose Up
+-- +goose StatementBegin
+CREATE TABLE IF NOT EXISTS event_notifications_log
+(
+    id_event_notifications_log SERIAL,
+    id_events                  INTEGER      NOT NULL,
+    email                      VARCHAR(100) NOT NULL,
+    notification_type          VARCHAR(50)  NOT NULL, -- 'CREATED' | 'REMINDER_1H'
+    sent_at                    TIMESTAMP    NOT NULL DEFAULT CURRENT_TIMESTAMP,
+    PRIMARY KEY (id_event_notifications_log),
+    CONSTRAINT fk_event_notifications_event FOREIGN KEY (id_events) REFERENCES events (id_events) ON DELETE CASCADE,
+    CONSTRAINT fk_event_notifications_user FOREIGN KEY (email) REFERENCES newf (email) ON DELETE CASCADE,
+    CONSTRAINT uq_event_notification_once UNIQUE (id_events, email, notification_type)
+);
+-- +goose StatementEnd
+
+-- +goose Down
+-- +goose StatementBegin
+DROP TABLE IF EXISTS event_notifications_log;
+-- +goose StatementEnd
+
+

handlers/event/event_handler.go

@@ -9,16 +9,19 @@ import (
 
 	"github.com/gofiber/fiber/v2"
 	"github.com/plugimt/transat-backend/models"
+	"github.com/plugimt/transat-backend/services"
 	"github.com/plugimt/transat-backend/utils"
 )
 
 type EventHandler struct {
-	db *sql.DB
+	db       *sql.DB
+	notifier *services.EventNotificationService
 }
 
-func NewEventHandler(db *sql.DB) *EventHandler {
+func NewEventHandler(db *sql.DB, notifier *services.EventNotificationService) *EventHandler {
 	return &EventHandler{
-		db: db,
+		db:       db,
+		notifier: notifier,
 	}
 }
 
@@ -778,6 +781,13 @@ func (h *EventHandler) CreateEvent(c *fiber.Ctx) error {
 	utils.LogLineKeyValue(utils.LevelInfo, "Event ID", eventID)
 	utils.LogFooter()
 
+	// Fire-and-forget creation notification (non-blocking)
+	if h.notifier != nil {
+		go func(id int) {
+			_ = h.notifier.SendEventCreated(id)
+		}(eventID)
+	}
+
 	return c.Status(fiber.StatusCreated).JSON(fiber.Map{
 		"message": "Event created successfully",
 		"event": map[string]interface{}{

i18n/active.de.toml

@@ -1,3 +1,10 @@
+[event.created]
+title = "📅 Neues Ereignis erstellt"
+message = "Das Ereignis '{{.Name}}' wurde für {{.StartTime}} erstellt."
+
+[event.reminder]
+title = "⏰ Ereignis beginnt in 1 Stunde"
+message = "'{{.Name}}' beginnt in 1 Stunde."
 [restaurant_notification]
 title = "🍽️ NEUES MENÜ VERFÜGBAR!"
 message = "Ein köstliches neues Menü erwartet Sie im RU! Entdecken Sie die Tagesgerichte und hinterlassen Sie Ihre Kommentare. Guten Appetit!"

i18n/active.en.toml

@@ -51,6 +51,14 @@ open_restaurant = "View menu"
 download_app = "Download app"
 open_profile = "Access my profile"
 
+[event.created]
+title = "📅 New event created"
+message = "Event '{{.Name}}' created for {{.StartTime}}."
+
+[event.reminder]
+title = "⏰ Event starts in 1 hour"
+message = "'{{.Name}}' starts in 1 hour."
+
 [weather]
 thunderstorm = "Thunderstorm"
 drizzle = "Drizzle"

i18n/active.es.toml

@@ -1,3 +1,10 @@
+[event.created]
+title = "📅 Nuevo evento creado"
+message = "El evento '{{.Name}}' se ha creado para {{.StartTime}}."
+
+[event.reminder]
+title = "⏰ El evento comienza en 1 hora"
+message = "'{{.Name}}' comienza en 1 hora."
 [email_verification]
 title = "Tu código de verificación Transat"
 subject = "🔐 Tu código de verificación Transat: {{.VerificationCode}}"

i18n/active.fr.toml

@@ -1,3 +1,10 @@
+[event.created]
+title = "📅 Nouvel évènement créé"
+message = "L'évènement '{{.Name}}' est créé pour le {{.StartTime}}."
+
+[event.reminder]
+title = "⏰ L'évènement commence dans 1 heure"
+message = "'{{.Name}}' commence dans 1 heure."
 [email_verification]
 title = "Ton code de vérification Transat"
 subject = "🔐 Ton code de vérification Transat : {{.VerificationCode}}"

main.go

@@ -61,6 +61,7 @@ func main() {
 	app.Use(utils.SentryHandler)
 
 	notificationService := services.NewNotificationService(db)
+	eventNotifier := services.NewEventNotificationService(db, notificationService)
 	translationService, err := services.NewTranslationService()
 	if err != nil {
 		log.Fatalf("💥 Failed to create Translation Service: %v", err)
@@ -100,7 +101,7 @@ func main() {
 
 	clubsHandler := club.NewclubHandler(db)
 
-	eventHandler := event.NewEventHandler(db)
+	eventHandler := event.NewEventHandler(db, eventNotifier)
 
 	appScheduler := scheduler.NewScheduler(restHandler)
 	appScheduler.StartAll()
@@ -109,6 +110,10 @@ func main() {
 	// Cron Jobs - Requires access to handlers/services
 	c := cron.New()
 
+	// Add periodic job to send 1-hour event reminders every 5 minutes
+	_, _ = c.AddFunc("CRON_TZ=Europe/Paris */5 * * * *", func() {
+		_ = eventNotifier.SendDueOneHourReminders()
+	})
 	c.Start()
 	defer c.Stop()