aboutsummaryrefslogtreecommitdiff
path: root/libdino/src/service/entity_info.vala
diff options
context:
space:
mode:
authorfiaxh <git@lightrise.org>2020-07-03 21:14:39 +0200
committerfiaxh <git@lightrise.org>2020-07-16 23:31:19 +0200
commite159fd2492c28c1ef4ab64828ca0e8c2de877b41 (patch)
treeaca3c42854b08b5683a1c85e7c7a74fd0a4bdf0d /libdino/src/service/entity_info.vala
parent74f7fa897f9aec298eeadcfc7a7b971f06498858 (diff)
downloaddino-e159fd2492c28c1ef4ab64828ca0e8c2de877b41.tar.gz
dino-e159fd2492c28c1ef4ab64828ca0e8c2de877b41.zip
Only query entity caps when we need them
Diffstat (limited to 'libdino/src/service/entity_info.vala')
-rw-r--r--libdino/src/service/entity_info.vala161
1 files changed, 155 insertions, 6 deletions
diff --git a/libdino/src/service/entity_info.vala b/libdino/src/service/entity_info.vala
index 8efea7e5..7a78b154 100644
--- a/libdino/src/service/entity_info.vala
+++ b/libdino/src/service/entity_info.vala
@@ -1,5 +1,6 @@
using Gee;
using Dino.Entities;
+using Qlite;
using Xmpp;
using Xmpp.Xep;
using Xmpp.Xep.ServiceDiscovery;
@@ -15,6 +16,10 @@ public class EntityInfo : StreamInteractionModule, Object {
private HashMap<Jid, string> entity_caps_hashes = new HashMap<Jid, string>(Jid.hash_func, Jid.equals_func);
+ private HashMap<string, Gee.List<string>> entity_features = new HashMap<string, Gee.List<string>>();
+ private HashMap<Jid, Gee.List<string>> jid_features = new HashMap<Jid, Gee.List<string>>(Jid.hash_func, Jid.equals_func);
+ private HashMap<string, Gee.Set<Identity>> entity_identity = new HashMap<string, Gee.Set<Identity>>();
+ private HashMap<Jid, Gee.Set<Identity>> jid_identity = new HashMap<Jid, Gee.Set<Identity>>(Jid.hash_func, Jid.equals_func);
public static void start(StreamInteractor stream_interactor, Database db) {
EntityInfo m = new EntityInfo(stream_interactor, db);
@@ -27,13 +32,62 @@ public class EntityInfo : StreamInteractionModule, Object {
this.entity_capabilities_storage = new EntityCapabilitiesStorage(db);
stream_interactor.account_added.connect(on_account_added);
+ stream_interactor.stream_negotiated.connect((account, stream) => {
+ var cache = new CapsCacheImpl(account, this);
+ stream.get_module(ServiceDiscovery.Module.IDENTITY).cache = cache;
+
+ string? hash = EntityCapabilities.get_server_caps_hash(stream);
+ entity_caps_hashes[new Jid(account.domainpart)] = hash;
+ });
stream_interactor.module_manager.initialize_account_modules.connect(initialize_modules);
}
- public Identity? get_identity(Account account, Jid jid) {
- string? caps_hash = entity_caps_hashes[jid];
- if (caps_hash == null) return null;
- return entity_capabilities_storage.get_identities(caps_hash);
+ public async Identity? get_identity(Account account, Jid jid) {
+ Gee.Set<ServiceDiscovery.Identity>? identities = null;
+
+ if (jid_identity.has_key(jid)) {
+ identities = jid_identity[jid];
+ }
+
+ if (identities == null) {
+ string? hash = entity_caps_hashes[jid];
+ if (hash != null) {
+ identities = get_identities(hash);
+ }
+
+ if (identities == null) {
+ ServiceDiscovery.InfoResult? info_result = yield get_info_result(account, jid, hash);
+ identities = info_result.identities;
+ }
+ }
+
+ if (identities != null) {
+ foreach (var identity in identities) {
+ if (identity.category == Identity.CATEGORY_CLIENT) {
+ return identity;
+ }
+ }
+ }
+ return null;
+ }
+
+ public async bool has_feature(Account account, Jid jid, string feature) {
+ if (jid_features.has_key(jid)) {
+ return jid_features[jid].contains(feature);
+ }
+
+ string? hash = entity_caps_hashes[jid];
+ if (hash != null) {
+ Gee.List<string>? features = get_features(hash);
+ if (features != null) {
+ return features.contains(feature);
+ }
+ }
+
+ ServiceDiscovery.InfoResult? info_result = yield get_info_result(account, jid, hash);
+ if (info_result == null) return false;
+
+ return info_result.features.contains(feature);
}
private void on_received_available_presence(Account account, Presence.Stanza presence) {
@@ -43,19 +97,93 @@ public class EntityInfo : StreamInteractionModule, Object {
string? caps_hash = EntityCapabilities.get_caps_hash(presence);
if (caps_hash == null) return;
- db.entity.upsert()
+ /*db.entity.upsert()
.value(db.entity.account_id, account.id, true)
.value(db.entity.jid_id, db.get_jid_id(presence.from), true)
.value(db.entity.resource, presence.from.resourcepart, true)
.value(db.entity.last_seen, (long)(new DateTime.now_local()).to_unix())
.value(db.entity.caps_hash, caps_hash)
- .perform();
+ .perform();*/
if (caps_hash != null) {
entity_caps_hashes[presence.from] = caps_hash;
}
}
+ private void store_features(string entity, Gee.List<string> features) {
+ if (entity_features.has_key(entity)) return;
+
+ foreach (string feature in features) {
+ db.entity_feature.insert()
+ .value(db.entity_feature.entity, entity)
+ .value(db.entity_feature.feature, feature)
+ .perform();
+ }
+ entity_features[entity] = features;
+ }
+
+ private void store_identities(string entity, Gee.Set<Identity> identities) {
+ foreach (Identity identity in identities) {
+ db.entity_identity.insert()
+ .value(db.entity_identity.entity, entity)
+ .value(db.entity_identity.category, identity.category)
+ .value(db.entity_identity.type, identity.type_)
+ .value(db.entity_identity.entity_name, identity.name)
+ .perform();
+ }
+ }
+
+ private Gee.List<string>? get_features(string entity) {
+ Gee.List<string>? features = entity_features[entity];
+ if (features != null) {
+ return features;
+ }
+
+ features = new ArrayList<string>();
+ foreach (Row row in db.entity_feature.select({db.entity_feature.feature}).with(db.entity_feature.entity, "=", entity)) {
+ features.add(row[db.entity_feature.feature]);
+ }
+
+ if (features.size == 0) {
+ return null;
+ }
+ entity_features[entity] = features;
+ return features;
+ }
+
+ private Gee.Set<Identity> get_identities(string entity) {
+ Gee.Set<Identity>? identities = entity_identity[entity];
+ if (identities != null) {
+ return identities;
+ }
+
+ var qry = db.entity_identity.select().with(db.entity_identity.entity, "=", entity);
+ foreach (Row row in qry) {
+ if (identities == null) identities = new HashSet<Identity>(Identity.hash_func, Identity.equals_func);
+ var identity = new Identity(row[db.entity_identity.category], row[db.entity_identity.type], row[db.entity_identity.entity_name]);
+ identities.add(identity);
+ }
+ return identities;
+ }
+
+ private async ServiceDiscovery.InfoResult? get_info_result(Account account, Jid jid, string? hash = null) {
+ XmppStream? stream = stream_interactor.get_stream(account);
+ if (stream == null) return null;
+
+ ServiceDiscovery.InfoResult? info_result = yield stream.get_module(ServiceDiscovery.Module.IDENTITY).request_info(stream, jid);
+ if (info_result == null) return null;
+
+ if (hash != null && EntityCapabilities.Module.compute_hash_for_info_result(info_result) == hash) {
+ store_features(hash, info_result.features);
+ store_identities(hash, info_result.identities);
+ } else {
+ jid_features[jid] = info_result.features;
+ jid_identity[jid] = info_result.identities;
+ }
+
+ return info_result;
+ }
+
private void on_account_added(Account account) {
stream_interactor.module_manager.get_module(account, Presence.Module.IDENTITY).received_available.connect((stream, presence) => on_received_available_presence(account, presence));
}
@@ -64,4 +192,25 @@ public class EntityInfo : StreamInteractionModule, Object {
modules.add(new Xep.EntityCapabilities.Module(entity_capabilities_storage));
}
}
+
+public class CapsCacheImpl : CapsCache, Object {
+
+ private Account account;
+ private EntityInfo entity_info;
+
+ public CapsCacheImpl(Account account, EntityInfo entity_info) {
+ this.account = account;
+ this.entity_info = entity_info;
+ }
+
+ public async bool has_entity_feature(Jid jid, string feature) {
+ return yield entity_info.has_feature(account, jid, feature);
+ }
+
+ public async Gee.Set<Identity> get_entity_identities(Jid jid) {
+ var ret = new HashSet<Identity>(Identity.hash_func, Identity.equals_func);
+ ret.add(yield entity_info.get_identity(account, jid));
+ return ret;
+ }
+}
}