mbox: use named logger

Signed-off-by: Robin Jarry <robin@jarry.cc>

1 files changed, 10 insertions, 10 deletions

diff --git a/worker/mbox/worker.go b/worker/mbox/worker.go
index 7a746cf0..0e6c64d1 100644
--- a/worker/mbox/worker.go
+++ b/worker/mbox/worker.go
@@ -80,7 +80,7 @@ func (w *mboxWorker) handleMessage(msg types.WorkerMessage) error {
 			reterr = err
 			break
 		} else {
-			log.Debugf("configured with mbox file %s", dir)
+			w.worker.Debugf("configured with mbox file %s", dir)
 		}
 
 	case *types.Connect, *types.Reconnect, *types.Disconnect:
@@ -116,7 +116,7 @@ func (w *mboxWorker) handleMessage(msg types.WorkerMessage) error {
 			Info: w.data.DirectoryInfo(msg.Directory),
 		}, nil)
 		w.worker.PostMessage(&types.Done{Message: types.RespondTo(msg)}, nil)
-		log.Debugf("%s opened", msg.Directory)
+		w.worker.Debugf("%s opened", msg.Directory)
 
 	case *types.FetchDirectoryContents:
 		uids, err := filterUids(w.folder, w.folder.Uids(), msg.FilterCriteria)
@@ -183,7 +183,7 @@ func (w *mboxWorker) handleMessage(msg types.WorkerMessage) error {
 	case *types.FetchMessageBodyPart:
 		m, err := w.folder.Message(msg.Uid)
 		if err != nil {
-			log.Errorf("could not get message %d: %v", msg.Uid, err)
+			w.worker.Errorf("could not get message %d: %v", msg.Uid, err)
 			reterr = err
 			break
 		}
@@ -202,7 +202,7 @@ func (w *mboxWorker) handleMessage(msg types.WorkerMessage) error {
 
 		r, err := lib.FetchEntityPartReader(fullMsg, msg.Part)
 		if err != nil {
-			log.Errorf(
+			w.worker.Errorf(
 				"could not get body part reader for message=%d, parts=%#v: %w",
 				msg.Uid, msg.Part, err)
 			reterr = err
@@ -221,18 +221,18 @@ func (w *mboxWorker) handleMessage(msg types.WorkerMessage) error {
 		for _, uid := range msg.Uids {
 			m, err := w.folder.Message(uid)
 			if err != nil {
-				log.Errorf("could not get message for uid %d: %v", uid, err)
+				w.worker.Errorf("could not get message for uid %d: %v", uid, err)
 				continue
 			}
 			r, err := m.NewReader()
 			if err != nil {
-				log.Errorf("could not get message reader: %v", err)
+				w.worker.Errorf("could not get message reader: %v", err)
 				continue
 			}
 			defer r.Close()
 			b, err := io.ReadAll(r)
 			if err != nil {
-				log.Errorf("could not get message reader: %v", err)
+				w.worker.Errorf("could not get message reader: %v", err)
 				continue
 			}
 			w.worker.PostMessage(&types.FullMessage{
@@ -267,17 +267,17 @@ func (w *mboxWorker) handleMessage(msg types.WorkerMessage) error {
 		for _, uid := range msg.Uids {
 			m, err := w.folder.Message(uid)
 			if err != nil {
-				log.Errorf("could not get message: %v", err)
+				w.worker.Errorf("could not get message: %v", err)
 				continue
 			}
 			if err := m.(*message).SetFlag(msg.Flags, msg.Enable); err != nil {
-				log.Errorf("could not change flag %v to %t on message: %v",
+				w.worker.Errorf("could not change flag %v to %t on message: %v",
 					msg.Flags, msg.Enable, err)
 				continue
 			}
 			info, err := lib.MessageInfo(m)
 			if err != nil {
-				log.Errorf("could not get message info: %v", err)
+				w.worker.Errorf("could not get message info: %v", err)
 				continue
 			}