Skip to content

Commit

Permalink
fmt: let else
Browse files Browse the repository at this point in the history
  • Loading branch information
Nugine committed Jul 2, 2023
1 parent 9982417 commit 50f0034
Show file tree
Hide file tree
Showing 4 changed files with 17 additions and 12 deletions.
2 changes: 1 addition & 1 deletion codegen/src/dto.rs
Original file line number Diff line number Diff line change
Expand Up @@ -556,7 +556,7 @@ fn codegen_builders(rust_types: &RustTypes, ops: &Operations) {
);

for op in ops.values() {
let rust::Type::Struct(ty) = &rust_types[&op.input] else {continue};
let rust::Type::Struct(ty) = &rust_types[&op.input] else { continue };
codegen_struct_builder(ty, rust_types);
g!();
}
Expand Down
2 changes: 1 addition & 1 deletion codegen/src/ops.rs
Original file line number Diff line number Diff line change
Expand Up @@ -671,7 +671,7 @@ impl PathPattern {
}

fn query_patterns(part: &str) -> Vec<(String, String)> {
let Some((_, q)) = part.split_once('?') else{ return Vec::new() };
let Some((_, q)) = part.split_once('?') else { return Vec::new() };
let mut qs: Vec<(String, String)> = serde_urlencoded::from_str(q).unwrap();
qs.retain(|(n, v)| n != "x-id" && v.is_empty().not());
qs
Expand Down
24 changes: 14 additions & 10 deletions crates/s3s/src/http/de.rs
Original file line number Diff line number Diff line change
Expand Up @@ -34,7 +34,7 @@ where
{
let mut iter = req.headers.get_all(name).into_iter();
let Some(val) = iter.next() else { return Err(missing_header(name)) };
let None = iter.next() else { return Err(duplicate_header(name)) } ;
let None = iter.next() else { return Err(duplicate_header(name)) };

T::try_from_header_value(val).map_err(|err| invalid_header(err, name, val))
}
Expand All @@ -46,7 +46,7 @@ where
{
let mut iter = req.headers.get_all(name).into_iter();
let Some(val) = iter.next() else { return Ok(None) };
let None = iter.next() else { return Err(duplicate_header(name)) } ;
let None = iter.next() else { return Err(duplicate_header(name)) };

match T::try_from_header_value(val) {
Ok(ans) => Ok(Some(ans)),
Expand All @@ -57,7 +57,7 @@ where
pub fn parse_opt_header_timestamp(req: &Request, name: &HeaderName, fmt: TimestampFormat) -> S3Result<Option<Timestamp>> {
let mut iter = req.headers.get_all(name).into_iter();
let Some(val) = iter.next() else { return Ok(None) };
let None = iter.next() else { return Err(duplicate_header(name)) } ;
let None = iter.next() else { return Err(duplicate_header(name)) };

let s = val.to_str().map_err(|err| invalid_header(err, name, val))?;
match Timestamp::parse(fmt, s) {
Expand Down Expand Up @@ -102,7 +102,7 @@ where

let mut iter = qs.get_all(name);
let Some(val) = iter.next() else { return Err(missing_query(name)) };
let None = iter.next() else { return Err(duplicate_query(name)) } ;
let None = iter.next() else { return Err(duplicate_query(name)) };

val.parse::<T>().map_err(|err| invalid_query(err, name, val))
}
Expand All @@ -115,7 +115,7 @@ where

let mut iter = qs.get_all(name);
let Some(val) = iter.next() else { return Ok(None) };
let None = iter.next() else { return Err(duplicate_query(name)) } ;
let None = iter.next() else { return Err(duplicate_query(name)) };

Ok(Some(val.parse::<T>().map_err(|err| invalid_query(err, name, val))?))
}
Expand All @@ -125,21 +125,25 @@ pub fn parse_opt_query_timestamp(req: &Request, name: &str, fmt: TimestampFormat

let mut iter = qs.get_all(name);
let Some(val) = iter.next() else { return Ok(None) };
let None = iter.next() else { return Err(duplicate_query(name)) } ;
let None = iter.next() else { return Err(duplicate_query(name)) };

Ok(Some(Timestamp::parse(fmt, val).map_err(|err| invalid_query(err, name, val))?))
}

#[track_caller]
pub fn unwrap_bucket(req: &mut Request) -> String {
let Some(S3Path::Bucket { bucket }) = req.s3ext.s3_path.take() else { panic!("s3 path not found") };
bucket.into()
match req.s3ext.s3_path.take() {
Some(S3Path::Bucket { bucket }) => bucket.into(),
_ => panic!("s3 path not found, expected bucket"),
}
}

#[track_caller]
pub fn unwrap_object(req: &mut Request) -> (String, String) {
let Some(S3Path::Object { bucket, key }) = req.s3ext.s3_path.take() else { panic!("s3 path not found") };
(bucket.into(), key.into())
match req.s3ext.s3_path.take() {
Some(S3Path::Object { bucket, key }) => (bucket.into(), key.into()),
_ => panic!("s3 path not found, expected object"),
}
}

fn malformed_xml(source: xml::DeError) -> S3Error {
Expand Down
1 change: 1 addition & 0 deletions rustfmt.toml
Original file line number Diff line number Diff line change
@@ -1,2 +1,3 @@
max_width = 130
fn_call_width = 90
single_line_let_else_max_width = 100

0 comments on commit 50f0034

Please sign in to comment.