brood 0.9.1

//! Entity access at query time.
//!
//! This module allows access to entity entries in a `World` while iterating over entities in the
//! same `World`. Such access allows for strong inter-entity relationships.
//!
//! Access to components of entities is restricted to the specific components viewed. These views
//! must not conflict with the components being iterated simultaneously.

use crate::{
    entity,
    entity::allocator::Location,
    query::{
        filter::And,
        view,
        view::SubSet,
    },
    registry,
    registry::contains::views::{
        ContainsViewsOuter,
        Sealed as ContainsViewsSealed,
    },
    Query,
    World,
};
use core::marker::PhantomData;

/// A view into a single entity in a [`World`].
///
/// [`World`]: crate::World
pub struct Entry<'a, 'b, Registry, Resources, Views, Indices>
where
    Registry: registry::Registry,
{
    entries: &'b mut Entries<'a, Registry, Resources, Views, Indices>,
    location: Location<Registry>,
}

impl<'a, 'b, Registry, Resources, Views, Indices> Entry<'a, 'b, Registry, Resources, Views, Indices>
where
    Registry: registry::Registry,
{
    fn new(
        entries: &'b mut Entries<'a, Registry, Resources, Views, Indices>,
        location: Location<Registry>,
    ) -> Self {
        Self { entries, location }
    }
}

impl<'a, 'b, Registry, Resources, Views, Indices> Entry<'a, 'b, Registry, Resources, Views, Indices>
where
    Views: view::Views<'a>,
    Registry: registry::ContainsViews<'a, Views, Indices>,
{
    /// Query for components contained within this entity using the given `SubViews` and `Filter`.
    ///
    /// Returns a `Some` value if the entity matches the `SubViews` and `Filter`, and returns a
    /// `None` value otherwise.
    ///
    /// Note that `SubViews` must be a [`SubSet`] of `Views`. See the documentation for the
    /// `SubSet` trait for what exactly is required for a subset.
    pub fn query<SubViews, Filter, FilterIndices, SubViewsFilterIndices, SubSetIndices>(
        &mut self,
        #[allow(unused_variables)] query: Query<SubViews, Filter>,
    ) -> Option<SubViews>
    where
        SubViews: SubSet<'a, Views, SubSetIndices> + view::Views<'a>,
        // Note: we currently can't filter on components outside of the `Views`. This is an
        // unfortunate limitation of not being able to index directly into the `Registry` for an
        // arbitrary `Filter`.
        Views: view::ContainsFilter<
            'a,
            And<Filter, SubViews>,
            And<FilterIndices, SubViewsFilterIndices>,
        >,
    {
        let indices = <<Registry as ContainsViewsSealed<'a, Views, Indices>>::Viewable as ContainsViewsOuter<'a, Views, <Registry as ContainsViewsSealed<'a, Views, Indices>>::Containments, <Registry as ContainsViewsSealed<'a, Views, Indices>>::Indices, <Registry as ContainsViewsSealed<'a, Views, Indices>>::ReshapeIndices>>::indices();
        // SAFETY: The `indices` provided here are the valid indices into `Registry`, and therefore
        // into the `archetype::Identifier<Registry>` used here.
        if unsafe { Views::filter(&indices, self.location.identifier) } {
            // Since we can't view with the subviews directly on the registry, we instead view on
            // the super-views `Views` first, and then mask it with the `SubViews`.
            //
            // This is necessary because callers can't guarantee that every possible `Registry` is
            // viewable by every possible `SubViews` (for example, in a `System` where the
            // `Registry` is generic). Therefore, we instead prove that the `Views` can be viewed
            // by the `SubViews`.

            // SAFETY: `self.location.index` is a valid index into this archetype, as guaranteed by
            // the entity allocator.
            let super_views = unsafe {
                (*self.entries.world)
                    .archetypes
                    .get_mut(self.location.identifier)?
                    .view_row_maybe_uninit_unchecked::<Views, Indices>(self.location.index)
            };

            // SAFETY: `super_views` is viewed on the archetype identified by
            // `self.location.identifier`. The `indices` also correspond to the registry the
            // archetype is generic over. Finally, the `SubViews` filter has already been applied.
            Some(unsafe { SubViews::view(super_views, indices, self.location.identifier) })
        } else {
            None
        }
    }
}

/// Access to entity [`Entry`]s.
///
/// These entity `Entry`s allow access to the components viewed in `Views`.
pub struct Entries<'a, Registry, Resources, Views, Indices>
where
    Registry: registry::Registry,
{
    world: *mut World<Registry, Resources>,

    lifetime: PhantomData<&'a ()>,
    views: PhantomData<Views>,
    indices: PhantomData<Indices>,
}

impl<'a, Registry, Resources, Views, Indices> Entries<'a, Registry, Resources, Views, Indices>
where
    Registry: registry::Registry,
{
    /// Creates a new `Entries` for the given `world`, allowing [`Entry`] access to the components
    /// viewed by `Views`.
    ///
    /// # Safety
    /// The returned `Entries` must not outlive `world`. In other words, the lifetime `'a` must not
    /// outlive the lifetime of `world`.
    ///
    /// The components in `world` accessed by `Views` must not be accessed anywhere else (such as,
    /// for example, in a simultaneous query iteration).
    ///
    /// Entities must not be added or removed from the `World` while pointed at by `Entries`, nor
    /// should existing entities change shape (meaning, they shouldn't be moved between
    /// archetypes).
    ///
    /// # Example
    /// ```
    /// use brood::{
    ///     entity,
    ///     query::{
    ///         filter,
    ///         result,
    ///         Views,
    ///     },
    ///     Query,
    ///     Registry,
    ///     World,
    /// };
    ///
    /// #[derive(Debug, PartialEq)]
    /// struct A(u32);
    /// struct B(char);
    ///
    /// let mut world = World::<Registry!(A, B)>::new();
    /// let entity_identifier = world.insert(entity!(A(42), B('a')));
    ///
    /// let mut query_result =
    ///     world.query(Query::<Views!(), filter::None, Views!(), Views!(&A)>::new());
    ///
    /// let result!(a) = query_result
    ///     .entries
    ///     .entry(entity_identifier)
    ///     .unwrap()
    ///     .query(Query::<Views!(&A)>::new())
    ///     .unwrap();
    /// assert_eq!(a, &A(42));
    /// ```
    pub(crate) unsafe fn new(world: *mut World<Registry, Resources>) -> Self {
        Entries {
            world,

            lifetime: PhantomData,
            views: PhantomData,
            indices: PhantomData,
        }
    }

    /// Gets an [`Entry`] for the entity associated with an `entity::Identifier`.
    ///
    /// If no such entry exists, [`None`] is returned.
    ///
    /// [`None`]: Option::None
    pub fn entry<'b>(
        &'b mut self,
        entity_identifier: entity::Identifier,
    ) -> Option<Entry<'a, 'b, Registry, Resources, Views, Indices>> {
        // SAFETY: The invariants of `Entries` guarantees that `World` won't have any entities
        // added or removed, meaning the `entity_allocator` will not be mutated during this time.
        unsafe { &*self.world }
            .entity_allocator
            .get(entity_identifier)
            .map(|location| Entry::new(self, location))
    }
}

// SAFETY: Since the access to the viewed components is unique, this can be sent between threads
// safely.
unsafe impl<'a, Registry, Resources, Views, Indices> Send
    for Entries<'a, Registry, Resources, Views, Indices>
where
    Registry: registry::Registry,
{
}

// SAFETY: Since the access to the viewed components is unique, this can be shared between threads
// safely.
unsafe impl<'a, Registry, Resources, Views, Indices> Sync
    for Entries<'a, Registry, Resources, Views, Indices>
where
    Registry: registry::Registry,
{
}

#[cfg(test)]
mod tests {
    use super::Entries;
    use crate::{
        entity,
        query::{
            filter,
            result,
            Views,
        },
        Query,
        Registry,
        World,
    };
    use claims::{
        assert_none,
        assert_some,
    };

    // Define components.
    #[derive(Debug, PartialEq)]
    struct A(u32);
    #[derive(Debug, PartialEq)]
    struct B(char);
    #[derive(Debug, PartialEq)]
    struct C(f32);

    type Registry = Registry!(A, B, C);

    #[test]
    fn empty_query() {
        let mut world = World::<Registry!()>::new();
        let identifier = world.insert(entity!());

        let mut entries = unsafe { Entries::<_, _, Views!(), _>::new(&mut world) };
        let mut entry = assert_some!(entries.entry(identifier));

        assert_some!(entry.query(Query::<Views!()>::new()));
    }

    #[test]
    fn empty_query_with_filter_succeeds() {
        let mut world = World::<Registry>::new();
        let identifier = world.insert(entity!(A(42)));

        let mut entries = unsafe { Entries::<_, _, Views!(&A), _>::new(&mut world) };
        let mut entry = assert_some!(entries.entry(identifier));

        assert_some!(entry.query(Query::<Views!(), filter::Has<A>>::new()));
    }

    #[test]
    fn empty_query_with_filter_fails() {
        let mut world = World::<Registry>::new();
        let identifier = world.insert(entity!(A(42)));

        let mut entries = unsafe { Entries::<_, _, Views!(&B), _>::new(&mut world) };
        let mut entry = assert_some!(entries.entry(identifier));

        assert_none!(entry.query(Query::<Views!(), filter::Has<B>>::new()));
    }

    #[test]
    fn empty_query_with_filter_on_mutable_ref_in_super_views() {
        let mut world = World::<Registry>::new();
        let identifier = world.insert(entity!(A(42)));

        let mut entries = unsafe { Entries::<_, _, Views!(&mut A), _>::new(&mut world) };
        let mut entry = assert_some!(entries.entry(identifier));

        assert_some!(entry.query(Query::<Views!(), filter::Has<A>>::new()));
    }

    #[test]
    fn empty_query_with_filter_on_optional_ref_in_super_views() {
        let mut world = World::<Registry>::new();
        let identifier = world.insert(entity!(A(42)));

        let mut entries = unsafe { Entries::<_, _, Views!(Option<&A>), _>::new(&mut world) };
        let mut entry = assert_some!(entries.entry(identifier));

        assert_some!(entry.query(Query::<Views!(), filter::Has<A>>::new()));
    }

    #[test]
    fn empty_query_with_filter_on_optional_mutable_ref_in_super_views() {
        let mut world = World::<Registry>::new();
        let identifier = world.insert(entity!(A(42)));

        let mut entries = unsafe { Entries::<_, _, Views!(Option<&mut A>), _>::new(&mut world) };
        let mut entry = assert_some!(entries.entry(identifier));

        assert_some!(entry.query(Query::<Views!(), filter::Has<A>>::new()));
    }

    #[test]
    fn empty_query_with_filter_on_second_view_in_super_views() {
        let mut world = World::<Registry>::new();
        let identifier = world.insert(entity!(A(42)));

        let mut entries = unsafe { Entries::<_, _, Views!(&C, &A), _>::new(&mut world) };
        let mut entry = assert_some!(entries.entry(identifier));

        assert_some!(entry.query(Query::<Views!(), filter::Has<A>>::new()));
    }

    #[test]
    fn empty_query_with_or_filter() {
        let mut world = World::<Registry>::new();
        let identifier = world.insert(entity!(A(42)));

        let mut entries = unsafe { Entries::<_, _, Views!(&A, &B), _>::new(&mut world) };
        let mut entry = assert_some!(entries.entry(identifier));

        assert_some!(
            entry.query(Query::<Views!(), filter::Or<filter::Has<A>, filter::Has<B>>>::new())
        );
    }

    #[test]
    fn empty_query_with_or_filter_second() {
        let mut world = World::<Registry>::new();
        let identifier = world.insert(entity!(A(42)));

        let mut entries = unsafe { Entries::<_, _, Views!(&A, &B), _>::new(&mut world) };
        let mut entry = assert_some!(entries.entry(identifier));

        assert_some!(
            entry.query(Query::<Views!(), filter::Or<filter::Has<B>, filter::Has<A>>>::new())
        );
    }

    #[test]
    fn empty_query_with_and_filter() {
        let mut world = World::<Registry>::new();
        let identifier = world.insert(entity!(A(42), B('a')));

        let mut entries = unsafe { Entries::<_, _, Views!(&A, &B), _>::new(&mut world) };
        let mut entry = assert_some!(entries.entry(identifier));

        assert_some!(
            entry.query(Query::<Views!(), filter::And<filter::Has<A>, filter::Has<B>>>::new())
        );
    }

    #[test]
    fn empty_query_with_not_filter() {
        let mut world = World::<Registry>::new();
        let identifier = world.insert(entity!(A(42)));

        let mut entries = unsafe { Entries::<_, _, Views!(&B), _>::new(&mut world) };
        let mut entry = assert_some!(entries.entry(identifier));

        assert_some!(entry.query(Query::<Views!(), filter::Not<filter::Has<B>>>::new()));
    }

    #[test]
    fn empty_query_with_nonempty_superset() {
        let mut world = World::<Registry>::new();
        let identifier = world.insert(entity!());

        let mut entries = unsafe { Entries::<_, _, Views!(&A, &mut C), _>::new(&mut world) };
        let mut entry = assert_some!(entries.entry(identifier));

        assert_some!(entry.query(Query::<Views!()>::new()));
    }

    #[test]
    fn query_immutable_superset_immutable() {
        let mut world = World::<Registry>::new();
        let identifier = world.insert(entity!(A(42), B('a'), C(3.14)));

        let mut entries = unsafe { Entries::<_, _, Views!(&A, &mut C), _>::new(&mut world) };
        let mut entry = assert_some!(entries.entry(identifier));

        let result!(a) = assert_some!(entry.query(Query::<Views!(&A)>::new()));
        assert_eq!(a, &A(42));
    }

    #[test]
    fn query_immutable_superset_mutable() {
        let mut world = World::<Registry>::new();
        let identifier = world.insert(entity!(A(42), B('a'), C(3.14)));

        let mut entries = unsafe { Entries::<_, _, Views!(&A, &mut C), _>::new(&mut world) };
        let mut entry = assert_some!(entries.entry(identifier));

        let result!(c) = assert_some!(entry.query(Query::<Views!(&C)>::new()));
        assert_eq!(c, &C(3.14));
    }

    #[test]
    fn query_mutable_superset_mutable() {
        let mut world = World::<Registry>::new();
        let identifier = world.insert(entity!(A(42), B('a'), C(3.14)));

        let mut entries = unsafe { Entries::<_, _, Views!(&A, &mut C), _>::new(&mut world) };
        let mut entry = assert_some!(entries.entry(identifier));

        let result!(c) = assert_some!(entry.query(Query::<Views!(&mut C)>::new()));
        assert_eq!(c, &mut C(3.14));
    }

    #[test]
    fn query_optional_immutable_superset_immutable() {
        let mut world = World::<Registry>::new();
        let identifier = world.insert(entity!(A(42), B('a'), C(3.14)));

        let mut entries = unsafe { Entries::<_, _, Views!(&A, &mut C), _>::new(&mut world) };
        let mut entry = assert_some!(entries.entry(identifier));

        let result!(a) = assert_some!(entry.query(Query::<Views!(Option<&A>)>::new()));
        assert_eq!(a, Some(&A(42)));
    }

    #[test]
    fn query_optional_immutable_superset_mutable() {
        let mut world = World::<Registry>::new();
        let identifier = world.insert(entity!(A(42), B('a'), C(3.14)));

        let mut entries = unsafe { Entries::<_, _, Views!(&A, &mut C), _>::new(&mut world) };
        let mut entry = assert_some!(entries.entry(identifier));

        let result!(c) = assert_some!(entry.query(Query::<Views!(Option<&C>)>::new()));
        assert_eq!(c, Some(&C(3.14)));
    }

    #[test]
    fn query_optional_immutable_superset_mutable_not_present() {
        let mut world = World::<Registry>::new();
        let identifier = world.insert(entity!(A(42), B('a')));

        let mut entries = unsafe { Entries::<_, _, Views!(&A, &mut C), _>::new(&mut world) };
        let mut entry = assert_some!(entries.entry(identifier));

        let result!(c) = assert_some!(entry.query(Query::<Views!(Option<&C>)>::new()));
        assert_eq!(c, None);
    }

    #[test]
    fn query_optional_mutable_superset_mutable() {
        let mut world = World::<Registry>::new();
        let identifier = world.insert(entity!(A(42), B('a'), C(3.14)));

        let mut entries = unsafe { Entries::<_, _, Views!(&A, &mut C), _>::new(&mut world) };
        let mut entry = assert_some!(entries.entry(identifier));

        let result!(c) = assert_some!(entry.query(Query::<Views!(Option<&mut C>)>::new()));
        assert_eq!(c, Some(&mut C(3.14)));
    }

    #[test]
    fn query_optional_mutable_superset_mutable_not_present() {
        let mut world = World::<Registry>::new();
        let identifier = world.insert(entity!(A(42), B('a')));

        let mut entries = unsafe { Entries::<_, _, Views!(&A, &mut C), _>::new(&mut world) };
        let mut entry = assert_some!(entries.entry(identifier));

        let result!(c) = assert_some!(entry.query(Query::<Views!(Option<&mut C>)>::new()));
        assert_eq!(c, None);
    }

    #[test]
    fn query_optional_none() {
        let mut world = World::<Registry>::new();
        let identifier = world.insert(entity!(A(42), C(3.14)));

        let mut entries = unsafe { Entries::<_, _, Views!(&A, &mut C, &B), _>::new(&mut world) };
        let mut entry = assert_some!(entries.entry(identifier));

        let result!(b) = assert_some!(entry.query(Query::<Views!(Option<&B>)>::new()));
        assert_eq!(b, None);
    }

    #[test]
    fn query_entity_identifier() {
        let mut world = World::<Registry>::new();
        let identifier = world.insert(entity!(A(42), B('a'), C(3.14)));

        let mut entries =
            unsafe { Entries::<_, _, Views!(&A, &mut C, entity::Identifier), _>::new(&mut world) };
        let mut entry = assert_some!(entries.entry(identifier));

        let result!(queried_identifier) =
            assert_some!(entry.query(Query::<Views!(entity::Identifier)>::new()));
        assert_eq!(queried_identifier, identifier);
    }

    #[test]
    fn query_multiple() {
        let mut world = World::<Registry>::new();
        let identifier = world.insert(entity!(B('a'), C(3.14)));

        let mut entries =
            unsafe { Entries::<_, _, Views!(&A, &mut B, entity::Identifier), _>::new(&mut world) };
        let mut entry = assert_some!(entries.entry(identifier));

        let result!(queried_identifier, b, a) =
            assert_some!(entry.query(Query::<Views!(entity::Identifier, &B, Option<&A>)>::new()));
        assert_eq!(queried_identifier, identifier);
        assert_eq!(a, None);
        assert_eq!(b, &B('a'));
    }

    #[test]
    fn query_ref_with_optional_super_view() {
        let mut world = World::<Registry>::new();
        let identifier = world.insert(entity!(A(42)));

        let mut entries = unsafe { Entries::<_, _, Views!(Option<&A>), _>::new(&mut world) };
        let mut entry = assert_some!(entries.entry(identifier));

        let result!(a) = assert_some!(entry.query(Query::<Views!(&A)>::new()));
        assert_eq!(a, &A(42));
    }

    #[test]
    fn query_ref_with_optional_mutable_super_view() {
        let mut world = World::<Registry>::new();
        let identifier = world.insert(entity!(A(42)));

        let mut entries = unsafe { Entries::<_, _, Views!(Option<&mut A>), _>::new(&mut world) };
        let mut entry = assert_some!(entries.entry(identifier));

        let result!(a) = assert_some!(entry.query(Query::<Views!(&A)>::new()));
        assert_eq!(a, &A(42));
    }

    #[test]
    fn query_mutable_ref_with_optional_mutable_super_view() {
        let mut world = World::<Registry>::new();
        let identifier = world.insert(entity!(A(42)));

        let mut entries = unsafe { Entries::<_, _, Views!(Option<&mut A>), _>::new(&mut world) };
        let mut entry = assert_some!(entries.entry(identifier));

        let result!(a) = assert_some!(entry.query(Query::<Views!(&mut A)>::new()));
        assert_eq!(a, &mut A(42));
    }

    #[test]
    fn query_optional_with_optional_super_view() {
        let mut world = World::<Registry>::new();
        let identifier = world.insert(entity!(A(42)));

        let mut entries = unsafe { Entries::<_, _, Views!(Option<&A>), _>::new(&mut world) };
        let mut entry = assert_some!(entries.entry(identifier));

        let result!(a) = assert_some!(entry.query(Query::<Views!(Option<&A>)>::new()));
        assert_eq!(a, Some(&A(42)));
    }

    #[test]
    fn query_optional_with_optional_mutable_super_view() {
        let mut world = World::<Registry>::new();
        let identifier = world.insert(entity!(A(42)));

        let mut entries = unsafe { Entries::<_, _, Views!(Option<&mut A>), _>::new(&mut world) };
        let mut entry = assert_some!(entries.entry(identifier));

        let result!(a) = assert_some!(entry.query(Query::<Views!(Option<&A>)>::new()));
        assert_eq!(a, Some(&A(42)));
    }

    #[test]
    fn query_optional_mutable_with_optional_mutable_super_view() {
        let mut world = World::<Registry>::new();
        let identifier = world.insert(entity!(A(42)));

        let mut entries = unsafe { Entries::<_, _, Views!(Option<&mut A>), _>::new(&mut world) };
        let mut entry = assert_some!(entries.entry(identifier));

        let result!(a) = assert_some!(entry.query(Query::<Views!(Option<&mut A>)>::new()));
        assert_eq!(a, Some(&mut A(42)));
    }
}