libyang2 and libyang3

wrappers/C macro to be able to compile with both versions.

Signed-off-by: Vincent Jardin <[email protected]>

Author: vjardin

lib/mgmt_be_client.c

@@ -342,7 +342,14 @@ static int mgmt_be_send_notification(void *__be_client, const char *xpath,
 	if (err) {
 		flog_err(EC_LIB_LIBYANG,
 			 "%s: error creating notification data: %s", __func__,
-			 ly_strerrcode(err));
+#if defined(HAVE_LY_STRERRCODE)
+			 ly_strerrcode(err)
+#elif defined(HAVE_LY_STRERR)
+			 ly_strerr(err)
+#else
+#error missing ly_strerror()
+#endif
+		);
 		ret = 1;
 		goto done;
 	}

lib/northbound.c

@@ -2134,7 +2134,15 @@ int nb_notification_send(const char *xpath, struct list *arguments)
 lyerr:
 			flog_err(EC_LIB_LIBYANG,
 				 "%s: error creating notification data: %s",
-				 __func__, ly_strerrcode(err));
+				 __func__,
+#if defined(HAVE_LY_STRERRCODE)
+				 ly_strerrcode(err)
+#elif defined(HAVE_LY_STRERR)
+				 ly_strerr(err)
+#else
+#error missing ly_strerror()
+#endif
+			);
 			ret += 1;
 			goto done;
 		}

lib/northbound_cli.c

@@ -16,6 +16,7 @@
 #include "termtable.h"
 #include "db.h"
 #include "debug.h"
+#include <libyang/version.h>
 #include "yang_translator.h"
 #include "northbound.h"
 #include "northbound_cli.h"
@@ -1434,7 +1435,13 @@ static int nb_cli_oper_data_cb(const struct lysc_node *snode,
 			     LYD_NEW_PATH_UPDATE, &dnode);
 	if (err) {
 		flog_warn(EC_LIB_LIBYANG, "%s: lyd_new_path(%s) failed: %s",
-			  __func__, data->xpath, ly_errmsg(ly_native_ctx));
+			  __func__, data->xpath,
+#if (LY_VERSION_MAJOR < 3)
+			  ly_errmsg(ly_native_ctx)
+#else
+			  ly_last_logmsg()
+#endif
+		);
 		goto error;
 	}
 

lib/vty.c

@@ -39,6 +39,7 @@
 #include "libfrr.h"
 #include "frrstr.h"
 #include "lib_errors.h"
+#include <libyang/version.h>
 #include "northbound_cli.h"
 #include "printfrr.h"
 #include "json.h"
@@ -3670,15 +3671,24 @@ static ssize_t vty_mgmt_libyang_print(void *user_data, const void *buf,
 }
 
 static void vty_out_yang_error(struct vty *vty, LYD_FORMAT format,
-			       struct ly_err_item *ei)
+			       const struct ly_err_item *ei)
 {
+#if (LY_VERSION_MAJOR < 3)
+#define data_path path
+#else
+#define data_path data_path
+#endif
 	bool have_apptag = ei->apptag && ei->apptag[0] != 0;
-	bool have_path = ei->path && ei->path[0] != 0;
+	bool have_path = ei->data_path && ei->data_path[0] != 0;
 	bool have_msg = ei->msg && ei->msg[0] != 0;
 	const char *severity = NULL;
 	const char *evalid = NULL;
 	const char *ecode = NULL;
+#if (LY_VERSION_MAJOR < 3)
 	LY_ERR err = ei->no;
+#else
+	LY_ERR err = ei->err;
+#endif
 
 	if (ei->level == LY_LLERR)
 		severity = "error";
@@ -3703,7 +3713,8 @@ static void vty_out_yang_error(struct vty *vty, LYD_FORMAT format,
 			vty_out(vty, "<error-validation>%s</error-validation>\n",
 				evalid);
 		if (have_path)
-			vty_out(vty, "<error-path>%s</error-path>\n", ei->path);
+			vty_out(vty, "<error-path>%s</error-path>\n",
+				ei->data_path);
 		if (have_apptag)
 			vty_out(vty, "<error-app-tag>%s</error-app-tag>\n",
 				ei->apptag);
@@ -3722,7 +3733,7 @@ static void vty_out_yang_error(struct vty *vty, LYD_FORMAT format,
 		if (evalid)
 			vty_out(vty, ", \"error-validation\": \"%s\"", evalid);
 		if (have_path)
-			vty_out(vty, ", \"error-path\": \"%s\"", ei->path);
+			vty_out(vty, ", \"error-path\": \"%s\"", ei->data_path);
 		if (have_apptag)
 			vty_out(vty, ", \"error-app-tag\": \"%s\"", ei->apptag);
 		if (have_msg)
@@ -3739,18 +3750,19 @@ static void vty_out_yang_error(struct vty *vty, LYD_FORMAT format,
 		if (evalid)
 			vty_out(vty, " invalid: %s", evalid);
 		if (have_path)
-			vty_out(vty, " path: %s", ei->path);
+			vty_out(vty, " path: %s", ei->data_path);
 		if (have_apptag)
 			vty_out(vty, " app-tag: %s", ei->apptag);
 		if (have_msg)
 			vty_out(vty, " msg: %s", ei->msg);
 		break;
 	}
+#undef data_path
 }
 
 static uint vty_out_yang_errors(struct vty *vty, LYD_FORMAT format)
 {
-	struct ly_err_item *ei = ly_err_first(ly_native_ctx);
+	const struct ly_err_item *ei = ly_err_first(ly_native_ctx);
 	uint count;
 
 	if (!ei)

lib/yang.c

@@ -11,6 +11,7 @@
 #include "lib_errors.h"
 #include "yang.h"
 #include "yang_translator.h"
+#include <libyang/version.h>
 #include "northbound.h"
 
 #include "lib/config_paths.h"
@@ -701,7 +702,12 @@ struct yang_data *yang_data_list_find(const struct list *list,
 }
 
 /* Make libyang log its errors using FRR logging infrastructure. */
-static void ly_log_cb(LY_LOG_LEVEL level, const char *msg, const char *path)
+static void ly_zlog_cb(LY_LOG_LEVEL level, const char *msg, const char *data_path
+#if !(LY_VERSION_MAJOR < 3)
+		       ,
+		       const char *schema_path, uint64_t line
+#endif
+)
 {
 	int priority = LOG_ERR;
 
@@ -718,8 +724,14 @@ static void ly_log_cb(LY_LOG_LEVEL level, const char *msg, const char *path)
 		break;
 	}
 
-	if (path)
-		zlog(priority, "libyang: %s (%s)", msg, path);
+	if (data_path)
+		zlog(priority, "libyang: %s (%s)", msg, data_path);
+#if !(LY_VERSION_MAJOR < 3)
+	else if (schema_path)
+		zlog(priority, "libyang %s (%s)\n", msg, schema_path);
+	else if (line)
+		zlog(priority, "libyang %s (line %" PRIu64 ")\n", msg, line);
+#endif
 	else
 		zlog(priority, "libyang: %s", msg);
 }
@@ -734,21 +746,38 @@ LY_ERR yang_parse_notification(const char *xpath, LYD_FORMAT format,
 
 	err = ly_in_new_memory(data, &in);
 	if (err) {
+#if (LY_VERSION_MAJOR < 3)
 		zlog_err("Failed to initialize ly_in: %s", ly_last_errmsg());
+#else
+		zlog_err("Failed to initialize ly_in: %s", ly_last_logmsg());
+#endif
 		return err;
 	}
 
 	err = lyd_parse_op(ly_native_ctx, NULL, in, format, LYD_TYPE_NOTIF_YANG,
 			   &tree, NULL);
 	ly_in_free(in, 0);
 	if (err) {
+#if (LY_VERSION_MAJOR < 3)
 		zlog_err("Failed to parse notification: %s", ly_last_errmsg());
+#else
+		zlog_err("Failed to parse notification: %s", ly_last_logmsg());
+#endif
 		return err;
 	}
 
+#if (LY_VERSION_MAJOR < 3)
 	err = lyd_find_xpath3(NULL, tree, xpath, NULL, &set);
+#else
+	err = lyd_find_xpath3(NULL, tree, xpath, LY_VALUE_JSON, NULL, NULL,
+			      &set);
+#endif
 	if (err) {
+#if (LY_VERSION_MAJOR < 3)
 		zlog_err("Failed to parse notification: %s", ly_last_errmsg());
+#else
+		zlog_err("Failed to parse notification: %s", ly_last_logmsg());
+#endif
 		lyd_free_all(tree);
 		return err;
 	}
@@ -778,7 +807,11 @@ LY_ERR yang_print_tree_append(uint8_t **darr, const struct lyd_node *root,
 
 	err = lyd_print_clb(yang_print_darr, darr, root, format, options);
 	if (err)
+#if (LY_VERSION_MAJOR < 3)
 		zlog_err("Failed to save yang tree: %s", ly_last_errmsg());
+#else
+		zlog_err("Failed to save yang tree: %s", ly_last_logmsg());
+#endif
 	else if (format != LYD_LYB)
 		*darr_append(*darr) = 0;
 	return err;
@@ -819,7 +852,12 @@ char *yang_convert_lyd_format(const char *data, size_t data_len,
 	if (err) {
 		flog_err_sys(EC_LIB_LIBYANG,
 			     "cannot parse input data to convert: %s",
-			     ly_last_errmsg());
+#if (LY_VERSION_MAJOR < 3)
+			     ly_last_errmsg()
+#else
+			     ly_last_logmsg()
+#endif
+		);
 		return NULL;
 	}
 
@@ -839,23 +877,29 @@ char *yang_convert_lyd_format(const char *data, size_t data_len,
 
 const char *yang_print_errors(struct ly_ctx *ly_ctx, char *buf, size_t buf_len)
 {
-	struct ly_err_item *ei;
+	const struct ly_err_item *ei;
 
 	ei = ly_err_first(ly_ctx);
 	if (!ei)
 		return "";
 
 	strlcpy(buf, "YANG error(s):\n", buf_len);
+#if (LY_VERSION_MAJOR < 3)
+#define data_path path
+#else
+#define data_path data_path
+#endif
 	for (; ei; ei = ei->next) {
-		if (ei->path) {
+		if (ei->data_path) {
 			strlcat(buf, " Path: ", buf_len);
-			strlcat(buf, ei->path, buf_len);
+			strlcat(buf, ei->data_path, buf_len);
 			strlcat(buf, "\n", buf_len);
 		}
 		strlcat(buf, " Error: ", buf_len);
 		strlcat(buf, ei->msg, buf_len);
 		strlcat(buf, "\n", buf_len);
 	}
+#undef data_path
 
 	ly_err_clean(ly_ctx, NULL);
 
@@ -907,7 +951,12 @@ struct ly_ctx *yang_ctx_new_setup(bool embedded_modules, bool explicit_compile)
 void yang_init(bool embedded_modules, bool defer_compile)
 {
 	/* Initialize libyang global parameters that affect all containers. */
-	ly_set_log_clb(ly_log_cb, 1);
+	ly_set_log_clb(ly_zlog_cb
+#if (LY_VERSION_MAJOR < 3)
+		       ,
+		       1
+#endif
+	);
 	ly_log_options(LY_LOLOG | LY_LOSTORE);
 
 	/* Initialize libyang container for native models. */
@@ -926,7 +975,12 @@ void yang_init_loading_complete(void)
 	if (ly_ctx_compile(ly_native_ctx) != LY_SUCCESS) {
 		flog_err(EC_LIB_YANG_MODULE_LOAD,
 			 "%s: failed to compile loaded modules: %s", __func__,
-			 ly_errmsg(ly_native_ctx));
+#if (LY_VERSION_MAJOR < 3)
+			 ly_errmsg(ly_native_ctx)
+#else
+			 ly_last_logmsg()
+#endif
+		);
 		exit(1);
 	}
 }
@@ -1219,7 +1273,12 @@ LY_ERR yang_lyd_trim_xpath(struct lyd_node **root, const char *xpath)
 
 	*root = lyd_first_sibling(*root);
 
+#if (LY_VERSION_MAJOR < 3)
 	err = lyd_find_xpath3(NULL, *root, xpath, NULL, &set);
+#else
+	err = lyd_find_xpath3(NULL, *root, xpath, LY_VALUE_JSON, NULL, NULL,
+			      &set);
+#endif
 	if (err) {
 		flog_err_sys(EC_LIB_LIBYANG,
 			     "cannot obtain specific result for xpath \"%s\": %s",