Function array3_parser

redis-server/src/parser.rs:115–165

(input: &[u8])

}

fn array3_parser(input: &[u8]) -> IResult<&[u8], (Cmd<'_>, usize)> {
    let mut taken = 0;

    let (rem, (ln, sz)) = line_parser(input)?;

    taken += sz;

    tag("*3")(ln)?;

    // What is the next value? That tells us if we should proceed now or not.
    let (rem, (itype1, sz)) = type_parser(rem)?;
    taken += sz;

    match itype1 {
        IType::BulkString(b"CONFIG") => {
            let (rem, (itype2, sz)) = type_parser(rem)?;
            taken += sz;
            let (rem, (itype3, sz)) = type_parser(rem)?;
            taken += sz;

            trace!("array3_parser - taken {:?}", taken);

            match (itype2, itype3) {
                (IType::BulkString(b"GET"), IType::BulkString(key)) => {
                    Ok((rem, (Cmd::ConfigGet(key), taken)))
                }
                _ => Ok((rem, (Cmd::Disconnect, taken))),
            }
        }
        IType::BulkString(b"SET") => {
            let (rem, (itype2, sz)) = type_parser(rem)?;
            taken += sz;

            trace!("array3_parser - taken {:?}", taken);

            match itype2 {
                IType::BulkString(key) => {
                    let (rem, (strln, sz)) = bulkstrln_parser(rem)?;
                    taken += sz;
                    trace!("array3_parser - SET - taken {:?}", taken);

                    Ok((rem, (Cmd::Set(key, strln), taken)))
                } // _ => Ok((rem, (Cmd::Disconnect, taken))),
            }
        }
        _ => Ok((rem, (Cmd::Disconnect, taken))),
    }

    // do a "first value" parse, capable of reading if it's bulk or simple string.
    // once we know the first value, can understand the second.
}

fn array2_parser(input: &[u8]) -> IResult<&[u8], (Cmd<'_>, usize)> {
    // The *2 parser then checks the first element