Function startup_message

nodedb/tests/pgwire_tls_e2e.rs:124–142

Build a pgwire v3 StartupMessage for `user=nodedb, database=nodedb`.

()

/// Build a pgwire v3 StartupMessage for `user=nodedb, database=nodedb`.
fn startup_message() -> Vec<u8> {
    let mut params: Vec<u8> = Vec::new();
    for (k, v) in &[("user", "nodedb"), ("database", "nodedb")] {
        params.extend_from_slice(k.as_bytes());
        params.push(0);
        params.extend_from_slice(v.as_bytes());
        params.push(0);
    }
    params.push(0); // trailing null

    // Total length = 4 (length field) + 4 (protocol version) + params length.
    let total_len = 4u32 + 4u32 + params.len() as u32;
    let mut msg = Vec::with_capacity(total_len as usize);
    msg.extend_from_slice(&total_len.to_be_bytes());
    // Protocol version 3.0: major=3, minor=0 → 0x00_03_00_00
    msg.extend_from_slice(&196608u32.to_be_bytes());
    msg.extend_from_slice(&params);
    msg
}

/// Build a pgwire simple Query message.
fn query_message(sql: &str) -> Vec<u8> {