From 6bd87a567ef481b922f6baec2b475ec376c45443 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Ren=C3=A9=20=27Necoro=27=20Neumann?= Date: Thu, 23 Apr 2020 20:10:05 +0200 Subject: Concurrent imap --- main.go | 14 ++++++++------ 1 file changed, 8 insertions(+), 6 deletions(-) (limited to 'main.go') diff --git a/main.go b/main.go index 0fd5ba4..5764ae4 100644 --- a/main.go +++ b/main.go @@ -31,13 +31,15 @@ func processFeed(feed *feed.Feed, cfg *config.Config, client *imap.Client, wg *s } folder := client.NewFolder(feed.Target) - client.EnsureFolder(folder, func(err error) string { - return fmt.Sprintf("Creating folder of feed %s: %s", feed.Name, err) - }) + if err = client.EnsureFolder(folder); err != nil { + log.Errorf("Creating folder of feed %s: %s", feed.Name, err) + return + } - client.PutMessages(folder, mails, func(err error) string { - return fmt.Sprintf("Uploading messages of feed %s: %s", feed.Name, err) - }) + if err = client.PutMessages(folder, mails); err != nil { + log.Errorf("Uploading messages of feed %s: %s", feed.Name, err) + return + } log.Printf("Uploaded %d messages to '%s' @ %s", len(mails), feed.Name, folder) } -- cgit v1.2.3