agentic-outer-dag-bin 0.1.2

External outer-DAG driver for worktree→PR→CodeRabbit loops
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73

use anyhow::Result;
use pr_comments::PrComments;
use pr_comments::git;
use pr_comments::models::PrRef;

pub struct GitHubPrClient {
    pr_comments: PrComments,
    repo_context: RepoContext,
}

#[derive(Debug, Clone, PartialEq, Eq)]
pub struct DetectedPrLookup {
    pub requested_branch: String,
    pub current_branch: Option<String>,
    pub repo_owner: String,
    pub repo_name: String,
    pub token_source: Option<String>,
    pub empty_result_reason: Option<String>,
    pub pr: Option<PrRef>,
}

#[derive(Debug, Clone)]
struct RepoContext {
    owner: String,
    repo: String,
    current_branch: Option<String>,
}

impl GitHubPrClient {
    pub fn new() -> Result<Self> {
        let repo_context = RepoContext::from_current_dir()?;
        Ok(Self {
            pr_comments: PrComments::with_repo(
                repo_context.owner.clone(),
                repo_context.repo.clone(),
            ),
            repo_context,
        })
    }

    pub async fn detect_open_pr_from_branch(&self, branch: &str) -> Result<DetectedPrLookup> {
        let lookup = self
            .pr_comments
            .get_open_pr_ref_from_branch_detailed(branch)
            .await?;

        Ok(DetectedPrLookup {
            requested_branch: branch.to_string(),
            current_branch: self.repo_context.current_branch.clone(),
            repo_owner: self.repo_context.owner.clone(),
            repo_name: self.repo_context.repo.clone(),
            token_source: self.pr_comments.token_source_label().map(str::to_string),
            empty_result_reason: lookup.empty_result_reason,
            pr: lookup.pr,
        })
    }

    pub async fn mark_ready_for_review(&self, pr: &PrRef) -> Result<PrRef> {
        self.pr_comments.mark_pr_ready_for_review(&pr.node_id).await
    }
}

impl RepoContext {
    fn from_current_dir() -> Result<Self> {
        let git_info = git::get_git_info()?;

        Ok(Self {
            owner: git_info.owner,
            repo: git_info.repo,
            current_branch: git_info.current_branch,
        })
    }
}