edi-energy 0.15.0

use edifact_rs::OwnedSegment;

use crate::{
    MessageType,
    messages::{
        core::MessageCore,
        segments::{Bgm, Dtm, Ftx, Nad, collect_dtm, find_bgm, find_nad, try_deserialize},
    },
};

/// ORDRSP — Purchase Order Response (Bestellantwort) message.
///
/// Used in the German energy market as the response to ORDERS and ORDCHG
/// messages — confirming or rejecting orders for metering-point services,
/// lock/unlock operations, value subscriptions, and configuration changes.
///
/// | Field      | Segment | Meaning                             |
/// |------------|---------|-------------------------------------|
/// | `bgm`      | BGM     | Document type / message reference   |
/// | `dtm`      | DTM     | Date / time segments (up to 6)      |
/// | `sender`   | NAD+MS  | Message sender                      |
/// | `receiver` | NAD+MR  | Message receiver                    |
/// | `ftx`      | FTX     | Free text (rejection reason, …)     |
///
/// Wire type string: `ORDRSP:D:10A:UN:{release}`.
///
/// Supported releases (fv-dated profiles):
/// - `releases::ordrsp_fv20251001()` (wire: `"1.4b"`, AHB 1.1a, valid from 2025-10-01)
/// - `releases::ordrsp_fv20260401()` (wire: `"1.4c"`, AHB 1.1b, valid from 2026-04-01)
///
/// The key structural change between MIG 1.4b and MIG 1.4c is the **addition of
/// FTX+Z33** (APN-Kommunikationsdaten-Zugriffsparameter) in SG27. Both releases
/// use the same 40 Prüfidentifikatoren (19001–19302).
#[derive(Debug, Clone)]
pub struct OrdrespMessage {
    pub(crate) core: MessageCore,
    /// BGM — beginning of message.
    bgm: Option<Bgm>,
    /// DTM — date/time segments (message date, execution date, etc.).
    dtm: Vec<Dtm>,
    /// NAD+MS — message sender.
    sender: Option<Nad>,
    /// NAD+MR — message receiver.
    receiver: Option<Nad>,
    /// FTX — free text segments (rejection reason, commentary, …).
    ftx: Vec<Ftx>,
}

impl OrdrespMessage {
    #[must_use]
    pub(crate) fn from_parts(
        segments: Vec<OwnedSegment>,
        message_ref: impl Into<Box<str>>,
        assoc_code: impl Into<Box<str>>,
        pruefidentifikator: Option<u32>,
    ) -> Self {
        let (bgm, dtm, sender, receiver, ftx) = {
            let borrowed: Vec<edifact_rs::Segment<'_>> =
                segments.iter().map(|s| s.as_borrowed()).collect();
            let ftx = borrowed
                .iter()
                .filter(|s| s.tag == "FTX")
                .filter_map(|s| try_deserialize::<Ftx>(s))
                .collect::<Vec<_>>();
            (
                find_bgm(&borrowed),
                collect_dtm(&borrowed),
                find_nad(&borrowed, "MS"),
                find_nad(&borrowed, "MR"),
                ftx,
            )
        };
        Self {
            core: MessageCore::new(
                segments,
                message_ref,
                assoc_code,
                pruefidentifikator,
                MessageType::Ordrsp,
            ),
            bgm,
            dtm,
            sender,
            receiver,
            ftx,
        }
    }

    /// The EDI@Energy release / association code from UNH DE 0057.
    #[must_use]
    pub fn assoc_code(&self) -> &str {
        &self.core.assoc_code
    }

    /// Raw parsed segments (authoritative for validation and serialization).
    #[must_use]
    pub fn segments(&self) -> &[OwnedSegment] {
        &self.core.segments
    }

    /// BGM — beginning of message.  Returns `None` when absent or malformed.
    #[must_use]
    pub fn bgm(&self) -> Option<&Bgm> {
        self.bgm.as_ref()
    }

    /// DTM — message-level date/time segments.
    #[must_use]
    pub fn dtm(&self) -> &[Dtm] {
        &self.dtm
    }

    /// NAD+MS — message sender.  Returns `None` when absent or malformed.
    #[must_use]
    pub fn sender(&self) -> Option<&Nad> {
        self.sender.as_ref()
    }

    /// NAD+MR — message recipient.  Returns `None` when absent or malformed.
    #[must_use]
    pub fn receiver(&self) -> Option<&Nad> {
        self.receiver.as_ref()
    }

    /// FTX — free text segments (rejection reasons, commentary, …).
    ///
    /// For ORDRSP 19002 (Ablehnung), the rejection reason is typically
    /// carried in the first FTX segment's text field.
    #[must_use]
    pub fn ftx(&self) -> &[Ftx] {
        &self.ftx
    }
}

impl_edi_energy_message!(OrdrespMessage);