From 54aacd370773e18fc2176bf3e85bc01c2b697459 Mon Sep 17 00:00:00 2001
From: kolaente <k@knt.li>
Date: Tue, 24 Feb 2026 19:50:42 +0100
Subject: [PATCH] feat: dispatch TaskOverdueEvent from overdue cron

---
 pkg/models/task_overdue_reminder.go | 20 ++++++++++++++++++++
 1 file changed, 20 insertions(+)

diff --git a/pkg/models/task_overdue_reminder.go b/pkg/models/task_overdue_reminder.go
index d126026d4..b5bb59bf4 100644
--- a/pkg/models/task_overdue_reminder.go
+++ b/pkg/models/task_overdue_reminder.go
@@ -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"
@@ -172,6 +173,25 @@ func RegisterOverdueReminderCron() {
 
 			log.Debugf("[Undone Overdue Tasks Reminder] Sent reminder email for %d tasks to user %d", len(ut.tasks), ut.user.ID)
 		}
+
+		// Dispatch webhook events, deduplicated by task ID across all users
+		dispatchedTasks := make(map[int64]bool)
+		for _, ut := range uts {
+			for _, t := range ut.tasks {
+				if dispatchedTasks[t.ID] {
+					continue
+				}
+				dispatchedTasks[t.ID] = true
+				err = events.Dispatch(&TaskOverdueEvent{
+					Task:    t,
+					Project: projects[t.ProjectID],
+				})
+				if err != nil {
+					log.Errorf("[Undone Overdue Tasks Reminder] Could not dispatch overdue event for task %d: %s", t.ID, err)
+					return
+				}
+			}
+		}
 	})
 	if err != nil {
 		log.Fatalf("Could not register undone overdue tasks reminder cron: %s", err)