composefs-oci: add support for splitfdstream

Signed-off-by: Giuseppe Scrivano <gscrivan@redhat.com>

Author: giuseppe

crates/composefs-oci/Cargo.toml

@@ -16,11 +16,14 @@ fn-error-context = "0.2"
 async-compression = { version = "0.4.0", default-features = false, features = ["tokio", "zstd", "gzip"] }
 bytes = { version = "1", default-features = false }
 composefs = { workspace = true }
+splitfdstream = { workspace = true }
 containers-image-proxy = { version = "0.9.2", default-features = false }
+libc = "0.2"
 hex = { version = "0.4.0", default-features = false }
 indicatif = { version = "0.17.0", default-features = false, features = ["tokio"] }
 oci-spec = { version = "0.8.0", default-features = false }
-rustix = { version = "1.0.0", features = ["fs"] }
+rustix = { version = "1.0.0", features = ["fs", "net"] }
+serde_json = { version = "1.0", default-features = false, features = ["std"] }
 sha2 = { version = "0.10.1", default-features = false }
 tar = { version = "0.4.38", default-features = false }
 tokio = { version = "1.24.2", features = ["rt-multi-thread"] }

crates/composefs-oci/src/lib.rs

@@ -12,8 +12,11 @@
 
 pub mod image;
 pub mod skopeo;
+pub mod splitfdstream;
 pub mod tar;
 
+pub use splitfdstream::import_from_splitfdstream;
+
 use std::{collections::HashMap, io::Read, sync::Arc};
 
 use anyhow::{bail, ensure, Context, Result};
@@ -28,7 +31,7 @@ use crate::tar::get_entry;
 
 type ContentAndVerity<ObjectID> = (String, ObjectID);
 
-fn layer_identifier(diff_id: &str) -> String {
+pub(crate) fn layer_identifier(diff_id: &str) -> String {
     format!("oci-layer-{diff_id}")
 }