From c1a1ca91febf69695cf3f989f3aa7945d50c055e Mon Sep 17 00:00:00 2001 From: Ynah537 Date: Wed, 21 Jan 2026 11:18:59 +0800 Subject: [PATCH 1/3] fix: include message id in the payload --- scenario.go | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/scenario.go b/scenario.go index 6d900ba..5bf1332 100644 --- a/scenario.go +++ b/scenario.go @@ -49,6 +49,7 @@ type ReportPubsub struct { Attributes map[string]string `json:"attributes"` // [status]=success|error Status string `json:"status"` // success|error Data string `json:"data"` + MessageID string `json:"message_id"` // Unique message ID for tracking } // Scenario represents a single scenario file to run. @@ -504,9 +505,10 @@ func doScenario(in *doScenarioInput) error { Attributes: attr, Status: status, Data: data, + MessageID: uniuri.NewLen(10), } - err := in.app.rpub.Publish(uniuri.NewLen(10), r) + err := in.app.rpub.Publish(r.MessageID, r) if err != nil { log.Printf("Publish failed: %v", err) } From d2824613359195f8800287692629073ebe2cf522 Mon Sep 17 00:00:00 2001 From: Ynah537 Date: Wed, 21 Jan 2026 11:24:16 +0800 Subject: [PATCH 2/3] style: remove duplicate success indicator --- scenario.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/scenario.go b/scenario.go index 5bf1332..c7ccdfd 100644 --- a/scenario.go +++ b/scenario.go @@ -448,7 +448,7 @@ func doScenario(in *doScenarioInput) error { { Color: "good", Title: fmt.Sprintf("%v - success", filepath.Base(f)), - Text: fmt.Sprintf("All tests passed! ✅\nMaintainers: %v", strings.Join(s.Maintainers, ", ")), + Text: fmt.Sprintf("All tests passed! \nMaintainers: %v", strings.Join(s.Maintainers, ", ")), Footer: "oops", Timestamp: time.Now().Unix(), }, From a229b65e1b349f906b71e5675813179a74c9e143 Mon Sep 17 00:00:00 2001 From: Ynah537 Date: Wed, 21 Jan 2026 11:39:10 +0800 Subject: [PATCH 3/3] chore: update log messages --- scenario.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/scenario.go b/scenario.go index c7ccdfd..5a61346 100644 --- a/scenario.go +++ b/scenario.go @@ -412,7 +412,7 @@ func doScenario(in *doScenarioInput) error { { Color: "warning", Title: fmt.Sprintf("%v - cancelled", filepath.Base(f)), - Text: fmt.Sprintf("Test execution was cancelled (PR closed or manually cancelled)\nMaintainers: %v", strings.Join(s.Maintainers, ", ")), + Text: fmt.Sprintf("Test execution was cancelled (PR closed )\nMaintainers: %v", strings.Join(s.Maintainers, ", ")), Footer: "oops", Timestamp: time.Now().Unix(), }, @@ -477,7 +477,7 @@ func doScenario(in *doScenarioInput) error { if wasCancelled { status = "cancelled" - data = "Test execution was cancelled (PR closed or manually cancelled)" + data = "Test execution was cancelled (PR closed)" } else if len(s.errs) > 0 { status = "error" data = fmt.Sprintf("%v", s.errs)