experiments/clixon
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Add username when reading and subscribing streams

Browse source
This commit is contained in:
Mico Micic 2024-09-02 10:10:39 +02:00 • committed by Olof Hagsand
parent 5af422f09b
commit f5372fb124
1 changed files with 13 additions and 5 deletions
Download patch file Download diff file Expand all files Collapse all files

18
apps/snmp/snmp_stream.c
View file

@ -358,8 +358,12 @@ snmp_stream_subscribe(clixon_handle h,
clixon_err(OE_SNMP, errno, "cbuf_new"); clixon_err(OE_SNMP, errno, "cbuf_new");
goto done; goto done;
} }
cprintf(cb, "<rpc xmlns=\"%s\" %s><create-subscription xmlns=\"%s\"><stream>%s</stream>", cprintf(cb, "<rpc xmlns=\"%s\" username=\"%s\" %s><create-subscription xmlns=\"%s\"><stream>%s</stream>",
NETCONF_BASE_NAMESPACE, NETCONF_MESSAGE_ID_ATTR, EVENT_RFC5277_NAMESPACE, stream); NETCONF_BASE_NAMESPACE,
clicon_username_get(h),
NETCONF_MESSAGE_ID_ATTR,
EVENT_RFC5277_NAMESPACE,
stream);
cprintf(cb, "</create-subscription></rpc>]]>]]>"); cprintf(cb, "</create-subscription></rpc>]]>]]>");
if (clicon_rpc_netconf(h, cbuf_get(cb), &xret, &s) < 0) if (clicon_rpc_netconf(h, cbuf_get(cb), &xret, &s) < 0)
goto done; goto done;
@ -421,9 +425,13 @@ get_all_streams_from_backend(clixon_handle h,
clixon_err(OE_SNMP, errno, "cbuf_new"); clixon_err(OE_SNMP, errno, "cbuf_new");
goto done; goto done;
} }
/* get alle streams from backend */ /* get all streams from backend */
cprintf(cb, "<rpc xmlns=\"%s\" %s><get><filter type=\"subtree\"><netconf xmlns=\"%s\"><streams/></netconf></filter></get></rpc>]]>]]>", cprintf(cb, "<rpc xmlns=\"%s\" username=\"%s\" %s><get><filter type=\"subtree\">"
NETCONF_BASE_NAMESPACE, NETCONF_MESSAGE_ID_ATTR, EVENT_RFC5277_NAMESPACE); "<netconf xmlns=\"%s\"><streams/></netconf></filter></get></rpc>]]>]]>",
NETCONF_BASE_NAMESPACE,
clicon_username_get(h),
NETCONF_MESSAGE_ID_ATTR,
EVENT_RFC5277_NAMESPACE);
if (clicon_rpc_netconf(h, cbuf_get(cb), &xret, NULL) < 0) if (clicon_rpc_netconf(h, cbuf_get(cb), &xret, NULL) < 0)
goto done; goto done;
if ((xe = xpath_first(xret, NULL, "rpc-reply/rpc-error")) != NULL) if ((xe = xpath_first(xret, NULL, "rpc-reply/rpc-error")) != NULL)