Add Bookmarks2 implementation, introduce bookmarks interfaces

1 files changed, 116 insertions, 0 deletions

diff --git a/xmpp-vala/src/module/xep/0402_bookmarks2.vala b/xmpp-vala/src/module/xep/0402_bookmarks2.vala
new file mode 100644
index 00000000..cbe6ea45
--- /dev/null
+++ b/xmpp-vala/src/module/xep/0402_bookmarks2.vala
@@ -0,0 +1,116 @@
+using Gee;
+
+namespace Xmpp.Xep.Bookmarks2 {
+
+private const string NS_URI = "urn:xmpp:bookmarks:0";
+
+public class Module : BookmarksProvider, XmppStreamModule {
+    public static ModuleIdentity<Module> IDENTITY = new ModuleIdentity<Module>(NS_URI, "0402_bookmarks2");
+
+    public async Set<Conference>? get_conferences(XmppStream stream) {
+        HashMap<Jid, Conference>? hm = null;
+
+        Flag? flag = stream.get_flag(Flag.IDENTITY);
+        if (flag != null) {
+            hm = flag.conferences;
+        } else {
+            Gee.List<StanzaNode>? items = yield stream.get_module(Pubsub.Module.IDENTITY).request_all(stream, stream.get_flag(Bind.Flag.IDENTITY).my_jid.bare_jid, NS_URI);
+
+            hm = new HashMap<Jid, Conference>(Jid.hash_func, Jid.equals_func);
+            foreach (StanzaNode item_node in items) {
+                Conference? conference = parse_item_node(item_node, item_node.get_attribute("id"));
+                if (conference == null) continue;
+                hm[conference.jid] = conference;
+            }
+            stream.add_flag(new Flag(hm));
+        }
+
+
+        var ret = new HashSet<Conference>();
+        foreach (var conference in hm.values) {
+            ret.add(conference);
+        }
+        return ret;
+    }
+
+    public async void add_conference(XmppStream stream, Conference conference) {
+        StanzaNode conference_node = new StanzaNode.build("conference", NS_URI).add_self_xmlns()
+            .put_attribute("autojoin", conference.autojoin ? "true" : "false");
+        if (conference.name != null) {
+            conference_node.put_attribute("name", conference.name);
+        }
+        if (conference.nick != null) {
+            conference_node.put_node((new StanzaNode.build("nick", NS_URI)).put_node(new StanzaNode.text(conference.nick)));
+        }
+        yield stream.get_module(Pubsub.Module.IDENTITY).publish(stream, stream.get_flag(Bind.Flag.IDENTITY).my_jid.bare_jid, NS_URI, conference.jid.to_string(), conference_node, Xmpp.Xep.Pubsub.ACCESS_MODEL_WHITELIST, 128);
+    }
+
+    public async void replace_conference(XmppStream stream, Conference orig_conference, Conference modified_conference) {
+        yield add_conference(stream, modified_conference);
+    }
+
+    public async void remove_conference(XmppStream stream, Conference conference) {
+        yield stream.get_module(Pubsub.Module.IDENTITY).retract_item(stream,
+                    stream.get_flag(Bind.Flag.IDENTITY).my_jid.bare_jid,
+                    NS_URI,
+                    conference.jid.to_string());
+    }
+
+    private void on_pupsub_event(XmppStream stream, Jid jid, string id, StanzaNode? node) {
+        if (node.name == "item") {
+            Conference conference = parse_item_node(node, id);
+            Flag? flag = stream.get_flag(Flag.IDENTITY);
+            if (flag != null) {
+                flag.conferences[conference.jid] = conference;
+            }
+            conference_added(stream, conference);
+        } else if (node.name == "retract") {
+            string jid_str = node.get_attribute("id");
+            Jid jid_parsed = Jid.parse(jid_str);
+            Flag? flag = stream.get_flag(Flag.IDENTITY);
+            if (flag != null) {
+                flag.conferences.unset(jid_parsed);
+            }
+            conference_removed(stream, jid_parsed);
+        }
+    }
+
+    private Conference? parse_item_node(StanzaNode item_node, string id) {
+        Conference conference = new Conference();
+        Jid? jid_parsed = Jid.parse(id);
+        if (jid_parsed == null || jid_parsed.resourcepart != null) return null;
+        conference.jid = jid_parsed;
+
+        StanzaNode? conference_node = item_node.get_subnode("conference", NS_URI);
+        if (conference_node == null) return null;
+
+        conference.name = conference_node.get_attribute("name", NS_URI);
+        conference.autojoin = conference_node.get_attribute("autojoin", NS_URI) == "true";
+        conference.nick = conference_node.get_deep_string_content("nick");
+        return conference;
+    }
+
+    public override void attach(XmppStream stream) {
+        stream.get_module(Pubsub.Module.IDENTITY).add_filtered_notification(stream, NS_URI, on_pupsub_event);
+    }
+
+    public override void detach(XmppStream stream) { }
+
+    public override string get_ns() { return NS_URI; }
+    public override string get_id() { return IDENTITY.id; }
+}
+
+public class Flag : XmppStreamFlag {
+    public static FlagIdentity<Flag> IDENTITY = new FlagIdentity<Flag>(NS_URI, "bookmarks2");
+
+    public Flag(HashMap<Jid, Conference> conferences) {
+        this.conferences = conferences;
+    }
+
+    public HashMap<Jid, Conference> conferences = new HashMap<Jid, Conference>(Jid.hash_func, Jid.equals_func);
+
+    public override string get_ns() { return NS_URI; }
+    public override string get_id() { return IDENTITY.id; }
+}
+
+}