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
|
using Gee;
using Xmpp.Core;
namespace Xmpp.Xep.Bookmarks {
private const string NS_URI = "storage:bookmarks";
public class Module : XmppStreamModule {
public const string ID = "0048_bookmarks_module";
public static ModuleIdentity<Module> IDENTITY = new ModuleIdentity<Module>(NS_URI, ID);
public signal void conferences_updated(XmppStream stream, ArrayList<Conference> conferences);
public void get_conferences(XmppStream stream, ConferencesRetrieveResponseListener response_listener) {
StanzaNode get_node = new StanzaNode.build("storage", NS_URI).add_self_xmlns();
stream.get_module(PrivateXmlStorage.Module.IDENTITY).retrieve(stream, get_node, new GetConferences(response_listener));
}
public void set_conferences(XmppStream stream, ArrayList<Conference> conferences) {
StanzaNode storage_node = (new StanzaNode.build("storage", NS_URI)).add_self_xmlns();
foreach (Conference conference in conferences) {
storage_node.put_node(conference.stanza_node);
}
stream.get_module(PrivateXmlStorage.Module.IDENTITY).store(stream, storage_node, new StoreResponseListenerImpl(conferences));
}
private class StoreResponseListenerImpl : PrivateXmlStorage.StoreResponseListener, Object {
ArrayList<Conference> conferences;
public StoreResponseListenerImpl(ArrayList<Conference> conferences) {
this.conferences = conferences;
}
public void on_success(XmppStream stream) {
stream.get_module(Module.IDENTITY).conferences_updated(stream, conferences);
}
}
public void add_conference(XmppStream stream, Conference add) {
get_conferences(stream, new AddConference(add));
}
public void replace_conference(XmppStream stream, Conference was, Conference modified) {
get_conferences(stream, new ModifyConference(was, modified));
}
public void remove_conference(XmppStream stream, Conference conference) {
get_conferences(stream, new RemoveConference(conference));
}
private class GetConferences : PrivateXmlStorage.RetrieveResponseListener, Object {
ConferencesRetrieveResponseListener response_listener;
public GetConferences(ConferencesRetrieveResponseListener response_listener) {
this.response_listener = response_listener;
}
public void on_result(XmppStream stream, StanzaNode node) {
response_listener.on_result(stream, get_conferences_from_stanza(node));
}
}
private class AddConference : ConferencesRetrieveResponseListener, Object {
private Conference conference;
public AddConference(Conference conference) {
this.conference = conference;
}
public void on_result(XmppStream stream, ArrayList<Conference> conferences) {
conferences.add(conference);
stream.get_module(Module.IDENTITY).set_conferences(stream, conferences);
}
}
private class ModifyConference : ConferencesRetrieveResponseListener, Object {
private Conference was;
private Conference modified;
public ModifyConference(Conference was, Conference modified) {
this.was = was;
this.modified = modified;
}
public void on_result(XmppStream stream, ArrayList<Conference> conferences) {
foreach (Conference conference in conferences) {
if (conference.name == was.name && conference.jid == was.jid && conference.autojoin == was.autojoin) {
conference.autojoin = modified.autojoin;
conference.name = modified.name;
conference.jid = modified.jid;
break;
}
}
stream.get_module(Module.IDENTITY).set_conferences(stream, conferences);
}
}
private class RemoveConference : ConferencesRetrieveResponseListener, Object {
private Conference remove;
public RemoveConference(Conference remove) {
this.remove = remove;
}
public void on_result(XmppStream stream, ArrayList<Conference> conferences) {
Conference? rem = null;
foreach (Conference conference in conferences) {
if (conference.name == remove.name && conference.jid == remove.jid && conference.autojoin == remove.autojoin) {
rem = conference;
}
}
if (rem != null) conferences.remove(rem);
stream.get_module(Module.IDENTITY).set_conferences(stream, conferences);
}
}
public override void attach(XmppStream stream) { }
public override void detach(XmppStream stream) { }
public static void require(XmppStream stream) {
if (stream.get_module(IDENTITY) == null) stderr.printf("");
}
public override string get_ns() { return NS_URI; }
public override string get_id() { return ID; }
private static ArrayList<Conference> get_conferences_from_stanza(StanzaNode node) {
ArrayList<Conference> conferences = new ArrayList<Conference>();
ArrayList<StanzaNode> conferenceNodes = node.get_subnode("storage", NS_URI).get_subnodes("conference", NS_URI);
foreach (StanzaNode conferenceNode in conferenceNodes) {
conferences.add(new Conference.from_stanza_node(conferenceNode));
}
return conferences;
}
}
public interface ConferencesRetrieveResponseListener : Object {
public abstract void on_result(XmppStream stream, ArrayList<Conference> conferences);
}
}
|
