Struct RuleBasedCompressor 

pub struct RuleBasedCompressor { /* private fields */ }

Regex-based compressor that applies operator- and LLM-evolved rules to tool output.

Rules are sorted deterministically by id to ensure stable application order. Hit counts are stored in hits keyed by rule.id; the rules vec can be swapped on reload without losing any unflushed counts.

Invariants

• Rules are applied in id-ascending order (deterministic).
• compress returns the first successful match (earliest rule wins).
• A rule is skipped when glob is set and does not match tool_name.
• regex::Regex::replace_all guarantees linear time (no catastrophic backtracking). No catch_unwind is needed around replace_all.

Implementations

impl RuleBasedCompressor

pub async fn load( store: Arc<CompressionRuleStore>, max_output_lines: usize, regex_timeout_ms: u64, ) -> Result<Self, CompressionError>

Load all active rules from the store and compile them.

Rules that fail compilation are skipped and logged as warnings.

regex_timeout_ms controls the DoS-safe regex compilation timeout passed to super::safe_compile. Sourced from [tools.compression] regex_compile_timeout_ms.

Errors

Returns CompressionError::Db if the store query fails.

pub async fn reload(&self) -> Result<(), CompressionError>

Reload rules from the store, preserving hit counts for still-present rules and flushing counts for rules that no longer exist.

Errors

Returns CompressionError::Db if the store query fails.

pub async fn flush_hit_counts(&self) -> Result<(), CompressionError>

Drain pending hit counts into a batch and write them to the store.

Called during the maybe_autodream maintenance pass. Resets all counters to zero after flushing.

Errors

Returns a database error if the batch write fails.

Trait Implementations

impl Debug for RuleBasedCompressor

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl OutputCompressor for RuleBasedCompressor

fn compress<'a>( &'a self, tool_name: &'a ToolName, output: &'a str, ) -> Pin<Box<dyn Future<Output = Result<Option<String>, CompressionError>> + Send + 'a>>

Attempt to compress output for the given tool_name.

fn name(&self) -> &'static str

Stable identifier for this compressor (used in logs).