Skip to content

Commit

Permalink
feat: batch type
Browse files Browse the repository at this point in the history
  • Loading branch information
refcell committed Oct 27, 2024
1 parent cda485c commit f14ac3b
Showing 1 changed file with 77 additions and 0 deletions.
77 changes: 77 additions & 0 deletions crates/protocol/src/batch_type.rs
Original file line number Diff line number Diff line change
@@ -0,0 +1,77 @@
//! Batch Types
//!
//! This module contains the batch types for the OP Stack derivation pipeline.
//!
//! ## Batch
//!
//! A batch is either a `SpanBatch` or a `SingleBatch`.
//!
//! The batch type is encoded as a single byte:
//! - `0x00` for a `SingleBatch`
//! - `0x01` for a `SpanBatch`
use alloy_rlp::{Decodable, Encodable};

/// The single batch type identifier.
pub const SINGLE_BATCH_TYPE: u8 = 0x00;

/// The span batch type identifier.
pub const SPAN_BATCH_TYPE: u8 = 0x01;

/// The Batch Type.
#[derive(Debug, Clone, PartialEq, Eq)]
#[repr(u8)]
pub enum BatchType {
/// Single Batch.
Single = SINGLE_BATCH_TYPE,
/// Span Batch.
Span = SPAN_BATCH_TYPE,
}

impl From<u8> for BatchType {
fn from(val: u8) -> Self {
match val {
SINGLE_BATCH_TYPE => Self::Single,
SPAN_BATCH_TYPE => Self::Span,
_ => panic!("Invalid batch type: {val}"),
}
}
}

impl From<&[u8]> for BatchType {
fn from(buf: &[u8]) -> Self {
Self::from(buf[0])
}
}

impl Encodable for BatchType {
fn encode(&self, out: &mut dyn alloy_rlp::BufMut) {
let val = match self {
Self::Single => SINGLE_BATCH_TYPE,
Self::Span => SPAN_BATCH_TYPE,
};
val.encode(out);
}
}

impl Decodable for BatchType {
fn decode(buf: &mut &[u8]) -> alloy_rlp::Result<Self> {
let val = u8::decode(buf)?;
Ok(Self::from(val))
}
}

#[cfg(test)]
mod test {
use super::*;
use alloc::vec::Vec;

#[test]
fn test_batch_type_rlp_roundtrip() {
let batch_type = BatchType::Single;
let mut buf = Vec::new();
batch_type.encode(&mut buf);
let decoded = BatchType::decode(&mut buf.as_slice()).unwrap();
assert_eq!(batch_type, decoded);
}
}

0 comments on commit f14ac3b

Please sign in to comment.