rrpack-prime 0.41.0

RillRate Pack: Prime
Documentation
use super::state::*;
use derive_more::{Deref, DerefMut};
use rill_derive::TracerOpts;
use rill_protocol::flow::core::FlowMode;
use rrpack_basis::{AutoPath, BindedTracer};

#[derive(TracerOpts, Clone, Default)]
pub struct TableOpts {
    pub columns: Vec<(u64, String)>,
}

impl From<TableOpts> for TableSpec {
    fn from(opts: TableOpts) -> Self {
        let columns = opts
            .columns
            .into_iter()
            .map(|(col_id, title)| {
                let record = ColRecord { title };
                (Col(col_id), record)
            })
            .collect();
        Self { columns }
    }
}

#[derive(Debug, Deref, DerefMut, Clone)]
pub struct Table {
    tracer: BindedTracer<TableState>,
}

impl Table {
    pub fn new(auto_path: impl Into<AutoPath>, mode: FlowMode, spec: impl Into<TableSpec>) -> Self {
        let tracer = BindedTracer::new(auto_path.into(), mode, spec.into());
        Self { tracer }
    }

    /// Adds a new row
    pub fn add_row(&self, row: Row) {
        let event = TableEvent::AddRow { row };
        self.tracer.send(event, None);
    }

    /// Deletes a row by id
    pub fn del_row(&self, row: Row) {
        let event = TableEvent::DelRow { row };
        self.tracer.send(event, None);
    }

    /// Sets a value to the cell
    pub fn set_cell(&self, row: Row, col: Col, value: impl ToString) {
        let event = TableEvent::SetCell {
            row,
            col,
            value: value.to_string(),
        };
        self.tracer.send(event, None);
    }
}