Function array4_parser

redis-server/src/parser.rs:78–113

(input: &[u8])

}

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

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

    taken += sz;

    tag("*4")(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"CLIENT") => {
            let (rem, (itype2, sz)) = type_parser(rem)?;
            taken += sz;
            let (rem, (itype3, sz)) = type_parser(rem)?;
            taken += sz;
            let (rem, (itype4, sz)) = type_parser(rem)?;
            taken += sz;

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

            match (itype2, itype3, itype4) {
                (
                    IType::BulkString(b"SETINFO"),
                    IType::BulkString(name),
                    IType::BulkString(version),
                ) => Ok((rem, (Cmd::ClientSetInfo(name, Some(version)), taken))),
                _ => Ok((rem, (Cmd::Disconnect, taken))),
            }
        }
        _ => Ok((rem, (Cmd::Disconnect, taken))),
    }
}

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