Skip to content

Commit 43d1609

Browse files
committed
Fix clippy warnings in latest rust version
Signed-off-by: Ryan Bottriell <[email protected]>
1 parent af2cf6b commit 43d1609

File tree

8 files changed

+30
-49
lines changed

8 files changed

+30
-49
lines changed

crates/spfs/src/graph/tree.rs

Lines changed: 6 additions & 12 deletions
Original file line numberDiff line numberDiff line change
@@ -30,12 +30,9 @@ impl Tree {
3030
}
3131

3232
pub fn get<S: AsRef<str>>(&self, name: S) -> Option<&Entry> {
33-
for entry in self.entries.iter() {
34-
if entry.name == name.as_ref() {
35-
return Some(entry);
36-
}
37-
}
38-
None
33+
self.entries
34+
.iter()
35+
.find(|&entry| entry.name == name.as_ref())
3936
}
4037

4138
pub fn is_empty(&self) -> bool {
@@ -64,12 +61,9 @@ impl Tree {
6461
}
6562

6663
pub fn remove<S: AsRef<str>>(&mut self, name: S) -> Option<&Entry> {
67-
for entry in self.entries.iter() {
68-
if entry.name == name.as_ref() {
69-
return Some(entry);
70-
}
71-
}
72-
None
64+
self.entries
65+
.iter()
66+
.find(|&entry| entry.name == name.as_ref())
7367
}
7468

7569
pub fn iter(&self) -> impl Iterator<Item = &Entry> {

crates/spfs/src/proto/conversions.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -63,7 +63,7 @@ impl TryFrom<Option<super::Tag>> for tracking::Tag {
6363
impl TryFrom<super::Tag> for tracking::Tag {
6464
type Error = Error;
6565
fn try_from(source: super::Tag) -> Result<Self> {
66-
let org = source.org.is_empty().not().then(|| source.org);
66+
let org = source.org.is_empty().not().then_some(source.org);
6767
let mut tag = Self::new(org, source.name, convert_digest(source.target)?)?;
6868
tag.parent = convert_digest(source.parent)?;
6969
tag.user = source.user;

crates/spfs/src/storage/manifest_test.rs

Lines changed: 1 addition & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -72,10 +72,7 @@ async fn test_manifest_parity(
7272
.expect("stored manifest was not written");
7373
let actual = out.unlock();
7474
let mut diffs = tracking::compute_diff(&expected, &actual);
75-
diffs = diffs
76-
.into_iter()
77-
.filter(|d| !d.mode.is_unchanged())
78-
.collect();
75+
diffs.retain(|d| !d.mode.is_unchanged());
7976

8077
for diff in diffs.iter() {
8178
println!("{diff}, {:?}", diff.mode);

crates/spk-schema/crates/foundation/src/version/mod.rs

Lines changed: 2 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -249,9 +249,8 @@ impl std::cmp::Eq for VersionParts {}
249249
impl std::hash::Hash for VersionParts {
250250
fn hash<H: std::hash::Hasher>(&self, state: &mut H) {
251251
// trailing zeros do not alter the hash/cmp for a version
252-
match self.parts.iter().rposition(|d| d != &0) {
253-
Some(last_nonzero) => self.parts[..=last_nonzero].hash(state),
254-
None => {}
252+
if let Some(last_nonzero) = self.parts.iter().rposition(|d| d != &0) {
253+
self.parts[..=last_nonzero].hash(state)
255254
};
256255
self.plus_epsilon.hash(state);
257256
}

crates/spk-schema/crates/validators/src/validators.rs

Lines changed: 14 additions & 17 deletions
Original file line numberDiff line numberDiff line change
@@ -29,23 +29,20 @@ where
2929
let mut diffs: Vec<_> = diffs.iter().filter(|d| d.mode.is_added()).collect();
3030
let data_path = data_path(spec.ident()).to_path("/");
3131
for component in spec.components_iter() {
32-
diffs = diffs
33-
.into_iter()
34-
.filter(|d| {
35-
let entry = match &d.mode {
36-
spfs::tracking::DiffMode::Unchanged(e) => e,
37-
spfs::tracking::DiffMode::Changed(_, e) => e,
38-
spfs::tracking::DiffMode::Added(e) => e,
39-
spfs::tracking::DiffMode::Removed(_) => return false,
40-
};
41-
let path = d.path.to_path("/");
42-
// either part of a component explicitly or implicitly
43-
// because it's a data file
44-
let is_explicit = component.files().matches(&path, entry.is_dir());
45-
let is_collected = is_explicit || path.starts_with(&data_path);
46-
!is_collected
47-
})
48-
.collect();
32+
diffs.retain(|d| {
33+
let entry = match &d.mode {
34+
spfs::tracking::DiffMode::Unchanged(e) => e,
35+
spfs::tracking::DiffMode::Changed(_, e) => e,
36+
spfs::tracking::DiffMode::Added(e) => e,
37+
spfs::tracking::DiffMode::Removed(_) => return false,
38+
};
39+
let path = d.path.to_path("/");
40+
// either part of a component explicitly or implicitly
41+
// because it's a data file
42+
let is_explicit = component.files().matches(&path, entry.is_dir());
43+
let is_collected = is_explicit || path.starts_with(&data_path);
44+
!is_collected
45+
});
4946
if diffs.is_empty() {
5047
return None;
5148
}

crates/spk-solve/src/io.rs

Lines changed: 1 addition & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -105,9 +105,7 @@ where
105105
}
106106

107107
fn check_for_interruptions(&mut self) -> Result<()> {
108-
if let Err(err) = self.check_if_taking_too_long() {
109-
return Err(err);
110-
};
108+
self.check_if_taking_too_long()?;
111109
self.check_if_user_hit_ctrlc()
112110
}
113111

crates/spk-storage/src/storage/repository.rs

Lines changed: 2 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -393,9 +393,8 @@ pub trait Repository: Storage + Sync {
393393
};
394394

395395
let components = self.read_components(package.ident()).await?;
396-
if let Err(err) = self.publish_package_to_storage(package, &components).await {
397-
return Err(err);
398-
}
396+
self.publish_package_to_storage(package, &components)
397+
.await?;
399398

400399
// Changes that affect embedded stubs:
401400
// - change in deprecation status

crates/spk-storage/src/storage/spfs.rs

Lines changed: 3 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -123,7 +123,7 @@ impl std::ops::Drop for SPFSRepository {
123123
fn drop(&mut self) {
124124
// Safety: We only put valid `Box` pointers into `self.cache_policy`.
125125
unsafe {
126-
Box::from_raw(self.cache_policy.load(Ordering::Relaxed));
126+
let _ = Box::from_raw(self.cache_policy.load(Ordering::Relaxed));
127127
}
128128
}
129129
}
@@ -597,11 +597,8 @@ impl Repository for SPFSRepository {
597597

598598
async fn read_recipe(&self, pkg: &Ident) -> Result<Arc<Self::Recipe>> {
599599
let address = self.address();
600-
match pkg.build {
601-
Some(_) => {
602-
return Err(format!("cannot read a recipe for a package build: {pkg}").into());
603-
}
604-
None => {}
600+
if pkg.build.is_some() {
601+
return Err(format!("cannot read a recipe for a package build: {pkg}").into());
605602
};
606603
if self.cached_result_permitted() {
607604
let r = RECIPE_CACHE

0 commit comments

Comments
 (0)