Function decode_normal_message

src/protocol/codec.rs:113–203

(src: &mut BytesMut)

}

fn decode_normal_message(src: &mut BytesMut) -> io::Result<Option<FrontendMessage>> {
    if src.len() < 5 {
        return Ok(None);
    }
    
    let msg_type = src[0];
    let len = (&src[1..5]).get_i32() as usize;
    
    if src.len() < len + 1 {
        return Ok(None);
    }
    
    let msg_bytes = src.split_to(len + 1);
    let mut msg_buf = &msg_bytes[5..]; // Skip type and length
    
    match msg_type {
        b'Q' => {
            let query = read_cstring(&mut msg_buf)?;
            Ok(Some(FrontendMessage::Query(query)))
        }
        b'P' => {
            let name = read_cstring(&mut msg_buf)?;
            let query = read_cstring(&mut msg_buf)?;
            let param_count = msg_buf.get_i16();
            let mut param_types = Vec::new();
            for _ in 0..param_count {
                param_types.push(msg_buf.get_i32());
            }
            Ok(Some(FrontendMessage::Parse { name, query, param_types }))
        }
        b'B' => {
            let portal = read_cstring(&mut msg_buf)?;
            let statement = read_cstring(&mut msg_buf)?;
            
            let format_count = msg_buf.get_i16();
            let mut formats = Vec::new();
            for _ in 0..format_count {
                formats.push(msg_buf.get_i16());
            }
            
            let value_count = msg_buf.get_i16();
            let mut values = Vec::new();
            for _ in 0..value_count {
                let len = msg_buf.get_i32();
                if len == -1 {
                    values.push(None);
                } else {
                    let mut value = vec![0u8; len as usize];
                    msg_buf.copy_to_slice(&mut value);
                    values.push(Some(value));
                }
            }
            
            let result_format_count = msg_buf.get_i16();
            let mut result_formats = Vec::new();
            for _ in 0..result_format_count {
                result_formats.push(msg_buf.get_i16());
            }