From 3d0d6441d1713ecd0853aef848b2bb7440945ca5 Mon Sep 17 00:00:00 2001 From: Janyk Date: Sun, 17 Nov 2024 00:13:57 +0100 Subject: [PATCH] refactor(email_processor): simplify UpdateLastProcessed method --- internal/processor/email_processor.go | 4 ++-- internal/processor/processor.go | 6 +++--- 2 files changed, 5 insertions(+), 5 deletions(-) diff --git a/internal/processor/email_processor.go b/internal/processor/email_processor.go index 528f4bb..08f6dd2 100644 --- a/internal/processor/email_processor.go +++ b/internal/processor/email_processor.go @@ -45,8 +45,8 @@ func (p *EmailProcessor) ProcessEmails(ctx context.Context) ([]gmail.Email, erro return emails, nil } -func (p *EmailProcessor) UpdateLastProcessed(email gmail.Email) error { - p.lastUpdate = email.Date.Add(time.Second) +func (p *EmailProcessor) UpdateLastProcessed() error { + p.lastUpdate = time.Now() p.cfg.App.LastUpdate = p.lastUpdate.Format(time.RFC3339) if err := config.SaveConfig(p.cfg); err != nil { diff --git a/internal/processor/processor.go b/internal/processor/processor.go index 4f40ce1..c2e92e1 100644 --- a/internal/processor/processor.go +++ b/internal/processor/processor.go @@ -66,10 +66,10 @@ func (p *Processor) processNewEmails(ctx context.Context) error { continue } } + } - if err := p.emailProcessor.UpdateLastProcessed(email); err != nil { - log.Printf("Failed to update last processed time: %v", err) - } + if err := p.emailProcessor.UpdateLastProcessed(); err != nil { + log.Printf("Failed to update last processed time: %v", err) } return nil