use crate::{
error::Result,
forge::{Forge, ForgeCreateMergeRequestOptions, ForgeMergeRequestState, github::GitHubForge},
tests::{TestRepo, unique_branch},
};
#[tokio::test]
async fn test_submit_creates_pr() -> Result<()> {
let repo = TestRepo::with_azure_remote();
let branch = unique_branch("create-pr");
repo.jj.exec(["new", "main"])?;
repo.create_change("test.txt", "content", "Test commit")
.create_and_push_bookmark(&branch);
repo.run(["submit", &branch]).await;
let pr = repo
.forge()
.find_merge_request_by_source_branch(&branch)
.await?
.expect("PR should exist");
assert_eq!(pr.source_branch(), branch);
assert_eq!(pr.target_branch(), "main");
assert_eq!(pr.state(), ForgeMergeRequestState::Open);
Ok(())
}
#[tokio::test]
async fn test_submit_creates_stacked_prs() -> Result<()> {
let repo = TestRepo::with_azure_remote();
let branch_a = unique_branch("stack-a");
let branch_b = unique_branch("stack-b");
let branch_c = unique_branch("stack-c");
repo.jj.exec(["new", "main"])?;
repo.create_change("a.txt", "a", "Commit A")
.create_and_push_bookmark(&branch_a);
repo.jj.exec(["new"])?;
repo.create_change("b.txt", "b", "Commit B")
.create_and_push_bookmark(&branch_b);
repo.jj.exec(["new"])?;
repo.create_change("c.txt", "c", "Commit C")
.create_and_push_bookmark(&branch_c);
repo.run(["submit", &branch_c]).await;
assert_eq!(
repo.forge()
.find_merge_request_by_source_branch(&branch_a)
.await?
.map(|pr| pr.target_branch().to_string()),
Some("main".to_string())
);
assert_eq!(
repo.forge()
.find_merge_request_by_source_branch(&branch_b)
.await?
.map(|pr| pr.target_branch().to_string()),
Some(branch_a.to_string())
);
assert_eq!(
repo.forge()
.find_merge_request_by_source_branch(&branch_c)
.await?
.map(|pr| pr.target_branch().to_string()),
Some(branch_b.to_string())
);
Ok(())
}
#[tokio::test]
async fn test_submit_is_idempotent() -> Result<()> {
let repo = TestRepo::with_azure_remote();
let branch = unique_branch("idempotent");
repo.jj.exec(["new", "main"])?;
repo.create_change("test.txt", "content", "Test commit")
.create_and_push_bookmark(&branch);
repo.run(["submit", &branch]).await;
let pr1 = repo
.forge()
.find_merge_request_by_source_branch(&branch)
.await?
.expect("PR should exist");
repo.run(["submit", &branch]).await;
let pr2 = repo
.forge()
.find_merge_request_by_source_branch(&branch)
.await?
.expect("PR should exist");
assert_eq!(pr1.iid(), pr2.iid());
Ok(())
}
#[tokio::test]
async fn test_submit_retargets_after_middle_bookmark_deleted() -> Result<()> {
let repo = TestRepo::with_azure_remote();
let branch_a = unique_branch("retarget-a");
let branch_b = unique_branch("retarget-b");
let branch_c = unique_branch("retarget-c");
repo.jj.exec(["new", "main"])?;
repo.create_change("a.txt", "a", "Commit A")
.create_and_push_bookmark(&branch_a);
repo.jj.exec(["new"])?;
repo.create_change("b.txt", "b", "Commit B")
.create_and_push_bookmark(&branch_b);
repo.jj.exec(["new"])?;
repo.create_change("c.txt", "c", "Commit C")
.create_and_push_bookmark(&branch_c);
repo.run(["submit", &branch_c]).await;
assert_eq!(
repo.forge()
.find_merge_request_by_source_branch(&branch_c)
.await?
.map(|pr| pr.target_branch().to_string()),
Some(branch_b.to_string())
);
repo.jj.exec(["bookmark", "delete", &branch_b])?;
repo.run(["submit", &branch_c]).await;
assert_eq!(
repo.forge()
.find_merge_request_by_source_branch(&branch_c)
.await?
.map(|pr| pr.target_branch().to_string()),
Some(branch_a.to_string())
);
Ok(())
}
#[tokio::test]
async fn test_invalid_token_errors_clearly() -> Result<()> {
dotenv::dotenv().ok();
let host =
std::env::var("GITHUB_HOST").unwrap_or_else(|_| "https://api.github.com".to_string());
let project = std::env::var("GITHUB_PROJECT").expect("GITHUB_PROJECT required");
let ca_bundle = std::env::var("GITHUB_CA_BUNDLE").ok();
let accept_non_compliant = std::env::var("GITHUB_TLS_ACCEPT_NON_COMPLIANT_CERTS")
.ok()
.and_then(|v| v.parse::<bool>().ok())
.unwrap_or(false);
let client = GitHubForge::new(
host,
project.clone(),
project,
"ghp_invalid_token_12345".to_string(),
ca_bundle,
accept_non_compliant,
)?;
let result = client
.create_merge_request(ForgeCreateMergeRequestOptions {
source_branch: unique_branch("invalid-token"),
target_branch: "main".to_string(),
title: "This should fail".to_string(),
description: Some("Testing invalid token".to_string()),
..Default::default()
})
.await;
assert!(result.unwrap_err().to_string().contains("401"));
Ok(())
}
#[tokio::test]
async fn test_nonexistent_project_errors_clearly() -> Result<()> {
dotenv::dotenv().ok();
let host =
std::env::var("GITHUB_HOST").unwrap_or_else(|_| "https://api.github.com".to_string());
let token = std::env::var("GITHUB_TOKEN").expect("GITHUB_TOKEN required");
let ca_bundle = std::env::var("GITHUB_CA_BUNDLE").ok();
let accept_non_compliant = std::env::var("GITHUB_TLS_ACCEPT_NON_COMPLIANT_CERTS")
.ok()
.and_then(|v| v.parse::<bool>().ok())
.unwrap_or(false);
let client = GitHubForge::new(
host,
"nonexistent/fake-project-12345".to_string(),
"nonexistent/fake-project-12345".to_string(),
token,
ca_bundle,
accept_non_compliant,
)?;
let result = client
.create_merge_request(ForgeCreateMergeRequestOptions {
source_branch: unique_branch("nonexistent-project"),
target_branch: "main".to_string(),
title: "This should fail".to_string(),
description: Some("Testing nonexistent project".to_string()),
..Default::default()
})
.await;
assert!(result.unwrap_err().to_string().contains("404"));
Ok(())
}