@bors info command

Author: Rhythm1710

.gitignore

@@ -1 +1,2 @@
 target/
+.env

src/bors/command/mod.rs

@@ -49,4 +49,6 @@ pub enum BorsCommand {
     TryCancel,
     /// Set the priority of a commit.
     SetPriority(Priority),
+    /// Get information about the current PR.
+    Info,
 }

src/bors/command/parser.rs

@@ -51,6 +51,7 @@ impl CommandParser {
             parser_ping,
             parser_try_cancel,
             parser_try,
+            parser_info,
         ];
 
         text.lines()
@@ -130,7 +131,6 @@ fn parse_parts(input: &str) -> Result<Vec<CommandPart>, CommandParseError> {
 }
 
 /// Parsers
-
 /// Parses "@bors r+ <p=priority>"
 fn parse_self_approve<'a>(command: &'a str, parts: &[CommandPart<'a>]) -> ParseResult<'a> {
     if command != "r+" {
@@ -321,6 +321,15 @@ fn parse_priority_arg<'a>(parts: &[CommandPart<'a>]) -> Result<Option<u32>, Comm
     Ok(priority)
 }
 
+/// Parses "@bors info"
+fn parser_info<'a>(command: &'a str, _parts: &[CommandPart<'a>]) -> ParseResult<'a> {
+    if command == "info" {
+        Some(Ok(BorsCommand::Info))
+    } else {
+        None
+    }
+}
+
 #[cfg(test)]
 mod tests {
     use crate::bors::command::parser::{CommandParseError, CommandParser};
@@ -814,6 +823,20 @@ line two
         "###)
     }
 
+    #[test]
+    fn parse_info() {
+        let cmds = parse_commands("@bors info");
+        assert_eq!(cmds.len(), 1);
+        assert!(matches!(cmds[0], Ok(BorsCommand::Info)));
+    }
+
+    #[test]
+    fn parse_info_unknown_arg() {
+        let cmds = parse_commands("@bors info a");
+        assert_eq!(cmds.len(), 1);
+        assert!(matches!(cmds[0], Ok(BorsCommand::Info)));
+    }
+
     #[test]
     fn parse_try_cancel() {
         let cmds = parse_commands("@bors try cancel");

src/bors/handlers/help.rs

@@ -26,6 +26,7 @@ pub(super) async fn command_help(
         BorsCommand::TryCancel,
         BorsCommand::Ping,
         BorsCommand::Help,
+        BorsCommand::Info,
     ]
     .into_iter()
     .map(|help| format!("- {}", get_command_help(help)))
@@ -65,6 +66,9 @@ fn get_command_help(command: BorsCommand) -> String {
         BorsCommand::TryCancel => {
             "`try cancel`: Cancel a running try build"
         }
+        BorsCommand::Info => {
+            "`info`: Get information about the current PR including delegation, priority, merge status, and try build status"
+        }
     };
     help.to_string()
 }
@@ -86,6 +90,7 @@ mod tests {
             - `try cancel`: Cancel a running try build
             - `ping`: Check if the bot is alive
             - `help`: Print this help message
+            - `info`: Get information about the current PR including delegation, priority, merge status, and try build status
             ");
             Ok(tester)
         })

src/bors/handlers/info.rs

@@ -0,0 +1,58 @@
+use crate::bors::Comment;
+use crate::bors::RepositoryState;
+use crate::database::PgDbClient;
+use crate::github::PullRequest;
+use std::sync::Arc;
+
+pub(super) async fn command_info(
+    repo: Arc<RepositoryState>,
+    pr: &PullRequest,
+    db: Arc<PgDbClient>,
+) -> anyhow::Result<()> {
+    // Geting PR info from database
+    let pr_model = db.get_pull_request(repo.repository(), pr.number).await?;
+
+    // Building the info message
+    let mut info_lines = Vec::new();
+
+    // Approval info
+    if let Some(pr) = pr_model {
+        if let Some(approved_by) = pr.approved_by {
+            info_lines.push(format!("- **Approved by:** @{}", approved_by));
+        } else {
+            info_lines.push("- **Approved by:** No one".to_string());
+        }
+
+        // Priority info
+        if let Some(priority) = pr.priority {
+            info_lines.push(format!("- **Priority:** {}", priority));
+        } else {
+            info_lines.push("- **Priority:** None".to_string());
+        }
+
+        // Build status
+        if let Some(try_build) = pr.try_build {
+            info_lines.push(format!("- **Try build branch:** {}", try_build.branch));
+        } else {
+            info_lines.push("- **Try build:** None".to_string());
+        }
+    } else {
+        info_lines.push("- **PR not found in database**".to_string());
+    }
+
+    // Merge status (placeholder for future)
+    info_lines.push("- **Merge status:** Not implemented yet".to_string());
+
+    // Queue link (placeholder for future)
+    info_lines.push("- **Queue link:** Not implemented yet".to_string());
+
+    // Joining all lines
+    let info = info_lines.join("\n");
+
+    // Post the comment
+    repo.client
+        .post_comment(pr.number, Comment::new(info))
+        .await?;
+
+    Ok(())
+}

src/bors/handlers/mod.rs

@@ -8,6 +8,7 @@ use tracing::Instrument;
 use crate::bors::command::{BorsCommand, CommandParseError};
 use crate::bors::event::{BorsGlobalEvent, BorsRepositoryEvent, PullRequestComment};
 use crate::bors::handlers::help::command_help;
+use crate::bors::handlers::info::command_info;
 use crate::bors::handlers::ping::command_ping;
 use crate::bors::handlers::refresh::refresh_repository;
 use crate::bors::handlers::review::{
@@ -24,6 +25,7 @@ use crate::{load_repositories, PgDbClient, TeamApiClient};
 use crate::tests::util::TestSyncMarker;
 
 mod help;
+mod info;
 mod labels;
 mod ping;
 mod refresh;
@@ -264,6 +266,12 @@ async fn handle_comment(
                             .instrument(span)
                             .await
                     }
+                    BorsCommand::Info => {
+                        let span = tracing::info_span!("Info");
+                        command_info(repo, &pull_request, database)
+                            .instrument(span)
+                            .await
+                    }
                 };
                 if result.is_err() {
                     return result.context("Cannot execute Bors command");

src/database/client.rs

@@ -168,4 +168,11 @@ impl PgDbClient {
             .collect::<Vec<_>>();
         Ok(workflows)
     }
+    pub async fn get_pull_request(
+        &self,
+        repo: &GithubRepoName,
+        pr_number: PullRequestNumber,
+    ) -> anyhow::Result<Option<PullRequestModel>> {
+        get_pull_request(&self.pool, repo, pr_number).await
+    }
 }