Function parse_array

nodedb/src/control/server/resp/codec.rs:288–319

(buf: &[u8])

}

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

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

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

    let count = count as usize;
    let mut offset = crlf_pos + 2;
    let mut items = Vec::with_capacity(count);

    for _ in 0..count {
        match parse_value(&buf[offset..])? {
            Some((value, consumed)) => {
                items.push(value);
                offset += consumed;
            }
            None => return Ok(None), // Need more data.
        }
    }

    Ok(Some((RespValue::Array(Some(items)), offset)))
}

/// Parse an inline command (plain text) into a RESP array of bulk strings.
fn parse_inline_command(line: &[u8]) -> RespValue {