Give the ureq host clients that keep templates, a buffer and a key

hosts/ureq/examples/azure_get.rs

@@ -3,6 +3,7 @@
 use std::env;
 use std::io::Write;
 
+use borink_object_storage_proto::ListOptions;
 use borink_object_storage_proto::azure::Container;
 use borink_object_storage_ureq::azure;
 
@@ -12,6 +13,7 @@ fn main() -> Result<(), Box<dyn std::error::Error>> {
     let token = env::var("AZURE_STORAGE_ACCESS_TOKEN")?;
     let key = env::args().nth(1).ok_or("missing object key")?;
     let container = Container::new(&endpoint, &container)?;
-    std::io::stdout().write_all(&azure::get(&container, &token, &key)?)?;
+    let mut blobs = azure::Blobs::new(&container, &token, &ListOptions::default())?;
+    std::io::stdout().write_all(&blobs.get(&key)?)?;
     Ok(())
 }

hosts/ureq/examples/azure_list.rs

@@ -2,9 +2,8 @@
 
 use std::env;
 
-use borink_object_storage_proto::azure as proto;
-use borink_object_storage_proto::azure::{AzureNamespace, Container};
-use borink_object_storage_proto::{Error, ListEntry, ListItem, ListMarker, ListOptions};
+use borink_object_storage_proto::azure::Container;
+use borink_object_storage_proto::{ListEntry, ListItem, ListMarker, ListOptions};
 use borink_object_storage_ureq::azure;
 
 fn main() -> Result<(), Box<dyn std::error::Error>> {
@@ -14,21 +13,12 @@ fn main() -> Result<(), Box<dyn std::error::Error>> {
     let prefix = env::args().nth(1).unwrap_or_default();
     let container = Container::new(&endpoint, &container)?;
 
-    // Every page shares the template: an empty buffer is refused with the
-    // size it needs.
+    // Every page shares the client's list template.
     let options = ListOptions {
         max_results: Some(1000),
         ..ListOptions::default()
     };
-    let prepare = |buf: &mut [u8]| {
-        proto::prepare_list(&container, &token, AzureNamespace::Unknown, &options, buf)
-    };
-    let size = match prepare(&mut []) {
-        Err(Error::Capacity(capacity)) => capacity.required,
-        other => return Err(format!("{other:?}").into()),
-    };
-    let mut bytes = vec![0; size];
-    let template = prepare(&mut bytes)?;
+    let mut blobs = azure::Blobs::new(&container, &token, &options)?;
 
     let mut marker: Option<String> = None;
     let mut body = Vec::new();
@@ -41,7 +31,7 @@ fn main() -> Result<(), Box<dyn std::error::Error>> {
             marker: marker.as_deref().map(ListMarker::Text),
             ..ListItem::new(&prefix)
         };
-        let page = azure::list(&template, &bytes, &item, &mut body, &mut entries)?;
+        let page = blobs.list(&item, &mut body, &mut entries)?;
         for entry in &entries[..page.filled] {
             println!("{}", entry.key);
         }

hosts/ureq/examples/s3_get.rs

@@ -5,6 +5,7 @@
 use std::env;
 use std::io::Write;
 
+use borink_object_storage_proto::ListOptions;
 use borink_object_storage_proto::s3::{Bucket, Service};
 use borink_object_storage_proto::sigv4::Credentials;
 use borink_object_storage_ureq::s3;
@@ -27,6 +28,7 @@ fn main() -> Result<(), Box<dyn std::error::Error>> {
     if let Some(token) = &session_token {
         credentials = credentials.with_session_token(token)?;
     }
-    std::io::stdout().write_all(&s3::get(&bucket, &credentials, &key)?)?;
+    let mut objects = s3::Objects::new(&bucket, credentials, &ListOptions::default())?;
+    std::io::stdout().write_all(&objects.get(&key)?)?;
     Ok(())
 }

hosts/ureq/examples/s3_list.rs

@@ -4,9 +4,9 @@
 
 use std::env;
 
-use borink_object_storage_proto::s3::{self as proto, Bucket, Service};
+use borink_object_storage_proto::s3::{Bucket, Service};
 use borink_object_storage_proto::sigv4::Credentials;
-use borink_object_storage_proto::{Error, ListEntry, ListItem, ListMarker, ListOptions};
+use borink_object_storage_proto::{ListEntry, ListItem, ListMarker, ListOptions};
 use borink_object_storage_ureq::s3;
 
 fn main() -> Result<(), Box<dyn std::error::Error>> {
@@ -28,19 +28,12 @@ fn main() -> Result<(), Box<dyn std::error::Error>> {
         credentials = credentials.with_session_token(token)?;
     }
 
-    // Every page shares the template: an empty buffer is refused with the
-    // size it needs.
+    // Every page shares the client's list template.
     let options = ListOptions {
         max_results: Some(1000),
         ..ListOptions::default()
     };
-    let prepare = |buf: &mut [u8]| proto::prepare_list(&bucket, &credentials, &options, buf);
-    let size = match prepare(&mut []) {
-        Err(Error::Capacity(capacity)) => capacity.required,
-        other => return Err(format!("{other:?}").into()),
-    };
-    let mut bytes = vec![0; size];
-    let template = prepare(&mut bytes)?;
+    let mut objects = s3::Objects::new(&bucket, credentials, &options)?;
 
     let mut marker: Option<String> = None;
     let mut body = Vec::new();
@@ -52,14 +45,7 @@ fn main() -> Result<(), Box<dyn std::error::Error>> {
             marker: marker.as_deref().map(ListMarker::Text),
             ..ListItem::new(&prefix)
         };
-        let page = s3::list(
-            &template,
-            &bytes,
-            &credentials,
-            &item,
-            &mut body,
-            &mut entries,
-        )?;
+        let page = objects.list(&item, &mut body, &mut entries)?;
         for entry in &entries[..page.filled] {
             println!("{}", entry.key);
         }