Function parse_value

nodedb/src/control/server/resp/codec.rs:212–233

Parse a RESP value starting at `buf[0]`. Returns `(value, bytes_consumed)`.

(buf: &[u8])

/// Parse a RESP value starting at `buf[0]`. Returns `(value, bytes_consumed)`.
fn parse_value(buf: &[u8]) -> io::Result<Option<(RespValue, usize)>> {
    if buf.is_empty() {
        return Ok(None);
    }

    match buf[0] {
        b'+' => parse_simple_string(&buf[1..])
            .map(|opt| opt.map(|(s, n)| (RespValue::SimpleString(s), n + 1))),
        b'-' => {
            parse_simple_string(&buf[1..]).map(|opt| opt.map(|(s, n)| (RespValue::Error(s), n + 1)))
        }
        b':' => {
            parse_integer(&buf[1..]).map(|opt| opt.map(|(i, n)| (RespValue::Integer(i), n + 1)))
        }
        b'$' => parse_bulk_string(&buf[1..]).map(|opt| opt.map(|(v, n)| (v, n + 1))),
        b'*' => parse_array(&buf[1..]).map(|opt| opt.map(|(v, n)| (v, n + 1))),
        other => Err(io::Error::new(
            io::ErrorKind::InvalidData,
            format!("unexpected RESP type byte: 0x{other:02x}"),
        )),
    }
}

fn parse_simple_string(buf: &[u8]) -> io::Result<Option<(String, usize)>> {
    match find_crlf(buf) {