diff --git a/src/main.rs b/src/main.rs index 32836ce..200a185 100644 --- a/src/main.rs +++ b/src/main.rs @@ -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::>() - // ) - // }) - // .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::>() + ) + }) + .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) })); } diff --git a/src/minio.rs b/src/minio.rs index e1d6f85..16a97d5 100644 --- a/src/minio.rs +++ b/src/minio.rs @@ -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) }