fiscal-core 0.7.2

//! NF-e/NFC-e XML builder module.
//!
//! Provides [`InvoiceBuilder`] — a typestate builder that enforces the
//! invoice lifecycle at compile time:
//!
//! ```text
//! InvoiceBuilder::new(issuer, env, model)   // Draft
//!     .series(1)
//!     .invoice_number(42)
//!     .add_item(item)
//!     .recipient(recipient)
//!     .payments(vec![payment])
//!     .build()?                              // Built
//!     .sign_with(|xml| sign(xml))?           // Signed
//!     .signed_xml()                          // &str
//! ```

pub mod access_key;
mod builder;
pub mod dest;
pub mod det;
pub mod emit;
pub mod ide;
pub mod optional;
pub mod pag;
pub mod tax_id;
pub mod total;
pub mod transp;

pub use access_key::build_access_key;
pub use builder::{Built, Draft, InvoiceBuilder, Signed};

/// Build an NF-e/NFC-e XML directly from a fully populated [`InvoiceBuildData`].
///
/// This is the FFI-friendly alternative to the typestate [`InvoiceBuilder`].
/// Intended for bindings (Node.js, Python, WASM) where the data arrives as
/// a deserialized struct rather than through chainable setters.
///
/// Returns [`InvoiceXmlResult`] containing the unsigned XML and access key.
///
/// # Errors
///
/// Returns [`FiscalError`] if the data is invalid (unknown state code,
/// invalid tax data, etc.).
pub fn build_from_data(
    data: &crate::types::InvoiceBuildData,
) -> Result<crate::types::InvoiceXmlResult, FiscalError> {
    generate_xml(data)
}

use crate::FiscalError;
use crate::constants::{NFE_NAMESPACE, NFE_VERSION};
use crate::newtypes::IbgeCode;
use crate::state_codes::STATE_IBGE_CODES;
use crate::tax_icms::{create_icms_totals, merge_icms_totals};
use crate::types::{AccessKeyParams, InvoiceBuildData, InvoiceXmlResult};
use crate::xml_utils::{TagContent, tag};

/// Internal XML generation from a fully populated [`InvoiceBuildData`].
///
/// Called by [`InvoiceBuilder::build`]; not part of the public API.
fn generate_xml(data: &InvoiceBuildData) -> Result<InvoiceXmlResult, FiscalError> {
    let state_ibge = STATE_IBGE_CODES
        .get(data.issuer.state_code.as_str())
        .copied()
        .ok_or_else(|| FiscalError::InvalidStateCode(data.issuer.state_code.clone()))?;

    let numeric_code = access_key::generate_numeric_code();
    let year_month = access_key::format_year_month(&data.issued_at);

    let ak_params = AccessKeyParams {
        state_code: IbgeCode(state_ibge.to_string()),
        year_month,
        tax_id: data.issuer.tax_id.clone(),
        model: data.model,
        series: data.series,
        number: data.number,
        emission_type: data.emission_type,
        numeric_code: numeric_code.clone(),
    };

    let access_key = build_access_key(&ak_params)?;
    let inf_nfe_id = format!("NFe{access_key}");

    // Build items and accumulate tax totals
    let mut icms_totals = create_icms_totals();
    let mut total_products: i64 = 0;
    let mut total_ipi: i64 = 0;
    let mut total_pis: i64 = 0;
    let mut total_cofins: i64 = 0;
    let mut total_ii: i64 = 0;
    let mut total_frete: i64 = 0;
    let mut total_seg: i64 = 0;
    let mut total_desc: i64 = 0;
    let mut total_outro: i64 = 0;
    let mut total_tot_trib: i64 = 0;
    let mut total_ipi_devol: i64 = 0;
    let mut total_pis_st: i64 = 0;
    let mut total_cofins_st: i64 = 0;
    let mut any_ind_deduz_deson = false;

    let mut det_elements = Vec::with_capacity(data.items.len());
    for item in &data.items {
        let det_result = det::build_det(item, data)?;
        // Track ind_deduz_deson from any item
        if det_result.ind_deduz_deson {
            any_ind_deduz_deson = true;
        }
        // Only accumulate into totals when indTot == 1 (the default)
        if det_result.ind_tot == 1 {
            total_products += item.total_price.0;
            total_ipi += det_result.v_ipi;
            total_pis += det_result.v_pis;
            total_cofins += det_result.v_cofins;
            total_ii += det_result.v_ii;
            total_frete += det_result.v_frete;
            total_seg += det_result.v_seg;
            total_desc += det_result.v_desc;
            total_outro += det_result.v_outro;
            total_tot_trib += det_result.v_tot_trib;
            total_ipi_devol += det_result.v_ipi_devol;
            total_pis_st += det_result.v_pis_st;
            total_cofins_st += det_result.v_cofins_st;
            merge_icms_totals(&mut icms_totals, &det_result.icms_totals);
        }
        det_elements.push(det_result.xml);
    }

    // Assemble infNFe children in schema order
    let mut inf_children = vec![
        ide::build_ide(data, state_ibge, &numeric_code, &access_key),
        emit::build_emit(data),
    ];

    if let Some(dest_xml) = dest::build_dest(data) {
        inf_children.push(dest_xml);
    }

    if let Some(ref w) = data.withdrawal {
        inf_children.push(optional::build_withdrawal(w));
    }
    if let Some(ref d) = data.delivery {
        inf_children.push(optional::build_delivery(d));
    }
    if let Some(ref auths) = data.authorized_xml {
        for a in auths {
            inf_children.push(optional::build_aut_xml(a));
        }
    }

    inf_children.extend(det_elements);

    // Propagate item-level indDeduzDeson to ICMS totals
    if any_ind_deduz_deson {
        icms_totals.ind_deduz_deson = true;
    }

    inf_children.push(total::build_total(
        total_products,
        &icms_totals,
        &total::OtherTotals {
            v_ipi: total_ipi,
            v_pis: total_pis,
            v_cofins: total_cofins,
            v_ii: total_ii,
            v_frete: total_frete,
            v_seg: total_seg,
            v_desc: total_desc,
            v_outro: total_outro,
            v_tot_trib: total_tot_trib,
            v_ipi_devol: total_ipi_devol,
            v_pis_st: total_pis_st,
            v_cofins_st: total_cofins_st,
        },
        data.ret_trib.as_ref(),
        data.issqn_tot.as_ref(),
        data.is_tot.as_ref(),
        data.ibs_cbs_tot.as_ref(),
        data.schema_version,
        data.calculation_method,
        data.v_nf_tot_override,
    ));

    inf_children.push(transp::build_transp(data));

    if let Some(ref billing) = data.billing {
        inf_children.push(optional::build_cobr(billing));
    }

    inf_children.push(pag::build_pag(
        &data.payments,
        data.change_amount,
        data.payment_card_details.as_deref(),
    ));

    if let Some(ref intermed) = data.intermediary {
        inf_children.push(optional::build_intermediary(intermed));
    }

    let inf_adic = optional::build_inf_adic(data);
    if !inf_adic.is_empty() {
        inf_children.push(inf_adic);
    }

    if let Some(ref exp) = data.export {
        inf_children.push(optional::build_export(exp));
    }
    if let Some(ref purchase) = data.purchase {
        inf_children.push(optional::build_purchase(purchase));
    }
    if let Some(ref cana) = data.cana {
        inf_children.push(optional::build_cana(cana));
    }
    if let Some(ref tech) = data.tech_responsible {
        inf_children.push(optional::build_tech_responsible_with_key(tech, &access_key));
    }
    // agropecuario — only emitted when schema is PL_010 or later
    // (matching PHP: if ($this->schema < 10) { return; })
    if data.schema_version.is_pl010() {
        if let Some(ref agro) = data.agropecuario {
            inf_children.push(optional::build_agropecuario(agro));
        }
    }

    // Matches PHP sped-nfe: no xmlns on infNFe (inherited from NFe parent),
    // Id before versao (same order as PHP's DOMDocument setAttribute calls)
    let inf_nfe = tag(
        "infNFe",
        &[("Id", &inf_nfe_id), ("versao", NFE_VERSION)],
        TagContent::Children(inf_children),
    );

    let mut xml = format!(
        "<?xml version=\"1.0\" encoding=\"UTF-8\"?>{}",
        tag(
            "NFe",
            &[("xmlns", NFE_NAMESPACE)],
            TagContent::Children(vec![inf_nfe])
        ),
    );

    if data.only_ascii {
        xml = crate::sanitize::sanitize_xml_text(&xml);
    }

    Ok(InvoiceXmlResult { xml, access_key })
}