1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
|
/**
@file rexmpp_pubsub.c
@brief XEP-0060 helper functions
@author defanor <defanor@uberspace.net>
@date 2021
@copyright MIT license.
*/
#include "rexmpp.h"
void
rexmpp_pubsub_iq (rexmpp_t *s,
const char *iq_type,
const char *pubsub_namespace,
const char *service_jid,
xmlNodePtr payload,
rexmpp_iq_callback_t callback,
void *cb_data)
{
xmlNodePtr pubsub = xmlNewNode(NULL, "pubsub");
if (pubsub_namespace == NULL) {
xmlNewNs(pubsub, "http://jabber.org/protocol/pubsub", NULL);
} else {
xmlNewNs(pubsub, pubsub_namespace, NULL);
}
xmlAddChild(pubsub, payload);
rexmpp_iq_new(s, iq_type, service_jid, pubsub, callback, cb_data);
}
void
rexmpp_pubsub_item_publish (rexmpp_t *s,
const char *service_jid,
const char *node,
const char *item_id,
xmlNodePtr payload,
rexmpp_iq_callback_t callback,
void *cb_data)
{
xmlNodePtr item = xmlNewNode(NULL, "item");
xmlNewNs(item, "http://jabber.org/protocol/pubsub", NULL);
if (item_id != NULL) {
xmlNewProp(item, "id", item_id);
}
xmlAddChild(item, payload);
xmlNodePtr publish = xmlNewNode(NULL, "publish");
xmlNewNs(publish, "http://jabber.org/protocol/pubsub", NULL);
xmlNewProp(publish, "node", node);
xmlAddChild(publish, item);
rexmpp_pubsub_iq(s, "set", NULL, service_jid, publish, callback, cb_data);
}
void
rexmpp_pubsub_item_retract (rexmpp_t *s,
const char *service_jid,
const char *node,
const char *item_id,
rexmpp_iq_callback_t callback,
void *cb_data)
{
xmlNodePtr item = xmlNewNode(NULL, "item");
xmlNewNs(item, "http://jabber.org/protocol/pubsub", NULL);
if (item_id != NULL) {
xmlNewProp(item, "id", item_id);
}
xmlNodePtr retract = xmlNewNode(NULL, "retract");
xmlNewNs(retract, "http://jabber.org/protocol/pubsub", NULL);
xmlNewProp(retract, "node", node);
xmlAddChild(retract, item);
rexmpp_pubsub_iq(s, "set", NULL, service_jid, retract, callback, cb_data);
}
void
rexmpp_pubsub_node_delete (rexmpp_t *s,
const char *service_jid,
const char *node,
rexmpp_iq_callback_t callback,
void *cb_data)
{
xmlNodePtr delete = xmlNewNode(NULL, "delete");
xmlNewNs(delete, "http://jabber.org/protocol/pubsub#owner", NULL);
xmlNewProp(delete, "node", node);
rexmpp_pubsub_iq(s, "set", "http://jabber.org/protocol/pubsub#owner",
service_jid, delete, callback, cb_data);
}
|
