Error if Remote Ignores HTTP Range Header

object_store/src/http/client.rs

@@ -37,6 +37,9 @@ enum Error {
     #[snafu(display("Request error: {}", source))]
     Reqwest { source: reqwest::Error },
 
+    #[snafu(display("Range request not supported by {}", href))]
+    RangeNotSupported { href: String },
+
     #[snafu(display("Error decoding PROPFIND response: {}", source))]
     InvalidPropFind { source: quick_xml::de::DeError },
 
@@ -238,8 +241,9 @@ impl Client {
     pub async fn get(&self, location: &Path, options: GetOptions) -> Result<Response> {
         let url = self.path_url(location);
         let builder = self.client.get(url);
+        let has_range = options.range.is_some();
 
-        builder
+        let res = builder
             .with_get_options(options)
             .send_retry(&self.retry_config)
             .await
@@ -252,7 +256,20 @@ impl Client {
                     }
                 }
                 _ => Error::Request { source }.into(),
-            })
+            })?;
+
+        // We expect a 206 Partial Content response if a range was requested
+        // a 200 OK response would indicate the server did not fulfill the request
+        if has_range && res.status() == StatusCode::OK {
+            return Err(crate::Error::Generic {
+                store: "HTTP",
+                source: Box::new(Error::RangeNotSupported {
+                    href: location.to_string(),
+                }),
+            });
+        }
+
+        Ok(res)
     }
 
     pub async fn copy(&self, from: &Path, to: &Path, overwrite: bool) -> Result<()> {