cfsctl: add import-image-splitfdstream command

Assisted-by: Claude Opus 4.6 <noreply@anthropic.com>
Signed-off-by: Giuseppe Scrivano <gscrivan@redhat.com>

Author: giuseppe

crates/composefs-ctl/Cargo.toml

@@ -19,7 +19,7 @@ path = "src/main.rs"
 [features]
 default = ['pre-6.15', 'oci', 'containers-storage']
 http = ['composefs-http']
-oci = ['composefs-oci', 'composefs-oci/varlink']
+oci = ['composefs-oci', 'composefs-oci/varlink', 'splitfdstream']
 containers-storage = ['composefs-oci/containers-storage', 'cstorage']
 rhel9 = ['composefs/rhel9']
 'pre-6.15' = ['composefs/pre-6.15']
@@ -34,6 +34,7 @@ composefs-boot = { workspace = true }
 composefs-oci = { workspace = true, optional = true, features = ["boot"] }
 composefs-http = { workspace = true, optional = true }
 cstorage = { package = "composefs-storage", path = "../composefs-storage", version = "0.4.0", features = ["userns-helper"], optional = true }
+splitfdstream = { workspace = true, optional = true }
 env_logger = { version = "0.11.0", default-features = false }
 hex = { version = "0.4.0", default-features = false }
 indicatif = { version = "0.17.0", default-features = false }

crates/composefs-ctl/src/lib.rs

@@ -348,6 +348,16 @@ enum OciCommand {
         /// Optional human-readable name for the layer
         name: Option<String>,
     },
+    /// Imports a complete image from a splitfdstream server into the repository.
+    ImportImageSplitfdstream {
+        /// Path to the splitfdstream server socket
+        socket: PathBuf,
+        /// The image ID (manifest digest or tag)
+        image_id: String,
+        /// Tag name for imported image
+        #[clap(long)]
+        tag: Option<String>,
+    },
     /// Dump the rootfs of a stored OCI image as a composefs dumpfile to stdout
     ///
     /// The image can be specified by ref name or @digest:
@@ -1209,6 +1219,27 @@ where
                 .await?;
                 println!("{}", object_id.to_id());
             }
+            OciCommand::ImportImageSplitfdstream {
+                socket,
+                image_id,
+                tag,
+            } => {
+                let result = composefs_oci::import_complete_image_from_splitfdstream(
+                    &repo,
+                    &socket,
+                    &image_id,
+                    tag.as_deref(),
+                )?;
+
+                println!("Imported complete image:");
+                println!("  Manifest: {}", result.manifest_digest);
+                println!("  Config:   {}", result.config_digest);
+                println!("  Layers:   {}", result.layers_imported);
+                println!("  Size:     {} bytes", result.total_size_bytes);
+                if let Some(tag_name) = tag {
+                    println!("  Tagged:   {}", tag_name);
+                }
+            }
             OciCommand::Dump { config_opts } => {
                 let fs = load_filesystem_from_oci_image(&repo, config_opts)?;
                 fs.print_dumpfile()?;