blob: 8d1de064b1733ebffecad031bbdb66a35e60e6f7 [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/**
Michal Vasko271d2e32023-01-31 15:43:19 +010047 * @brief Callback for checking first instance hash table values equivalence.
48 *
49 * @param[in] val1_p If not @p mod, pointer to the first instance.
50 * @param[in] val2_p If not @p mod, pointer to the found dup inst item.
51 */
52static ly_bool
53lyht_dup_inst_ht_equal_cb(void *val1_p, void *val2_p, ly_bool mod, void *UNUSED(cb_data))
54{
55 if (mod) {
56 struct lyd_dup_inst **item1 = val1_p, **item2 = val2_p;
57
58 /* equal on 2 dup inst items */
59 return *item1 == *item2 ? 1 : 0;
60 } else {
61 struct lyd_node **first_inst = val1_p;
62 struct lyd_dup_inst **item = val2_p;
63
64 /* equal on dup inst item and a first instance */
65 return (*item)->set->dnodes[0] == *first_inst ? 1 : 0;
66 }
67}
68
69/**
Michal Vaskod7c048c2021-05-18 16:12:55 +020070 * @brief Find an entry in duplicate instance cache for an instance. Create it if it does not exist.
71 *
Michal Vasko271d2e32023-01-31 15:43:19 +010072 * @param[in] first_inst First instance of the cache entry.
73 * @param[in] dup_inst_ht Duplicate instance cache hash table.
Michal Vaskod7c048c2021-05-18 16:12:55 +020074 * @return Instance cache entry.
75 */
76static struct lyd_dup_inst *
Michal Vasko8efac242023-03-30 08:24:56 +020077lyd_dup_inst_get(const struct lyd_node *first_inst, struct ly_ht **dup_inst_ht)
Michal Vaskod7c048c2021-05-18 16:12:55 +020078{
Michal Vasko271d2e32023-01-31 15:43:19 +010079 struct lyd_dup_inst **item_p, *item;
Michal Vaskod7c048c2021-05-18 16:12:55 +020080
Michal Vasko271d2e32023-01-31 15:43:19 +010081 if (*dup_inst_ht) {
82 /* find the item of the first instance */
83 if (!lyht_find(*dup_inst_ht, &first_inst, first_inst->hash, (void **)&item_p)) {
84 return *item_p;
Michal Vaskod7c048c2021-05-18 16:12:55 +020085 }
Michal Vasko271d2e32023-01-31 15:43:19 +010086 } else {
87 /* create the hash table */
88 *dup_inst_ht = lyht_new(2, sizeof item, lyht_dup_inst_ht_equal_cb, NULL, 1);
89 LY_CHECK_RET(!*dup_inst_ht, NULL);
Michal Vaskod7c048c2021-05-18 16:12:55 +020090 }
91
Michal Vasko271d2e32023-01-31 15:43:19 +010092 /* first instance has no dup inst item, create it */
93 item = calloc(1, sizeof *item);
94 LY_CHECK_RET(!item, NULL);
95
96 /* add into the hash table */
97 if (lyht_insert(*dup_inst_ht, &item, first_inst->hash, NULL)) {
98 return NULL;
99 }
Michal Vaskod7c048c2021-05-18 16:12:55 +0200100
101 return item;
102}
103
104LY_ERR
Michal Vasko8efac242023-03-30 08:24:56 +0200105lyd_dup_inst_next(struct lyd_node **inst, const struct lyd_node *siblings, struct ly_ht **dup_inst_ht)
Michal Vaskod7c048c2021-05-18 16:12:55 +0200106{
107 struct lyd_dup_inst *dup_inst;
108
Michal Vasko83ae7772022-06-08 10:01:55 +0200109 if (!*inst) {
110 /* no match, inst is unchanged */
Michal Vaskod7c048c2021-05-18 16:12:55 +0200111 return LY_SUCCESS;
112 }
113
Michal Vasko83ae7772022-06-08 10:01:55 +0200114 /* there can be more exact same instances (even if not allowed in invalid data) and we must make sure we do not
115 * match a single node more times */
Michal Vasko271d2e32023-01-31 15:43:19 +0100116 dup_inst = lyd_dup_inst_get(*inst, dup_inst_ht);
Michal Vaskod7c048c2021-05-18 16:12:55 +0200117 LY_CHECK_ERR_RET(!dup_inst, LOGMEM(LYD_CTX(siblings)), LY_EMEM);
118
119 if (!dup_inst->used) {
120 /* we did not cache these instances yet, do so */
Michal Vasko271d2e32023-01-31 15:43:19 +0100121 lyd_find_sibling_dup_inst_set(siblings, *inst, &dup_inst->set);
122 assert(dup_inst->set->count && (dup_inst->set->dnodes[0] == *inst));
Michal Vaskod7c048c2021-05-18 16:12:55 +0200123 }
124
Michal Vasko271d2e32023-01-31 15:43:19 +0100125 if (dup_inst->used == dup_inst->set->count) {
Michal Vasko4525e1f2022-07-13 16:20:59 +0200126 if (lysc_is_dup_inst_list((*inst)->schema)) {
127 /* we have used all the instances */
128 *inst = NULL;
129 } /* else just keep using the last (ideally only) instance */
Michal Vaskod7c048c2021-05-18 16:12:55 +0200130 } else {
Michal Vasko271d2e32023-01-31 15:43:19 +0100131 assert(dup_inst->used < dup_inst->set->count);
Michal Vaskod7c048c2021-05-18 16:12:55 +0200132
133 /* use another instance */
Michal Vasko271d2e32023-01-31 15:43:19 +0100134 *inst = dup_inst->set->dnodes[dup_inst->used];
Michal Vaskod7c048c2021-05-18 16:12:55 +0200135 ++dup_inst->used;
136 }
137
138 return LY_SUCCESS;
139}
140
Michal Vasko271d2e32023-01-31 15:43:19 +0100141/**
142 * @brief Callback for freeing first instance hash table values.
143 */
144static void
145lyht_dup_inst_ht_free_cb(void *val_p)
Michal Vaskod7c048c2021-05-18 16:12:55 +0200146{
Michal Vasko271d2e32023-01-31 15:43:19 +0100147 struct lyd_dup_inst **item = val_p;
Michal Vaskod7c048c2021-05-18 16:12:55 +0200148
Michal Vasko271d2e32023-01-31 15:43:19 +0100149 ly_set_free((*item)->set, NULL);
150 free(*item);
151}
152
153void
Michal Vasko8efac242023-03-30 08:24:56 +0200154lyd_dup_inst_free(struct ly_ht *dup_inst_ht)
Michal Vasko271d2e32023-01-31 15:43:19 +0100155{
156 lyht_free(dup_inst_ht, lyht_dup_inst_ht_free_cb);
Michal Vaskod7c048c2021-05-18 16:12:55 +0200157}
158
Michal Vaskoa6669ba2020-08-06 16:14:26 +0200159struct lyd_node *
160lys_getnext_data(const struct lyd_node *last, const struct lyd_node *sibling, const struct lysc_node **slast,
Radek Krejci0f969882020-08-21 16:56:47 +0200161 const struct lysc_node *parent, const struct lysc_module *module)
Michal Vaskoa6669ba2020-08-06 16:14:26 +0200162{
163 const struct lysc_node *siter = NULL;
164 struct lyd_node *match = NULL;
165
166 assert(parent || module);
167 assert(!last || (slast && *slast));
168
169 if (slast) {
170 siter = *slast;
171 }
172
173 if (last && last->next && (last->next->schema == siter)) {
174 /* return next data instance */
175 return last->next;
176 }
177
178 /* find next schema node data instance */
179 while ((siter = lys_getnext(siter, parent, module, 0))) {
180 if (!lyd_find_sibling_val(sibling, siter, NULL, 0, &match)) {
181 break;
182 }
183 }
184
185 if (slast) {
186 *slast = siter;
187 }
188 return match;
189}
190
Radek Krejcie7b95092019-05-15 11:03:07 +0200191struct lyd_node **
Michal Vaskoe0665742021-02-11 11:08:44 +0100192lyd_node_child_p(struct lyd_node *node)
Radek Krejcie7b95092019-05-15 11:03:07 +0200193{
194 assert(node);
Michal Vasko52927e22020-03-16 17:26:14 +0100195
196 if (!node->schema) {
197 return &((struct lyd_node_opaq *)node)->child;
198 } else {
199 switch (node->schema->nodetype) {
200 case LYS_CONTAINER:
201 case LYS_LIST:
Michal Vasko1bf09392020-03-27 12:38:10 +0100202 case LYS_RPC:
Michal Vasko52927e22020-03-16 17:26:14 +0100203 case LYS_ACTION:
204 case LYS_NOTIF:
205 return &((struct lyd_node_inner *)node)->child;
206 default:
207 return NULL;
208 }
Radek Krejcie7b95092019-05-15 11:03:07 +0200209 }
210}
211
Jan Kundrátc53a7ec2021-12-09 16:01:19 +0100212LIBYANG_API_DEF LY_ERR
aPiecekdf23eee2021-10-07 12:21:50 +0200213lyxp_vars_set(struct lyxp_var **vars, const char *name, const char *value)
214{
215 LY_ERR ret = LY_SUCCESS;
216 char *var_name = NULL, *var_value = NULL;
217 struct lyxp_var *item;
218
219 if (!vars || !name || !value) {
220 return LY_EINVAL;
221 }
222
Michal Vasko90189962023-02-28 12:10:34 +0100223 /* if variable is already defined then change its value */
224 if (*vars && !lyxp_vars_find(NULL, *vars, name, 0, &item)) {
aPiecekdf23eee2021-10-07 12:21:50 +0200225 var_value = strdup(value);
226 LY_CHECK_RET(!var_value, LY_EMEM);
227
Michal Vasko90189962023-02-28 12:10:34 +0100228 /* update value */
aPiecekdf23eee2021-10-07 12:21:50 +0200229 free(item->value);
230 item->value = var_value;
231 } else {
232 var_name = strdup(name);
233 var_value = strdup(value);
234 LY_CHECK_ERR_GOTO(!var_name || !var_value, ret = LY_EMEM, error);
235
Michal Vasko90189962023-02-28 12:10:34 +0100236 /* add new variable */
aPiecekdf23eee2021-10-07 12:21:50 +0200237 LY_ARRAY_NEW_GOTO(NULL, *vars, item, ret, error);
238 item->name = var_name;
239 item->value = var_value;
240 }
241
242 return LY_SUCCESS;
243
244error:
245 free(var_name);
246 free(var_value);
247 return ret;
248}
249
Jan Kundrátc53a7ec2021-12-09 16:01:19 +0100250LIBYANG_API_DEF void
aPiecekdf23eee2021-10-07 12:21:50 +0200251lyxp_vars_free(struct lyxp_var *vars)
252{
253 LY_ARRAY_COUNT_TYPE u;
254
255 if (!vars) {
256 return;
257 }
258
259 LY_ARRAY_FOR(vars, u) {
260 free(vars[u].name);
261 free(vars[u].value);
262 }
263
264 LY_ARRAY_FREE(vars);
265}
266
Jan Kundrátc53a7ec2021-12-09 16:01:19 +0100267LIBYANG_API_DEF struct lyd_node *
Radek Krejcia1c1e542020-09-29 16:06:52 +0200268lyd_child_no_keys(const struct lyd_node *node)
269{
270 struct lyd_node **children;
271
272 if (!node) {
273 return NULL;
274 }
275
276 if (!node->schema) {
277 /* opaq node */
Michal Vasko9e685082021-01-29 14:49:09 +0100278 return ((struct lyd_node_opaq *)node)->child;
Radek Krejcia1c1e542020-09-29 16:06:52 +0200279 }
280
Michal Vaskoe0665742021-02-11 11:08:44 +0100281 children = lyd_node_child_p((struct lyd_node *)node);
Radek Krejcia1c1e542020-09-29 16:06:52 +0200282 if (children) {
283 struct lyd_node *child = *children;
Michal Vasko26bbb272022-08-02 14:54:33 +0200284
Radek Krejcia1c1e542020-09-29 16:06:52 +0200285 while (child && child->schema && (child->schema->flags & LYS_KEY)) {
286 child = child->next;
Michal Vasko5bfd4be2020-06-23 13:26:19 +0200287 }
288 return child;
Radek Krejcie7b95092019-05-15 11:03:07 +0200289 } else {
290 return NULL;
291 }
292}
Michal Vasko9b368d32020-02-14 13:53:31 +0100293
Jan Kundrátc53a7ec2021-12-09 16:01:19 +0100294LIBYANG_API_DEF const struct lys_module *
Michal Vaskoc193ce92020-03-06 11:04:48 +0100295lyd_owner_module(const struct lyd_node *node)
Michal Vasko9b368d32020-02-14 13:53:31 +0100296{
Michal Vaskod5cfa6e2020-11-23 16:56:08 +0100297 const struct lyd_node_opaq *opaq;
Michal Vasko9b368d32020-02-14 13:53:31 +0100298
Michal Vaskod5cfa6e2020-11-23 16:56:08 +0100299 if (!node) {
Michal Vaskoc193ce92020-03-06 11:04:48 +0100300 return NULL;
301 }
Michal Vasko9b368d32020-02-14 13:53:31 +0100302
Michal Vaskod5cfa6e2020-11-23 16:56:08 +0100303 if (!node->schema) {
304 opaq = (struct lyd_node_opaq *)node;
305 switch (opaq->format) {
Radek Krejci8df109d2021-04-23 12:19:08 +0200306 case LY_VALUE_XML:
Michal Vasko09fbb812023-04-13 14:11:06 +0200307 if (opaq->name.module_ns) {
308 return ly_ctx_get_module_implemented_ns(LYD_CTX(node), opaq->name.module_ns);
309 }
310 break;
Radek Krejci8df109d2021-04-23 12:19:08 +0200311 case LY_VALUE_JSON:
Michal Vasko09fbb812023-04-13 14:11:06 +0200312 if (opaq->name.module_name) {
313 return ly_ctx_get_module_implemented(LYD_CTX(node), opaq->name.module_name);
314 }
315 break;
Michal Vaskod5cfa6e2020-11-23 16:56:08 +0100316 default:
317 return NULL;
318 }
Michal Vasko09fbb812023-04-13 14:11:06 +0200319
320 /* try a parent */
321 return lyd_owner_module(lyd_parent(node));
Michal Vaskod5cfa6e2020-11-23 16:56:08 +0100322 }
323
Michal Vaskoef53c812021-10-13 10:21:03 +0200324 return lysc_owner_module(node->schema);
Michal Vasko9b368d32020-02-14 13:53:31 +0100325}
Michal Vaskob1b5c262020-03-05 14:29:47 +0100326
Michal Vasko598063b2021-07-19 11:39:05 +0200327void
328lyd_first_module_sibling(struct lyd_node **node, const struct lys_module *mod)
329{
330 int cmp;
331 struct lyd_node *first;
Michal Vaskoec139eb2022-05-10 10:08:40 +0200332 const struct lys_module *own_mod;
Michal Vasko598063b2021-07-19 11:39:05 +0200333
334 assert(node && mod);
335
336 if (!*node) {
337 return;
338 }
339
340 first = *node;
Michal Vaskoec139eb2022-05-10 10:08:40 +0200341 own_mod = lyd_owner_module(first);
342 cmp = own_mod ? strcmp(own_mod->name, mod->name) : 1;
Michal Vasko598063b2021-07-19 11:39:05 +0200343 if (cmp > 0) {
344 /* there may be some preceding data */
345 while (first->prev->next) {
346 first = first->prev;
347 if (lyd_owner_module(first) == mod) {
348 cmp = 0;
349 break;
350 }
351 }
352 }
353
354 if (cmp == 0) {
355 /* there may be some preceding data belonging to this module */
356 while (first->prev->next) {
357 if (lyd_owner_module(first->prev) != mod) {
358 break;
359 }
360 first = first->prev;
361 }
362 }
363
364 if (cmp < 0) {
365 /* there may be some following data */
366 LY_LIST_FOR(first, first) {
367 if (lyd_owner_module(first) == mod) {
368 cmp = 0;
369 break;
370 }
371 }
372 }
373
374 if (cmp == 0) {
375 /* we have found the first module data node */
376 *node = first;
377 }
378}
379
Michal Vaskob1b5c262020-03-05 14:29:47 +0100380const struct lys_module *
Michal Vasko26e80012020-07-08 10:55:46 +0200381lyd_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 +0200382 struct lyd_node **first)
Michal Vaskob1b5c262020-03-05 14:29:47 +0100383{
384 struct lyd_node *iter;
385 const struct lys_module *mod;
386
387 /* get the next module */
Michal Vasko26e80012020-07-08 10:55:46 +0200388 if (module) {
389 if (*i) {
Michal Vaskob1b5c262020-03-05 14:29:47 +0100390 mod = NULL;
Michal Vasko26e80012020-07-08 10:55:46 +0200391 } else {
392 mod = module;
393 ++(*i);
Michal Vaskob1b5c262020-03-05 14:29:47 +0100394 }
395 } else {
396 do {
397 mod = ly_ctx_get_module_iter(ctx, i);
398 } while (mod && !mod->implemented);
399 }
400
401 /* find its data */
402 *first = NULL;
403 if (mod) {
404 LY_LIST_FOR(tree, iter) {
Michal Vaskoc193ce92020-03-06 11:04:48 +0100405 if (lyd_owner_module(iter) == mod) {
Michal Vaskob1b5c262020-03-05 14:29:47 +0100406 *first = iter;
407 break;
408 }
409 }
410 }
411
412 return mod;
413}
414
415const struct lys_module *
416lyd_data_next_module(struct lyd_node **next, struct lyd_node **first)
417{
418 const struct lys_module *mod;
419
420 if (!*next) {
421 /* all data traversed */
422 *first = NULL;
423 return NULL;
424 }
425
426 *first = *next;
427
428 /* prepare next */
Michal Vaskoc193ce92020-03-06 11:04:48 +0100429 mod = lyd_owner_module(*next);
Michal Vaskob1b5c262020-03-05 14:29:47 +0100430 LY_LIST_FOR(*next, *next) {
Michal Vaskoc193ce92020-03-06 11:04:48 +0100431 if (lyd_owner_module(*next) != mod) {
Michal Vaskob1b5c262020-03-05 14:29:47 +0100432 break;
433 }
434 }
435
436 return mod;
437}
Michal Vasko9f96a052020-03-10 09:41:45 +0100438
439LY_ERR
Michal Vasko59892dd2022-05-13 11:02:30 +0200440lyd_value_store(const struct ly_ctx *ctx, struct lyd_value *val, const struct lysc_type *type, const void *value,
441 size_t value_len, ly_bool *dynamic, LY_VALUE_FORMAT format, void *prefix_data, uint32_t hints,
442 const struct lysc_node *ctx_node, ly_bool *incomplete)
443{
444 LY_ERR ret;
445 struct ly_err_item *err = NULL;
446 uint32_t options = (dynamic && *dynamic ? LYPLG_TYPE_STORE_DYNAMIC : 0);
447
448 if (!value) {
449 value = "";
450 }
451 if (incomplete) {
452 *incomplete = 0;
453 }
454
455 ret = type->plugin->store(ctx, type, value, value_len, options, format, prefix_data, hints, ctx_node, val, NULL, &err);
456 if (dynamic) {
457 *dynamic = 0;
458 }
459
460 if (ret == LY_EINCOMPLETE) {
461 if (incomplete) {
462 *incomplete = 1;
463 }
464 } else if (ret) {
465 if (err) {
466 LOGVAL_ERRITEM(ctx, err);
467 ly_err_free(err);
468 } else {
469 LOGVAL(ctx, LYVE_OTHER, "Storing value failed.");
470 }
471 return ret;
472 }
473
474 return LY_SUCCESS;
475}
476
477LY_ERR
478lyd_value_validate_incomplete(const struct ly_ctx *ctx, const struct lysc_type *type, struct lyd_value *val,
479 const struct lyd_node *ctx_node, const struct lyd_node *tree)
480{
481 LY_ERR ret;
482 struct ly_err_item *err = NULL;
483
484 assert(type->plugin->validate);
485
486 ret = type->plugin->validate(ctx, type, ctx_node, tree, val, &err);
487 if (ret) {
488 if (err) {
489 LOGVAL_ERRITEM(ctx, err);
490 ly_err_free(err);
491 } else {
492 LOGVAL(ctx, LYVE_OTHER, "Resolving value \"%s\" failed.", type->plugin->print(ctx, val, LY_VALUE_CANON,
493 NULL, NULL, NULL));
494 }
495 return ret;
496 }
497
498 return LY_SUCCESS;
499}
500
501LY_ERR
Michal Vasko583b4642023-05-25 10:39:34 +0200502ly_value_validate(const struct ly_ctx *ctx, const struct lysc_node *node, const char *value, size_t value_len,
503 LY_VALUE_FORMAT format, void *prefix_data, uint32_t hints)
Michal Vasko59892dd2022-05-13 11:02:30 +0200504{
505 LY_ERR rc = LY_SUCCESS;
506 struct ly_err_item *err = NULL;
507 struct lyd_value storage;
508 struct lysc_type *type;
509
Michal Vasko0c361552023-04-04 10:04:03 +0200510 LY_CHECK_ARG_RET(ctx, node, LY_EINVAL);
Michal Vasko59892dd2022-05-13 11:02:30 +0200511
512 if (!(node->nodetype & (LYS_LEAF | LYS_LEAFLIST))) {
513 LOGARG(ctx, node);
514 return LY_EINVAL;
515 }
516
517 type = ((struct lysc_node_leaf *)node)->type;
Michal Vasko583b4642023-05-25 10:39:34 +0200518 rc = type->plugin->store(ctx ? ctx : node->module->ctx, type, value, value_len, 0, format, prefix_data, hints, node,
519 &storage, NULL, &err);
Michal Vasko59892dd2022-05-13 11:02:30 +0200520 if (rc == LY_EINCOMPLETE) {
521 /* actually success since we do not provide the context tree and call validation with
522 * LY_TYPE_OPTS_INCOMPLETE_DATA */
523 rc = LY_SUCCESS;
524 } else if (rc && err) {
525 if (ctx) {
526 /* log only in case the ctx was provided as input parameter */
Michal Vaskof8da2682022-06-16 07:52:37 +0200527 if (err->path) {
528 LOG_LOCSET(NULL, NULL, err->path, NULL);
Michal Vaskof8da2682022-06-16 07:52:37 +0200529 }
Michal Vasko59892dd2022-05-13 11:02:30 +0200530 LOGVAL_ERRITEM(ctx, err);
Michal Vaskof8da2682022-06-16 07:52:37 +0200531 if (err->path) {
532 LOG_LOCBACK(0, 0, 1, 0);
Michal Vaskof8da2682022-06-16 07:52:37 +0200533 }
Michal Vasko59892dd2022-05-13 11:02:30 +0200534 }
535 ly_err_free(err);
536 }
537
538 if (!rc) {
539 type->plugin->free(ctx ? ctx : node->module->ctx, &storage);
540 }
541 return rc;
542}
543
544LIBYANG_API_DEF LY_ERR
545lyd_value_validate(const struct ly_ctx *ctx, const struct lysc_node *schema, const char *value, size_t value_len,
546 const struct lyd_node *ctx_node, const struct lysc_type **realtype, const char **canonical)
547{
548 LY_ERR rc;
549 struct ly_err_item *err = NULL;
550 struct lysc_type *type;
551 struct lyd_value val = {0};
552 ly_bool stored = 0, log = 1;
553
Michal Vasko3dd16da2022-06-15 07:58:41 +0200554 LY_CHECK_ARG_RET(ctx, schema, !value_len || value, LY_EINVAL);
Michal Vasko59892dd2022-05-13 11:02:30 +0200555
556 if (!ctx) {
557 ctx = schema->module->ctx;
558 log = 0;
559 }
Michal Vasko3dd16da2022-06-15 07:58:41 +0200560 if (!value_len) {
561 value = "";
562 }
Michal Vasko59892dd2022-05-13 11:02:30 +0200563 type = ((struct lysc_node_leaf *)schema)->type;
564
565 /* store */
566 rc = type->plugin->store(ctx, type, value, value_len, 0, LY_VALUE_JSON, NULL,
567 LYD_HINT_DATA, schema, &val, NULL, &err);
568 if (!rc || (rc == LY_EINCOMPLETE)) {
569 stored = 1;
570 }
571
572 if (ctx_node && (rc == LY_EINCOMPLETE)) {
573 /* resolve */
574 rc = type->plugin->validate(ctx, type, ctx_node, ctx_node, &val, &err);
575 }
576
577 if (rc && (rc != LY_EINCOMPLETE) && err) {
578 if (log) {
579 /* log error */
580 if (err->path) {
581 LOG_LOCSET(NULL, NULL, err->path, NULL);
582 } else if (ctx_node) {
583 LOG_LOCSET(NULL, ctx_node, NULL, NULL);
584 } else {
585 LOG_LOCSET(schema, NULL, NULL, NULL);
586 }
587 LOGVAL_ERRITEM(ctx, err);
588 if (err->path) {
589 LOG_LOCBACK(0, 0, 1, 0);
590 } else if (ctx_node) {
591 LOG_LOCBACK(0, 1, 0, 0);
592 } else {
593 LOG_LOCBACK(1, 0, 0, 0);
594 }
595 }
596 ly_err_free(err);
597 }
598
599 if (!rc || (rc == LY_EINCOMPLETE)) {
600 if (realtype) {
601 /* return realtype */
602 if (val.realtype->basetype == LY_TYPE_UNION) {
603 *realtype = val.subvalue->value.realtype;
604 } else {
605 *realtype = val.realtype;
606 }
607 }
608
609 if (canonical) {
610 /* return canonical value */
611 lydict_insert(ctx, val.realtype->plugin->print(ctx, &val, LY_VALUE_CANON, NULL, NULL, NULL), 0, canonical);
612 }
613 }
614
615 if (stored) {
616 /* free value */
617 type->plugin->free(ctx ? ctx : schema->module->ctx, &val);
618 }
619 return rc;
620}
621
622LIBYANG_API_DEF LY_ERR
623lyd_value_compare(const struct lyd_node_term *node, const char *value, size_t value_len)
624{
625 LY_ERR ret = LY_SUCCESS;
626 struct ly_ctx *ctx;
627 struct lysc_type *type;
628 struct lyd_value val = {0};
629
630 LY_CHECK_ARG_RET(node ? node->schema->module->ctx : NULL, node, value, LY_EINVAL);
631
632 ctx = node->schema->module->ctx;
633 type = ((struct lysc_node_leaf *)node->schema)->type;
634
635 /* store the value */
636 LOG_LOCSET(node->schema, &node->node, NULL, NULL);
637 ret = lyd_value_store(ctx, &val, type, value, value_len, NULL, LY_VALUE_JSON, NULL, LYD_HINT_DATA, node->schema, NULL);
638 LOG_LOCBACK(1, 1, 0, 0);
639 LY_CHECK_RET(ret);
640
641 /* compare values */
642 ret = type->plugin->compare(&node->value, &val);
643
644 type->plugin->free(ctx, &val);
645 return ret;
646}
647
648LIBYANG_API_DEF ly_bool
649lyd_is_default(const struct lyd_node *node)
650{
651 const struct lysc_node_leaf *leaf;
652 const struct lysc_node_leaflist *llist;
653 const struct lyd_node_term *term;
654 LY_ARRAY_COUNT_TYPE u;
655
656 if (!(node->schema->nodetype & LYD_NODE_TERM)) {
657 return 0;
658 }
659
660 term = (const struct lyd_node_term *)node;
661
662 if (node->schema->nodetype == LYS_LEAF) {
663 leaf = (const struct lysc_node_leaf *)node->schema;
664 if (!leaf->dflt) {
665 return 0;
666 }
667
668 /* compare with the default value */
669 if (!leaf->type->plugin->compare(&term->value, leaf->dflt)) {
670 return 1;
671 }
672 } else {
673 llist = (const struct lysc_node_leaflist *)node->schema;
674 if (!llist->dflts) {
675 return 0;
676 }
677
678 LY_ARRAY_FOR(llist->dflts, u) {
679 /* compare with each possible default value */
680 if (!llist->type->plugin->compare(&term->value, llist->dflts[u])) {
681 return 1;
682 }
683 }
684 }
685
686 return 0;
687}
688
689LIBYANG_API_DEF uint32_t
690lyd_list_pos(const struct lyd_node *instance)
691{
692 const struct lyd_node *iter = NULL;
693 uint32_t pos = 0;
694
695 if (!instance || !(instance->schema->nodetype & (LYS_LIST | LYS_LEAFLIST))) {
696 return 0;
697 }
698
699 /* data instances are ordered, so we can stop when we found instance of other schema node */
700 for (iter = instance; iter->schema == instance->schema; iter = iter->prev) {
701 if (pos && (iter->next == NULL)) {
702 /* overrun to the end of the siblings list */
703 break;
704 }
705 ++pos;
706 }
707
708 return pos;
709}
710
711LIBYANG_API_DEF struct lyd_node *
712lyd_first_sibling(const struct lyd_node *node)
713{
714 struct lyd_node *start;
715
716 if (!node) {
717 return NULL;
718 }
719
720 /* get the first sibling */
721 if (node->parent) {
722 start = node->parent->child;
723 } else {
724 for (start = (struct lyd_node *)node; start->prev->next; start = start->prev) {}
725 }
726
727 return start;
728}
729
Michal Vaskobfff6ac2022-02-23 16:22:53 +0100730/**
731 * @brief Check list node parsed into an opaque node for the reason.
732 *
733 * @param[in] node Opaque node.
734 * @param[in] snode Schema node of @p opaq.
735 * @return LY_SUCCESS if the node is valid;
736 * @return LY_ERR on error.
737 */
738static LY_ERR
739lyd_parse_opaq_list_error(const struct lyd_node *node, const struct lysc_node *snode)
740{
741 LY_ERR ret = LY_SUCCESS;
742 struct ly_set key_set = {0};
743 const struct lysc_node *key = NULL;
744 const struct lyd_node *child;
745 const struct lyd_node_opaq *opaq_k;
746 uint32_t i;
747
748 assert(!node->schema);
749
750 /* get all keys into a set */
Michal Vaskof30bcf12023-07-14 12:12:03 +0200751 while ((key = lys_getnext(key, snode, NULL, 0)) && (key->flags & LYS_KEY)) {
752 LY_CHECK_GOTO(ret = ly_set_add(&key_set, (void *)key, 1, NULL), cleanup);
Michal Vaskobfff6ac2022-02-23 16:22:53 +0100753 }
754
755 LY_LIST_FOR(lyd_child(node), child) {
756 if (child->schema) {
757 LOGERR(LYD_CTX(node), LY_EINVAL, "Unexpected node %s \"%s\".", lys_nodetype2str(child->schema->nodetype),
758 LYD_NAME(child));
759 ret = LY_EINVAL;
760 goto cleanup;
761 }
762
763 opaq_k = (struct lyd_node_opaq *)child;
764
765 /* find the key schema node */
766 for (i = 0; i < key_set.count; ++i) {
767 key = key_set.snodes[i];
768 if (!strcmp(key->name, opaq_k->name.name)) {
769 break;
770 }
771 }
772 if (i == key_set.count) {
773 /* some other node, skip */
774 continue;
775 }
776
777 /* key found */
778 ly_set_rm_index(&key_set, i, NULL);
779
780 /* check value */
Michal Vasko583b4642023-05-25 10:39:34 +0200781 ret = ly_value_validate(LYD_CTX(node), key, opaq_k->value, strlen(opaq_k->value), opaq_k->format,
782 opaq_k->val_prefix_data, opaq_k->hints);
Michal Vaskobfff6ac2022-02-23 16:22:53 +0100783 LY_CHECK_GOTO(ret, cleanup);
784 }
785
786 if (key_set.count) {
787 /* missing keys */
788 LOGVAL(LYD_CTX(node), LY_VCODE_NOKEY, key_set.snodes[0]->name);
789 ret = LY_EVALID;
790 goto cleanup;
791 }
792
793cleanup:
794 ly_set_erase(&key_set, NULL);
795 return ret;
796}
797
798LIBYANG_API_DEF LY_ERR
799lyd_parse_opaq_error(const struct lyd_node *node)
800{
Michal Vasko6727c682023-02-17 10:40:26 +0100801 LY_ERR rc = LY_SUCCESS;
Michal Vaskobfff6ac2022-02-23 16:22:53 +0100802 const struct ly_ctx *ctx;
803 const struct lyd_node_opaq *opaq;
804 const struct lyd_node *parent;
805 const struct lys_module *mod;
806 const struct lysc_node *snode;
Michal Vasko6727c682023-02-17 10:40:26 +0100807 uint32_t loc_node = 0, loc_path = 0;
Michal Vaskobfff6ac2022-02-23 16:22:53 +0100808
809 LY_CHECK_ARG_RET(LYD_CTX(node), node, !node->schema, !lyd_parent(node) || lyd_parent(node)->schema, LY_EINVAL);
810
811 ctx = LYD_CTX(node);
812 opaq = (struct lyd_node_opaq *)node;
813 parent = lyd_parent(node);
814
Michal Vasko6727c682023-02-17 10:40:26 +0100815 if (lyd_parent(node)) {
816 LOG_LOCSET(NULL, lyd_parent(node), NULL, NULL);
817 ++loc_node;
818 } else {
819 LOG_LOCSET(NULL, NULL, "/", NULL);
820 ++loc_path;
821 }
822
Michal Vaskof4e63922022-05-10 10:32:13 +0200823 if (!opaq->name.module_ns) {
824 LOGVAL(ctx, LYVE_REFERENCE, "Unknown module of node \"%s\".", opaq->name.name);
Michal Vasko6727c682023-02-17 10:40:26 +0100825 rc = LY_EVALID;
826 goto cleanup;
Michal Vaskof4e63922022-05-10 10:32:13 +0200827 }
Michal Vaskobfff6ac2022-02-23 16:22:53 +0100828
829 /* module */
830 switch (opaq->format) {
831 case LY_VALUE_XML:
832 if (!parent || strcmp(opaq->name.module_ns, parent->schema->module->ns)) {
833 mod = ly_ctx_get_module_implemented_ns(ctx, opaq->name.module_ns);
834 if (!mod) {
Michal Vasko959f8d82022-06-16 07:51:50 +0200835 LOGVAL(ctx, LYVE_REFERENCE, "No (implemented) module with namespace \"%s\" of node \"%s\" in the context.",
836 opaq->name.module_ns, opaq->name.name);
Michal Vasko6727c682023-02-17 10:40:26 +0100837 rc = LY_EVALID;
838 goto cleanup;
Michal Vaskobfff6ac2022-02-23 16:22:53 +0100839 }
840 } else {
841 /* inherit */
842 mod = parent->schema->module;
843 }
844 break;
845 case LY_VALUE_JSON:
846 case LY_VALUE_LYB:
847 if (!parent || strcmp(opaq->name.module_name, parent->schema->module->name)) {
848 mod = ly_ctx_get_module_implemented(ctx, opaq->name.module_name);
849 if (!mod) {
Michal Vasko959f8d82022-06-16 07:51:50 +0200850 LOGVAL(ctx, LYVE_REFERENCE, "No (implemented) module named \"%s\" of node \"%s\" in the context.",
851 opaq->name.module_name, opaq->name.name);
Michal Vasko6727c682023-02-17 10:40:26 +0100852 rc = LY_EVALID;
853 goto cleanup;
Michal Vaskobfff6ac2022-02-23 16:22:53 +0100854 }
855 } else {
856 /* inherit */
857 mod = parent->schema->module;
858 }
859 break;
860 default:
861 LOGERR(ctx, LY_EINVAL, "Unsupported value format.");
Michal Vasko6727c682023-02-17 10:40:26 +0100862 rc = LY_EINVAL;
863 goto cleanup;
Michal Vaskobfff6ac2022-02-23 16:22:53 +0100864 }
865
866 /* schema */
867 snode = lys_find_child(parent ? parent->schema : NULL, mod, opaq->name.name, 0, 0, 0);
Michal Vaskoac6f4be2022-05-02 10:16:50 +0200868 if (!snode && parent && parent->schema && (parent->schema->nodetype & (LYS_RPC | LYS_ACTION))) {
869 /* maybe output node */
Michal Vasko89afc6e2022-05-02 10:24:26 +0200870 snode = lys_find_child(parent->schema, mod, opaq->name.name, 0, 0, LYS_GETNEXT_OUTPUT);
Michal Vaskoac6f4be2022-05-02 10:16:50 +0200871 }
Michal Vaskobfff6ac2022-02-23 16:22:53 +0100872 if (!snode) {
873 if (parent) {
874 LOGVAL(ctx, LYVE_REFERENCE, "Node \"%s\" not found as a child of \"%s\" node.", opaq->name.name,
875 LYD_NAME(parent));
876 } else {
877 LOGVAL(ctx, LYVE_REFERENCE, "Node \"%s\" not found in the \"%s\" module.", opaq->name.name, mod->name);
878 }
Michal Vasko6727c682023-02-17 10:40:26 +0100879 rc = LY_EVALID;
880 goto cleanup;
Michal Vaskobfff6ac2022-02-23 16:22:53 +0100881 }
882
Michal Vasko6727c682023-02-17 10:40:26 +0100883 /* schema node exists */
884 LOG_LOCBACK(0, loc_node, loc_path, 0);
885 loc_node = 0;
886 loc_path = 0;
887 LOG_LOCSET(NULL, node, NULL, NULL);
888 ++loc_node;
889
Michal Vaskobfff6ac2022-02-23 16:22:53 +0100890 if (snode->nodetype & LYD_NODE_TERM) {
891 /* leaf / leaf-list */
Michal Vasko583b4642023-05-25 10:39:34 +0200892 rc = ly_value_validate(ctx, snode, opaq->value, strlen(opaq->value), opaq->format, opaq->val_prefix_data, opaq->hints);
Michal Vasko6727c682023-02-17 10:40:26 +0100893 LY_CHECK_GOTO(rc, cleanup);
Michal Vaskobfff6ac2022-02-23 16:22:53 +0100894 } else if (snode->nodetype == LYS_LIST) {
895 /* list */
Michal Vasko6727c682023-02-17 10:40:26 +0100896 rc = lyd_parse_opaq_list_error(node, snode);
897 LY_CHECK_GOTO(rc, cleanup);
Michal Vaskobfff6ac2022-02-23 16:22:53 +0100898 } else if (snode->nodetype & LYD_NODE_INNER) {
899 /* inner node */
900 if (opaq->value) {
901 LOGVAL(ctx, LYVE_DATA, "Invalid value \"%s\" for %s \"%s\".", opaq->value,
902 lys_nodetype2str(snode->nodetype), snode->name);
Michal Vasko6727c682023-02-17 10:40:26 +0100903 rc = LY_EVALID;
904 goto cleanup;
Michal Vaskobfff6ac2022-02-23 16:22:53 +0100905 }
906 } else {
907 LOGERR(ctx, LY_EINVAL, "Unexpected opaque schema node %s \"%s\".", lys_nodetype2str(snode->nodetype), snode->name);
Michal Vasko6727c682023-02-17 10:40:26 +0100908 rc = LY_EINVAL;
909 goto cleanup;
Michal Vaskobfff6ac2022-02-23 16:22:53 +0100910 }
911
912 LOGERR(ctx, LY_EINVAL, "Unexpected valid opaque node %s \"%s\".", lys_nodetype2str(snode->nodetype), snode->name);
Michal Vasko6727c682023-02-17 10:40:26 +0100913 rc = LY_EINVAL;
914
915cleanup:
916 LOG_LOCBACK(0, loc_node, loc_path, 0);
917 return rc;
Michal Vaskobfff6ac2022-02-23 16:22:53 +0100918}
919
Jan Kundrátc53a7ec2021-12-09 16:01:19 +0100920LIBYANG_API_DEF const char *
Christian Hopps46bd21b2021-04-27 09:43:58 -0400921lyd_value_get_canonical(const struct ly_ctx *ctx, const struct lyd_value *value)
Radek Krejci6d5ba0c2021-04-26 07:49:59 +0200922{
Michal Vaskoab40e7e2021-04-28 17:04:24 +0200923 LY_CHECK_ARG_RET(ctx, ctx, value, NULL);
924
Michal Vasko33876022021-04-27 16:42:24 +0200925 return value->_canonical ? value->_canonical :
926 (const char *)value->realtype->plugin->print(ctx, value, LY_VALUE_CANON, NULL, NULL, NULL);
Radek Krejci6d5ba0c2021-04-26 07:49:59 +0200927}
928
Jan Kundrátc53a7ec2021-12-09 16:01:19 +0100929LIBYANG_API_DEF LY_ERR
Michal Vaskoa820c312021-02-05 16:33:00 +0100930lyd_any_value_str(const struct lyd_node *any, char **value_str)
931{
932 const struct lyd_node_any *a;
933 struct lyd_node *tree = NULL;
934 const char *str = NULL;
935 ly_bool dynamic = 0;
936 LY_ERR ret = LY_SUCCESS;
937
938 LY_CHECK_ARG_RET(NULL, any, value_str, LY_EINVAL);
Radek Krejci71877df2021-04-06 17:24:06 +0200939 LY_CHECK_ARG_RET(NULL, any->schema, any->schema->nodetype & LYS_ANYDATA, LY_EINVAL);
Michal Vaskoa820c312021-02-05 16:33:00 +0100940
941 a = (struct lyd_node_any *)any;
942 *value_str = NULL;
943
944 if (!a->value.str) {
945 /* there is no value in the union */
946 return LY_SUCCESS;
947 }
948
949 switch (a->value_type) {
950 case LYD_ANYDATA_LYB:
951 /* parse into a data tree */
952 ret = lyd_parse_data_mem(LYD_CTX(any), a->value.mem, LYD_LYB, LYD_PARSE_ONLY, 0, &tree);
953 LY_CHECK_GOTO(ret, cleanup);
954 dynamic = 1;
955 break;
956 case LYD_ANYDATA_DATATREE:
957 tree = a->value.tree;
958 break;
959 case LYD_ANYDATA_STRING:
960 case LYD_ANYDATA_XML:
961 case LYD_ANYDATA_JSON:
962 /* simply use the string */
963 str = a->value.str;
964 break;
965 }
966
967 if (tree) {
968 /* print into a string */
969 ret = lyd_print_mem(value_str, tree, LYD_XML, LYD_PRINT_WITHSIBLINGS);
970 LY_CHECK_GOTO(ret, cleanup);
971 } else {
972 assert(str);
973 *value_str = strdup(str);
974 LY_CHECK_ERR_GOTO(!*value_str, LOGMEM(LYD_CTX(any)), cleanup);
975 }
976
977 /* success */
978
979cleanup:
980 if (dynamic) {
981 lyd_free_all(tree);
982 }
983 return ret;
984}
985
Jan Kundrátc53a7ec2021-12-09 16:01:19 +0100986LIBYANG_API_DEF LY_ERR
Michal Vasko61551fa2020-07-09 15:45:45 +0200987lyd_any_copy_value(struct lyd_node *trg, const union lyd_any_value *value, LYD_ANYDATA_VALUETYPE value_type)
988{
989 struct lyd_node_any *t;
Michal Vasko61551fa2020-07-09 15:45:45 +0200990
Michal Vaskoa820c312021-02-05 16:33:00 +0100991 LY_CHECK_ARG_RET(NULL, trg, LY_EINVAL);
Radek Krejci71877df2021-04-06 17:24:06 +0200992 LY_CHECK_ARG_RET(NULL, trg->schema, trg->schema->nodetype & LYS_ANYDATA, LY_EINVAL);
Michal Vasko61551fa2020-07-09 15:45:45 +0200993
994 t = (struct lyd_node_any *)trg;
995
996 /* free trg */
997 switch (t->value_type) {
998 case LYD_ANYDATA_DATATREE:
999 lyd_free_all(t->value.tree);
1000 break;
1001 case LYD_ANYDATA_STRING:
1002 case LYD_ANYDATA_XML:
1003 case LYD_ANYDATA_JSON:
Michal Vaskoe180ed02021-02-05 16:31:20 +01001004 lydict_remove(LYD_CTX(trg), t->value.str);
Michal Vasko61551fa2020-07-09 15:45:45 +02001005 break;
1006 case LYD_ANYDATA_LYB:
1007 free(t->value.mem);
1008 break;
1009 }
1010 t->value.str = NULL;
1011
1012 if (!value) {
1013 /* only free value in this case */
1014 return LY_SUCCESS;
1015 }
1016
1017 /* copy src */
1018 t->value_type = value_type;
1019 switch (value_type) {
1020 case LYD_ANYDATA_DATATREE:
1021 if (value->tree) {
Michal Vasko3a41dff2020-07-15 14:30:28 +02001022 LY_CHECK_RET(lyd_dup_siblings(value->tree, NULL, LYD_DUP_RECURSIVE, &t->value.tree));
Michal Vasko61551fa2020-07-09 15:45:45 +02001023 }
1024 break;
1025 case LYD_ANYDATA_STRING:
1026 case LYD_ANYDATA_XML:
1027 case LYD_ANYDATA_JSON:
1028 if (value->str) {
Radek Krejci011e4aa2020-09-04 15:22:31 +02001029 LY_CHECK_RET(lydict_insert(LYD_CTX(trg), value->str, 0, &t->value.str));
Michal Vasko61551fa2020-07-09 15:45:45 +02001030 }
1031 break;
1032 case LYD_ANYDATA_LYB:
1033 if (value->mem) {
Radek Krejci1deb5be2020-08-26 16:43:36 +02001034 int len = lyd_lyb_data_length(value->mem);
Michal Vasko26bbb272022-08-02 14:54:33 +02001035
Radek Krejci82fa8d42020-07-11 22:00:59 +02001036 LY_CHECK_RET(len == -1, LY_EINVAL);
Michal Vasko61551fa2020-07-09 15:45:45 +02001037 t->value.mem = malloc(len);
Michal Vaskob7be7a82020-08-20 09:09:04 +02001038 LY_CHECK_ERR_RET(!t->value.mem, LOGMEM(LYD_CTX(trg)), LY_EMEM);
Michal Vasko61551fa2020-07-09 15:45:45 +02001039 memcpy(t->value.mem, value->mem, len);
1040 }
1041 break;
1042 }
1043
1044 return LY_SUCCESS;
1045}
1046
Michal Vasko106f0862021-11-02 11:49:27 +01001047const struct lysc_node *
1048lyd_node_schema(const struct lyd_node *node)
1049{
1050 const struct lysc_node *schema = NULL;
1051 const struct lyd_node *prev_iter = NULL, *iter;
1052 const struct lys_module *mod;
1053
1054 if (!node) {
1055 return NULL;
1056 } else if (node->schema) {
1057 return node->schema;
1058 }
1059
1060 /* get schema node of an opaque node */
1061 do {
1062 /* get next data node */
1063 for (iter = node; lyd_parent(iter) != prev_iter; iter = lyd_parent(iter)) {}
1064
1065 /* get equivalent schema node */
1066 if (iter->schema) {
1067 schema = iter->schema;
1068 } else {
1069 /* get module */
1070 mod = lyd_owner_module(iter);
Michal Vaskoa41826a2021-11-02 12:13:03 +01001071 if (!mod && !schema) {
1072 /* top-level opaque node has unknown module */
1073 break;
1074 }
Michal Vasko106f0862021-11-02 11:49:27 +01001075
1076 /* get schema node */
1077 schema = lys_find_child(schema, mod ? mod : schema->module, LYD_NAME(iter), 0, 0, 0);
1078 }
Michal Vaskod2f404f2021-11-04 15:37:11 +01001079
1080 /* remember to move to the descendant */
1081 prev_iter = iter;
Michal Vasko106f0862021-11-02 11:49:27 +01001082 } while (schema && (iter != node));
1083
1084 return schema;
1085}
1086
Michal Vasko4754d4a2022-12-01 10:11:21 +01001087void
1088lyd_cont_set_dflt(struct lyd_node *node)
1089{
1090 const struct lyd_node *child;
1091
1092 while (node) {
1093 if (!node->schema || (node->flags & LYD_DEFAULT) || !lysc_is_np_cont(node->schema)) {
1094 /* not a non-dflt NP container */
1095 break;
1096 }
1097
1098 LY_LIST_FOR(lyd_child(node), child) {
1099 if (!(child->flags & LYD_DEFAULT)) {
1100 break;
1101 }
1102 }
1103 if (child) {
1104 /* explicit child, no dflt change */
1105 break;
1106 }
1107
1108 /* set the dflt flag */
1109 node->flags |= LYD_DEFAULT;
1110
1111 /* check all parent containers */
1112 node = lyd_parent(node);
1113 }
1114}
1115
Michal Vasko59892dd2022-05-13 11:02:30 +02001116/**
1117 * @brief Comparison callback to match schema node with a schema of a data node.
1118 *
1119 * @param[in] val1_p Pointer to the schema node
1120 * @param[in] val2_p Pointer to the data node
1121 * Implementation of ::lyht_value_equal_cb.
1122 */
1123static ly_bool
1124lyd_hash_table_schema_val_equal(void *val1_p, void *val2_p, ly_bool UNUSED(mod), void *UNUSED(cb_data))
1125{
1126 struct lysc_node *val1;
1127 struct lyd_node *val2;
1128
1129 val1 = *((struct lysc_node **)val1_p);
1130 val2 = *((struct lyd_node **)val2_p);
1131
1132 if (val1 == val2->schema) {
1133 /* schema match is enough */
1134 return 1;
1135 } else {
1136 return 0;
1137 }
1138}
1139
1140LY_ERR
1141lyd_find_sibling_schema(const struct lyd_node *siblings, const struct lysc_node *schema, struct lyd_node **match)
1142{
1143 struct lyd_node **match_p;
1144 struct lyd_node_inner *parent;
Michal Vaskodf8ebf62022-11-10 10:33:28 +01001145 const struct lysc_node *cur_schema;
Michal Vasko59892dd2022-05-13 11:02:30 +02001146 uint32_t hash;
1147 lyht_value_equal_cb ht_cb;
1148
Michal Vasko21beaeb2022-08-02 10:42:48 +02001149 assert(schema);
1150 if (!siblings) {
1151 /* no data */
1152 if (match) {
1153 *match = NULL;
1154 }
1155 return LY_ENOTFOUND;
1156 }
Michal Vasko59892dd2022-05-13 11:02:30 +02001157
1158 parent = siblings->parent;
1159 if (parent && parent->schema && parent->children_ht) {
1160 /* calculate our hash */
Michal Vaskoae130f52023-04-20 14:25:16 +02001161 hash = lyht_hash_multi(0, schema->module->name, strlen(schema->module->name));
1162 hash = lyht_hash_multi(hash, schema->name, strlen(schema->name));
1163 hash = lyht_hash_multi(hash, NULL, 0);
Michal Vasko59892dd2022-05-13 11:02:30 +02001164
1165 /* use special hash table function */
1166 ht_cb = lyht_set_cb(parent->children_ht, lyd_hash_table_schema_val_equal);
1167
1168 /* find by hash */
1169 if (!lyht_find(parent->children_ht, &schema, hash, (void **)&match_p)) {
1170 siblings = *match_p;
1171 } else {
1172 /* not found */
1173 siblings = NULL;
1174 }
1175
1176 /* set the original hash table compare function back */
1177 lyht_set_cb(parent->children_ht, ht_cb);
1178 } else {
1179 /* find first sibling */
1180 if (siblings->parent) {
1181 siblings = siblings->parent->child;
1182 } else {
1183 while (siblings->prev->next) {
1184 siblings = siblings->prev;
1185 }
1186 }
1187
1188 /* search manually without hashes */
1189 for ( ; siblings; siblings = siblings->next) {
Michal Vaskodf8ebf62022-11-10 10:33:28 +01001190 cur_schema = lyd_node_schema(siblings);
1191 if (!cur_schema) {
1192 /* some unknown opaque node */
1193 continue;
Michal Vasko31bac382022-07-20 08:07:59 +02001194 }
Michal Vaskodf8ebf62022-11-10 10:33:28 +01001195
1196 /* schema match is enough */
1197 if (cur_schema->module->ctx == schema->module->ctx) {
1198 if (cur_schema == schema) {
1199 break;
1200 }
1201 } else {
1202 if (!strcmp(cur_schema->name, schema->name) && !strcmp(cur_schema->module->name, schema->module->name)) {
1203 break;
1204 }
Michal Vasko59892dd2022-05-13 11:02:30 +02001205 }
1206 }
1207 }
1208
1209 if (!siblings) {
1210 if (match) {
1211 *match = NULL;
1212 }
1213 return LY_ENOTFOUND;
1214 }
1215
1216 if (match) {
1217 *match = (struct lyd_node *)siblings;
1218 }
1219 return LY_SUCCESS;
1220}
1221
Michal Vasko6b5cb2a2020-11-11 19:11:21 +01001222void
Michal Vaskod3bb12f2020-12-04 14:33:09 +01001223lyd_del_move_root(struct lyd_node **root, const struct lyd_node *to_del, const struct lys_module *mod)
1224{
1225 if (*root && (lyd_owner_module(*root) != mod)) {
1226 /* there are no data of mod so this is simply the first top-level sibling */
1227 mod = NULL;
1228 }
1229
1230 if ((*root != to_del) || (*root)->parent) {
1231 return;
1232 }
1233
Michal Vasko598063b2021-07-19 11:39:05 +02001234 if (mod && (*root)->prev->next && (!(*root)->next || (lyd_owner_module(to_del) != lyd_owner_module((*root)->next)))) {
1235 /* there are no more nodes from mod, simply get the first top-level sibling */
Michal Vaskod3bb12f2020-12-04 14:33:09 +01001236 *root = lyd_first_sibling(*root);
Michal Vasko598063b2021-07-19 11:39:05 +02001237 } else {
1238 *root = (*root)->next;
Michal Vaskod3bb12f2020-12-04 14:33:09 +01001239 }
1240}
1241
Michal Vasko8cc3f662022-03-29 11:25:51 +02001242LY_ERR
1243ly_nested_ext_schema(const struct lyd_node *parent, const struct lysc_node *sparent, const char *prefix,
1244 size_t prefix_len, LY_VALUE_FORMAT format, void *prefix_data, const char *name, size_t name_len,
1245 const struct lysc_node **snode, struct lysc_ext_instance **ext)
1246{
1247 LY_ERR r;
1248 LY_ARRAY_COUNT_TYPE u;
1249 struct lysc_ext_instance *nested_exts = NULL;
1250 lyplg_ext_data_snode_clb ext_snode_cb;
1251
1252 /* check if there are any nested extension instances */
1253 if (parent && parent->schema) {
1254 nested_exts = parent->schema->exts;
1255 } else if (sparent) {
1256 nested_exts = sparent->exts;
1257 }
1258 LY_ARRAY_FOR(nested_exts, u) {
Michal Vasko305c6cb2022-04-27 10:33:04 +02001259 if (!nested_exts[u].def->plugin) {
1260 /* no plugin */
1261 continue;
1262 }
1263
Michal Vasko8cc3f662022-03-29 11:25:51 +02001264 ext_snode_cb = nested_exts[u].def->plugin->snode;
1265 if (!ext_snode_cb) {
1266 /* not an extension with nested data */
1267 continue;
1268 }
1269
1270 /* try to get the schema node */
1271 r = ext_snode_cb(&nested_exts[u], parent, sparent, prefix, prefix_len, format, prefix_data, name, name_len, snode);
1272 if (!r) {
Michal Vasko66330fc2022-11-21 15:52:24 +01001273 if (ext) {
1274 /* data successfully created, remember the ext instance */
1275 *ext = &nested_exts[u];
1276 }
Michal Vasko8cc3f662022-03-29 11:25:51 +02001277 return LY_SUCCESS;
1278 } else if (r != LY_ENOT) {
1279 /* fatal error */
1280 return r;
1281 }
1282 /* data was not from this module, continue */
1283 }
1284
1285 /* no extensions or none matched */
1286 return LY_ENOT;
1287}
1288
Michal Vaskod3bb12f2020-12-04 14:33:09 +01001289void
Radek Krejci8df109d2021-04-23 12:19:08 +02001290ly_free_prefix_data(LY_VALUE_FORMAT format, void *prefix_data)
Michal Vasko6b5cb2a2020-11-11 19:11:21 +01001291{
1292 struct ly_set *ns_list;
1293 struct lysc_prefix *prefixes;
1294 uint32_t i;
1295 LY_ARRAY_COUNT_TYPE u;
1296
1297 if (!prefix_data) {
1298 return;
1299 }
1300
1301 switch (format) {
Radek Krejci8df109d2021-04-23 12:19:08 +02001302 case LY_VALUE_XML:
Michal Vaskoddd76592022-01-17 13:34:48 +01001303 case LY_VALUE_STR_NS:
Michal Vasko6b5cb2a2020-11-11 19:11:21 +01001304 ns_list = prefix_data;
1305 for (i = 0; i < ns_list->count; ++i) {
1306 free(((struct lyxml_ns *)ns_list->objs[i])->prefix);
1307 free(((struct lyxml_ns *)ns_list->objs[i])->uri);
1308 }
1309 ly_set_free(ns_list, free);
1310 break;
Radek Krejci8df109d2021-04-23 12:19:08 +02001311 case LY_VALUE_SCHEMA_RESOLVED:
Michal Vasko6b5cb2a2020-11-11 19:11:21 +01001312 prefixes = prefix_data;
1313 LY_ARRAY_FOR(prefixes, u) {
1314 free(prefixes[u].prefix);
1315 }
1316 LY_ARRAY_FREE(prefixes);
1317 break;
Radek Krejci224d4b42021-04-23 13:54:59 +02001318 case LY_VALUE_CANON:
Radek Krejci8df109d2021-04-23 12:19:08 +02001319 case LY_VALUE_SCHEMA:
1320 case LY_VALUE_JSON:
Radek Krejcif9943642021-04-26 10:18:21 +02001321 case LY_VALUE_LYB:
Michal Vasko6b5cb2a2020-11-11 19:11:21 +01001322 break;
1323 }
1324}
1325
1326LY_ERR
Radek Krejci8df109d2021-04-23 12:19:08 +02001327ly_dup_prefix_data(const struct ly_ctx *ctx, LY_VALUE_FORMAT format, const void *prefix_data,
Michal Vasko6b5cb2a2020-11-11 19:11:21 +01001328 void **prefix_data_p)
1329{
1330 LY_ERR ret = LY_SUCCESS;
1331 struct lyxml_ns *ns;
1332 struct lysc_prefix *prefixes = NULL, *orig_pref;
1333 struct ly_set *ns_list, *orig_ns;
1334 uint32_t i;
1335 LY_ARRAY_COUNT_TYPE u;
1336
1337 assert(!*prefix_data_p);
1338
1339 switch (format) {
Radek Krejci8df109d2021-04-23 12:19:08 +02001340 case LY_VALUE_SCHEMA:
Michal Vasko6b5cb2a2020-11-11 19:11:21 +01001341 *prefix_data_p = (void *)prefix_data;
1342 break;
Radek Krejci8df109d2021-04-23 12:19:08 +02001343 case LY_VALUE_SCHEMA_RESOLVED:
Michal Vasko6b5cb2a2020-11-11 19:11:21 +01001344 /* copy all the value prefixes */
1345 orig_pref = (struct lysc_prefix *)prefix_data;
1346 LY_ARRAY_CREATE_GOTO(ctx, prefixes, LY_ARRAY_COUNT(orig_pref), ret, cleanup);
1347 *prefix_data_p = prefixes;
1348
1349 LY_ARRAY_FOR(orig_pref, u) {
1350 if (orig_pref[u].prefix) {
1351 prefixes[u].prefix = strdup(orig_pref[u].prefix);
1352 LY_CHECK_ERR_GOTO(!prefixes[u].prefix, LOGMEM(ctx); ret = LY_EMEM, cleanup);
1353 }
1354 prefixes[u].mod = orig_pref[u].mod;
1355 LY_ARRAY_INCREMENT(prefixes);
1356 }
1357 break;
Radek Krejci8df109d2021-04-23 12:19:08 +02001358 case LY_VALUE_XML:
Michal Vaskoddd76592022-01-17 13:34:48 +01001359 case LY_VALUE_STR_NS:
Michal Vasko6b5cb2a2020-11-11 19:11:21 +01001360 /* copy all the namespaces */
1361 LY_CHECK_GOTO(ret = ly_set_new(&ns_list), cleanup);
1362 *prefix_data_p = ns_list;
1363
1364 orig_ns = (struct ly_set *)prefix_data;
1365 for (i = 0; i < orig_ns->count; ++i) {
1366 ns = calloc(1, sizeof *ns);
1367 LY_CHECK_ERR_GOTO(!ns, LOGMEM(ctx); ret = LY_EMEM, cleanup);
1368 LY_CHECK_GOTO(ret = ly_set_add(ns_list, ns, 1, NULL), cleanup);
1369
1370 if (((struct lyxml_ns *)orig_ns->objs[i])->prefix) {
1371 ns->prefix = strdup(((struct lyxml_ns *)orig_ns->objs[i])->prefix);
1372 LY_CHECK_ERR_GOTO(!ns->prefix, LOGMEM(ctx); ret = LY_EMEM, cleanup);
1373 }
1374 ns->uri = strdup(((struct lyxml_ns *)orig_ns->objs[i])->uri);
1375 LY_CHECK_ERR_GOTO(!ns->uri, LOGMEM(ctx); ret = LY_EMEM, cleanup);
1376 }
1377 break;
Radek Krejci224d4b42021-04-23 13:54:59 +02001378 case LY_VALUE_CANON:
Radek Krejci8df109d2021-04-23 12:19:08 +02001379 case LY_VALUE_JSON:
Radek Krejcif9943642021-04-26 10:18:21 +02001380 case LY_VALUE_LYB:
Michal Vasko6b5cb2a2020-11-11 19:11:21 +01001381 assert(!prefix_data);
1382 *prefix_data_p = NULL;
1383 break;
1384 }
1385
1386cleanup:
1387 if (ret) {
1388 ly_free_prefix_data(format, *prefix_data_p);
1389 *prefix_data_p = NULL;
1390 }
1391 return ret;
1392}
1393
1394LY_ERR
Radek Krejcif9943642021-04-26 10:18:21 +02001395ly_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 +02001396 const void *prefix_data, LY_VALUE_FORMAT *format_p, void **prefix_data_p)
Michal Vasko6b5cb2a2020-11-11 19:11:21 +01001397{
1398 LY_ERR ret = LY_SUCCESS;
Michal Vasko6b5cb2a2020-11-11 19:11:21 +01001399 const struct lys_module *mod;
Michal Vaskofc2cd072021-02-24 13:17:17 +01001400 const struct lyxml_ns *ns;
1401 struct lyxml_ns *new_ns;
Michal Vasko6b5cb2a2020-11-11 19:11:21 +01001402 struct ly_set *ns_list;
1403 struct lysc_prefix *prefixes = NULL, *val_pref;
aPiecek83436bc2021-03-30 12:20:45 +02001404 const char *value_iter, *value_next, *value_end;
1405 uint32_t substr_len;
1406 ly_bool is_prefix;
Michal Vasko6b5cb2a2020-11-11 19:11:21 +01001407
1408 switch (format) {
Radek Krejci8df109d2021-04-23 12:19:08 +02001409 case LY_VALUE_SCHEMA:
Michal Vaskofc2cd072021-02-24 13:17:17 +01001410 /* copy all referenced modules as prefix - module pairs */
1411 if (!*prefix_data_p) {
1412 /* new prefix data */
Michal Vasko6b5cb2a2020-11-11 19:11:21 +01001413 LY_ARRAY_CREATE_GOTO(ctx, prefixes, 0, ret, cleanup);
Radek Krejci8df109d2021-04-23 12:19:08 +02001414 *format_p = LY_VALUE_SCHEMA_RESOLVED;
Michal Vasko6b5cb2a2020-11-11 19:11:21 +01001415 *prefix_data_p = prefixes;
Michal Vaskofc2cd072021-02-24 13:17:17 +01001416 } else {
1417 /* reuse prefix data */
Radek Krejci8df109d2021-04-23 12:19:08 +02001418 assert(*format_p == LY_VALUE_SCHEMA_RESOLVED);
Michal Vaskofc2cd072021-02-24 13:17:17 +01001419 prefixes = *prefix_data_p;
Michal Vasko6b5cb2a2020-11-11 19:11:21 +01001420 }
1421
Michal Vaskoc0f9c4c2022-05-06 12:12:17 +02001422 /* add current module for unprefixed values */
1423 LY_ARRAY_NEW_GOTO(ctx, prefixes, val_pref, ret, cleanup);
1424 *prefix_data_p = prefixes;
1425
1426 val_pref->prefix = NULL;
1427 val_pref->mod = ((const struct lysp_module *)prefix_data)->mod;
1428
Michal Vasko6b5cb2a2020-11-11 19:11:21 +01001429 /* add all used prefixes */
Michal Vasko59e90fc2021-09-22 12:17:08 +02001430 value_end = (char *)value + value_len;
aPiecek83436bc2021-03-30 12:20:45 +02001431 for (value_iter = value; value_iter; value_iter = value_next) {
aPieceke3f828d2021-05-10 15:34:41 +02001432 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 +02001433 if (is_prefix) {
1434 /* we have a possible prefix. Do we already have the prefix? */
1435 mod = ly_resolve_prefix(ctx, value_iter, substr_len, *format_p, *prefix_data_p);
1436 if (!mod) {
1437 mod = ly_resolve_prefix(ctx, value_iter, substr_len, format, prefix_data);
1438 if (mod) {
Radek Krejci8df109d2021-04-23 12:19:08 +02001439 assert(*format_p == LY_VALUE_SCHEMA_RESOLVED);
aPiecek83436bc2021-03-30 12:20:45 +02001440 /* store a new prefix - module pair */
1441 LY_ARRAY_NEW_GOTO(ctx, prefixes, val_pref, ret, cleanup);
1442 *prefix_data_p = prefixes;
Michal Vasko6b5cb2a2020-11-11 19:11:21 +01001443
aPiecek83436bc2021-03-30 12:20:45 +02001444 val_pref->prefix = strndup(value_iter, substr_len);
1445 LY_CHECK_ERR_GOTO(!val_pref->prefix, LOGMEM(ctx); ret = LY_EMEM, cleanup);
1446 val_pref->mod = mod;
1447 } /* else it is not even defined */
1448 } /* else the prefix is already present */
Michal Vaskofc2cd072021-02-24 13:17:17 +01001449 }
1450 }
1451 break;
Radek Krejci8df109d2021-04-23 12:19:08 +02001452 case LY_VALUE_XML:
Michal Vaskoddd76592022-01-17 13:34:48 +01001453 case LY_VALUE_STR_NS:
Michal Vaskofc2cd072021-02-24 13:17:17 +01001454 /* copy all referenced namespaces as prefix - namespace pairs */
1455 if (!*prefix_data_p) {
1456 /* new prefix data */
1457 LY_CHECK_GOTO(ret = ly_set_new(&ns_list), cleanup);
Michal Vaskoddd76592022-01-17 13:34:48 +01001458 *format_p = format;
Michal Vaskofc2cd072021-02-24 13:17:17 +01001459 *prefix_data_p = ns_list;
1460 } else {
1461 /* reuse prefix data */
Michal Vaskoddd76592022-01-17 13:34:48 +01001462 assert(*format_p == format);
Michal Vaskofc2cd072021-02-24 13:17:17 +01001463 ns_list = *prefix_data_p;
1464 }
Michal Vasko6b5cb2a2020-11-11 19:11:21 +01001465
Michal Vasko294e7f02022-02-28 13:59:00 +01001466 /* store default namespace */
1467 ns = lyxml_ns_get(prefix_data, NULL, 0);
1468 if (ns) {
1469 new_ns = calloc(1, sizeof *new_ns);
1470 LY_CHECK_ERR_GOTO(!new_ns, LOGMEM(ctx); ret = LY_EMEM, cleanup);
1471 LY_CHECK_GOTO(ret = ly_set_add(ns_list, new_ns, 1, NULL), cleanup);
1472
1473 new_ns->prefix = NULL;
1474 new_ns->uri = strdup(ns->uri);
1475 LY_CHECK_ERR_GOTO(!new_ns->uri, LOGMEM(ctx); ret = LY_EMEM, cleanup);
1476 }
1477
Michal Vaskofc2cd072021-02-24 13:17:17 +01001478 /* add all used prefixes */
Michal Vasko59e90fc2021-09-22 12:17:08 +02001479 value_end = (char *)value + value_len;
aPiecek83436bc2021-03-30 12:20:45 +02001480 for (value_iter = value; value_iter; value_iter = value_next) {
aPieceke3f828d2021-05-10 15:34:41 +02001481 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 +02001482 if (is_prefix) {
1483 /* we have a possible prefix. Do we already have the prefix? */
1484 ns = lyxml_ns_get(ns_list, value_iter, substr_len);
1485 if (!ns) {
1486 ns = lyxml_ns_get(prefix_data, value_iter, substr_len);
1487 if (ns) {
1488 /* store a new prefix - namespace pair */
1489 new_ns = calloc(1, sizeof *new_ns);
1490 LY_CHECK_ERR_GOTO(!new_ns, LOGMEM(ctx); ret = LY_EMEM, cleanup);
1491 LY_CHECK_GOTO(ret = ly_set_add(ns_list, new_ns, 1, NULL), cleanup);
Michal Vaskofc2cd072021-02-24 13:17:17 +01001492
aPiecek83436bc2021-03-30 12:20:45 +02001493 new_ns->prefix = strndup(value_iter, substr_len);
1494 LY_CHECK_ERR_GOTO(!new_ns->prefix, LOGMEM(ctx); ret = LY_EMEM, cleanup);
1495 new_ns->uri = strdup(ns->uri);
1496 LY_CHECK_ERR_GOTO(!new_ns->uri, LOGMEM(ctx); ret = LY_EMEM, cleanup);
1497 } /* else it is not even defined */
1498 } /* else the prefix is already present */
Michal Vasko6b5cb2a2020-11-11 19:11:21 +01001499 }
1500 }
1501 break;
Radek Krejci224d4b42021-04-23 13:54:59 +02001502 case LY_VALUE_CANON:
Radek Krejci8df109d2021-04-23 12:19:08 +02001503 case LY_VALUE_SCHEMA_RESOLVED:
1504 case LY_VALUE_JSON:
Radek Krejcif9943642021-04-26 10:18:21 +02001505 case LY_VALUE_LYB:
Michal Vaskofc2cd072021-02-24 13:17:17 +01001506 if (!*prefix_data_p) {
1507 /* new prefix data - simply copy all the prefix data */
1508 *format_p = format;
1509 LY_CHECK_GOTO(ret = ly_dup_prefix_data(ctx, format, prefix_data, prefix_data_p), cleanup);
1510 } /* else reuse prefix data - the prefix data are always the same, nothing to do */
Michal Vasko6b5cb2a2020-11-11 19:11:21 +01001511 break;
1512 }
1513
1514cleanup:
1515 if (ret) {
1516 ly_free_prefix_data(*format_p, *prefix_data_p);
1517 *prefix_data_p = NULL;
1518 }
1519 return ret;
1520}
Michal Vasko7ed1fcb2020-12-03 14:15:22 +01001521
1522const char *
Radek Krejci8df109d2021-04-23 12:19:08 +02001523ly_format2str(LY_VALUE_FORMAT format)
Michal Vasko7ed1fcb2020-12-03 14:15:22 +01001524{
1525 switch (format) {
Radek Krejci224d4b42021-04-23 13:54:59 +02001526 case LY_VALUE_CANON:
1527 return "canonical";
Radek Krejci8df109d2021-04-23 12:19:08 +02001528 case LY_VALUE_SCHEMA:
Michal Vasko7ed1fcb2020-12-03 14:15:22 +01001529 return "schema imports";
Radek Krejci8df109d2021-04-23 12:19:08 +02001530 case LY_VALUE_SCHEMA_RESOLVED:
Michal Vasko7ed1fcb2020-12-03 14:15:22 +01001531 return "schema stored mapping";
Radek Krejci8df109d2021-04-23 12:19:08 +02001532 case LY_VALUE_XML:
Michal Vasko7ed1fcb2020-12-03 14:15:22 +01001533 return "XML prefixes";
Radek Krejci8df109d2021-04-23 12:19:08 +02001534 case LY_VALUE_JSON:
Michal Vasko7ed1fcb2020-12-03 14:15:22 +01001535 return "JSON module names";
Radek Krejcif9943642021-04-26 10:18:21 +02001536 case LY_VALUE_LYB:
1537 return "LYB prefixes";
Michal Vasko7ed1fcb2020-12-03 14:15:22 +01001538 default:
1539 break;
1540 }
1541
1542 return NULL;
1543}
Michal Vasko43297a02021-05-19 11:12:37 +02001544
Michal Vaskof17bb2a2023-02-10 11:34:55 +01001545LIBYANG_API_DEF int
1546ly_time_tz_offset(void)
1547{
Michal Vasko9b560332023-04-24 15:43:56 +02001548 return ly_time_tz_offset_at(time(NULL));
1549}
1550
1551LIBYANG_API_DEF int
1552ly_time_tz_offset_at(time_t time)
1553{
Michal Vaskof17bb2a2023-02-10 11:34:55 +01001554 struct tm tm_local, tm_utc;
1555 int result = 0;
1556
1557 /* init timezone */
1558 tzset();
1559
1560 /* get local and UTC time */
Michal Vasko9b560332023-04-24 15:43:56 +02001561 localtime_r(&time, &tm_local);
1562 gmtime_r(&time, &tm_utc);
Michal Vaskoe50b98d2023-03-28 11:39:01 +02001563
Michal Vasko9b560332023-04-24 15:43:56 +02001564 /* account for year/month/day change by adding/subtracting from the hours, the change cannot be more than 1 day */
1565 if (tm_local.tm_year < tm_utc.tm_year) {
1566 tm_utc.tm_hour += 24;
1567 } else if (tm_local.tm_year > tm_utc.tm_year) {
1568 tm_local.tm_hour += 24;
1569 } else if (tm_local.tm_mon < tm_utc.tm_mon) {
1570 tm_utc.tm_hour += 24;
1571 } else if (tm_local.tm_mon > tm_utc.tm_mon) {
1572 tm_local.tm_hour += 24;
1573 } else if (tm_local.tm_mday < tm_utc.tm_mday) {
1574 tm_utc.tm_hour += 24;
1575 } else if (tm_local.tm_mday > tm_utc.tm_mday) {
1576 tm_local.tm_hour += 24;
Michal Vaskoe50b98d2023-03-28 11:39:01 +02001577 }
Michal Vaskof17bb2a2023-02-10 11:34:55 +01001578
1579 /* hours shift in seconds */
1580 result += (tm_local.tm_hour - tm_utc.tm_hour) * 3600;
1581
1582 /* minutes shift in seconds */
1583 result += (tm_local.tm_min - tm_utc.tm_min) * 60;
1584
1585 /* seconds shift */
1586 result += tm_local.tm_sec - tm_utc.tm_sec;
1587
1588 return result;
1589}
1590
Jan Kundrátc53a7ec2021-12-09 16:01:19 +01001591LIBYANG_API_DEF LY_ERR
Michal Vasko43297a02021-05-19 11:12:37 +02001592ly_time_str2time(const char *value, time_t *time, char **fractions_s)
1593{
1594 struct tm tm = {0};
1595 uint32_t i, frac_len;
1596 const char *frac;
1597 int64_t shift, shift_m;
1598 time_t t;
1599
1600 LY_CHECK_ARG_RET(NULL, value, time, LY_EINVAL);
1601
1602 tm.tm_year = atoi(&value[0]) - 1900;
1603 tm.tm_mon = atoi(&value[5]) - 1;
1604 tm.tm_mday = atoi(&value[8]);
1605 tm.tm_hour = atoi(&value[11]);
1606 tm.tm_min = atoi(&value[14]);
1607 tm.tm_sec = atoi(&value[17]);
1608
Michal Vasko2b7e1612023-08-08 13:37:34 +02001609 /* explicit checks for some gross errors */
1610 if (tm.tm_mon > 11) {
1611 LOGERR(NULL, LY_EINVAL, "Invalid date-and-time month \"%d\".", tm.tm_mon);
1612 return LY_EINVAL;
1613 }
1614 if ((tm.tm_mday < 1) || (tm.tm_mday > 31)) {
1615 LOGERR(NULL, LY_EINVAL, "Invalid date-and-time day of month \"%d\".", tm.tm_mday);
1616 return LY_EINVAL;
1617 }
1618 if (tm.tm_hour > 23) {
1619 LOGERR(NULL, LY_EINVAL, "Invalid date-and-time hours \"%d\".", tm.tm_hour);
1620 return LY_EINVAL;
1621 }
1622 if (tm.tm_min > 59) {
1623 LOGERR(NULL, LY_EINVAL, "Invalid date-and-time minutes \"%d\".", tm.tm_min);
1624 return LY_EINVAL;
1625 }
1626 if (tm.tm_sec > 60) {
1627 LOGERR(NULL, LY_EINVAL, "Invalid date-and-time seconds \"%d\".", tm.tm_sec);
1628 return LY_EINVAL;
1629 }
1630
Michal Vasko43297a02021-05-19 11:12:37 +02001631 t = timegm(&tm);
1632 i = 19;
1633
1634 /* fractions of a second */
1635 if (value[i] == '.') {
1636 ++i;
1637 frac = &value[i];
1638 for (frac_len = 0; isdigit(frac[frac_len]); ++frac_len) {}
1639
1640 i += frac_len;
Michal Vasko43297a02021-05-19 11:12:37 +02001641 } else {
1642 frac = NULL;
1643 }
1644
1645 /* apply offset */
1646 if ((value[i] == 'Z') || (value[i] == 'z')) {
1647 /* zero shift */
1648 shift = 0;
1649 } else {
1650 shift = strtol(&value[i], NULL, 10);
Michal Vasko2b7e1612023-08-08 13:37:34 +02001651 if (shift > 23) {
1652 LOGERR(NULL, LY_EINVAL, "Invalid date-and-time timezone hour \"%" PRIi64 "\".", shift);
1653 return LY_EINVAL;
1654 }
Michal Vasko43297a02021-05-19 11:12:37 +02001655 shift = shift * 60 * 60; /* convert from hours to seconds */
Michal Vasko2b7e1612023-08-08 13:37:34 +02001656
1657 shift_m = strtol(&value[i + 4], NULL, 10);
1658 if (shift_m > 59) {
1659 LOGERR(NULL, LY_EINVAL, "Invalid date-and-time timezone minutes \"%" PRIi64 "\".", shift_m);
1660 return LY_EINVAL;
1661 }
1662 shift_m *= 60; /* convert from minutes to seconds */
1663
Michal Vasko43297a02021-05-19 11:12:37 +02001664 /* correct sign */
1665 if (shift < 0) {
1666 shift_m *= -1;
1667 }
Michal Vasko2b7e1612023-08-08 13:37:34 +02001668
Michal Vasko43297a02021-05-19 11:12:37 +02001669 /* connect hours and minutes of the shift */
1670 shift = shift + shift_m;
1671 }
1672
1673 /* we have to shift to the opposite way to correct the time */
1674 t -= shift;
1675
1676 *time = t;
1677 if (fractions_s) {
1678 if (frac) {
1679 *fractions_s = strndup(frac, frac_len);
1680 LY_CHECK_RET(!*fractions_s, LY_EMEM);
1681 } else {
1682 *fractions_s = NULL;
1683 }
1684 }
1685 return LY_SUCCESS;
1686}
1687
Jan Kundrátc53a7ec2021-12-09 16:01:19 +01001688LIBYANG_API_DEF LY_ERR
Michal Vasko43297a02021-05-19 11:12:37 +02001689ly_time_time2str(time_t time, const char *fractions_s, char **str)
1690{
1691 struct tm tm;
Michal Vaskof17bb2a2023-02-10 11:34:55 +01001692 char zoneshift[12];
1693 int zonediff_s, zonediff_h, zonediff_m;
Michal Vasko43297a02021-05-19 11:12:37 +02001694
1695 LY_CHECK_ARG_RET(NULL, str, LY_EINVAL);
1696
Michal Vaskof17bb2a2023-02-10 11:34:55 +01001697 /* init timezone */
Michal Vasko43297a02021-05-19 11:12:37 +02001698 tzset();
1699
1700 /* convert */
1701 if (!localtime_r(&time, &tm)) {
1702 return LY_ESYS;
1703 }
1704
Michal Vaskoe50b98d2023-03-28 11:39:01 +02001705 /* get timezone offset (do not use tm_gmtoff to avoid portability problems) */
Michal Vasko9b560332023-04-24 15:43:56 +02001706 zonediff_s = ly_time_tz_offset_at(time);
Michal Vaskof17bb2a2023-02-10 11:34:55 +01001707 zonediff_h = zonediff_s / 60 / 60;
1708 zonediff_m = zonediff_s / 60 % 60;
Michal Vasko43297a02021-05-19 11:12:37 +02001709 sprintf(zoneshift, "%+03d:%02d", zonediff_h, zonediff_m);
1710
1711 /* print */
1712 if (asprintf(str, "%04d-%02d-%02dT%02d:%02d:%02d%s%s%s",
1713 tm.tm_year + 1900, tm.tm_mon + 1, tm.tm_mday, tm.tm_hour, tm.tm_min, tm.tm_sec,
1714 fractions_s ? "." : "", fractions_s ? fractions_s : "", zoneshift) == -1) {
1715 return LY_EMEM;
1716 }
1717
1718 return LY_SUCCESS;
1719}
1720
Jan Kundrátc53a7ec2021-12-09 16:01:19 +01001721LIBYANG_API_DEF LY_ERR
Michal Vasko43297a02021-05-19 11:12:37 +02001722ly_time_str2ts(const char *value, struct timespec *ts)
1723{
1724 LY_ERR rc;
Michal Vasko72975062021-08-25 08:13:04 +02001725 char *fractions_s, frac_buf[10];
Michal Vasko43297a02021-05-19 11:12:37 +02001726 int frac_len;
1727
1728 LY_CHECK_ARG_RET(NULL, value, ts, LY_EINVAL);
1729
1730 rc = ly_time_str2time(value, &ts->tv_sec, &fractions_s);
1731 LY_CHECK_RET(rc);
1732
1733 /* convert fractions of a second to nanoseconds */
1734 if (fractions_s) {
Michal Vasko72975062021-08-25 08:13:04 +02001735 /* init frac_buf with zeroes */
1736 memset(frac_buf, '0', 9);
1737 frac_buf[9] = '\0';
1738
Michal Vasko43297a02021-05-19 11:12:37 +02001739 frac_len = strlen(fractions_s);
1740 memcpy(frac_buf, fractions_s, frac_len > 9 ? 9 : frac_len);
1741 ts->tv_nsec = atol(frac_buf);
1742 free(fractions_s);
1743 } else {
1744 ts->tv_nsec = 0;
1745 }
1746
1747 return LY_SUCCESS;
1748}
1749
Jan Kundrátc53a7ec2021-12-09 16:01:19 +01001750LIBYANG_API_DEF LY_ERR
Michal Vasko43297a02021-05-19 11:12:37 +02001751ly_time_ts2str(const struct timespec *ts, char **str)
1752{
1753 char frac_buf[10];
1754
Jan Kundrátbd157002021-08-30 14:02:22 +02001755 LY_CHECK_ARG_RET(NULL, ts, str, ((ts->tv_nsec <= 999999999) && (ts->tv_nsec >= 0)), LY_EINVAL);
Michal Vasko43297a02021-05-19 11:12:37 +02001756
1757 /* convert nanoseconds to fractions of a second */
1758 if (ts->tv_nsec) {
1759 sprintf(frac_buf, "%09ld", ts->tv_nsec);
1760 }
1761
1762 return ly_time_time2str(ts->tv_sec, ts->tv_nsec ? frac_buf : NULL, str);
1763}