diff options
Diffstat (limited to 'src/resp_parser.h')
| -rw-r--r-- | src/resp_parser.h | 94 |
1 files changed, 94 insertions, 0 deletions
diff --git a/src/resp_parser.h b/src/resp_parser.h new file mode 100644 index 0000000..0b5c8e2 --- /dev/null +++ b/src/resp_parser.h @@ -0,0 +1,94 @@ +/* + * Copyright (c) 2021, Redis Labs Ltd. + * All rights reserved. + * + * Redistribution and use in source and binary forms, with or without + * modification, are permitted provided that the following conditions are met: + * + * * Redistributions of source code must retain the above copyright notice, + * this list of conditions and the following disclaimer. + * * Redistributions in binary form must reproduce the above copyright + * notice, this list of conditions and the following disclaimer in the + * documentation and/or other materials provided with the distribution. + * * Neither the name of Redis nor the names of its contributors may be used + * to endorse or promote products derived from this software without + * specific prior written permission. + * + * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS" + * AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE + * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE + * ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT OWNER OR CONTRIBUTORS BE + * LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR + * CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF + * SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS + * INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN + * CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) + * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE + * POSSIBILITY OF SUCH DAMAGE. + */ + +#ifndef SRC_RESP_PARSER_H_ +#define SRC_RESP_PARSER_H_ + +#include <stddef.h> + +typedef struct ReplyParser ReplyParser; + +typedef struct ReplyParserCallbacks { + /* Called when the parser reaches an empty mbulk ('*-1') */ + void (*null_array_callback)(void *ctx, const char *proto, size_t proto_len); + + /* Called when the parser reaches an empty bulk ('$-1') (bulk len is -1) */ + void (*null_bulk_string_callback)(void *ctx, const char *proto, size_t proto_len); + + /* Called when the parser reaches a bulk ('$'), which is passed as 'str' along with its length 'len' */ + void (*bulk_string_callback)(void *ctx, const char *str, size_t len, const char *proto, size_t proto_len); + + /* Called when the parser reaches an error ('-'), which is passed as 'str' along with its length 'len' */ + void (*error_callback)(void *ctx, const char *str, size_t len, const char *proto, size_t proto_len); + + /* Called when the parser reaches a simple string ('+'), which is passed as 'str' along with its length 'len' */ + void (*simple_str_callback)(void *ctx, const char *str, size_t len, const char *proto, size_t proto_len); + + /* Called when the parser reaches a long long value (':'), which is passed as an argument 'val' */ + void (*long_callback)(void *ctx, long long val, const char *proto, size_t proto_len); + + /* Called when the parser reaches an array ('*'). The array length is passed as an argument 'len' */ + void (*array_callback)(struct ReplyParser *parser, void *ctx, size_t len, const char *proto); + + /* Called when the parser reaches a set ('~'). The set length is passed as an argument 'len' */ + void (*set_callback)(struct ReplyParser *parser, void *ctx, size_t len, const char *proto); + + /* Called when the parser reaches a map ('%'). The map length is passed as an argument 'len' */ + void (*map_callback)(struct ReplyParser *parser, void *ctx, size_t len, const char *proto); + + /* Called when the parser reaches a bool ('#'), which is passed as an argument 'val' */ + void (*bool_callback)(void *ctx, int val, const char *proto, size_t proto_len); + + /* Called when the parser reaches a double (','), which is passed as an argument 'val' */ + void (*double_callback)(void *ctx, double val, const char *proto, size_t proto_len); + + /* Called when the parser reaches a big number ('('), which is passed as 'str' along with its length 'len' */ + void (*big_number_callback)(void *ctx, const char *str, size_t len, const char *proto, size_t proto_len); + + /* Called when the parser reaches a string ('='), which is passed as 'str' along with its 'format' and length 'len' */ + void (*verbatim_string_callback)(void *ctx, const char *format, const char *str, size_t len, const char *proto, size_t proto_len); + + /* Called when the parser reaches an attribute ('|'). The attribute length is passed as an argument 'len' */ + void (*attribute_callback)(struct ReplyParser *parser, void *ctx, size_t len, const char *proto); + + /* Called when the parser reaches a null ('_') */ + void (*null_callback)(void *ctx, const char *proto, size_t proto_len); + + void (*error)(void *ctx); +} ReplyParserCallbacks; + +struct ReplyParser { + /* The current location in the reply buffer, needs to be set to the beginning of the reply */ + const char *curr_location; + ReplyParserCallbacks callbacks; +}; + +int parseReply(ReplyParser *parser, void *p_ctx); + +#endif /* SRC_RESP_PARSER_H_ */ |