Merge pull request #397 from JerryQ17/minimize-comment-v2

Add comment minimization logic and minimize try build started comments

Author: Kobzol

.sqlx/query-31a9c72676df4d3c7f13b7a0b92dcb7e473fa2086d7e4b84a9dd4aacac2fde28.json

@@ -70,6 +70,7 @@ regex = "1"
 parking_lot = "0.12"
 thread_local = "1"
 sqlparser = { version = "0.58", features = ["visitor"] }
+graphql-parser = "0.4"
 
 [profile.release]
 debug = 1

.sqlx/query-6bb7558f15546f6b11396411a4b0461b25d20350e99cd55e8f0bc2bca2177134.json

@@ -0,0 +1,3 @@
+DROP INDEX IF EXISTS comment_repo_pr_tag_idx;
+
+DROP TABLE IF EXISTS comment;

.sqlx/query-94ce8ab6ef6cb76aa62aaf81c9f4b1751318faf2009b411b6cd616f47a82abf0.json

@@ -0,0 +1,10 @@
+CREATE TABLE IF NOT EXISTS comment (
+  id SERIAL PRIMARY KEY,
+  repository TEXT NOT NULL,
+  pr_number BIGINT NOT NULL,
+  tag TEXT NOT NULL,
+  node_id TEXT NOT NULL,
+  created_at TIMESTAMPTZ NOT NULL DEFAULT CURRENT_TIMESTAMP
+);
+
+CREATE INDEX comment_repo_pr_tag_idx ON comment (repository, pr_number, tag);

Cargo.lock

@@ -24,6 +24,12 @@ pub enum CommentMetadata {
     TryBuildCompleted { merge_sha: String },
 }
 
+/// A tag for a comment, used to identify the comment.
+#[derive(Debug, Copy, Clone, PartialEq, Eq)]
+pub enum CommentTag {
+    TryBuildStarted,
+}
+
 impl Comment {
     pub fn new(text: String) -> Self {
         Self {

Cargo.toml

@@ -574,6 +574,23 @@ fn is_bors_observed_branch(branch: &str) -> bool {
     branch == TRY_BRANCH_NAME || branch == AUTO_BRANCH_NAME
 }
 
+#[derive(PartialEq, Eq, Copy, Clone, Debug)]
+pub enum BuildType {
+    Try,
+    Auto,
+}
+
+/// Get the build type based on the branch where it happened.
+pub fn get_build_type(branch: &str) -> Option<BuildType> {
+    if branch == TRY_BRANCH_NAME {
+        Some(BuildType::Try)
+    } else if branch == AUTO_BRANCH_NAME {
+        Some(BuildType::Auto)
+    } else {
+        None
+    }
+}
+
 /// Deny permission for a request.
 async fn deny_request(
     repo: &RepositoryState,
@@ -593,7 +610,8 @@ async fn deny_request(
                 author.username, permission_type
             )),
         )
-        .await
+        .await?;
+    Ok(())
 }
 
 /// Check if a user has specified permission or has been delegated.

migrations/20250729051122_create_comment.down.sql

@@ -258,7 +258,8 @@ async fn notify_of_edited_pr(
 PR will need to be re-approved."#,
             )),
         )
-        .await
+        .await?;
+    Ok(())
 }
 
 async fn notify_of_pushed_pr(
@@ -279,7 +280,8 @@ PR will need to be re-approved."#,
 
     repo.client
         .post_comment(pr_number, Comment::new(comment))
-        .await
+        .await?;
+    Ok(())
 }
 
 #[cfg(test)]