webgraph 0.6.1

/*
 * SPDX-FileCopyrightText: 2025 Sebastiano Vigna
 * SPDX-FileCopyrightText: 2025 Tommaso Fontana
 *
 * SPDX-License-Identifier: Apache-2.0 OR LGPL-2.1-or-later
 */

use super::bvgraph::EF;
use crate::traits::*;
use common_traits::UnsignedInt;
use epserde::Epserde;
use lender::{IntoLender, Lend, Lender, Lending, check_covariance, for_};
use sux::{
    bits::BitFieldVec,
    dict::EliasFanoBuilder,
    rank_sel::{SelectAdaptConst, SelectZeroAdaptConst},
};
use value_traits::{
    iter::{IterFrom, IterateByValueFrom},
    slices::SliceByValue,
};

/// A [`CsrGraph`] with Elias–Fano-encoded degree cumulative function and
/// [`BitFieldVec`]-encoded successors.
pub type CompressedCsrGraph = CsrGraph<EF, BitFieldVec>;

/// A [`CsrSortedGraph`] with Elias–Fano-encoded degree cumulative function and
/// [`BitFieldVec`]-encoded successors.
pub type CompressedCsrSortedGraph = CsrSortedGraph<EF, BitFieldVec>;

/// A compressed sparse-row graph.
///
/// It is a graph representation that stores the degree cumulative function
/// (DCF) and the successors in a compressed format. The DCF is a sequence of
/// offsets that indicates the start of the neighbors for each node in the
/// graph. Building a CSR graph requires always a sorted lender.
///
/// The lenders returned by a CSR graph are sorted; however, the successors may
/// be unsorted. If you need the additional guarantee that the successors are
/// sorted, use [`CsrSortedGraph`], which however requires a lender returning
/// sorted successors.
///
/// Depending on the performance and memory requirements, both the DCF and
/// successors can be stored in different formats. The default is to use boxed
/// slices for both the DCF and successors, which is the fastest choice.
///
/// A [`CompressedCsrGraph`], instead, is a [`CsrGraph`] where the DCF is
/// represented using an Elias-Fano encoding, and the successors are represented
/// using a [`BitFieldVec`]. There is also a [version with sorted
/// successors](CompressedCsrSortedGraph). Their construction requires a
/// sequential graph providing the number of arcs.
#[derive(Debug, Clone, Epserde)]
#[cfg_attr(feature = "serde", derive(serde::Serialize, serde::Deserialize))]
pub struct CsrGraph<DCF = Box<[usize]>, S = Box<[usize]>> {
    dcf: DCF,
    successors: S,
}

/// A wrapper for a [`CsrGraph`] with the additional guarantee that the
/// successors are sorted.
#[derive(Debug, Clone, Epserde)]
#[cfg_attr(feature = "serde", derive(serde::Serialize, serde::Deserialize))]
pub struct CsrSortedGraph<DCF = Box<[usize]>, S = Box<[usize]>>(CsrGraph<DCF, S>);

impl<DCF, S> CsrGraph<DCF, S> {
    /// Creates a new CSR graph from the given degree cumulative function and
    /// successors.
    ///
    /// # Safety
    /// The degree cumulative function must be monotone and coherent with the
    /// successors.
    pub unsafe fn from_parts(dcf: DCF, successors: S) -> Self {
        Self { dcf, successors }
    }

    /// Returns a reference to the degree cumulative function.
    #[inline(always)]
    pub fn dcf(&self) -> &DCF {
        &self.dcf
    }

    /// Returns a reference to the successors.
    #[inline(always)]
    pub fn successors(&self) -> &S {
        &self.successors
    }

    /// Consumes the graph, returning the degree cumulative function and
    /// the successors.
    #[inline(always)]
    pub fn into_inner(self) -> (DCF, S) {
        (self.dcf, self.successors)
    }
}

impl core::default::Default for CsrGraph {
    fn default() -> Self {
        Self {
            dcf: vec![0].into(),
            successors: vec![].into(),
        }
    }
}

impl CsrGraph {
    /// Creates an empty CSR graph.
    pub fn new() -> Self {
        Self::default()
    }

    /// Internal method to create a graph from a lender with optional size hints.
    ///
    /// The `num_nodes_hint` and `num_arcs_hint` parameters are used to
    /// pre-allocate the vectors, improving performance when the sizes are known
    /// in advance.
    fn _from_lender<I: IntoLender>(
        iter_nodes: I,
        num_nodes_hint: Option<usize>,
        num_arcs_hint: Option<usize>,
    ) -> Self
    where
        I::Lender: for<'next> NodeLabelsLender<'next, Label = usize> + SortedLender,
    {
        let mut max_node = 0;
        let mut dcf = Vec::with_capacity(num_nodes_hint.unwrap_or(0) + 1);
        dcf.push(0);
        let mut successors = Vec::with_capacity(num_arcs_hint.unwrap_or(0));

        let mut last_src = 0;
        for_!( (src, succs) in iter_nodes {
            while last_src < src {
                dcf.push(successors.len());
                last_src += 1;
            }
            max_node = max_node.max(src);
            for succ in succs {
                successors.push(succ);
                max_node = max_node.max(succ);
            }
        });
        for _ in last_src..=max_node {
            dcf.push(successors.len());
        }
        dcf.shrink_to_fit();
        successors.shrink_to_fit();
        unsafe { Self::from_parts(dcf.into(), successors.into()) }
    }

    /// Creates a new CSR graph from an [`IntoLender`] yielding a
    /// [`NodeLabelsLender`].
    ///
    /// This method will determine the number of nodes from the maximum node ID
    /// encountered.
    pub fn from_lender<I: IntoLender>(iter_nodes: I) -> Self
    where
        I::Lender: for<'next> NodeLabelsLender<'next, Label = usize> + SortedLender,
    {
        Self::_from_lender(iter_nodes, None, None)
    }

    /// Creates a new CSR graph from a sorted [`IntoLender`] yielding a
    /// sorted [`NodeLabelsLender`].
    ///
    /// This method is an alias for [`from_lender`](Self::from_lender), as both
    /// sorted and unsorted lenders are handled identically in the unsorted case.
    pub fn from_sorted_lender<I: IntoLender>(iter_nodes: I) -> Self
    where
        I::Lender: for<'next> NodeLabelsLender<'next, Label = usize> + SortedLender,
        for<'succ> LenderIntoIter<'succ, I::Lender>: SortedIterator,
    {
        Self::from_lender(iter_nodes)
    }

    /// Creates a new CSR graph from a [`SequentialGraph`].
    ///
    /// This method uses the graph's size hints for efficient pre-allocation.
    pub fn from_seq_graph<G: SequentialGraph>(g: &G) -> Self
    where
        for<'a> G::Lender<'a>: SortedLender,
    {
        Self::_from_lender(
            g.iter(),
            Some(g.num_nodes()),
            g.num_arcs_hint().map(|n| n as usize),
        )
    }
}

impl CsrSortedGraph {
    /// Creates a new sorted CSR graph from an [`IntoLender`] yielding a sorted
    /// [`NodeLabelsLender`] with sorted successors.
    pub fn from_lender<I: IntoLender>(iter_nodes: I) -> Self
    where
        I::Lender: for<'next> NodeLabelsLender<'next, Label = usize> + SortedLender,
        for<'succ> LenderIntoIter<'succ, I::Lender>: SortedIterator,
    {
        CsrSortedGraph(CsrGraph::from_lender(iter_nodes))
    }

    /// Creates a new sorted CSR graph from a [`SequentialGraph`] with
    /// sorted lenders and sorted successors.
    pub fn from_seq_graph<G: SequentialGraph>(g: &G) -> Self
    where
        for<'a> G::Lender<'a>: SortedLender,
        for<'a, 'b> LenderIntoIter<'b, G::Lender<'a>>: SortedIterator,
    {
        CsrSortedGraph(CsrGraph::from_seq_graph(g))
    }
}

impl CompressedCsrGraph {
    /// Creates a new compressed CSR graph from a sequential graph with sorted
    /// lender and providing the number of arcs.
    ///
    /// This method will return an error if the graph does not provide
    /// the number of arcs.
    pub fn try_from_graph<G: SequentialGraph>(g: &G) -> anyhow::Result<Self>
    where
        for<'a> G::Lender<'a>: SortedLender,
    {
        let n = g.num_nodes();
        let u = g.num_arcs_hint().ok_or(anyhow::Error::msg(
            "This sequential graph does not provide the number of arcs",
        ))?;
        let mut efb = EliasFanoBuilder::new(n + 1, u as usize + 1);
        efb.push(0);
        let mut successors = BitFieldVec::with_capacity(
            if n == 0 { 0 } else { n.ilog2_ceil() as usize },
            u as usize,
        );
        let mut last_src = 0;
        for_!((src, succ) in g.iter() {
            while last_src < src {
                efb.push(successors.len());
                last_src += 1;
            }
            successors.extend(succ);
        });
        for _ in last_src..g.num_nodes() {
            efb.push(successors.len());
        }
        let ef = efb.build();
        let ef: EF = unsafe { ef.map_high_bits(SelectAdaptConst::<_, _, 12, 4>::new) };
        unsafe { Ok(Self::from_parts(ef, successors)) }
    }
}

impl CompressedCsrSortedGraph {
    /// Creates a new compressed CSR sorted graph from a sequential graph with
    /// sorted lender, sorted successors, and providing the number of arcs.
    ///
    /// This method will return an error if the graph does not provide
    /// the number of arcs.
    pub fn try_from_graph<G: SequentialGraph>(g: &G) -> anyhow::Result<Self>
    where
        for<'a> G::Lender<'a>: SortedLender,
        for<'a, 'b> LenderIntoIter<'b, G::Lender<'a>>: SortedIterator,
    {
        Ok(CsrSortedGraph(CsrGraph::try_from_graph(g)?))
    }
}

/// Convenience implementation that makes it possible to iterate
/// over the graph using the [`for_`] macro
/// (see the [crate documentation](crate)).
impl<'a, DCF, S> IntoLender for &'a CsrGraph<DCF, S>
where
    DCF: SliceByValue + IterateByValueFrom<Item = usize>,
    S: SliceByValue + IterateByValueFrom<Item = usize>,
{
    type Lender = NodeLabels<IterFrom<'a, DCF>, IterFrom<'a, S>>;

    #[inline(always)]
    fn into_lender(self) -> Self::Lender {
        self.iter()
    }
}

/// Convenience implementation that makes it possible to iterate
/// over the graph using the [`for_`] macro
/// (see the [crate documentation](crate)).
impl<'a, DCF, S> IntoLender for &'a CsrSortedGraph<DCF, S>
where
    DCF: SliceByValue + IterateByValueFrom<Item = usize>,
    S: SliceByValue + IterateByValueFrom<Item = usize>,
{
    type Lender = <Self as SequentialLabeling>::Lender<'a>;

    #[inline(always)]
    fn into_lender(self) -> Self::Lender {
        self.iter()
    }
}

impl<DCF, S> SequentialLabeling for CsrGraph<DCF, S>
where
    DCF: SliceByValue + IterateByValueFrom<Item = usize>,
    S: SliceByValue + IterateByValueFrom<Item = usize>,
{
    type Label = usize;
    type Lender<'a>
        = NodeLabels<IterFrom<'a, DCF>, IterFrom<'a, S>>
    where
        Self: 'a;

    #[inline(always)]
    fn num_nodes(&self) -> usize {
        self.dcf.len() - 1
    }

    #[inline(always)]
    fn num_arcs_hint(&self) -> Option<u64> {
        Some(self.successors.len() as u64)
    }

    #[inline(always)]
    fn iter_from(&self, from: usize) -> Self::Lender<'_> {
        let mut offsets_iter = self.dcf.iter_value_from(from);
        // skip the first offset, we don't start from `from + 1`
        // because it might not exist
        let offset = offsets_iter.next().unwrap_or(0);

        NodeLabels {
            node: from,
            last_offset: offset,
            current_offset: offset,
            offsets_iter,
            successors_iter: self.successors.iter_value_from(offset),
        }
    }

    fn build_dcf(&self) -> crate::graphs::bvgraph::DCF {
        let n = self.num_nodes();
        let num_arcs = self.num_arcs_hint().unwrap() as usize;
        let mut efb = EliasFanoBuilder::new(n + 1, num_arcs);
        for val in self.dcf.iter_value_from(0).take(n + 1) {
            efb.push(val);
        }
        unsafe {
            efb.build().map_high_bits(|high_bits| {
                SelectZeroAdaptConst::<_, _, 12, 4>::new(SelectAdaptConst::<_, _, 12, 4>::new(
                    high_bits,
                ))
            })
        }
    }
}

impl<DCF, S> SequentialLabeling for CsrSortedGraph<DCF, S>
where
    DCF: SliceByValue + IterateByValueFrom<Item = usize>,
    S: SliceByValue + IterateByValueFrom<Item = usize>,
{
    type Label = usize;
    type Lender<'a>
        = LenderSortedImpl<IterFrom<'a, DCF>, IterFrom<'a, S>>
    where
        Self: 'a;

    #[inline(always)]
    fn num_nodes(&self) -> usize {
        self.0.num_nodes()
    }

    #[inline(always)]
    fn num_arcs_hint(&self) -> Option<u64> {
        self.0.num_arcs_hint()
    }

    #[inline(always)]
    fn iter_from(&self, from: usize) -> Self::Lender<'_> {
        LenderSortedImpl(self.0.iter_from(from))
    }

    fn build_dcf(&self) -> crate::graphs::bvgraph::DCF {
        self.0.build_dcf()
    }
}

impl<D, S> SequentialGraph for CsrGraph<D, S>
where
    D: SliceByValue + IterateByValueFrom<Item = usize>,
    S: SliceByValue + IterateByValueFrom<Item = usize>,
{
}

impl<D, S> SequentialGraph for CsrSortedGraph<D, S>
where
    D: SliceByValue + IterateByValueFrom<Item = usize>,
    S: SliceByValue + IterateByValueFrom<Item = usize>,
{
}

impl<DCF, S> RandomAccessLabeling for CsrGraph<DCF, S>
where
    DCF: SliceByValue<Value = usize> + IterateByValueFrom<Item = usize>,
    S: SliceByValue<Value = usize> + IterateByValueFrom<Item = usize>,
{
    type Labels<'succ>
        = core::iter::Take<IterFrom<'succ, S>>
    where
        Self: 'succ;

    #[inline(always)]
    fn num_arcs(&self) -> u64 {
        self.successors.len() as u64
    }

    #[inline(always)]
    fn outdegree(&self, node: usize) -> usize {
        self.dcf.index_value(node + 1) - self.dcf.index_value(node)
    }

    #[inline(always)]
    fn labels(&self, node: usize) -> <Self as RandomAccessLabeling>::Labels<'_> {
        let start = self.dcf.index_value(node);
        let end = self.dcf.index_value(node + 1);
        self.successors.iter_value_from(start).take(end - start)
    }
}

impl<DCF, S> RandomAccessLabeling for CsrSortedGraph<DCF, S>
where
    DCF: SliceByValue<Value = usize> + IterateByValueFrom<Item = usize>,
    S: SliceByValue<Value = usize> + IterateByValueFrom<Item = usize>,
{
    type Labels<'succ>
        = AssumeSortedIterator<core::iter::Take<IterFrom<'succ, S>>>
    where
        Self: 'succ;

    #[inline(always)]
    fn num_arcs(&self) -> u64 {
        self.0.num_arcs()
    }

    #[inline(always)]
    fn outdegree(&self, node: usize) -> usize {
        self.0.outdegree(node)
    }

    #[inline(always)]
    fn labels(&self, node: usize) -> <Self as RandomAccessLabeling>::Labels<'_> {
        let labels = <CsrGraph<DCF, S> as RandomAccessLabeling>::labels(&self.0, node);
        unsafe { AssumeSortedIterator::new(labels) }
    }
}

impl<DCF, S> RandomAccessGraph for CsrGraph<DCF, S>
where
    DCF: SliceByValue<Value = usize> + IterateByValueFrom<Item = usize>,
    S: SliceByValue<Value = usize> + IterateByValueFrom<Item = usize>,
{
}

impl<DCF, S> RandomAccessGraph for CsrSortedGraph<DCF, S>
where
    DCF: SliceByValue<Value = usize> + IterateByValueFrom<Item = usize>,
    S: SliceByValue<Value = usize> + IterateByValueFrom<Item = usize>,
{
}

/// Sequential Lender for the CSR graph.
#[derive(Debug, Clone)]
pub struct NodeLabels<O: Iterator<Item = usize>, S: Iterator<Item = usize>> {
    /// The next node to lend labels for.
    node: usize,
    /// This is the offset of the last successor of the previous node.
    last_offset: usize,
    /// This is the offset of the next successor to lend. This is modified
    /// by the iterator we return.
    current_offset: usize,
    /// The offsets iterator.
    offsets_iter: O,
    /// The successors iterator.
    successors_iter: S,
}

unsafe impl<O: Iterator<Item = usize>, S: Iterator<Item = usize>> SortedLender
    for NodeLabels<O, S>
{
}

impl<'succ, I, D> NodeLabelsLender<'succ> for NodeLabels<I, D>
where
    I: Iterator<Item = usize>,
    D: Iterator<Item = usize>,
{
    type Label = usize;
    type IntoIterator = SeqSucc<'succ, D>;
}

impl<'succ, I, D> Lending<'succ> for NodeLabels<I, D>
where
    I: Iterator<Item = usize>,
    D: Iterator<Item = usize>,
{
    type Lend = (usize, SeqSucc<'succ, D>);
}

impl<I, D> Lender for NodeLabels<I, D>
where
    I: Iterator<Item = usize>,
    D: Iterator<Item = usize>,
{
    check_covariance!();

    #[inline(always)]
    fn next(&mut self) -> Option<Lend<'_, Self>> {
        // if the user of the iterator wasn't fully consumed,
        // we need to skip the remaining successors
        while self.current_offset < self.last_offset {
            self.current_offset += 1;
            self.successors_iter.next()?;
        }

        // implicitly exit if the offsets iterator is empty
        let offset = self.offsets_iter.next()?;
        self.last_offset = offset;

        let node = self.node;
        self.node += 1;

        Some((
            node,
            SeqSucc {
                succ_iter: &mut self.successors_iter,
                current_offset: &mut self.current_offset,
                last_offset: &self.last_offset,
            },
        ))
    }
}

/// Sequential Lender for the CSR graph.
#[derive(Debug, Clone)]
#[repr(transparent)]
pub struct LenderSortedImpl<O: Iterator<Item = usize>, S: Iterator<Item = usize>>(NodeLabels<O, S>);

unsafe impl<O: Iterator<Item = usize>, S: Iterator<Item = usize>> SortedLender
    for LenderSortedImpl<O, S>
{
}

impl<'succ, I, D> NodeLabelsLender<'succ> for LenderSortedImpl<I, D>
where
    I: Iterator<Item = usize>,
    D: Iterator<Item = usize>,
{
    type Label = usize;
    type IntoIterator = AssumeSortedIterator<SeqSucc<'succ, D>>;
}

impl<'succ, I, D> Lending<'succ> for LenderSortedImpl<I, D>
where
    I: Iterator<Item = usize>,
    D: Iterator<Item = usize>,
{
    type Lend = (usize, AssumeSortedIterator<SeqSucc<'succ, D>>);
}

impl<I, D> Lender for LenderSortedImpl<I, D>
where
    I: Iterator<Item = usize>,
    D: Iterator<Item = usize>,
{
    check_covariance!();

    #[inline(always)]
    fn next(&mut self) -> Option<Lend<'_, Self>> {
        let (src, succ) = self.0.next()?;
        Some((src, unsafe { AssumeSortedIterator::new(succ) }))
    }
}

/// The iterator on successors returned by the lender.
///
/// This is different from the random-access iterator because for better
/// efficiency we have a single successors iterators that is forwarded by the
/// lender.
///
/// If the DCF and the successors are compressed representations, this might be
/// much faster than the random access iterator. When using vectors it might be
/// slower, but it is still a good idea to use this iterator to avoid the
/// overhead of creating a new iterator for each node.
pub struct SeqSucc<'a, D> {
    succ_iter: &'a mut D,
    current_offset: &'a mut usize,
    last_offset: &'a usize,
}

impl<D: Iterator<Item = usize>> Iterator for SeqSucc<'_, D> {
    type Item = usize;

    #[inline(always)]
    fn next(&mut self) -> Option<Self::Item> {
        if *self.current_offset >= *self.last_offset {
            return None;
        }
        *self.current_offset += 1;
        self.succ_iter.next()
    }

    #[inline(always)]
    fn count(self) -> usize {
        self.len()
    }

    #[inline(always)]
    fn size_hint(&self) -> (usize, Option<usize>) {
        let len = self.last_offset - *self.current_offset;
        (len, Some(len))
    }
}

impl<D: Iterator<Item = usize>> ExactSizeIterator for SeqSucc<'_, D> {
    #[inline(always)]
    fn len(&self) -> usize {
        self.last_offset - *self.current_offset
    }
}