use bstr::ByteSlice;use gix_features::progress;use gix_protocol::handshake;use gix_transport::Protocol; use crate::fetch::{_impl::FetchConnection, CloneDelegate, LsRemoteDelegate, helper_unused, oid, transport}; #[crate::bisync::bisync]#[cfg_attr(feature = "blocking-client", test)]#[cfg_attr(all(feature = "async-client", not(feature = "blocking-client")), async_std::test)]async fn clone() -> crate::Result {    for with_keepalive in [false, true] {        let out = Vec::new();        let mut dlg = CloneDelegate::default();        let fixture = format!(            "v1/clone{}.response",            if with_keepalive {                "-with-keepalive"            } else {                Default::default()            }        );        crate::fetch(            transport(                out,                &fixture,                Protocol::V1,                gix_transport::client::git::ConnectMode::Daemon,            ),            &mut dlg,            helper_unused,            progress::Discard,            FetchConnection::TerminateOnSuccessfulCompletion,            "agent",            false,        )        .await?;        assert_eq!(dlg.pack_bytes, 876, "{fixture}: It be able to read pack bytes");    }    Ok(())} #[crate::bisync::bisync]#[cfg_attr(feature = "blocking-client", test)]#[cfg_attr(all(feature = "async-client", not(feature = "blocking-client")), async_std::test)]async fn clone_empty_with_capabilities() -> crate::Result {    let out = Vec::new();    let mut dlg = CloneDelegate::default();    crate::fetch(        transport(            out,            "v1/clone-empty-with-capabilities.response",            Protocol::V1,            gix_transport::client::git::ConnectMode::Daemon,        ),        &mut dlg,        helper_unused,        progress::Discard,        FetchConnection::TerminateOnSuccessfulCompletion,        "agent",        false,    )    .await?;    assert_eq!(dlg.pack_bytes, 0, "there is no pack");    Ok(())} #[crate::bisync::bisync]#[cfg_attr(feature = "blocking-client", test)]#[cfg_attr(all(feature = "async-client", not(feature = "blocking-client")), async_std::test)]async fn ls_remote() -> crate::Result {    let out = Vec::new();    let mut delegate = LsRemoteDelegate::default();    let mut transport = transport(        out,        "v1/clone.response",        Protocol::V1,        gix_transport::client::git::ConnectMode::Daemon,    );    crate::fetch(        &mut transport,        &mut delegate,        helper_unused,        progress::Discard,        FetchConnection::AllowReuse,        "agent",        false,    )    .await?;     assert_eq!(        delegate.refs,        vec![            handshake::Ref::Symbolic {                full_ref_name: "HEAD".into(),                object: oid("808e50d724f604f69ab93c6da2919c014667bedb"),                tag: None,                target: "refs/heads/master".into()            },            handshake::Ref::Direct {                full_ref_name: "refs/heads/master".into(),                object: oid("808e50d724f604f69ab93c6da2919c014667bedb")            }        ]    );    assert_eq!(        transport.into_inner().1.as_bstr(),        b"003agit-upload-pack does/not/matter\x00\x00value-only\x00key=value\x000000".as_bstr(),        "we don't have to send anything in V1, except for the final flush byte to indicate we are done"    );    Ok(())} #[crate::bisync::bisync]#[cfg_attr(feature = "blocking-client", test)]#[cfg_attr(all(feature = "async-client", not(feature = "blocking-client")), async_std::test)]async fn ls_remote_handshake_failure_due_to_downgrade() -> crate::Result {    let out = Vec::new();    let delegate = LsRemoteDelegate::default();     crate::fetch(        transport(            out,            "v1/clone.response",            Protocol::V2,            gix_transport::client::git::ConnectMode::Process,        ),        delegate,        helper_unused,        progress::Discard,        FetchConnection::AllowReuse,        "agent",        false,    )    .await    .expect("V1 is OK for this transport");    Ok(())}