+ return ret;
+}
+
+static char *
+ubus_cli_get_monitor_data(struct blob_attr *data)
+{
+ static const struct blob_attr_info policy[UBUS_ATTR_MAX] = {
+ [UBUS_ATTR_STATUS] = { .type = BLOB_ATTR_INT32 },
+ [UBUS_ATTR_OBJPATH] = { .type = BLOB_ATTR_STRING },
+ [UBUS_ATTR_OBJID] = { .type = BLOB_ATTR_INT32 },
+ [UBUS_ATTR_METHOD] = { .type = BLOB_ATTR_STRING },
+ [UBUS_ATTR_OBJTYPE] = { .type = BLOB_ATTR_INT32 },
+ [UBUS_ATTR_SIGNATURE] = { .type = BLOB_ATTR_NESTED },
+ [UBUS_ATTR_DATA] = { .type = BLOB_ATTR_NESTED },
+ [UBUS_ATTR_ACTIVE] = { .type = BLOB_ATTR_INT8 },
+ [UBUS_ATTR_NO_REPLY] = { .type = BLOB_ATTR_INT8 },
+ [UBUS_ATTR_USER] = { .type = BLOB_ATTR_STRING },
+ [UBUS_ATTR_GROUP] = { .type = BLOB_ATTR_STRING },
+ };
+ static const char * const names[UBUS_ATTR_MAX] = {
+ [UBUS_ATTR_STATUS] = "status",
+ [UBUS_ATTR_OBJPATH] = "objpath",
+ [UBUS_ATTR_OBJID] = "objid",
+ [UBUS_ATTR_METHOD] = "method",
+ [UBUS_ATTR_OBJTYPE] = "objtype",
+ [UBUS_ATTR_SIGNATURE] = "signature",
+ [UBUS_ATTR_DATA] = "data",
+ [UBUS_ATTR_ACTIVE] = "active",
+ [UBUS_ATTR_NO_REPLY] = "no_reply",
+ [UBUS_ATTR_USER] = "user",
+ [UBUS_ATTR_GROUP] = "group",
+ };
+ struct blob_attr *tb[UBUS_ATTR_MAX];
+ int i;
+
+ blob_buf_init(&b, 0);
+ blob_parse(data, tb, policy, UBUS_ATTR_MAX);
+
+ for (i = 0; i < UBUS_ATTR_MAX; i++) {
+ const char *n = names[i];
+ struct blob_attr *v = tb[i];
+
+ if (!tb[i] || !n)
+ continue;
+
+ switch(policy[i].type) {
+ case BLOB_ATTR_INT32:
+ blobmsg_add_u32(&b, n, blob_get_int32(v));
+ break;
+ case BLOB_ATTR_STRING:
+ blobmsg_add_string(&b, n, blob_data(v));
+ break;
+ case BLOB_ATTR_INT8:
+ blobmsg_add_u8(&b, n, !!blob_get_int8(v));
+ break;
+ case BLOB_ATTR_NESTED:
+ blobmsg_add_field(&b, BLOBMSG_TYPE_TABLE, n, blobmsg_data(v), blobmsg_data_len(v));