//! Module providing abstractions for a generational arena implemenation.
//!
//! ## Usage
//! ```
//! #[no_std]
//!
//! use generational_cache::prelude::*;
//!
//! const CAPACITY: usize = 5;
//!
//! let mut arena = Arena::<_, i32>::with_vector(Array::<_, CAPACITY>::new());
//! let index = arena.insert(78).unwrap(); // allocate new element in arena
//! let i_ref = arena.get(&index);
//! assert_eq!(i_ref, Some(&78));
//! let i_m_ref = arena.get_mut(&index).unwrap();
//! *i_m_ref = -68418;
//! assert_eq!(arena.get(&index), Some(&-68418));
//!
//! arena.remove(&index).unwrap();
//!
//! assert!(arena.get(&index).is_none());
//! ```
use crate::vector::Vector;
use core::{
    fmt::{self, Debug, Display},
    marker::PhantomData,
};

/// An generational counter augemented index to track entries.
#[derive(Clone, Copy, PartialEq, Eq, Debug)]
pub struct Index {
    pub generation: u64,
    pub idx: usize,
}

/// An allocation entry in a generational arena.
#[derive(Clone, Copy, PartialEq, Eq, Debug)]
pub enum Entry<T> {
    Occupied { value: T, generation: u64 },
    Free { next_free_idx: Option<usize> },
    Unmapped,
}

impl<T> Default for Entry<T> {
    fn default() -> Self {
        Self::Unmapped
    }
}

/// A generational arena for allocating memory based off a vector. Every
/// entry is associated with a generation counter to uniquely identify
/// newer allocations from older reclaimed allocations at the same
/// position in the vector.
///
/// This is inspired from the crate
/// ["generational-arena"](https://docs.rs/generational-arena)
///
/// ## Usage
/// ```
/// #[no_std]
///
/// use generational_cache::prelude::*;
///
/// const CAPACITY: usize = 5;
///
/// let mut arena = Arena::<_, i32>::with_vector(Array::<_, CAPACITY>::new());
/// let index = arena.insert(78).unwrap(); // allocate new element in arena
/// let i_ref = arena.get(&index);
/// assert_eq!(i_ref, Some(&78));
/// let i_m_ref = arena.get_mut(&index).unwrap();
/// *i_m_ref = -68418;
/// assert_eq!(arena.get(&index), Some(&-68418));
///
/// arena.remove(&index).unwrap();
///
/// assert!(arena.get(&index).is_none());
/// ```
pub struct Arena<V, T> {
    entries_vec: V,
    generation: u64,
    free_list_head: Option<usize>,

    len: usize,
    capacity: usize,

    _phantom_type: PhantomData<T>,
}

#[derive(Debug)]
pub enum ArenaError<VE> {
    OutOfMemory,
    InvalidIdx,
    VectorError(VE),
}

impl<VE> Display for ArenaError<VE>
where
    VE: Debug,
{
    fn fmt(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result {
        write!(f, "{self:?}")
    }
}

/// A generational arena.
impl<V, T> Arena<V, T>
where
    V: Vector<Entry<T>>,
{
    pub fn reserve(&mut self, additional: usize) -> Result<(), ArenaError<V::Error>> {
        let reserve_start = self.entries_vec.len();
        let old_head = self.free_list_head;

        self.entries_vec
            .reserve(additional)
            .map_err(ArenaError::VectorError)?;

        for i in 0..additional {
            let free_idx = i + reserve_start;

            let next_free_idx = if i < additional - 1 {
                Some(free_idx + 1)
            } else {
                old_head
            };

            let free_entry = Entry::Free { next_free_idx };
            self.entries_vec
                .push(free_entry)
                .map_err(ArenaError::VectorError)?;
        }

        self.free_list_head = Some(reserve_start);

        self.capacity += additional;

        Ok(())
    }

    pub fn clear(&mut self) -> Result<(), ArenaError<V::Error>> {
        self.free_list_head = Some(0);
        self.generation = 0;
        self.len = 0;

        self.entries_vec.clear();

        let capacity = self.capacity();

        for i in 0..capacity {
            let next_free_idx = i + 1;
            let next_free_idx = if next_free_idx < capacity {
                Some(next_free_idx)
            } else {
                None
            };

            let free_entry = Entry::Free { next_free_idx };
            self.entries_vec
                .push(free_entry)
                .map_err(ArenaError::VectorError)?;
        }

        Ok(())
    }

    pub fn with_vector(vector: V) -> Self {
        let capacity = vector.capacity();

        let mut arena = Self {
            entries_vec: vector,
            generation: 0,
            free_list_head: Some(0),
            len: 0,
            capacity,
            _phantom_type: PhantomData,
        };

        arena.clear().unwrap();

        arena
    }

    pub fn insert(&mut self, item: T) -> Result<Index, ArenaError<V::Error>> {
        let old_free = self.free_list_head.ok_or(ArenaError::OutOfMemory)?;

        self.free_list_head = self
            .entries_vec
            .get(old_free)
            .map(|x| match x {
                Entry::Free { next_free_idx } => *next_free_idx,
                _ => None,
            })
            .ok_or(ArenaError::InvalidIdx)?;

        let entry = Entry::Occupied {
            value: item,
            generation: self.generation,
        };

        *self
            .entries_vec
            .get_mut(old_free)
            .ok_or(ArenaError::InvalidIdx)? = entry;
        self.generation += 1;

        self.len += 1;

        Ok(Index {
            generation: self.generation - 1,
            idx: old_free,
        })
    }

    pub fn remove(&mut self, index: &Index) -> Option<T> {
        match self.entries_vec.get(index.idx) {
            Some(Entry::Occupied {
                value: _,
                generation,
            }) if &index.generation == generation => {
                let new_free_list_head_entry = Entry::<T>::Free {
                    next_free_idx: self.free_list_head,
                };

                let old_entry = core::mem::replace(
                    self.entries_vec.get_mut(index.idx)?,
                    new_free_list_head_entry,
                );

                self.free_list_head = Some(index.idx);

                self.len -= 1;

                Some(old_entry)
            }
            _ => None,
        }
        .and_then(|x| match x {
            Entry::Occupied {
                value,
                generation: _,
            } => Some(value),
            _ => None,
        })
    }

    pub fn get_mut(&mut self, index: &Index) -> Option<&mut T> {
        match self.entries_vec.get_mut(index.idx) {
            Some(Entry::Occupied { value, generation }) if &index.generation == generation => {
                Some(value)
            }
            _ => None,
        }
    }

    pub fn get(&self, index: &Index) -> Option<&T> {
        match self.entries_vec.get(index.idx) {
            Some(Entry::Occupied { value, generation }) if &index.generation == generation => {
                Some(value)
            }
            _ => None,
        }
    }

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

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

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

#[doc(hidden)]
pub mod tests {
    use super::{Arena, Entry, Index, Vector};
    use core::{cmp::PartialEq, fmt::Debug};

    pub fn _test_arena_free_entries_init<T, V>(mut arena: Arena<V, T>)
    where
        V: Vector<Entry<T>>,
        T: Debug + PartialEq,
    {
        arena.clear().unwrap();

        assert_eq!(arena.free_list_head, Some(0));

        let capacity = arena.capacity();

        for i in 0..capacity {
            let entry = &arena.entries_vec[i];

            if i == capacity - 1 {
                assert_eq!(
                    entry,
                    &Entry::Free {
                        next_free_idx: None
                    }
                )
            } else {
                assert_eq!(
                    entry,
                    &Entry::Free {
                        next_free_idx: Some(i + 1)
                    }
                )
            };
        }
    }

    pub fn _test_arena_reserve<T, V>(mut arena: Arena<V, T>)
    where
        V: Vector<Entry<T>>,
        T: Debug + PartialEq,
    {
        arena.clear().unwrap();

        let old_capacity = arena.capacity();

        const ADDITIONAL: usize = 5;

        let result = arena.reserve(ADDITIONAL);

        if result.is_err() {
            return;
        }

        assert_eq!(arena.free_list_head, Some(old_capacity));

        let capacity = arena.capacity();

        for i in 0..capacity {
            let entry = &arena.entries_vec[i];

            if i == capacity - 1 {
                assert_eq!(
                    entry,
                    &Entry::Free {
                        next_free_idx: Some(0)
                    }
                )
            } else if i == old_capacity - 1 {
                assert_eq!(
                    entry,
                    &Entry::Free {
                        next_free_idx: None
                    }
                )
            } else {
                assert_eq!(
                    entry,
                    &Entry::Free {
                        next_free_idx: Some(i + 1)
                    }
                )
            };
        }
    }

    pub fn _test_arena_insert<V>(mut arena: Arena<V, i32>)
    where
        V: Vector<Entry<i32>>,
    {
        assert!(
            arena.capacity() >= 2,
            "Test not valid for arena with capacity < 2"
        );

        arena.clear().unwrap();

        let index_0 = arena.insert(0);
        assert_eq!(
            index_0.as_ref().unwrap(),
            &Index {
                generation: 0,
                idx: 0
            }
        );

        let index_1 = arena.insert(1);
        assert_eq!(
            index_1.as_ref().unwrap(),
            &Index {
                generation: 1,
                idx: 1
            }
        );

        let index_0_val = index_0.as_ref().unwrap();
        let item_0 = arena.get(index_0_val);
        assert_eq!(item_0, Some(&0));

        let index_1_val = index_1.unwrap();
        let item_1 = arena.get(&index_1_val);
        assert_eq!(item_1, Some(&1));

        let item_0 = arena.get_mut(index_0_val);
        assert_eq!(item_0, Some(&mut 0));
        let item_0 = item_0.unwrap();
        *item_0 = 25;

        let item_0 = arena.get(index_0_val);
        assert_eq!(item_0, Some(&25));

        let item_1 = arena.get_mut(&index_1_val);
        assert_eq!(item_1, Some(&mut 1));
        let item_1 = item_1.unwrap();
        *item_1 = -78;

        let item_1 = arena.get(&index_1_val);
        assert_eq!(item_1, Some(&-78));

        let last_len = arena.len();

        let remaining = arena.capacity() - last_len;

        for i in 0..remaining {
            let possible_idx = last_len + i;

            assert_eq!(
                arena.insert(0).unwrap(),
                Index {
                    generation: possible_idx as u64,
                    idx: possible_idx
                }
            )
        }

        const ADDITIONAL: usize = 5;

        let result = arena.reserve(ADDITIONAL);

        if result.is_ok() {
            for _ in 0..ADDITIONAL {
                arena.insert(0).unwrap();
            }
        }

        arena.clear().unwrap();

        assert!(arena.is_empty());
    }

    pub fn _test_arena_remove<V>(mut arena: Arena<V, i32>)
    where
        V: Vector<Entry<i32>>,
    {
        assert!(
            arena.capacity() >= 2,
            "Test not valid for arena with capacity < 2"
        );

        arena.clear().unwrap();

        assert_eq!(arena.free_list_head.unwrap(), 0);

        let index = arena.insert(0).unwrap();
        assert_eq!(arena.get(&index), Some(&0));
        assert_eq!(
            index,
            Index {
                generation: 0,
                idx: 0
            }
        );

        assert_eq!(arena.free_list_head.unwrap(), 1);

        assert_eq!(arena.remove(&index).unwrap(), 0);
        assert_eq!(arena.get(&index), None);

        assert_eq!(arena.free_list_head.unwrap(), 0);

        let index = arena.insert(0).unwrap();
        assert_eq!(arena.get(&index), Some(&0));
        assert_eq!(
            index,
            Index {
                generation: 1,
                idx: 0
            }
        );

        assert_eq!(arena.free_list_head.unwrap(), 1);

        let last_arena_len = arena.len();
        let remaining = arena.capacity() - last_arena_len;

        let current_generation = index.generation + 1;

        for i in 0..remaining {
            let index = arena.insert(i as i32).unwrap();
            assert_eq!(
                index,
                Index {
                    generation: current_generation + i as u64,
                    idx: last_arena_len + i
                }
            );
        }

        // remove elements at odd indices
        let mut i = 1;
        let mut removed_count = 0;
        while i < arena.capacity() {
            arena
                .remove(&Index {
                    generation: i as u64 + 1,
                    idx: i,
                })
                .unwrap();

            i += 2;
            removed_count += 1;
        }

        // iterate through free list
        let mut free_position_count = 0;
        let mut free_idx = arena.free_list_head;

        while let Some(next_free) = free_idx {
            assert_eq!(next_free & 1, 1);
            free_idx = match arena.entries_vec[next_free] {
                Entry::Free { next_free_idx } => next_free_idx,
                _ => None,
            };
            free_position_count += 1;
        }

        assert_eq!(removed_count, free_position_count);

        arena.clear().unwrap();

        assert!(arena.is_empty());
    }
}