wacore 0.7.0

Core WhatsApp protocol implementation without runtime dependencies
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111

//! WebP format utilities.

/// Detects animated WebP by parsing RIFF/VP8X headers.
pub fn is_animated(data: &[u8]) -> bool {
    // Minimum: RIFF(4) + size(4) + WEBP(4) + chunk header(8) = 20
    if data.len() < 20 {
        return false;
    }
    if &data[0..4] != b"RIFF" || &data[8..12] != b"WEBP" {
        return false;
    }

    let mut offset = 12;
    while offset + 8 <= data.len() {
        let fourcc = &data[offset..offset + 4];
        let chunk_size = u32::from_le_bytes([
            data[offset + 4],
            data[offset + 5],
            data[offset + 6],
            data[offset + 7],
        ]) as usize;

        if fourcc == b"VP8X"
            && chunk_size >= 10
            && offset + 8 < data.len()
            && data[offset + 8] & 0x02 != 0
        {
            return true;
        }

        if fourcc == b"ANIM" || fourcc == b"ANMF" {
            return true;
        }

        // Each addition checked to prevent overflow on 32-bit
        offset = match offset
            .checked_add(8)
            .and_then(|v| v.checked_add(chunk_size))
            .and_then(|v| v.checked_add(chunk_size & 1))
        {
            Some(next) => next,
            None => break,
        };
    }

    false
}

#[cfg(test)]
mod tests {
    use super::*;

    fn make_webp_vp8x(flags: u8) -> Vec<u8> {
        let mut buf = Vec::new();
        // RIFF header
        buf.extend_from_slice(b"RIFF");
        buf.extend_from_slice(&0u32.to_le_bytes()); // placeholder file size
        buf.extend_from_slice(b"WEBP");
        // VP8X chunk
        buf.extend_from_slice(b"VP8X");
        buf.extend_from_slice(&10u32.to_le_bytes()); // chunk size
        buf.push(flags);
        buf.extend_from_slice(&[0u8; 9]); // rest of VP8X payload
        // Fix RIFF size
        let riff_size = (buf.len() - 8) as u32;
        buf[4..8].copy_from_slice(&riff_size.to_le_bytes());
        buf
    }

    #[test]
    fn static_webp() {
        let data = make_webp_vp8x(0x00);
        assert!(!is_animated(&data));
    }

    #[test]
    fn animated_webp_via_flag() {
        let data = make_webp_vp8x(0x02);
        assert!(is_animated(&data));
    }

    #[test]
    fn animated_webp_via_anim_chunk() {
        let mut buf = Vec::new();
        buf.extend_from_slice(b"RIFF");
        buf.extend_from_slice(&0u32.to_le_bytes());
        buf.extend_from_slice(b"WEBP");
        // VP8X without animation flag
        buf.extend_from_slice(b"VP8X");
        buf.extend_from_slice(&10u32.to_le_bytes());
        buf.extend_from_slice(&[0u8; 10]);
        // ANIM chunk
        buf.extend_from_slice(b"ANIM");
        buf.extend_from_slice(&6u32.to_le_bytes());
        buf.extend_from_slice(&[0u8; 6]);
        let riff_size = (buf.len() - 8) as u32;
        buf[4..8].copy_from_slice(&riff_size.to_le_bytes());

        assert!(is_animated(&buf));
    }

    #[test]
    fn too_short() {
        assert!(!is_animated(&[0; 10]));
    }

    #[test]
    fn not_webp() {
        assert!(!is_animated(b"NOT A WEBP FILE AT ALL!!"));
    }
}