Method add_block

crates/batcher/encoder/src/encoder.rs:444–463

(&mut self, block: BaseBlock)

impl BatchPipeline for BatchEncoder {
    fn add_block(&mut self, block: BaseBlock) -> Result<(), (ReorgError, Box<BaseBlock>)> {
        if let Some(expected) = self.tip
            && block.header.parent_hash != expected
        {
            return Err((
                ReorgError::ParentMismatch { expected, got: block.header.parent_hash },
                Box::new(block),
            ));
        }

        let number = block.header.number;
        let hash = block.header.hash_slow();
        self.tip = Some(hash);
        self.blocks.push_back(block);
        BatcherMetrics::pending_blocks().increment(1.0);

        debug!(block = %number, pending_blocks = %self.blocks.len(), "block added to encoder queue");

        Ok(())
    }

    fn step(&mut self) -> Result<StepResult, StepError> {
        // One transition: deferred error, timeout close, or one queued block.