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
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
|
using Gee;
using Xmpp.Core;
namespace Xmpp.Xep.ServiceDiscovery {
private const string NS_URI = "http://jabber.org/protocol/disco";
public const string NS_URI_INFO = NS_URI + "#info";
public const string NS_URI_ITEMS = NS_URI + "#items";
public class Module : XmppStreamModule, Iq.Handler {
public const string ID = "0030_service_discovery_module";
public ArrayList<Identity> identities = new ArrayList<Identity>();
public Module.with_identity(string category, string type, string? name = null) {
add_identity(category, type, name);
}
public void add_feature(XmppStream stream, string feature) {
Flag.get_flag(stream).add_own_feature(feature);
}
public void add_feature_notify(XmppStream stream, string feature) {
add_feature(stream, feature + "+notify");
}
public void add_identity(string category, string type, string? name = null) {
identities.add(new Identity(category, type, name));
}
public void request_info(XmppStream stream, string jid, InfoResponseListener response_listener) {
Iq.Stanza iq = new Iq.Stanza.get(new StanzaNode.build("query", NS_URI_INFO).add_self_xmlns());
iq.to = jid;
Iq.Module.get_module(stream).send_iq(stream, iq, new IqInfoResponseListener(response_listener));
}
private class IqInfoResponseListener : Iq.ResponseListener, Object {
InfoResponseListener response_listener;
public IqInfoResponseListener(InfoResponseListener response_listener) {
this.response_listener = response_listener;
}
public void on_result(XmppStream stream, Iq.Stanza iq) {
InfoResult? result = InfoResult.create_from_iq(iq);
if (result != null) {
Flag.get_flag(stream).set_entitiy_features(iq.from, result.features);
response_listener.on_result(stream, result);
} else {
response_listener.on_error(stream, iq);
}
}
}
public void request_items(XmppStream stream, string jid, ItemsResponseListener response_listener) {
Iq.Stanza iq = new Iq.Stanza.get(new StanzaNode.build("query", NS_URI_ITEMS).add_self_xmlns());
iq.to = jid;
Iq.Module.get_module(stream).send_iq(stream, iq, new IqItemsResponseListener(response_listener));
}
private class IqItemsResponseListener : Iq.ResponseListener, Object {
ItemsResponseListener response_listener;
public IqItemsResponseListener(ItemsResponseListener response_listener) { this.response_listener = response_listener; }
public void on_result(XmppStream stream, Iq.Stanza iq) {
//response_listener.on_result(stream, new ServiceDiscoveryItemsResult.from_iq(iq));
}
}
public void on_iq_get(XmppStream stream, Iq.Stanza iq) {
StanzaNode? query_node = iq.stanza.get_subnode("query", NS_URI_INFO);
if (query_node != null) {
send_query_result(stream, iq);
}
}
public void on_iq_set(XmppStream stream, Iq.Stanza iq) { }
public override void attach(XmppStream stream) {
Iq.Module.require(stream);
Iq.Module.get_module(stream).register_for_namespace(NS_URI_INFO, this);
stream.add_flag(new Flag());
add_feature(stream, NS_URI_INFO);
}
public override void detach(XmppStream stream) { }
public static Module? get_module(XmppStream stream) {
return (Module?) stream.get_module(NS_URI, ID);
}
public static void require(XmppStream stream) {
if (get_module(stream) == null) stream.add_module(new ServiceDiscovery.Module());
}
public override string get_ns() { return NS_URI; }
public override string get_id() { return ID; }
private void send_query_result(XmppStream stream, Iq.Stanza iq_request) {
InfoResult query_result = new ServiceDiscovery.InfoResult(iq_request);
query_result.features = Flag.get_flag(stream).features;
query_result.identities = identities;
Iq.Module.get_module(stream).send_iq(stream, query_result.iq, null);
}
}
public class Identity {
public string category { get; set; }
public string type_ { get; set; }
public string? name { get; set; }
public Identity(string category, string type, string? name = null) {
this.category = category;
this.type_ = type;
this.name = name;
}
}
public class Item {
public string jid;
public string? name;
public string? node;
public Item(string jid, string? name = null, string? node = null) {
this.jid = jid;
this.name = name;
this.node = node;
}
}
public interface InfoResponseListener : Object {
public abstract void on_result(XmppStream stream, InfoResult query_result);
public void on_error(XmppStream stream, Iq.Stanza iq) { }
}
public interface ItemsResponseListener : Object {
public abstract void on_result(XmppStream stream, ItemsResult query_result);
public void on_error(XmppStream stream, Iq.Stanza iq) { }
}
}
|
