lightyear 0.3.0

//! Wrapper around a list where the index is a wrapping key
use std::marker::PhantomData;

use crate::utils::wrapping_id::WrappedId;

/// Fixed size data structure with
/// - constant time insertion
/// - constant time get by key
/// - constant time removal
///
/// The key must be a WrappedId, we update the buffer by using the key modulo the buffer size
/// More optimized than HashMap
#[derive(Debug)]
pub struct SequenceBuffer<K: WrappedId, T, const N: usize> {
    buffer: [Option<T>; N],
    _marker: PhantomData<K>,
}

impl<K: WrappedId, T, const N: usize> Default for SequenceBuffer<K, T, N> {
    fn default() -> Self {
        Self::new()
    }
}

impl<K: WrappedId, T, const N: usize> SequenceBuffer<K, T, N> {
    pub fn new() -> Self {
        Self {
            buffer: std::array::from_fn(|_| None),
            _marker: PhantomData,
        }
    }

    pub fn push(&mut self, key: &K, value: T) {
        let index = self.index(key);
        // TODO: risk that we keep around the previously buffered value
        //  solution would be to clear values between the last insert and K (if K is more recent)
        self.buffer[index] = Some(value);
    }

    pub fn get(&self, key: &K) -> Option<&T> {
        let index = self.index(key);
        self.buffer[index].as_ref()
    }

    pub fn remove(&mut self, key: &K) -> Option<T> {
        let index = self.index(key);
        self.buffer[index].take()
    }

    pub fn clear(&mut self) {
        for i in 0..N {
            self.buffer[i] = None;
        }
    }

    fn index(&self, key: &K) -> usize {
        key.rem(N)
    }
}

#[cfg(test)]
mod tests {
    use crate::packet::message::MessageId;

    use super::*;

    #[test]
    fn test_sequence_buffer() {
        let mut buffer = SequenceBuffer::<MessageId, u8, 32>::new();

        // check basic behaviour
        buffer.push(&MessageId(0), 0);
        assert_eq!(buffer.get(&MessageId(0)), Some(&0));

        assert_eq!(buffer.remove(&MessageId(0)), Some(0));

        // check loop around behaviour
        buffer.push(&MessageId(0), 0);
        buffer.push(&MessageId(32), 1);
        assert_eq!(buffer.get(&MessageId(0)), Some(&1));
    }
}