Skip to content

Commit cf0044b

Browse files
authored
feat(derivation-pipeline): Accept CodecV9 (Galileo) (#423)
1 parent 233845d commit cf0044b

File tree

3 files changed

+2
-4
lines changed

3 files changed

+2
-4
lines changed

crates/codec/src/decoding/v7/mod.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -31,7 +31,7 @@ pub fn decode_v7(blob: &[u8]) -> Result<Batch, DecodingError> {
3131

3232
// check version.
3333
let version = from_be_bytes_slice_and_advance_buf!(u8, buf);
34-
debug_assert!((version == 7) | (version == 8), "incorrect blob version");
34+
debug_assert!((version == 7) || (version == 8) || (version == 9), "incorrect blob version");
3535

3636
let blob_payload_size = from_be_bytes_slice_and_advance_buf!(u32, 3, buf) as usize;
3737

crates/codec/src/error.rs

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -12,8 +12,6 @@ pub enum CodecError {
1212
/// An error occurring during the decoding.
1313
#[derive(Debug, thiserror::Error)]
1414
pub enum DecodingError {
15-
#[error("missing codec version in input")]
16-
MissingCodecVersion,
1715
#[error("unsupported codec version {0}")]
1816
UnsupportedCodecVersion(u8),
1917
#[error("malformed codec version: {0}")]

crates/codec/src/lib.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -59,7 +59,7 @@ impl Codec {
5959
let blob = input.blob().ok_or(DecodingError::MissingBlob)?;
6060
decode_v4(calldata, blob.as_ref())?
6161
}
62-
7..=8 => {
62+
7..=9 => {
6363
let blob = input.blob().ok_or(DecodingError::MissingBlob)?;
6464
decode_v7(blob.as_ref())?
6565
}

0 commit comments

Comments
 (0)