Function decode_startup_message

src/protocol/codec.rs:77–111

(src: &mut BytesMut)

}

fn decode_startup_message(src: &mut BytesMut) -> io::Result<Option<FrontendMessage>> {
    if src.len() < 4 {
        return Ok(None);
    }
    
    let len = (&src[0..4]).get_i32() as usize;
    
    if src.len() < len {
        return Ok(None);
    }
    
    let msg_bytes = src.split_to(len);
    let mut msg_buf = &msg_bytes[4..]; // Skip length
    
    let protocol_version = msg_buf.get_i32();
    
    // Check for SSL request (protocol version 80877103)
    if protocol_version == 80877103 {
        return Ok(Some(FrontendMessage::SslRequest));
    }
    
    let mut parameters = HashMap::new();
    
    // Read parameter pairs until we hit null terminator
    while msg_buf.has_remaining() && msg_buf[0] != 0 {
        let key = read_cstring(&mut msg_buf)?;
        let value = read_cstring(&mut msg_buf)?;
        parameters.insert(key, value);
    }
    
    Ok(Some(FrontendMessage::StartupMessage(StartupMessage {
        protocol_version,
        parameters,
    })))
}

fn decode_normal_message(src: &mut BytesMut) -> io::Result<Option<FrontendMessage>> {
    if src.len() < 5 {