refactor(email_processor): simplify UpdateLastProcessed method

janyksteenbeek · Nov 16, 2024 · 3d0d644 · 3d0d644
1 parent ef3f6ba
commit 3d0d644
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 5 deletions.
diff --git 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
@@ -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