use crate::fixture_bytes;use bstr::ByteSlice;use git_transport::client::Identity;use git_transport::{ client::{self, http, SetServiceResponse, Transport, TransportV2Ext}, Protocol, Service,};use std::{ cell::RefCell, error::Error, io::{self, BufRead, Read, Write}, ops::Deref, rc::Rc,}; mod mock; fn assert_error_status( status: usize, kind: std::io::ErrorKind,) -> Result<(mock::Server, http::Transport<http::Impl>), crate::Error> { let (server, mut client) = mock::serve_and_connect(&format!("http-{}.response", status), "path/not-important", Protocol::V1)?; let error = client .handshake(Service::UploadPack) .err() .expect("non-200 status causes error"); let error = error .source() .expect("source") .downcast_ref::<std::io::Error>() .expect("io error as source"); assert_eq!(error.kind(), kind); assert_eq!(error.to_string(), format!("Received HTTP status {}", status)); drop(server.received()); Ok((server, client))} #[test]fn http_authentication_error_can_be_differentiated_and_identity_is_transmitted() -> crate::Result { let (server, mut client) = assert_error_status(401, std::io::ErrorKind::PermissionDenied)?; server.next_read_and_respond_with(fixture_bytes("v1/http-handshake.response")); client.set_identity(Identity::Account { username: "user".into(), password: "password".into(), })?; client.handshake(Service::UploadPack)?; assert_eq!( server.received_as_string().lines().collect::<Vec<_>>(), format!( "GET /path/not-important/info/refs?service=git-upload-pack HTTP/1.1Host: 127.0.0.1:{}Accept: */*User-Agent: git/oxide-{}Authorization: Basic dXNlcjpwYXNzd29yZA== ", server.addr.port(), env!("CARGO_PKG_VERSION") ) .lines() .collect::<Vec<_>>() ); server.next_read_and_respond_with(fixture_bytes("v1/http-handshake.response")); client.request(client::WriteMode::Binary, client::MessageKind::Flush)?; assert_eq!( server.received_as_string().lines().collect::<Vec<_>>(), format!( "POST /path/not-important/git-upload-pack HTTP/1.1Host: 127.0.0.1:{}Transfer-Encoding: chunkedUser-Agent: git/oxide-{}Content-Type: application/x-git-upload-pack-requestAccept: application/x-git-upload-pack-resultAuthorization: Basic dXNlcjpwYXNzd29yZA== 0 ", server.addr.port(), env!("CARGO_PKG_VERSION") ) .lines() .collect::<Vec<_>>(), "the authentication information is used in subsequent calls" ); Ok(())} #[test]fn http_error_results_in_observable_error() -> crate::Result { assert_error_status(404, std::io::ErrorKind::Other)?; Ok(())} #[test]fn handshake_v1() -> crate::Result { let (server, mut c) = mock::serve_and_connect( "v1/http-handshake.response", "path/not/important/due/to/mock", Protocol::V1, )?; assert!(!c.is_stateful(), "http connections are never stateful"); let SetServiceResponse { actual_protocol, capabilities, refs, } = c.handshake(Service::UploadPack)?; assert_eq!(actual_protocol, Protocol::V1); assert_eq!( capabilities .iter() .map(|c| (c.name().to_owned(), c.value().map(ToOwned::to_owned))) .collect::<Vec<_>>(), [ ("multi_ack", None), ("thin-pack", None), ("side-band", None), ("side-band-64k", None), ("ofs-delta", None), ("shallow", None), ("deepen-since", None), ("deepen-not", None), ("deepen-relative", None), ("no-progress", None), ("include-tag", None), ("multi_ack_detailed", None), ("allow-tip-sha1-in-want", None), ("allow-reachable-sha1-in-want", None), ("no-done", None), ("symref", Some("HEAD:refs/heads/main")), ("filter", None), ("agent", Some("git/github-gdf51a71f0236")) ] .iter() .map(|(n, v)| ( n.as_bytes().as_bstr().to_owned(), v.map(|v| v.as_bytes().as_bstr().to_owned()) )) .collect::<Vec<_>>() ); let refs = refs .expect("v1 protocol provides refs") .lines() .flat_map(Result::ok) .collect::<Vec<_>>(); assert_eq!( refs, vec![ "73a6868963993a3328e7d8fe94e5a6ac5078a944 HEAD", "73a6868963993a3328e7d8fe94e5a6ac5078a944 refs/heads/main", "8e472f9ccc7d745927426cbb2d9d077de545aa4e refs/pull/13/head", "1a33becbfa6aaf7661824ce40016acb8c179f13c refs/pull/14/head", "add2e3e8d155571154c8816cf57f473a6e4d8d31 refs/pull/2/head", "dce0ea858eef7ff61ad345cc5cdac62203fb3c10 refs/tags/git-commitgraph-v0.0.0", "21c9b7500cb144b3169a6537961ec2b9e865be81 refs/tags/git-commitgraph-v0.0.0^{}", "7ba6656568da186d153d66f26990b9b364ea9609 refs/tags/git-features-v0.1.0", "5688a3427ff3673e1422d43106f4d685fa837aed refs/tags/git-features-v0.1.0^{}", "92945a59059bf044744639673f1a0f5b314762ee refs/tags/git-features-v0.2.0", "0bb831480d8657e1bb29ee7009aeac673471403e refs/tags/git-features-v0.2.0^{}", "97e1d77270a8f9cbff19baf3803de8b4f5a339bf refs/tags/git-features-v0.3.0", "4351e2871c9dcf342b8471fffa74cae338a53269 refs/tags/git-features-v0.3.0^{}", "d5f78373a75de13ef3c08eedf03e616b2ec395f2 refs/tags/git-features-v0.4.0", "9d6b8790e2edd7fa01b3239adff86a7cd2393f10 refs/tags/git-features-v0.4.0^{}", "be64896ed543437b67e939c36ecd70945e100d6c refs/tags/git-object-v0.1.0", "5688a3427ff3673e1422d43106f4d685fa837aed refs/tags/git-object-v0.1.0^{}", "7b34dc75ac5010741c0675d8c3a9645adb9b2ee1 refs/tags/git-object-v0.3.0", "e8df6c1ffb7afa27aff9abbe11c7e4b80d19b61e refs/tags/git-object-v0.3.0^{}", "2249ae57005b7c5ff94409bbe0e3213cbfd1745f refs/tags/git-odb-v0.1.0", "2b80181ad428a9bf267a9660886f347a850fc76f refs/tags/git-odb-v0.1.0^{}", "a9bb4d08a8c159d2444615ce9f9bc68f40fe98b1 refs/tags/git-odb-v0.3.0", "e8df6c1ffb7afa27aff9abbe11c7e4b80d19b61e refs/tags/git-odb-v0.3.0^{}", "d5d9eabaa9f190e535771c8dcc9fd1bcf69b7947 refs/tags/git-packetline-v0.1.0", "9d6b8790e2edd7fa01b3239adff86a7cd2393f10 refs/tags/git-packetline-v0.1.0^{}", "defd2a7783ab4618f41c270477921aa2336693db refs/tags/git-protocol-v0.0.0", "14615143dc170217ca4acc80191f4e6725dc460a refs/tags/git-protocol-v0.0.0^{}", "7e168eef62b8ad6ddd49e4e50d500761b84cfb4f refs/tags/git-ref-v0.1.0", "e66c9ed041c7ebede869e899ecd4398fee47028b refs/tags/git-ref-v0.1.0^{}", "fde229329d5d4540d21a04dcaf8cfb13a1e8a8c5 refs/tags/git-ref-v0.2.0", "d350a13784685ea82b84646b18736986aeb68146 refs/tags/git-ref-v0.2.0^{}", "4f75945daf9e0a669b694b0652c5a7e8a6dd2246 refs/tags/git-ref-v0.3.0", "e8df6c1ffb7afa27aff9abbe11c7e4b80d19b61e refs/tags/git-ref-v0.3.0^{}", "058e7f3f554f37f05cc9aaf0c86b4bbe8bea9242 refs/tags/git-repository-v0.1.0", "2b80181ad428a9bf267a9660886f347a850fc76f refs/tags/git-repository-v0.1.0^{}", "74b85f2bc7a9bcdd59218ee54135d5dd3a8dbd72 refs/tags/git-repository-v0.3.0", "e8df6c1ffb7afa27aff9abbe11c7e4b80d19b61e refs/tags/git-repository-v0.3.0^{}", "40046d9f4ab51a8895e8de8a3ed4e213d87f042e refs/tags/git-transport-v0.0.0", "19e7fec7deb5a6419f36a2732c90006377414181 refs/tags/git-transport-v0.0.0^{}", "64bdbb4ef5415d4cfb088fbbdc8f5f6dca37aeca refs/tags/git-tui-v0.0.0", "a0b73afdd1df9b1096f0c6fe388f795a6dfe7f33 refs/tags/git-tui-v0.0.0^{}", "320c79b59068fc5f0fc11d331de7352bb1952f10 refs/tags/git-url-v0.0.0", "fd2e5bab97f09666c983634fa89947a4bed1c92d refs/tags/git-url-v0.0.0^{}", "58cbf2153987f6f4e91bd58074a1dd648f30f932 refs/tags/gitoxide-core-v0.1.0", "19e7fec7deb5a6419f36a2732c90006377414181 refs/tags/gitoxide-core-v0.1.0^{}", "640ce76991e36035af707ec4f9afc550cc33cb58 refs/tags/gitoxide-core-v0.3.0", "e8df6c1ffb7afa27aff9abbe11c7e4b80d19b61e refs/tags/gitoxide-core-v0.3.0^{}", "df1d23e4e6c489a74ab6c6845de49e54fe5a8f4d refs/tags/v0.1.0", "19e7fec7deb5a6419f36a2732c90006377414181 refs/tags/v0.1.0^{}", "7443892cb6b7925d98687903ab6d7ee0bdd1e9cf refs/tags/v0.3.0", "e8df6c1ffb7afa27aff9abbe11c7e4b80d19b61e refs/tags/v0.3.0^{}" ] ); c.close()?; assert_eq!( server.received_as_string().lines().collect::<Vec<_>>(), format!( "GET /path/not/important/due/to/mock/info/refs?service=git-upload-pack HTTP/1.1Host: 127.0.0.1:{}Accept: */*User-Agent: git/oxide-{} ", server.addr.port(), env!("CARGO_PKG_VERSION") ) .lines() .collect::<Vec<_>>() ); Ok(())} #[test]fn clone_v1() -> crate::Result { let (server, mut c) = mock::serve_and_connect( "v1/http-handshake.response", "path/not/important/due/to/mock", Protocol::V1, )?; let SetServiceResponse { refs, .. } = c.handshake(Service::UploadPack)?; io::copy(&mut refs.expect("refs in protocol V1"), &mut io::sink())?; server.ignore_this_result(); server.next_read_and_respond_with(fixture_bytes("v1/http-clone.response")); let mut writer = c.request( client::WriteMode::OneLfTerminatedLinePerWriteCall, client::MessageKind::Text(b"done"), )?; writer.write_all(b"hello")?; writer.write_all(b"world")?; let mut reader = writer.into_read()?; let mut line = String::new(); reader.read_line(&mut line)?; assert_eq!(line, "NAK\n", "we receive a NAK in text mode before the PACK is sent"); let messages = Rc::new(RefCell::new(Vec::<String>::new())); reader.set_progress_handler(Some(Box::new({ let sb = messages.clone(); move |is_err, data| { assert!(!is_err); sb.deref() .borrow_mut() .push(std::str::from_utf8(data).expect("valid utf8").to_owned()) } }))); let mut pack = Vec::new(); reader.read_to_end(&mut pack)?; assert_eq!(pack.len(), 876, "we receive the whole pack…"); drop(reader); let sidebands = Rc::try_unwrap(messages).expect("no other handle").into_inner(); assert_eq!(sidebands.len(), 3); assert_eq!( server.received_as_string().lines().collect::<Vec<_>>(), format!( "POST /path/not/important/due/to/mock/git-upload-pack HTTP/1.1Host: 127.0.0.1:{}Transfer-Encoding: chunkedUser-Agent: git/oxide-{}Content-Type: application/x-git-upload-pack-requestAccept: application/x-git-upload-pack-result 1d000ahello000aworld0009done 0 ", server.addr.port(), env!("CARGO_PKG_VERSION") ) .lines() .collect::<Vec<_>>() ); Ok(())} #[test]fn handshake_and_lsrefs_and_fetch_v2() -> crate::Result { let (server, mut c) = mock::serve_and_connect( "v2/http-handshake.response", "path/not/important/due/to/mock", Protocol::V2, )?; assert!(!c.is_stateful(), "http connections are never stateful"); let SetServiceResponse { actual_protocol, capabilities, refs, } = c.handshake(Service::UploadPack)?; assert_eq!(actual_protocol, Protocol::V2); assert!( refs.is_none(), "refs are only returned in V1, as V2 favors a separate command (with more options)" ); assert_eq!( capabilities .iter() .map(|v| { ( v.name().to_owned(), v.values().map(|v| v.map(ToOwned::to_owned).collect::<Vec<_>>()), ) }) .collect::<Vec<_>>(), [ ("agent", Some(&["git/github-gdf51a71f0236"][..])), ("ls-refs", None), ("fetch", Some(&["shallow", "filter"])), ("server-option", None) ] .iter() .map(|(k, v)| ( k.as_bytes().into(), v.map(|v| v.iter().map(|v| v.as_bytes().into()).collect::<Vec<_>>()) )) .collect::<Vec<_>>() ); assert_eq!( server.received_as_string().lines().collect::<Vec<_>>(), format!( "GET /path/not/important/due/to/mock/info/refs?service=git-upload-pack HTTP/1.1Host: 127.0.0.1:{}Accept: */*User-Agent: git/oxide-{}Git-Protocol: version=2 ", server.addr.port(), env!("CARGO_PKG_VERSION") ) .lines() .collect::<Vec<_>>() ); server.next_read_and_respond_with(fixture_bytes("v2/http-lsrefs.response")); drop(refs); let res = c.invoke( "ls-refs", [("without-value", None), ("with-value", Some("value"))].iter().cloned(), Some(vec!["arg1".as_bytes().as_bstr().to_owned()]), )?; assert_eq!( res.lines().collect::<Result<Vec<_>, _>>()?, vec![ "808e50d724f604f69ab93c6da2919c014667bedb HEAD symref-target:refs/heads/master", "808e50d724f604f69ab93c6da2919c014667bedb refs/heads/master" ] ); assert_eq!( server.received_as_string().lines().collect::<Vec<_>>(), format!( "POST /path/not/important/due/to/mock/git-upload-pack HTTP/1.1Host: 127.0.0.1:{}Transfer-Encoding: chunkedUser-Agent: git/oxide-{}Content-Type: application/x-git-upload-pack-requestAccept: application/x-git-upload-pack-resultGit-Protocol: version=2 4c0014command=ls-refs0012without-value0015with-value=value00010009arg100000 ", server.addr.port(), env!("CARGO_PKG_VERSION") ) .lines() .collect::<Vec<_>>() ); server.next_read_and_respond_with(fixture_bytes("v2/http-fetch.response")); let mut res = c.invoke("fetch", Vec::new(), None::<Vec<bstr::BString>>)?; let mut line = String::new(); res.read_line(&mut line)?; assert_eq!(line, "packfile\n"); let messages = Rc::new(RefCell::new(Vec::<String>::new())); res.set_progress_handler(Some(Box::new({ let sb = messages.clone(); move |is_err, data| { assert!(!is_err); sb.deref() .borrow_mut() .push(std::str::from_utf8(data).expect("valid utf8").to_owned()) } }))); let mut pack = Vec::new(); res.read_to_end(&mut pack)?; assert_eq!(pack.len(), 876); drop(res); let messages = Rc::try_unwrap(messages).expect("no other handle").into_inner(); assert_eq!(messages.len(), 5); c.close()?; assert_eq!( server.received_as_string().lines().collect::<Vec<_>>(), format!( "POST /path/not/important/due/to/mock/git-upload-pack HTTP/1.1Host: 127.0.0.1:{}Transfer-Encoding: chunkedUser-Agent: git/oxide-{}Content-Type: application/x-git-upload-pack-requestAccept: application/x-git-upload-pack-resultGit-Protocol: version=2 160012command=fetch00000 ", server.addr.port(), env!("CARGO_PKG_VERSION") ) .lines() .collect::<Vec<_>>() ); Ok(())}
use crate::fixture_bytes;
use bstr::ByteSlice;
use git_transport::client::Identity;
use git_transport::{
client::{self, http, SetServiceResponse, Transport, TransportV2Ext},
Protocol, Service,
};
use std::{
cell::RefCell,
error::Error,
io::{self, BufRead, Read, Write},
ops::Deref,
rc::Rc,
};
mod mock;
fn assert_error_status(
status: usize,
kind: std::io::ErrorKind,
) -> Result<(mock::Server, http::Transport<http::Impl>), crate::Error> {
let (server, mut client) =
mock::serve_and_connect(&format!("http-{}.response", status), "path/not-important", Protocol::V1)?;
let error = client
.handshake(Service::UploadPack)
.err()
.expect("non-200 status causes error");
let error = error
.source()
.expect("source")
.downcast_ref::<std::io::Error>()
.expect("io error as source");
assert_eq!(error.kind(), kind);
assert_eq!(error.to_string(), format!("Received HTTP status {}", status));
drop(server.received());
Ok((server, client))
}
#[test]
fn http_authentication_error_can_be_differentiated_and_identity_is_transmitted() -> crate::Result {
let (server, mut client) = assert_error_status(401, std::io::ErrorKind::PermissionDenied)?;
server.next_read_and_respond_with(fixture_bytes("v1/http-handshake.response"));
client.set_identity(Identity::Account {
username: "user".into(),
password: "password".into(),
})?;
client.handshake(Service::UploadPack)?;
assert_eq!(
server.received_as_string().lines().collect::<Vec<_>>(),
format!(
"GET /path/not-important/info/refs?service=git-upload-pack HTTP/1.1
Host: 127.0.0.1:{}
Accept: */*
User-Agent: git/oxide-{}
Authorization: Basic dXNlcjpwYXNzd29yZA==
",
server.addr.port(),
env!("CARGO_PKG_VERSION")
)
.lines()
.collect::<Vec<_>>()
);
server.next_read_and_respond_with(fixture_bytes("v1/http-handshake.response"));
client.request(client::WriteMode::Binary, client::MessageKind::Flush)?;
assert_eq!(
server.received_as_string().lines().collect::<Vec<_>>(),
format!(
"POST /path/not-important/git-upload-pack HTTP/1.1
Host: 127.0.0.1:{}
Transfer-Encoding: chunked
User-Agent: git/oxide-{}
Content-Type: application/x-git-upload-pack-request
Accept: application/x-git-upload-pack-result
Authorization: Basic dXNlcjpwYXNzd29yZA==
0
",
server.addr.port(),
env!("CARGO_PKG_VERSION")
)
.lines()
.collect::<Vec<_>>(),
"the authentication information is used in subsequent calls"
);
Ok(())
}
#[test]
fn http_error_results_in_observable_error() -> crate::Result {
assert_error_status(404, std::io::ErrorKind::Other)?;
Ok(())
}
#[test]
fn handshake_v1() -> crate::Result {
let (server, mut c) = mock::serve_and_connect(
"v1/http-handshake.response",
"path/not/important/due/to/mock",
Protocol::V1,
)?;
assert!(!c.is_stateful(), "http connections are never stateful");
let SetServiceResponse {
actual_protocol,
capabilities,
refs,
} = c.handshake(Service::UploadPack)?;
assert_eq!(actual_protocol, Protocol::V1);
assert_eq!(
capabilities
.iter()
.map(|c| (c.name().to_owned(), c.value().map(ToOwned::to_owned)))
.collect::<Vec<_>>(),
[
("multi_ack", None),
("thin-pack", None),
("side-band", None),
("side-band-64k", None),
("ofs-delta", None),
("shallow", None),
("deepen-since", None),
("deepen-not", None),
("deepen-relative", None),
("no-progress", None),
("include-tag", None),
("multi_ack_detailed", None),
("allow-tip-sha1-in-want", None),
("allow-reachable-sha1-in-want", None),
("no-done", None),
("symref", Some("HEAD:refs/heads/main")),
("filter", None),
("agent", Some("git/github-gdf51a71f0236"))
]
.iter()
.map(|(n, v)| (
n.as_bytes().as_bstr().to_owned(),
v.map(|v| v.as_bytes().as_bstr().to_owned())
))
.collect::<Vec<_>>()
);
let refs = refs
.expect("v1 protocol provides refs")
.lines()
.flat_map(Result::ok)
.collect::<Vec<_>>();
assert_eq!(
refs,
vec![
"73a6868963993a3328e7d8fe94e5a6ac5078a944 HEAD",
"73a6868963993a3328e7d8fe94e5a6ac5078a944 refs/heads/main",
"8e472f9ccc7d745927426cbb2d9d077de545aa4e refs/pull/13/head",
"1a33becbfa6aaf7661824ce40016acb8c179f13c refs/pull/14/head",
"add2e3e8d155571154c8816cf57f473a6e4d8d31 refs/pull/2/head",
"dce0ea858eef7ff61ad345cc5cdac62203fb3c10 refs/tags/git-commitgraph-v0.0.0",
"21c9b7500cb144b3169a6537961ec2b9e865be81 refs/tags/git-commitgraph-v0.0.0^{}",
"7ba6656568da186d153d66f26990b9b364ea9609 refs/tags/git-features-v0.1.0",
"5688a3427ff3673e1422d43106f4d685fa837aed refs/tags/git-features-v0.1.0^{}",
"92945a59059bf044744639673f1a0f5b314762ee refs/tags/git-features-v0.2.0",
"0bb831480d8657e1bb29ee7009aeac673471403e refs/tags/git-features-v0.2.0^{}",
"97e1d77270a8f9cbff19baf3803de8b4f5a339bf refs/tags/git-features-v0.3.0",
"4351e2871c9dcf342b8471fffa74cae338a53269 refs/tags/git-features-v0.3.0^{}",
"d5f78373a75de13ef3c08eedf03e616b2ec395f2 refs/tags/git-features-v0.4.0",
"9d6b8790e2edd7fa01b3239adff86a7cd2393f10 refs/tags/git-features-v0.4.0^{}",
"be64896ed543437b67e939c36ecd70945e100d6c refs/tags/git-object-v0.1.0",
"5688a3427ff3673e1422d43106f4d685fa837aed refs/tags/git-object-v0.1.0^{}",
"7b34dc75ac5010741c0675d8c3a9645adb9b2ee1 refs/tags/git-object-v0.3.0",
"e8df6c1ffb7afa27aff9abbe11c7e4b80d19b61e refs/tags/git-object-v0.3.0^{}",
"2249ae57005b7c5ff94409bbe0e3213cbfd1745f refs/tags/git-odb-v0.1.0",
"2b80181ad428a9bf267a9660886f347a850fc76f refs/tags/git-odb-v0.1.0^{}",
"a9bb4d08a8c159d2444615ce9f9bc68f40fe98b1 refs/tags/git-odb-v0.3.0",
"e8df6c1ffb7afa27aff9abbe11c7e4b80d19b61e refs/tags/git-odb-v0.3.0^{}",
"d5d9eabaa9f190e535771c8dcc9fd1bcf69b7947 refs/tags/git-packetline-v0.1.0",
"9d6b8790e2edd7fa01b3239adff86a7cd2393f10 refs/tags/git-packetline-v0.1.0^{}",
"defd2a7783ab4618f41c270477921aa2336693db refs/tags/git-protocol-v0.0.0",
"14615143dc170217ca4acc80191f4e6725dc460a refs/tags/git-protocol-v0.0.0^{}",
"7e168eef62b8ad6ddd49e4e50d500761b84cfb4f refs/tags/git-ref-v0.1.0",
"e66c9ed041c7ebede869e899ecd4398fee47028b refs/tags/git-ref-v0.1.0^{}",
"fde229329d5d4540d21a04dcaf8cfb13a1e8a8c5 refs/tags/git-ref-v0.2.0",
"d350a13784685ea82b84646b18736986aeb68146 refs/tags/git-ref-v0.2.0^{}",
"4f75945daf9e0a669b694b0652c5a7e8a6dd2246 refs/tags/git-ref-v0.3.0",
"e8df6c1ffb7afa27aff9abbe11c7e4b80d19b61e refs/tags/git-ref-v0.3.0^{}",
"058e7f3f554f37f05cc9aaf0c86b4bbe8bea9242 refs/tags/git-repository-v0.1.0",
"2b80181ad428a9bf267a9660886f347a850fc76f refs/tags/git-repository-v0.1.0^{}",
"74b85f2bc7a9bcdd59218ee54135d5dd3a8dbd72 refs/tags/git-repository-v0.3.0",
"e8df6c1ffb7afa27aff9abbe11c7e4b80d19b61e refs/tags/git-repository-v0.3.0^{}",
"40046d9f4ab51a8895e8de8a3ed4e213d87f042e refs/tags/git-transport-v0.0.0",
"19e7fec7deb5a6419f36a2732c90006377414181 refs/tags/git-transport-v0.0.0^{}",
"64bdbb4ef5415d4cfb088fbbdc8f5f6dca37aeca refs/tags/git-tui-v0.0.0",
"a0b73afdd1df9b1096f0c6fe388f795a6dfe7f33 refs/tags/git-tui-v0.0.0^{}",
"320c79b59068fc5f0fc11d331de7352bb1952f10 refs/tags/git-url-v0.0.0",
"fd2e5bab97f09666c983634fa89947a4bed1c92d refs/tags/git-url-v0.0.0^{}",
"58cbf2153987f6f4e91bd58074a1dd648f30f932 refs/tags/gitoxide-core-v0.1.0",
"19e7fec7deb5a6419f36a2732c90006377414181 refs/tags/gitoxide-core-v0.1.0^{}",
"640ce76991e36035af707ec4f9afc550cc33cb58 refs/tags/gitoxide-core-v0.3.0",
"e8df6c1ffb7afa27aff9abbe11c7e4b80d19b61e refs/tags/gitoxide-core-v0.3.0^{}",
"df1d23e4e6c489a74ab6c6845de49e54fe5a8f4d refs/tags/v0.1.0",
"19e7fec7deb5a6419f36a2732c90006377414181 refs/tags/v0.1.0^{}",
"7443892cb6b7925d98687903ab6d7ee0bdd1e9cf refs/tags/v0.3.0",
"e8df6c1ffb7afa27aff9abbe11c7e4b80d19b61e refs/tags/v0.3.0^{}"
]
);
c.close()?;
assert_eq!(
server.received_as_string().lines().collect::<Vec<_>>(),
format!(
"GET /path/not/important/due/to/mock/info/refs?service=git-upload-pack HTTP/1.1
Host: 127.0.0.1:{}
Accept: */*
User-Agent: git/oxide-{}
",
server.addr.port(),
env!("CARGO_PKG_VERSION")
)
.lines()
.collect::<Vec<_>>()
);
Ok(())
}
#[test]
fn clone_v1() -> crate::Result {
let (server, mut c) = mock::serve_and_connect(
"v1/http-handshake.response",
"path/not/important/due/to/mock",
Protocol::V1,
)?;
let SetServiceResponse { refs, .. } = c.handshake(Service::UploadPack)?;
io::copy(&mut refs.expect("refs in protocol V1"), &mut io::sink())?;
server.ignore_this_result();
server.next_read_and_respond_with(fixture_bytes("v1/http-clone.response"));
let mut writer = c.request(
client::WriteMode::OneLfTerminatedLinePerWriteCall,
client::MessageKind::Text(b"done"),
)?;
writer.write_all(b"hello")?;
writer.write_all(b"world")?;
let mut reader = writer.into_read()?;
let mut line = String::new();
reader.read_line(&mut line)?;
assert_eq!(line, "NAK\n", "we receive a NAK in text mode before the PACK is sent");
let messages = Rc::new(RefCell::new(Vec::<String>::new()));
reader.set_progress_handler(Some(Box::new({
let sb = messages.clone();
move |is_err, data| {
assert!(!is_err);
sb.deref()
.borrow_mut()
.push(std::str::from_utf8(data).expect("valid utf8").to_owned())
}
})));
let mut pack = Vec::new();
reader.read_to_end(&mut pack)?;
assert_eq!(pack.len(), 876, "we receive the whole pack…");
drop(reader);
let sidebands = Rc::try_unwrap(messages).expect("no other handle").into_inner();
assert_eq!(sidebands.len(), 3);
assert_eq!(
server.received_as_string().lines().collect::<Vec<_>>(),
format!(
"POST /path/not/important/due/to/mock/git-upload-pack HTTP/1.1
Host: 127.0.0.1:{}
Transfer-Encoding: chunked
User-Agent: git/oxide-{}
Content-Type: application/x-git-upload-pack-request
Accept: application/x-git-upload-pack-result
1d
000ahello
000aworld
0009done
0
",
server.addr.port(),
env!("CARGO_PKG_VERSION")
)
.lines()
.collect::<Vec<_>>()
);
Ok(())
}
#[test]
fn handshake_and_lsrefs_and_fetch_v2() -> crate::Result {
let (server, mut c) = mock::serve_and_connect(
"v2/http-handshake.response",
"path/not/important/due/to/mock",
Protocol::V2,
)?;
assert!(!c.is_stateful(), "http connections are never stateful");
let SetServiceResponse {
actual_protocol,
capabilities,
refs,
} = c.handshake(Service::UploadPack)?;
assert_eq!(actual_protocol, Protocol::V2);
assert!(
refs.is_none(),
"refs are only returned in V1, as V2 favors a separate command (with more options)"
);
assert_eq!(
capabilities
.iter()
.map(|v| {
(
v.name().to_owned(),
v.values().map(|v| v.map(ToOwned::to_owned).collect::<Vec<_>>()),
)
})
.collect::<Vec<_>>(),
[
("agent", Some(&["git/github-gdf51a71f0236"][..])),
("ls-refs", None),
("fetch", Some(&["shallow", "filter"])),
("server-option", None)
]
.iter()
.map(|(k, v)| (
k.as_bytes().into(),
v.map(|v| v.iter().map(|v| v.as_bytes().into()).collect::<Vec<_>>())
))
.collect::<Vec<_>>()
);
assert_eq!(
server.received_as_string().lines().collect::<Vec<_>>(),
format!(
"GET /path/not/important/due/to/mock/info/refs?service=git-upload-pack HTTP/1.1
Host: 127.0.0.1:{}
Accept: */*
User-Agent: git/oxide-{}
Git-Protocol: version=2
",
server.addr.port(),
env!("CARGO_PKG_VERSION")
)
.lines()
.collect::<Vec<_>>()
);
server.next_read_and_respond_with(fixture_bytes("v2/http-lsrefs.response"));
drop(refs);
let res = c.invoke(
"ls-refs",
[("without-value", None), ("with-value", Some("value"))].iter().cloned(),
Some(vec!["arg1".as_bytes().as_bstr().to_owned()]),
)?;
assert_eq!(
res.lines().collect::<Result<Vec<_>, _>>()?,
vec![
"808e50d724f604f69ab93c6da2919c014667bedb HEAD symref-target:refs/heads/master",
"808e50d724f604f69ab93c6da2919c014667bedb refs/heads/master"
]
);
assert_eq!(
server.received_as_string().lines().collect::<Vec<_>>(),
format!(
"POST /path/not/important/due/to/mock/git-upload-pack HTTP/1.1
Host: 127.0.0.1:{}
Transfer-Encoding: chunked
User-Agent: git/oxide-{}
Content-Type: application/x-git-upload-pack-request
Accept: application/x-git-upload-pack-result
Git-Protocol: version=2
4c
0014command=ls-refs
0012without-value
0015with-value=value
00010009arg1
0000
0
",
server.addr.port(),
env!("CARGO_PKG_VERSION")
)
.lines()
.collect::<Vec<_>>()
);
server.next_read_and_respond_with(fixture_bytes("v2/http-fetch.response"));
let mut res = c.invoke("fetch", Vec::new(), None::<Vec<bstr::BString>>)?;
let mut line = String::new();
res.read_line(&mut line)?;
assert_eq!(line, "packfile\n");
let messages = Rc::new(RefCell::new(Vec::<String>::new()));
res.set_progress_handler(Some(Box::new({
let sb = messages.clone();
move |is_err, data| {
assert!(!is_err);
sb.deref()
.borrow_mut()
.push(std::str::from_utf8(data).expect("valid utf8").to_owned())
}
})));
let mut pack = Vec::new();
res.read_to_end(&mut pack)?;
assert_eq!(pack.len(), 876);
drop(res);
let messages = Rc::try_unwrap(messages).expect("no other handle").into_inner();
assert_eq!(messages.len(), 5);
c.close()?;
assert_eq!(
server.received_as_string().lines().collect::<Vec<_>>(),
format!(
"POST /path/not/important/due/to/mock/git-upload-pack HTTP/1.1
Host: 127.0.0.1:{}
Transfer-Encoding: chunked
User-Agent: git/oxide-{}
Content-Type: application/x-git-upload-pack-request
Accept: application/x-git-upload-pack-result
Git-Protocol: version=2
16
0012command=fetch
0000
0
",
server.addr.port(),
env!("CARGO_PKG_VERSION")
)
.lines()
.collect::<Vec<_>>()
);
Ok(())
}