use std::marker::PhantomData;
use std::ops::Index;
use oximo_expr::Expr;
use rustc_hash::FxHashMap;
use crate::set::{Axis, FromIndexKey, IndexKey};
#[derive(Clone)]
pub(crate) enum Storage<'a> {
Dense { data: Vec<Expr<'a>>, keys: Vec<IndexKey>, axes: Box<[Axis]> },
Sparse(FxHashMap<IndexKey, Expr<'a>>),
}
mod sealed {
pub trait Sealed {}
}
#[doc(hidden)]
pub trait Family: sealed::Sealed {
const NAME: &'static str;
}
#[doc(hidden)]
#[derive(Debug)]
pub struct VarFamily;
#[doc(hidden)]
#[derive(Debug)]
pub struct ParamFamily;
impl sealed::Sealed for VarFamily {}
impl sealed::Sealed for ParamFamily {}
impl Family for VarFamily {
const NAME: &'static str = "IndexedVar";
}
impl Family for ParamFamily {
const NAME: &'static str = "IndexedParam";
}
pub struct IndexedFamily<'a, K = IndexKey, F = VarFamily> {
pub(crate) storage: Storage<'a>,
pub(crate) _marker: PhantomData<fn() -> (K, F)>,
}
pub type IndexedVar<'a, K = IndexKey> = IndexedFamily<'a, K, VarFamily>;
pub type IndexedParam<'a, K = IndexKey> = IndexedFamily<'a, K, ParamFamily>;
impl<'a, K, F> Clone for IndexedFamily<'a, K, F> {
fn clone(&self) -> Self {
Self { storage: self.storage.clone(), _marker: PhantomData }
}
}
impl<'a, K, F: Family> std::fmt::Debug for IndexedFamily<'a, K, F> {
fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
f.debug_struct(F::NAME).field("len", &self.len()).field("dense", &self.is_dense()).finish()
}
}
impl<'a, K, F> IndexedFamily<'a, K, F> {
pub fn len(&self) -> usize {
match &self.storage {
Storage::Dense { data, .. } => data.len(),
Storage::Sparse(m) => m.len(),
}
}
pub fn is_empty(&self) -> bool {
self.len() == 0
}
pub fn is_dense(&self) -> bool {
matches!(self.storage, Storage::Dense { .. })
}
pub fn shape(&self) -> Option<Box<[usize]>> {
match &self.storage {
Storage::Dense { axes, .. } => Some(axes.iter().map(|a| a.len).collect()),
Storage::Sparse(_) => None,
}
}
pub fn iter(&self) -> impl Iterator<Item = (&IndexKey, &Expr<'a>)> + '_ {
let it: Box<dyn Iterator<Item = (&IndexKey, &Expr<'a>)>> = match &self.storage {
Storage::Dense { data, keys, .. } => Box::new(keys.iter().zip(data.iter())),
Storage::Sparse(m) => Box::new(m.iter()),
};
it
}
pub fn get<Q: Into<IndexKey>>(&self, key: Q) -> Option<Expr<'a>> {
match &self.storage {
Storage::Sparse(m) => m.get(&key.into()).copied(),
Storage::Dense { data, axes, .. } => {
grid_offset(axes, &key.into()).map(|off| data[off])
}
}
}
pub fn at<const N: usize>(&self, coords: [usize; N]) -> Expr<'a> {
*self.get_ref(&coords).expect("indexed family: coordinates not present")
}
pub fn get_at<const N: usize>(&self, coords: [usize; N]) -> Option<Expr<'a>> {
self.get_ref(&coords).copied()
}
fn get_ref(&self, coords: &[usize]) -> Option<&Expr<'a>> {
match &self.storage {
Storage::Dense { data, axes, .. } => {
grid_offset_coords(axes, coords).map(|off| &data[off])
}
Storage::Sparse(m) => m.get(&coords_to_key(coords)),
}
}
}
impl<'a, K: FromIndexKey, F> IndexedFamily<'a, K, F> {
pub fn keys(&self) -> impl Iterator<Item = (K, Expr<'a>)> + '_ {
self.iter().map(|(k, e)| (K::from_index_key(k), *e))
}
}
impl<'a, K, F, Q: Into<IndexKey>> Index<Q> for IndexedFamily<'a, K, F> {
type Output = Expr<'a>;
fn index(&self, key: Q) -> &Self::Output {
match &self.storage {
Storage::Sparse(m) => m.get(&key.into()).expect("indexed family: key not present"),
Storage::Dense { data, axes, .. } => {
let off = grid_offset(axes, &key.into()).expect("indexed family: key not present");
&data[off]
}
}
}
}
impl<'a, K, F> Index<&IndexKey> for IndexedFamily<'a, K, F> {
type Output = Expr<'a>;
fn index(&self, key: &IndexKey) -> &Self::Output {
match &self.storage {
Storage::Sparse(m) => m.get(key).expect("indexed family: key not present"),
Storage::Dense { data, axes, .. } => {
let off = grid_offset(axes, key).expect("indexed family: key not present");
&data[off]
}
}
}
}
impl<'a, K, F, const N: usize> Index<[usize; N]> for IndexedFamily<'a, K, F> {
type Output = Expr<'a>;
fn index(&self, coords: [usize; N]) -> &Self::Output {
self.get_ref(&coords).expect("indexed family: coordinates not present")
}
}
pub(crate) fn build_storage<'a>(
keys: Vec<IndexKey>,
axes: Option<Box<[Axis]>>,
mut make: impl FnMut(&IndexKey) -> Expr<'a>,
) -> Storage<'a> {
if let Some(axes) = axes {
let total = keys.len();
let mut data: Vec<Option<Expr<'a>>> = vec![None; total];
let mut kept: Vec<Option<IndexKey>> = vec![None; total];
for key in keys {
let expr = make(&key);
let off = grid_offset(&axes, &key).expect("dense grid key out of range");
data[off] = Some(expr);
kept[off] = Some(key);
}
let data = data.into_iter().map(|o| o.expect("dense grid had a gap")).collect();
let kept = kept.into_iter().map(|o| o.expect("dense grid had a gap")).collect();
Storage::Dense { data, keys: kept, axes }
} else {
let mut entries = FxHashMap::default();
for key in keys {
let expr = make(&key);
entries.insert(key, expr);
}
Storage::Sparse(entries)
}
}
fn axis_index(a: &Axis, v: i64) -> Option<usize> {
let d = v.checked_sub(a.start)?;
let u = usize::try_from(d).ok()?;
(u < a.len).then_some(u)
}
pub(crate) fn grid_offset(axes: &[Axis], key: &IndexKey) -> Option<usize> {
match (axes, key) {
([a], IndexKey::Int(v)) => axis_index(a, *v),
(axes, IndexKey::Tuple(parts)) if parts.len() == axes.len() => {
let mut off = 0usize;
for (a, p) in axes.iter().zip(parts.iter()) {
off = off.checked_mul(a.len)?.checked_add(axis_index(a, p.as_i64()?)?)?;
}
Some(off)
}
_ => None,
}
}
fn grid_offset_coords(axes: &[Axis], coords: &[usize]) -> Option<usize> {
if coords.len() != axes.len() {
return None;
}
let mut off = 0usize;
for (a, &c) in axes.iter().zip(coords) {
off = off * a.len + axis_index(a, i64::try_from(c).ok()?)?;
}
Some(off)
}
fn coords_to_key(coords: &[usize]) -> IndexKey {
if let [single] = coords {
IndexKey::from(*single)
} else {
IndexKey::Tuple(coords.iter().map(|&c| IndexKey::from(c)).collect())
}
}