mirror/wakapi
1
0
Fork 0
mirror of https://github.com/muety/wakapi.git synced 2023-08-10 21:12:56 +03:00
Code Issues Projects Releases Wiki Activity

chore: refine report scheduling

Browse Source
This commit is contained in:
Ferdinand Mütsch 2022-12-01 10:57:51 +01:00
parent 21f6809f05
commit 964405f349
1 changed files with 14 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

20
services/report.go
View File

@ -12,7 +12,7 @@ import (
) )
// delay between evey report generation task (to throttle email sending frequency) // delay between evey report generation task (to throttle email sending frequency)
const reportDelay = 5 * time.Second const reportDelay = 10 * time.Second
// past time range to cover in the report // past time range to cover in the report
const reportRange = 7 * 24 * time.Hour const reportRange = 7 * 24 * time.Hour
@ -46,12 +46,20 @@ func NewReportService(summaryService ISummaryService, userService IUserService,
func (srv *ReportService) Schedule() { func (srv *ReportService) Schedule() {
logbuch.Info("scheduling report generation") logbuch.Info("scheduling report generation")
scheduleUserReport := func(u *models.User, index int) { scheduleUserReport := func(u *models.User) {
if err := srv.queueWorkers.DispatchIn(func() { if err := srv.queueWorkers.Dispatch(func() {
t0 := time.Now()
if err := srv.SendReport(u, reportRange); err != nil { if err := srv.SendReport(u, reportRange); err != nil {
config.Log().Error("failed to generate report for '%s', %v", u.ID, err) config.Log().Error("failed to generate report for '%s', %v", u.ID, err)
} }
}, time.Duration(index)*reportDelay); err != nil {
// make the job take at least reportDelay seconds
if diff := reportDelay - time.Now().Sub(t0); diff > 0 {
logbuch.Debug("waiting for %v before sending next report", diff)
time.Sleep(diff)
}
}); err != nil {
config.Log().Error("failed to dispatch report generation job for user '%s', %v", u.ID, err) config.Log().Error("failed to dispatch report generation job for user '%s', %v", u.ID, err)
} }
} }
@ -71,8 +79,8 @@ func (srv *ReportService) Schedule() {
// schedule jobs, throttled by one job per x seconds // schedule jobs, throttled by one job per x seconds
logbuch.Info("scheduling report generation for %d users", len(users)) logbuch.Info("scheduling report generation for %d users", len(users))
for i, u := range users { for _, u := range users {
scheduleUserReport(u, i) scheduleUserReport(u)
} }
}, srv.config.App.GetWeeklyReportCron()) }, srv.config.App.GetWeeklyReportCron())