blob: c7b8ecf7ed0eea9142ff5913056ddcfe000092eb [file] [log] [blame]
/**
* @file xml.c
* @author Radek Krejci <rkrejci@cesnet.cz>
* @brief XML data parser for libyang
*
* Copyright (c) 2015 CESNET, z.s.p.o.
*
* Redistribution and use in source and binary forms, with or without
* modification, are permitted provided that the following conditions
* are met:
* 1. Redistributions of source code must retain the above copyright
* notice, this list of conditions and the following disclaimer.
* 2. Redistributions in binary form must reproduce the above copyright
* notice, this list of conditions and the following disclaimer in
* the documentation and/or other materials provided with the
* distribution.
* 3. Neither the name of the Company nor the names of its contributors
* may be used to endorse or promote products derived from this
* software without specific prior written permission.
*/
#include <assert.h>
#include <ctype.h>
#include <errno.h>
#include <stdlib.h>
#include <string.h>
#include <sys/types.h>
#include <regex.h>
#include "libyang.h"
#include "common.h"
#include "context.h"
#include "resolve.h"
#include "xml.h"
#include "tree_internal.h"
#include "validation.h"
#define LY_NSNC "urn:ietf:params:xml:ns:netconf:base:1.0"
/* kind == 0 - unsigned (unum used), 1 - signed (snum used), 2 - floating point (fnum used) */
static int
validate_length_range(uint8_t kind, uint64_t unum, int64_t snum, long double fnum, struct lys_type *type,
struct lyxml_elem *xml, const char *str_val, int log)
{
struct len_ran_intv *intv = NULL, *tmp_intv;
int ret = EXIT_FAILURE;
if (resolve_len_ran_interval(NULL, type, 0, &intv)) {
return EXIT_FAILURE;
}
if (!intv) {
return EXIT_SUCCESS;
}
for (tmp_intv = intv; tmp_intv; tmp_intv = tmp_intv->next) {
if (((kind == 0) && (unum < tmp_intv->value.uval.min))
|| ((kind == 1) && (snum < tmp_intv->value.sval.min))
|| ((kind == 2) && (fnum < tmp_intv->value.fval.min))) {
break;
}
if (((kind == 0) && (unum >= tmp_intv->value.uval.min) && (unum <= tmp_intv->value.uval.max))
|| ((kind == 1) && (snum >= tmp_intv->value.sval.min) && (snum <= tmp_intv->value.sval.max))
|| ((kind == 2) && (fnum >= tmp_intv->value.fval.min) && (fnum <= tmp_intv->value.fval.max))) {
ret = EXIT_SUCCESS;
break;
}
}
while (intv) {
tmp_intv = intv->next;
free(intv);
intv = tmp_intv;
}
if (ret && log) {
/* so that it's used even in RELEASE target */
(void)xml;
LOGVAL(LYE_OORVAL, LOGLINE(xml), str_val);
}
return ret;
}
static int
validate_pattern(const char *str, struct lys_type *type, struct lyxml_elem *xml, const char *str_val, int log)
{
int i;
regex_t preq;
char *posix_regex;
assert(type->base == LY_TYPE_STRING);
if (type->der && validate_pattern(str, &type->der->type, xml, str_val, log)) {
return EXIT_FAILURE;
}
for (i = 0; i < type->info.str.pat_count; ++i) {
/*
* adjust the expression to a POSIX.2 equivalent
*
* http://www.w3.org/TR/2004/REC-xmlschema-2-20041028/#regexs
*/
posix_regex = malloc((strlen(type->info.str.patterns[i].expr)+3) * sizeof(char));
posix_regex[0] = '\0';
if (strncmp(type->info.str.patterns[i].expr, ".*", 2)) {
strcat(posix_regex, "^");
}
strcat(posix_regex, type->info.str.patterns[i].expr);
if (strncmp(type->info.str.patterns[i].expr
+ strlen(type->info.str.patterns[i].expr) - 2, ".*", 2)) {
strcat(posix_regex, "$");
}
/* must return 0, already checked during parsing */
if (regcomp(&preq, posix_regex, REG_EXTENDED | REG_NOSUB)) {
LOGINT;
free(posix_regex);
return EXIT_FAILURE;
}
free(posix_regex);
if (regexec(&preq, str, 0, 0, 0)) {
regfree(&preq);
if (log) {
LOGVAL(LYE_INVAL, LOGLINE(xml), str_val, xml->name);
}
return EXIT_FAILURE;
}
regfree(&preq);
}
return EXIT_SUCCESS;
}
static struct lys_node *
xml_data_search_schemanode(struct lyxml_elem *xml, struct lys_node *start)
{
struct lys_node *result, *aux;
LY_TREE_FOR(start, result) {
/* skip groupings */
if (result->nodetype == LYS_GROUPING) {
continue;
}
/* go into cases, choices, uses */
if (result->nodetype & (LYS_CHOICE | LYS_CASE | LYS_USES)) {
aux = xml_data_search_schemanode(xml, result->child);
if (aux) {
/* we have matching result */
return aux;
}
/* else, continue with next schema node */
continue;
}
/* match data nodes */
if (result->name == xml->name) {
/* names matches, what about namespaces? */
if (result->module->ns == xml->ns->value) {
/* we have matching result */
return result;
}
/* else, continue with next schema node */
continue;
}
}
/* no match */
return NULL;
}
static int
parse_int(const char *str_val, struct lyxml_elem *xml, int64_t min, int64_t max, int base, int64_t *ret, int log)
{
char *strptr;
/* convert to 64-bit integer, all the redundant characters are handled */
errno = 0;
strptr = NULL;
*ret = strtoll(str_val, &strptr, base);
if (errno || (*ret < min) || (*ret > max)) {
if (log) {
LOGVAL(LYE_OORVAL, LOGLINE(xml), str_val, xml->name);
}
return EXIT_FAILURE;
} else if (strptr && *strptr) {
while (isspace(*strptr)) {
++strptr;
}
if (*strptr) {
if (log) {
LOGVAL(LYE_INVAL, LOGLINE(xml), str_val, xml->name);
}
return EXIT_FAILURE;
}
}
return EXIT_SUCCESS;
}
static int
parse_uint(const char *str_val, struct lyxml_elem *xml, uint64_t max, int base, uint64_t *ret, int log)
{
char *strptr;
errno = 0;
strptr = NULL;
*ret = strtoull(str_val, &strptr, base);
if (errno || (*ret > max)) {
if (log) {
LOGVAL(LYE_OORVAL, LOGLINE(xml), str_val, xml->name);
}
return EXIT_FAILURE;
} else if (strptr && *strptr) {
while (isspace(*strptr)) {
++strptr;
}
if (*strptr) {
if (log) {
LOGVAL(LYE_INVAL, LOGLINE(xml), str_val, xml->name);
}
return EXIT_FAILURE;
}
}
return EXIT_SUCCESS;
}
static struct lys_type *
get_next_union_type(struct lys_type *type, struct lys_type *prev_type, int *found)
{
int i;
struct lys_type *ret = NULL;
for (i = 0; i < type->info.uni.count; ++i) {
if (type->info.uni.types[i].base == LY_TYPE_UNION) {
ret = get_next_union_type(&type->info.uni.types[i], prev_type, found);
if (ret) {
break;;
}
continue;
}
if (!prev_type || *found) {
ret = &type->info.uni.types[i];
break;
}
if (&type->info.uni.types[i] == prev_type) {
*found = 1;
}
}
if (!ret && type->der) {
ret = get_next_union_type(&type->der->type, prev_type, found);
}
return ret;
}
static const char *
instid_xml2json(struct ly_ctx *ctx, struct lyxml_elem *xml)
{
const char *in = xml->content;
char *out, *aux, *prefix;
size_t out_size, len, size, i = 0, o = 0;
int start = 1, interior = 1;
struct lys_module *mod, *mod_prev = NULL;
struct lyxml_ns *ns;
out_size = strlen(in);
out = malloc((out_size + 1) * sizeof *out);
while (in[i]) {
/* skip whitespaces */
while (isspace(in[i])) {
i++;
}
if (start) {
/* leading '/' character */
if (start == 1 && in[i] != '/') {
LOGVAL(LYE_INCHAR, LOGLINE(xml), in[i], &in[i]);
free(out);
return NULL;
}
/* check the output buffer size */
if (out_size == o) {
out_size += 16; /* just add some size */
aux = realloc(out, out_size + 1);
if (!aux) {
free(out);
LOGMEM;
return NULL;
}
out = aux;
}
out[o++] = in[i++];
start = 0;
continue;
} else {
/* translate the node identifier */
/* prefix */
aux = strchr(&in[i], ':');
if (aux) {
/* interior segment */
len = aux - &in[i];
prefix = strndup(&in[i], len);
i += len + 1; /* move after ':' */
} else {
/* missing prefix -> invalid instance-identifier */
LOGVAL(LYE_INVAL, LOGLINE(xml), xml->content, xml->name);
free(out);
return NULL;
}
ns = lyxml_get_ns(xml, prefix);
free(prefix);
mod = ly_ctx_get_module_by_ns(ctx, ns->value, NULL);
/* node name */
aux = strpbrk(&in[i], "/[=");
if (aux) {
/* interior segment */
len = aux - &in[i];
} else {
/* end segment */
interior = 0;
len = strlen(&in[i]);
}
/* check the output buffer size */
if (!mod_prev || (mod != mod_prev)) {
/* prefix + ':' + name to print + '/' */
size = o + len + 1 + strlen(mod->name) + interior;
} else {
/* name to print + '/' */
size = o + len + interior;
}
if (out_size <= size) {
/* extend to fit the needed size */
out_size = size;
aux = realloc(out, out_size + 1);
if (!aux) {
free(out);
LOGMEM;
return NULL;
}
out = aux;
}
if (!mod_prev || (mod != mod_prev)) {
mod_prev = mod;
size = strlen(mod->name);
memcpy(&out[o], mod->name, size);
o += size;
out[o++] = ':';
}
memcpy(&out[o], &in[i], len);
o += len;
i += len;
if (in[i] == '=') {
/* we are in the predicate on the value, so just copy data */
aux = strchr(&in[i], ']');
if (aux) {
len = aux - &in[i] + 1; /* include ] */
/* check the output buffer size */
size = o + len + 1;
if (out_size <= size) {
out_size = size; /* just add some size */
aux = realloc(out, out_size + 1);
if (!aux) {
free(out);
LOGMEM;
return NULL;
}
out = aux;
}
memcpy(&out[o], &in[i], len);
o += len;
i += len;
} else {
/* missing closing ] of predicate -> invalid instance-identifier */
LOGVAL(LYE_INVAL, LOGLINE(xml), xml->content, xml->name);
free(out);
return NULL;
}
}
start = 2;
}
}
/* terminating NULL byte */
/* check the output buffer size */
if (out_size < o) {
out_size += 1; /* just add some size */
aux = realloc(out, out_size + 1);
if (!aux) {
free(out);
LOGMEM;
return NULL;
}
out = aux;
}
out[o] = '\0';
return lydict_insert_zc(ctx, out);
}
static int
_xml_get_value(struct lyd_node *node, struct lys_type *node_type, struct lyxml_elem *xml,
int options, struct unres_data **unres, int log)
{
#define DECSIZE 21
struct lyd_node_leaf *leaf = (struct lyd_node_leaf *)node;
struct lys_type *type;
struct lyxml_ns *ns;
char dec[DECSIZE];
char *strptr;
const char *name;
int64_t num;
uint64_t unum;
int len;
int c, i, j, d;
int found;
struct unres_data *new_unres;
leaf->value_str = xml->content;
xml->content = NULL;
/* will be change in case of union */
leaf->value_type = node_type->base;
if ((options & LYD_OPT_FILTER) && !leaf->value_str) {
/* no value in filter (selection) node -> nothing more is needed */
return EXIT_SUCCESS;
}
switch (node_type->base) {
case LY_TYPE_BINARY:
leaf->value.binary = leaf->value_str;
if (node_type->info.binary.length
&& validate_length_range(0, strlen(leaf->value.binary), 0, 0, node_type, xml, leaf->value_str, log)) {
return EXIT_FAILURE;
}
break;
case LY_TYPE_BITS:
/* locate bits structure with the bits definitions */
for (type = node_type; type->der->type.der; type = &type->der->type);
/* allocate the array of pointers to bits definition */
leaf->value.bit = calloc(type->info.bits.count, sizeof *leaf->value.bit);
if (!leaf->value_str) {
/* no bits set */
break;
}
c = 0;
i = 0;
while (leaf->value_str[c]) {
/* skip leading whitespaces */
while(isspace(leaf->value_str[c])) {
c++;
}
/* get the length of the bit identifier */
for (len = 0; leaf->value_str[c] && !isspace(leaf->value_str[c]); c++, len++);
/* go back to the beginning of the identifier */
c = c - len;
/* find bit definition, identifiers appear ordered by their posititon */
for (found = 0; i < type->info.bits.count; i++) {
if (!strncmp(type->info.bits.bit[i].name, &leaf->value_str[c], len)
&& !type->info.bits.bit[i].name[len]) {
/* we have match, store the pointer */
leaf->value.bit[i] = &type->info.bits.bit[i];
/* stop searching */
i++;
found = 1;
break;
}
}
if (!found) {
/* referenced bit value does not exists */
if (log) {
LOGVAL(LYE_INVAL, LOGLINE(xml), leaf->value_str, xml->name);
}
return EXIT_FAILURE;
}
c = c + len;
}
break;
case LY_TYPE_BOOL:
if (!strcmp(leaf->value_str, "true")) {
leaf->value.bool = 1;
} /* else false, so keep it zero */
break;
case LY_TYPE_DEC64:
/* locate dec64 structure with the fraction-digits value */
for (type = node_type; type->der->type.der; type = &type->der->type);
for (c = 0; isspace(leaf->value_str[c]); c++);
for (len = 0; leaf->value_str[c] && !isspace(leaf->value_str[c]); c++, len++);
c = c - len;
if (len > DECSIZE) {
/* too long */
if (log) {
LOGVAL(LYE_INVAL, LOGLINE(xml), leaf->value_str, xml->name);
}
return EXIT_FAILURE;
}
/* normalize the number */
dec[0] = '\0';
for (i = j = d = found = 0; i < DECSIZE; i++) {
if (leaf->value_str[c + i] == '.') {
found = 1;
j = type->info.dec64.dig;
i--;
c++;
continue;
}
if (leaf->value_str[c + i] == '\0') {
c--;
if (!found) {
j = type->info.dec64.dig;
found = 1;
}
if (!j) {
dec[i] = '\0';
break;
}
d++;
if (d > DECSIZE - 2) {
if (log) {
LOGVAL(LYE_OORVAL, LOGLINE(xml), leaf->value_str, xml->name);
}
return EXIT_FAILURE;
}
dec[i] = '0';
} else {
if (!isdigit(leaf->value_str[c + i])) {
if (i || leaf->value_str[c] != '-') {
if (log) {
LOGVAL(LYE_INVAL, LOGLINE(xml), leaf->value_str, xml->name);
}
return EXIT_FAILURE;
}
} else {
d++;
}
if (d > DECSIZE - 2 || (found && !j)) {
if (log) {
LOGVAL(LYE_OORVAL, LOGLINE(xml), leaf->value_str, xml->name);
}
return EXIT_FAILURE;
}
dec[i] = leaf->value_str[c + i];
}
if (j) {
j--;
}
}
if (parse_int(dec, xml, -9223372036854775807L - 1L, 9223372036854775807L, 10, &num, log)
|| validate_length_range(2, 0, 0, ((long double)num)/(1 << type->info.dec64.dig), node_type, xml, leaf->value_str, log)) {
return EXIT_FAILURE;
}
leaf->value.dec64 = num;
break;
case LY_TYPE_EMPTY:
/* just check that it is empty */
if (leaf->value_str && leaf->value_str[0]) {
if (log) {
LOGVAL(LYE_INVAL, LOGLINE(xml), leaf->value_str, xml->name);
}
return EXIT_FAILURE;
}
break;
case LY_TYPE_ENUM:
if (!leaf->value_str) {
if (log) {
LOGVAL(LYE_INVAL, LOGLINE(xml), "", xml->name);
}
return EXIT_FAILURE;
}
/* locate enums structure with the enumeration definitions */
for (type = node_type; type->der->type.der; type = &type->der->type);
/* find matching enumeration value */
for (i = 0; i < type->info.enums.count; i++) {
if (!strcmp(leaf->value_str, type->info.enums.enm[i].name)) {
/* we have match, store pointer to the definition */
leaf->value.enm = &type->info.enums.enm[i];
break;
}
}
if (!leaf->value.enm) {
if (log) {
LOGVAL(LYE_INVAL, LOGLINE(xml), leaf->value_str, xml->name);
}
return EXIT_FAILURE;
}
break;
case LY_TYPE_IDENT:
if ((strptr = strchr(leaf->value_str, ':'))) {
len = strptr - leaf->value_str;
if (!len) {
if (log) {
LOGVAL(LYE_INVAL, LOGLINE(xml), leaf->value_str, xml->name);
}
return EXIT_FAILURE;
}
strptr = strndup(leaf->value_str, len);
}
ns = lyxml_get_ns(xml, strptr);
if (!ns) {
if (log) {
LOGVAL(LYE_INVAL, LOGLINE(xml), leaf->value_str, xml->name);
}
return EXIT_FAILURE;
}
if (strptr) {
free(strptr);
name = leaf->value_str + len + 1;
} else {
name = leaf->value_str;
}
leaf->value.ident = resolve_identityref(node_type->info.ident.ref, name, ns->value);
if (!leaf->value.ident) {
if (log) {
LOGVAL(LYE_INVAL, LOGLINE(xml), leaf->value_str, xml->name);
}
return EXIT_FAILURE;
}
break;
case LY_TYPE_INST:
if (!leaf->value_str) {
if (log) {
LOGVAL(LYE_INVAL, LOGLINE(xml), "", xml->name);
}
return EXIT_FAILURE;
}
/* convert the path from the XML form using XML namespaces into the JSON format
* using module names as namespaces
*/
xml->content = leaf->value_str;
leaf->value_str = instid_xml2json(node->schema->module->ctx, xml);
lydict_remove(node->schema->module->ctx, xml->content);
xml->content = NULL;
if (!leaf->value_str) {
return EXIT_FAILURE;
}
if (options & (LYD_OPT_EDIT | LYD_OPT_FILTER)) {
leaf->value_type |= LY_TYPE_INST_UNRES;
} else {
/* validity checking is performed later, right now the data tree
* is not complete, so many instanceids cannot be resolved
*/
/* remember the leaf for later checking */
new_unres = malloc(sizeof *new_unres);
new_unres->is_leafref = 0;
new_unres->dnode = node;
new_unres->next = *unres;
#ifndef NDEBUG
new_unres->line = LOGLINE(xml);
#endif
*unres = new_unres;
}
break;
case LY_TYPE_LEAFREF:
if (!leaf->value_str) {
if (log) {
LOGVAL(LYE_INVAL, LOGLINE(xml), "", xml->name);
}
return EXIT_FAILURE;
}
if (options & (LYD_OPT_EDIT | LYD_OPT_FILTER)) {
do {
type = &((struct lys_node_leaf *)leaf->schema)->type.info.lref.target->type;
} while (type->base == LY_TYPE_LEAFREF);
leaf->value_type = type->base | LY_TYPE_LEAFREF_UNRES;
} else {
/* validity checking is performed later, right now the data tree
* is not complete, so many leafrefs cannot be resolved
*/
/* remember the leaf for later checking */
new_unres = malloc(sizeof *new_unres);
new_unres->is_leafref = 1;
new_unres->dnode = node;
new_unres->next = *unres;
#ifndef NDEBUG
new_unres->line = LOGLINE(xml);
#endif
*unres = new_unres;
}
break;
case LY_TYPE_STRING:
leaf->value.string = leaf->value_str;
if (node_type->info.str.length
&& validate_length_range(0, strlen(leaf->value.string), 0, 0, node_type, xml, leaf->value_str, log)) {
return EXIT_FAILURE;
}
if (node_type->info.str.patterns
&& validate_pattern(leaf->value.string, node_type, xml, leaf->value_str, log)) {
return EXIT_FAILURE;
}
break;
case LY_TYPE_UNION:
found = 0;
type = get_next_union_type(node_type, NULL, &found);
for (; type; found = 0, type = get_next_union_type(node_type, type, &found)) {
xml->content = leaf->value_str;
if (!_xml_get_value(node, type, xml, options, unres, 0)) {
leaf->value_type = type->base;
break;
}
}
if (!type) {
if (log) {
LOGVAL(LYE_INVAL, LOGLINE(xml), leaf->value_str, xml->name);
}
return EXIT_FAILURE;
}
break;
case LY_TYPE_INT8:
if (parse_int(leaf->value_str, xml, -128, 127, 0, &num, log)
|| validate_length_range(1, 0, num, 0, node_type, xml, leaf->value_str, log)) {
return EXIT_FAILURE;
}
leaf->value.int8 = num;
break;
case LY_TYPE_INT16:
if (parse_int(leaf->value_str, xml, -32768, 32767, 0, &num, log)
|| validate_length_range(1, 0, num, 0, node_type, xml, leaf->value_str, log)) {
return EXIT_FAILURE;
}
leaf->value.int16 = num;
break;
case LY_TYPE_INT32:
if (parse_int(leaf->value_str, xml, -2147483648, 2147483647, 0, &num, log)
|| validate_length_range(1, 0, num, 0, node_type, xml, leaf->value_str, log)) {
return EXIT_FAILURE;
}
leaf->value.int32 = num;
break;
case LY_TYPE_INT64:
if (parse_int(leaf->value_str, xml, -9223372036854775807L - 1L, 9223372036854775807L, 0, &num, log)
|| validate_length_range(1, 0, num, 0, node_type, xml, leaf->value_str, log)) {
return EXIT_FAILURE;
}
leaf->value.int64 = num;
break;
case LY_TYPE_UINT8:
if (parse_uint(leaf->value_str, xml, 255, 0, &unum, log)
|| validate_length_range(0, unum, 0, 0, node_type, xml, leaf->value_str, log)) {
return EXIT_FAILURE;
}
leaf->value.uint8 = unum;
break;
case LY_TYPE_UINT16:
if (parse_uint(leaf->value_str, xml, 65535, 0, &unum, log)
|| validate_length_range(0, unum, 0, 0, node_type, xml, leaf->value_str, log)) {
return EXIT_FAILURE;
}
leaf->value.uint16 = unum;
break;
case LY_TYPE_UINT32:
if (parse_uint(leaf->value_str, xml, 4294967295, 0, &unum, log)
|| validate_length_range(0, unum, 0, 0, node_type, xml, leaf->value_str, log)) {
return EXIT_FAILURE;
}
leaf->value.uint32 = unum;
break;
case LY_TYPE_UINT64:
if (parse_uint(leaf->value_str, xml, 18446744073709551615UL, 0, &unum, log)
|| validate_length_range(0, unum, 0, 0, node_type, xml, leaf->value_str, log)) {
return EXIT_FAILURE;
}
leaf->value.uint64 = unum;
break;
default:
return EXIT_FAILURE;
}
return EXIT_SUCCESS;
}
static int
xml_get_value(struct lyd_node *node, struct lyxml_elem *xml, int options, struct unres_data **unres)
{
return _xml_get_value(node, &((struct lys_node_leaf *)node->schema)->type, xml, options, unres, 1);
}
struct lyd_node *
xml_parse_data(struct ly_ctx *ctx, struct lyxml_elem *xml, struct lyd_node *parent, struct lyd_node *prev,
int options, struct unres_data **unres)
{
struct lyd_node *result = NULL, *diter;
struct lys_node *schema = NULL, *siter;
int i, havechildren;
if (!xml) {
return NULL;
}
if (!xml->ns || !xml->ns->value) {
LOGVAL(LYE_XML_MISS, LOGLINE(xml), "element's", "namespace");
return NULL;
}
/* find schema node */
if (!parent) {
/* starting in root */
for (i = 0; i < ctx->models.used; i++) {
/* match data model based on namespace */
if (ctx->models.list[i]->ns == xml->ns->value) {
/* get the proper schema node */
LY_TREE_FOR(ctx->models.list[i]->data, schema) {
if (schema->name == xml->name) {
break;
}
}
break;
}
}
} else {
/* parsing some internal node, we start with parent's schema pointer */
schema = xml_data_search_schemanode(xml, parent->schema->child);
}
if (!schema) {
if ((options & LYD_OPT_STRICT) || ly_ctx_get_module_by_ns(ctx, xml->ns->value, NULL)) {
LOGVAL(LYE_INELEM, LOGLINE(xml), xml->name);
return NULL;
} else {
goto siblings;
}
}
switch (schema->nodetype) {
case LYS_CONTAINER:
result = calloc(1, sizeof *result);
havechildren = 1;
break;
case LYS_LEAF:
result = calloc(1, sizeof(struct lyd_node_leaf));
havechildren = 0;
break;
case LYS_LEAFLIST:
result = calloc(1, sizeof(struct lyd_node_leaflist));
havechildren = 0;
break;
case LYS_LIST:
result = calloc(1, sizeof(struct lyd_node_list));
havechildren = 1;
break;
case LYS_ANYXML:
result = calloc(1, sizeof(struct lyd_node_anyxml));
havechildren = 0;
break;
default:
LOGINT;
return NULL;
}
result->parent = parent;
result->prev = prev;
result->schema = schema;
/* check number of instances for non-list nodes */
if (!(options & LYD_OPT_FILTER) && (schema->nodetype & (LYS_CONTAINER | LYS_LEAF | LYS_ANYXML))) {
for (diter = result->prev; diter; diter = diter->prev) {
if (diter->schema == schema) {
LOGVAL(LYE_TOOMANY, LOGLINE(xml), xml->name, xml->parent ? xml->parent->name : "data tree");
goto error;
}
}
}
/* type specific processing */
if (schema->nodetype == LYS_LIST) {
/* pointers to next and previous instances of the same list */
for (diter = result->prev; diter; diter = diter->prev) {
if (diter->schema == result->schema) {
/* instances of the same list */
((struct lyd_node_list *)diter)->lnext = (struct lyd_node_list *)result;
((struct lyd_node_list *)result)->lprev = (struct lyd_node_list *)diter;
break;
}
}
} else if (schema->nodetype == LYS_LEAF) {
/* type detection and assigning the value */
if (xml_get_value(result, xml, options, unres)) {
goto error;
}
} else if (schema->nodetype == LYS_LEAFLIST) {
/* type detection and assigning the value */
if (xml_get_value(result, xml, options, unres)) {
goto error;
}
/* pointers to next and previous instances of the same leaflist */
for (diter = result->prev; diter; diter = diter->prev) {
if (diter->schema == result->schema) {
/* instances of the same list */
((struct lyd_node_leaflist *)diter)->lnext = (struct lyd_node_leaflist *)result;
((struct lyd_node_leaflist *)result)->lprev = (struct lyd_node_leaflist *)diter;
break;
}
}
} else if (schema->nodetype == LYS_ANYXML) {
((struct lyd_node_anyxml *)result)->value = xml;
lyxml_unlink_elem(xml);
}
/* process children */
if (havechildren && xml->child) {
result->child = xml_parse_data(ctx, xml->child, result, NULL, options, unres);
if (ly_errno) {
goto error;
}
}
/* various validation checks */
/* check presence of all keys in case of list */
if (schema->nodetype == LYS_LIST && !(options & LYD_OPT_FILTER)) {
siter = (struct lys_node *)lyv_keys_present((struct lyd_node_list *)result);
if (siter) {
/* key not found in the data */
LOGVAL(LYE_MISSELEM, LOGLINE(xml), siter->name, schema->name);
goto error;
}
}
/* mandatory children */
if (havechildren && !(options & (LYD_OPT_FILTER | LYD_OPT_EDIT))) {
siter = ly_check_mandatory(result);
if (siter) {
if (siter->nodetype & (LYS_LIST | LYS_LEAFLIST)) {
LOGVAL(LYE_SPEC, LOGLINE(xml), "Number of \"%s\" instances in \"%s\" does not follow min/max constraints.",
siter->name, siter->parent->name);
} else {
LOGVAL(LYE_MISSELEM, LOGLINE(xml), siter->name, siter->parent->name);
}
goto error;
}
}
siblings:
/* process siblings */
if (xml->next) {
if (result) {
result->next = xml_parse_data(ctx, xml->next, parent, result, options, unres);
} else {
result = xml_parse_data(ctx, xml->next, parent, prev, options, unres);
}
if (ly_errno) {
goto error;
}
}
/* fix the "last" pointer */
if (result && !result->prev) {
for (diter = result; diter->next; diter = diter->next);
result->prev = diter;
}
return result;
error:
if (result) {
result->next = NULL;
result->parent = NULL;
result->prev = result;
lyd_free(result);
}
return NULL;
}
static int
check_unres(struct unres_data **list)
{
struct lyd_node_leaf *leaf;
struct lys_node_leaf *sleaf;
struct unres_data *item, *refset = NULL, *ref;
while (*list) {
leaf = (struct lyd_node_leaf *)(*list)->dnode;
sleaf = (struct lys_node_leaf *)(*list)->dnode->schema;
/* resolve path and create a set of possible leafrefs (we need their values) */
if ((*list)->is_leafref) {
if (resolve_path_arg_data(*list, sleaf->type.info.lref.path, &refset)) {
LOGERR(LY_EVALID, "Leafref \"%s\" could not be resolved.", sleaf->type.info.lref.path);
goto error;
}
while (refset) {
if (leaf->value_str == ((struct lyd_node_leaf *)refset->dnode)->value_str) {
leaf->value.leafref = refset->dnode;
}
ref = refset->next;
free(refset);
refset = ref;
}
if (!leaf->value.leafref) {
/* reference not found */
LOGERR(LY_EVALID, "Leafref \"%s\" value \"%s\" did not match any node value.", sleaf->type.info.lref.path, leaf->value_str);
goto error;
}
/* instance-identifier */
} else {
ly_errno = 0;
if (!resolve_instid((*list)->dnode, leaf->value_str, LOGLINE(*list))) {
if (ly_errno) {
goto error;
} else if (sleaf->type.info.inst.req > -1) {
LOGERR(LY_EVALID, "Instance for the \"%s\" does not exist.", leaf->value_str);
goto error;
} else {
LOGVRB("Instance for the \"%s\" does not exist.", leaf->value_str);
}
}
}
item = (*list)->next;
free(*list);
*list = item;
}
return EXIT_SUCCESS;
error:
while (*list) {
item = (*list)->next;
free(*list);
*list = item;
}
return EXIT_FAILURE;
}
struct lyd_node *
xml_read_data(struct ly_ctx *ctx, const char *data, int options)
{
struct lyxml_elem *xml;
struct lyd_node *result, *next, *iter;
struct unres_data *unres = NULL;
xml = lyxml_read(ctx, data, 0);
if (!xml) {
return NULL;
}
ly_errno = 0;
result = xml_parse_data(ctx, xml->child, NULL, NULL, options, &unres);
/* check leafrefs and/or instids if any */
if (check_unres(&unres)) {
/* leafref & instid checking failed */
LY_TREE_FOR_SAFE(result, next, iter) {
lyd_free(iter);
}
result = NULL;
}
/* free source XML tree */
lyxml_free_elem(ctx, xml);
return result;
}