Revert "Add ObjectMeta::version and GetOptions::version (#4925) (apache#4935)"

This reverts commit f4a2a88.

Author: jacksonrnewhouse

object_store/src/aws/client.rs

@@ -20,7 +20,6 @@ use crate::aws::credential::{AwsCredential, CredentialExt};
 use crate::aws::{AwsCredentialProvider, S3CopyIfNotExists, STORE, STRICT_PATH_ENCODE_SET};
 use crate::client::get::GetClient;
 use crate::client::header::get_etag;
-use crate::client::header::HeaderConfig;
 use crate::client::list::ListClient;
 use crate::client::list_response::ListResponse;
 use crate::client::retry::RetryExt;
@@ -550,12 +549,6 @@ impl S3Client {
 impl GetClient for S3Client {
     const STORE: &'static str = STORE;
 
-    const HEADER_CONFIG: HeaderConfig = HeaderConfig {
-        etag_required: false,
-        last_modified_required: false,
-        version_header: Some("x-amz-version-id"),
-    };
-
     /// Make an S3 GET request <https://docs.aws.amazon.com/AmazonS3/latest/API/API_GetObject.html>
     async fn get_request(&self, path: &Path, options: GetOptions) -> Result<Response> {
         let credential = self.get_credential().await?;
@@ -565,11 +558,7 @@ impl GetClient for S3Client {
             false => Method::GET,
         };
 
-        let mut builder = self.client.request(method, url);
-
-        if let Some(v) = &options.version {
-            builder = builder.query(&[("versionId", v)])
-        }
+        let builder = self.client.request(method, url);
 
         let response = builder
             .with_get_options(options)

object_store/src/azure/client.rs

@@ -19,7 +19,6 @@ use super::credential::AzureCredential;
 use crate::azure::credential::*;
 use crate::azure::{AzureCredentialProvider, STORE};
 use crate::client::get::GetClient;
-use crate::client::header::HeaderConfig;
 use crate::client::list::ListClient;
 use crate::client::retry::RetryExt;
 use crate::client::GetOptionsExt;
@@ -255,12 +254,6 @@ impl AzureClient {
 impl GetClient for AzureClient {
     const STORE: &'static str = STORE;
 
-    const HEADER_CONFIG: HeaderConfig = HeaderConfig {
-        etag_required: true,
-        last_modified_required: true,
-        version_header: Some("x-ms-version-id"),
-    };
-
     /// Make an Azure GET request
     /// <https://docs.microsoft.com/en-us/rest/api/storageservices/get-blob>
     /// <https://docs.microsoft.com/en-us/rest/api/storageservices/get-blob-properties>
@@ -272,16 +265,12 @@ impl GetClient for AzureClient {
             false => Method::GET,
         };
 
-        let mut builder = self
+        let builder = self
             .client
             .request(method, url)
             .header(CONTENT_LENGTH, HeaderValue::from_static("0"))
             .body(Bytes::new());
 
-        if let Some(v) = &options.version {
-            builder = builder.query(&[("versionid", v)])
-        }
-
         let response = builder
             .with_get_options(options)
             .with_azure_authorization(&credential, &self.config.account)
@@ -438,7 +427,6 @@ impl TryFrom<Blob> for ObjectMeta {
             last_modified: value.properties.last_modified,
             size: value.properties.content_length as usize,
             e_tag: value.properties.e_tag,
-            version: None, // For consistency with S3 and GCP which don't include this
         })
     }
 }

object_store/src/client/get.rs

@@ -29,7 +29,10 @@ pub trait GetClient: Send + Sync + 'static {
     const STORE: &'static str;
 
     /// Configure the [`HeaderConfig`] for this client
-    const HEADER_CONFIG: HeaderConfig;
+    const HEADER_CONFIG: HeaderConfig = HeaderConfig {
+        etag_required: true,
+        last_modified_required: true,
+    };
 
     async fn get_request(&self, path: &Path, options: GetOptions) -> Result<Response>;
 }

object_store/src/client/header.rs

@@ -35,9 +35,6 @@ pub struct HeaderConfig {
     ///
     /// Defaults to `true`
     pub last_modified_required: bool,
-
-    /// The version header name if any
-    pub version_header: Option<&'static str>,
 }
 
 #[derive(Debug, Snafu)]
@@ -101,20 +98,14 @@ pub fn header_meta(
         .context(MissingContentLengthSnafu)?;
 
     let content_length = content_length.to_str().context(BadHeaderSnafu)?;
-    let size = content_length
+    let content_length = content_length
         .parse()
         .context(InvalidContentLengthSnafu { content_length })?;
 
-    let version = match cfg.version_header.and_then(|h| headers.get(h)) {
-        Some(v) => Some(v.to_str().context(BadHeaderSnafu)?.to_string()),
-        None => None,
-    };
-
     Ok(ObjectMeta {
         location: location.clone(),
         last_modified,
-        version,
-        size,
+        size: content_length,
         e_tag,
     })
 }

object_store/src/client/list_response.rs

@@ -80,7 +80,6 @@ impl TryFrom<ListContents> for ObjectMeta {
             last_modified: value.last_modified,
             size: value.size,
             e_tag: value.e_tag,
-            version: None,
         })
     }
 }

object_store/src/gcp/client.rs

@@ -16,7 +16,7 @@
 // under the License.
 
 use crate::client::get::GetClient;
-use crate::client::header::{get_etag, HeaderConfig};
+use crate::client::header::get_etag;
 use crate::client::list::ListClient;
 use crate::client::list_response::ListResponse;
 use crate::client::retry::RetryExt;
@@ -333,11 +333,6 @@ impl GoogleCloudStorageClient {
 #[async_trait]
 impl GetClient for GoogleCloudStorageClient {
     const STORE: &'static str = STORE;
-    const HEADER_CONFIG: HeaderConfig = HeaderConfig {
-        etag_required: true,
-        last_modified_required: true,
-        version_header: Some("x-goog-generation"),
-    };
 
     /// Perform a get request <https://cloud.google.com/storage/docs/xml-api/get-object-download>
     async fn get_request(&self, path: &Path, options: GetOptions) -> Result<Response> {

object_store/src/http/client.rs

@@ -277,7 +277,6 @@ impl GetClient for Client {
     const HEADER_CONFIG: HeaderConfig = HeaderConfig {
         etag_required: false,
         last_modified_required: false,
-        version_header: None,
     };
 
     async fn get_request(&self, path: &Path, options: GetOptions) -> Result<Response> {
@@ -376,7 +375,6 @@ impl MultiStatusResponse {
             last_modified,
             size: self.size()?,
             e_tag: self.prop_stat.prop.e_tag.clone(),
-            version: None,
         })
     }
 

object_store/src/lib.rs

@@ -676,8 +676,6 @@ pub struct ObjectMeta {
     ///
     /// <https://datatracker.ietf.org/doc/html/rfc9110#name-etag>
     pub e_tag: Option<String>,
-    /// A version indicator for this object
-    pub version: Option<String>,
 }
 
 /// Options for a get request, such as range
@@ -726,8 +724,6 @@ pub struct GetOptions {
     ///
     /// <https://datatracker.ietf.org/doc/html/rfc9110#name-range>
     pub range: Option<Range<usize>>,
-    /// Request a particular object version
-    pub version: Option<String>,
     /// Request transfer of no content
     ///
     /// <https://datatracker.ietf.org/doc/html/rfc9110#name-head>
@@ -1422,24 +1418,6 @@ mod tests {
         };
         let err = storage.get_opts(&path, options).await.unwrap_err();
         assert!(matches!(err, Error::Precondition { .. }), "{err}");
-
-        if let Some(version) = meta.version {
-            storage.put(&path, "bar".into()).await.unwrap();
-
-            let options = GetOptions {
-                version: Some(version),
-                ..GetOptions::default()
-            };
-
-            // Can retrieve previous version
-            let get_opts = storage.get_opts(&path, options).await.unwrap();
-            let old = get_opts.bytes().await.unwrap();
-            assert_eq!(old, b"foo".as_slice());
-
-            // Current version contains the updated data
-            let current = storage.get(&path).await.unwrap().bytes().await.unwrap();
-            assert_eq!(&current, b"bar".as_slice());
-        }
     }
 
     /// Returns a chunk of length `chunk_length`
@@ -1752,7 +1730,6 @@ mod tests {
             last_modified: Utc.timestamp_nanos(100),
             size: 100,
             e_tag: Some("123".to_string()),
-            version: None,
         };
 
         let mut options = GetOptions::default();

object_store/src/local.rs

@@ -969,7 +969,6 @@ fn convert_metadata(metadata: Metadata, location: Path) -> Result<ObjectMeta> {
         last_modified,
         size,
         e_tag: Some(get_etag(&metadata)),
-        version: None,
     })
 }
 

object_store/src/memory.rs

@@ -166,7 +166,6 @@ impl ObjectStore for InMemory {
             last_modified: entry.last_modified,
             size: entry.data.len(),
             e_tag: Some(e_tag),
-            version: None,
         };
         options.check_preconditions(&meta)?;
 
@@ -213,7 +212,6 @@ impl ObjectStore for InMemory {
             last_modified: entry.last_modified,
             size: entry.data.len(),
             e_tag: Some(entry.e_tag.to_string()),
-            version: None,
         })
     }
 
@@ -243,7 +241,6 @@ impl ObjectStore for InMemory {
                     last_modified: value.last_modified,
                     size: value.data.len(),
                     e_tag: Some(value.e_tag.to_string()),
-                    version: None,
                 })
             })
             .collect();
@@ -288,7 +285,6 @@ impl ObjectStore for InMemory {
                     last_modified: v.last_modified,
                     size: v.data.len(),
                     e_tag: Some(v.e_tag.to_string()),
-                    version: None,
                 };
                 objects.push(object);
             }

object_store/src/prefix.rs

@@ -73,7 +73,6 @@ impl<T: ObjectStore> PrefixStore<T> {
             size: meta.size,
             location: self.strip_prefix(meta.location),
             e_tag: meta.e_tag,
-            version: None,
         }
     }
 }