vimp_engine_core/client/

unpack.rs

//! Декодер бинарного кадра v5 — порт unpackFrame из src/lib/snapshotCodec.js
//! (срез 2.6). Раскладка зеркальна упаковке core/src/snapshot.rs (big-endian);
//! float снапшота восстанавливаются повторным округлением до 2 знаков
//! (round2), player-блок читается без округления (точность нужна предикту).

use indexmap::IndexMap;
use serde_json::{Map, Value, json};

use crate::config::{BlockKind, BlockSchema, FieldType, FieldValue, PLAYER_STATE_LEN, SnapshotConfig};
use crate::physics::round2;

const CAMERA_FLAG_HAS_CAMERA: u8 = 1;
const CAMERA_FLAG_FORCE_RESET: u8 = 2;
const CAMERA_FLAG_HAS_SHAKE: u8 = 4;
const CAMERA_FLAG_HAS_PLAYER: u8 = 8;

/// Камера кадра: [x, y, forceReset?, shake?] из JS-формы.
#[derive(Clone)]
pub struct DecodedCamera {
    pub x: f32,
    pub y: f32,
    pub force_reset: bool,
    pub shake: Option<String>,
}

/// Player-блок предикшена играющего (без округления).
#[derive(Clone)]
pub struct DecodedPlayer {
    pub game_id: u8,
    pub input_seq: u32,
    pub state: [f32; PLAYER_STATE_LEN],
    pub centering: bool,
}

/// Данные блока по kind — форма (см. `BlockKind`), не игровая сущность;
/// поля строки — generic `Vec<FieldValue>` в порядке `schema.fields`
/// (зеркало BLOCK_READERS snapshotCodec.js).
#[derive(Clone)]
pub enum BlockData {
    /// id → поля строки | None (null-маркер удаления)
    Indexed8(IndexMap<u8, Option<Vec<FieldValue>>>),
    /// id → поля строки | None (null-маркер удаления)
    Indexed32(IndexMap<u32, Option<Vec<FieldValue>>>),
    List16(Vec<Vec<FieldValue>>),
    /// индекс → поля строки
    IndexedNoNull8(IndexMap<u8, Vec<FieldValue>>),
}

/// Блок снапшота с ключом реестра opcodes.js.
#[derive(Clone)]
pub struct DecodedBlock {
    pub key: String,
    pub key_id: u8,
    pub data: BlockData,
}

/// Тело снапшота: блоки в порядке следования в кадре.
#[derive(Clone, Default)]
pub struct DecodedSnapshot {
    pub blocks: Vec<DecodedBlock>,
}

impl DecodedSnapshot {
    pub fn block_by_key(&self, key: &str) -> Option<&BlockData> {
        self.blocks
            .iter()
            .find(|block| block.key == key)
            .map(|block| &block.data)
    }
}

/// Распакованный кадр v3.
pub struct DecodedFrame {
    pub port: u8,
    pub seq: u32,
    pub server_time: f64,
    pub camera: Option<DecodedCamera>,
    pub player: Option<DecodedPlayer>,
    pub snapshot: DecodedSnapshot,
}

pub enum UnpackError {
    /// Версия формата кадра не совпадает — кадр отбрасывается.
    WrongVersion,
    /// Кадр обрывается посреди блока — повреждённые данные.
    Truncated,
}

/// Курсор чтения big-endian с проверкой границ.
struct Reader<'a> {
    data: &'a [u8],
    offset: usize,
}

impl<'a> Reader<'a> {
    fn new(data: &'a [u8]) -> Self {
        Self { data, offset: 0 }
    }

    fn remaining(&self) -> usize {
        self.data.len() - self.offset
    }

    fn take(&mut self, len: usize) -> Result<&'a [u8], UnpackError> {
        if self.remaining() < len {
            return Err(UnpackError::Truncated);
        }

        let slice = &self.data[self.offset..self.offset + len];

        self.offset += len;
        Ok(slice)
    }

    fn u8(&mut self) -> Result<u8, UnpackError> {
        Ok(self.take(1)?[0])
    }

    fn u16(&mut self) -> Result<u16, UnpackError> {
        Ok(u16::from_be_bytes(self.take(2)?.try_into().unwrap()))
    }

    fn u32(&mut self) -> Result<u32, UnpackError> {
        Ok(u32::from_be_bytes(self.take(4)?.try_into().unwrap()))
    }

    fn f32_raw(&mut self) -> Result<f32, UnpackError> {
        Ok(f32::from_be_bytes(self.take(4)?.try_into().unwrap()))
    }

    /// Float снапшота: восстановление round2-значения (readFloat из JS).
    fn f32_round2(&mut self) -> Result<f32, UnpackError> {
        Ok(round2(self.f32_raw()?))
    }

    fn f64(&mut self) -> Result<f64, UnpackError> {
        Ok(f64::from_be_bytes(self.take(8)?.try_into().unwrap()))
    }
}

/// Читает одно поле строки по типу схемы (интерпретатор `FieldSchema`,
/// зеркало `snapshot::write_field`). Float снапшота — с округлением
/// round2 (readFloat из JS-версии).
fn read_field(r: &mut Reader, ty: FieldType) -> Result<FieldValue, UnpackError> {
    Ok(match ty {
        FieldType::F32 => FieldValue::F32(r.f32_round2()?),
        FieldType::U8 => FieldValue::U8(r.u8()?),
        FieldType::U16 => FieldValue::U16(r.u16()?),
        FieldType::U32 => FieldValue::U32(r.u32()?),
    })
}

/// Распаковывает бинарный кадр (порт unpackFrame).
pub fn unpack_frame(data: &[u8], cfg: &SnapshotConfig) -> Result<DecodedFrame, UnpackError> {
    let mut r = Reader::new(data);

    let port = r.u8()?;
    let version = r.u8()?;

    if version != cfg.version {
        return Err(UnpackError::WrongVersion);
    }

    let seq = r.u32()?;
    let server_time = r.f64()?;
    let flags = r.u8()?;

    let mut camera = None;

    if flags & CAMERA_FLAG_HAS_CAMERA != 0 {
        let x = r.f32_round2()?;
        let y = r.f32_round2()?;
        let force_reset = flags & CAMERA_FLAG_FORCE_RESET != 0;

        let shake = if flags & CAMERA_FLAG_HAS_SHAKE != 0 {
            let len = r.u8()? as usize;
            let bytes = r.take(len)?;

            Some(String::from_utf8_lossy(bytes).into_owned())
        } else {
            None
        };

        camera = Some(DecodedCamera {
            x,
            y,
            force_reset,
            shake,
        });
    }

    let mut player = None;

    if flags & CAMERA_FLAG_HAS_PLAYER != 0 {
        let game_id = r.u8()?;
        let input_seq = r.u32()?;
        let mut state = [0.0f32; PLAYER_STATE_LEN];

        for value in &mut state {
            *value = r.f32_raw()?; // без округления (предикшен)
        }

        let centering = r.u8()? == 1;

        player = Some(DecodedPlayer {
            game_id,
            input_seq,
            state,
            centering,
        });
    }

    let mut snapshot = DecodedSnapshot::default();

    while r.remaining() > 0 {
        let key_id = r.u8()?;

        // неизвестный id блока — остаток кадра отбрасывается (как в JS)
        let Some((key, info)) = cfg.keys.iter().find(|(_, info)| info.id == key_id) else {
            break;
        };

        let data = match info.kind {
            BlockKind::Indexed8 => read_indexed8(&mut r, info)?,
            BlockKind::Indexed32 => read_indexed32(&mut r, info)?,
            BlockKind::List16 => read_list16(&mut r, info)?,
            BlockKind::IndexedNoNull8 => read_indexed_no_null8(&mut r, info)?,
        };

        snapshot.blocks.push(DecodedBlock {
            key: key.clone(),
            key_id,
            data,
        });
    }

    Ok(DecodedFrame {
        port,
        seq,
        server_time,
        camera,
        player,
        snapshot,
    })
}

/// Нулевое значение поля по его типу — отсутствующий опциональный хвост
/// читается именно так: «тело покоится», то есть нулевые скорости.
fn zero_field(ty: FieldType) -> FieldValue {
    match ty {
        FieldType::F32 => FieldValue::F32(0.0),
        FieldType::U8 => FieldValue::U8(0),
        FieldType::U16 => FieldValue::U16(0),
        FieldType::U32 => FieldValue::U32(0),
    }
}

/// Читает строку по позиционной схеме `schema.fields` — generic для любого
/// kind, раскладка полей внутри строки не зависит от формы блока.
/// Схема с опциональным хвостом (`optionalFrom`) начинает строку флаг-байтом;
/// при нулевом флаге хвост в кадре отсутствует и добивается нулями — наружу
/// строка всегда отдаётся полной ширины (интерполятор и hot-буфер читают
/// поля по индексу и переменную длину не переживут).
fn read_row(r: &mut Reader, schema: &BlockSchema) -> Result<Vec<FieldValue>, UnpackError> {
    let has_tail = match schema.optional_from {
        None => true,
        Some(_) => r.u8()? == 1,
    };

    let read_len = if has_tail {
        schema.fields.len()
    } else {
        schema.required_len()
    };

    schema
        .fields
        .iter()
        .enumerate()
        .map(|(i, field)| {
            if i < read_len {
                read_field(r, field.ty)
            } else {
                Ok(zero_field(field.ty))
            }
        })
        .collect()
}

fn read_indexed8(r: &mut Reader, schema: &BlockSchema) -> Result<BlockData, UnpackError> {
    let count = r.u8()?;
    let mut result = IndexMap::new();

    for _ in 0..count {
        let id = r.u8()?;

        if r.u8()? == 0 {
            result.insert(id, None);
            continue;
        }

        result.insert(id, Some(read_row(r, schema)?));
    }

    Ok(BlockData::Indexed8(result))
}

fn read_indexed32(r: &mut Reader, schema: &BlockSchema) -> Result<BlockData, UnpackError> {
    let count = r.u16()?;
    let mut result = IndexMap::new();

    for _ in 0..count {
        let id = r.u32()?;

        if r.u8()? == 0 {
            result.insert(id, None);
            continue;
        }

        result.insert(id, Some(read_row(r, schema)?));
    }

    Ok(BlockData::Indexed32(result))
}

fn read_list16(r: &mut Reader, schema: &BlockSchema) -> Result<BlockData, UnpackError> {
    let count = r.u16()?;
    let mut result = Vec::with_capacity(count as usize);

    for _ in 0..count {
        result.push(read_row(r, schema)?);
    }

    Ok(BlockData::List16(result))
}

fn read_indexed_no_null8(r: &mut Reader, schema: &BlockSchema) -> Result<BlockData, UnpackError> {
    let count = r.u8()?;
    let mut result = IndexMap::new();

    for _ in 0..count {
        let index = r.u8()?;

        result.insert(index, read_row(r, schema)?);
    }

    Ok(BlockData::IndexedNoNull8(result))
}

// ***** JSON-сериализация (формы, идентичные unpackFrame) ***** //

/// round2-значение f32 → точный двухзначный f64 для JSON
/// (JS readFloat возвращал round(f32·100)/100 в f64).
pub fn round2_f64(v: f32) -> f64 {
    ((v as f64) * 100.0).round() / 100.0
}

/// u32 → base36 (ключи бомб; JS id.toString(36)).
pub fn to_base36(mut v: u32) -> String {
    const DIGITS: &[u8; 36] = b"0123456789abcdefghijklmnopqrstuvwxyz";

    if v == 0 {
        return "0".to_string();
    }

    let mut out = Vec::new();

    while v > 0 {
        out.push(DIGITS[(v % 36) as usize]);
        v /= 36;
    }

    out.reverse();
    String::from_utf8(out).unwrap()
}

/// Камера в JS-форму: 0 | [x, y] | [x, y, true] | [x, y, ..., shake].
pub fn camera_to_json(camera: Option<&DecodedCamera>) -> Value {
    let Some(camera) = camera else {
        return json!(0);
    };

    let mut arr = vec![
        Value::from(round2_f64(camera.x)),
        Value::from(round2_f64(camera.y)),
    ];

    if camera.force_reset {
        arr.push(Value::from(true));
    }

    if let Some(shake) = &camera.shake {
        // shake живёт в camera[3]; без forceReset слот [2] — null (как в JS)
        while arr.len() < 3 {
            arr.push(Value::Null);
        }

        arr.push(Value::from(shake.clone()));
    }

    Value::Array(arr)
}

fn field_value_to_json(value: FieldValue) -> Value {
    match value {
        FieldValue::F32(v) => Value::from(round2_f64(v)),
        FieldValue::U8(v) => Value::from(v),
        FieldValue::U16(v) => Value::from(v),
        FieldValue::U32(v) => Value::from(v),
    }
}

/// Строка блока в JS-форму: позиционный массив значений полей (порядок —
/// `schema.fields`), как в JS-версии snapshotCodec.js.
fn row_to_json(fields: &[FieldValue]) -> Value {
    Value::Array(fields.iter().copied().map(field_value_to_json).collect())
}

/// Тело снапшота в JS-форму { ключ: данные } для parse-конвейера клиента.
/// Форма контейнера по kind — не по игровой сущности: `Indexed8`/`Indexed32`
/// дают объект id → строка|null, `List16` — массив строк, `IndexedNoNull8`
/// — объект `d{index}` → строка (сохраняет исторический формат ключей
/// динамических элементов карты).
pub fn snapshot_to_json(snapshot: &DecodedSnapshot) -> Map<String, Value> {
    let mut result = Map::new();

    for block in &snapshot.blocks {
        let value = match &block.data {
            BlockData::Indexed8(items) => {
                let mut map = Map::new();

                for (id, row) in items {
                    map.insert(
                        id.to_string(),
                        row.as_deref().map_or(Value::Null, row_to_json),
                    );
                }

                Value::Object(map)
            }
            BlockData::Indexed32(items) => {
                let mut map = Map::new();

                for (id, row) in items {
                    map.insert(
                        to_base36(*id),
                        row.as_deref().map_or(Value::Null, row_to_json),
                    );
                }

                Value::Object(map)
            }
            BlockData::List16(items) => {
                Value::Array(items.iter().map(|fields| row_to_json(fields)).collect())
            }
            BlockData::IndexedNoNull8(items) => {
                let mut map = Map::new();

                for (index, fields) in items {
                    map.insert(format!("d{index}"), row_to_json(fields));
                }

                Value::Object(map)
            }
        };

        result.insert(block.key.clone(), value);
    }

    result
}

/// Полный кадр в JSON-форму unpackFrame — для тестов и харнесса
/// (ClientCore.decode_frame): { port, seq, serverTime, camera, player, snapshot }.
pub fn frame_to_json(frame: &DecodedFrame) -> Value {
    let player = frame.player.as_ref().map_or(Value::Null, |p| {
        json!({
            "gameId": p.game_id,
            "inputSeq": p.input_seq,
            // без округления: f64-расширение Float32 (как getFloat32 в JS)
            "state": p.state.iter().map(|v| *v as f64).collect::<Vec<f64>>(),
            "centering": p.centering,
        })
    });

    json!({
        "port": frame.port,
        "seq": frame.seq,
        "serverTime": frame.server_time,
        "camera": camera_to_json(frame.camera.as_ref()),
        "player": player,
        "snapshot": Value::Object(snapshot_to_json(&frame.snapshot)),
    })
}

#[cfg(test)]
mod tests {
    use super::*;
    use crate::config::test_support::full_snapshot_config;
    use crate::snapshot::{Block, CameraData, PlayerBlock, SnapshotPacker};

    // round-trip против упаковщика того же crate: раскладка не может
    // разойтись между pack и unpack по построению, тесты фиксируют формы
    fn test_config() -> SnapshotConfig {
        full_snapshot_config(3, 5)
    }

    fn packed_frame(
        blocks: &[(String, Block)],
        camera: Option<&CameraData>,
        player: Option<&PlayerBlock>,
    ) -> Vec<u8> {
        let mut packer = SnapshotPacker::new(test_config());

        packer.pack_body(blocks).unwrap();
        packer.pack_frame(1234.5, 42, camera, player).to_vec()
    }

    fn tank_row(floats: [f32; 7], condition: u8, size: u8, team: u8) -> Vec<FieldValue> {
        let mut fields: Vec<FieldValue> = floats.iter().copied().map(FieldValue::F32).collect();

        fields.push(FieldValue::U8(condition));
        fields.push(FieldValue::U8(size));
        fields.push(FieldValue::U8(team));
        fields
    }

    fn tracer_row(floats: [f32; 6], was_hit: bool, shooter: u8) -> Vec<FieldValue> {
        let mut fields: Vec<FieldValue> = floats.iter().copied().map(FieldValue::F32).collect();

        fields.push(FieldValue::U8(was_hit as u8));
        fields.push(FieldValue::U8(shooter));
        fields
    }

    fn bomb_row(x: f32, y: f32, angle: f32, size: u8, time: u16, owner: u8) -> Vec<FieldValue> {
        vec![
            FieldValue::F32(x),
            FieldValue::F32(y),
            FieldValue::F32(angle),
            FieldValue::U8(size),
            FieldValue::U16(time),
            FieldValue::U8(owner),
        ]
    }

    fn explosion_row(x: f32, y: f32, radius: f32) -> Vec<FieldValue> {
        vec![FieldValue::F32(x), FieldValue::F32(y), FieldValue::F32(radius)]
    }

    fn field_f32(fields: &[FieldValue], i: usize) -> f32 {
        match fields[i] {
            FieldValue::F32(v) => v,
            _ => panic!("поле {i} не F32"),
        }
    }

    #[test]
    fn full_frame_round_trip() {
        let blocks = vec![
            (
                "m1".to_string(),
                Block::Indexed8(vec![
                    (
                        2,
                        Some(tank_row(
                            [10.567, -3.141, 1.5, 0.25, 100.0, -50.5, 1.2],
                            3,
                            2,
                            1,
                        )),
                    ),
                    (3, None),
                ]),
            ),
            (
                "w1".to_string(),
                Block::List16(vec![tracer_row(
                    [1.0, 2.0, 3.0, 4.0, 5.0, 6.0],
                    true,
                    7,
                )]),
            ),
            (
                "w2".to_string(),
                Block::Indexed32(vec![
                    (
                        // 'a1f' в base36
                        u32::from_str_radix("a1f", 36).unwrap(),
                        Some(bomb_row(5.5, 6.5, 0.0, 8, 300, 2)),
                    ),
                    (1, None),
                ]),
            ),
            (
                "w2e".to_string(),
                Block::List16(vec![explosion_row(100.0, 200.0, 50.0)]),
            ),
            (
                "c1".to_string(),
                Block::IndexedNoNull8(vec![(0, explosion_row(10.0, 20.0, 0.5))]),
            ),
        ];

        let camera = CameraData {
            x: 10.5,
            y: -3.25,
            force_reset: true,
            shake: Some("20:200".to_string()),
        };
        let player = PlayerBlock {
            game_id: 2,
            input_seq: 77,
            state: [10.56789, 2.0, 0.5, 3.0, 4.0, 0.1, 0.2, 0.7],
            centering: true,
        };

        let data = packed_frame(&blocks, Some(&camera), Some(&player));
        let frame = unpack_frame(&data, &test_config()).ok().unwrap();

        assert_eq!(frame.port, 5);
        assert_eq!(frame.seq, 42);
        assert_eq!(frame.server_time, 1234.5);

        // камера: координаты round2, флаги
        let cam = frame.camera.as_ref().unwrap();

        assert_eq!(cam.x, 10.5);
        assert_eq!(cam.y, -3.25);
        assert!(cam.force_reset);
        assert_eq!(cam.shake.as_deref(), Some("20:200"));

        // player-блок: без округления (точное f32-значение)
        let p = frame.player.as_ref().unwrap();

        assert_eq!(p.game_id, 2);
        assert_eq!(p.input_seq, 77);
        assert_eq!(p.state[0], 10.56789f32);
        assert!(p.centering);

        // танки: float снапшота восстановлены округлением до 2 знаков
        let Some(BlockData::Indexed8(tanks)) = frame.snapshot.block_by_key("m1") else {
            panic!("нет блока m1");
        };
        let row = tanks[&2].as_ref().unwrap();

        assert_eq!(field_f32(row, 0), 10.57);
        assert_eq!(field_f32(row, 1), -3.14);

        match (row[7], row[8], row[9]) {
            (FieldValue::U8(condition), FieldValue::U8(size), FieldValue::U8(team)) => {
                assert_eq!((condition, size, team), (3, 2, 1));
            }
            _ => panic!("неожиданные типы полей tank"),
        }
        assert!(tanks[&3].is_none()); // null-маркер

        let Some(BlockData::List16(tracers)) = frame.snapshot.block_by_key("w1") else {
            panic!("нет блока w1");
        };

        match tracers[0][6] {
            FieldValue::U8(v) => assert_eq!(v, 1),
            _ => panic!("поле 6 не U8"),
        }
        match tracers[0][7] {
            FieldValue::U8(v) => assert_eq!(v, 7),
            _ => panic!("поле 7 не U8"),
        }

        let Some(BlockData::Indexed32(bombs)) = frame.snapshot.block_by_key("w2") else {
            panic!("нет блока w2");
        };
        let bomb = bombs[&u32::from_str_radix("a1f", 36).unwrap()]
            .as_ref()
            .unwrap();

        match (bomb[3], bomb[4], bomb[5]) {
            (FieldValue::U8(size), FieldValue::U16(time), FieldValue::U8(owner)) => {
                assert_eq!((size, time, owner), (8, 300, 2));
            }
            _ => panic!("неожиданные типы полей bomb"),
        }
        assert!(bombs[&1].is_none());

        let Some(BlockData::List16(explosions)) = frame.snapshot.block_by_key("w2e") else {
            panic!("нет блока w2e");
        };

        assert_eq!(
            (
                field_f32(&explosions[0], 0),
                field_f32(&explosions[0], 1),
                field_f32(&explosions[0], 2)
            ),
            (100.0, 200.0, 50.0)
        );

        let Some(BlockData::IndexedNoNull8(dynamics)) = frame.snapshot.block_by_key("c1") else {
            panic!("нет блока c1");
        };

        let dyn_row = &dynamics[&0];

        assert_eq!(
            (
                field_f32(dyn_row, 0),
                field_f32(dyn_row, 1),
                field_f32(dyn_row, 2)
            ),
            (10.0, 20.0, 0.5)
        );

        // строка пришла без опционального хвоста — наружу она всё равно
        // полной ширины схемы, скорости нулевые
        assert_eq!(dyn_row.len(), 6);
        assert_eq!(
            (
                field_f32(dyn_row, 3),
                field_f32(dyn_row, 4),
                field_f32(dyn_row, 5)
            ),
            (0.0, 0.0, 0.0)
        );
    }

    #[test]
    fn dynamics_optional_tail_round_trip() {
        let resting = vec![
            FieldValue::F32(10.0),
            FieldValue::F32(20.0),
            FieldValue::F32(0.5),
        ];
        let moving = vec![
            FieldValue::F32(30.0),
            FieldValue::F32(40.0),
            FieldValue::F32(1.5),
            FieldValue::F32(-2.25),
            FieldValue::F32(3.75),
            FieldValue::F32(0.9),
        ];

        let data = packed_frame(
            &[(
                "c1".to_string(),
                Block::IndexedNoNull8(vec![(0, resting), (1, moving)]),
            )],
            None,
            None,
        );
        let frame = unpack_frame(&data, &test_config()).ok().unwrap();

        let Some(BlockData::IndexedNoNull8(dynamics)) = frame.snapshot.block_by_key("c1") else {
            panic!("нет блока c1");
        };

        // покоящееся тело: хвоста в кадре нет, читается как нулевые скорости
        assert_eq!(
            (
                field_f32(&dynamics[&0], 3),
                field_f32(&dynamics[&0], 4),
                field_f32(&dynamics[&0], 5)
            ),
            (0.0, 0.0, 0.0)
        );

        // движущееся: хвост дошёл значениями
        assert_eq!(
            (
                field_f32(&dynamics[&1], 0),
                field_f32(&dynamics[&1], 3),
                field_f32(&dynamics[&1], 4),
                field_f32(&dynamics[&1], 5)
            ),
            (30.0, -2.25, 3.75, 0.9)
        );

        // строка без хвоста дешевле ровно на 3 × f32
        assert_eq!(data.len(), 15 + 1 + 1 + (2 + 12) + (2 + 12 + 12));
    }

    #[test]
    fn wrong_version_is_rejected() {
        let mut data = packed_frame(&[], None, None);

        data[1] = 99;
        assert!(matches!(
            unpack_frame(&data, &test_config()),
            Err(UnpackError::WrongVersion)
        ));
    }

    #[test]
    fn truncated_frame_is_error() {
        let data = packed_frame(
            &[(
                "m1".to_string(),
                Block::Indexed8(vec![(1, Some(tank_row([0.0; 7], 3, 2, 1)))]),
            )],
            None,
            None,
        );

        assert!(matches!(
            unpack_frame(&data[..data.len() - 4], &test_config()),
            Err(UnpackError::Truncated)
        ));
    }

    #[test]
    fn unknown_block_id_drops_rest() {
        let mut data = packed_frame(
            &[(
                "w2e".to_string(),
                Block::List16(vec![explosion_row(1.0, 2.0, 3.0)]),
            )],
            None,
            None,
        );

        // подмена id блока на незарегистрированный
        data[15] = 200;

        let frame = unpack_frame(&data, &test_config()).ok().unwrap();

        assert!(frame.snapshot.blocks.is_empty());
    }

    #[test]
    fn base36_matches_js() {
        assert_eq!(to_base36(0), "0");
        assert_eq!(to_base36(35), "z");
        assert_eq!(to_base36(u32::from_str_radix("a1f", 36).unwrap()), "a1f");
    }

    #[test]
    fn camera_json_forms() {
        assert_eq!(camera_to_json(None), json!(0));

        let plain = DecodedCamera {
            x: 1.5,
            y: 2.5,
            force_reset: false,
            shake: None,
        };

        assert_eq!(camera_to_json(Some(&plain)), json!([1.5, 2.5]));

        let reset = DecodedCamera {
            force_reset: true,
            ..plain.clone()
        };

        assert_eq!(camera_to_json(Some(&reset)), json!([1.5, 2.5, true]));

        // shake без reset: слот [2] — null (как в JS-массиве с «дыркой»)
        let shake = DecodedCamera {
            shake: Some("20:200".to_string()),
            ..plain
        };

        assert_eq!(
            camera_to_json(Some(&shake)),
            json!([1.5, 2.5, null, "20:200"])
        );
    }

    #[test]
    fn snapshot_json_matches_unpack_frame_forms() {
        let blocks = vec![
            (
                "m1".to_string(),
                Block::Indexed8(vec![
                    (
                        2,
                        Some(tank_row([51.28, 2.0, 3.0, 4.0, 5.0, 6.0, 7.0], 3, 2, 1)),
                    ),
                    (3, None),
                ]),
            ),
            (
                "w2".to_string(),
                Block::Indexed32(vec![(
                    u32::from_str_radix("a1f", 36).unwrap(),
                    Some(bomb_row(1.0, 2.0, 0.0, 8, 300, 2)),
                )]),
            ),
        ];
        let data = packed_frame(&blocks, None, None);
        let frame = unpack_frame(&data, &test_config()).ok().unwrap();
        let game = Value::Object(snapshot_to_json(&frame.snapshot));

        // round2-значения сериализуются точными двухзначными числами
        assert_eq!(
            game,
            json!({
                "m1": { "2": [51.28, 2.0, 3.0, 4.0, 5.0, 6.0, 7.0, 3, 2, 1], "3": null },
                "w2": { "a1f": [1.0, 2.0, 0.0, 8, 300, 2] },
            })
        );
    }
}