Influxdata
/
influxdb
mirror of https://github.com/influxdata/influxdb.git
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

test: Update tests to match new cloud storage error behavior

pull/24376/head
Carol (Nichols || Goulding) 2021-02-17 14:21:04 -05:00
parent ef54131afb
commit f934a21efe
1 changed files with 25 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

35
object_store/src/gcp.rs
View File

@ -306,15 +306,22 @@ mod test {
let mut location = integration.new_path();
location.set_file_name(NON_EXISTENT_NAME);
let result = get_nonexistent_object(&integration, Some(location)).await?;
let err = get_nonexistent_object(&integration, Some(location))
.await
.unwrap_err();
assert_eq!(
result,
Bytes::from(format!(
"No such object: {}/{}",
bucket_name, NON_EXISTENT_NAME
))
);
if let Some(Error::UnableToGetData {
source,
bucket,
location,
}) = err.downcast_ref::<Error>()
{
assert!(matches!(source, cloud_storage::Error::Reqwest(_)));
assert_eq!(bucket, &bucket_name);
assert_eq!(location, NON_EXISTENT_NAME);
} else {
panic!("unexpected error type")
}
Ok(())
}
@ -327,9 +334,17 @@ mod test {
let mut location = integration.new_path();
location.set_file_name(NON_EXISTENT_NAME);
let result = get_nonexistent_object(&integration, Some(location)).await?;
let err = get_nonexistent_object(&integration, Some(location))
.await
.unwrap_err();
assert_eq!(result, Bytes::from("Not Found"));
if let Some(Error::UnableToStreamListData { source, bucket }) = err.downcast_ref::<Error>()
{
assert!(matches!(source, cloud_storage::Error::Google(_)));
assert_eq!(bucket, bucket_name);
} else {
panic!("unexpected error type")
}
Ok(())
}