feat(remote): `list` includes open proposals

and filters out other branches in `prs/*` namespace

1 files changed, 100 insertions, 0 deletions

diff --git a/tests/git_remote_helper.rs b/tests/git_remote_helper.rs
index 4a60e63..77d7ecb 100644
--- a/tests/git_remote_helper.rs
+++ b/tests/git_remote_helper.rs
@@ -447,6 +447,106 @@ mod list {
                 Ok(())
             }
         }
+
+        mod when_there_are_open_proposals {
+
+            use super::*;
+
+            #[tokio::test]
+            #[serial]
+            async fn open_proposal_listed_in_prs_namespace() -> Result<()> {
+                let (state_event, source_git_repo) = generate_repo_with_state_event().await?;
+                let source_path = source_git_repo.dir.to_str().unwrap().to_string();
+
+                let main_commit_id = source_git_repo.get_tip_of_local_branch("main")?;
+                let example_commit_id =
+                    source_git_repo.get_tip_of_local_branch("example-branch")?;
+
+                let git_repo = prep_git_repo()?;
+
+                let events = vec![
+                    generate_test_key_1_metadata_event("fred"),
+                    generate_test_key_1_relay_list_event(),
+                    generate_repo_ref_event_with_git_server(vec![
+                        source_git_repo.dir.to_str().unwrap().to_string(),
+                    ]),
+                    state_event,
+                ];
+                // fallback (51,52) user write (53, 55) repo (55, 56) blaster (57)
+                let (mut r51, mut r52, mut r53, mut r55, mut r56, mut r57) = (
+                    Relay::new(8051, None, None),
+                    Relay::new(8052, None, None),
+                    Relay::new(8053, None, None),
+                    Relay::new(8055, None, None),
+                    Relay::new(8056, None, None),
+                    Relay::new(8057, None, None),
+                );
+                r51.events = events.clone();
+                r55.events = events;
+
+                let cli_tester_handle = std::thread::spawn(move || -> Result<String> {
+                    cli_tester_create_proposals()?;
+
+                    let mut p = cli_tester_after_fetch(&git_repo)?;
+                    p.send_line("list")?;
+                    p.expect(format!("fetching refs list: {}...\r\n\r", source_path).as_str())?;
+                    // println!("{}", p.expect_eventually("\r\n\r\n")?);
+                    let res = p.expect_eventually("\r\n\r\n")?;
+
+                    p.exit()?;
+                    for p in [51, 52, 53, 55, 56, 57] {
+                        relay::shutdown_relay(8000 + p)?;
+                    }
+                    Ok(res)
+                });
+                // launch relays
+                let _ = join!(
+                    r51.listen_until_close(),
+                    r52.listen_until_close(),
+                    r53.listen_until_close(),
+                    r55.listen_until_close(),
+                    r56.listen_until_close(),
+                    r57.listen_until_close(),
+                );
+
+                let res = cli_tester_handle.join().unwrap()?;
+
+                let proposal_creation_repo = cli_tester_create_proposal_branches_ready_to_send()?;
+
+                let mut pr_refs = vec![];
+                for name in [
+                    FEATURE_BRANCH_NAME_1,
+                    FEATURE_BRANCH_NAME_2,
+                    FEATURE_BRANCH_NAME_3,
+                ] {
+                    pr_refs.push(format!(
+                        "{} {}",
+                        proposal_creation_repo.get_tip_of_local_branch(name)?,
+                        get_proposal_branch_name_from_events(&r55.events, name)?,
+                    ));
+                }
+
+                assert_eq!(
+                    res.split("\r\n")
+                        .map(|e| e.to_string())
+                        .collect::<HashSet<String>>(),
+                    [
+                        vec![
+                            "@refs/heads/main HEAD".to_string(),
+                            format!("{} refs/heads/main", main_commit_id),
+                            format!("{} refs/heads/example-branch", example_commit_id),
+                        ],
+                        pr_refs,
+                    ]
+                    .concat()
+                    .iter()
+                    .cloned()
+                    .collect::<HashSet<String>>()
+                );
+
+                Ok(())
+            }
+        }
     }
 }