From f4b2c8322b176a90173abb4adf6bceb703544f87 Mon Sep 17 00:00:00 2001
From: Aleksandr Nogikh <nogikh@google.com>
Date: Tue, 22 Jul 2025 15:40:32 +0200
Subject: syz-cluster: improve email-reporter logging

Give more visibility into what the component is doing and why it fails.
---
 syz-cluster/email-reporter/handler.go | 3 +++
 syz-cluster/email-reporter/main.go    | 4 +++-
 syz-cluster/email-reporter/stream.go  | 3 +++
 3 files changed, 9 insertions(+), 1 deletion(-)

diff --git a/syz-cluster/email-reporter/handler.go b/syz-cluster/email-reporter/handler.go
index 5074ad24f..c0af2e7d7 100644
--- a/syz-cluster/email-reporter/handler.go
+++ b/syz-cluster/email-reporter/handler.go
@@ -26,6 +26,9 @@ type Handler struct {
 }
 
 func (h *Handler) PollReportsLoop(ctx context.Context, pollPeriod time.Duration) {
+	defer log.Printf("reporter server polling aborted")
+	log.Printf("reporter server polling started")
+
 	for {
 		_, err := h.PollAndReport(ctx)
 		if err != nil {
diff --git a/syz-cluster/email-reporter/main.go b/syz-cluster/email-reporter/main.go
index 5ed7e8a6a..2557bbb8d 100644
--- a/syz-cluster/email-reporter/main.go
+++ b/syz-cluster/email-reporter/main.go
@@ -76,5 +76,7 @@ func main() {
 		handler.PollReportsLoop(loopCtx, senderPollPeriod)
 		return nil
 	})
-	eg.Wait()
+	if err = eg.Wait(); err != nil {
+		app.Errorf("failed: %s", err)
+	}
 }
diff --git a/syz-cluster/email-reporter/stream.go b/syz-cluster/email-reporter/stream.go
index 4aa035cec..a27f71d9f 100644
--- a/syz-cluster/email-reporter/stream.go
+++ b/syz-cluster/email-reporter/stream.go
@@ -53,6 +53,9 @@ const (
 )
 
 func (s *LKMLEmailStream) Loop(ctx context.Context, pollPeriod time.Duration) error {
+	defer log.Printf("lore archive polling aborted")
+	log.Printf("lore archive %s polling started", s.cfg.LoreArchiveURL)
+
 	last, err := s.client.LastReply(ctx, s.reporterName)
 	if err != nil {
 		return fmt.Errorf("failed to query the last reply: %w", err)
-- 
cgit mrf-deployment