Function decode

core/server/src/binary/dispatch.rs:69–88

(payload: &[u8])

}

fn decode<T: WireDecode>(payload: &[u8]) -> Result<T, IggyError> {
    use iggy_binary_protocol::error::WireError;

    let (val, consumed) = T::decode(payload).map_err(|e| {
        warn!("wire decode error: {e}");
        match e {
            WireError::PayloadTooLarge { .. } => IggyError::InvalidSizeBytes,
            WireError::Validation(_) => IggyError::InvalidFormat,
            _ => IggyError::InvalidCommand,
        }
    })?;
    if consumed != payload.len() {
        warn!(
            "wire decode: {} trailing bytes (consumed {consumed}, payload {})",
            payload.len() - consumed,
            payload.len()
        );
    }
    Ok(val)
}

/// Convert a `WireIdentifier` to the domain `Identifier`.
pub fn wire_id_to_identifier(