Function parse_bulk_string

nodedb/src/control/server/resp/codec.rs:259–286

(buf: &[u8])

}

fn parse_bulk_string(buf: &[u8]) -> io::Result<Option<(RespValue, usize)>> {
    let crlf_pos = match find_crlf(buf) {
        Some(p) => p,
        None => return Ok(None),
    };

    let len_str = std::str::from_utf8(&buf[..crlf_pos])
        .map_err(|e| io::Error::new(io::ErrorKind::InvalidData, e))?;
    let len: i64 = len_str
        .parse()
        .map_err(|e| io::Error::new(io::ErrorKind::InvalidData, e))?;

    if len < 0 {
        return Ok(Some((RespValue::nil(), crlf_pos + 2)));
    }

    let len = len as usize;
    let data_start = crlf_pos + 2;
    let data_end = data_start + len;
    let frame_end = data_end + 2; // trailing \r\n

    if buf.len() < frame_end {
        return Ok(None); // Need more data.
    }

    let data = buf[data_start..data_end].to_vec();
    Ok(Some((RespValue::BulkString(Some(data)), frame_end)))
}

fn parse_array(buf: &[u8]) -> io::Result<Option<(RespValue, usize)>> {
    let crlf_pos = match find_crlf(buf) {