payload_dumper 0.8.3

// SPDX-License-Identifier: Apache-2.0
// Copyright (c) 2025 rhythmcache
// https://github.com/rhythmcache/payload-dumper-rust

use ahash::AHashSet as HashSet;
use anyhow::{Result, anyhow};
use payload_dumper::metadata::get_metadata;
use payload_dumper::structs::DeltaArchiveManifest;
use std::path::Path;
use tokio::fs;
use tokio::io::AsyncWriteExt;

/// handles metadata extraction and saving based on the provided mode
///
/// # arguments
/// * `manifest` - the parsed payload manifest
/// * `out_dir` - output directory path
/// * `data_offset` - offset where payload data starts
/// * `mode` - metadata mode: "compact" or "full"
/// * `filter_images` - comma-separated partition names to filter, or empty for all
/// * `is_stdout` - whether output is directed to stdout
pub async fn handle_metadata_extraction(
    manifest: &DeltaArchiveManifest,
    out_dir: &Path,
    data_offset: u64,
    mode: &str,
    filter_images: &str,
    is_stdout: bool,
) -> Result<()> {
    let full_mode = mode == "full";

    // parse filter partitions if provided
    let filter_partitions: Option<HashSet<&str>> = if !filter_images.is_empty() {
        Some(filter_images.split(',').collect())
    } else {
        None
    };

    // generate metadata
    let metadata =
        get_metadata(manifest, data_offset, full_mode, filter_partitions.as_ref()).await?;

    // serialize to JSON
    let json_output = serde_json::to_string_pretty(&metadata)
        .map_err(|e| anyhow!("Failed to serialize metadata: {}", e))?;

    // output handling
    if is_stdout {
        // write to stdout
        let mut stdout = tokio::io::stdout();
        stdout
            .write_all(json_output.as_bytes())
            .await
            .map_err(|e| anyhow!("Failed to write metadata to stdout: {}", e))?;
        stdout
            .flush()
            .await
            .map_err(|e| anyhow!("Failed to flush stdout: {}", e))?;
    } else {
        // write to file
        let metadata_file = out_dir.join("metadata.json");
        fs::write(&metadata_file, json_output)
            .await
            .map_err(|e| anyhow!("Failed to write metadata file: {}", e))?;
    }

    Ok(())
}