Index: openacs-4/packages/notifications/tcl/notification-sse-procs.tcl
===================================================================
RCS file: /usr/local/cvsroot/openacs-4/packages/notifications/tcl/notification-sse-procs.tcl,v
diff -u -r1.1 -r1.2
--- openacs-4/packages/notifications/tcl/notification-sse-procs.tcl	19 Dec 2024 16:59:14 -0000	1.1
+++ openacs-4/packages/notifications/tcl/notification-sse-procs.tcl	20 Dec 2024 12:14:51 -0000	1.2
@@ -38,7 +38,7 @@
         ad_script_abort
     }
 
-    ad_proc -public unsubscribe {
+    ad_proc -private unsubscribe {
         channel
         subscription_id
     } {
Index: openacs-4/packages/notifications/tcl/sweep-init.tcl
===================================================================
RCS file: /usr/local/cvsroot/openacs-4/packages/notifications/tcl/sweep-init.tcl,v
diff -u -r1.8 -r1.9
--- openacs-4/packages/notifications/tcl/sweep-init.tcl	11 Sep 2024 06:15:52 -0000	1.8
+++ openacs-4/packages/notifications/tcl/sweep-init.tcl	20 Dec 2024 12:14:51 -0000	1.9
@@ -14,6 +14,11 @@
                          -default 900]
 ad_schedule_proc -thread t $cleanupInterval notification::sweep::cleanup_notifications
 
+#
+# Cleanup leftover SSE handles.
+#
+ad_schedule_proc -thread t 60 notification::sweep::cleanup_sse_subscriptions
+
 foreach interval [notification::get_all_intervals] {
     set n_seconds [lindex $interval 2]
     if {$n_seconds > 0} {
Index: openacs-4/packages/notifications/tcl/sweep-procs.tcl
===================================================================
RCS file: /usr/local/cvsroot/openacs-4/packages/notifications/tcl/sweep-procs.tcl,v
diff -u -r1.30 -r1.31
--- openacs-4/packages/notifications/tcl/sweep-procs.tcl	11 Sep 2024 06:15:52 -0000	1.30
+++ openacs-4/packages/notifications/tcl/sweep-procs.tcl	20 Dec 2024 12:14:52 -0000	1.31
@@ -10,6 +10,21 @@
 
 namespace eval notification::sweep {
 
+    ad_proc -private cleanup_sse_subscriptions {} {
+        Cleanup unused SSE channels.
+    } {
+        foreach {subscription channels} [nsv_array get ::notification::sse channels-*] {
+            set to_user_id [string range $subscription [string length channels-] end]
+            foreach channel $channels {
+                try {
+                    ns_connchan write $channel [string cat {: ping} \n\n]
+                } on error {errmsg} {
+                    ::notification::sse::unsubscribe $channel $to_user_id
+                }
+            }
+        }
+    }
+
     ad_proc -private cleanup_notifications {} {
         Clean up the notifications that have been sent out (DRB: inefficiently...).
     } {