ankurah-core 0.8.1

use crate::entity::Entity;
use ankurah_proto::{self as proto, Attested, Event};

/// Describes how an entity's membership changed for a specific predicate
#[derive(Debug, Clone, PartialEq)]
pub enum MembershipChange {
    /// First time seeing this entity for this predicate
    Initial,
    /// Entity now matches predicate (wasn't matching before)
    Add,
    /// Entity no longer matches predicate (was matching before)
    Remove,
    // Note: No "Update" variant - if entity still matches and changed,
    // it's included in the ReactorUpdateItem but not as a membership change
}

/// Update from the reactor that supports both single and multi-predicate subscriptions
#[derive(Debug, Clone, PartialEq)]
pub struct ReactorUpdate<E = Entity, Ev = Attested<Event>> {
    /// All entities that changed, with their relevance information
    pub items: Vec<ReactorUpdateItem<E, Ev>>,
}

/// A single entity update with all relevance information
#[derive(Debug, Clone, PartialEq)]
pub struct ReactorUpdateItem<E = Entity, Ev = Attested<Event>> {
    /// The entity that changed
    pub entity: E,
    /// Events that caused this update
    pub events: Vec<Ev>,
    /// Which predicates this update is relevant to (if any) and how
    pub predicate_relevance: Vec<(proto::QueryId, MembershipChange)>,
}

impl<E, Ev: Clone> ReactorUpdateItem<E, Ev> {
    /// Check if this item represents any membership change
    pub fn has_membership_change(&self) -> bool { !self.predicate_relevance.is_empty() }
}

// Note: ReactorUpdate to ChangeSet<Entity> conversion removed since Entity doesn't implement View
// ReactorUpdate should be converted to ChangeSet<R> at the LiveQuery level instead