pipecircuit 0.0.2

//! [`WarpTable`]: bounded, primary-indexed columnar storage.
//!
//! [`WarpTable`] reserves its declared capacity at construction, stores each
//! row field in an aligned dense column, and keeps primary lookup synchronized
//! with swap-remove relocation. [`WarpTableRow`] derives that physical storage
//! from an ordinary logical row type. Unless a caller-owned primary type is
//! declared, insertion returns a generated [`WarpId<Row>`].
//!
//! Fields marked `#[index(secondary)]` receive independent equality indexes;
//! fields marked `#[index(range)]` receive bit-sliced numeric range indexes.
//! Both may be declared on one field. Lookups return opaque `Selection`
//! values. Selections compose before row access, so unions, intersections,
//! exclusions, and unions excluding overlap neither scan nor copy logical
//! rows. Calling `Selection::rows` resolves the final membership into flat
//! generated row references containing `id` beside every field declared by
//! the logical row.
//!
//! The optional `Brand` parameter names one stable-membership universe. The
//! row type is the convenient default; distinct stores of the same row type
//! can supply distinct zero-sized brands so Rust rejects cross-store algebra.
//!
//! # Example
//!
//! ```
//! # #[cfg(feature = "secondary-indexes")]
//! # mod example {
//! use core::num::NonZeroU32;
//! use pipecircuit::storage::warp_table::{
//!     Capacity, WarpTableRow, WarpTable, WarpTableInsertOutcome,
//!     MutableSelectionForEachOutcome,
//! };
//!
//! #[derive(WarpTableRow)]
//! struct Pet {
//!     name: &'static str,
//!     #[index(secondary, range)]
//!     age: u8,
//!     #[index(secondary)]
//!     species: u8,
//! }
//!
//! enum Shelter {}
//!
//! # pub fn run() -> Result<(), &'static str> {
//! let Some(maximum_rows) = NonZeroU32::new(3) else {
//!     return Err("zero capacity");
//! };
//! let capacity = Capacity::new(maximum_rows);
//! let Ok(mut pets) = WarpTable::<Pet, Shelter>::try_new(capacity) else {
//!     return Err("pet storage unavailable");
//! };
//!
//! let WarpTableInsertOutcome::Inserted { key: luna_id, .. } =
//!     pets.insert(Pet { name: "Luna", age: 5, species: 1 }) else {
//!     return Err("Luna could not be inserted");
//! };
//! let WarpTableInsertOutcome::Inserted { .. } =
//!     pets.insert(Pet { name: "Milo", age: 5, species: 2 }) else {
//!     return Err("Milo could not be inserted");
//! };
//! let WarpTableInsertOutcome::Inserted { .. } =
//!     pets.insert(Pet { name: "Suki", age: 7, species: 1 }) else {
//!     return Err("Suki could not be inserted");
//! };
//!
//! let documented_ages = pets.query().find_age(5)
//!     .or(|pets| pets.find_age(7));
//! let school_age_cats = pets.query().find_age_in(5..=7)
//!     .map_err(|_| "age range index inconsistent")?
//!     .and(|pets| pets.find_species(1));
//! let five_year_old_cats = pets.query().find_species(1)
//!     .and(|pets| pets.find_age(5));
//! let five_year_old_non_dogs = pets.query().find_age(5)
//!     .and_not(|pets| pets.find_species(2));
//! let cats_or_five_year_olds_but_not_both = pets.query().find_species(1)
//!     .xor(|pets| pets.find_age(5));
//! let cats = pets.query().find_species(1);
//! let dogs = pets.query().find_species(2);
//! assert_eq!(documented_ages.len(), 3);
//! assert_eq!(school_age_cats.len(), 2);
//! assert_eq!(five_year_old_cats.len(), 1);
//! assert_eq!(five_year_old_non_dogs.len(), 1);
//! assert_eq!(cats_or_five_year_olds_but_not_both.len(), 2);
//! assert!(cats.is_disjoint(&dogs));
//!
//! let mut matches = five_year_old_cats.rows();
//! let Some(pet) = matches.next() else {
//!     return Err("matching pet unavailable");
//! };
//! assert_eq!(*pet.id, luna_id);
//! assert_eq!((pet.name, pet.age, pet.species), (&"Luna", &5, &1));
//! assert!(matches.next().is_none());
//! assert_eq!(
//!     pets.query_mut().find_species(1)
//!         .and(|pets| pets.find_age(5))
//!         .for_each(|mut pet| {
//!             let _ = pet.set_age(8);
//!         }),
//!     MutableSelectionForEachOutcome::Updated { rows: 1 },
//! );
//! assert_eq!(pets.query().find_age(8).len(), 1);
//! # Ok(())
//! # }
//! # }
//! # #[cfg(feature = "secondary-indexes")]
//! # fn main() -> Result<(), &'static str> { example::run() }
//! # #[cfg(not(feature = "secondary-indexes"))]
//! # fn main() {}
//! ```

#[cfg(feature = "secondary-indexes")]
pub use pipecircuit_macros::RangeIndexKey;
pub use pipecircuit_macros::WarpTableRow;

#[doc(hidden)]
pub mod __private {
    pub use super::inconsistency::invariant_violation;
    #[cfg(feature = "secondary-indexes")]
    pub use super::query::{
        bind_detached_range_lookup, bind_detached_secondary_lookup, bind_mutable_range_lookup,
        bind_mutable_secondary_lookup, bind_range_lookup, bind_secondary_lookup,
        own_secondary_membership,
    };
    #[cfg(feature = "secondary-indexes")]
    pub use super::secondary_index::{
        PreparedRangeIndexInsert, PreparedRangeIndexMove, PreparedRangeIndexRemove,
        PreparedSecondaryIndexInsert, PreparedSecondaryIndexMove, PreparedSecondaryIndexRemove,
        PreparedSlotSetInsert, PreparedStableSlotInsert, PreparedStableSlotRemove, RangeIndex,
        RangeIndexCreationError, RangeIndexInconsistency, RangeIndexInsertError,
        RangeIndexInsertOutcome, RangeIndexMembership, RangeIndexMoveError, RangeIndexMoveOutcome,
        RangeIndexRemoveError, RangeIndexRemoveOutcome, SecondaryIndex,
        SecondaryIndexCommitRemoveOutcome, SecondaryIndexCreationError,
        SecondaryIndexInconsistency, SecondaryIndexInsertError, SecondaryIndexInsertOutcome,
        SecondaryIndexMembership, SecondaryIndexMoveError, SecondaryIndexMoveOutcome,
        SecondaryIndexPrepareRemoveOutcome, SecondaryIndexRemoveError, SecondaryIndexRemoveOutcome,
        SecondaryIndexRemoveResult, SlotSet, SlotSetInsertError, SlotSetInsertOutcome,
        SlotSetRemoveOutcome, SlotSetSlots, StableSlot, StableSlotInsertError,
        StableSlotRemoveOutcome, StableSlotResolutions, StableSlotResolveOutcome,
        StableSlotResolver, StableSlotRowRelocation, StableSlots, StableSlotsCreationError,
        StableSlotsInconsistency,
    };
    pub use alloc::{collections::TryReserveError, vec::Vec};
}

mod creation;
mod dense_key_index;
mod get;
mod id;
mod inconsistency;
mod insert;
mod query;
mod remove;
mod replace;
mod row;
mod rows;
#[cfg(feature = "secondary-indexes")]
mod secondary_index;
mod update;
mod upsert;

pub use creation::{Capacity, WarpTableCreationError};
use dense_key_index::DenseKeyIndex;
pub use get::{WarpTableGetAtOutcome, WarpTableGetOutcome};
pub use id::{WarpId, integer_index_word, sequential_index_word};
pub use inconsistency::WarpTableInconsistency;
pub use insert::{WarpTableInsertAllOutcome, WarpTableInsertOutcome, WarpTableInsertWithIdOutcome};
#[cfg(feature = "secondary-indexes")]
#[doc(hidden)]
pub use query::SelectionOperand;
#[cfg(feature = "secondary-indexes")]
#[doc(hidden)]
pub use query::{
    DetachedRangeIndexLookupOutcome, DetachedSecondaryIndexLookupOutcome, DetachedSelection,
    MutableSelectionOperand,
};
#[cfg(feature = "secondary-indexes")]
pub use query::{
    MutableRangeIndexLookupOutcome, MutableSecondaryIndexLookupOutcome, MutableSelection,
    MutableSelectionForEachOutcome, RangeIndexLookupOutcome, SecondaryIndexLookupOutcome,
    Selection, SelectionMembershipInconsistency, SelectionRows,
};
pub use remove::{WarpTableRemoveOutcome, WarpTableRowRelocation};
pub use replace::WarpTableReplaceOutcome;
pub use row::{
    IndexKey, WarpTableRow, WarpTableRowGetError, WarpTableRowGetOutcome, WarpTableRowReplaceError,
    WarpTableRowReplaceOutcome,
};
pub use rows::WarpTableRows;
#[cfg(feature = "secondary-indexes")]
pub use secondary_index::SecondaryIndexInconsistency;
#[cfg(feature = "secondary-indexes")]
pub use secondary_index::{
    RangeIndexBounds, RangeIndexCreationError, RangeIndexInconsistency, RangeIndexInsertFailure,
    RangeIndexKey, RangeIndexLookupError, RangeIndexMoveFailure, RangeIndexRemoveFailure,
    SecondaryIndexInsertFailure, SecondaryIndexMoveFailure, SecondaryIndexRemoveFailure,
    StableMembershipInsertFailure,
};
pub use update::WarpTableUpdateOutcome;
pub use upsert::WarpTableUpsertOutcome;

pub struct WarpTable<Row: WarpTableRow, Brand = Row> {
    capacity: Capacity,
    maximum_rows: usize,
    len: usize,
    next_id: Option<core::num::NonZeroU64>,
    primary_keys: __private::Vec<Row::Key>,
    columns: Row::Columns,
    indexes: Row::Indexes,
    primary_index: DenseKeyIndex,
    brand: core::marker::PhantomData<fn() -> Brand>,
}

impl<Row: WarpTableRow, Brand> WarpTable<Row, Brand> {
    pub const fn capacity(&self) -> Capacity {
        self.capacity
    }

    pub const fn len(&self) -> usize {
        self.len
    }

    pub const fn is_empty(&self) -> bool {
        self.len == 0
    }

    pub fn primary_keys(&self) -> &[Row::Key] {
        &self.primary_keys
    }

    /// Borrows the physical columns for read-only, column-oriented traversal.
    ///
    /// Mutation remains behind indexed operations so a primary key cannot be
    /// changed without keeping the index synchronized.
    pub const fn columns(&self) -> &Row::Columns {
        &self.columns
    }

    #[doc(hidden)]
    pub const fn __indexes(&self) -> &Row::Indexes {
        &self.indexes
    }
}

#[cfg(test)]
mod derive_tests;
#[cfg(test)]
mod tests;