github-starred/vikunja
2
0
Fork 0
mirror of https://github.com/go-vikunja/vikunja.git synced 2026-04-29 19:10:51 -05:00
Code Issues 690 Packages Projects Releases 11 Wiki Activity

feat: dispatch TaskReminderFiredEvent from reminder cron

Browse Source
This commit is contained in:
kolaente
2026-02-24 19:50:39 +01:00
parent 83dc7537c4
commit 626e731ae4
1 changed files with 18 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

18
pkg/models/task_reminder.go
View File

@@ -22,6 +22,7 @@ import (
"code.vikunja.io/api/pkg/config"
"code.vikunja.io/api/pkg/cron"
"code.vikunja.io/api/pkg/db"
"code.vikunja.io/api/pkg/events"
"code.vikunja.io/api/pkg/log"
"code.vikunja.io/api/pkg/notifications"
"code.vikunja.io/api/pkg/user"
@@ -379,6 +380,23 @@ func RegisterReminderCron() {
log.Debugf("[Task Reminder Cron] Sent reminder email for task %d to user %d", n.Task.ID, n.User.ID)
}
// Dispatch webhook events, deduplicated by task ID
dispatchedTasks := make(map[int64]bool)
for _, n := range reminders {
if dispatchedTasks[n.Task.ID] {
continue
}
dispatchedTasks[n.Task.ID] = true
err = events.Dispatch(&TaskReminderFiredEvent{
Task: n.Task,
Project: n.Project,
})
if err != nil {
log.Errorf("[Task Reminder Cron] Could not dispatch reminder event for task %d: %s", n.Task.ID, err)
return
}
}
})
if err != nil {
log.Fatalf("Could not register reminder cron: %s", err)