mirrors/minio-rs
1
0
Fork 0
mirror of https://github.com/minio/minio-rs.git synced 2025-12-06 23:36:52 +08:00
Code Issues Packages Projects Releases Wiki Activity

[CLEAN] tests back to original

Browse Source
This commit is contained in:
grumbach 2020-09-24 13:35:55 +02:00
parent b9b939e8e8
commit 93e5cb1108
2 changed files with 50 additions and 54 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

102
src/main.rs
View File

@ -36,39 +36,29 @@ fn main() {
// let c = get_local_default_server();
let c = minio::Client::get_play_client();
let bucket = "000";
let file = "lulu";
// let region_req = c
// .get_bucket_location(bucket)
// .map(|res| println!("{}", res.to_string()))
// .map_err(|err| println!("{:?}", err));
//
// let del_req = c
// .delete_bucket(bucket)
// .map(|_| println!("Deleted!"))
// .map_err(|err| println!("del err: {:?}", err));
let region_req = c
.get_bucket_location(bucket)
.map(|res| println!("{}", res.to_string()))
.map_err(|err| println!("{:?}", err));
// let buc_exists_req = c
// .bucket_exists(bucket)
// .map(move |e| println!("Bucket {} exists: {}", bucket, e))
// .map_err(|err| println!("exists err: {:?}", err));
//
// let make_bucket_req = c
// .make_bucket(bucket)
// .map(move |_| println!("Bucket {} created", bucket))
// .map_err(move |err| println!("Bucket create for {} failed with {:?}", bucket, err));
//
// let download_req = c
// .get_object_req(bucket, "issue", vec![])
// .and_then(|g| {
// println!("issue: {} {} {:?}", g.object_size, g.etag, g.content_type);
// g.get_object_stream().concat2()
// })
// .map(|c| println!("get obj res: {:?}", c))
// .map_err(|c| println!("err res: {:?}", c));
let del_req = c
.delete_bucket(bucket)
.map(|_| println!("Deleted!"))
.map_err(|err| println!("del err: {:?}", err));
let upload_req = c
.put_object_req(bucket, file, vec![], "ca marche lulu!!".as_bytes().to_vec())
let buc_exists_req = c
.bucket_exists(bucket)
.map(move |e| println!("Bucket {} exists: {}", bucket, e))
.map_err(|err| println!("exists err: {:?}", err));
let make_bucket_req = c
.make_bucket(bucket)
.map(move |_| println!("Bucket {} created", bucket))
.map_err(move |err| println!("Bucket create for {} failed with {:?}", bucket, err));
let download_req = c
.get_object_req(bucket, "issue", vec![])
.and_then(|g| {
println!("issue: {} {} {:?}", g.object_size, g.etag, g.content_type);
g.get_object_stream().concat2()
@ -76,29 +66,37 @@ fn main() {
.map(|c| println!("get obj res: {:?}", c))
.map_err(|c| println!("err res: {:?}", c));
// let list_buckets_req = c
// .list_buckets()
// .map(|buckets| {
// println!(
// "{:?}",
// buckets
// .iter()
// .map(|bucket: &BucketInfo| bucket.name.clone())
// .collect::<Vec<String>>()
// )
// })
// .map_err(|err| println!("{:?}", err));
let upload_req = c
.put_object_req(bucket, "issue", vec![], "object content".as_bytes().to_vec())
.and_then(|g| {
println!("issue: {} {} {:?}", g.object_size, g.etag, g.content_type);
g.get_object_stream().concat2()
})
.map(|c| println!("get obj res: {:?}", c))
.map_err(|c| println!("err res: {:?}", c));
// let list_objects_req = c
// .list_objects(bucket, None, None, None, None)
// .map(|l_obj_resp| println!("{:?} {:?}", l_obj_resp, l_obj_resp.object_infos.len()))
// .map_err(|err| println!("{:?}", err));
let list_buckets_req = c
.list_buckets()
.map(|buckets| {
println!(
"{:?}",
buckets
.iter()
.map(|bucket: &BucketInfo| bucket.name.clone())
.collect::<Vec<String>>()
)
})
.map_err(|err| println!("{:?}", err));
// del_req
// .join2(upload_req)
// .map(|_| ())
// .and_then(|_| list_buckets_req)
// .then(|_| list_objects_req)
upload_req
let list_objects_req = c
.list_objects(bucket, None, None, None, None)
.map(|l_obj_resp| println!("{:?} {:?}", l_obj_resp, l_obj_resp.object_infos.len()))
.map_err(|err| println!("{:?}", err));
del_req
.join5(make_bucket_req, region_req, buc_exists_req, download_req)
.map(|_| ())
.and_then(|_| list_buckets_req)
.then(|_| list_objects_req)
}));
}

2
src/minio.rs
View File

@ -331,8 +331,6 @@ impl Client {
ts: time::now_utc(),
};
println!("BBBBBBBBBODAAAAAAAAAYY: {:?}", Body::from(data.clone()));
self.signed_req_future(s3_req, Ok(Body::from(data)))
.and_then(GetObjectResp::new)
}