blob: e023c549055240e2c9cefbb07f2c2a9116f38880 [file] [log] [blame]
Radek Krejcie7b95092019-05-15 11:03:07 +02001/**
Michal Vasko59892dd2022-05-13 11:02:30 +02002 * @file tree_data_common.c
Radek Krejcie7b95092019-05-15 11:03:07 +02003 * @author Radek Krejci <rkrejci@cesnet.cz>
Michal Vasko59892dd2022-05-13 11:02:30 +02004 * @author Michal Vasko <mvasko@cesnet.cz>
5 * @brief Parsing and validation common functions for data trees
Radek Krejcie7b95092019-05-15 11:03:07 +02006 *
Michal Vasko8cc3f662022-03-29 11:25:51 +02007 * Copyright (c) 2015 - 2022 CESNET, z.s.p.o.
Radek Krejcie7b95092019-05-15 11:03:07 +02008 *
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 */
Michal Vasko43297a02021-05-19 11:12:37 +020015
16#define _GNU_SOURCE /* asprintf, strdup */
Radek Krejcie7b95092019-05-15 11:03:07 +020017
18#include <assert.h>
Michal Vasko43297a02021-05-19 11:12:37 +020019#include <ctype.h>
Radek Krejci535ea9f2020-05-29 16:01:05 +020020#include <stdint.h>
Radek Krejcie7b95092019-05-15 11:03:07 +020021#include <stdlib.h>
Radek Krejciad97c5f2020-06-30 09:19:28 +020022#include <string.h>
Michal Vasko43297a02021-05-19 11:12:37 +020023#include <time.h>
Radek Krejcie7b95092019-05-15 11:03:07 +020024
Radek Krejci535ea9f2020-05-29 16:01:05 +020025#include "common.h"
Michal Vasko6b5cb2a2020-11-11 19:11:21 +010026#include "compat.h"
Radek Krejci535ea9f2020-05-29 16:01:05 +020027#include "context.h"
Radek Krejci47fab892020-11-05 17:02:41 +010028#include "dict.h"
Radek Krejciad97c5f2020-06-30 09:19:28 +020029#include "hash_table.h"
Radek Krejcie7b95092019-05-15 11:03:07 +020030#include "log.h"
Radek Krejciad97c5f2020-06-30 09:19:28 +020031#include "lyb.h"
Radek Krejci7931b192020-06-25 17:05:03 +020032#include "parser_data.h"
Michal Vasko8cc3f662022-03-29 11:25:51 +020033#include "plugins_exts.h"
Michal Vaskoa820c312021-02-05 16:33:00 +010034#include "printer_data.h"
Radek Krejciad97c5f2020-06-30 09:19:28 +020035#include "set.h"
Radek Krejci535ea9f2020-05-29 16:01:05 +020036#include "tree.h"
Radek Krejcie7b95092019-05-15 11:03:07 +020037#include "tree_data.h"
Michal Vasko60ea6352020-06-29 13:39:39 +020038#include "tree_data_internal.h"
Radek Krejci859a15a2021-03-05 20:56:59 +010039#include "tree_edit.h"
Radek Krejcie7b95092019-05-15 11:03:07 +020040#include "tree_schema.h"
Radek Krejci0aa1f702021-04-01 16:16:19 +020041#include "tree_schema_internal.h"
Radek Krejci4f2e3e52021-03-30 14:20:28 +020042#include "validation.h"
Radek Krejci77114102021-03-10 15:21:57 +010043#include "xml.h"
aPiecekdf23eee2021-10-07 12:21:50 +020044#include "xpath.h"
Radek Krejcie7b95092019-05-15 11:03:07 +020045
Michal Vaskod7c048c2021-05-18 16:12:55 +020046/**
47 * @brief Find an entry in duplicate instance cache for an instance. Create it if it does not exist.
48 *
49 * @param[in] first_inst Instance of the cache entry.
50 * @param[in,out] dup_inst_cache Duplicate instance cache.
51 * @return Instance cache entry.
52 */
53static struct lyd_dup_inst *
54lyd_dup_inst_get(const struct lyd_node *first_inst, struct lyd_dup_inst **dup_inst_cache)
55{
56 struct lyd_dup_inst *item;
57 LY_ARRAY_COUNT_TYPE u;
58
59 LY_ARRAY_FOR(*dup_inst_cache, u) {
60 if ((*dup_inst_cache)[u].inst_set->dnodes[0] == first_inst) {
61 return &(*dup_inst_cache)[u];
62 }
63 }
64
65 /* it was not added yet, add it now */
66 LY_ARRAY_NEW_RET(LYD_CTX(first_inst), *dup_inst_cache, item, NULL);
67
68 return item;
69}
70
71LY_ERR
72lyd_dup_inst_next(struct lyd_node **inst, const struct lyd_node *siblings, struct lyd_dup_inst **dup_inst_cache)
73{
74 struct lyd_dup_inst *dup_inst;
75
Michal Vasko83ae7772022-06-08 10:01:55 +020076 if (!*inst) {
77 /* no match, inst is unchanged */
Michal Vaskod7c048c2021-05-18 16:12:55 +020078 return LY_SUCCESS;
79 }
80
Michal Vasko83ae7772022-06-08 10:01:55 +020081 /* there can be more exact same instances (even if not allowed in invalid data) and we must make sure we do not
82 * match a single node more times */
Michal Vaskod7c048c2021-05-18 16:12:55 +020083 dup_inst = lyd_dup_inst_get(*inst, dup_inst_cache);
84 LY_CHECK_ERR_RET(!dup_inst, LOGMEM(LYD_CTX(siblings)), LY_EMEM);
85
86 if (!dup_inst->used) {
87 /* we did not cache these instances yet, do so */
88 lyd_find_sibling_dup_inst_set(siblings, *inst, &dup_inst->inst_set);
89 assert(dup_inst->inst_set->count && (dup_inst->inst_set->dnodes[0] == *inst));
90 }
91
92 if (dup_inst->used == dup_inst->inst_set->count) {
93 /* we have used all the instances */
94 *inst = NULL;
95 } else {
96 assert(dup_inst->used < dup_inst->inst_set->count);
97
98 /* use another instance */
99 *inst = dup_inst->inst_set->dnodes[dup_inst->used];
100 ++dup_inst->used;
101 }
102
103 return LY_SUCCESS;
104}
105
106void
107lyd_dup_inst_free(struct lyd_dup_inst *dup_inst)
108{
109 LY_ARRAY_COUNT_TYPE u;
110
111 LY_ARRAY_FOR(dup_inst, u) {
112 ly_set_free(dup_inst[u].inst_set, NULL);
113 }
114 LY_ARRAY_FREE(dup_inst);
115}
116
Michal Vaskoa6669ba2020-08-06 16:14:26 +0200117struct lyd_node *
118lys_getnext_data(const struct lyd_node *last, const struct lyd_node *sibling, const struct lysc_node **slast,
Radek Krejci0f969882020-08-21 16:56:47 +0200119 const struct lysc_node *parent, const struct lysc_module *module)
Michal Vaskoa6669ba2020-08-06 16:14:26 +0200120{
121 const struct lysc_node *siter = NULL;
122 struct lyd_node *match = NULL;
123
124 assert(parent || module);
125 assert(!last || (slast && *slast));
126
127 if (slast) {
128 siter = *slast;
129 }
130
131 if (last && last->next && (last->next->schema == siter)) {
132 /* return next data instance */
133 return last->next;
134 }
135
136 /* find next schema node data instance */
137 while ((siter = lys_getnext(siter, parent, module, 0))) {
138 if (!lyd_find_sibling_val(sibling, siter, NULL, 0, &match)) {
139 break;
140 }
141 }
142
143 if (slast) {
144 *slast = siter;
145 }
146 return match;
147}
148
Radek Krejcie7b95092019-05-15 11:03:07 +0200149struct lyd_node **
Michal Vaskoe0665742021-02-11 11:08:44 +0100150lyd_node_child_p(struct lyd_node *node)
Radek Krejcie7b95092019-05-15 11:03:07 +0200151{
152 assert(node);
Michal Vasko52927e22020-03-16 17:26:14 +0100153
154 if (!node->schema) {
155 return &((struct lyd_node_opaq *)node)->child;
156 } else {
157 switch (node->schema->nodetype) {
158 case LYS_CONTAINER:
159 case LYS_LIST:
Michal Vasko1bf09392020-03-27 12:38:10 +0100160 case LYS_RPC:
Michal Vasko52927e22020-03-16 17:26:14 +0100161 case LYS_ACTION:
162 case LYS_NOTIF:
163 return &((struct lyd_node_inner *)node)->child;
164 default:
165 return NULL;
166 }
Radek Krejcie7b95092019-05-15 11:03:07 +0200167 }
168}
169
Jan Kundrátc53a7ec2021-12-09 16:01:19 +0100170LIBYANG_API_DEF LY_ERR
aPiecekdf23eee2021-10-07 12:21:50 +0200171lyxp_vars_set(struct lyxp_var **vars, const char *name, const char *value)
172{
173 LY_ERR ret = LY_SUCCESS;
174 char *var_name = NULL, *var_value = NULL;
175 struct lyxp_var *item;
176
177 if (!vars || !name || !value) {
178 return LY_EINVAL;
179 }
180
181 /* If variable is already defined then change its value. */
182 if (*vars && !lyxp_vars_find(*vars, name, 0, &item)) {
183 var_value = strdup(value);
184 LY_CHECK_RET(!var_value, LY_EMEM);
185
186 /* Set new value. */
187 free(item->value);
188 item->value = var_value;
189 } else {
190 var_name = strdup(name);
191 var_value = strdup(value);
192 LY_CHECK_ERR_GOTO(!var_name || !var_value, ret = LY_EMEM, error);
193
194 /* Add new variable. */
195 LY_ARRAY_NEW_GOTO(NULL, *vars, item, ret, error);
196 item->name = var_name;
197 item->value = var_value;
198 }
199
200 return LY_SUCCESS;
201
202error:
203 free(var_name);
204 free(var_value);
205 return ret;
206}
207
Jan Kundrátc53a7ec2021-12-09 16:01:19 +0100208LIBYANG_API_DEF void
aPiecekdf23eee2021-10-07 12:21:50 +0200209lyxp_vars_free(struct lyxp_var *vars)
210{
211 LY_ARRAY_COUNT_TYPE u;
212
213 if (!vars) {
214 return;
215 }
216
217 LY_ARRAY_FOR(vars, u) {
218 free(vars[u].name);
219 free(vars[u].value);
220 }
221
222 LY_ARRAY_FREE(vars);
223}
224
Jan Kundrátc53a7ec2021-12-09 16:01:19 +0100225LIBYANG_API_DEF struct lyd_node *
Radek Krejcia1c1e542020-09-29 16:06:52 +0200226lyd_child_no_keys(const struct lyd_node *node)
227{
228 struct lyd_node **children;
229
230 if (!node) {
231 return NULL;
232 }
233
234 if (!node->schema) {
235 /* opaq node */
Michal Vasko9e685082021-01-29 14:49:09 +0100236 return ((struct lyd_node_opaq *)node)->child;
Radek Krejcia1c1e542020-09-29 16:06:52 +0200237 }
238
Michal Vaskoe0665742021-02-11 11:08:44 +0100239 children = lyd_node_child_p((struct lyd_node *)node);
Radek Krejcia1c1e542020-09-29 16:06:52 +0200240 if (children) {
241 struct lyd_node *child = *children;
242 while (child && child->schema && (child->schema->flags & LYS_KEY)) {
243 child = child->next;
Michal Vasko5bfd4be2020-06-23 13:26:19 +0200244 }
245 return child;
Radek Krejcie7b95092019-05-15 11:03:07 +0200246 } else {
247 return NULL;
248 }
249}
Michal Vasko9b368d32020-02-14 13:53:31 +0100250
Jan Kundrátc53a7ec2021-12-09 16:01:19 +0100251LIBYANG_API_DEF const struct lys_module *
Michal Vaskoc193ce92020-03-06 11:04:48 +0100252lyd_owner_module(const struct lyd_node *node)
Michal Vasko9b368d32020-02-14 13:53:31 +0100253{
Michal Vaskod5cfa6e2020-11-23 16:56:08 +0100254 const struct lyd_node_opaq *opaq;
Michal Vasko9b368d32020-02-14 13:53:31 +0100255
Michal Vaskod5cfa6e2020-11-23 16:56:08 +0100256 if (!node) {
Michal Vaskoc193ce92020-03-06 11:04:48 +0100257 return NULL;
258 }
Michal Vasko9b368d32020-02-14 13:53:31 +0100259
Michal Vaskod5cfa6e2020-11-23 16:56:08 +0100260 if (!node->schema) {
261 opaq = (struct lyd_node_opaq *)node;
262 switch (opaq->format) {
Radek Krejci8df109d2021-04-23 12:19:08 +0200263 case LY_VALUE_XML:
Michal Vaskod5cfa6e2020-11-23 16:56:08 +0100264 return ly_ctx_get_module_implemented_ns(LYD_CTX(node), opaq->name.module_ns);
Radek Krejci8df109d2021-04-23 12:19:08 +0200265 case LY_VALUE_JSON:
Michal Vaskod5cfa6e2020-11-23 16:56:08 +0100266 return ly_ctx_get_module_implemented(LYD_CTX(node), opaq->name.module_name);
267 default:
268 return NULL;
269 }
270 }
271
Michal Vaskoef53c812021-10-13 10:21:03 +0200272 return lysc_owner_module(node->schema);
Michal Vasko9b368d32020-02-14 13:53:31 +0100273}
Michal Vaskob1b5c262020-03-05 14:29:47 +0100274
Michal Vasko598063b2021-07-19 11:39:05 +0200275void
276lyd_first_module_sibling(struct lyd_node **node, const struct lys_module *mod)
277{
278 int cmp;
279 struct lyd_node *first;
Michal Vaskoec139eb2022-05-10 10:08:40 +0200280 const struct lys_module *own_mod;
Michal Vasko598063b2021-07-19 11:39:05 +0200281
282 assert(node && mod);
283
284 if (!*node) {
285 return;
286 }
287
288 first = *node;
Michal Vaskoec139eb2022-05-10 10:08:40 +0200289 own_mod = lyd_owner_module(first);
290 cmp = own_mod ? strcmp(own_mod->name, mod->name) : 1;
Michal Vasko598063b2021-07-19 11:39:05 +0200291 if (cmp > 0) {
292 /* there may be some preceding data */
293 while (first->prev->next) {
294 first = first->prev;
295 if (lyd_owner_module(first) == mod) {
296 cmp = 0;
297 break;
298 }
299 }
300 }
301
302 if (cmp == 0) {
303 /* there may be some preceding data belonging to this module */
304 while (first->prev->next) {
305 if (lyd_owner_module(first->prev) != mod) {
306 break;
307 }
308 first = first->prev;
309 }
310 }
311
312 if (cmp < 0) {
313 /* there may be some following data */
314 LY_LIST_FOR(first, first) {
315 if (lyd_owner_module(first) == mod) {
316 cmp = 0;
317 break;
318 }
319 }
320 }
321
322 if (cmp == 0) {
323 /* we have found the first module data node */
324 *node = first;
325 }
326}
327
Michal Vaskob1b5c262020-03-05 14:29:47 +0100328const struct lys_module *
Michal Vasko26e80012020-07-08 10:55:46 +0200329lyd_mod_next_module(struct lyd_node *tree, const struct lys_module *module, const struct ly_ctx *ctx, uint32_t *i,
Radek Krejci0f969882020-08-21 16:56:47 +0200330 struct lyd_node **first)
Michal Vaskob1b5c262020-03-05 14:29:47 +0100331{
332 struct lyd_node *iter;
333 const struct lys_module *mod;
334
335 /* get the next module */
Michal Vasko26e80012020-07-08 10:55:46 +0200336 if (module) {
337 if (*i) {
Michal Vaskob1b5c262020-03-05 14:29:47 +0100338 mod = NULL;
Michal Vasko26e80012020-07-08 10:55:46 +0200339 } else {
340 mod = module;
341 ++(*i);
Michal Vaskob1b5c262020-03-05 14:29:47 +0100342 }
343 } else {
344 do {
345 mod = ly_ctx_get_module_iter(ctx, i);
346 } while (mod && !mod->implemented);
347 }
348
349 /* find its data */
350 *first = NULL;
351 if (mod) {
352 LY_LIST_FOR(tree, iter) {
Michal Vaskoc193ce92020-03-06 11:04:48 +0100353 if (lyd_owner_module(iter) == mod) {
Michal Vaskob1b5c262020-03-05 14:29:47 +0100354 *first = iter;
355 break;
356 }
357 }
358 }
359
360 return mod;
361}
362
363const struct lys_module *
364lyd_data_next_module(struct lyd_node **next, struct lyd_node **first)
365{
366 const struct lys_module *mod;
367
368 if (!*next) {
369 /* all data traversed */
370 *first = NULL;
371 return NULL;
372 }
373
374 *first = *next;
375
376 /* prepare next */
Michal Vaskoc193ce92020-03-06 11:04:48 +0100377 mod = lyd_owner_module(*next);
Michal Vaskob1b5c262020-03-05 14:29:47 +0100378 LY_LIST_FOR(*next, *next) {
Michal Vaskoc193ce92020-03-06 11:04:48 +0100379 if (lyd_owner_module(*next) != mod) {
Michal Vaskob1b5c262020-03-05 14:29:47 +0100380 break;
381 }
382 }
383
384 return mod;
385}
Michal Vasko9f96a052020-03-10 09:41:45 +0100386
387LY_ERR
Michal Vasko59892dd2022-05-13 11:02:30 +0200388lyd_value_store(const struct ly_ctx *ctx, struct lyd_value *val, const struct lysc_type *type, const void *value,
389 size_t value_len, ly_bool *dynamic, LY_VALUE_FORMAT format, void *prefix_data, uint32_t hints,
390 const struct lysc_node *ctx_node, ly_bool *incomplete)
391{
392 LY_ERR ret;
393 struct ly_err_item *err = NULL;
394 uint32_t options = (dynamic && *dynamic ? LYPLG_TYPE_STORE_DYNAMIC : 0);
395
396 if (!value) {
397 value = "";
398 }
399 if (incomplete) {
400 *incomplete = 0;
401 }
402
403 ret = type->plugin->store(ctx, type, value, value_len, options, format, prefix_data, hints, ctx_node, val, NULL, &err);
404 if (dynamic) {
405 *dynamic = 0;
406 }
407
408 if (ret == LY_EINCOMPLETE) {
409 if (incomplete) {
410 *incomplete = 1;
411 }
412 } else if (ret) {
413 if (err) {
414 LOGVAL_ERRITEM(ctx, err);
415 ly_err_free(err);
416 } else {
417 LOGVAL(ctx, LYVE_OTHER, "Storing value failed.");
418 }
419 return ret;
420 }
421
422 return LY_SUCCESS;
423}
424
425LY_ERR
426lyd_value_validate_incomplete(const struct ly_ctx *ctx, const struct lysc_type *type, struct lyd_value *val,
427 const struct lyd_node *ctx_node, const struct lyd_node *tree)
428{
429 LY_ERR ret;
430 struct ly_err_item *err = NULL;
431
432 assert(type->plugin->validate);
433
434 ret = type->plugin->validate(ctx, type, ctx_node, tree, val, &err);
435 if (ret) {
436 if (err) {
437 LOGVAL_ERRITEM(ctx, err);
438 ly_err_free(err);
439 } else {
440 LOGVAL(ctx, LYVE_OTHER, "Resolving value \"%s\" failed.", type->plugin->print(ctx, val, LY_VALUE_CANON,
441 NULL, NULL, NULL));
442 }
443 return ret;
444 }
445
446 return LY_SUCCESS;
447}
448
449LY_ERR
450lys_value_validate(const struct ly_ctx *ctx, const struct lysc_node *node, const char *value, size_t value_len,
451 LY_VALUE_FORMAT format, void *prefix_data)
452{
453 LY_ERR rc = LY_SUCCESS;
454 struct ly_err_item *err = NULL;
455 struct lyd_value storage;
456 struct lysc_type *type;
457
458 LY_CHECK_ARG_RET(ctx, node, value, LY_EINVAL);
459
460 if (!(node->nodetype & (LYS_LEAF | LYS_LEAFLIST))) {
461 LOGARG(ctx, node);
462 return LY_EINVAL;
463 }
464
465 type = ((struct lysc_node_leaf *)node)->type;
466 rc = type->plugin->store(ctx ? ctx : node->module->ctx, type, value, value_len, 0, format, prefix_data,
467 LYD_HINT_SCHEMA, node, &storage, NULL, &err);
468 if (rc == LY_EINCOMPLETE) {
469 /* actually success since we do not provide the context tree and call validation with
470 * LY_TYPE_OPTS_INCOMPLETE_DATA */
471 rc = LY_SUCCESS;
472 } else if (rc && err) {
473 if (ctx) {
474 /* log only in case the ctx was provided as input parameter */
475 LOG_LOCSET(NULL, NULL, err->path, NULL);
476 LOGVAL_ERRITEM(ctx, err);
477 LOG_LOCBACK(0, 0, 1, 0);
478 }
479 ly_err_free(err);
480 }
481
482 if (!rc) {
483 type->plugin->free(ctx ? ctx : node->module->ctx, &storage);
484 }
485 return rc;
486}
487
488LIBYANG_API_DEF LY_ERR
489lyd_value_validate(const struct ly_ctx *ctx, const struct lysc_node *schema, const char *value, size_t value_len,
490 const struct lyd_node *ctx_node, const struct lysc_type **realtype, const char **canonical)
491{
492 LY_ERR rc;
493 struct ly_err_item *err = NULL;
494 struct lysc_type *type;
495 struct lyd_value val = {0};
496 ly_bool stored = 0, log = 1;
497
Michal Vasko3dd16da2022-06-15 07:58:41 +0200498 LY_CHECK_ARG_RET(ctx, schema, !value_len || value, LY_EINVAL);
Michal Vasko59892dd2022-05-13 11:02:30 +0200499
500 if (!ctx) {
501 ctx = schema->module->ctx;
502 log = 0;
503 }
Michal Vasko3dd16da2022-06-15 07:58:41 +0200504 if (!value_len) {
505 value = "";
506 }
Michal Vasko59892dd2022-05-13 11:02:30 +0200507 type = ((struct lysc_node_leaf *)schema)->type;
508
509 /* store */
510 rc = type->plugin->store(ctx, type, value, value_len, 0, LY_VALUE_JSON, NULL,
511 LYD_HINT_DATA, schema, &val, NULL, &err);
512 if (!rc || (rc == LY_EINCOMPLETE)) {
513 stored = 1;
514 }
515
516 if (ctx_node && (rc == LY_EINCOMPLETE)) {
517 /* resolve */
518 rc = type->plugin->validate(ctx, type, ctx_node, ctx_node, &val, &err);
519 }
520
521 if (rc && (rc != LY_EINCOMPLETE) && err) {
522 if (log) {
523 /* log error */
524 if (err->path) {
525 LOG_LOCSET(NULL, NULL, err->path, NULL);
526 } else if (ctx_node) {
527 LOG_LOCSET(NULL, ctx_node, NULL, NULL);
528 } else {
529 LOG_LOCSET(schema, NULL, NULL, NULL);
530 }
531 LOGVAL_ERRITEM(ctx, err);
532 if (err->path) {
533 LOG_LOCBACK(0, 0, 1, 0);
534 } else if (ctx_node) {
535 LOG_LOCBACK(0, 1, 0, 0);
536 } else {
537 LOG_LOCBACK(1, 0, 0, 0);
538 }
539 }
540 ly_err_free(err);
541 }
542
543 if (!rc || (rc == LY_EINCOMPLETE)) {
544 if (realtype) {
545 /* return realtype */
546 if (val.realtype->basetype == LY_TYPE_UNION) {
547 *realtype = val.subvalue->value.realtype;
548 } else {
549 *realtype = val.realtype;
550 }
551 }
552
553 if (canonical) {
554 /* return canonical value */
555 lydict_insert(ctx, val.realtype->plugin->print(ctx, &val, LY_VALUE_CANON, NULL, NULL, NULL), 0, canonical);
556 }
557 }
558
559 if (stored) {
560 /* free value */
561 type->plugin->free(ctx ? ctx : schema->module->ctx, &val);
562 }
563 return rc;
564}
565
566LIBYANG_API_DEF LY_ERR
567lyd_value_compare(const struct lyd_node_term *node, const char *value, size_t value_len)
568{
569 LY_ERR ret = LY_SUCCESS;
570 struct ly_ctx *ctx;
571 struct lysc_type *type;
572 struct lyd_value val = {0};
573
574 LY_CHECK_ARG_RET(node ? node->schema->module->ctx : NULL, node, value, LY_EINVAL);
575
576 ctx = node->schema->module->ctx;
577 type = ((struct lysc_node_leaf *)node->schema)->type;
578
579 /* store the value */
580 LOG_LOCSET(node->schema, &node->node, NULL, NULL);
581 ret = lyd_value_store(ctx, &val, type, value, value_len, NULL, LY_VALUE_JSON, NULL, LYD_HINT_DATA, node->schema, NULL);
582 LOG_LOCBACK(1, 1, 0, 0);
583 LY_CHECK_RET(ret);
584
585 /* compare values */
586 ret = type->plugin->compare(&node->value, &val);
587
588 type->plugin->free(ctx, &val);
589 return ret;
590}
591
592LIBYANG_API_DEF ly_bool
593lyd_is_default(const struct lyd_node *node)
594{
595 const struct lysc_node_leaf *leaf;
596 const struct lysc_node_leaflist *llist;
597 const struct lyd_node_term *term;
598 LY_ARRAY_COUNT_TYPE u;
599
600 if (!(node->schema->nodetype & LYD_NODE_TERM)) {
601 return 0;
602 }
603
604 term = (const struct lyd_node_term *)node;
605
606 if (node->schema->nodetype == LYS_LEAF) {
607 leaf = (const struct lysc_node_leaf *)node->schema;
608 if (!leaf->dflt) {
609 return 0;
610 }
611
612 /* compare with the default value */
613 if (!leaf->type->plugin->compare(&term->value, leaf->dflt)) {
614 return 1;
615 }
616 } else {
617 llist = (const struct lysc_node_leaflist *)node->schema;
618 if (!llist->dflts) {
619 return 0;
620 }
621
622 LY_ARRAY_FOR(llist->dflts, u) {
623 /* compare with each possible default value */
624 if (!llist->type->plugin->compare(&term->value, llist->dflts[u])) {
625 return 1;
626 }
627 }
628 }
629
630 return 0;
631}
632
633LIBYANG_API_DEF uint32_t
634lyd_list_pos(const struct lyd_node *instance)
635{
636 const struct lyd_node *iter = NULL;
637 uint32_t pos = 0;
638
639 if (!instance || !(instance->schema->nodetype & (LYS_LIST | LYS_LEAFLIST))) {
640 return 0;
641 }
642
643 /* data instances are ordered, so we can stop when we found instance of other schema node */
644 for (iter = instance; iter->schema == instance->schema; iter = iter->prev) {
645 if (pos && (iter->next == NULL)) {
646 /* overrun to the end of the siblings list */
647 break;
648 }
649 ++pos;
650 }
651
652 return pos;
653}
654
655LIBYANG_API_DEF struct lyd_node *
656lyd_first_sibling(const struct lyd_node *node)
657{
658 struct lyd_node *start;
659
660 if (!node) {
661 return NULL;
662 }
663
664 /* get the first sibling */
665 if (node->parent) {
666 start = node->parent->child;
667 } else {
668 for (start = (struct lyd_node *)node; start->prev->next; start = start->prev) {}
669 }
670
671 return start;
672}
673
Michal Vaskobfff6ac2022-02-23 16:22:53 +0100674/**
675 * @brief Check list node parsed into an opaque node for the reason.
676 *
677 * @param[in] node Opaque node.
678 * @param[in] snode Schema node of @p opaq.
679 * @return LY_SUCCESS if the node is valid;
680 * @return LY_ERR on error.
681 */
682static LY_ERR
683lyd_parse_opaq_list_error(const struct lyd_node *node, const struct lysc_node *snode)
684{
685 LY_ERR ret = LY_SUCCESS;
686 struct ly_set key_set = {0};
687 const struct lysc_node *key = NULL;
688 const struct lyd_node *child;
689 const struct lyd_node_opaq *opaq_k;
690 uint32_t i;
691
692 assert(!node->schema);
693
694 /* get all keys into a set */
695 while ((key = lys_getnext(key, snode, NULL, 0)) && (snode->flags & LYS_KEY)) {
696 LY_CHECK_GOTO(ret = ly_set_add(&key_set, (void *)snode, 1, NULL), cleanup);
697 }
698
699 LY_LIST_FOR(lyd_child(node), child) {
700 if (child->schema) {
701 LOGERR(LYD_CTX(node), LY_EINVAL, "Unexpected node %s \"%s\".", lys_nodetype2str(child->schema->nodetype),
702 LYD_NAME(child));
703 ret = LY_EINVAL;
704 goto cleanup;
705 }
706
707 opaq_k = (struct lyd_node_opaq *)child;
708
709 /* find the key schema node */
710 for (i = 0; i < key_set.count; ++i) {
711 key = key_set.snodes[i];
712 if (!strcmp(key->name, opaq_k->name.name)) {
713 break;
714 }
715 }
716 if (i == key_set.count) {
717 /* some other node, skip */
718 continue;
719 }
720
721 /* key found */
722 ly_set_rm_index(&key_set, i, NULL);
723
724 /* check value */
725 ret = lys_value_validate(LYD_CTX(node), key, opaq_k->value, strlen(opaq_k->value), opaq_k->format,
726 opaq_k->val_prefix_data);
727 LY_CHECK_GOTO(ret, cleanup);
728 }
729
730 if (key_set.count) {
731 /* missing keys */
732 LOGVAL(LYD_CTX(node), LY_VCODE_NOKEY, key_set.snodes[0]->name);
733 ret = LY_EVALID;
734 goto cleanup;
735 }
736
737cleanup:
738 ly_set_erase(&key_set, NULL);
739 return ret;
740}
741
742LIBYANG_API_DEF LY_ERR
743lyd_parse_opaq_error(const struct lyd_node *node)
744{
745 const struct ly_ctx *ctx;
746 const struct lyd_node_opaq *opaq;
747 const struct lyd_node *parent;
748 const struct lys_module *mod;
749 const struct lysc_node *snode;
750
751 LY_CHECK_ARG_RET(LYD_CTX(node), node, !node->schema, !lyd_parent(node) || lyd_parent(node)->schema, LY_EINVAL);
752
753 ctx = LYD_CTX(node);
754 opaq = (struct lyd_node_opaq *)node;
755 parent = lyd_parent(node);
756
Michal Vaskof4e63922022-05-10 10:32:13 +0200757 if (!opaq->name.module_ns) {
758 LOGVAL(ctx, LYVE_REFERENCE, "Unknown module of node \"%s\".", opaq->name.name);
759 return LY_EVALID;
760 }
Michal Vaskobfff6ac2022-02-23 16:22:53 +0100761
762 /* module */
763 switch (opaq->format) {
764 case LY_VALUE_XML:
765 if (!parent || strcmp(opaq->name.module_ns, parent->schema->module->ns)) {
766 mod = ly_ctx_get_module_implemented_ns(ctx, opaq->name.module_ns);
767 if (!mod) {
768 LOGVAL(ctx, LYVE_REFERENCE, "No (implemented) module with namespace \"%s\" in the context.",
769 opaq->name.module_ns);
770 return LY_EVALID;
771 }
772 } else {
773 /* inherit */
774 mod = parent->schema->module;
775 }
776 break;
777 case LY_VALUE_JSON:
778 case LY_VALUE_LYB:
779 if (!parent || strcmp(opaq->name.module_name, parent->schema->module->name)) {
780 mod = ly_ctx_get_module_implemented(ctx, opaq->name.module_name);
781 if (!mod) {
782 LOGVAL(ctx, LYVE_REFERENCE, "No (implemented) module named \"%s\" in the context.", opaq->name.module_name);
783 return LY_EVALID;
784 }
785 } else {
786 /* inherit */
787 mod = parent->schema->module;
788 }
789 break;
790 default:
791 LOGERR(ctx, LY_EINVAL, "Unsupported value format.");
792 return LY_EINVAL;
793 }
794
795 /* schema */
796 snode = lys_find_child(parent ? parent->schema : NULL, mod, opaq->name.name, 0, 0, 0);
Michal Vaskoac6f4be2022-05-02 10:16:50 +0200797 if (!snode && parent && parent->schema && (parent->schema->nodetype & (LYS_RPC | LYS_ACTION))) {
798 /* maybe output node */
Michal Vasko89afc6e2022-05-02 10:24:26 +0200799 snode = lys_find_child(parent->schema, mod, opaq->name.name, 0, 0, LYS_GETNEXT_OUTPUT);
Michal Vaskoac6f4be2022-05-02 10:16:50 +0200800 }
Michal Vaskobfff6ac2022-02-23 16:22:53 +0100801 if (!snode) {
802 if (parent) {
803 LOGVAL(ctx, LYVE_REFERENCE, "Node \"%s\" not found as a child of \"%s\" node.", opaq->name.name,
804 LYD_NAME(parent));
805 } else {
806 LOGVAL(ctx, LYVE_REFERENCE, "Node \"%s\" not found in the \"%s\" module.", opaq->name.name, mod->name);
807 }
808 return LY_EVALID;
809 }
810
811 if (snode->nodetype & LYD_NODE_TERM) {
812 /* leaf / leaf-list */
813 LY_CHECK_RET(lys_value_validate(ctx, snode, opaq->value, strlen(opaq->value), opaq->format, opaq->val_prefix_data));
814 } else if (snode->nodetype == LYS_LIST) {
815 /* list */
816 LY_CHECK_RET(lyd_parse_opaq_list_error(node, snode));
817 } else if (snode->nodetype & LYD_NODE_INNER) {
818 /* inner node */
819 if (opaq->value) {
820 LOGVAL(ctx, LYVE_DATA, "Invalid value \"%s\" for %s \"%s\".", opaq->value,
821 lys_nodetype2str(snode->nodetype), snode->name);
822 return LY_EVALID;
823 }
824 } else {
825 LOGERR(ctx, LY_EINVAL, "Unexpected opaque schema node %s \"%s\".", lys_nodetype2str(snode->nodetype), snode->name);
826 return LY_EINVAL;
827 }
828
829 LOGERR(ctx, LY_EINVAL, "Unexpected valid opaque node %s \"%s\".", lys_nodetype2str(snode->nodetype), snode->name);
830 return LY_EINVAL;
831}
832
Jan Kundrátc53a7ec2021-12-09 16:01:19 +0100833LIBYANG_API_DEF const char *
Christian Hopps46bd21b2021-04-27 09:43:58 -0400834lyd_value_get_canonical(const struct ly_ctx *ctx, const struct lyd_value *value)
Radek Krejci6d5ba0c2021-04-26 07:49:59 +0200835{
Michal Vaskoab40e7e2021-04-28 17:04:24 +0200836 LY_CHECK_ARG_RET(ctx, ctx, value, NULL);
837
Michal Vasko33876022021-04-27 16:42:24 +0200838 return value->_canonical ? value->_canonical :
839 (const char *)value->realtype->plugin->print(ctx, value, LY_VALUE_CANON, NULL, NULL, NULL);
Radek Krejci6d5ba0c2021-04-26 07:49:59 +0200840}
841
Jan Kundrátc53a7ec2021-12-09 16:01:19 +0100842LIBYANG_API_DEF LY_ERR
Michal Vaskoa820c312021-02-05 16:33:00 +0100843lyd_any_value_str(const struct lyd_node *any, char **value_str)
844{
845 const struct lyd_node_any *a;
846 struct lyd_node *tree = NULL;
847 const char *str = NULL;
848 ly_bool dynamic = 0;
849 LY_ERR ret = LY_SUCCESS;
850
851 LY_CHECK_ARG_RET(NULL, any, value_str, LY_EINVAL);
Radek Krejci71877df2021-04-06 17:24:06 +0200852 LY_CHECK_ARG_RET(NULL, any->schema, any->schema->nodetype & LYS_ANYDATA, LY_EINVAL);
Michal Vaskoa820c312021-02-05 16:33:00 +0100853
854 a = (struct lyd_node_any *)any;
855 *value_str = NULL;
856
857 if (!a->value.str) {
858 /* there is no value in the union */
859 return LY_SUCCESS;
860 }
861
862 switch (a->value_type) {
863 case LYD_ANYDATA_LYB:
864 /* parse into a data tree */
865 ret = lyd_parse_data_mem(LYD_CTX(any), a->value.mem, LYD_LYB, LYD_PARSE_ONLY, 0, &tree);
866 LY_CHECK_GOTO(ret, cleanup);
867 dynamic = 1;
868 break;
869 case LYD_ANYDATA_DATATREE:
870 tree = a->value.tree;
871 break;
872 case LYD_ANYDATA_STRING:
873 case LYD_ANYDATA_XML:
874 case LYD_ANYDATA_JSON:
875 /* simply use the string */
876 str = a->value.str;
877 break;
878 }
879
880 if (tree) {
881 /* print into a string */
882 ret = lyd_print_mem(value_str, tree, LYD_XML, LYD_PRINT_WITHSIBLINGS);
883 LY_CHECK_GOTO(ret, cleanup);
884 } else {
885 assert(str);
886 *value_str = strdup(str);
887 LY_CHECK_ERR_GOTO(!*value_str, LOGMEM(LYD_CTX(any)), cleanup);
888 }
889
890 /* success */
891
892cleanup:
893 if (dynamic) {
894 lyd_free_all(tree);
895 }
896 return ret;
897}
898
Jan Kundrátc53a7ec2021-12-09 16:01:19 +0100899LIBYANG_API_DEF LY_ERR
Michal Vasko61551fa2020-07-09 15:45:45 +0200900lyd_any_copy_value(struct lyd_node *trg, const union lyd_any_value *value, LYD_ANYDATA_VALUETYPE value_type)
901{
902 struct lyd_node_any *t;
Michal Vasko61551fa2020-07-09 15:45:45 +0200903
Michal Vaskoa820c312021-02-05 16:33:00 +0100904 LY_CHECK_ARG_RET(NULL, trg, LY_EINVAL);
Radek Krejci71877df2021-04-06 17:24:06 +0200905 LY_CHECK_ARG_RET(NULL, trg->schema, trg->schema->nodetype & LYS_ANYDATA, LY_EINVAL);
Michal Vasko61551fa2020-07-09 15:45:45 +0200906
907 t = (struct lyd_node_any *)trg;
908
909 /* free trg */
910 switch (t->value_type) {
911 case LYD_ANYDATA_DATATREE:
912 lyd_free_all(t->value.tree);
913 break;
914 case LYD_ANYDATA_STRING:
915 case LYD_ANYDATA_XML:
916 case LYD_ANYDATA_JSON:
Michal Vaskoe180ed02021-02-05 16:31:20 +0100917 lydict_remove(LYD_CTX(trg), t->value.str);
Michal Vasko61551fa2020-07-09 15:45:45 +0200918 break;
919 case LYD_ANYDATA_LYB:
920 free(t->value.mem);
921 break;
922 }
923 t->value.str = NULL;
924
925 if (!value) {
926 /* only free value in this case */
927 return LY_SUCCESS;
928 }
929
930 /* copy src */
931 t->value_type = value_type;
932 switch (value_type) {
933 case LYD_ANYDATA_DATATREE:
934 if (value->tree) {
Michal Vasko3a41dff2020-07-15 14:30:28 +0200935 LY_CHECK_RET(lyd_dup_siblings(value->tree, NULL, LYD_DUP_RECURSIVE, &t->value.tree));
Michal Vasko61551fa2020-07-09 15:45:45 +0200936 }
937 break;
938 case LYD_ANYDATA_STRING:
939 case LYD_ANYDATA_XML:
940 case LYD_ANYDATA_JSON:
941 if (value->str) {
Radek Krejci011e4aa2020-09-04 15:22:31 +0200942 LY_CHECK_RET(lydict_insert(LYD_CTX(trg), value->str, 0, &t->value.str));
Michal Vasko61551fa2020-07-09 15:45:45 +0200943 }
944 break;
945 case LYD_ANYDATA_LYB:
946 if (value->mem) {
Radek Krejci1deb5be2020-08-26 16:43:36 +0200947 int len = lyd_lyb_data_length(value->mem);
Radek Krejci82fa8d42020-07-11 22:00:59 +0200948 LY_CHECK_RET(len == -1, LY_EINVAL);
Michal Vasko61551fa2020-07-09 15:45:45 +0200949 t->value.mem = malloc(len);
Michal Vaskob7be7a82020-08-20 09:09:04 +0200950 LY_CHECK_ERR_RET(!t->value.mem, LOGMEM(LYD_CTX(trg)), LY_EMEM);
Michal Vasko61551fa2020-07-09 15:45:45 +0200951 memcpy(t->value.mem, value->mem, len);
952 }
953 break;
954 }
955
956 return LY_SUCCESS;
957}
958
Michal Vasko106f0862021-11-02 11:49:27 +0100959const struct lysc_node *
960lyd_node_schema(const struct lyd_node *node)
961{
962 const struct lysc_node *schema = NULL;
963 const struct lyd_node *prev_iter = NULL, *iter;
964 const struct lys_module *mod;
965
966 if (!node) {
967 return NULL;
968 } else if (node->schema) {
969 return node->schema;
970 }
971
972 /* get schema node of an opaque node */
973 do {
974 /* get next data node */
975 for (iter = node; lyd_parent(iter) != prev_iter; iter = lyd_parent(iter)) {}
976
977 /* get equivalent schema node */
978 if (iter->schema) {
979 schema = iter->schema;
980 } else {
981 /* get module */
982 mod = lyd_owner_module(iter);
Michal Vaskoa41826a2021-11-02 12:13:03 +0100983 if (!mod && !schema) {
984 /* top-level opaque node has unknown module */
985 break;
986 }
Michal Vasko106f0862021-11-02 11:49:27 +0100987
988 /* get schema node */
989 schema = lys_find_child(schema, mod ? mod : schema->module, LYD_NAME(iter), 0, 0, 0);
990 }
Michal Vaskod2f404f2021-11-04 15:37:11 +0100991
992 /* remember to move to the descendant */
993 prev_iter = iter;
Michal Vasko106f0862021-11-02 11:49:27 +0100994 } while (schema && (iter != node));
995
996 return schema;
997}
998
Michal Vasko59892dd2022-05-13 11:02:30 +0200999/**
1000 * @brief Comparison callback to match schema node with a schema of a data node.
1001 *
1002 * @param[in] val1_p Pointer to the schema node
1003 * @param[in] val2_p Pointer to the data node
1004 * Implementation of ::lyht_value_equal_cb.
1005 */
1006static ly_bool
1007lyd_hash_table_schema_val_equal(void *val1_p, void *val2_p, ly_bool UNUSED(mod), void *UNUSED(cb_data))
1008{
1009 struct lysc_node *val1;
1010 struct lyd_node *val2;
1011
1012 val1 = *((struct lysc_node **)val1_p);
1013 val2 = *((struct lyd_node **)val2_p);
1014
1015 if (val1 == val2->schema) {
1016 /* schema match is enough */
1017 return 1;
1018 } else {
1019 return 0;
1020 }
1021}
1022
1023LY_ERR
1024lyd_find_sibling_schema(const struct lyd_node *siblings, const struct lysc_node *schema, struct lyd_node **match)
1025{
1026 struct lyd_node **match_p;
1027 struct lyd_node_inner *parent;
1028 uint32_t hash;
1029 lyht_value_equal_cb ht_cb;
1030
1031 assert(siblings && schema);
1032
1033 parent = siblings->parent;
1034 if (parent && parent->schema && parent->children_ht) {
1035 /* calculate our hash */
1036 hash = dict_hash_multi(0, schema->module->name, strlen(schema->module->name));
1037 hash = dict_hash_multi(hash, schema->name, strlen(schema->name));
1038 hash = dict_hash_multi(hash, NULL, 0);
1039
1040 /* use special hash table function */
1041 ht_cb = lyht_set_cb(parent->children_ht, lyd_hash_table_schema_val_equal);
1042
1043 /* find by hash */
1044 if (!lyht_find(parent->children_ht, &schema, hash, (void **)&match_p)) {
1045 siblings = *match_p;
1046 } else {
1047 /* not found */
1048 siblings = NULL;
1049 }
1050
1051 /* set the original hash table compare function back */
1052 lyht_set_cb(parent->children_ht, ht_cb);
1053 } else {
1054 /* find first sibling */
1055 if (siblings->parent) {
1056 siblings = siblings->parent->child;
1057 } else {
1058 while (siblings->prev->next) {
1059 siblings = siblings->prev;
1060 }
1061 }
1062
1063 /* search manually without hashes */
1064 for ( ; siblings; siblings = siblings->next) {
1065 if (siblings->schema == schema) {
1066 /* schema match is enough */
1067 break;
1068 }
1069 }
1070 }
1071
1072 if (!siblings) {
1073 if (match) {
1074 *match = NULL;
1075 }
1076 return LY_ENOTFOUND;
1077 }
1078
1079 if (match) {
1080 *match = (struct lyd_node *)siblings;
1081 }
1082 return LY_SUCCESS;
1083}
1084
Michal Vasko6b5cb2a2020-11-11 19:11:21 +01001085void
Michal Vaskod3bb12f2020-12-04 14:33:09 +01001086lyd_del_move_root(struct lyd_node **root, const struct lyd_node *to_del, const struct lys_module *mod)
1087{
1088 if (*root && (lyd_owner_module(*root) != mod)) {
1089 /* there are no data of mod so this is simply the first top-level sibling */
1090 mod = NULL;
1091 }
1092
1093 if ((*root != to_del) || (*root)->parent) {
1094 return;
1095 }
1096
Michal Vasko598063b2021-07-19 11:39:05 +02001097 if (mod && (*root)->prev->next && (!(*root)->next || (lyd_owner_module(to_del) != lyd_owner_module((*root)->next)))) {
1098 /* there are no more nodes from mod, simply get the first top-level sibling */
Michal Vaskod3bb12f2020-12-04 14:33:09 +01001099 *root = lyd_first_sibling(*root);
Michal Vasko598063b2021-07-19 11:39:05 +02001100 } else {
1101 *root = (*root)->next;
Michal Vaskod3bb12f2020-12-04 14:33:09 +01001102 }
1103}
1104
Michal Vasko8cc3f662022-03-29 11:25:51 +02001105LY_ERR
1106ly_nested_ext_schema(const struct lyd_node *parent, const struct lysc_node *sparent, const char *prefix,
1107 size_t prefix_len, LY_VALUE_FORMAT format, void *prefix_data, const char *name, size_t name_len,
1108 const struct lysc_node **snode, struct lysc_ext_instance **ext)
1109{
1110 LY_ERR r;
1111 LY_ARRAY_COUNT_TYPE u;
1112 struct lysc_ext_instance *nested_exts = NULL;
1113 lyplg_ext_data_snode_clb ext_snode_cb;
1114
1115 /* check if there are any nested extension instances */
1116 if (parent && parent->schema) {
1117 nested_exts = parent->schema->exts;
1118 } else if (sparent) {
1119 nested_exts = sparent->exts;
1120 }
1121 LY_ARRAY_FOR(nested_exts, u) {
Michal Vasko305c6cb2022-04-27 10:33:04 +02001122 if (!nested_exts[u].def->plugin) {
1123 /* no plugin */
1124 continue;
1125 }
1126
Michal Vasko8cc3f662022-03-29 11:25:51 +02001127 ext_snode_cb = nested_exts[u].def->plugin->snode;
1128 if (!ext_snode_cb) {
1129 /* not an extension with nested data */
1130 continue;
1131 }
1132
1133 /* try to get the schema node */
1134 r = ext_snode_cb(&nested_exts[u], parent, sparent, prefix, prefix_len, format, prefix_data, name, name_len, snode);
1135 if (!r) {
1136 /* data successfully created, remember the ext instance */
1137 *ext = &nested_exts[u];
1138 return LY_SUCCESS;
1139 } else if (r != LY_ENOT) {
1140 /* fatal error */
1141 return r;
1142 }
1143 /* data was not from this module, continue */
1144 }
1145
1146 /* no extensions or none matched */
1147 return LY_ENOT;
1148}
1149
Michal Vaskod3bb12f2020-12-04 14:33:09 +01001150void
Radek Krejci8df109d2021-04-23 12:19:08 +02001151ly_free_prefix_data(LY_VALUE_FORMAT format, void *prefix_data)
Michal Vasko6b5cb2a2020-11-11 19:11:21 +01001152{
1153 struct ly_set *ns_list;
1154 struct lysc_prefix *prefixes;
1155 uint32_t i;
1156 LY_ARRAY_COUNT_TYPE u;
1157
1158 if (!prefix_data) {
1159 return;
1160 }
1161
1162 switch (format) {
Radek Krejci8df109d2021-04-23 12:19:08 +02001163 case LY_VALUE_XML:
Michal Vaskoddd76592022-01-17 13:34:48 +01001164 case LY_VALUE_STR_NS:
Michal Vasko6b5cb2a2020-11-11 19:11:21 +01001165 ns_list = prefix_data;
1166 for (i = 0; i < ns_list->count; ++i) {
1167 free(((struct lyxml_ns *)ns_list->objs[i])->prefix);
1168 free(((struct lyxml_ns *)ns_list->objs[i])->uri);
1169 }
1170 ly_set_free(ns_list, free);
1171 break;
Radek Krejci8df109d2021-04-23 12:19:08 +02001172 case LY_VALUE_SCHEMA_RESOLVED:
Michal Vasko6b5cb2a2020-11-11 19:11:21 +01001173 prefixes = prefix_data;
1174 LY_ARRAY_FOR(prefixes, u) {
1175 free(prefixes[u].prefix);
1176 }
1177 LY_ARRAY_FREE(prefixes);
1178 break;
Radek Krejci224d4b42021-04-23 13:54:59 +02001179 case LY_VALUE_CANON:
Radek Krejci8df109d2021-04-23 12:19:08 +02001180 case LY_VALUE_SCHEMA:
1181 case LY_VALUE_JSON:
Radek Krejcif9943642021-04-26 10:18:21 +02001182 case LY_VALUE_LYB:
Michal Vasko6b5cb2a2020-11-11 19:11:21 +01001183 break;
1184 }
1185}
1186
1187LY_ERR
Radek Krejci8df109d2021-04-23 12:19:08 +02001188ly_dup_prefix_data(const struct ly_ctx *ctx, LY_VALUE_FORMAT format, const void *prefix_data,
Michal Vasko6b5cb2a2020-11-11 19:11:21 +01001189 void **prefix_data_p)
1190{
1191 LY_ERR ret = LY_SUCCESS;
1192 struct lyxml_ns *ns;
1193 struct lysc_prefix *prefixes = NULL, *orig_pref;
1194 struct ly_set *ns_list, *orig_ns;
1195 uint32_t i;
1196 LY_ARRAY_COUNT_TYPE u;
1197
1198 assert(!*prefix_data_p);
1199
1200 switch (format) {
Radek Krejci8df109d2021-04-23 12:19:08 +02001201 case LY_VALUE_SCHEMA:
Michal Vasko6b5cb2a2020-11-11 19:11:21 +01001202 *prefix_data_p = (void *)prefix_data;
1203 break;
Radek Krejci8df109d2021-04-23 12:19:08 +02001204 case LY_VALUE_SCHEMA_RESOLVED:
Michal Vasko6b5cb2a2020-11-11 19:11:21 +01001205 /* copy all the value prefixes */
1206 orig_pref = (struct lysc_prefix *)prefix_data;
1207 LY_ARRAY_CREATE_GOTO(ctx, prefixes, LY_ARRAY_COUNT(orig_pref), ret, cleanup);
1208 *prefix_data_p = prefixes;
1209
1210 LY_ARRAY_FOR(orig_pref, u) {
1211 if (orig_pref[u].prefix) {
1212 prefixes[u].prefix = strdup(orig_pref[u].prefix);
1213 LY_CHECK_ERR_GOTO(!prefixes[u].prefix, LOGMEM(ctx); ret = LY_EMEM, cleanup);
1214 }
1215 prefixes[u].mod = orig_pref[u].mod;
1216 LY_ARRAY_INCREMENT(prefixes);
1217 }
1218 break;
Radek Krejci8df109d2021-04-23 12:19:08 +02001219 case LY_VALUE_XML:
Michal Vaskoddd76592022-01-17 13:34:48 +01001220 case LY_VALUE_STR_NS:
Michal Vasko6b5cb2a2020-11-11 19:11:21 +01001221 /* copy all the namespaces */
1222 LY_CHECK_GOTO(ret = ly_set_new(&ns_list), cleanup);
1223 *prefix_data_p = ns_list;
1224
1225 orig_ns = (struct ly_set *)prefix_data;
1226 for (i = 0; i < orig_ns->count; ++i) {
1227 ns = calloc(1, sizeof *ns);
1228 LY_CHECK_ERR_GOTO(!ns, LOGMEM(ctx); ret = LY_EMEM, cleanup);
1229 LY_CHECK_GOTO(ret = ly_set_add(ns_list, ns, 1, NULL), cleanup);
1230
1231 if (((struct lyxml_ns *)orig_ns->objs[i])->prefix) {
1232 ns->prefix = strdup(((struct lyxml_ns *)orig_ns->objs[i])->prefix);
1233 LY_CHECK_ERR_GOTO(!ns->prefix, LOGMEM(ctx); ret = LY_EMEM, cleanup);
1234 }
1235 ns->uri = strdup(((struct lyxml_ns *)orig_ns->objs[i])->uri);
1236 LY_CHECK_ERR_GOTO(!ns->uri, LOGMEM(ctx); ret = LY_EMEM, cleanup);
1237 }
1238 break;
Radek Krejci224d4b42021-04-23 13:54:59 +02001239 case LY_VALUE_CANON:
Radek Krejci8df109d2021-04-23 12:19:08 +02001240 case LY_VALUE_JSON:
Radek Krejcif9943642021-04-26 10:18:21 +02001241 case LY_VALUE_LYB:
Michal Vasko6b5cb2a2020-11-11 19:11:21 +01001242 assert(!prefix_data);
1243 *prefix_data_p = NULL;
1244 break;
1245 }
1246
1247cleanup:
1248 if (ret) {
1249 ly_free_prefix_data(format, *prefix_data_p);
1250 *prefix_data_p = NULL;
1251 }
1252 return ret;
1253}
1254
1255LY_ERR
Radek Krejcif9943642021-04-26 10:18:21 +02001256ly_store_prefix_data(const struct ly_ctx *ctx, const void *value, size_t value_len, LY_VALUE_FORMAT format,
Radek Krejci8df109d2021-04-23 12:19:08 +02001257 const void *prefix_data, LY_VALUE_FORMAT *format_p, void **prefix_data_p)
Michal Vasko6b5cb2a2020-11-11 19:11:21 +01001258{
1259 LY_ERR ret = LY_SUCCESS;
Michal Vasko6b5cb2a2020-11-11 19:11:21 +01001260 const struct lys_module *mod;
Michal Vaskofc2cd072021-02-24 13:17:17 +01001261 const struct lyxml_ns *ns;
1262 struct lyxml_ns *new_ns;
Michal Vasko6b5cb2a2020-11-11 19:11:21 +01001263 struct ly_set *ns_list;
1264 struct lysc_prefix *prefixes = NULL, *val_pref;
aPiecek83436bc2021-03-30 12:20:45 +02001265 const char *value_iter, *value_next, *value_end;
1266 uint32_t substr_len;
1267 ly_bool is_prefix;
Michal Vasko6b5cb2a2020-11-11 19:11:21 +01001268
1269 switch (format) {
Radek Krejci8df109d2021-04-23 12:19:08 +02001270 case LY_VALUE_SCHEMA:
Michal Vaskofc2cd072021-02-24 13:17:17 +01001271 /* copy all referenced modules as prefix - module pairs */
1272 if (!*prefix_data_p) {
1273 /* new prefix data */
Michal Vasko6b5cb2a2020-11-11 19:11:21 +01001274 LY_ARRAY_CREATE_GOTO(ctx, prefixes, 0, ret, cleanup);
Radek Krejci8df109d2021-04-23 12:19:08 +02001275 *format_p = LY_VALUE_SCHEMA_RESOLVED;
Michal Vasko6b5cb2a2020-11-11 19:11:21 +01001276 *prefix_data_p = prefixes;
Michal Vaskofc2cd072021-02-24 13:17:17 +01001277 } else {
1278 /* reuse prefix data */
Radek Krejci8df109d2021-04-23 12:19:08 +02001279 assert(*format_p == LY_VALUE_SCHEMA_RESOLVED);
Michal Vaskofc2cd072021-02-24 13:17:17 +01001280 prefixes = *prefix_data_p;
Michal Vasko6b5cb2a2020-11-11 19:11:21 +01001281 }
1282
Michal Vaskoc0f9c4c2022-05-06 12:12:17 +02001283 /* add current module for unprefixed values */
1284 LY_ARRAY_NEW_GOTO(ctx, prefixes, val_pref, ret, cleanup);
1285 *prefix_data_p = prefixes;
1286
1287 val_pref->prefix = NULL;
1288 val_pref->mod = ((const struct lysp_module *)prefix_data)->mod;
1289
Michal Vasko6b5cb2a2020-11-11 19:11:21 +01001290 /* add all used prefixes */
Michal Vasko59e90fc2021-09-22 12:17:08 +02001291 value_end = (char *)value + value_len;
aPiecek83436bc2021-03-30 12:20:45 +02001292 for (value_iter = value; value_iter; value_iter = value_next) {
aPieceke3f828d2021-05-10 15:34:41 +02001293 LY_CHECK_GOTO(ret = ly_value_prefix_next(value_iter, value_end, &substr_len, &is_prefix, &value_next), cleanup);
aPiecek83436bc2021-03-30 12:20:45 +02001294 if (is_prefix) {
1295 /* we have a possible prefix. Do we already have the prefix? */
1296 mod = ly_resolve_prefix(ctx, value_iter, substr_len, *format_p, *prefix_data_p);
1297 if (!mod) {
1298 mod = ly_resolve_prefix(ctx, value_iter, substr_len, format, prefix_data);
1299 if (mod) {
Radek Krejci8df109d2021-04-23 12:19:08 +02001300 assert(*format_p == LY_VALUE_SCHEMA_RESOLVED);
aPiecek83436bc2021-03-30 12:20:45 +02001301 /* store a new prefix - module pair */
1302 LY_ARRAY_NEW_GOTO(ctx, prefixes, val_pref, ret, cleanup);
1303 *prefix_data_p = prefixes;
Michal Vasko6b5cb2a2020-11-11 19:11:21 +01001304
aPiecek83436bc2021-03-30 12:20:45 +02001305 val_pref->prefix = strndup(value_iter, substr_len);
1306 LY_CHECK_ERR_GOTO(!val_pref->prefix, LOGMEM(ctx); ret = LY_EMEM, cleanup);
1307 val_pref->mod = mod;
1308 } /* else it is not even defined */
1309 } /* else the prefix is already present */
Michal Vaskofc2cd072021-02-24 13:17:17 +01001310 }
1311 }
1312 break;
Radek Krejci8df109d2021-04-23 12:19:08 +02001313 case LY_VALUE_XML:
Michal Vaskoddd76592022-01-17 13:34:48 +01001314 case LY_VALUE_STR_NS:
Michal Vaskofc2cd072021-02-24 13:17:17 +01001315 /* copy all referenced namespaces as prefix - namespace pairs */
1316 if (!*prefix_data_p) {
1317 /* new prefix data */
1318 LY_CHECK_GOTO(ret = ly_set_new(&ns_list), cleanup);
Michal Vaskoddd76592022-01-17 13:34:48 +01001319 *format_p = format;
Michal Vaskofc2cd072021-02-24 13:17:17 +01001320 *prefix_data_p = ns_list;
1321 } else {
1322 /* reuse prefix data */
Michal Vaskoddd76592022-01-17 13:34:48 +01001323 assert(*format_p == format);
Michal Vaskofc2cd072021-02-24 13:17:17 +01001324 ns_list = *prefix_data_p;
1325 }
Michal Vasko6b5cb2a2020-11-11 19:11:21 +01001326
Michal Vasko294e7f02022-02-28 13:59:00 +01001327 /* store default namespace */
1328 ns = lyxml_ns_get(prefix_data, NULL, 0);
1329 if (ns) {
1330 new_ns = calloc(1, sizeof *new_ns);
1331 LY_CHECK_ERR_GOTO(!new_ns, LOGMEM(ctx); ret = LY_EMEM, cleanup);
1332 LY_CHECK_GOTO(ret = ly_set_add(ns_list, new_ns, 1, NULL), cleanup);
1333
1334 new_ns->prefix = NULL;
1335 new_ns->uri = strdup(ns->uri);
1336 LY_CHECK_ERR_GOTO(!new_ns->uri, LOGMEM(ctx); ret = LY_EMEM, cleanup);
1337 }
1338
Michal Vaskofc2cd072021-02-24 13:17:17 +01001339 /* add all used prefixes */
Michal Vasko59e90fc2021-09-22 12:17:08 +02001340 value_end = (char *)value + value_len;
aPiecek83436bc2021-03-30 12:20:45 +02001341 for (value_iter = value; value_iter; value_iter = value_next) {
aPieceke3f828d2021-05-10 15:34:41 +02001342 LY_CHECK_GOTO(ret = ly_value_prefix_next(value_iter, value_end, &substr_len, &is_prefix, &value_next), cleanup);
aPiecek83436bc2021-03-30 12:20:45 +02001343 if (is_prefix) {
1344 /* we have a possible prefix. Do we already have the prefix? */
1345 ns = lyxml_ns_get(ns_list, value_iter, substr_len);
1346 if (!ns) {
1347 ns = lyxml_ns_get(prefix_data, value_iter, substr_len);
1348 if (ns) {
1349 /* store a new prefix - namespace pair */
1350 new_ns = calloc(1, sizeof *new_ns);
1351 LY_CHECK_ERR_GOTO(!new_ns, LOGMEM(ctx); ret = LY_EMEM, cleanup);
1352 LY_CHECK_GOTO(ret = ly_set_add(ns_list, new_ns, 1, NULL), cleanup);
Michal Vaskofc2cd072021-02-24 13:17:17 +01001353
aPiecek83436bc2021-03-30 12:20:45 +02001354 new_ns->prefix = strndup(value_iter, substr_len);
1355 LY_CHECK_ERR_GOTO(!new_ns->prefix, LOGMEM(ctx); ret = LY_EMEM, cleanup);
1356 new_ns->uri = strdup(ns->uri);
1357 LY_CHECK_ERR_GOTO(!new_ns->uri, LOGMEM(ctx); ret = LY_EMEM, cleanup);
1358 } /* else it is not even defined */
1359 } /* else the prefix is already present */
Michal Vasko6b5cb2a2020-11-11 19:11:21 +01001360 }
1361 }
1362 break;
Radek Krejci224d4b42021-04-23 13:54:59 +02001363 case LY_VALUE_CANON:
Radek Krejci8df109d2021-04-23 12:19:08 +02001364 case LY_VALUE_SCHEMA_RESOLVED:
1365 case LY_VALUE_JSON:
Radek Krejcif9943642021-04-26 10:18:21 +02001366 case LY_VALUE_LYB:
Michal Vaskofc2cd072021-02-24 13:17:17 +01001367 if (!*prefix_data_p) {
1368 /* new prefix data - simply copy all the prefix data */
1369 *format_p = format;
1370 LY_CHECK_GOTO(ret = ly_dup_prefix_data(ctx, format, prefix_data, prefix_data_p), cleanup);
1371 } /* else reuse prefix data - the prefix data are always the same, nothing to do */
Michal Vasko6b5cb2a2020-11-11 19:11:21 +01001372 break;
1373 }
1374
1375cleanup:
1376 if (ret) {
1377 ly_free_prefix_data(*format_p, *prefix_data_p);
1378 *prefix_data_p = NULL;
1379 }
1380 return ret;
1381}
Michal Vasko7ed1fcb2020-12-03 14:15:22 +01001382
1383const char *
Radek Krejci8df109d2021-04-23 12:19:08 +02001384ly_format2str(LY_VALUE_FORMAT format)
Michal Vasko7ed1fcb2020-12-03 14:15:22 +01001385{
1386 switch (format) {
Radek Krejci224d4b42021-04-23 13:54:59 +02001387 case LY_VALUE_CANON:
1388 return "canonical";
Radek Krejci8df109d2021-04-23 12:19:08 +02001389 case LY_VALUE_SCHEMA:
Michal Vasko7ed1fcb2020-12-03 14:15:22 +01001390 return "schema imports";
Radek Krejci8df109d2021-04-23 12:19:08 +02001391 case LY_VALUE_SCHEMA_RESOLVED:
Michal Vasko7ed1fcb2020-12-03 14:15:22 +01001392 return "schema stored mapping";
Radek Krejci8df109d2021-04-23 12:19:08 +02001393 case LY_VALUE_XML:
Michal Vasko7ed1fcb2020-12-03 14:15:22 +01001394 return "XML prefixes";
Radek Krejci8df109d2021-04-23 12:19:08 +02001395 case LY_VALUE_JSON:
Michal Vasko7ed1fcb2020-12-03 14:15:22 +01001396 return "JSON module names";
Radek Krejcif9943642021-04-26 10:18:21 +02001397 case LY_VALUE_LYB:
1398 return "LYB prefixes";
Michal Vasko7ed1fcb2020-12-03 14:15:22 +01001399 default:
1400 break;
1401 }
1402
1403 return NULL;
1404}
Michal Vasko43297a02021-05-19 11:12:37 +02001405
Jan Kundrátc53a7ec2021-12-09 16:01:19 +01001406LIBYANG_API_DEF LY_ERR
Michal Vasko43297a02021-05-19 11:12:37 +02001407ly_time_str2time(const char *value, time_t *time, char **fractions_s)
1408{
1409 struct tm tm = {0};
1410 uint32_t i, frac_len;
1411 const char *frac;
1412 int64_t shift, shift_m;
1413 time_t t;
1414
1415 LY_CHECK_ARG_RET(NULL, value, time, LY_EINVAL);
1416
1417 tm.tm_year = atoi(&value[0]) - 1900;
1418 tm.tm_mon = atoi(&value[5]) - 1;
1419 tm.tm_mday = atoi(&value[8]);
1420 tm.tm_hour = atoi(&value[11]);
1421 tm.tm_min = atoi(&value[14]);
1422 tm.tm_sec = atoi(&value[17]);
1423
1424 t = timegm(&tm);
1425 i = 19;
1426
1427 /* fractions of a second */
1428 if (value[i] == '.') {
1429 ++i;
1430 frac = &value[i];
1431 for (frac_len = 0; isdigit(frac[frac_len]); ++frac_len) {}
1432
1433 i += frac_len;
Michal Vasko43297a02021-05-19 11:12:37 +02001434 } else {
1435 frac = NULL;
1436 }
1437
1438 /* apply offset */
1439 if ((value[i] == 'Z') || (value[i] == 'z')) {
1440 /* zero shift */
1441 shift = 0;
1442 } else {
1443 shift = strtol(&value[i], NULL, 10);
1444 shift = shift * 60 * 60; /* convert from hours to seconds */
1445 shift_m = strtol(&value[i + 4], NULL, 10) * 60; /* includes conversion from minutes to seconds */
1446 /* correct sign */
1447 if (shift < 0) {
1448 shift_m *= -1;
1449 }
1450 /* connect hours and minutes of the shift */
1451 shift = shift + shift_m;
1452 }
1453
1454 /* we have to shift to the opposite way to correct the time */
1455 t -= shift;
1456
1457 *time = t;
1458 if (fractions_s) {
1459 if (frac) {
1460 *fractions_s = strndup(frac, frac_len);
1461 LY_CHECK_RET(!*fractions_s, LY_EMEM);
1462 } else {
1463 *fractions_s = NULL;
1464 }
1465 }
1466 return LY_SUCCESS;
1467}
1468
Jan Kundrátc53a7ec2021-12-09 16:01:19 +01001469LIBYANG_API_DEF LY_ERR
Michal Vasko43297a02021-05-19 11:12:37 +02001470ly_time_time2str(time_t time, const char *fractions_s, char **str)
1471{
1472 struct tm tm;
Michal Vasko143ffa82021-05-20 11:11:39 +02001473 char zoneshift[8];
Michal Vasko43297a02021-05-19 11:12:37 +02001474 int32_t zonediff_h, zonediff_m;
1475
1476 LY_CHECK_ARG_RET(NULL, str, LY_EINVAL);
1477
1478 /* initialize the local timezone */
1479 tzset();
1480
Jan Kundrátb17efe92022-02-14 18:32:18 +01001481#ifdef HAVE_TM_GMTOFF
Michal Vasko43297a02021-05-19 11:12:37 +02001482 /* convert */
1483 if (!localtime_r(&time, &tm)) {
1484 return LY_ESYS;
1485 }
1486
1487 /* get timezone offset */
1488 if (tm.tm_gmtoff == 0) {
1489 /* time is Zulu (UTC) */
1490 zonediff_h = 0;
1491 zonediff_m = 0;
1492 } else {
1493 /* timezone offset */
1494 zonediff_h = tm.tm_gmtoff / 60 / 60;
1495 zonediff_m = tm.tm_gmtoff / 60 % 60;
1496 }
1497 sprintf(zoneshift, "%+03d:%02d", zonediff_h, zonediff_m);
Jan Kundráte182a272021-12-09 23:25:15 +01001498#else
Jan Kundrátb17efe92022-02-14 18:32:18 +01001499 /* convert */
1500 if (!gmtime_r(&time, &tm)) {
1501 return LY_ESYS;
1502 }
1503
Jan Kundráte182a272021-12-09 23:25:15 +01001504 (void)zonediff_h;
1505 (void)zonediff_m;
1506 sprintf(zoneshift, "-00:00");
1507#endif
Michal Vasko43297a02021-05-19 11:12:37 +02001508
1509 /* print */
1510 if (asprintf(str, "%04d-%02d-%02dT%02d:%02d:%02d%s%s%s",
1511 tm.tm_year + 1900, tm.tm_mon + 1, tm.tm_mday, tm.tm_hour, tm.tm_min, tm.tm_sec,
1512 fractions_s ? "." : "", fractions_s ? fractions_s : "", zoneshift) == -1) {
1513 return LY_EMEM;
1514 }
1515
1516 return LY_SUCCESS;
1517}
1518
Jan Kundrátc53a7ec2021-12-09 16:01:19 +01001519LIBYANG_API_DEF LY_ERR
Michal Vasko43297a02021-05-19 11:12:37 +02001520ly_time_str2ts(const char *value, struct timespec *ts)
1521{
1522 LY_ERR rc;
Michal Vasko72975062021-08-25 08:13:04 +02001523 char *fractions_s, frac_buf[10];
Michal Vasko43297a02021-05-19 11:12:37 +02001524 int frac_len;
1525
1526 LY_CHECK_ARG_RET(NULL, value, ts, LY_EINVAL);
1527
1528 rc = ly_time_str2time(value, &ts->tv_sec, &fractions_s);
1529 LY_CHECK_RET(rc);
1530
1531 /* convert fractions of a second to nanoseconds */
1532 if (fractions_s) {
Michal Vasko72975062021-08-25 08:13:04 +02001533 /* init frac_buf with zeroes */
1534 memset(frac_buf, '0', 9);
1535 frac_buf[9] = '\0';
1536
Michal Vasko43297a02021-05-19 11:12:37 +02001537 frac_len = strlen(fractions_s);
1538 memcpy(frac_buf, fractions_s, frac_len > 9 ? 9 : frac_len);
1539 ts->tv_nsec = atol(frac_buf);
1540 free(fractions_s);
1541 } else {
1542 ts->tv_nsec = 0;
1543 }
1544
1545 return LY_SUCCESS;
1546}
1547
Jan Kundrátc53a7ec2021-12-09 16:01:19 +01001548LIBYANG_API_DEF LY_ERR
Michal Vasko43297a02021-05-19 11:12:37 +02001549ly_time_ts2str(const struct timespec *ts, char **str)
1550{
1551 char frac_buf[10];
1552
Jan Kundrátbd157002021-08-30 14:02:22 +02001553 LY_CHECK_ARG_RET(NULL, ts, str, ((ts->tv_nsec <= 999999999) && (ts->tv_nsec >= 0)), LY_EINVAL);
Michal Vasko43297a02021-05-19 11:12:37 +02001554
1555 /* convert nanoseconds to fractions of a second */
1556 if (ts->tv_nsec) {
1557 sprintf(frac_buf, "%09ld", ts->tv_nsec);
1558 }
1559
1560 return ly_time_time2str(ts->tv_sec, ts->tv_nsec ? frac_buf : NULL, str);
1561}