github/kata-containers
1
0
Fork 1
mirror of https://github.com/kata-containers/kata-containers.git synced 2025-07-16 00:16:52 +00:00
Code Issues Projects Releases Wiki Activity

protocols: Fix the noise caused by non-formatted codes in protocols

Browse Source 
```
-            decoded.strip_prefix("CAP_").unwrap_or(decoded)
+            decoded
+                .strip_prefix("CAP_")
+                .unwrap_or(decoded)
                 .parse::<oci::Capability>()
                 .unwrap_or_else(|_| panic!("Failed to parse {:?} to
Enum Capability", cap))
         })
@@ -1318,8 +1320,6 @@ mod tests {
     #[test]
     #[should_panic]
     fn test_cap_vec2hashset_bad() {
-        cap_vec2hashset(vec![
-            "CAP_DOES_NOT_EXIST".to_string(),
-        ]);
+        cap_vec2hashset(vec!["CAP_DOES_NOT_EXIST".to_string()]);
```

Signed-off-by: alex.lyn <alex.lyn@antgroup.com>
This commit is contained in:
alex.lyn 2025-05-30 17:54:50 +08:00
parent 9488ce822d
commit 65931fb75f
2 changed files with 9 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
src/libs/protocols/src/lib.rs
View File

@ -9,6 +9,7 @@ pub mod agent;
pub mod agent_ttrpc; pub mod agent_ttrpc;
#[cfg(feature = "async")] #[cfg(feature = "async")]
pub mod agent_ttrpc_async; pub mod agent_ttrpc_async;
pub mod api;
pub mod csi; pub mod csi;
pub mod empty; pub mod empty;
mod gogo; mod gogo;
@ -17,15 +18,14 @@ pub mod health_ttrpc;
#[cfg(feature = "async")] #[cfg(feature = "async")]
pub mod health_ttrpc_async; pub mod health_ttrpc_async;
pub mod oci; pub mod oci;
#[cfg(feature = "with-serde")]
mod serde_config;
pub mod trans;
pub mod types;
pub mod remote; pub mod remote;
pub mod remote_ttrpc; pub mod remote_ttrpc;
#[cfg(feature = "async")] #[cfg(feature = "async")]
pub mod remote_ttrpc_async; pub mod remote_ttrpc_async;
pub mod api; #[cfg(feature = "with-serde")]
mod serde_config;
pub mod trans;
pub mod types;
#[cfg(feature = "with-serde")] #[cfg(feature = "with-serde")]
pub use serde_config::{ pub use serde_config::{

8
src/libs/protocols/src/trans.rs
View File

@ -42,7 +42,9 @@ fn cap_vec2hashset(caps: Vec<String>) -> HashSet<oci::Capability> {
.map(|cap: &String| { .map(|cap: &String| {
// cap might be JSON-encoded // cap might be JSON-encoded
let decoded: &str = serde_json::from_str(cap).unwrap_or(cap); let decoded: &str = serde_json::from_str(cap).unwrap_or(cap);
decoded.strip_prefix("CAP_").unwrap_or(decoded) decoded
.strip_prefix("CAP_")
.unwrap_or(decoded)
.parse::<oci::Capability>() .parse::<oci::Capability>()
.unwrap_or_else(|_| panic!("Failed to parse {:?} to Enum Capability", cap)) .unwrap_or_else(|_| panic!("Failed to parse {:?} to Enum Capability", cap))
}) })
@ -1318,8 +1320,6 @@ mod tests {
#[test] #[test]
#[should_panic] #[should_panic]
fn test_cap_vec2hashset_bad() { fn test_cap_vec2hashset_bad() {
cap_vec2hashset(vec![ cap_vec2hashset(vec!["CAP_DOES_NOT_EXIST".to_string()]);
"CAP_DOES_NOT_EXIST".to_string(),
]);
} }
} }