feat(derive): Pipeline Builder

[refcell]

Description

Implement a DerivationPipeline following the golang reference implementation.

The pipeline will need to chain each Stage together from the stages module, successively passing each stage into the previous one. An example of this is shown below. This would be crates/derive/src/lib.rs. Note, this may break since various constructors and stage implementation change.

use alloc::sync::Arc;
use core::fmt::Debug;
use stages::{AttributesProvider, AttributesBuilder};
use traits::{ChainProvider, DataAvailabilityProvider, L2ChainProvider, OriginProvider};
use types::RollupConfig;

mod params;
pub use params::{
    ChannelID, CHANNEL_ID_LENGTH, CONFIG_UPDATE_EVENT_VERSION_0, CONFIG_UPDATE_TOPIC,
    DERIVATION_VERSION_0, FRAME_OVERHEAD, MAX_CHANNEL_BANK_SIZE, MAX_FRAME_LEN,
    MAX_RLP_BYTES_PER_CHANNEL, MAX_SPAN_BATCH_BYTES,
};
pub mod sources;
pub mod stages;
pub mod traits;
pub mod types;

/// The derivation pipeline is responsible for deriving L2 inputs from L1 data.
#[derive(Debug, Clone, Copy)]
pub struct DerivationPipeline<P, AB>
where
    P: AttributesProvider + OriginProvider + Debug,
    AB: AttributesBuilder + Debug,
{
	/// The attributes queue to retrieve the next attributes.
	pub attributes: AttributesQueue<P, AB>,
}

impl DerivationPipeline {
    /// Creates a new instance of the [DerivationPipeline].
    pub fn new<P, DAP, F, B>(
        rollup_config: Arc<RollupConfig>,
        chain_provider: P,
		dap_source: DAP,
		fetcher: F,
		builder: B,
    ) -> Self
    where
        P: ChainProvider + Clone + Debug + Send,
		DAP: DataAvailabilityProvider + Clone + Debug + Send,
		F: L2ChainProvider + Clone + Debug + Send,
		B: AttributesBuilder + Clone + Debug + Send,
    {
		let l1_traversal = L1Traversal::new(chain_provider, rollup_config.clone());
		let l1_retrieval = L1Retrieval::new(l1_traversal, dap_source);
		let frame_queue = FrameQueue::new(l1_retrieval);
		let channel_bank = ChannelBank::new(rollup_config.clone(), frame_queue);
		let channel_reader = ChannelReader::new(channel_bank, rollup_config.clone());
		let batch_queue = BatchQueue::new(rollup_config.clone(), channel_reader, fetcher);
		let attributes_queue = AttributesQueue::new(rollup_config.clone(), batch_queue, builder);
		Self { attributes: attributes_queue }
    }
}

// TODO: implement async iterator for derivation pipeline to call `next_attributes` on the internal `AttributesQueue` stage/field.