Michal Vasko | 90932a9 | 2020-02-12 14:33:03 +0100 | [diff] [blame] | 1 | /** |
| 2 | * @file parser_json.c |
| 3 | * @author Radek Krejci <rkrejci@cesnet.cz> |
Michal Vasko | 61ad1ff | 2022-02-10 15:48:39 +0100 | [diff] [blame] | 4 | * @author Michal Vasko <mvasko@cesnet.cz> |
Michal Vasko | 90932a9 | 2020-02-12 14:33:03 +0100 | [diff] [blame] | 5 | * @brief JSON data parser for libyang |
| 6 | * |
Michal Vasko | 61ad1ff | 2022-02-10 15:48:39 +0100 | [diff] [blame] | 7 | * Copyright (c) 2020 - 2022 CESNET, z.s.p.o. |
Michal Vasko | 90932a9 | 2020-02-12 14:33:03 +0100 | [diff] [blame] | 8 | * |
| 9 | * This source code is licensed under BSD 3-Clause License (the "License"). |
| 10 | * You may not use this file except in compliance with the License. |
| 11 | * You may obtain a copy of the License at |
| 12 | * |
| 13 | * https://opensource.org/licenses/BSD-3-Clause |
| 14 | */ |
| 15 | |
Radek Krejci | 535ea9f | 2020-05-29 16:01:05 +0200 | [diff] [blame] | 16 | #define _GNU_SOURCE |
Michal Vasko | 90932a9 | 2020-02-12 14:33:03 +0100 | [diff] [blame] | 17 | |
Radek Krejci | 1798aae | 2020-07-14 13:26:06 +0200 | [diff] [blame] | 18 | #include <assert.h> |
Radek Krejci | 47fab89 | 2020-11-05 17:02:41 +0100 | [diff] [blame] | 19 | #include <stdint.h> |
Michal Vasko | 90932a9 | 2020-02-12 14:33:03 +0100 | [diff] [blame] | 20 | #include <stdlib.h> |
| 21 | #include <string.h> |
| 22 | |
Radek Krejci | 535ea9f | 2020-05-29 16:01:05 +0200 | [diff] [blame] | 23 | #include "common.h" |
Michal Vasko | bbdadda | 2022-01-06 11:40:10 +0100 | [diff] [blame] | 24 | #include "compat.h" |
Michal Vasko | 90932a9 | 2020-02-12 14:33:03 +0100 | [diff] [blame] | 25 | #include "context.h" |
Radek Krejci | 47fab89 | 2020-11-05 17:02:41 +0100 | [diff] [blame] | 26 | #include "dict.h" |
Michal Vasko | afac782 | 2020-10-20 14:22:26 +0200 | [diff] [blame] | 27 | #include "in_internal.h" |
Radek Krejci | 1798aae | 2020-07-14 13:26:06 +0200 | [diff] [blame] | 28 | #include "json.h" |
Radek Krejci | 47fab89 | 2020-11-05 17:02:41 +0100 | [diff] [blame] | 29 | #include "log.h" |
Radek Krejci | 7711410 | 2021-03-10 15:21:57 +0100 | [diff] [blame] | 30 | #include "parser_data.h" |
Radek Krejci | 1798aae | 2020-07-14 13:26:06 +0200 | [diff] [blame] | 31 | #include "parser_internal.h" |
Michal Vasko | 61ad1ff | 2022-02-10 15:48:39 +0100 | [diff] [blame] | 32 | #include "plugins_exts.h" |
Radek Krejci | 47fab89 | 2020-11-05 17:02:41 +0100 | [diff] [blame] | 33 | #include "set.h" |
| 34 | #include "tree.h" |
Radek Krejci | 1798aae | 2020-07-14 13:26:06 +0200 | [diff] [blame] | 35 | #include "tree_data.h" |
| 36 | #include "tree_data_internal.h" |
| 37 | #include "tree_schema.h" |
Radek Krejci | 47fab89 | 2020-11-05 17:02:41 +0100 | [diff] [blame] | 38 | #include "tree_schema_internal.h" |
Radek Krejci | 1798aae | 2020-07-14 13:26:06 +0200 | [diff] [blame] | 39 | #include "validation.h" |
Michal Vasko | 90932a9 | 2020-02-12 14:33:03 +0100 | [diff] [blame] | 40 | |
| 41 | /** |
Radek Krejci | 1798aae | 2020-07-14 13:26:06 +0200 | [diff] [blame] | 42 | * @brief Free the JSON data parser context. |
| 43 | * |
| 44 | * JSON implementation of lyd_ctx_free_clb(). |
| 45 | */ |
| 46 | static void |
| 47 | lyd_json_ctx_free(struct lyd_ctx *lydctx) |
| 48 | { |
| 49 | struct lyd_json_ctx *ctx = (struct lyd_json_ctx *)lydctx; |
| 50 | |
| 51 | if (lydctx) { |
| 52 | lyd_ctx_free(lydctx); |
| 53 | lyjson_ctx_free(ctx->jsonctx); |
| 54 | free(ctx); |
| 55 | } |
| 56 | } |
| 57 | |
| 58 | /** |
Michal Vasko | 61ad1ff | 2022-02-10 15:48:39 +0100 | [diff] [blame] | 59 | * @brief Pass the responsibility for releasing the dynamic values to @p dst. |
aPiecek | d2c3937 | 2021-06-16 14:03:12 +0200 | [diff] [blame] | 60 | * |
| 61 | * @param[in] jsonctx JSON context which contains the dynamic value. |
| 62 | * @param[in,out] dst Pointer to which the responsibility will be submited. |
Michal Vasko | 61ad1ff | 2022-02-10 15:48:39 +0100 | [diff] [blame] | 63 | * If the pointer is already pointing to some allocated memory, it is released beforehand. |
aPiecek | d2c3937 | 2021-06-16 14:03:12 +0200 | [diff] [blame] | 64 | */ |
| 65 | static void |
Michal Vasko | 61ad1ff | 2022-02-10 15:48:39 +0100 | [diff] [blame] | 66 | lyjson_ctx_give_dynamic_value(struct lyjson_ctx *jsonctx, char **dst) |
aPiecek | d2c3937 | 2021-06-16 14:03:12 +0200 | [diff] [blame] | 67 | { |
| 68 | assert(jsonctx && dst); |
| 69 | |
| 70 | if (!jsonctx->dynamic) { |
| 71 | return; |
| 72 | } |
| 73 | |
| 74 | if (dst) { |
| 75 | free(*dst); |
| 76 | } |
| 77 | *dst = NULL; |
| 78 | |
Michal Vasko | 61ad1ff | 2022-02-10 15:48:39 +0100 | [diff] [blame] | 79 | /* give the dynamic value */ |
aPiecek | d2c3937 | 2021-06-16 14:03:12 +0200 | [diff] [blame] | 80 | *dst = (char *)jsonctx->value; |
| 81 | |
Michal Vasko | 61ad1ff | 2022-02-10 15:48:39 +0100 | [diff] [blame] | 82 | /* responsibility for the release is now passed to dst */ |
aPiecek | d2c3937 | 2021-06-16 14:03:12 +0200 | [diff] [blame] | 83 | jsonctx->dynamic = 0; |
| 84 | } |
| 85 | |
| 86 | /** |
Radek Krejci | 1798aae | 2020-07-14 13:26:06 +0200 | [diff] [blame] | 87 | * @brief Parse JSON member-name as [\@][prefix:][name] |
| 88 | * |
Michal Vasko | cabe070 | 2020-08-12 10:14:36 +0200 | [diff] [blame] | 89 | * \@ - metadata flag, maps to 1 in @p is_meta_p |
Radek Krejci | 1798aae | 2020-07-14 13:26:06 +0200 | [diff] [blame] | 90 | * prefix - name of the module of the data node |
| 91 | * name - name of the data node |
| 92 | * |
| 93 | * All the output parameter are mandatory. Function only parse the member-name, all the appropriate checks are up to the caller. |
| 94 | * |
| 95 | * @param[in] value String to parse |
| 96 | * @param[in] value_len Length of the @p str. |
| 97 | * @param[out] name_p Pointer to the beginning of the parsed name. |
| 98 | * @param[out] name_len_p Pointer to the length of the parsed name. |
| 99 | * @param[out] prefix_p Pointer to the beginning of the parsed prefix. If the member-name does not contain prefix, result is NULL. |
| 100 | * @param[out] prefix_len_p Pointer to the length of the parsed prefix. If the member-name does not contain prefix, result is 0. |
Michal Vasko | cabe070 | 2020-08-12 10:14:36 +0200 | [diff] [blame] | 101 | * @param[out] is_meta_p Pointer to the metadata flag, set to 1 if the member-name contains \@, 0 otherwise. |
Radek Krejci | 1798aae | 2020-07-14 13:26:06 +0200 | [diff] [blame] | 102 | */ |
| 103 | static void |
Michal Vasko | cabe070 | 2020-08-12 10:14:36 +0200 | [diff] [blame] | 104 | lydjson_parse_name(const char *value, size_t value_len, const char **name_p, size_t *name_len_p, const char **prefix_p, |
Radek Krejci | 857189e | 2020-09-01 13:26:36 +0200 | [diff] [blame] | 105 | size_t *prefix_len_p, ly_bool *is_meta_p) |
Radek Krejci | 1798aae | 2020-07-14 13:26:06 +0200 | [diff] [blame] | 106 | { |
| 107 | const char *name, *prefix = NULL; |
| 108 | size_t name_len, prefix_len = 0; |
Radek Krejci | 857189e | 2020-09-01 13:26:36 +0200 | [diff] [blame] | 109 | ly_bool is_meta = 0; |
Radek Krejci | 1798aae | 2020-07-14 13:26:06 +0200 | [diff] [blame] | 110 | |
| 111 | name = memchr(value, ':', value_len); |
| 112 | if (name != NULL) { |
| 113 | prefix = value; |
| 114 | if (*prefix == '@') { |
Michal Vasko | cabe070 | 2020-08-12 10:14:36 +0200 | [diff] [blame] | 115 | is_meta = 1; |
Radek Krejci | 1798aae | 2020-07-14 13:26:06 +0200 | [diff] [blame] | 116 | prefix++; |
| 117 | } |
| 118 | prefix_len = name - prefix; |
| 119 | name++; |
Michal Vasko | cabe070 | 2020-08-12 10:14:36 +0200 | [diff] [blame] | 120 | name_len = value_len - (prefix_len + 1) - is_meta; |
Radek Krejci | 1798aae | 2020-07-14 13:26:06 +0200 | [diff] [blame] | 121 | } else { |
| 122 | name = value; |
| 123 | if (name[0] == '@') { |
Michal Vasko | cabe070 | 2020-08-12 10:14:36 +0200 | [diff] [blame] | 124 | is_meta = 1; |
Radek Krejci | 1798aae | 2020-07-14 13:26:06 +0200 | [diff] [blame] | 125 | name++; |
| 126 | } |
Michal Vasko | cabe070 | 2020-08-12 10:14:36 +0200 | [diff] [blame] | 127 | name_len = value_len - is_meta; |
Michal Vasko | 90932a9 | 2020-02-12 14:33:03 +0100 | [diff] [blame] | 128 | } |
| 129 | |
Radek Krejci | 1798aae | 2020-07-14 13:26:06 +0200 | [diff] [blame] | 130 | *name_p = name; |
| 131 | *name_len_p = name_len; |
| 132 | *prefix_p = prefix; |
| 133 | *prefix_len_p = prefix_len; |
Michal Vasko | cabe070 | 2020-08-12 10:14:36 +0200 | [diff] [blame] | 134 | *is_meta_p = is_meta; |
Radek Krejci | 1798aae | 2020-07-14 13:26:06 +0200 | [diff] [blame] | 135 | } |
| 136 | |
| 137 | /** |
| 138 | * @brief Get correct prefix (module_name) inside the @p node. |
| 139 | * |
| 140 | * @param[in] node Data node to get inherited prefix. |
| 141 | * @param[in] local_prefix Local prefix to replace the inherited prefix. |
| 142 | * @param[in] local_prefix_len Length of the @p local_prefix string. In case of 0, the inherited prefix is taken. |
| 143 | * @param[out] prefix_p Pointer to the resulting prefix string, Note that the result can be NULL in case of no local prefix |
| 144 | * and no context @p node to get inherited prefix. |
| 145 | * @param[out] prefix_len_p Pointer to the length of the resulting @p prefix_p string. Note that the result can be 0 in case |
| 146 | * of no local prefix and no context @p node to get inherited prefix. |
| 147 | * @return LY_ERR value. |
| 148 | */ |
| 149 | static LY_ERR |
Michal Vasko | a5da329 | 2020-08-12 13:10:50 +0200 | [diff] [blame] | 150 | lydjson_get_node_prefix(struct lyd_node *node, const char *local_prefix, size_t local_prefix_len, const char **prefix_p, |
Radek Krejci | 0f96988 | 2020-08-21 16:56:47 +0200 | [diff] [blame] | 151 | size_t *prefix_len_p) |
Radek Krejci | 1798aae | 2020-07-14 13:26:06 +0200 | [diff] [blame] | 152 | { |
| 153 | struct lyd_node_opaq *onode; |
| 154 | const char *module_name = NULL; |
| 155 | |
| 156 | assert(prefix_p && prefix_len_p); |
| 157 | |
| 158 | if (local_prefix_len) { |
| 159 | *prefix_p = local_prefix; |
| 160 | *prefix_len_p = local_prefix_len; |
| 161 | return LY_SUCCESS; |
| 162 | } |
| 163 | |
| 164 | *prefix_p = NULL; |
| 165 | while (node) { |
| 166 | if (node->schema) { |
| 167 | *prefix_p = node->schema->module->name; |
| 168 | break; |
| 169 | } |
Michal Vasko | 22df3f0 | 2020-08-24 13:29:22 +0200 | [diff] [blame] | 170 | onode = (struct lyd_node_opaq *)node; |
Michal Vasko | ad92b67 | 2020-11-12 13:11:31 +0100 | [diff] [blame] | 171 | if (onode->name.module_name) { |
| 172 | *prefix_p = onode->name.module_name; |
Radek Krejci | 1798aae | 2020-07-14 13:26:06 +0200 | [diff] [blame] | 173 | break; |
Michal Vasko | ad92b67 | 2020-11-12 13:11:31 +0100 | [diff] [blame] | 174 | } else if (onode->name.prefix) { |
| 175 | *prefix_p = onode->name.prefix; |
Radek Krejci | 1798aae | 2020-07-14 13:26:06 +0200 | [diff] [blame] | 176 | break; |
| 177 | } |
Michal Vasko | 9e68508 | 2021-01-29 14:49:09 +0100 | [diff] [blame] | 178 | node = lyd_parent(node); |
Radek Krejci | 1798aae | 2020-07-14 13:26:06 +0200 | [diff] [blame] | 179 | } |
| 180 | *prefix_len_p = ly_strlen(module_name); |
| 181 | |
| 182 | return LY_SUCCESS; |
| 183 | } |
| 184 | |
| 185 | /** |
Michal Vasko | d027f38 | 2023-02-10 09:13:25 +0100 | [diff] [blame] | 186 | * @brief Skip the current JSON item (baed on status). |
Michal Vasko | a4af625 | 2022-05-20 10:38:54 +0200 | [diff] [blame] | 187 | * |
Radek Krejci | 1798aae | 2020-07-14 13:26:06 +0200 | [diff] [blame] | 188 | * @param[in] jsonctx JSON context with the input data to skip. |
| 189 | * @return LY_ERR value. |
| 190 | */ |
| 191 | static LY_ERR |
| 192 | lydjson_data_skip(struct lyjson_ctx *jsonctx) |
| 193 | { |
| 194 | enum LYJSON_PARSER_STATUS status, current; |
Michal Vasko | a4af625 | 2022-05-20 10:38:54 +0200 | [diff] [blame] | 195 | uint32_t orig_depth; |
Radek Krejci | 1798aae | 2020-07-14 13:26:06 +0200 | [diff] [blame] | 196 | |
| 197 | status = lyjson_ctx_status(jsonctx, 0); |
Michal Vasko | a4af625 | 2022-05-20 10:38:54 +0200 | [diff] [blame] | 198 | orig_depth = jsonctx->depth; |
| 199 | |
| 200 | /* next */ |
| 201 | LY_CHECK_RET(lyjson_ctx_next(jsonctx, ¤t)); |
| 202 | |
Michal Vasko | d027f38 | 2023-02-10 09:13:25 +0100 | [diff] [blame] | 203 | if ((status != LYJSON_OBJECT) && (status != LYJSON_ARRAY)) { |
| 204 | return LY_SUCCESS; |
| 205 | } |
| 206 | |
Michal Vasko | a09e866 | 2022-06-15 07:58:24 +0200 | [diff] [blame] | 207 | if ((status == LYJSON_OBJECT) && (current != LYJSON_OBJECT) && (current != LYJSON_ARRAY)) { |
Michal Vasko | a4af625 | 2022-05-20 10:38:54 +0200 | [diff] [blame] | 208 | /* no nested objects */ |
| 209 | LY_CHECK_RET(lyjson_ctx_next(jsonctx, NULL)); |
| 210 | return LY_SUCCESS; |
Michal Vasko | 76096ec | 2022-02-24 16:06:16 +0100 | [diff] [blame] | 211 | } |
Radek Krejci | 1798aae | 2020-07-14 13:26:06 +0200 | [diff] [blame] | 212 | |
| 213 | /* skip after the content */ |
Michal Vasko | a4af625 | 2022-05-20 10:38:54 +0200 | [diff] [blame] | 214 | while ((jsonctx->depth > orig_depth) || (current != status + 1)) { |
Michal Vasko | 4f04d76 | 2022-09-05 08:38:26 +0200 | [diff] [blame] | 215 | if (current == LYJSON_ARRAY) { |
| 216 | /* skip the array separately */ |
| 217 | LY_CHECK_RET(lydjson_data_skip(jsonctx)); |
| 218 | current = lyjson_ctx_status(jsonctx, 0); |
| 219 | } else { |
| 220 | LY_CHECK_RET(lyjson_ctx_next(jsonctx, ¤t)); |
| 221 | } |
Juraj Vijtiuk | 2e88368 | 2021-09-20 17:00:56 +0200 | [diff] [blame] | 222 | |
Michal Vasko | a4af625 | 2022-05-20 10:38:54 +0200 | [diff] [blame] | 223 | if (current == LYJSON_END) { |
| 224 | break; |
Radek Krejci | 1798aae | 2020-07-14 13:26:06 +0200 | [diff] [blame] | 225 | } |
Michal Vasko | a4af625 | 2022-05-20 10:38:54 +0200 | [diff] [blame] | 226 | } |
Radek Krejci | 1798aae | 2020-07-14 13:26:06 +0200 | [diff] [blame] | 227 | |
| 228 | return LY_SUCCESS; |
| 229 | } |
| 230 | |
| 231 | /** |
Michal Vasko | 61ad1ff | 2022-02-10 15:48:39 +0100 | [diff] [blame] | 232 | * @brief Get schema node corresponding to the input parameters. |
| 233 | * |
| 234 | * @param[in] lydctx JSON data parser context. |
| 235 | * @param[in] is_attr Flag if the reference to the node is an attribute, for logging only. |
| 236 | * @param[in] prefix Requested node's prefix (module name). |
| 237 | * @param[in] prefix_len Length of the @p prefix. |
| 238 | * @param[in] name Requested node's name. |
| 239 | * @param[in] name_len Length of the @p name. |
| 240 | * @param[in] parent Parent of the node being processed, can be NULL in case of top-level. |
Michal Vasko | 8cc3f66 | 2022-03-29 11:25:51 +0200 | [diff] [blame] | 241 | * @param[out] snode Found schema node corresponding to the input parameters. If NULL, parse as an opaque node. |
| 242 | * @param[out] ext Extension instance that provided @p snode, if any. |
Michal Vasko | 61ad1ff | 2022-02-10 15:48:39 +0100 | [diff] [blame] | 243 | * @return LY_SUCCES on success. |
| 244 | * @return LY_ENOT if the whole object was parsed (skipped or as an extension). |
| 245 | * @return LY_ERR on error. |
| 246 | */ |
| 247 | static LY_ERR |
| 248 | lydjson_get_snode(struct lyd_json_ctx *lydctx, ly_bool is_attr, const char *prefix, size_t prefix_len, const char *name, |
Michal Vasko | 8cc3f66 | 2022-03-29 11:25:51 +0200 | [diff] [blame] | 249 | size_t name_len, struct lyd_node *parent, const struct lysc_node **snode, struct lysc_ext_instance **ext) |
Michal Vasko | 61ad1ff | 2022-02-10 15:48:39 +0100 | [diff] [blame] | 250 | { |
| 251 | LY_ERR ret = LY_SUCCESS, r; |
| 252 | struct lys_module *mod = NULL; |
| 253 | uint32_t getnext_opts = lydctx->int_opts & LYD_INTOPT_REPLY ? LYS_GETNEXT_OUTPUT : 0; |
| 254 | |
Michal Vasko | 8cc3f66 | 2022-03-29 11:25:51 +0200 | [diff] [blame] | 255 | *snode = NULL; |
| 256 | *ext = NULL; |
Michal Vasko | 61ad1ff | 2022-02-10 15:48:39 +0100 | [diff] [blame] | 257 | |
Michal Vasko | 8cc3f66 | 2022-03-29 11:25:51 +0200 | [diff] [blame] | 258 | /* get the element module, prefer parent context because of extensions */ |
Michal Vasko | 61ad1ff | 2022-02-10 15:48:39 +0100 | [diff] [blame] | 259 | if (prefix_len) { |
Michal Vasko | 8cc3f66 | 2022-03-29 11:25:51 +0200 | [diff] [blame] | 260 | mod = ly_ctx_get_module_implemented2(parent ? LYD_CTX(parent) : lydctx->jsonctx->ctx, prefix, prefix_len); |
Michal Vasko | 61ad1ff | 2022-02-10 15:48:39 +0100 | [diff] [blame] | 261 | } else if (parent) { |
| 262 | if (parent->schema) { |
| 263 | mod = parent->schema->module; |
| 264 | } |
Michal Vasko | e3ed7dc | 2022-11-30 11:39:44 +0100 | [diff] [blame] | 265 | } else if (!(lydctx->int_opts & LYD_INTOPT_ANY)) { |
Michal Vasko | 61ad1ff | 2022-02-10 15:48:39 +0100 | [diff] [blame] | 266 | LOGVAL(lydctx->jsonctx->ctx, LYVE_SYNTAX_JSON, "Top-level JSON object member \"%.*s\" must be namespace-qualified.", |
| 267 | (int)(is_attr ? name_len + 1 : name_len), is_attr ? name - 1 : name); |
| 268 | ret = LY_EVALID; |
| 269 | goto cleanup; |
| 270 | } |
| 271 | if (!mod) { |
| 272 | /* check for extension data */ |
Michal Vasko | 8cc3f66 | 2022-03-29 11:25:51 +0200 | [diff] [blame] | 273 | r = ly_nested_ext_schema(parent, NULL, prefix, prefix_len, LY_VALUE_JSON, NULL, name, name_len, snode, ext); |
| 274 | if (r != LY_ENOT) { |
| 275 | /* success or error */ |
Michal Vasko | 61ad1ff | 2022-02-10 15:48:39 +0100 | [diff] [blame] | 276 | ret = r; |
| 277 | goto cleanup; |
| 278 | } |
| 279 | |
| 280 | /* unknown module */ |
| 281 | if (lydctx->parse_opts & LYD_PARSE_STRICT) { |
| 282 | LOGVAL(lydctx->jsonctx->ctx, LYVE_REFERENCE, "No module named \"%.*s\" in the context.", (int)prefix_len, prefix); |
| 283 | ret = LY_EVALID; |
| 284 | goto cleanup; |
| 285 | } |
| 286 | if (!(lydctx->parse_opts & LYD_PARSE_OPAQ)) { |
| 287 | /* skip element with children */ |
| 288 | ret = lydjson_data_skip(lydctx->jsonctx); |
| 289 | LY_CHECK_GOTO(ret, cleanup); |
| 290 | |
| 291 | ret = LY_ENOT; |
| 292 | goto cleanup; |
| 293 | } |
| 294 | } |
| 295 | |
| 296 | /* get the schema node */ |
| 297 | if (mod && (!parent || parent->schema)) { |
| 298 | if (!parent && lydctx->ext) { |
Michal Vasko | 8cc3f66 | 2022-03-29 11:25:51 +0200 | [diff] [blame] | 299 | *snode = lysc_ext_find_node(lydctx->ext, mod, name, name_len, 0, getnext_opts); |
Michal Vasko | 61ad1ff | 2022-02-10 15:48:39 +0100 | [diff] [blame] | 300 | } else { |
Michal Vasko | 8cc3f66 | 2022-03-29 11:25:51 +0200 | [diff] [blame] | 301 | *snode = lys_find_child(parent ? parent->schema : NULL, mod, name, name_len, 0, getnext_opts); |
Michal Vasko | 61ad1ff | 2022-02-10 15:48:39 +0100 | [diff] [blame] | 302 | } |
Michal Vasko | 8cc3f66 | 2022-03-29 11:25:51 +0200 | [diff] [blame] | 303 | if (!*snode) { |
Michal Vasko | 61ad1ff | 2022-02-10 15:48:39 +0100 | [diff] [blame] | 304 | /* check for extension data */ |
Michal Vasko | 8cc3f66 | 2022-03-29 11:25:51 +0200 | [diff] [blame] | 305 | r = ly_nested_ext_schema(parent, NULL, prefix, prefix_len, LY_VALUE_JSON, NULL, name, name_len, snode, ext); |
| 306 | if (r != LY_ENOT) { |
| 307 | /* success or error */ |
Michal Vasko | 61ad1ff | 2022-02-10 15:48:39 +0100 | [diff] [blame] | 308 | ret = r; |
| 309 | goto cleanup; |
| 310 | } |
| 311 | |
| 312 | /* unknown data node */ |
| 313 | if (lydctx->parse_opts & LYD_PARSE_STRICT) { |
| 314 | if (parent) { |
| 315 | LOGVAL(lydctx->jsonctx->ctx, LYVE_REFERENCE, "Node \"%.*s\" not found as a child of \"%s\" node.", |
| 316 | (int)name_len, name, LYD_NAME(parent)); |
| 317 | } else if (lydctx->ext) { |
| 318 | if (lydctx->ext->argument) { |
| 319 | LOGVAL(lydctx->jsonctx->ctx, LYVE_REFERENCE, |
| 320 | "Node \"%.*s\" not found in the \"%s\" %s extension instance.", |
| 321 | (int)name_len, name, lydctx->ext->argument, lydctx->ext->def->name); |
| 322 | } else { |
| 323 | LOGVAL(lydctx->jsonctx->ctx, LYVE_REFERENCE, "Node \"%.*s\" not found in the %s extension instance.", |
| 324 | (int)name_len, name, lydctx->ext->def->name); |
| 325 | } |
| 326 | } else { |
| 327 | LOGVAL(lydctx->jsonctx->ctx, LYVE_REFERENCE, "Node \"%.*s\" not found in the \"%s\" module.", |
| 328 | (int)name_len, name, mod->name); |
| 329 | } |
| 330 | ret = LY_EVALID; |
| 331 | goto cleanup; |
| 332 | } else if (!(lydctx->parse_opts & LYD_PARSE_OPAQ)) { |
| 333 | /* skip element with children */ |
| 334 | ret = lydjson_data_skip(lydctx->jsonctx); |
| 335 | LY_CHECK_GOTO(ret, cleanup); |
| 336 | |
| 337 | ret = LY_ENOT; |
| 338 | goto cleanup; |
| 339 | } |
| 340 | } else { |
| 341 | /* check that schema node is valid and can be used */ |
Michal Vasko | 8cc3f66 | 2022-03-29 11:25:51 +0200 | [diff] [blame] | 342 | ret = lyd_parser_check_schema((struct lyd_ctx *)lydctx, *snode); |
Michal Vasko | 61ad1ff | 2022-02-10 15:48:39 +0100 | [diff] [blame] | 343 | } |
| 344 | } |
| 345 | |
| 346 | cleanup: |
Michal Vasko | 61ad1ff | 2022-02-10 15:48:39 +0100 | [diff] [blame] | 347 | return ret; |
| 348 | } |
| 349 | |
| 350 | /** |
Radek Krejci | 1798aae | 2020-07-14 13:26:06 +0200 | [diff] [blame] | 351 | * @brief Check that the input data are parseable as the @p list. |
| 352 | * |
| 353 | * Checks for all the list's keys. Function does not revert the context state. |
| 354 | * |
| 355 | * @param[in] jsonctx JSON parser context. |
| 356 | * @param[in] list List schema node corresponding to the input data object. |
| 357 | * @return LY_SUCCESS in case the data are ok for the @p list |
| 358 | * @return LY_ENOT in case the input data are not sufficient to fully parse the list instance. |
| 359 | */ |
| 360 | static LY_ERR |
| 361 | lydjson_check_list(struct lyjson_ctx *jsonctx, const struct lysc_node *list) |
| 362 | { |
| 363 | LY_ERR ret = LY_SUCCESS; |
| 364 | enum LYJSON_PARSER_STATUS status = lyjson_ctx_status(jsonctx, 0); |
| 365 | struct ly_set key_set = {0}; |
| 366 | const struct lysc_node *snode; |
| 367 | uint32_t i, status_count; |
| 368 | |
| 369 | assert(list && (list->nodetype == LYS_LIST)); |
Radek Krejci | 1798aae | 2020-07-14 13:26:06 +0200 | [diff] [blame] | 370 | |
| 371 | /* get all keys into a set (keys do not have if-features or anything) */ |
| 372 | snode = NULL; |
Michal Vasko | 7b1ad1a | 2020-11-02 15:41:27 +0100 | [diff] [blame] | 373 | while ((snode = lys_getnext(snode, list, NULL, 0)) && (snode->flags & LYS_KEY)) { |
Radek Krejci | 3d92e44 | 2020-10-12 12:48:13 +0200 | [diff] [blame] | 374 | ret = ly_set_add(&key_set, (void *)snode, 1, NULL); |
Radek Krejci | ba03a5a | 2020-08-27 14:40:41 +0200 | [diff] [blame] | 375 | LY_CHECK_GOTO(ret, cleanup); |
Radek Krejci | 1798aae | 2020-07-14 13:26:06 +0200 | [diff] [blame] | 376 | } |
| 377 | |
Michal Vasko | 86fdf34 | 2022-12-01 11:08:29 +0100 | [diff] [blame] | 378 | if (status == LYJSON_OBJECT) { |
Radek Krejci | 1798aae | 2020-07-14 13:26:06 +0200 | [diff] [blame] | 379 | status_count = jsonctx->status.count; |
| 380 | |
Michal Vasko | 86fdf34 | 2022-12-01 11:08:29 +0100 | [diff] [blame] | 381 | while (key_set.count && (status != LYJSON_OBJECT_CLOSED)) { |
Radek Krejci | 1798aae | 2020-07-14 13:26:06 +0200 | [diff] [blame] | 382 | const char *name, *prefix; |
| 383 | size_t name_len, prefix_len; |
Radek Krejci | 857189e | 2020-09-01 13:26:36 +0200 | [diff] [blame] | 384 | ly_bool is_attr; |
Radek Krejci | 1798aae | 2020-07-14 13:26:06 +0200 | [diff] [blame] | 385 | |
| 386 | /* match the key */ |
| 387 | snode = NULL; |
| 388 | lydjson_parse_name(jsonctx->value, jsonctx->value_len, &name, &name_len, &prefix, &prefix_len, &is_attr); |
| 389 | |
| 390 | if (!is_attr && !prefix) { |
| 391 | for (i = 0; i < key_set.count; ++i) { |
| 392 | snode = (const struct lysc_node *)key_set.objs[i]; |
| 393 | if (!ly_strncmp(snode->name, name, name_len)) { |
| 394 | break; |
| 395 | } |
| 396 | } |
| 397 | /* go into the item to a) process it as a key or b) start skipping it as another list child */ |
| 398 | ret = lyjson_ctx_next(jsonctx, &status); |
| 399 | LY_CHECK_GOTO(ret, cleanup); |
| 400 | |
| 401 | if (snode) { |
| 402 | /* we have the key, validate the value */ |
| 403 | if (status < LYJSON_NUMBER) { |
| 404 | /* not a terminal */ |
| 405 | ret = LY_ENOT; |
| 406 | goto cleanup; |
| 407 | } |
| 408 | |
Radek Krejci | 8df109d | 2021-04-23 12:19:08 +0200 | [diff] [blame] | 409 | ret = lys_value_validate(NULL, snode, jsonctx->value, jsonctx->value_len, LY_VALUE_JSON, NULL); |
Radek Krejci | 1798aae | 2020-07-14 13:26:06 +0200 | [diff] [blame] | 410 | LY_CHECK_GOTO(ret, cleanup); |
| 411 | |
| 412 | /* key with a valid value, remove from the set */ |
| 413 | ly_set_rm_index(&key_set, i, NULL); |
| 414 | } |
| 415 | } else { |
| 416 | /* start skipping the member we are not interested in */ |
| 417 | ret = lyjson_ctx_next(jsonctx, &status); |
| 418 | LY_CHECK_GOTO(ret, cleanup); |
| 419 | } |
| 420 | /* move to the next child */ |
| 421 | while (status_count < jsonctx->status.count) { |
| 422 | ret = lyjson_ctx_next(jsonctx, &status); |
| 423 | LY_CHECK_GOTO(ret, cleanup); |
| 424 | } |
| 425 | } |
| 426 | } |
| 427 | |
| 428 | if (key_set.count) { |
| 429 | /* some keys are missing/did not validate */ |
| 430 | ret = LY_ENOT; |
| 431 | } |
| 432 | |
| 433 | cleanup: |
| 434 | ly_set_erase(&key_set, NULL); |
| 435 | return ret; |
| 436 | } |
| 437 | |
| 438 | /** |
| 439 | * @brief Get the hint for the data type parsers according to the current JSON parser context. |
| 440 | * |
| 441 | * @param[in] lydctx JSON data parser context. The context is supposed to be on a value. |
| 442 | * @param[in,out] status Pointer to the current context status, |
| 443 | * in some circumstances the function manipulates with the context so the status is updated. |
| 444 | * @param[out] type_hint_p Pointer to the variable to store the result. |
| 445 | * @return LY_SUCCESS in case of success. |
| 446 | * @return LY_EINVAL in case of invalid context status not referring to a value. |
| 447 | */ |
| 448 | static LY_ERR |
Radek Krejci | 1deb5be | 2020-08-26 16:43:36 +0200 | [diff] [blame] | 449 | lydjson_value_type_hint(struct lyd_json_ctx *lydctx, enum LYJSON_PARSER_STATUS *status_p, uint32_t *type_hint_p) |
Radek Krejci | 1798aae | 2020-07-14 13:26:06 +0200 | [diff] [blame] | 450 | { |
| 451 | *type_hint_p = 0; |
| 452 | |
| 453 | if (*status_p == LYJSON_ARRAY) { |
| 454 | /* only [null] */ |
| 455 | LY_CHECK_RET(lyjson_ctx_next(lydctx->jsonctx, status_p)); |
Michal Vasko | 0ebc95f | 2022-07-11 15:55:38 +0200 | [diff] [blame] | 456 | if (*status_p != LYJSON_NULL) { |
Michal Vasko | d1336a3 | 2022-10-25 15:00:20 +0200 | [diff] [blame] | 457 | LOGVAL(lydctx->jsonctx->ctx, LYVE_SYNTAX_JSON, |
| 458 | "Expected JSON name/value or special name/[null], but input data contains name/[%s].", |
Michal Vasko | 0ebc95f | 2022-07-11 15:55:38 +0200 | [diff] [blame] | 459 | lyjson_token2str(*status_p)); |
| 460 | return LY_EINVAL; |
| 461 | } |
Radek Krejci | 1798aae | 2020-07-14 13:26:06 +0200 | [diff] [blame] | 462 | |
| 463 | LY_CHECK_RET(lyjson_ctx_next(lydctx->jsonctx, NULL)); |
Michal Vasko | 0ebc95f | 2022-07-11 15:55:38 +0200 | [diff] [blame] | 464 | if (lyjson_ctx_status(lydctx->jsonctx, 0) != LYJSON_ARRAY_CLOSED) { |
| 465 | LOGVAL(lydctx->jsonctx->ctx, LYVE_SYNTAX_JSON, "Expected array end, but input data contains %s.", |
| 466 | lyjson_token2str(*status_p)); |
| 467 | return LY_EINVAL; |
| 468 | } |
Radek Krejci | 1798aae | 2020-07-14 13:26:06 +0200 | [diff] [blame] | 469 | |
Michal Vasko | feca4fb | 2020-10-05 08:58:40 +0200 | [diff] [blame] | 470 | *type_hint_p = LYD_VALHINT_EMPTY; |
Radek Krejci | 1798aae | 2020-07-14 13:26:06 +0200 | [diff] [blame] | 471 | } else if (*status_p == LYJSON_STRING) { |
Michal Vasko | feca4fb | 2020-10-05 08:58:40 +0200 | [diff] [blame] | 472 | *type_hint_p = LYD_VALHINT_STRING | LYD_VALHINT_NUM64; |
Radek Krejci | 1798aae | 2020-07-14 13:26:06 +0200 | [diff] [blame] | 473 | } else if (*status_p == LYJSON_NUMBER) { |
Michal Vasko | feca4fb | 2020-10-05 08:58:40 +0200 | [diff] [blame] | 474 | *type_hint_p = LYD_VALHINT_DECNUM; |
Michal Vasko | 6973015 | 2020-10-09 16:30:07 +0200 | [diff] [blame] | 475 | } else if ((*status_p == LYJSON_FALSE) || (*status_p == LYJSON_TRUE)) { |
Michal Vasko | feca4fb | 2020-10-05 08:58:40 +0200 | [diff] [blame] | 476 | *type_hint_p = LYD_VALHINT_BOOLEAN; |
Radek Krejci | 1798aae | 2020-07-14 13:26:06 +0200 | [diff] [blame] | 477 | } else if (*status_p == LYJSON_NULL) { |
| 478 | *type_hint_p = 0; |
| 479 | } else { |
Michal Vasko | 0ebc95f | 2022-07-11 15:55:38 +0200 | [diff] [blame] | 480 | LOGVAL(lydctx->jsonctx->ctx, LYVE_SYNTAX_JSON, "Unexpected input data %s.", lyjson_token2str(*status_p)); |
Radek Krejci | 1798aae | 2020-07-14 13:26:06 +0200 | [diff] [blame] | 481 | return LY_EINVAL; |
| 482 | } |
| 483 | |
| 484 | return LY_SUCCESS; |
| 485 | } |
| 486 | |
| 487 | /** |
| 488 | * @brief Check in advance if the input data are parsable according to the provided @p snode. |
| 489 | * |
| 490 | * Note that the checks are done only in case the LYD_PARSE_OPAQ is allowed. Otherwise the same checking |
| 491 | * is naturally done when the data are really parsed. |
| 492 | * |
| 493 | * @param[in] lydctx JSON data parser context. When the function returns, the context is in the same state |
| 494 | * as before calling, despite it is necessary to process input data for checking. |
| 495 | * @param[in] snode Schema node corresponding to the member currently being processed in the context. |
| 496 | * @param[out] type_hint_p Pointer to a variable to store detected value type hint in case of leaf or leaf-list. |
| 497 | * @return LY_SUCCESS in case the data are ok for the @p snode or the LYD_PARSE_OPAQ is not enabled. |
| 498 | * @return LY_ENOT in case the input data are not sufficient to fully parse the list instance |
| 499 | * @return LY_EINVAL in case of invalid leaf JSON encoding |
| 500 | * and they are expected to be parsed as opaq nodes. |
| 501 | */ |
| 502 | static LY_ERR |
Radek Krejci | 1deb5be | 2020-08-26 16:43:36 +0200 | [diff] [blame] | 503 | lydjson_data_check_opaq(struct lyd_json_ctx *lydctx, const struct lysc_node *snode, uint32_t *type_hint_p) |
Radek Krejci | 1798aae | 2020-07-14 13:26:06 +0200 | [diff] [blame] | 504 | { |
| 505 | LY_ERR ret = LY_SUCCESS; |
| 506 | struct lyjson_ctx *jsonctx = lydctx->jsonctx; |
| 507 | enum LYJSON_PARSER_STATUS status; |
| 508 | |
| 509 | assert(snode); |
Radek Krejci | 1798aae | 2020-07-14 13:26:06 +0200 | [diff] [blame] | 510 | |
Michal Vasko | 32ac994 | 2020-08-12 14:35:12 +0200 | [diff] [blame] | 511 | if (!(snode->nodetype & (LYD_NODE_TERM | LYS_LIST))) { |
| 512 | /* can always be parsed as a data node if we have the schema node */ |
| 513 | return LY_SUCCESS; |
| 514 | } |
| 515 | |
Michal Vasko | 8543070 | 2021-07-21 14:29:56 +0200 | [diff] [blame] | 516 | /* backup parser */ |
| 517 | lyjson_ctx_backup(jsonctx); |
| 518 | status = lyjson_ctx_status(jsonctx, 0); |
Radek Krejci | 1798aae | 2020-07-14 13:26:06 +0200 | [diff] [blame] | 519 | |
Michal Vasko | 8543070 | 2021-07-21 14:29:56 +0200 | [diff] [blame] | 520 | if (lydctx->parse_opts & LYD_PARSE_OPAQ) { |
Michal Vasko | 32ac994 | 2020-08-12 14:35:12 +0200 | [diff] [blame] | 521 | /* check if the node is parseable. if not, NULL the snode to announce that it is supposed to be parsed |
| 522 | * as an opaq node */ |
Radek Krejci | 1798aae | 2020-07-14 13:26:06 +0200 | [diff] [blame] | 523 | switch (snode->nodetype) { |
| 524 | case LYS_LEAFLIST: |
| 525 | case LYS_LEAF: |
| 526 | /* value may not be valid in which case we parse it as an opaque node */ |
| 527 | ret = lydjson_value_type_hint(lydctx, &status, type_hint_p); |
| 528 | if (ret) { |
| 529 | break; |
| 530 | } |
| 531 | |
Radek Krejci | 8df109d | 2021-04-23 12:19:08 +0200 | [diff] [blame] | 532 | if (lys_value_validate(NULL, snode, jsonctx->value, jsonctx->value_len, LY_VALUE_JSON, NULL)) { |
Radek Krejci | 1798aae | 2020-07-14 13:26:06 +0200 | [diff] [blame] | 533 | ret = LY_ENOT; |
| 534 | } |
| 535 | break; |
| 536 | case LYS_LIST: |
| 537 | /* lists may not have all its keys */ |
| 538 | if (lydjson_check_list(jsonctx, snode)) { |
Michal Vasko | 86fdf34 | 2022-12-01 11:08:29 +0100 | [diff] [blame] | 539 | /* invalid list, parse as opaque if it misses/has invalid some keys */ |
Radek Krejci | 1798aae | 2020-07-14 13:26:06 +0200 | [diff] [blame] | 540 | ret = LY_ENOT; |
| 541 | } |
Michal Vasko | 32ac994 | 2020-08-12 14:35:12 +0200 | [diff] [blame] | 542 | break; |
Radek Krejci | 1798aae | 2020-07-14 13:26:06 +0200 | [diff] [blame] | 543 | } |
Michal Vasko | 32ac994 | 2020-08-12 14:35:12 +0200 | [diff] [blame] | 544 | } else if (snode->nodetype & LYD_NODE_TERM) { |
Radek Krejci | 1798aae | 2020-07-14 13:26:06 +0200 | [diff] [blame] | 545 | status = lyjson_ctx_status(jsonctx, 0); |
| 546 | ret = lydjson_value_type_hint(lydctx, &status, type_hint_p); |
| 547 | } |
| 548 | |
Michal Vasko | 8543070 | 2021-07-21 14:29:56 +0200 | [diff] [blame] | 549 | /* restore parser */ |
| 550 | lyjson_ctx_restore(jsonctx); |
| 551 | |
Radek Krejci | 1798aae | 2020-07-14 13:26:06 +0200 | [diff] [blame] | 552 | return ret; |
| 553 | } |
| 554 | |
| 555 | /** |
| 556 | * @brief Join the forward-referencing metadata with their target data nodes. |
| 557 | * |
| 558 | * Note that JSON encoding for YANG data allows forward-referencing metadata only for leafs/leaf-lists. |
| 559 | * |
| 560 | * @param[in] lydctx JSON data parser context. |
| 561 | * @param[in,out] first_p Pointer to the first sibling node variable (top-level or in a particular parent node) |
| 562 | * as a starting point to search for the metadata's target data node |
| 563 | * @return LY_SUCCESS on success |
| 564 | * @return LY_EVALID in case there are some metadata with unresolved target data node instance |
| 565 | */ |
| 566 | static LY_ERR |
| 567 | lydjson_metadata_finish(struct lyd_json_ctx *lydctx, struct lyd_node **first_p) |
| 568 | { |
| 569 | LY_ERR ret = LY_SUCCESS; |
aPiecek | 5057c2e | 2021-05-17 10:28:03 +0200 | [diff] [blame] | 570 | struct lyd_node *node, *attr, *next, *meta_iter; |
Michal Vasko | 8cc3f66 | 2022-03-29 11:25:51 +0200 | [diff] [blame] | 571 | struct lysc_ext_instance *ext; |
Radek Krejci | 1deb5be | 2020-08-26 16:43:36 +0200 | [diff] [blame] | 572 | uint64_t instance = 0; |
Radek Krejci | 1798aae | 2020-07-14 13:26:06 +0200 | [diff] [blame] | 573 | const char *prev = NULL; |
Radek Krejci | 2efc45b | 2020-12-22 16:25:44 +0100 | [diff] [blame] | 574 | uint32_t log_location_items = 0; |
Radek Krejci | 1798aae | 2020-07-14 13:26:06 +0200 | [diff] [blame] | 575 | |
| 576 | /* finish linking metadata */ |
| 577 | LY_LIST_FOR_SAFE(*first_p, next, attr) { |
Michal Vasko | 22df3f0 | 2020-08-24 13:29:22 +0200 | [diff] [blame] | 578 | struct lyd_node_opaq *meta_container = (struct lyd_node_opaq *)attr; |
Radek Krejci | 1deb5be | 2020-08-26 16:43:36 +0200 | [diff] [blame] | 579 | uint64_t match = 0; |
Radek Krejci | 857189e | 2020-09-01 13:26:36 +0200 | [diff] [blame] | 580 | ly_bool is_attr; |
Radek Krejci | 1798aae | 2020-07-14 13:26:06 +0200 | [diff] [blame] | 581 | const char *name, *prefix; |
| 582 | size_t name_len, prefix_len; |
| 583 | const struct lysc_node *snode; |
| 584 | |
Michal Vasko | ad92b67 | 2020-11-12 13:11:31 +0100 | [diff] [blame] | 585 | if (attr->schema || (meta_container->name.name[0] != '@')) { |
Radek Krejci | 1798aae | 2020-07-14 13:26:06 +0200 | [diff] [blame] | 586 | /* not an opaq metadata node */ |
| 587 | continue; |
| 588 | } |
| 589 | |
Radek Krejci | ddace2c | 2021-01-08 11:30:56 +0100 | [diff] [blame] | 590 | LOG_LOCSET(NULL, attr, NULL, NULL); |
Radek Krejci | 2efc45b | 2020-12-22 16:25:44 +0100 | [diff] [blame] | 591 | log_location_items++; |
| 592 | |
Michal Vasko | ad92b67 | 2020-11-12 13:11:31 +0100 | [diff] [blame] | 593 | if (prev != meta_container->name.name) { |
Radek Krejci | 1798aae | 2020-07-14 13:26:06 +0200 | [diff] [blame] | 594 | /* metas' names are stored in dictionary, so checking pointers must works */ |
| 595 | lydict_remove(lydctx->jsonctx->ctx, prev); |
Michal Vasko | ad92b67 | 2020-11-12 13:11:31 +0100 | [diff] [blame] | 596 | LY_CHECK_GOTO(ret = lydict_insert(lydctx->jsonctx->ctx, meta_container->name.name, 0, &prev), cleanup); |
Radek Krejci | 1798aae | 2020-07-14 13:26:06 +0200 | [diff] [blame] | 597 | instance = 1; |
| 598 | } else { |
| 599 | instance++; |
| 600 | } |
| 601 | |
aPiecek | 5057c2e | 2021-05-17 10:28:03 +0200 | [diff] [blame] | 602 | /* find the corresponding data node */ |
| 603 | LY_LIST_FOR(*first_p, node) { |
Radek Krejci | 1798aae | 2020-07-14 13:26:06 +0200 | [diff] [blame] | 604 | if (!node->schema) { |
| 605 | /* opaq node - we are going to put into it just a generic attribute. */ |
Michal Vasko | ad92b67 | 2020-11-12 13:11:31 +0100 | [diff] [blame] | 606 | if (strcmp(&meta_container->name.name[1], ((struct lyd_node_opaq *)node)->name.name)) { |
Radek Krejci | 1798aae | 2020-07-14 13:26:06 +0200 | [diff] [blame] | 607 | continue; |
| 608 | } |
| 609 | |
Michal Vasko | feca4fb | 2020-10-05 08:58:40 +0200 | [diff] [blame] | 610 | if (((struct lyd_node_opaq *)node)->hints & LYD_NODEHINT_LIST) { |
Radek Krejci | 2efc45b | 2020-12-22 16:25:44 +0100 | [diff] [blame] | 611 | LOGVAL(lydctx->jsonctx->ctx, LYVE_SYNTAX, "Metadata container references a sibling list node %s.", |
| 612 | ((struct lyd_node_opaq *)node)->name.name); |
Radek Krejci | 1798aae | 2020-07-14 13:26:06 +0200 | [diff] [blame] | 613 | ret = LY_EVALID; |
| 614 | goto cleanup; |
| 615 | } |
| 616 | |
| 617 | /* match */ |
| 618 | match++; |
| 619 | if (match != instance) { |
| 620 | continue; |
| 621 | } |
| 622 | |
| 623 | LY_LIST_FOR(meta_container->child, meta_iter) { |
| 624 | /* convert opaq node to a attribute of the opaq node */ |
Michal Vasko | 22df3f0 | 2020-08-24 13:29:22 +0200 | [diff] [blame] | 625 | struct lyd_node_opaq *meta = (struct lyd_node_opaq *)meta_iter; |
Radek Krejci | bb27df3 | 2020-11-13 15:39:16 +0100 | [diff] [blame] | 626 | |
Michal Vasko | ad92b67 | 2020-11-12 13:11:31 +0100 | [diff] [blame] | 627 | ret = lyd_create_attr(node, NULL, lydctx->jsonctx->ctx, meta->name.name, strlen(meta->name.name), |
| 628 | meta->name.prefix, ly_strlen(meta->name.prefix), meta->name.module_name, |
Radek Krejci | 8df109d | 2021-04-23 12:19:08 +0200 | [diff] [blame] | 629 | ly_strlen(meta->name.module_name), meta->value, ly_strlen(meta->value), NULL, LY_VALUE_JSON, |
Michal Vasko | ad92b67 | 2020-11-12 13:11:31 +0100 | [diff] [blame] | 630 | NULL, meta->hints); |
Radek Krejci | 1798aae | 2020-07-14 13:26:06 +0200 | [diff] [blame] | 631 | LY_CHECK_GOTO(ret, cleanup); |
| 632 | } |
| 633 | |
| 634 | /* done */ |
| 635 | break; |
| 636 | } else { |
| 637 | /* this is the second time we are resolving the schema node, so it must succeed, |
| 638 | * but remember that snode can be still NULL */ |
Michal Vasko | ad92b67 | 2020-11-12 13:11:31 +0100 | [diff] [blame] | 639 | lydjson_parse_name(meta_container->name.name, strlen(meta_container->name.name), &name, &name_len, |
| 640 | &prefix, &prefix_len, &is_attr); |
Radek Krejci | 1798aae | 2020-07-14 13:26:06 +0200 | [diff] [blame] | 641 | assert(is_attr); |
Michal Vasko | 8cc3f66 | 2022-03-29 11:25:51 +0200 | [diff] [blame] | 642 | lydjson_get_snode(lydctx, is_attr, prefix, prefix_len, name, name_len, lyd_parent(*first_p), &snode, &ext); |
Radek Krejci | 1798aae | 2020-07-14 13:26:06 +0200 | [diff] [blame] | 643 | |
| 644 | if (snode != node->schema) { |
| 645 | continue; |
| 646 | } |
| 647 | |
| 648 | /* match */ |
| 649 | match++; |
| 650 | if (match != instance) { |
| 651 | continue; |
| 652 | } |
| 653 | |
| 654 | LY_LIST_FOR(meta_container->child, meta_iter) { |
| 655 | /* convert opaq node to a metadata of the node */ |
Michal Vasko | 22df3f0 | 2020-08-24 13:29:22 +0200 | [diff] [blame] | 656 | struct lyd_node_opaq *meta = (struct lyd_node_opaq *)meta_iter; |
Radek Krejci | 1798aae | 2020-07-14 13:26:06 +0200 | [diff] [blame] | 657 | struct lys_module *mod = NULL; |
Radek Krejci | 1798aae | 2020-07-14 13:26:06 +0200 | [diff] [blame] | 658 | |
Michal Vasko | ad92b67 | 2020-11-12 13:11:31 +0100 | [diff] [blame] | 659 | mod = ly_ctx_get_module_implemented(lydctx->jsonctx->ctx, meta->name.prefix); |
Radek Krejci | 1798aae | 2020-07-14 13:26:06 +0200 | [diff] [blame] | 660 | if (mod) { |
Michal Vasko | 22df3f0 | 2020-08-24 13:29:22 +0200 | [diff] [blame] | 661 | ret = lyd_parser_create_meta((struct lyd_ctx *)lydctx, node, NULL, mod, |
Michal Vasko | ad92b67 | 2020-11-12 13:11:31 +0100 | [diff] [blame] | 662 | meta->name.name, strlen(meta->name.name), meta->value, ly_strlen(meta->value), |
Michal Vasko | ddd7659 | 2022-01-17 13:34:48 +0100 | [diff] [blame] | 663 | NULL, LY_VALUE_JSON, NULL, meta->hints, node->schema); |
Radek Krejci | 1798aae | 2020-07-14 13:26:06 +0200 | [diff] [blame] | 664 | LY_CHECK_GOTO(ret, cleanup); |
Michal Vasko | e066574 | 2021-02-11 11:08:44 +0100 | [diff] [blame] | 665 | } else if (lydctx->parse_opts & LYD_PARSE_STRICT) { |
Michal Vasko | 4eab562 | 2021-07-22 15:36:45 +0200 | [diff] [blame] | 666 | if (meta->name.prefix) { |
| 667 | LOGVAL(lydctx->jsonctx->ctx, LYVE_REFERENCE, |
| 668 | "Unknown (or not implemented) YANG module \"%s\" of metadata \"%s%s%s\".", |
| 669 | meta->name.prefix, meta->name.prefix, ly_strlen(meta->name.prefix) ? ":" : "", |
| 670 | meta->name.name); |
| 671 | } else { |
| 672 | LOGVAL(lydctx->jsonctx->ctx, LYVE_REFERENCE, "Missing YANG module of metadata \"%s\".", |
| 673 | meta->name.name); |
| 674 | } |
Radek Krejci | 1798aae | 2020-07-14 13:26:06 +0200 | [diff] [blame] | 675 | ret = LY_EVALID; |
| 676 | goto cleanup; |
| 677 | } |
| 678 | } |
Radek Krejci | 1798aae | 2020-07-14 13:26:06 +0200 | [diff] [blame] | 679 | |
Michal Vasko | 8cc3f66 | 2022-03-29 11:25:51 +0200 | [diff] [blame] | 680 | /* add/correct flags */ |
| 681 | ret = lyd_parse_set_data_flags(node, &node->meta, (struct lyd_ctx *)lydctx, ext); |
| 682 | LY_CHECK_GOTO(ret, cleanup); |
Radek Krejci | 1798aae | 2020-07-14 13:26:06 +0200 | [diff] [blame] | 683 | break; |
| 684 | } |
| 685 | } |
| 686 | |
| 687 | if (match != instance) { |
| 688 | /* there is no corresponding data node for the metadata */ |
| 689 | if (instance > 1) { |
Michal Vasko | 61ad1ff | 2022-02-10 15:48:39 +0100 | [diff] [blame] | 690 | LOGVAL(lydctx->jsonctx->ctx, LYVE_REFERENCE, |
| 691 | "Missing JSON data instance #%" PRIu64 " to be coupled with %s metadata.", |
Michal Vasko | 54ba891 | 2021-07-23 12:46:23 +0200 | [diff] [blame] | 692 | instance, meta_container->name.name); |
Radek Krejci | 1798aae | 2020-07-14 13:26:06 +0200 | [diff] [blame] | 693 | } else { |
Radek Krejci | 2efc45b | 2020-12-22 16:25:44 +0100 | [diff] [blame] | 694 | LOGVAL(lydctx->jsonctx->ctx, LYVE_REFERENCE, "Missing JSON data instance to be coupled with %s metadata.", |
| 695 | meta_container->name.name); |
Radek Krejci | 1798aae | 2020-07-14 13:26:06 +0200 | [diff] [blame] | 696 | } |
| 697 | ret = LY_EVALID; |
| 698 | } else { |
| 699 | /* remove the opaq attr */ |
| 700 | if (attr == (*first_p)) { |
aPiecek | 5057c2e | 2021-05-17 10:28:03 +0200 | [diff] [blame] | 701 | *first_p = attr->next; |
Radek Krejci | 1798aae | 2020-07-14 13:26:06 +0200 | [diff] [blame] | 702 | } |
| 703 | lyd_free_tree(attr); |
| 704 | } |
Radek Krejci | 2efc45b | 2020-12-22 16:25:44 +0100 | [diff] [blame] | 705 | |
Radek Krejci | ddace2c | 2021-01-08 11:30:56 +0100 | [diff] [blame] | 706 | LOG_LOCBACK(0, log_location_items, 0, 0); |
Radek Krejci | 2efc45b | 2020-12-22 16:25:44 +0100 | [diff] [blame] | 707 | log_location_items = 0; |
Radek Krejci | 1798aae | 2020-07-14 13:26:06 +0200 | [diff] [blame] | 708 | } |
| 709 | |
| 710 | cleanup: |
| 711 | lydict_remove(lydctx->jsonctx->ctx, prev); |
| 712 | |
Radek Krejci | ddace2c | 2021-01-08 11:30:56 +0100 | [diff] [blame] | 713 | LOG_LOCBACK(0, log_location_items, 0, 0); |
Radek Krejci | 1798aae | 2020-07-14 13:26:06 +0200 | [diff] [blame] | 714 | return ret; |
| 715 | } |
| 716 | |
| 717 | /** |
| 718 | * @brief Parse a metadata member. |
| 719 | * |
| 720 | * @param[in] lydctx JSON data parser context. |
| 721 | * @param[in] snode Schema node of the metadata parent. |
| 722 | * @param[in] node Parent node in case the metadata is not forward-referencing (only LYD_NODE_TERM) |
| 723 | * so the data node does not exists. In such a case the metadata is stored in the context for the later |
| 724 | * processing by lydjson_metadata_finish(). |
| 725 | * @return LY_SUCCESS on success |
| 726 | * @return Various LY_ERR values in case of failure. |
| 727 | */ |
| 728 | static LY_ERR |
| 729 | lydjson_metadata(struct lyd_json_ctx *lydctx, const struct lysc_node *snode, struct lyd_node *node) |
| 730 | { |
| 731 | LY_ERR ret = LY_SUCCESS; |
| 732 | enum LYJSON_PARSER_STATUS status; |
| 733 | const char *expected; |
Radek Krejci | 857189e | 2020-09-01 13:26:36 +0200 | [diff] [blame] | 734 | ly_bool in_parent = 0; |
Radek Krejci | 1798aae | 2020-07-14 13:26:06 +0200 | [diff] [blame] | 735 | const char *name, *prefix = NULL; |
aPiecek | 303fb25 | 2021-06-16 11:54:26 +0200 | [diff] [blame] | 736 | char *dynamic_prefname = NULL; |
Radek Krejci | 1798aae | 2020-07-14 13:26:06 +0200 | [diff] [blame] | 737 | size_t name_len, prefix_len = 0; |
| 738 | struct lys_module *mod; |
Radek Krejci | 1798aae | 2020-07-14 13:26:06 +0200 | [diff] [blame] | 739 | const struct ly_ctx *ctx = lydctx->jsonctx->ctx; |
Radek Krejci | 857189e | 2020-09-01 13:26:36 +0200 | [diff] [blame] | 740 | ly_bool is_attr = 0; |
Radek Krejci | 1798aae | 2020-07-14 13:26:06 +0200 | [diff] [blame] | 741 | struct lyd_node *prev = node; |
Michal Vasko | 09d13b3 | 2022-12-01 13:49:50 +0100 | [diff] [blame] | 742 | uint32_t instance = 0, val_hints; |
Radek Krejci | 1798aae | 2020-07-14 13:26:06 +0200 | [diff] [blame] | 743 | uint16_t nodetype; |
| 744 | |
| 745 | assert(snode || node); |
| 746 | |
| 747 | nodetype = snode ? snode->nodetype : LYS_CONTAINER; |
Michal Vasko | 66c1631 | 2022-12-01 10:37:43 +0100 | [diff] [blame] | 748 | LOG_LOCSET(snode, NULL, NULL, NULL); |
Radek Krejci | 1798aae | 2020-07-14 13:26:06 +0200 | [diff] [blame] | 749 | |
| 750 | /* move to the second item in the name/X pair */ |
| 751 | ret = lyjson_ctx_next(lydctx->jsonctx, &status); |
| 752 | LY_CHECK_GOTO(ret, cleanup); |
| 753 | |
| 754 | /* check attribute encoding */ |
| 755 | switch (nodetype) { |
| 756 | case LYS_LEAFLIST: |
| 757 | expected = "@name/array of objects/nulls"; |
| 758 | |
| 759 | LY_CHECK_GOTO(status != LYJSON_ARRAY, representation_error); |
| 760 | |
| 761 | next_entry: |
| 762 | instance++; |
| 763 | |
Michal Vasko | 57c8d43 | 2022-11-30 15:35:56 +0100 | [diff] [blame] | 764 | /* move into array/next entry */ |
Radek Krejci | 1798aae | 2020-07-14 13:26:06 +0200 | [diff] [blame] | 765 | ret = lyjson_ctx_next(lydctx->jsonctx, &status); |
| 766 | LY_CHECK_GOTO(ret, cleanup); |
| 767 | |
| 768 | if (status == LYJSON_ARRAY_CLOSED) { |
Michal Vasko | 57c8d43 | 2022-11-30 15:35:56 +0100 | [diff] [blame] | 769 | /* no more metadata */ |
Radek Krejci | 1798aae | 2020-07-14 13:26:06 +0200 | [diff] [blame] | 770 | goto cleanup; |
| 771 | } |
Michal Vasko | 57c8d43 | 2022-11-30 15:35:56 +0100 | [diff] [blame] | 772 | LY_CHECK_GOTO((status != LYJSON_OBJECT) && (status != LYJSON_NULL), representation_error); |
Radek Krejci | 1798aae | 2020-07-14 13:26:06 +0200 | [diff] [blame] | 773 | |
Michal Vasko | 6973015 | 2020-10-09 16:30:07 +0200 | [diff] [blame] | 774 | if (!node || (node->schema != prev->schema)) { |
Michal Vasko | 54ba891 | 2021-07-23 12:46:23 +0200 | [diff] [blame] | 775 | LOGVAL(lydctx->jsonctx->ctx, LYVE_REFERENCE, "Missing JSON data instance #%u of %s:%s to be coupled with metadata.", |
Michal Vasko | 6973015 | 2020-10-09 16:30:07 +0200 | [diff] [blame] | 776 | instance, prev->schema->module->name, prev->schema->name); |
Radek Krejci | 1798aae | 2020-07-14 13:26:06 +0200 | [diff] [blame] | 777 | ret = LY_EVALID; |
| 778 | goto cleanup; |
| 779 | } |
| 780 | |
| 781 | if (status == LYJSON_NULL) { |
| 782 | /* continue with the next entry in the leaf-list array */ |
| 783 | prev = node; |
| 784 | node = node->next; |
| 785 | goto next_entry; |
| 786 | } |
| 787 | break; |
| 788 | case LYS_LEAF: |
| 789 | case LYS_ANYXML: |
| 790 | expected = "@name/object"; |
| 791 | |
aPiecek | 5b115fc | 2021-05-24 14:32:42 +0200 | [diff] [blame] | 792 | LY_CHECK_GOTO(status != LYJSON_OBJECT, representation_error); |
Radek Krejci | 1798aae | 2020-07-14 13:26:06 +0200 | [diff] [blame] | 793 | break; |
| 794 | case LYS_CONTAINER: |
| 795 | case LYS_LIST: |
| 796 | case LYS_ANYDATA: |
| 797 | case LYS_NOTIF: |
| 798 | case LYS_ACTION: |
| 799 | case LYS_RPC: |
| 800 | in_parent = 1; |
| 801 | expected = "@/object"; |
| 802 | LY_CHECK_GOTO(status != LYJSON_OBJECT, representation_error); |
| 803 | break; |
Radek Krejci | 8f5fad2 | 2020-09-15 16:50:54 +0200 | [diff] [blame] | 804 | default: |
Michal Vasko | 66c1631 | 2022-12-01 10:37:43 +0100 | [diff] [blame] | 805 | LOGINT(ctx); |
| 806 | ret = LY_EINT; |
| 807 | goto cleanup; |
Radek Krejci | 1798aae | 2020-07-14 13:26:06 +0200 | [diff] [blame] | 808 | } |
| 809 | |
| 810 | /* process all the members inside a single metadata object */ |
| 811 | assert(status == LYJSON_OBJECT); |
Radek Krejci | 1798aae | 2020-07-14 13:26:06 +0200 | [diff] [blame] | 812 | while (status != LYJSON_OBJECT_CLOSED) { |
Michal Vasko | ebcd9a9 | 2022-05-23 08:06:34 +0200 | [diff] [blame] | 813 | LY_CHECK_GOTO(status != LYJSON_OBJECT, representation_error); |
| 814 | |
aPiecek | d2c3937 | 2021-06-16 14:03:12 +0200 | [diff] [blame] | 815 | lydjson_parse_name(lydctx->jsonctx->value, lydctx->jsonctx->value_len, &name, &name_len, &prefix, &prefix_len, &is_attr); |
Michal Vasko | 61ad1ff | 2022-02-10 15:48:39 +0100 | [diff] [blame] | 816 | lyjson_ctx_give_dynamic_value(lydctx->jsonctx, &dynamic_prefname); |
aPiecek | 303fb25 | 2021-06-16 11:54:26 +0200 | [diff] [blame] | 817 | |
Michal Vasko | 69d0ca1 | 2021-07-23 10:22:03 +0200 | [diff] [blame] | 818 | if (!name_len) { |
| 819 | LOGVAL(ctx, LYVE_SYNTAX_JSON, "Metadata in JSON found with an empty name, followed by: %.10s", name); |
| 820 | ret = LY_EVALID; |
| 821 | goto cleanup; |
| 822 | } else if (!prefix_len) { |
Radek Krejci | 2efc45b | 2020-12-22 16:25:44 +0100 | [diff] [blame] | 823 | LOGVAL(ctx, LYVE_SYNTAX_JSON, "Metadata in JSON must be namespace-qualified, missing prefix for \"%.*s\".", |
Radek Krejci | 422afb1 | 2021-03-04 16:38:16 +0100 | [diff] [blame] | 824 | (int)lydctx->jsonctx->value_len, lydctx->jsonctx->value); |
Radek Krejci | 1798aae | 2020-07-14 13:26:06 +0200 | [diff] [blame] | 825 | ret = LY_EVALID; |
| 826 | goto cleanup; |
| 827 | } else if (is_attr) { |
Radek Krejci | 2efc45b | 2020-12-22 16:25:44 +0100 | [diff] [blame] | 828 | LOGVAL(ctx, LYVE_SYNTAX_JSON, "Invalid format of the Metadata identifier in JSON, unexpected '@' in \"%.*s\"", |
Radek Krejci | 422afb1 | 2021-03-04 16:38:16 +0100 | [diff] [blame] | 829 | (int)lydctx->jsonctx->value_len, lydctx->jsonctx->value); |
Radek Krejci | 1798aae | 2020-07-14 13:26:06 +0200 | [diff] [blame] | 830 | ret = LY_EVALID; |
| 831 | goto cleanup; |
| 832 | } |
| 833 | |
| 834 | /* get the element module */ |
| 835 | mod = ly_ctx_get_module_implemented2(ctx, prefix, prefix_len); |
| 836 | if (!mod) { |
Michal Vasko | e066574 | 2021-02-11 11:08:44 +0100 | [diff] [blame] | 837 | if (lydctx->parse_opts & LYD_PARSE_STRICT) { |
Radek Krejci | 2efc45b | 2020-12-22 16:25:44 +0100 | [diff] [blame] | 838 | LOGVAL(ctx, LYVE_REFERENCE, "Prefix \"%.*s\" of the metadata \"%.*s\" does not match any module in the context.", |
Radek Krejci | 422afb1 | 2021-03-04 16:38:16 +0100 | [diff] [blame] | 839 | (int)prefix_len, prefix, (int)name_len, name); |
Radek Krejci | 1798aae | 2020-07-14 13:26:06 +0200 | [diff] [blame] | 840 | ret = LY_EVALID; |
| 841 | goto cleanup; |
| 842 | } |
Michal Vasko | a556f16 | 2022-01-17 14:08:30 +0100 | [diff] [blame] | 843 | if (node->schema) { |
Radek Krejci | 1798aae | 2020-07-14 13:26:06 +0200 | [diff] [blame] | 844 | /* skip element with children */ |
| 845 | ret = lydjson_data_skip(lydctx->jsonctx); |
| 846 | LY_CHECK_GOTO(ret, cleanup); |
| 847 | status = lyjson_ctx_status(lydctx->jsonctx, 0); |
| 848 | /* end of the item */ |
| 849 | continue; |
| 850 | } |
Michal Vasko | a556f16 | 2022-01-17 14:08:30 +0100 | [diff] [blame] | 851 | assert(lydctx->parse_opts & LYD_PARSE_OPAQ); |
Radek Krejci | 1798aae | 2020-07-14 13:26:06 +0200 | [diff] [blame] | 852 | } |
| 853 | |
| 854 | /* get the value */ |
Michal Vasko | 09d13b3 | 2022-12-01 13:49:50 +0100 | [diff] [blame] | 855 | ret = lyjson_ctx_next(lydctx->jsonctx, &status); |
| 856 | LY_CHECK_GOTO(ret, cleanup); |
| 857 | |
| 858 | /* get value hints */ |
| 859 | ret = lydjson_value_type_hint(lydctx, &status, &val_hints); |
Radek Krejci | 1798aae | 2020-07-14 13:26:06 +0200 | [diff] [blame] | 860 | LY_CHECK_GOTO(ret, cleanup); |
| 861 | |
| 862 | if (node->schema) { |
| 863 | /* create metadata */ |
Michal Vasko | b404355 | 2022-12-01 10:11:55 +0100 | [diff] [blame] | 864 | ret = lyd_parser_create_meta((struct lyd_ctx *)lydctx, node, NULL, mod, name, name_len, lydctx->jsonctx->value, |
Michal Vasko | 09d13b3 | 2022-12-01 13:49:50 +0100 | [diff] [blame] | 865 | lydctx->jsonctx->value_len, &lydctx->jsonctx->dynamic, LY_VALUE_JSON, NULL, val_hints, node->schema); |
Radek Krejci | 1798aae | 2020-07-14 13:26:06 +0200 | [diff] [blame] | 866 | LY_CHECK_GOTO(ret, cleanup); |
| 867 | |
| 868 | /* add/correct flags */ |
Michal Vasko | b404355 | 2022-12-01 10:11:55 +0100 | [diff] [blame] | 869 | ret = lyd_parse_set_data_flags(node, &node->meta, (struct lyd_ctx *)lydctx, NULL); |
Michal Vasko | 8cc3f66 | 2022-03-29 11:25:51 +0200 | [diff] [blame] | 870 | LY_CHECK_GOTO(ret, cleanup); |
Radek Krejci | 1798aae | 2020-07-14 13:26:06 +0200 | [diff] [blame] | 871 | } else { |
| 872 | /* create attribute */ |
Radek Krejci | 1798aae | 2020-07-14 13:26:06 +0200 | [diff] [blame] | 873 | const char *module_name; |
| 874 | size_t module_name_len; |
| 875 | |
| 876 | lydjson_get_node_prefix(node, prefix, prefix_len, &module_name, &module_name_len); |
| 877 | |
Radek Krejci | 1798aae | 2020-07-14 13:26:06 +0200 | [diff] [blame] | 878 | /* attr2 is always changed to the created attribute */ |
Michal Vasko | 501af03 | 2020-11-11 20:27:44 +0100 | [diff] [blame] | 879 | ret = lyd_create_attr(node, NULL, lydctx->jsonctx->ctx, name, name_len, prefix, prefix_len, module_name, |
| 880 | module_name_len, lydctx->jsonctx->value, lydctx->jsonctx->value_len, &lydctx->jsonctx->dynamic, |
Michal Vasko | 09d13b3 | 2022-12-01 13:49:50 +0100 | [diff] [blame] | 881 | LY_VALUE_JSON, NULL, val_hints); |
Radek Krejci | 1798aae | 2020-07-14 13:26:06 +0200 | [diff] [blame] | 882 | LY_CHECK_GOTO(ret, cleanup); |
| 883 | } |
| 884 | /* next member */ |
| 885 | ret = lyjson_ctx_next(lydctx->jsonctx, &status); |
| 886 | LY_CHECK_GOTO(ret, cleanup); |
aPiecek | de3c692 | 2021-05-24 14:42:10 +0200 | [diff] [blame] | 887 | LY_CHECK_GOTO((status != LYJSON_OBJECT) && (status != LYJSON_OBJECT_CLOSED), representation_error); |
Radek Krejci | 1798aae | 2020-07-14 13:26:06 +0200 | [diff] [blame] | 888 | } |
| 889 | |
| 890 | if (nodetype == LYS_LEAFLIST) { |
| 891 | /* continue by processing another metadata object for the following |
Michal Vasko | b404355 | 2022-12-01 10:11:55 +0100 | [diff] [blame] | 892 | * leaf-list instance since they are always instantiated in JSON array */ |
Radek Krejci | 1798aae | 2020-07-14 13:26:06 +0200 | [diff] [blame] | 893 | prev = node; |
| 894 | node = node->next; |
| 895 | goto next_entry; |
| 896 | } |
| 897 | |
Radek Krejci | 5813c36 | 2021-01-05 10:51:57 +0100 | [diff] [blame] | 898 | /* success */ |
| 899 | goto cleanup; |
Radek Krejci | 1798aae | 2020-07-14 13:26:06 +0200 | [diff] [blame] | 900 | |
| 901 | representation_error: |
Radek Krejci | 2efc45b | 2020-12-22 16:25:44 +0100 | [diff] [blame] | 902 | LOGVAL(ctx, LYVE_SYNTAX_JSON, |
Michal Vasko | 6973015 | 2020-10-09 16:30:07 +0200 | [diff] [blame] | 903 | "The attribute(s) of %s \"%s\" is expected to be represented as JSON %s, but input data contains @%s/%s.", |
Michal Vasko | 5722c1b | 2022-01-24 07:47:49 +0100 | [diff] [blame] | 904 | lys_nodetype2str(nodetype), node ? LYD_NAME(node) : LYD_NAME(prev), expected, lyjson_token2str(status), |
| 905 | in_parent ? "" : "name"); |
Radek Krejci | 2efc45b | 2020-12-22 16:25:44 +0100 | [diff] [blame] | 906 | ret = LY_EVALID; |
Radek Krejci | 5813c36 | 2021-01-05 10:51:57 +0100 | [diff] [blame] | 907 | |
| 908 | cleanup: |
aPiecek | 303fb25 | 2021-06-16 11:54:26 +0200 | [diff] [blame] | 909 | free(dynamic_prefname); |
Radek Krejci | ddace2c | 2021-01-08 11:30:56 +0100 | [diff] [blame] | 910 | LOG_LOCBACK(1, 0, 0, 0); |
Radek Krejci | 5813c36 | 2021-01-05 10:51:57 +0100 | [diff] [blame] | 911 | return ret; |
Radek Krejci | 1798aae | 2020-07-14 13:26:06 +0200 | [diff] [blame] | 912 | } |
| 913 | |
| 914 | /** |
Michal Vasko | 6ee6f43 | 2021-07-16 09:49:14 +0200 | [diff] [blame] | 915 | * @brief Eat the node pointed by @p node_p by inserting it into @p parent and maintain the @p first_p pointing |
| 916 | * to the first child node. |
Radek Krejci | 1798aae | 2020-07-14 13:26:06 +0200 | [diff] [blame] | 917 | * |
| 918 | * @param[in] parent Parent node to insert to, can be NULL in case of top-level (or provided first_p). |
Michal Vasko | 6ee6f43 | 2021-07-16 09:49:14 +0200 | [diff] [blame] | 919 | * @param[in,out] first_p Pointer to the first sibling node in case of top-level. |
| 920 | * @param[in,out] node_p pointer to the new node to insert, after the insert is done, pointer is set to NULL. |
| 921 | * @param[in] last If set, always insert at the end. |
Michal Vasko | 8cc3f66 | 2022-03-29 11:25:51 +0200 | [diff] [blame] | 922 | * @param[in] ext Extension instance of @p node_p, if any. |
Radek Krejci | 1798aae | 2020-07-14 13:26:06 +0200 | [diff] [blame] | 923 | */ |
| 924 | static void |
Michal Vasko | 8cc3f66 | 2022-03-29 11:25:51 +0200 | [diff] [blame] | 925 | lydjson_maintain_children(struct lyd_node *parent, struct lyd_node **first_p, struct lyd_node **node_p, ly_bool last, |
| 926 | struct lysc_ext_instance *ext) |
Radek Krejci | 1798aae | 2020-07-14 13:26:06 +0200 | [diff] [blame] | 927 | { |
Michal Vasko | d027f38 | 2023-02-10 09:13:25 +0100 | [diff] [blame] | 928 | if (!*node_p) { |
| 929 | return; |
| 930 | } |
| 931 | |
| 932 | /* insert, keep first pointer correct */ |
| 933 | if (ext) { |
| 934 | lyplg_ext_insert(parent, *node_p); |
| 935 | } else { |
| 936 | lyd_insert_node(parent, first_p, *node_p, last); |
| 937 | } |
| 938 | if (first_p) { |
| 939 | if (parent) { |
| 940 | *first_p = lyd_child(parent); |
Michal Vasko | 8cc3f66 | 2022-03-29 11:25:51 +0200 | [diff] [blame] | 941 | } else { |
Michal Vasko | d027f38 | 2023-02-10 09:13:25 +0100 | [diff] [blame] | 942 | while ((*first_p)->prev->next) { |
| 943 | *first_p = (*first_p)->prev; |
Radek Krejci | 1798aae | 2020-07-14 13:26:06 +0200 | [diff] [blame] | 944 | } |
| 945 | } |
Radek Krejci | 1798aae | 2020-07-14 13:26:06 +0200 | [diff] [blame] | 946 | } |
Michal Vasko | d027f38 | 2023-02-10 09:13:25 +0100 | [diff] [blame] | 947 | *node_p = NULL; |
Radek Krejci | 1798aae | 2020-07-14 13:26:06 +0200 | [diff] [blame] | 948 | } |
| 949 | |
aPiecek | 4bf4721 | 2021-05-27 10:55:47 +0200 | [diff] [blame] | 950 | /** |
| 951 | * @brief Wrapper for ::lyd_create_opaq(). |
| 952 | * |
| 953 | * @param[in] lydctx JSON data parser context. |
| 954 | * @param[in] name Name of the opaq node to create. |
| 955 | * @param[in] name_len Length of the @p name string. |
| 956 | * @param[in] prefix Prefix of the opaq node to create. |
| 957 | * @param[in] prefix_len Length of the @p prefx string. |
| 958 | * @param[in] parent Data parent of the opaq node to create, can be NULL in case of top level, |
| 959 | * but must be set if @p first is not. |
| 960 | * @param[in,out] status_inner_p In case of processing JSON array, this parameter points to a standalone |
| 961 | * context status of the array content. Otherwise, it is supposed to be the same as @p status_p. |
| 962 | * @param[out] node_p Pointer to the created opaq node. |
| 963 | * @return LY_ERR value. |
| 964 | */ |
| 965 | static LY_ERR |
| 966 | lydjson_create_opaq(struct lyd_json_ctx *lydctx, const char *name, size_t name_len, const char *prefix, size_t prefix_len, |
Michal Vasko | 61ad1ff | 2022-02-10 15:48:39 +0100 | [diff] [blame] | 967 | struct lyd_node *parent, enum LYJSON_PARSER_STATUS *status_inner_p, struct lyd_node **node_p) |
aPiecek | 4bf4721 | 2021-05-27 10:55:47 +0200 | [diff] [blame] | 968 | { |
| 969 | LY_ERR ret = LY_SUCCESS; |
| 970 | const char *value = NULL, *module_name; |
| 971 | size_t value_len = 0, module_name_len = 0; |
| 972 | ly_bool dynamic = 0; |
| 973 | uint32_t type_hint = 0; |
| 974 | |
| 975 | if ((*status_inner_p != LYJSON_OBJECT) && (*status_inner_p != LYJSON_OBJECT_EMPTY)) { |
| 976 | /* prepare for creating opaq node with a value */ |
| 977 | value = lydctx->jsonctx->value; |
| 978 | value_len = lydctx->jsonctx->value_len; |
| 979 | dynamic = lydctx->jsonctx->dynamic; |
| 980 | lydctx->jsonctx->dynamic = 0; |
| 981 | |
| 982 | LY_CHECK_RET(lydjson_value_type_hint(lydctx, status_inner_p, &type_hint)); |
| 983 | } |
| 984 | |
| 985 | /* create node */ |
Michal Vasko | 61ad1ff | 2022-02-10 15:48:39 +0100 | [diff] [blame] | 986 | lydjson_get_node_prefix(parent, prefix, prefix_len, &module_name, &module_name_len); |
aPiecek | 4bf4721 | 2021-05-27 10:55:47 +0200 | [diff] [blame] | 987 | ret = lyd_create_opaq(lydctx->jsonctx->ctx, name, name_len, prefix, prefix_len, module_name, module_name_len, value, |
| 988 | value_len, &dynamic, LY_VALUE_JSON, NULL, type_hint, node_p); |
| 989 | if (dynamic) { |
| 990 | free((char *)value); |
| 991 | } |
| 992 | |
| 993 | return ret; |
| 994 | } |
| 995 | |
Michal Vasko | e066574 | 2021-02-11 11:08:44 +0100 | [diff] [blame] | 996 | static LY_ERR lydjson_subtree_r(struct lyd_json_ctx *lydctx, struct lyd_node *parent, struct lyd_node **first_p, |
| 997 | struct ly_set *parsed); |
Radek Krejci | 1798aae | 2020-07-14 13:26:06 +0200 | [diff] [blame] | 998 | |
| 999 | /** |
| 1000 | * @brief Parse opaq node from the input. |
| 1001 | * |
| 1002 | * In case of processing array, the whole array is being processed and the resulting @p node_p is the last item of the array. |
| 1003 | * |
| 1004 | * @param[in] lydctx JSON data parser context. |
| 1005 | * @param[in] name Name of the opaq node to create. |
| 1006 | * @param[in] name_len Length of the @p name string. |
| 1007 | * @param[in] prefix Prefix of the opaq node to create. |
| 1008 | * @param[in] prefix_len Length of the @p prefx string. |
| 1009 | * @param[in] parent Data parent of the opaq node to create, can be NULL in case of top level, |
| 1010 | * but must be set if @p first is not. |
| 1011 | * @param[in,out] status_p Pointer to the current status of the parser context, |
| 1012 | * since the function manipulates with the context and process the input, the status can be updated. |
| 1013 | * @param[in,out] status_inner_p In case of processing JSON array, this parameter points to a standalone |
| 1014 | * context status of the array content. Otherwise, it is supposed to be the same as @p status_p. |
| 1015 | * @param[in,out] first_p First top-level/parent sibling, must be set if @p parent is not. |
| 1016 | * @param[out] node_p Pointer to the created opaq node. |
| 1017 | * @return LY_ERR value. |
| 1018 | */ |
| 1019 | static LY_ERR |
Michal Vasko | a5da329 | 2020-08-12 13:10:50 +0200 | [diff] [blame] | 1020 | lydjson_parse_opaq(struct lyd_json_ctx *lydctx, const char *name, size_t name_len, const char *prefix, size_t prefix_len, |
Michal Vasko | 61ad1ff | 2022-02-10 15:48:39 +0100 | [diff] [blame] | 1021 | struct lyd_node *parent, enum LYJSON_PARSER_STATUS *status_p, enum LYJSON_PARSER_STATUS *status_inner_p, |
| 1022 | struct lyd_node **first_p, struct lyd_node **node_p) |
Radek Krejci | 1798aae | 2020-07-14 13:26:06 +0200 | [diff] [blame] | 1023 | { |
Michal Vasko | 61ad1ff | 2022-02-10 15:48:39 +0100 | [diff] [blame] | 1024 | LY_CHECK_RET(lydjson_create_opaq(lydctx, name, name_len, prefix, prefix_len, parent, status_inner_p, node_p)); |
Radek Krejci | 1798aae | 2020-07-14 13:26:06 +0200 | [diff] [blame] | 1025 | |
Michal Vasko | 1a85d33 | 2021-08-27 10:35:28 +0200 | [diff] [blame] | 1026 | if ((*status_p == LYJSON_ARRAY) && (*status_inner_p == LYJSON_NULL)) { |
| 1027 | /* special array null value */ |
| 1028 | ((struct lyd_node_opaq *)*node_p)->hints |= LYD_VALHINT_EMPTY; |
| 1029 | |
| 1030 | /* must be the only item */ |
| 1031 | LY_CHECK_RET(lyjson_ctx_next(lydctx->jsonctx, status_inner_p)); |
| 1032 | if (*status_inner_p != LYJSON_ARRAY_CLOSED) { |
| 1033 | LOGVAL(lydctx->jsonctx->ctx, LYVE_SYNTAX, "Array \"null\" member with another member."); |
| 1034 | return LY_EVALID; |
| 1035 | } |
| 1036 | |
| 1037 | goto finish; |
| 1038 | } |
| 1039 | |
aPiecek | dbb8baf | 2021-05-27 11:01:51 +0200 | [diff] [blame] | 1040 | while ((*status_p == LYJSON_ARRAY) || (*status_p == LYJSON_ARRAY_EMPTY)) { |
Radek Krejci | 1798aae | 2020-07-14 13:26:06 +0200 | [diff] [blame] | 1041 | /* process another instance of the same node */ |
Radek Krejci | 1798aae | 2020-07-14 13:26:06 +0200 | [diff] [blame] | 1042 | |
Michal Vasko | 6973015 | 2020-10-09 16:30:07 +0200 | [diff] [blame] | 1043 | if ((*status_inner_p == LYJSON_OBJECT) || (*status_inner_p == LYJSON_OBJECT_EMPTY)) { |
Michal Vasko | 1a85d33 | 2021-08-27 10:35:28 +0200 | [diff] [blame] | 1044 | /* array with objects, list */ |
| 1045 | ((struct lyd_node_opaq *)*node_p)->hints |= LYD_NODEHINT_LIST; |
| 1046 | |
Radek Krejci | 1798aae | 2020-07-14 13:26:06 +0200 | [diff] [blame] | 1047 | /* but first process children of the object in the array */ |
Michal Vasko | 1a85d33 | 2021-08-27 10:35:28 +0200 | [diff] [blame] | 1048 | while ((*status_inner_p != LYJSON_OBJECT_CLOSED) && (*status_inner_p != LYJSON_OBJECT_EMPTY)) { |
Michal Vasko | e066574 | 2021-02-11 11:08:44 +0100 | [diff] [blame] | 1049 | LY_CHECK_RET(lydjson_subtree_r(lydctx, *node_p, lyd_node_child_p(*node_p), NULL)); |
Radek Krejci | 1798aae | 2020-07-14 13:26:06 +0200 | [diff] [blame] | 1050 | *status_inner_p = lyjson_ctx_status(lydctx->jsonctx, 0); |
| 1051 | } |
Michal Vasko | 1a85d33 | 2021-08-27 10:35:28 +0200 | [diff] [blame] | 1052 | } else { |
| 1053 | /* array with values, leaf-list */ |
| 1054 | ((struct lyd_node_opaq *)*node_p)->hints |= LYD_NODEHINT_LEAFLIST; |
Radek Krejci | 1798aae | 2020-07-14 13:26:06 +0200 | [diff] [blame] | 1055 | } |
| 1056 | |
| 1057 | LY_CHECK_RET(lyjson_ctx_next(lydctx->jsonctx, status_inner_p)); |
aPiecek | dbb8baf | 2021-05-27 11:01:51 +0200 | [diff] [blame] | 1058 | if (*status_inner_p == LYJSON_ARRAY_CLOSED) { |
| 1059 | goto finish; |
| 1060 | } |
Radek Krejci | 1798aae | 2020-07-14 13:26:06 +0200 | [diff] [blame] | 1061 | |
| 1062 | /* continue with the next instance */ |
aPiecek | dbb8baf | 2021-05-27 11:01:51 +0200 | [diff] [blame] | 1063 | assert(node_p); |
Michal Vasko | 8cc3f66 | 2022-03-29 11:25:51 +0200 | [diff] [blame] | 1064 | lydjson_maintain_children(parent, first_p, node_p, lydctx->parse_opts & LYD_PARSE_ORDERED ? 1 : 0, NULL); |
Michal Vasko | 61ad1ff | 2022-02-10 15:48:39 +0100 | [diff] [blame] | 1065 | LY_CHECK_RET(lydjson_create_opaq(lydctx, name, name_len, prefix, prefix_len, parent, status_inner_p, node_p)); |
aPiecek | dbb8baf | 2021-05-27 11:01:51 +0200 | [diff] [blame] | 1066 | } |
| 1067 | |
| 1068 | if ((*status_p == LYJSON_OBJECT) || (*status_p == LYJSON_OBJECT_EMPTY)) { |
| 1069 | /* process children */ |
| 1070 | while (*status_p != LYJSON_OBJECT_CLOSED && *status_p != LYJSON_OBJECT_EMPTY) { |
| 1071 | LY_CHECK_RET(lydjson_subtree_r(lydctx, *node_p, lyd_node_child_p(*node_p), NULL)); |
| 1072 | *status_p = lyjson_ctx_status(lydctx->jsonctx, 0); |
Radek Krejci | 1798aae | 2020-07-14 13:26:06 +0200 | [diff] [blame] | 1073 | } |
| 1074 | } |
| 1075 | |
aPiecek | dbb8baf | 2021-05-27 11:01:51 +0200 | [diff] [blame] | 1076 | finish: |
Radek Krejci | 1798aae | 2020-07-14 13:26:06 +0200 | [diff] [blame] | 1077 | /* finish linking metadata */ |
Michal Vasko | 61ad1ff | 2022-02-10 15:48:39 +0100 | [diff] [blame] | 1078 | return lydjson_metadata_finish(lydctx, lyd_node_child_p(*node_p)); |
Radek Krejci | 1798aae | 2020-07-14 13:26:06 +0200 | [diff] [blame] | 1079 | } |
| 1080 | |
| 1081 | /** |
aPiecek | 6cee5d0 | 2021-05-12 10:32:00 +0200 | [diff] [blame] | 1082 | * @brief Move to the second item in the name/X pair and parse opaq node from the input. |
| 1083 | * |
| 1084 | * This function is basically the wrapper of the ::lydjson_parse_opaq(). |
| 1085 | * In addition, it calls the ::json_ctx_next() and prepares the status_inner_p parameter |
| 1086 | * for ::lydjson_parse_opaq(). |
| 1087 | * |
| 1088 | * @param[in] lydctx JSON data parser context. |
| 1089 | * @param[in] name Name of the opaq node to create. |
| 1090 | * @param[in] name_len Length of the @p name string. |
| 1091 | * @param[in] prefix Prefix of the opaq node to create. |
| 1092 | * @param[in] prefix_len Length of the @p prefx string. |
| 1093 | * @param[in] parent Data parent of the opaq node to create, can be NULL in case of top level, |
| 1094 | * but must be set if @p first is not. |
| 1095 | * @param[in,out] status_p Pointer to the current status of the parser context, |
| 1096 | * since the function manipulates with the context and process the input, the status can be updated. |
| 1097 | * @param[in,out] first_p First top-level/parent sibling, must be set if @p parent is not. |
| 1098 | * @param[out] node_p Pointer to the created opaq node. |
| 1099 | * @return LY_ERR value. |
| 1100 | */ |
| 1101 | static LY_ERR |
| 1102 | lydjson_ctx_next_parse_opaq(struct lyd_json_ctx *lydctx, const char *name, size_t name_len, |
Michal Vasko | 61ad1ff | 2022-02-10 15:48:39 +0100 | [diff] [blame] | 1103 | const char *prefix, size_t prefix_len, struct lyd_node *parent, enum LYJSON_PARSER_STATUS *status_p, |
aPiecek | 6cee5d0 | 2021-05-12 10:32:00 +0200 | [diff] [blame] | 1104 | struct lyd_node **first_p, struct lyd_node **node_p) |
| 1105 | { |
| 1106 | enum LYJSON_PARSER_STATUS status_inner = 0; |
| 1107 | |
| 1108 | /* move to the second item in the name/X pair */ |
| 1109 | LY_CHECK_RET(lyjson_ctx_next(lydctx->jsonctx, status_p)); |
| 1110 | |
| 1111 | if (*status_p == LYJSON_ARRAY) { |
| 1112 | /* move into the array */ |
| 1113 | LY_CHECK_RET(lyjson_ctx_next(lydctx->jsonctx, &status_inner)); |
| 1114 | } else { |
| 1115 | /* just a flag to pass correct parameters into lydjson_parse_opaq() */ |
| 1116 | status_inner = LYJSON_ERROR; |
| 1117 | } |
| 1118 | |
| 1119 | if (status_inner == LYJSON_ERROR) { |
| 1120 | status_inner = *status_p; |
| 1121 | } |
| 1122 | |
| 1123 | /* parse opaq node from the input */ |
Michal Vasko | 61ad1ff | 2022-02-10 15:48:39 +0100 | [diff] [blame] | 1124 | LY_CHECK_RET(lydjson_parse_opaq(lydctx, name, name_len, prefix, prefix_len, parent, status_p, &status_inner, |
| 1125 | first_p, node_p)); |
aPiecek | 6cee5d0 | 2021-05-12 10:32:00 +0200 | [diff] [blame] | 1126 | |
| 1127 | return LY_SUCCESS; |
| 1128 | } |
| 1129 | |
| 1130 | /** |
Radek Krejci | 1798aae | 2020-07-14 13:26:06 +0200 | [diff] [blame] | 1131 | * @brief Process the attribute container (starting by @) |
| 1132 | * |
| 1133 | * @param[in] lydctx JSON data parser context. |
| 1134 | * @param[in] attr_node The data node referenced by the attribute container, if already known. |
| 1135 | * @param[in] snode The schema node of the data node referenced by the attribute container, if known. |
| 1136 | * @param[in] name Name of the opaq node to create. |
| 1137 | * @param[in] name_len Length of the @p name string. |
| 1138 | * @param[in] prefix Prefix of the opaq node to create. |
| 1139 | * @param[in] prefix_len Length of the @p prefx string. |
| 1140 | * @param[in] parent Data parent of the opaq node to create, can be NULL in case of top level, |
| 1141 | * but must be set if @p first is not. |
| 1142 | * @param[in,out] status_p Pointer to the current status of the parser context, |
| 1143 | * since the function manipulates with the context and process the input, the status can be updated. |
| 1144 | * @param[in,out] first_p First top-level/parent sibling, must be set if @p parent is not. |
| 1145 | * @param[out] node_p Pointer to the created opaq node. |
| 1146 | * @return LY_ERR value. |
| 1147 | */ |
| 1148 | static LY_ERR |
| 1149 | lydjson_parse_attribute(struct lyd_json_ctx *lydctx, struct lyd_node *attr_node, const struct lysc_node *snode, |
Michal Vasko | e066574 | 2021-02-11 11:08:44 +0100 | [diff] [blame] | 1150 | const char *name, size_t name_len, const char *prefix, size_t prefix_len, struct lyd_node *parent, |
| 1151 | enum LYJSON_PARSER_STATUS *status_p, struct lyd_node **first_p, struct lyd_node **node_p) |
Radek Krejci | 1798aae | 2020-07-14 13:26:06 +0200 | [diff] [blame] | 1152 | { |
Michal Vasko | 61ad1ff | 2022-02-10 15:48:39 +0100 | [diff] [blame] | 1153 | LY_ERR r; |
Michal Vasko | dcad5c8 | 2022-12-01 16:16:58 +0100 | [diff] [blame] | 1154 | const char *opaq_name, *mod_name; |
Michal Vasko | 61ad1ff | 2022-02-10 15:48:39 +0100 | [diff] [blame] | 1155 | size_t opaq_name_len; |
Radek Krejci | 1798aae | 2020-07-14 13:26:06 +0200 | [diff] [blame] | 1156 | |
Michal Vasko | fceac69 | 2022-12-01 13:50:27 +0100 | [diff] [blame] | 1157 | if (!snode && !prefix) { |
| 1158 | /* set the prefix */ |
| 1159 | if (parent) { |
| 1160 | lydjson_get_node_prefix(parent, NULL, 0, &prefix, &prefix_len); |
| 1161 | } else { |
| 1162 | prefix = ""; |
| 1163 | prefix_len = 0; |
| 1164 | } |
| 1165 | } |
| 1166 | |
| 1167 | /* parse as an attribute to a (opaque) node */ |
| 1168 | if (!attr_node) { |
Radek Krejci | 1798aae | 2020-07-14 13:26:06 +0200 | [diff] [blame] | 1169 | /* try to find the instance */ |
Michal Vasko | fceac69 | 2022-12-01 13:50:27 +0100 | [diff] [blame] | 1170 | LY_LIST_FOR(*first_p, attr_node) { |
| 1171 | if (snode) { |
| 1172 | if (attr_node->schema) { |
| 1173 | if (attr_node->schema == snode) { |
| 1174 | break; |
| 1175 | } |
| 1176 | } else { |
Michal Vasko | dcad5c8 | 2022-12-01 16:16:58 +0100 | [diff] [blame] | 1177 | mod_name = ((struct lyd_node_opaq *)attr_node)->name.module_name; |
| 1178 | if (!strcmp(LYD_NAME(attr_node), snode->name) && mod_name && !strcmp(mod_name, snode->module->name)) { |
Michal Vasko | fceac69 | 2022-12-01 13:50:27 +0100 | [diff] [blame] | 1179 | break; |
| 1180 | } |
| 1181 | } |
| 1182 | } else { |
| 1183 | if (attr_node->schema) { |
| 1184 | if (!ly_strncmp(LYD_NAME(attr_node), name, name_len) && |
| 1185 | !ly_strncmp(attr_node->schema->module->name, prefix, prefix_len)) { |
| 1186 | break; |
| 1187 | } |
| 1188 | } else { |
Michal Vasko | dcad5c8 | 2022-12-01 16:16:58 +0100 | [diff] [blame] | 1189 | mod_name = ((struct lyd_node_opaq *)attr_node)->name.module_name; |
| 1190 | if (!ly_strncmp(LYD_NAME(attr_node), name, name_len) && mod_name && |
| 1191 | !ly_strncmp(mod_name, prefix, prefix_len)) { |
Michal Vasko | fceac69 | 2022-12-01 13:50:27 +0100 | [diff] [blame] | 1192 | break; |
| 1193 | } |
| 1194 | } |
Radek Krejci | 1798aae | 2020-07-14 13:26:06 +0200 | [diff] [blame] | 1195 | } |
| 1196 | } |
| 1197 | } |
| 1198 | if (!attr_node) { |
| 1199 | /* parse just as an opaq node with the name beginning with @, |
| 1200 | * later we have to check that it belongs to a standard node |
| 1201 | * and it is supposed to be converted to a metadata */ |
| 1202 | uint32_t prev_opts; |
| 1203 | |
Radek Krejci | 1798aae | 2020-07-14 13:26:06 +0200 | [diff] [blame] | 1204 | /* backup parser options to parse unknown metadata as opaq nodes and try to resolve them later */ |
Michal Vasko | e066574 | 2021-02-11 11:08:44 +0100 | [diff] [blame] | 1205 | prev_opts = lydctx->parse_opts; |
| 1206 | lydctx->parse_opts &= ~LYD_PARSE_STRICT; |
| 1207 | lydctx->parse_opts |= LYD_PARSE_OPAQ; |
Radek Krejci | 1798aae | 2020-07-14 13:26:06 +0200 | [diff] [blame] | 1208 | |
Michal Vasko | 61ad1ff | 2022-02-10 15:48:39 +0100 | [diff] [blame] | 1209 | opaq_name = prefix ? prefix - 1 : name - 1; |
| 1210 | opaq_name_len = prefix ? prefix_len + name_len + 2 : name_len + 1; |
| 1211 | r = lydjson_ctx_next_parse_opaq(lydctx, opaq_name, opaq_name_len, NULL, 0, parent, status_p, first_p, node_p); |
Radek Krejci | 1798aae | 2020-07-14 13:26:06 +0200 | [diff] [blame] | 1212 | |
| 1213 | /* restore the parser options */ |
Michal Vasko | e066574 | 2021-02-11 11:08:44 +0100 | [diff] [blame] | 1214 | lydctx->parse_opts = prev_opts; |
Michal Vasko | 61ad1ff | 2022-02-10 15:48:39 +0100 | [diff] [blame] | 1215 | LY_CHECK_RET(r); |
Radek Krejci | 1798aae | 2020-07-14 13:26:06 +0200 | [diff] [blame] | 1216 | } else { |
Michal Vasko | 61ad1ff | 2022-02-10 15:48:39 +0100 | [diff] [blame] | 1217 | LY_CHECK_RET(lydjson_metadata(lydctx, snode, attr_node)); |
Radek Krejci | 1798aae | 2020-07-14 13:26:06 +0200 | [diff] [blame] | 1218 | } |
| 1219 | |
Michal Vasko | 61ad1ff | 2022-02-10 15:48:39 +0100 | [diff] [blame] | 1220 | return LY_SUCCESS; |
Radek Krejci | 1798aae | 2020-07-14 13:26:06 +0200 | [diff] [blame] | 1221 | } |
| 1222 | |
| 1223 | /** |
Michal Vasko | 76096ec | 2022-02-24 16:06:16 +0100 | [diff] [blame] | 1224 | * @brief Parse a single anydata/anyxml node. |
| 1225 | * |
| 1226 | * @param[in] lydctx JSON data parser context. When the function returns, the context is in the same state |
| 1227 | * as before calling, despite it is necessary to process input data for checking. |
| 1228 | * @param[in] snode Schema node corresponding to the member currently being processed in the context. |
Michal Vasko | 8cc3f66 | 2022-03-29 11:25:51 +0200 | [diff] [blame] | 1229 | * @param[in] ext Extension instance of @p snode, if any. |
Michal Vasko | 76096ec | 2022-02-24 16:06:16 +0100 | [diff] [blame] | 1230 | * @param[in,out] status JSON parser status, is updated. |
| 1231 | * @param[out] node Parsed data (or opaque) node. |
| 1232 | * @return LY_SUCCESS if a node was successfully parsed, |
| 1233 | * @return LY_ENOT in case of invalid JSON encoding, |
| 1234 | * @return LY_ERR on other errors. |
| 1235 | */ |
| 1236 | static LY_ERR |
Michal Vasko | 8cc3f66 | 2022-03-29 11:25:51 +0200 | [diff] [blame] | 1237 | lydjson_parse_any(struct lyd_json_ctx *lydctx, const struct lysc_node *snode, struct lysc_ext_instance *ext, |
| 1238 | enum LYJSON_PARSER_STATUS *status, struct lyd_node **node) |
Michal Vasko | 76096ec | 2022-02-24 16:06:16 +0100 | [diff] [blame] | 1239 | { |
Michal Vasko | d027f38 | 2023-02-10 09:13:25 +0100 | [diff] [blame] | 1240 | LY_ERR r, rc = LY_SUCCESS; |
Michal Vasko | 76096ec | 2022-02-24 16:06:16 +0100 | [diff] [blame] | 1241 | uint32_t prev_parse_opts, prev_int_opts; |
| 1242 | struct ly_in in_start; |
Michal Vasko | 7ca3325 | 2022-12-21 09:30:32 +0100 | [diff] [blame] | 1243 | char *val = NULL; |
Michal Vasko | 76096ec | 2022-02-24 16:06:16 +0100 | [diff] [blame] | 1244 | struct lyd_node *tree = NULL; |
| 1245 | |
| 1246 | assert(snode->nodetype & LYD_NODE_ANY); |
| 1247 | |
| 1248 | /* status check according to allowed JSON types */ |
| 1249 | if (snode->nodetype == LYS_ANYXML) { |
| 1250 | LY_CHECK_RET((*status != LYJSON_OBJECT) && (*status != LYJSON_OBJECT_EMPTY) && (*status != LYJSON_ARRAY) && |
Michal Vasko | 7ca3325 | 2022-12-21 09:30:32 +0100 | [diff] [blame] | 1251 | (*status != LYJSON_ARRAY_EMPTY) && (*status != LYJSON_NUMBER) && (*status != LYJSON_STRING) && |
| 1252 | (*status != LYJSON_FALSE) && (*status != LYJSON_TRUE) && (*status != LYJSON_NULL), LY_ENOT); |
Michal Vasko | 76096ec | 2022-02-24 16:06:16 +0100 | [diff] [blame] | 1253 | } else { |
Michal Vasko | e3ed7dc | 2022-11-30 11:39:44 +0100 | [diff] [blame] | 1254 | LY_CHECK_RET((*status != LYJSON_OBJECT) && (*status != LYJSON_OBJECT_EMPTY), LY_ENOT); |
Michal Vasko | 76096ec | 2022-02-24 16:06:16 +0100 | [diff] [blame] | 1255 | } |
| 1256 | |
| 1257 | /* create any node */ |
| 1258 | switch (*status) { |
| 1259 | case LYJSON_OBJECT: |
| 1260 | /* parse any data tree with correct options, first backup the current options and then make the parser |
| 1261 | * process data as opaq nodes */ |
| 1262 | prev_parse_opts = lydctx->parse_opts; |
| 1263 | lydctx->parse_opts &= ~LYD_PARSE_STRICT; |
Michal Vasko | 8cc3f66 | 2022-03-29 11:25:51 +0200 | [diff] [blame] | 1264 | lydctx->parse_opts |= LYD_PARSE_OPAQ | (ext ? LYD_PARSE_ONLY : 0); |
Michal Vasko | 76096ec | 2022-02-24 16:06:16 +0100 | [diff] [blame] | 1265 | prev_int_opts = lydctx->int_opts; |
| 1266 | lydctx->int_opts |= LYD_INTOPT_ANY | LYD_INTOPT_WITH_SIBLINGS; |
| 1267 | |
| 1268 | /* process the anydata content */ |
| 1269 | while (*status != LYJSON_OBJECT_CLOSED) { |
Michal Vasko | d027f38 | 2023-02-10 09:13:25 +0100 | [diff] [blame] | 1270 | r = lydjson_subtree_r(lydctx, NULL, &tree, NULL); |
| 1271 | LY_DPARSER_ERR_GOTO(r, rc = r, lydctx, cleanup); |
| 1272 | |
Michal Vasko | 76096ec | 2022-02-24 16:06:16 +0100 | [diff] [blame] | 1273 | *status = lyjson_ctx_status(lydctx->jsonctx, 0); |
| 1274 | } |
| 1275 | |
| 1276 | /* restore parser options */ |
| 1277 | lydctx->parse_opts = prev_parse_opts; |
| 1278 | lydctx->int_opts = prev_int_opts; |
| 1279 | |
| 1280 | /* finish linking metadata */ |
Michal Vasko | d027f38 | 2023-02-10 09:13:25 +0100 | [diff] [blame] | 1281 | r = lydjson_metadata_finish(lydctx, &tree); |
| 1282 | LY_CHECK_ERR_GOTO(r, rc = r, cleanup); |
Michal Vasko | 76096ec | 2022-02-24 16:06:16 +0100 | [diff] [blame] | 1283 | |
Michal Vasko | d027f38 | 2023-02-10 09:13:25 +0100 | [diff] [blame] | 1284 | r = lyd_create_any(snode, tree, LYD_ANYDATA_DATATREE, 1, node); |
| 1285 | LY_CHECK_ERR_GOTO(r, rc = r, cleanup); |
Michal Vasko | 76096ec | 2022-02-24 16:06:16 +0100 | [diff] [blame] | 1286 | break; |
Michal Vasko | 7ca3325 | 2022-12-21 09:30:32 +0100 | [diff] [blame] | 1287 | case LYJSON_ARRAY_EMPTY: |
| 1288 | /* store the empty array */ |
| 1289 | if (asprintf(&val, "[]") == -1) { |
| 1290 | LOGMEM(lydctx->jsonctx->ctx); |
| 1291 | return LY_EMEM; |
| 1292 | } |
Michal Vasko | d027f38 | 2023-02-10 09:13:25 +0100 | [diff] [blame] | 1293 | r = lyd_create_any(snode, val, LYD_ANYDATA_JSON, 1, node); |
| 1294 | LY_CHECK_ERR_GOTO(r, rc = r, val_err); |
Michal Vasko | 7ca3325 | 2022-12-21 09:30:32 +0100 | [diff] [blame] | 1295 | break; |
Michal Vasko | 76096ec | 2022-02-24 16:06:16 +0100 | [diff] [blame] | 1296 | case LYJSON_ARRAY: |
| 1297 | /* skip until the array end */ |
| 1298 | in_start = *lydctx->jsonctx->in; |
| 1299 | LY_CHECK_RET(lydjson_data_skip(lydctx->jsonctx)); |
| 1300 | |
| 1301 | /* make a copy of the whole array and store it */ |
| 1302 | if (asprintf(&val, "[%.*s", (int)(lydctx->jsonctx->in->current - in_start.current), in_start.current) == -1) { |
| 1303 | LOGMEM(lydctx->jsonctx->ctx); |
| 1304 | return LY_EMEM; |
| 1305 | } |
Michal Vasko | d027f38 | 2023-02-10 09:13:25 +0100 | [diff] [blame] | 1306 | r = lyd_create_any(snode, val, LYD_ANYDATA_JSON, 1, node); |
| 1307 | LY_CHECK_ERR_GOTO(r, rc = r, val_err); |
Michal Vasko | 76096ec | 2022-02-24 16:06:16 +0100 | [diff] [blame] | 1308 | break; |
| 1309 | case LYJSON_STRING: |
| 1310 | /* string value */ |
| 1311 | if (lydctx->jsonctx->dynamic) { |
| 1312 | LY_CHECK_RET(lyd_create_any(snode, lydctx->jsonctx->value, LYD_ANYDATA_STRING, 1, node)); |
| 1313 | lydctx->jsonctx->dynamic = 0; |
| 1314 | } else { |
| 1315 | val = strndup(lydctx->jsonctx->value, lydctx->jsonctx->value_len); |
| 1316 | LY_CHECK_ERR_RET(!val, LOGMEM(lydctx->jsonctx->ctx), LY_EMEM); |
| 1317 | |
Michal Vasko | d027f38 | 2023-02-10 09:13:25 +0100 | [diff] [blame] | 1318 | r = lyd_create_any(snode, val, LYD_ANYDATA_STRING, 1, node); |
| 1319 | LY_CHECK_ERR_GOTO(r, rc = r, val_err); |
Michal Vasko | 76096ec | 2022-02-24 16:06:16 +0100 | [diff] [blame] | 1320 | } |
| 1321 | break; |
| 1322 | case LYJSON_NUMBER: |
| 1323 | case LYJSON_FALSE: |
| 1324 | case LYJSON_TRUE: |
| 1325 | /* JSON value */ |
| 1326 | assert(!lydctx->jsonctx->dynamic); |
| 1327 | val = strndup(lydctx->jsonctx->value, lydctx->jsonctx->value_len); |
| 1328 | LY_CHECK_ERR_RET(!val, LOGMEM(lydctx->jsonctx->ctx), LY_EMEM); |
| 1329 | |
Michal Vasko | d027f38 | 2023-02-10 09:13:25 +0100 | [diff] [blame] | 1330 | r = lyd_create_any(snode, val, LYD_ANYDATA_JSON, 1, node); |
| 1331 | LY_CHECK_ERR_GOTO(r, rc = r, val_err); |
Michal Vasko | 76096ec | 2022-02-24 16:06:16 +0100 | [diff] [blame] | 1332 | break; |
| 1333 | case LYJSON_NULL: |
| 1334 | /* no value */ |
Michal Vasko | d027f38 | 2023-02-10 09:13:25 +0100 | [diff] [blame] | 1335 | r = lyd_create_any(snode, NULL, LYD_ANYDATA_JSON, 1, node); |
| 1336 | LY_CHECK_ERR_GOTO(r, rc = r, cleanup); |
Michal Vasko | 76096ec | 2022-02-24 16:06:16 +0100 | [diff] [blame] | 1337 | break; |
| 1338 | case LYJSON_OBJECT_EMPTY: |
| 1339 | /* empty object */ |
Michal Vasko | d027f38 | 2023-02-10 09:13:25 +0100 | [diff] [blame] | 1340 | r = lyd_create_any(snode, NULL, LYD_ANYDATA_DATATREE, 1, node); |
| 1341 | LY_CHECK_ERR_GOTO(r, rc = r, cleanup); |
Michal Vasko | 76096ec | 2022-02-24 16:06:16 +0100 | [diff] [blame] | 1342 | break; |
| 1343 | default: |
| 1344 | LOGINT_RET(lydctx->jsonctx->ctx); |
| 1345 | } |
| 1346 | |
Michal Vasko | d027f38 | 2023-02-10 09:13:25 +0100 | [diff] [blame] | 1347 | cleanup: |
| 1348 | return rc; |
Michal Vasko | 7ca3325 | 2022-12-21 09:30:32 +0100 | [diff] [blame] | 1349 | |
| 1350 | val_err: |
| 1351 | free(val); |
| 1352 | return rc; |
Michal Vasko | 76096ec | 2022-02-24 16:06:16 +0100 | [diff] [blame] | 1353 | } |
| 1354 | |
| 1355 | /** |
Michal Vasko | e0608fa | 2022-10-25 15:01:24 +0200 | [diff] [blame] | 1356 | * @brief Parse a single instance of an inner node. |
| 1357 | * |
| 1358 | * @param[in] lydctx JSON data parser context. |
| 1359 | * @param[in] snode Schema node corresponding to the member currently being processed in the context. |
| 1360 | * @param[in] ext Extension instance of @p snode, if any. |
| 1361 | * @param[in,out] status JSON parser status, is updated. |
| 1362 | * @param[out] node Parsed data (or opaque) node. |
| 1363 | * @return LY_SUCCESS if a node was successfully parsed, |
| 1364 | * @return LY_ENOT in case of invalid JSON encoding, |
| 1365 | * @return LY_ERR on other errors. |
| 1366 | */ |
| 1367 | static LY_ERR |
| 1368 | lydjson_parse_instance_inner(struct lyd_json_ctx *lydctx, const struct lysc_node *snode, struct lysc_ext_instance *ext, |
| 1369 | enum LYJSON_PARSER_STATUS *status, struct lyd_node **node) |
| 1370 | { |
Michal Vasko | d027f38 | 2023-02-10 09:13:25 +0100 | [diff] [blame] | 1371 | LY_ERR r, rc = LY_SUCCESS; |
Michal Vasko | e0608fa | 2022-10-25 15:01:24 +0200 | [diff] [blame] | 1372 | uint32_t prev_parse_opts = lydctx->parse_opts; |
| 1373 | |
| 1374 | LY_CHECK_RET((*status != LYJSON_OBJECT) && (*status != LYJSON_OBJECT_EMPTY), LY_ENOT); |
| 1375 | |
| 1376 | /* create inner node */ |
| 1377 | LY_CHECK_RET(lyd_create_inner(snode, node)); |
| 1378 | |
| 1379 | /* use it for logging */ |
| 1380 | LOG_LOCSET(NULL, *node, NULL, NULL); |
| 1381 | |
| 1382 | if (ext) { |
| 1383 | /* only parse these extension data and validate afterwards */ |
| 1384 | lydctx->parse_opts |= LYD_PARSE_ONLY; |
| 1385 | } |
| 1386 | |
| 1387 | /* process children */ |
| 1388 | while ((*status != LYJSON_OBJECT_CLOSED) && (*status != LYJSON_OBJECT_EMPTY)) { |
Michal Vasko | d027f38 | 2023-02-10 09:13:25 +0100 | [diff] [blame] | 1389 | r = lydjson_subtree_r(lydctx, *node, lyd_node_child_p(*node), NULL); |
| 1390 | LY_DPARSER_ERR_GOTO(r, rc = r, lydctx, cleanup); |
| 1391 | |
Michal Vasko | e0608fa | 2022-10-25 15:01:24 +0200 | [diff] [blame] | 1392 | *status = lyjson_ctx_status(lydctx->jsonctx, 0); |
| 1393 | } |
| 1394 | |
| 1395 | /* finish linking metadata */ |
Michal Vasko | d027f38 | 2023-02-10 09:13:25 +0100 | [diff] [blame] | 1396 | r = lydjson_metadata_finish(lydctx, lyd_node_child_p(*node)); |
| 1397 | LY_CHECK_ERR_GOTO(r, rc = r, cleanup); |
Michal Vasko | e0608fa | 2022-10-25 15:01:24 +0200 | [diff] [blame] | 1398 | |
| 1399 | if (snode->nodetype == LYS_LIST) { |
| 1400 | /* check all keys exist */ |
Michal Vasko | d027f38 | 2023-02-10 09:13:25 +0100 | [diff] [blame] | 1401 | r = lyd_parse_check_keys(*node); |
| 1402 | LY_DPARSER_ERR_GOTO(r, rc = r, lydctx, cleanup); |
Michal Vasko | e0608fa | 2022-10-25 15:01:24 +0200 | [diff] [blame] | 1403 | } |
| 1404 | |
| 1405 | if (!(lydctx->parse_opts & LYD_PARSE_ONLY)) { |
| 1406 | /* new node validation, autodelete CANNOT occur, all nodes are new */ |
Michal Vasko | d027f38 | 2023-02-10 09:13:25 +0100 | [diff] [blame] | 1407 | r = lyd_validate_new(lyd_node_child_p(*node), snode, NULL, lydctx->val_opts, NULL); |
| 1408 | LY_DPARSER_ERR_GOTO(r, rc = r, lydctx, cleanup); |
Michal Vasko | e0608fa | 2022-10-25 15:01:24 +0200 | [diff] [blame] | 1409 | |
| 1410 | /* add any missing default children */ |
Michal Vasko | d027f38 | 2023-02-10 09:13:25 +0100 | [diff] [blame] | 1411 | r = lyd_new_implicit_r(*node, lyd_node_child_p(*node), NULL, NULL, &lydctx->node_when, &lydctx->node_types, |
| 1412 | &lydctx->ext_node, (lydctx->val_opts & LYD_VALIDATE_NO_STATE) ? LYD_IMPLICIT_NO_STATE : 0, NULL); |
| 1413 | LY_CHECK_ERR_GOTO(r, rc = r, cleanup); |
Michal Vasko | e0608fa | 2022-10-25 15:01:24 +0200 | [diff] [blame] | 1414 | } |
| 1415 | |
| 1416 | cleanup: |
| 1417 | lydctx->parse_opts = prev_parse_opts; |
| 1418 | LOG_LOCBACK(0, 1, 0, 0); |
Michal Vasko | d027f38 | 2023-02-10 09:13:25 +0100 | [diff] [blame] | 1419 | return rc; |
Michal Vasko | e0608fa | 2022-10-25 15:01:24 +0200 | [diff] [blame] | 1420 | } |
| 1421 | |
| 1422 | /** |
Michal Vasko | 32ac994 | 2020-08-12 14:35:12 +0200 | [diff] [blame] | 1423 | * @brief Parse a single instance of a node. |
| 1424 | * |
| 1425 | * @param[in] lydctx JSON data parser context. When the function returns, the context is in the same state |
| 1426 | * as before calling, despite it is necessary to process input data for checking. |
| 1427 | * @param[in] parent Data parent of the subtree, must be set if @p first is not. |
| 1428 | * @param[in,out] first_p Pointer to the variable holding the first top-level sibling, must be set if @p parent is not. |
| 1429 | * @param[in] snode Schema node corresponding to the member currently being processed in the context. |
Michal Vasko | 8cc3f66 | 2022-03-29 11:25:51 +0200 | [diff] [blame] | 1430 | * @param[in] ext Extension instance of @p snode, if any. |
Michal Vasko | 32ac994 | 2020-08-12 14:35:12 +0200 | [diff] [blame] | 1431 | * @param[in] name Parsed JSON node name. |
| 1432 | * @param[in] name_len Lenght of @p name. |
| 1433 | * @param[in] prefix Parsed JSON node prefix. |
| 1434 | * @param[in] prefix_len Length of @p prefix. |
| 1435 | * @param[in,out] status JSON parser status, is updated. |
| 1436 | * @param[out] node Parsed data (or opaque) node. |
| 1437 | * @return LY_SUCCESS if a node was successfully parsed, |
Michal Vasko | 61ad1ff | 2022-02-10 15:48:39 +0100 | [diff] [blame] | 1438 | * @return LY_ENOT in case of invalid JSON encoding, |
Michal Vasko | 32ac994 | 2020-08-12 14:35:12 +0200 | [diff] [blame] | 1439 | * @return LY_ERR on other errors. |
| 1440 | */ |
| 1441 | static LY_ERR |
Michal Vasko | 61ad1ff | 2022-02-10 15:48:39 +0100 | [diff] [blame] | 1442 | lydjson_parse_instance(struct lyd_json_ctx *lydctx, struct lyd_node *parent, struct lyd_node **first_p, |
Michal Vasko | 8cc3f66 | 2022-03-29 11:25:51 +0200 | [diff] [blame] | 1443 | const struct lysc_node *snode, struct lysc_ext_instance *ext, const char *name, size_t name_len, |
| 1444 | const char *prefix, size_t prefix_len, enum LYJSON_PARSER_STATUS *status, struct lyd_node **node) |
Michal Vasko | 32ac994 | 2020-08-12 14:35:12 +0200 | [diff] [blame] | 1445 | { |
Michal Vasko | d027f38 | 2023-02-10 09:13:25 +0100 | [diff] [blame] | 1446 | LY_ERR r, rc = LY_SUCCESS; |
Michal Vasko | 76096ec | 2022-02-24 16:06:16 +0100 | [diff] [blame] | 1447 | uint32_t type_hints = 0; |
Michal Vasko | e0608fa | 2022-10-25 15:01:24 +0200 | [diff] [blame] | 1448 | |
| 1449 | LOG_LOCSET(snode, NULL, NULL, NULL); |
Michal Vasko | 32ac994 | 2020-08-12 14:35:12 +0200 | [diff] [blame] | 1450 | |
Michal Vasko | d027f38 | 2023-02-10 09:13:25 +0100 | [diff] [blame] | 1451 | r = lydjson_data_check_opaq(lydctx, snode, &type_hints); |
| 1452 | if (r == LY_SUCCESS) { |
Michal Vasko | 32ac994 | 2020-08-12 14:35:12 +0200 | [diff] [blame] | 1453 | assert(snode->nodetype & (LYD_NODE_TERM | LYD_NODE_INNER | LYD_NODE_ANY)); |
| 1454 | if (snode->nodetype & LYD_NODE_TERM) { |
Michal Vasko | e0608fa | 2022-10-25 15:01:24 +0200 | [diff] [blame] | 1455 | if ((*status != LYJSON_ARRAY) && (*status != LYJSON_NUMBER) && (*status != LYJSON_STRING) && |
| 1456 | (*status != LYJSON_FALSE) && (*status != LYJSON_TRUE) && (*status != LYJSON_NULL)) { |
Michal Vasko | d027f38 | 2023-02-10 09:13:25 +0100 | [diff] [blame] | 1457 | rc = LY_ENOT; |
Michal Vasko | e0608fa | 2022-10-25 15:01:24 +0200 | [diff] [blame] | 1458 | goto cleanup; |
| 1459 | } |
Michal Vasko | bbdadda | 2022-01-06 11:40:10 +0100 | [diff] [blame] | 1460 | |
Michal Vasko | 32ac994 | 2020-08-12 14:35:12 +0200 | [diff] [blame] | 1461 | /* create terminal node */ |
Michal Vasko | d027f38 | 2023-02-10 09:13:25 +0100 | [diff] [blame] | 1462 | r = lyd_parser_create_term((struct lyd_ctx *)lydctx, snode, lydctx->jsonctx->value, |
| 1463 | lydctx->jsonctx->value_len, &lydctx->jsonctx->dynamic, LY_VALUE_JSON, NULL, type_hints, node); |
| 1464 | LY_DPARSER_ERR_GOTO(r, rc = r, lydctx, cleanup); |
Michal Vasko | 32ac994 | 2020-08-12 14:35:12 +0200 | [diff] [blame] | 1465 | |
| 1466 | /* move JSON parser */ |
Michal Vasko | 8543070 | 2021-07-21 14:29:56 +0200 | [diff] [blame] | 1467 | if (*status == LYJSON_ARRAY) { |
| 1468 | /* only [null], 2 more moves are needed */ |
Michal Vasko | d027f38 | 2023-02-10 09:13:25 +0100 | [diff] [blame] | 1469 | r = lyjson_ctx_next(lydctx->jsonctx, status); |
| 1470 | LY_CHECK_ERR_GOTO(r, rc = r, cleanup); |
Michal Vasko | 8543070 | 2021-07-21 14:29:56 +0200 | [diff] [blame] | 1471 | assert(*status == LYJSON_NULL); |
Michal Vasko | d027f38 | 2023-02-10 09:13:25 +0100 | [diff] [blame] | 1472 | |
| 1473 | r = lyjson_ctx_next(lydctx->jsonctx, status); |
| 1474 | LY_CHECK_ERR_GOTO(r, rc = r, cleanup); |
Michal Vasko | 8543070 | 2021-07-21 14:29:56 +0200 | [diff] [blame] | 1475 | assert(*status == LYJSON_ARRAY_CLOSED); |
| 1476 | } |
Michal Vasko | 32ac994 | 2020-08-12 14:35:12 +0200 | [diff] [blame] | 1477 | } else if (snode->nodetype & LYD_NODE_INNER) { |
| 1478 | /* create inner node */ |
Michal Vasko | d027f38 | 2023-02-10 09:13:25 +0100 | [diff] [blame] | 1479 | r = lydjson_parse_instance_inner(lydctx, snode, ext, status, node); |
| 1480 | LY_DPARSER_ERR_GOTO(r, rc = r, lydctx, cleanup); |
Michal Vasko | 76096ec | 2022-02-24 16:06:16 +0100 | [diff] [blame] | 1481 | } else { |
Michal Vasko | 32ac994 | 2020-08-12 14:35:12 +0200 | [diff] [blame] | 1482 | /* create any node */ |
Michal Vasko | d027f38 | 2023-02-10 09:13:25 +0100 | [diff] [blame] | 1483 | r = lydjson_parse_any(lydctx, snode, ext, status, node); |
| 1484 | LY_DPARSER_ERR_GOTO(r, rc = r, lydctx, cleanup); |
Michal Vasko | 32ac994 | 2020-08-12 14:35:12 +0200 | [diff] [blame] | 1485 | } |
Michal Vasko | d027f38 | 2023-02-10 09:13:25 +0100 | [diff] [blame] | 1486 | LY_CHECK_GOTO(!*node, cleanup); |
Michal Vasko | caf608d | 2021-07-23 13:51:23 +0200 | [diff] [blame] | 1487 | |
| 1488 | /* add/correct flags */ |
Michal Vasko | d027f38 | 2023-02-10 09:13:25 +0100 | [diff] [blame] | 1489 | r = lyd_parse_set_data_flags(*node, &(*node)->meta, (struct lyd_ctx *)lydctx, ext); |
| 1490 | LY_CHECK_ERR_GOTO(r, rc = r, cleanup); |
Michal Vasko | 135719f | 2022-08-25 12:18:17 +0200 | [diff] [blame] | 1491 | |
Michal Vasko | eba2311 | 2022-08-26 08:35:41 +0200 | [diff] [blame] | 1492 | if (!(lydctx->parse_opts & LYD_PARSE_ONLY)) { |
| 1493 | /* store for ext instance node validation, if needed */ |
Michal Vasko | d027f38 | 2023-02-10 09:13:25 +0100 | [diff] [blame] | 1494 | r = lyd_validate_node_ext(*node, &lydctx->ext_node); |
| 1495 | LY_CHECK_ERR_GOTO(r, rc = r, cleanup); |
Michal Vasko | eba2311 | 2022-08-26 08:35:41 +0200 | [diff] [blame] | 1496 | } |
Michal Vasko | d027f38 | 2023-02-10 09:13:25 +0100 | [diff] [blame] | 1497 | } else if (r == LY_ENOT) { |
Michal Vasko | 32ac994 | 2020-08-12 14:35:12 +0200 | [diff] [blame] | 1498 | /* parse it again as an opaq node */ |
Michal Vasko | d027f38 | 2023-02-10 09:13:25 +0100 | [diff] [blame] | 1499 | r = lydjson_parse_opaq(lydctx, name, name_len, prefix, prefix_len, parent, status, status, first_p, node); |
| 1500 | LY_CHECK_ERR_GOTO(r, rc = r, cleanup); |
Michal Vasko | 32ac994 | 2020-08-12 14:35:12 +0200 | [diff] [blame] | 1501 | |
Michal Vasko | feca4fb | 2020-10-05 08:58:40 +0200 | [diff] [blame] | 1502 | if (snode->nodetype == LYS_LIST) { |
| 1503 | ((struct lyd_node_opaq *)*node)->hints |= LYD_NODEHINT_LIST; |
| 1504 | } else if (snode->nodetype == LYS_LEAFLIST) { |
| 1505 | ((struct lyd_node_opaq *)*node)->hints |= LYD_NODEHINT_LEAFLIST; |
Michal Vasko | 32ac994 | 2020-08-12 14:35:12 +0200 | [diff] [blame] | 1506 | } |
Michal Vasko | a32b6b7 | 2022-07-11 15:55:56 +0200 | [diff] [blame] | 1507 | } else { |
| 1508 | /* error */ |
Michal Vasko | 1e8746a | 2023-02-13 09:15:16 +0100 | [diff] [blame] | 1509 | rc = r; |
Michal Vasko | e0608fa | 2022-10-25 15:01:24 +0200 | [diff] [blame] | 1510 | goto cleanup; |
Michal Vasko | 32ac994 | 2020-08-12 14:35:12 +0200 | [diff] [blame] | 1511 | } |
| 1512 | |
Michal Vasko | e0608fa | 2022-10-25 15:01:24 +0200 | [diff] [blame] | 1513 | cleanup: |
| 1514 | LOG_LOCBACK(1, 0, 0, 0); |
Michal Vasko | d027f38 | 2023-02-10 09:13:25 +0100 | [diff] [blame] | 1515 | return rc; |
Michal Vasko | 32ac994 | 2020-08-12 14:35:12 +0200 | [diff] [blame] | 1516 | } |
| 1517 | |
| 1518 | /** |
Michal Vasko | a5da329 | 2020-08-12 13:10:50 +0200 | [diff] [blame] | 1519 | * @brief Parse JSON subtree. All leaf-list and list instances of a node are considered one subtree. |
Radek Krejci | 1798aae | 2020-07-14 13:26:06 +0200 | [diff] [blame] | 1520 | * |
| 1521 | * @param[in] lydctx JSON data parser context. |
| 1522 | * @param[in] parent Data parent of the subtree, must be set if @p first is not. |
| 1523 | * @param[in,out] first_p Pointer to the variable holding the first top-level sibling, must be set if @p parent is not. |
Michal Vasko | e066574 | 2021-02-11 11:08:44 +0100 | [diff] [blame] | 1524 | * @param[in,out] parsed Optional set to add all the parsed siblings into. |
Radek Krejci | 1798aae | 2020-07-14 13:26:06 +0200 | [diff] [blame] | 1525 | * @return LY_ERR value. |
| 1526 | */ |
| 1527 | static LY_ERR |
Michal Vasko | e066574 | 2021-02-11 11:08:44 +0100 | [diff] [blame] | 1528 | lydjson_subtree_r(struct lyd_json_ctx *lydctx, struct lyd_node *parent, struct lyd_node **first_p, struct ly_set *parsed) |
Radek Krejci | 1798aae | 2020-07-14 13:26:06 +0200 | [diff] [blame] | 1529 | { |
Michal Vasko | d027f38 | 2023-02-10 09:13:25 +0100 | [diff] [blame] | 1530 | LY_ERR r, rc = LY_SUCCESS; |
Radek Krejci | 1798aae | 2020-07-14 13:26:06 +0200 | [diff] [blame] | 1531 | enum LYJSON_PARSER_STATUS status = lyjson_ctx_status(lydctx->jsonctx, 0); |
aPiecek | 49e2a3a | 2021-05-13 10:36:46 +0200 | [diff] [blame] | 1532 | const char *name, *prefix = NULL, *expected = NULL; |
Radek Krejci | 1798aae | 2020-07-14 13:26:06 +0200 | [diff] [blame] | 1533 | size_t name_len, prefix_len = 0; |
Michal Vasko | 61ad1ff | 2022-02-10 15:48:39 +0100 | [diff] [blame] | 1534 | ly_bool is_meta = 0, parse_subtree; |
Michal Vasko | cabe070 | 2020-08-12 10:14:36 +0200 | [diff] [blame] | 1535 | const struct lysc_node *snode = NULL; |
Michal Vasko | 8cc3f66 | 2022-03-29 11:25:51 +0200 | [diff] [blame] | 1536 | struct lysc_ext_instance *ext; |
Michal Vasko | 32ac994 | 2020-08-12 14:35:12 +0200 | [diff] [blame] | 1537 | struct lyd_node *node = NULL, *attr_node = NULL; |
Radek Krejci | 1798aae | 2020-07-14 13:26:06 +0200 | [diff] [blame] | 1538 | const struct ly_ctx *ctx = lydctx->jsonctx->ctx; |
aPiecek | 49e2a3a | 2021-05-13 10:36:46 +0200 | [diff] [blame] | 1539 | char *value = NULL; |
Radek Krejci | 1798aae | 2020-07-14 13:26:06 +0200 | [diff] [blame] | 1540 | |
| 1541 | assert(parent || first_p); |
| 1542 | assert(status == LYJSON_OBJECT); |
| 1543 | |
Michal Vasko | 61ad1ff | 2022-02-10 15:48:39 +0100 | [diff] [blame] | 1544 | parse_subtree = lydctx->parse_opts & LYD_PARSE_SUBTREE ? 1 : 0; |
| 1545 | /* all descendants should be parsed */ |
| 1546 | lydctx->parse_opts &= ~LYD_PARSE_SUBTREE; |
| 1547 | |
Radek Krejci | 1798aae | 2020-07-14 13:26:06 +0200 | [diff] [blame] | 1548 | /* process the node name */ |
aPiecek | d2c3937 | 2021-06-16 14:03:12 +0200 | [diff] [blame] | 1549 | lydjson_parse_name(lydctx->jsonctx->value, lydctx->jsonctx->value_len, &name, &name_len, &prefix, &prefix_len, &is_meta); |
Michal Vasko | 61ad1ff | 2022-02-10 15:48:39 +0100 | [diff] [blame] | 1550 | lyjson_ctx_give_dynamic_value(lydctx->jsonctx, &value); |
Radek Krejci | 1798aae | 2020-07-14 13:26:06 +0200 | [diff] [blame] | 1551 | |
Michal Vasko | cabe070 | 2020-08-12 10:14:36 +0200 | [diff] [blame] | 1552 | if (!is_meta || name_len || prefix_len) { |
| 1553 | /* get the schema node */ |
Michal Vasko | 8cc3f66 | 2022-03-29 11:25:51 +0200 | [diff] [blame] | 1554 | r = lydjson_get_snode(lydctx, is_meta, prefix, prefix_len, name, name_len, parent, &snode, &ext); |
Michal Vasko | 61ad1ff | 2022-02-10 15:48:39 +0100 | [diff] [blame] | 1555 | if (r == LY_ENOT) { |
| 1556 | /* data parsed */ |
Radek Krejci | 1798aae | 2020-07-14 13:26:06 +0200 | [diff] [blame] | 1557 | goto cleanup; |
| 1558 | } |
Michal Vasko | d027f38 | 2023-02-10 09:13:25 +0100 | [diff] [blame] | 1559 | LY_CHECK_ERR_GOTO(r, rc = r, cleanup); |
Radek Krejci | 1798aae | 2020-07-14 13:26:06 +0200 | [diff] [blame] | 1560 | |
Michal Vasko | cabe070 | 2020-08-12 10:14:36 +0200 | [diff] [blame] | 1561 | if (!snode) { |
| 1562 | /* we will not be parsing it as metadata */ |
| 1563 | is_meta = 0; |
| 1564 | } |
| 1565 | } |
| 1566 | |
| 1567 | if (is_meta) { |
| 1568 | /* parse as metadata */ |
Michal Vasko | d027f38 | 2023-02-10 09:13:25 +0100 | [diff] [blame] | 1569 | if (!name_len && !prefix_len && !parent) { |
| 1570 | LOGVAL(ctx, LYVE_SYNTAX_JSON, |
| 1571 | "Invalid metadata format - \"@\" can be used only inside anydata, container or list entries."); |
| 1572 | r = LY_EVALID; |
| 1573 | LY_DPARSER_ERR_GOTO(r, rc = r, lydctx, cleanup); |
| 1574 | } else if (!name_len && !prefix_len) { |
Michal Vasko | cabe070 | 2020-08-12 10:14:36 +0200 | [diff] [blame] | 1575 | /* parent's metadata without a name - use the schema from the parent */ |
Michal Vasko | e066574 | 2021-02-11 11:08:44 +0100 | [diff] [blame] | 1576 | attr_node = parent; |
Michal Vasko | cabe070 | 2020-08-12 10:14:36 +0200 | [diff] [blame] | 1577 | snode = attr_node->schema; |
| 1578 | } |
Michal Vasko | d027f38 | 2023-02-10 09:13:25 +0100 | [diff] [blame] | 1579 | r = lydjson_parse_attribute(lydctx, attr_node, snode, name, name_len, prefix, prefix_len, parent, &status, |
Michal Vasko | 6973015 | 2020-10-09 16:30:07 +0200 | [diff] [blame] | 1580 | first_p, &node); |
Michal Vasko | d027f38 | 2023-02-10 09:13:25 +0100 | [diff] [blame] | 1581 | LY_CHECK_ERR_GOTO(r, rc = r, cleanup); |
Michal Vasko | cabe070 | 2020-08-12 10:14:36 +0200 | [diff] [blame] | 1582 | } else if (!snode) { |
Radek Krejci | 1798aae | 2020-07-14 13:26:06 +0200 | [diff] [blame] | 1583 | /* parse as an opaq node */ |
Michal Vasko | e066574 | 2021-02-11 11:08:44 +0100 | [diff] [blame] | 1584 | assert((lydctx->parse_opts & LYD_PARSE_OPAQ) || (lydctx->int_opts)); |
Radek Krejci | 1798aae | 2020-07-14 13:26:06 +0200 | [diff] [blame] | 1585 | |
aPiecek | b7b29e6 | 2021-05-11 10:02:43 +0200 | [diff] [blame] | 1586 | /* opaq node cannot have an empty string as the name. */ |
| 1587 | if (name_len == 0) { |
| 1588 | LOGVAL(lydctx->jsonctx->ctx, LYVE_SYNTAX_JSON, "A JSON object member name cannot be a zero-length string."); |
Michal Vasko | d027f38 | 2023-02-10 09:13:25 +0100 | [diff] [blame] | 1589 | r = LY_EVALID; |
| 1590 | LY_DPARSER_ERR_GOTO(r, rc = r, lydctx, cleanup); |
aPiecek | b7b29e6 | 2021-05-11 10:02:43 +0200 | [diff] [blame] | 1591 | } |
| 1592 | |
aPiecek | 6cee5d0 | 2021-05-12 10:32:00 +0200 | [diff] [blame] | 1593 | /* move to the second item in the name/X pair and parse opaq */ |
Michal Vasko | d027f38 | 2023-02-10 09:13:25 +0100 | [diff] [blame] | 1594 | r = lydjson_ctx_next_parse_opaq(lydctx, name, name_len, prefix, prefix_len, parent, &status, first_p, &node); |
| 1595 | LY_CHECK_ERR_GOTO(r, rc = r, cleanup); |
Michal Vasko | cabe070 | 2020-08-12 10:14:36 +0200 | [diff] [blame] | 1596 | } else { |
Michal Vasko | 32ac994 | 2020-08-12 14:35:12 +0200 | [diff] [blame] | 1597 | /* parse as a standard lyd_node but it can still turn out to be an opaque node */ |
Radek Krejci | 1798aae | 2020-07-14 13:26:06 +0200 | [diff] [blame] | 1598 | |
| 1599 | /* move to the second item in the name/X pair */ |
Michal Vasko | d027f38 | 2023-02-10 09:13:25 +0100 | [diff] [blame] | 1600 | r = lyjson_ctx_next(lydctx->jsonctx, &status); |
| 1601 | LY_CHECK_ERR_GOTO(r, rc = r, cleanup); |
Radek Krejci | 1798aae | 2020-07-14 13:26:06 +0200 | [diff] [blame] | 1602 | |
Michal Vasko | 7ca3325 | 2022-12-21 09:30:32 +0100 | [diff] [blame] | 1603 | /* set expected representation */ |
| 1604 | switch (snode->nodetype) { |
| 1605 | case LYS_LEAFLIST: |
| 1606 | expected = "name/array of values"; |
| 1607 | break; |
| 1608 | case LYS_LIST: |
| 1609 | expected = "name/array of objects"; |
| 1610 | break; |
| 1611 | case LYS_LEAF: |
| 1612 | if (status == LYJSON_ARRAY) { |
| 1613 | expected = "name/[null]"; |
| 1614 | } else { |
| 1615 | expected = "name/value"; |
| 1616 | } |
| 1617 | break; |
| 1618 | case LYS_CONTAINER: |
| 1619 | case LYS_NOTIF: |
| 1620 | case LYS_ACTION: |
| 1621 | case LYS_RPC: |
| 1622 | case LYS_ANYDATA: |
| 1623 | expected = "name/object"; |
| 1624 | break; |
| 1625 | case LYS_ANYXML: |
| 1626 | if (status == LYJSON_ARRAY) { |
| 1627 | expected = "name/array"; |
| 1628 | } else { |
| 1629 | expected = "name/value"; |
| 1630 | } |
| 1631 | break; |
| 1632 | } |
| 1633 | |
| 1634 | /* check the representation according to the nodetype and then continue with the content */ |
Radek Krejci | 1798aae | 2020-07-14 13:26:06 +0200 | [diff] [blame] | 1635 | switch (snode->nodetype) { |
| 1636 | case LYS_LEAFLIST: |
Michal Vasko | 32ac994 | 2020-08-12 14:35:12 +0200 | [diff] [blame] | 1637 | case LYS_LIST: |
Michal Vasko | 4e26adc | 2022-03-30 11:01:16 +0200 | [diff] [blame] | 1638 | if (status == LYJSON_ARRAY_EMPTY) { |
| 1639 | /* no instances, skip */ |
| 1640 | break; |
| 1641 | } |
Radek Krejci | 1798aae | 2020-07-14 13:26:06 +0200 | [diff] [blame] | 1642 | LY_CHECK_GOTO(status != LYJSON_ARRAY, representation_error); |
| 1643 | |
| 1644 | /* move into array */ |
Michal Vasko | d027f38 | 2023-02-10 09:13:25 +0100 | [diff] [blame] | 1645 | r = lyjson_ctx_next(lydctx->jsonctx, &status); |
| 1646 | LY_CHECK_ERR_GOTO(r, rc = r, cleanup); |
Radek Krejci | 1798aae | 2020-07-14 13:26:06 +0200 | [diff] [blame] | 1647 | |
Michal Vasko | 32ac994 | 2020-08-12 14:35:12 +0200 | [diff] [blame] | 1648 | /* process all the values/objects */ |
| 1649 | do { |
Michal Vasko | d027f38 | 2023-02-10 09:13:25 +0100 | [diff] [blame] | 1650 | r = lydjson_parse_instance(lydctx, parent, first_p, snode, ext, name, name_len, prefix, prefix_len, |
Michal Vasko | 61ad1ff | 2022-02-10 15:48:39 +0100 | [diff] [blame] | 1651 | &status, &node); |
Michal Vasko | d027f38 | 2023-02-10 09:13:25 +0100 | [diff] [blame] | 1652 | if (r == LY_ENOT) { |
Michal Vasko | 32ac994 | 2020-08-12 14:35:12 +0200 | [diff] [blame] | 1653 | goto representation_error; |
Radek Krejci | 1798aae | 2020-07-14 13:26:06 +0200 | [diff] [blame] | 1654 | } |
Michal Vasko | d027f38 | 2023-02-10 09:13:25 +0100 | [diff] [blame] | 1655 | LY_DPARSER_ERR_GOTO(r, rc = r, lydctx, cleanup); |
| 1656 | |
Michal Vasko | 8cc3f66 | 2022-03-29 11:25:51 +0200 | [diff] [blame] | 1657 | lydjson_maintain_children(parent, first_p, &node, lydctx->parse_opts & LYD_PARSE_ORDERED ? 1 : 0, ext); |
Radek Krejci | 1798aae | 2020-07-14 13:26:06 +0200 | [diff] [blame] | 1658 | |
Michal Vasko | 61ad1ff | 2022-02-10 15:48:39 +0100 | [diff] [blame] | 1659 | /* move after the item(s) */ |
Michal Vasko | d027f38 | 2023-02-10 09:13:25 +0100 | [diff] [blame] | 1660 | r = lyjson_ctx_next(lydctx->jsonctx, &status); |
| 1661 | LY_CHECK_ERR_GOTO(r, rc = r, cleanup); |
Michal Vasko | 61ad1ff | 2022-02-10 15:48:39 +0100 | [diff] [blame] | 1662 | } while (status != LYJSON_ARRAY_CLOSED); |
Radek Krejci | 1798aae | 2020-07-14 13:26:06 +0200 | [diff] [blame] | 1663 | |
| 1664 | break; |
Michal Vasko | 32ac994 | 2020-08-12 14:35:12 +0200 | [diff] [blame] | 1665 | case LYS_LEAF: |
Radek Krejci | 1798aae | 2020-07-14 13:26:06 +0200 | [diff] [blame] | 1666 | case LYS_CONTAINER: |
| 1667 | case LYS_NOTIF: |
| 1668 | case LYS_ACTION: |
| 1669 | case LYS_RPC: |
Michal Vasko | 32ac994 | 2020-08-12 14:35:12 +0200 | [diff] [blame] | 1670 | case LYS_ANYDATA: |
| 1671 | case LYS_ANYXML: |
Michal Vasko | 32ac994 | 2020-08-12 14:35:12 +0200 | [diff] [blame] | 1672 | /* process the value/object */ |
Michal Vasko | d027f38 | 2023-02-10 09:13:25 +0100 | [diff] [blame] | 1673 | r = lydjson_parse_instance(lydctx, parent, first_p, snode, ext, name, name_len, prefix, prefix_len, |
Michal Vasko | 8cc3f66 | 2022-03-29 11:25:51 +0200 | [diff] [blame] | 1674 | &status, &node); |
Michal Vasko | d027f38 | 2023-02-10 09:13:25 +0100 | [diff] [blame] | 1675 | if (r == LY_ENOT) { |
Michal Vasko | 32ac994 | 2020-08-12 14:35:12 +0200 | [diff] [blame] | 1676 | goto representation_error; |
Radek Krejci | 1798aae | 2020-07-14 13:26:06 +0200 | [diff] [blame] | 1677 | } |
Michal Vasko | d027f38 | 2023-02-10 09:13:25 +0100 | [diff] [blame] | 1678 | LY_DPARSER_ERR_GOTO(r, rc = r, lydctx, cleanup); |
Radek Krejci | 1798aae | 2020-07-14 13:26:06 +0200 | [diff] [blame] | 1679 | |
Michal Vasko | 32ac994 | 2020-08-12 14:35:12 +0200 | [diff] [blame] | 1680 | if (snode->nodetype & (LYS_RPC | LYS_ACTION | LYS_NOTIF)) { |
Radek Krejci | 1798aae | 2020-07-14 13:26:06 +0200 | [diff] [blame] | 1681 | /* rememeber the RPC/action/notification */ |
| 1682 | lydctx->op_node = node; |
| 1683 | } |
Radek Krejci | 1798aae | 2020-07-14 13:26:06 +0200 | [diff] [blame] | 1684 | break; |
Radek Krejci | 1798aae | 2020-07-14 13:26:06 +0200 | [diff] [blame] | 1685 | } |
Radek Krejci | 1798aae | 2020-07-14 13:26:06 +0200 | [diff] [blame] | 1686 | } |
| 1687 | |
Michal Vasko | 32ac994 | 2020-08-12 14:35:12 +0200 | [diff] [blame] | 1688 | /* finally connect the parsed node */ |
Michal Vasko | 8cc3f66 | 2022-03-29 11:25:51 +0200 | [diff] [blame] | 1689 | lydjson_maintain_children(parent, first_p, &node, lydctx->parse_opts & LYD_PARSE_ORDERED ? 1 : 0, ext); |
Michal Vasko | e066574 | 2021-02-11 11:08:44 +0100 | [diff] [blame] | 1690 | |
| 1691 | /* rememeber a successfully parsed node */ |
Michal Vasko | 4e26adc | 2022-03-30 11:01:16 +0200 | [diff] [blame] | 1692 | if (parsed && node) { |
Michal Vasko | e066574 | 2021-02-11 11:08:44 +0100 | [diff] [blame] | 1693 | ly_set_add(parsed, node, 1, NULL); |
| 1694 | } |
Radek Krejci | 1798aae | 2020-07-14 13:26:06 +0200 | [diff] [blame] | 1695 | |
Michal Vasko | 61ad1ff | 2022-02-10 15:48:39 +0100 | [diff] [blame] | 1696 | if (!parse_subtree) { |
| 1697 | /* move after the item(s) */ |
Michal Vasko | d027f38 | 2023-02-10 09:13:25 +0100 | [diff] [blame] | 1698 | r = lyjson_ctx_next(lydctx->jsonctx, &status); |
| 1699 | LY_CHECK_ERR_GOTO(r, rc = r, cleanup); |
Michal Vasko | 61ad1ff | 2022-02-10 15:48:39 +0100 | [diff] [blame] | 1700 | } |
| 1701 | |
Radek Krejci | 5813c36 | 2021-01-05 10:51:57 +0100 | [diff] [blame] | 1702 | /* success */ |
| 1703 | goto cleanup; |
Radek Krejci | 1798aae | 2020-07-14 13:26:06 +0200 | [diff] [blame] | 1704 | |
| 1705 | representation_error: |
Radek Krejci | 2efc45b | 2020-12-22 16:25:44 +0100 | [diff] [blame] | 1706 | LOGVAL(ctx, LYVE_SYNTAX_JSON, "The %s \"%s\" is expected to be represented as JSON %s, but input data contains name/%s.", |
Michal Vasko | 6973015 | 2020-10-09 16:30:07 +0200 | [diff] [blame] | 1707 | lys_nodetype2str(snode->nodetype), snode->name, expected, lyjson_token2str(status)); |
Michal Vasko | d027f38 | 2023-02-10 09:13:25 +0100 | [diff] [blame] | 1708 | rc = LY_EVALID; |
| 1709 | if (lydctx->val_opts & LYD_VALIDATE_MULTI_ERROR) { |
| 1710 | /* try to skip the invalid data */ |
Michal Vasko | 560f9de | 2023-02-10 09:56:01 +0100 | [diff] [blame] | 1711 | if ((r = lydjson_data_skip(lydctx->jsonctx))) { |
| 1712 | rc = r; |
| 1713 | } |
Michal Vasko | d027f38 | 2023-02-10 09:13:25 +0100 | [diff] [blame] | 1714 | } |
Radek Krejci | 5813c36 | 2021-01-05 10:51:57 +0100 | [diff] [blame] | 1715 | |
| 1716 | cleanup: |
aPiecek | 49e2a3a | 2021-05-13 10:36:46 +0200 | [diff] [blame] | 1717 | free(value); |
Radek Krejci | 5813c36 | 2021-01-05 10:51:57 +0100 | [diff] [blame] | 1718 | lyd_free_tree(node); |
Michal Vasko | d027f38 | 2023-02-10 09:13:25 +0100 | [diff] [blame] | 1719 | return rc; |
Radek Krejci | 1798aae | 2020-07-14 13:26:06 +0200 | [diff] [blame] | 1720 | } |
| 1721 | |
| 1722 | /** |
| 1723 | * @brief Common start of JSON parser processing different types of the input data. |
| 1724 | * |
| 1725 | * @param[in] ctx libyang context |
| 1726 | * @param[in] in Input structure. |
Michal Vasko | e066574 | 2021-02-11 11:08:44 +0100 | [diff] [blame] | 1727 | * @param[in] parse_opts Options for parser, see @ref dataparseroptions. |
| 1728 | * @param[in] val_opts Options for the validation phase, see @ref datavalidationoptions. |
Radek Krejci | 1798aae | 2020-07-14 13:26:06 +0200 | [diff] [blame] | 1729 | * @param[out] lydctx_p Data parser context to finish validation. |
Radek Krejci | cd5f622 | 2020-11-12 08:54:13 +0100 | [diff] [blame] | 1730 | * @param[out] status Storage for the current context's status |
Radek Krejci | 1798aae | 2020-07-14 13:26:06 +0200 | [diff] [blame] | 1731 | * @return LY_ERR value. |
| 1732 | */ |
| 1733 | static LY_ERR |
Michal Vasko | e066574 | 2021-02-11 11:08:44 +0100 | [diff] [blame] | 1734 | lyd_parse_json_init(const struct ly_ctx *ctx, struct ly_in *in, uint32_t parse_opts, uint32_t val_opts, |
Radek Krejci | cd5f622 | 2020-11-12 08:54:13 +0100 | [diff] [blame] | 1735 | struct lyd_json_ctx **lydctx_p, enum LYJSON_PARSER_STATUS *status) |
Radek Krejci | 1798aae | 2020-07-14 13:26:06 +0200 | [diff] [blame] | 1736 | { |
| 1737 | LY_ERR ret = LY_SUCCESS; |
| 1738 | struct lyd_json_ctx *lydctx; |
Radek Krejci | d54412f | 2020-12-17 20:25:35 +0100 | [diff] [blame] | 1739 | size_t i; |
Michal Vasko | 61ad1ff | 2022-02-10 15:48:39 +0100 | [diff] [blame] | 1740 | ly_bool subtree; |
Radek Krejci | 1798aae | 2020-07-14 13:26:06 +0200 | [diff] [blame] | 1741 | |
Radek Krejci | cd5f622 | 2020-11-12 08:54:13 +0100 | [diff] [blame] | 1742 | assert(lydctx_p); |
| 1743 | assert(status); |
| 1744 | |
Radek Krejci | 1798aae | 2020-07-14 13:26:06 +0200 | [diff] [blame] | 1745 | /* init context */ |
| 1746 | lydctx = calloc(1, sizeof *lydctx); |
| 1747 | LY_CHECK_ERR_RET(!lydctx, LOGMEM(ctx), LY_EMEM); |
Michal Vasko | e066574 | 2021-02-11 11:08:44 +0100 | [diff] [blame] | 1748 | lydctx->parse_opts = parse_opts; |
| 1749 | lydctx->val_opts = val_opts; |
Radek Krejci | 1798aae | 2020-07-14 13:26:06 +0200 | [diff] [blame] | 1750 | lydctx->free = lyd_json_ctx_free; |
Radek Krejci | 1798aae | 2020-07-14 13:26:06 +0200 | [diff] [blame] | 1751 | |
Radek Krejci | 284f31f | 2020-09-18 15:40:29 +0200 | [diff] [blame] | 1752 | /* starting top-level */ |
| 1753 | for (i = 0; in->current[i] != '\0' && is_jsonws(in->current[i]); i++) { |
Radek Krejci | f13b87b | 2020-12-01 22:02:17 +0100 | [diff] [blame] | 1754 | if (in->current[i] == '\n') { |
| 1755 | /* new line */ |
Radek Krejci | d54412f | 2020-12-17 20:25:35 +0100 | [diff] [blame] | 1756 | LY_IN_NEW_LINE(in); |
Michal Vasko | 61d7636 | 2020-10-07 10:47:30 +0200 | [diff] [blame] | 1757 | } |
Radek Krejci | 284f31f | 2020-09-18 15:40:29 +0200 | [diff] [blame] | 1758 | } |
Radek Krejci | 1798aae | 2020-07-14 13:26:06 +0200 | [diff] [blame] | 1759 | |
Michal Vasko | 61ad1ff | 2022-02-10 15:48:39 +0100 | [diff] [blame] | 1760 | subtree = (parse_opts & LYD_PARSE_SUBTREE) ? 1 : 0; |
| 1761 | LY_CHECK_ERR_RET(ret = lyjson_ctx_new(ctx, in, subtree, &lydctx->jsonctx), free(lydctx), ret); |
Radek Krejci | cd5f622 | 2020-11-12 08:54:13 +0100 | [diff] [blame] | 1762 | *status = lyjson_ctx_status(lydctx->jsonctx, 0); |
Michal Vasko | 61ad1ff | 2022-02-10 15:48:39 +0100 | [diff] [blame] | 1763 | |
Radek Krejci | bb27df3 | 2020-11-13 15:39:16 +0100 | [diff] [blame] | 1764 | if ((*status == LYJSON_END) || (*status == LYJSON_OBJECT_EMPTY) || (*status == LYJSON_OBJECT)) { |
Radek Krejci | 284f31f | 2020-09-18 15:40:29 +0200 | [diff] [blame] | 1765 | *lydctx_p = lydctx; |
| 1766 | return LY_SUCCESS; |
Radek Krejci | cd5f622 | 2020-11-12 08:54:13 +0100 | [diff] [blame] | 1767 | } else { |
| 1768 | /* expecting top-level object */ |
Michal Vasko | 61ad1ff | 2022-02-10 15:48:39 +0100 | [diff] [blame] | 1769 | LOGVAL(ctx, LYVE_SYNTAX_JSON, "Expected top-level JSON object, but %s found.", lyjson_token2str(*status)); |
Radek Krejci | cd5f622 | 2020-11-12 08:54:13 +0100 | [diff] [blame] | 1770 | *lydctx_p = NULL; |
Michal Vasko | 9350901 | 2020-11-13 10:26:09 +0100 | [diff] [blame] | 1771 | lyd_json_ctx_free((struct lyd_ctx *)lydctx); |
Radek Krejci | cd5f622 | 2020-11-12 08:54:13 +0100 | [diff] [blame] | 1772 | return LY_EVALID; |
Radek Krejci | 284f31f | 2020-09-18 15:40:29 +0200 | [diff] [blame] | 1773 | } |
Radek Krejci | 1798aae | 2020-07-14 13:26:06 +0200 | [diff] [blame] | 1774 | } |
| 1775 | |
| 1776 | LY_ERR |
Radek Krejci | f16e254 | 2021-02-17 15:39:23 +0100 | [diff] [blame] | 1777 | lyd_parse_json(const struct ly_ctx *ctx, const struct lysc_ext_instance *ext, struct lyd_node *parent, |
Michal Vasko | e3ed7dc | 2022-11-30 11:39:44 +0100 | [diff] [blame] | 1778 | struct lyd_node **first_p, struct ly_in *in, uint32_t parse_opts, uint32_t val_opts, uint32_t int_opts, |
Michal Vasko | ddd7659 | 2022-01-17 13:34:48 +0100 | [diff] [blame] | 1779 | struct ly_set *parsed, ly_bool *subtree_sibling, struct lyd_ctx **lydctx_p) |
Radek Krejci | 1798aae | 2020-07-14 13:26:06 +0200 | [diff] [blame] | 1780 | { |
Michal Vasko | d027f38 | 2023-02-10 09:13:25 +0100 | [diff] [blame] | 1781 | LY_ERR r, rc = LY_SUCCESS; |
Radek Krejci | 1798aae | 2020-07-14 13:26:06 +0200 | [diff] [blame] | 1782 | struct lyd_json_ctx *lydctx = NULL; |
| 1783 | enum LYJSON_PARSER_STATUS status; |
| 1784 | |
Michal Vasko | e066574 | 2021-02-11 11:08:44 +0100 | [diff] [blame] | 1785 | rc = lyd_parse_json_init(ctx, in, parse_opts, val_opts, &lydctx, &status); |
| 1786 | LY_CHECK_GOTO(rc || status == LYJSON_END || status == LYJSON_OBJECT_EMPTY, cleanup); |
Radek Krejci | 1798aae | 2020-07-14 13:26:06 +0200 | [diff] [blame] | 1787 | |
Radek Krejci | cd5f622 | 2020-11-12 08:54:13 +0100 | [diff] [blame] | 1788 | assert(status == LYJSON_OBJECT); |
Radek Krejci | 1798aae | 2020-07-14 13:26:06 +0200 | [diff] [blame] | 1789 | |
Michal Vasko | e066574 | 2021-02-11 11:08:44 +0100 | [diff] [blame] | 1790 | lydctx->int_opts = int_opts; |
Radek Krejci | f16e254 | 2021-02-17 15:39:23 +0100 | [diff] [blame] | 1791 | lydctx->ext = ext; |
Michal Vasko | e066574 | 2021-02-11 11:08:44 +0100 | [diff] [blame] | 1792 | |
| 1793 | /* find the operation node if it exists already */ |
| 1794 | LY_CHECK_GOTO(rc = lyd_parser_find_operation(parent, int_opts, &lydctx->op_node), cleanup); |
| 1795 | |
Radek Krejci | 1798aae | 2020-07-14 13:26:06 +0200 | [diff] [blame] | 1796 | /* read subtree(s) */ |
Michal Vasko | e066574 | 2021-02-11 11:08:44 +0100 | [diff] [blame] | 1797 | while (lydctx->jsonctx->in->current[0] && (status != LYJSON_OBJECT_CLOSED)) { |
Michal Vasko | d027f38 | 2023-02-10 09:13:25 +0100 | [diff] [blame] | 1798 | r = lydjson_subtree_r(lydctx, parent, first_p, parsed); |
| 1799 | LY_DPARSER_ERR_GOTO(r, rc = r, lydctx, cleanup); |
Radek Krejci | 1798aae | 2020-07-14 13:26:06 +0200 | [diff] [blame] | 1800 | |
| 1801 | status = lyjson_ctx_status(lydctx->jsonctx, 0); |
Michal Vasko | e066574 | 2021-02-11 11:08:44 +0100 | [diff] [blame] | 1802 | |
| 1803 | if (!(int_opts & LYD_INTOPT_WITH_SIBLINGS)) { |
| 1804 | break; |
| 1805 | } |
| 1806 | } |
| 1807 | |
| 1808 | if ((int_opts & LYD_INTOPT_NO_SIBLINGS) && lydctx->jsonctx->in->current[0] && |
| 1809 | (lyjson_ctx_status(lydctx->jsonctx, 0) != LYJSON_OBJECT_CLOSED)) { |
| 1810 | LOGVAL(ctx, LYVE_SYNTAX, "Unexpected sibling node."); |
Michal Vasko | d027f38 | 2023-02-10 09:13:25 +0100 | [diff] [blame] | 1811 | r = LY_EVALID; |
| 1812 | LY_DPARSER_ERR_GOTO(r, rc = r, lydctx, cleanup); |
Michal Vasko | e066574 | 2021-02-11 11:08:44 +0100 | [diff] [blame] | 1813 | } |
| 1814 | if ((int_opts & (LYD_INTOPT_RPC | LYD_INTOPT_ACTION | LYD_INTOPT_NOTIF | LYD_INTOPT_REPLY)) && !lydctx->op_node) { |
| 1815 | LOGVAL(ctx, LYVE_DATA, "Missing the operation node."); |
Michal Vasko | d027f38 | 2023-02-10 09:13:25 +0100 | [diff] [blame] | 1816 | r = LY_EVALID; |
| 1817 | LY_DPARSER_ERR_GOTO(r, rc = r, lydctx, cleanup); |
Radek Krejci | 1798aae | 2020-07-14 13:26:06 +0200 | [diff] [blame] | 1818 | } |
| 1819 | |
| 1820 | /* finish linking metadata */ |
Michal Vasko | d027f38 | 2023-02-10 09:13:25 +0100 | [diff] [blame] | 1821 | r = lydjson_metadata_finish(lydctx, parent ? lyd_node_child_p(parent) : first_p); |
| 1822 | LY_CHECK_ERR_GOTO(r, rc = r, cleanup); |
Radek Krejci | 1798aae | 2020-07-14 13:26:06 +0200 | [diff] [blame] | 1823 | |
Michal Vasko | 61ad1ff | 2022-02-10 15:48:39 +0100 | [diff] [blame] | 1824 | if (parse_opts & LYD_PARSE_SUBTREE) { |
| 1825 | /* check for a sibling object */ |
| 1826 | assert(subtree_sibling); |
| 1827 | if (lydctx->jsonctx->in->current[0] == ',') { |
| 1828 | *subtree_sibling = 1; |
| 1829 | |
| 1830 | /* move to the next object */ |
| 1831 | ly_in_skip(lydctx->jsonctx->in, 1); |
| 1832 | } else { |
| 1833 | *subtree_sibling = 0; |
| 1834 | } |
| 1835 | } |
| 1836 | |
Radek Krejci | 1798aae | 2020-07-14 13:26:06 +0200 | [diff] [blame] | 1837 | cleanup: |
| 1838 | /* there should be no unresolved types stored */ |
Michal Vasko | 58c8b56 | 2021-12-09 09:25:33 +0100 | [diff] [blame] | 1839 | assert(!(parse_opts & LYD_PARSE_ONLY) || !lydctx || (!lydctx->node_types.count && !lydctx->meta_types.count && |
Michal Vasko | 49c39d8 | 2020-11-06 17:20:27 +0100 | [diff] [blame] | 1840 | !lydctx->node_when.count)); |
Radek Krejci | 1798aae | 2020-07-14 13:26:06 +0200 | [diff] [blame] | 1841 | |
Michal Vasko | d027f38 | 2023-02-10 09:13:25 +0100 | [diff] [blame] | 1842 | if (rc && (!lydctx || !(lydctx->val_opts & LYD_VALIDATE_MULTI_ERROR) || (rc != LY_EVALID))) { |
Radek Krejci | 1798aae | 2020-07-14 13:26:06 +0200 | [diff] [blame] | 1843 | lyd_json_ctx_free((struct lyd_ctx *)lydctx); |
Radek Krejci | 1798aae | 2020-07-14 13:26:06 +0200 | [diff] [blame] | 1844 | } else { |
| 1845 | *lydctx_p = (struct lyd_ctx *)lydctx; |
Michal Vasko | f8ebf13 | 2022-11-21 14:06:48 +0100 | [diff] [blame] | 1846 | |
| 1847 | /* the JSON context is no more needed, freeing it also stops logging line numbers which would be confusing now */ |
| 1848 | lyjson_ctx_free(lydctx->jsonctx); |
| 1849 | lydctx->jsonctx = NULL; |
Radek Krejci | 1798aae | 2020-07-14 13:26:06 +0200 | [diff] [blame] | 1850 | } |
Michal Vasko | e066574 | 2021-02-11 11:08:44 +0100 | [diff] [blame] | 1851 | return rc; |
Michal Vasko | 90932a9 | 2020-02-12 14:33:03 +0100 | [diff] [blame] | 1852 | } |