using Gee; using Xmpp.Core; namespace Xmpp.Xep.EntityCapabilities { private const string NS_URI = "http://jabber.org/protocol/caps"; public class Module : XmppStreamModule { public static ModuleIdentity IDENTITY = new ModuleIdentity(NS_URI, "0115_entity_capabilities"); private string own_ver_hash; private Storage storage; public Module(Storage storage) { this.storage = storage; } private string get_own_hash(XmppStream stream) { if (own_ver_hash == null) { own_ver_hash = compute_hash(stream.get_module(ServiceDiscovery.Module.IDENTITY).identities, stream.get_flag(ServiceDiscovery.Flag.IDENTITY).features); } return own_ver_hash; } public override void attach(XmppStream stream) { stream.get_module(Presence.Module.IDENTITY).pre_send_presence_stanza.connect(on_pre_send_presence_stanza); stream.get_module(Presence.Module.IDENTITY).received_presence.connect(on_received_presence); stream.get_module(ServiceDiscovery.Module.IDENTITY).add_feature(stream, NS_URI); } public override void detach(XmppStream stream) { stream.get_module(Presence.Module.IDENTITY).pre_send_presence_stanza.disconnect(on_pre_send_presence_stanza); stream.get_module(Presence.Module.IDENTITY).received_presence.disconnect(on_received_presence); } public override string get_ns() { return NS_URI; } public override string get_id() { return IDENTITY.id; } private void on_pre_send_presence_stanza(XmppStream stream, Presence.Stanza presence) { if (presence.type_ == Presence.Stanza.TYPE_AVAILABLE) { presence.stanza.put_node(new StanzaNode.build("c", NS_URI).add_self_xmlns() .put_attribute("hash", "sha-1") .put_attribute("node", "https://dino.im") .put_attribute("ver", get_own_hash(stream))); } } private void on_received_presence(XmppStream stream, Presence.Stanza presence) { StanzaNode? c_node = presence.stanza.get_subnode("c", NS_URI); if (c_node != null) { string ver_attribute = c_node.get_attribute("ver", NS_URI); Gee.List capabilities = storage.get_features(ver_attribute); if (capabilities.size == 0) { stream.get_module(ServiceDiscovery.Module.IDENTITY).request_info(stream, presence.from, (stream, query_result) => { store_entity_result(stream, ver_attribute, query_result); }); } else { stream.get_flag(ServiceDiscovery.Flag.IDENTITY).set_entity_features(presence.from, capabilities); } } } private void store_entity_result(XmppStream stream, string entity, ServiceDiscovery.InfoResult? query_result) { if (query_result == null) return; if (compute_hash(query_result.identities, query_result.features) == entity) { storage.store_features(entity, query_result.features); stream.get_flag(ServiceDiscovery.Flag.IDENTITY).set_entity_features(query_result.iq.from, query_result.features); } } private static string compute_hash(Gee.List identities, Gee.List features) { identities.sort(compare_identities); features.sort(); string s = ""; foreach (ServiceDiscovery.Identity identity in identities) { string s_identity = identity.category + "/" + identity.type_ + "//"; if (identity.name != null) s_identity += identity.name; s_identity += "<"; s += s_identity; } foreach (string feature in features) { s += feature + "<"; } Checksum c = new Checksum(ChecksumType.SHA1); c.update(s.data, -1); size_t size = 20; uint8[] buf = new uint8[size]; c.get_digest(buf, ref size); return Base64.encode(buf); } private static int compare_identities(ServiceDiscovery.Identity a, ServiceDiscovery.Identity b) { int category_comp = a.category.collate(b.category); if (category_comp != 0) return category_comp; int type_comp = a.type_.collate(b.type_); if (type_comp != 0) return type_comp; // TODO lang return 0; } } public interface Storage : Object { public abstract void store_features(string entitiy, Gee.List capabilities); public abstract Gee.List get_features(string entitiy); } }