DeforaNetworks/corteza
3
0
Fork 0
Code Activity

Fix reminders websocket

Browse Source
This commit is contained in:
Jože Fortun
2022-01-14 17:28:45 +01:00
parent 3ffa0ef8be
commit 0b7409d7bb
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
system/service/reminder.go
+2 -2
View File
@@ -293,7 +293,7 @@ func (svc reminder) Delete(ctx context.Context, ID uint64) (err error) {
func (svc reminder) Watch(ctx context.Context) {
if svc.reminderSender != nil {
var (
interval = time.Second
interval = time.Minute
rTicker = time.NewTicker(interval)
)
@@ -319,7 +319,7 @@ func (svc reminder) Watch(ctx context.Context) {
// Send scheduled reminders to users
_ = rr.Walk(func(r *types.Reminder) error {
if r.RemindAt != nil && now().Round(interval) == r.RemindAt.Round(interval) {
if r.RemindAt != nil && r.DismissedAt == nil && now().Add(interval).After(*r.RemindAt) {
if err := svc.reminderSender.Send("reminder", r, r.AssignedTo); err != nil {
svc.log.Error("failed to send reminder to user", zap.Error(err))
}