meerkat-runtime 0.7.3

//! InputLedger — in-memory ledger of InputState entries.
//!
//! IndexMap<InputId, InputState>.

use indexmap::IndexMap;
use meerkat_core::lifecycle::InputId;

use crate::input_state::InputState;

/// In-memory ledger tracking InputState for all inputs.
#[derive(Debug, Default, Clone)]
pub struct InputLedger {
    /// InputId → InputState (insertion order preserved).
    states: IndexMap<InputId, InputState>,
}

impl InputLedger {
    /// Create a new empty ledger.
    pub fn new() -> Self {
        Self::default()
    }

    /// Accept a new InputState into the ledger.
    pub fn accept(&mut self, state: InputState) {
        self.states.insert(state.input_id.clone(), state);
    }

    /// Recover an InputState after generated recovery authority retained it.
    ///
    /// Recovery retention and idempotency ownership live in the generated
    /// MeerkatMachine recovery/admission path, not in the ledger.
    /// Returns `true` if the state was inserted.
    pub fn recover(&mut self, state: InputState) -> bool {
        self.states.insert(state.input_id.clone(), state);
        true
    }

    /// Get the state of a specific input.
    pub fn get(&self, input_id: &InputId) -> Option<&InputState> {
        self.states.get(input_id)
    }

    /// Remove an input from the ledger.
    pub fn remove(&mut self, input_id: &InputId) -> Option<InputState> {
        self.states.shift_remove(input_id)
    }

    /// Get mutable reference to the state of a specific input.
    pub fn get_mut(&mut self, input_id: &InputId) -> Option<&mut InputState> {
        self.states.get_mut(input_id)
    }

    /// Iterate over all input states. "Active" (non-terminal) filtering must
    /// happen at the driver level, which has DSL access; the ledger by itself
    /// carries only shell metadata.
    pub fn iter(&self) -> impl Iterator<Item = (&InputId, &InputState)> {
        self.states.iter()
    }

    /// Number of entries in the ledger.
    pub fn len(&self) -> usize {
        self.states.len()
    }

    /// Check if the ledger is empty.
    pub fn is_empty(&self) -> bool {
        self.states.is_empty()
    }
}

#[cfg(test)]
#[allow(clippy::unwrap_used)]
mod tests {
    use super::*;

    #[test]
    fn accept_and_retrieve() {
        let mut ledger = InputLedger::new();
        let id = InputId::new();
        let state = InputState::new_accepted(id.clone());
        ledger.accept(state);

        assert_eq!(ledger.len(), 1);
        assert!(!ledger.is_empty());
        let retrieved = ledger.get(&id).unwrap();
        assert_eq!(retrieved.input_id, id);
    }

    #[test]
    fn accept_preserves_idempotency_key_as_metadata_only() {
        let mut ledger = InputLedger::new();

        let input_id = InputId::new();
        let mut state = InputState::new_accepted(input_id.clone());
        state.idempotency_key = Some(crate::identifiers::IdempotencyKey::new("req-123"));
        ledger.accept(state);

        assert_eq!(ledger.len(), 1);
        assert_eq!(
            ledger
                .get(&input_id)
                .and_then(|state| state.idempotency_key.as_ref()),
            Some(&crate::identifiers::IdempotencyKey::new("req-123"))
        );
    }

    #[test]
    fn recover_does_not_interpret_durability() {
        let mut ledger = InputLedger::new();

        let mut state = InputState::new_accepted(InputId::new());
        state.durability = Some(crate::input::InputDurability::Ephemeral);
        assert!(
            ledger.recover(state),
            "the ledger inserts rows after machine authority has made the retention decision"
        );
        assert_eq!(ledger.len(), 1);
    }
}