Merge pull request #434 from mostafa630/add_workflow_links_to_try_build_started_comments

Add workflow links to try build started comments

Author: Kobzol

.sqlx/query-94ce8ab6ef6cb76aa62aaf81c9f4b1751318faf2009b411b6cd616f47a82abf0.json renamed to .sqlx/query-070fd5babee0d508900290c872bd9247855b9712d6633c1dc3683751941749b1.json

@@ -198,6 +198,14 @@ pub fn try_build_started_comment(
     Comment::new(msg)
 }
 
+pub fn append_workflow_links_to_comment(comment_content: &mut String, workflow_links: Vec<String>) {
+    comment_content.push_str("\n**Workflows**:\n\n");
+
+    for link in workflow_links {
+        comment_content.push_str(&format!("- {link}\n"));
+    }
+}
+
 pub fn merge_conflict_comment(branch: &str) -> Comment {
     let message = format!(
         r#":lock: Merge conflict

src/bors/comment.rs

@@ -87,7 +87,7 @@ mod tests {
     async fn help_command(pool: sqlx::PgPool) {
         run_test(pool, async |tester: &mut BorsTester| {
             tester.post_comment("@bors help").await?;
-            insta::assert_snapshot!(tester.get_comment_text(()).await?, @r"
+            insta::assert_snapshot!(tester.get_next_comment_text(()).await?, @r"
             You can use the following commands:
 
             ## PR management

src/bors/handlers/help.rs

@@ -93,7 +93,7 @@ mod tests {
         run_test(pool, async |tester: &mut BorsTester| {
             tester.post_comment("@bors info").await?;
             insta::assert_snapshot!(
-                tester.get_comment_text(()).await?,
+                tester.get_next_comment_text(()).await?,
                 @r"
             ## Status of PR `1`
             - Not Approved
@@ -113,7 +113,7 @@ mod tests {
 
             tester.post_comment("@bors info").await?;
             insta::assert_snapshot!(
-                tester.get_comment_text(()).await?,
+                tester.get_next_comment_text(()).await?,
                 @r"
             ## Status of PR `1`
             - Approved by: `default-user`
@@ -134,7 +134,7 @@ mod tests {
 
             tester.post_comment("@bors info").await?;
             insta::assert_snapshot!(
-                tester.get_comment_text(()).await?,
+                tester.get_next_comment_text(()).await?,
                 @r"
             ## Status of PR `1`
             - Not Approved
@@ -155,7 +155,7 @@ mod tests {
 
             tester.post_comment("@bors info").await?;
             insta::assert_snapshot!(
-                tester.get_comment_text(()).await?,
+                tester.get_next_comment_text(()).await?,
                 @r"
             ## Status of PR `1`
             - Not Approved
@@ -186,7 +186,7 @@ mod tests {
 
             tester.post_comment("@bors info").await?;
             insta::assert_snapshot!(
-                tester.get_comment_text(()).await?,
+                tester.get_next_comment_text(()).await?,
                 @r"
             ## Status of PR `1`
             - Approved by: `default-user`

src/bors/handlers/info.rs

@@ -108,7 +108,7 @@ pub async fn handle_bors_repository_event(
                 repo = payload.repository.to_string(),
                 id = payload.run_id.into_inner()
             );
-            handle_workflow_started(db, payload)
+            handle_workflow_started(repo, db, payload)
                 .instrument(span.clone())
                 .await?;
 
@@ -728,7 +728,7 @@ mod tests {
     async fn unknown_command(pool: sqlx::PgPool) {
         run_test(pool, async |tester: &mut BorsTester| {
             tester.post_comment(Comment::from("@bors foo")).await?;
-            insta::assert_snapshot!(tester.get_comment_text(()).await?, @r#"Unknown command "foo". Run `@bors help` to see available commands."#);
+            insta::assert_snapshot!(tester.get_next_comment_text(()).await?, @r#"Unknown command "foo". Run `@bors help` to see available commands."#);
             Ok(())
         })
         .await;

src/bors/handlers/mod.rs

@@ -22,7 +22,7 @@ mod tests {
     async fn ping_command(pool: sqlx::PgPool) {
         run_test(pool, async |tester: &mut BorsTester| {
             tester.post_comment("@bors ping").await?;
-            assert_eq!(tester.get_comment_text(()).await?, "Pong 🏓!");
+            assert_eq!(tester.get_next_comment_text(()).await?, "Pong 🏓!");
             Ok(())
         })
         .await;

src/bors/handlers/ping.rs

@@ -350,7 +350,7 @@ mod tests {
                 .await?;
 
             insta::assert_snapshot!(
-                tester.get_comment_text(()).await?,
+                tester.get_next_comment_text(()).await?,
                 @r"
             :warning: The base branch changed to `beta`, and the
             PR will need to be re-approved.
@@ -400,7 +400,7 @@ mod tests {
             tester.push_to_pr(()).await?;
 
             insta::assert_snapshot!(
-                tester.get_comment_text(()).await?,
+                tester.get_next_comment_text(()).await?,
                 @r"
             :warning: A new commit `pr-1-commit-1` was pushed to the branch, the
             PR will need to be re-approved.
@@ -713,7 +713,7 @@ mod tests {
                 .workflow_start(WorkflowRunData::from(tester.auto_branch().await).with_run_id(123))
                 .await?;
             tester.push_to_pr(()).await?;
-            insta::assert_snapshot!(tester.get_comment_text(()).await?, @r"
+            insta::assert_snapshot!(tester.get_next_comment_text(()).await?, @r"
                 :warning: A new commit `pr-1-commit-1` was pushed to the branch, the
                 PR will need to be re-approved.
 
@@ -741,7 +741,7 @@ mod tests {
 
             tester.workflow_start(tester.auto_branch().await).await?;
             tester.push_to_pr(()).await?;
-            insta::assert_snapshot!(tester.get_comment_text(()).await?, @r"
+            insta::assert_snapshot!(tester.get_next_comment_text(()).await?, @r"
                 :warning: A new commit `pr-1-commit-1` was pushed to the branch, the
                 PR will need to be re-approved.
 

src/bors/handlers/pr_events.rs

@@ -284,7 +284,7 @@ timeout = 3600
                     tester.cancel_timed_out_builds().await;
                 })
                 .await;
-                insta::assert_snapshot!(tester.get_comment_text(()).await?, @":boom: Test timed out after `3600`s");
+                insta::assert_snapshot!(tester.get_next_comment_text(()).await?, @":boom: Test timed out after `3600`s");
                 assert_eq!(
                     tester
                         .db()

src/bors/handlers/refresh.rs

@@ -56,7 +56,7 @@ mod tests {
                 .post_comment(Comment::from("@bors retry").with_author(User::unprivileged()))
                 .await?;
             insta::assert_snapshot!(
-                tester.get_comment_text(()).await?,
+                tester.get_next_comment_text(()).await?,
                 @"@unprivileged-user: :key: Insufficient privileges: not in review users"
             );
             Ok(())
@@ -69,7 +69,7 @@ mod tests {
         run_test(pool, async |tester: &mut BorsTester| {
             tester.post_comment(Comment::from("@bors retry")).await?;
             insta::assert_snapshot!(
-                tester.get_comment_text(()).await?,
+                tester.get_next_comment_text(()).await?,
                 @":exclamation: You can only retry pull requests that are approved and have a previously failed auto build"
             );
             Ok(())
@@ -90,7 +90,7 @@ mod tests {
             tester.wait_for_pr((), |pr| pr.auto_build.is_none()).await?;
             tester.process_merge_queue().await;
             insta::assert_snapshot!(
-                tester.get_comment_text(()).await?,
+                tester.get_next_comment_text(()).await?,
                 @":hourglass: Testing commit pr-1-sha with merge merge-1-pr-1..."
             );
             Ok(())