//! The recording buffer: the commands a person (or an agent) ran while recording, each with the //! document, sheet and selection it ran in. //! //! Only top-level calls are kept. A command that runs other commands (Custom Views › Show, a //! script) is one step, so playing the recording back does not run the inner commands twice. The //! buffer is separate from the journal, so trimming the journal never loses recorded steps, and //! secret parameters are left out as they are in the journal ([`crate::cmd::journal_params`]). use serde::Serialize; use serde_json::Value as Json; use crate::Selection; /// The most steps one recording keeps; later ones are counted in [`Recorder::dropped`]. pub const RECORD_LIMIT: usize = 100_000; /// The most bytes (steps serialized as JSON) one recording keeps. A step keeps its full /// parameters so it can be played back, and a `file.open` holds the whole file as base64, so /// without a size cap a recording of a few opens of a large workbook keeps tens of MB alive. pub const RECORD_MAX_BYTES: usize = 64 * 1024 * 1024; /// One recorded command and where it ran. #[derive(Clone, Debug, PartialEq, Serialize)] #[serde(rename_all = "camelCase")] pub struct RecordedStep { /// Uid of the document that was active when the command ran (0 when none was open). pub doc: u64, /// That document's active sheet (index and name) just before the command ran. pub sheet: usize, pub sheet_name: String, /// That document's selection just before the command ran. pub selection: Selection, /// The command id and its parameters, without secrets. pub id: String, pub params: Json, } /// The steps recorded since recording started. #[derive(Clone, Debug, Default)] pub struct Recorder { pub steps: Vec, /// Steps not kept because the recording reached [`RECORD_LIMIT`] or [`RECORD_MAX_BYTES`]. /// Once a step is dropped, every later one is too, so `steps` is always the beginning of /// what ran, never a sequence with gaps. pub dropped: usize, /// The size of `steps` serialized as JSON. bytes: usize, } impl Recorder { /// Adds a step, or counts it as dropped once the buffer is full. pub fn push(&mut self, step: RecordedStep) { // Once a step has been dropped, or the step count is full, the rest are counted without // being serialized (a `file.open` step holds a whole file). if self.dropped > 0 || self.steps.len() >= RECORD_LIMIT { self.dropped = self.dropped.saturating_add(1); return; } let size = serde_json::to_vec(&step).map_or(0, |v| v.len()); if self.bytes.saturating_add(size) <= RECORD_MAX_BYTES { self.bytes = self.bytes.saturating_add(size); self.steps.push(step); } else { self.dropped = self.dropped.saturating_add(1); } } }