@@ -8,15 +8,10 @@ import (
88 "net/http"
99 "time"
1010
11- "code.gitea.io/gitea/models"
12- "code.gitea.io/gitea/models/db"
1311 "code.gitea.io/gitea/modules/context"
14- "code.gitea.io/gitea/modules/convert"
1512 "code.gitea.io/gitea/modules/eventsource"
1613 "code.gitea.io/gitea/modules/graceful"
17- "code.gitea.io/gitea/modules/json"
1814 "code.gitea.io/gitea/modules/log"
19- "code.gitea.io/gitea/modules/setting"
2015 "code.gitea.io/gitea/routers/web/auth"
2116)
2217
@@ -71,8 +66,6 @@ func Events(ctx *context.Context) {
7166
7267 timer := time .NewTicker (30 * time .Second )
7368
74- stopwatchTimer := time .NewTicker (setting .UI .Notification .MinTimeout )
75-
7669loop:
7770 for {
7871 select {
9386 case <- shutdownCtx .Done ():
9487 go unregister ()
9588 break loop
96- case <- stopwatchTimer .C :
97- sws , err := models .GetUserStopwatches (ctx .Doer .ID , db.ListOptions {})
98- if err != nil {
99- log .Error ("Unable to GetUserStopwatches: %v" , err )
100- continue
101- }
102- apiSWs , err := convert .ToStopWatches (sws )
103- if err != nil {
104- log .Error ("Unable to APIFormat stopwatches: %v" , err )
105- continue
106- }
107- dataBs , err := json .Marshal (apiSWs )
108- if err != nil {
109- log .Error ("Unable to marshal stopwatches: %v" , err )
110- continue
111- }
112- _ , err = (& eventsource.Event {
113- Name : "stopwatches" ,
114- Data : string (dataBs ),
115- }).WriteTo (ctx .Resp )
116- if err != nil {
117- log .Error ("Unable to write to EventStream for user %s: %v" , ctx .Doer .Name , err )
118- go unregister ()
119- break loop
120- }
121- ctx .Resp .Flush ()
12289 case event , ok := <- messageChan :
12390 if ! ok {
12491 break loop
0 commit comments