diff options
| author | fiaxh <git@lightrise.org> | 2020-04-29 14:10:43 +0200 |
|---|---|---|
| committer | fiaxh <git@lightrise.org> | 2020-06-03 21:50:40 +0200 |
| commit | b5066e0e2f4b482204f43402c797d8bf9f7ef582 (patch) | |
| tree | 1caa9ac6b3c953b71f7923ae1ec090061c2dd239 /libdino/src/service | |
| parent | 1c59a3870da094dab2a5f4aea473dda57496d6d7 (diff) | |
| download | dino-b5066e0e2f4b482204f43402c797d8bf9f7ef582.tar.gz dino-b5066e0e2f4b482204f43402c797d8bf9f7ef582.zip | |
Check if server supports uid
Diffstat (limited to 'libdino/src/service')
| -rw-r--r-- | libdino/src/service/message_processor.vala | 15 |
1 files changed, 12 insertions, 3 deletions
diff --git a/libdino/src/service/message_processor.vala b/libdino/src/service/message_processor.vala index 0e390540..6a66f343 100644 --- a/libdino/src/service/message_processor.vala +++ b/libdino/src/service/message_processor.vala @@ -352,12 +352,21 @@ public class MessageProcessor : StreamInteractionModule, Object { XmppStream? stream = stream_interactor.get_stream(account); Xep.MessageArchiveManagement.MessageFlag? mam_message_flag = Xep.MessageArchiveManagement.MessageFlag.get_flag(message); Xep.MessageArchiveManagement.Flag? mam_flag = stream != null ? stream.get_flag(Xep.MessageArchiveManagement.Flag.IDENTITY) : null; - if (mam_message_flag != null && mam_flag != null && mam_flag.ns_ver == Xep.MessageArchiveManagement.NS_URI && mam_message_flag.mam_id != null) { + Xep.ServiceDiscovery.Module disco_module = stream.get_module(Xep.ServiceDiscovery.Module.IDENTITY); + if (mam_message_flag != null && mam_flag != null && mam_flag.ns_ver == Xep.MessageArchiveManagement.NS_URI_2 && mam_message_flag.mam_id != null) { new_message.server_id = mam_message_flag.mam_id; } else if (message.type_ == Xmpp.MessageStanza.TYPE_GROUPCHAT) { - new_message.server_id = Xep.UniqueStableStanzaIDs.get_stanza_id(message, new_message.counterpart.bare_jid); + bool server_supports_sid = (yield disco_module.has_entity_feature(stream, new_message.counterpart.bare_jid, Xep.UniqueStableStanzaIDs.NS_URI)) || + (yield disco_module.has_entity_feature(stream, new_message.counterpart.bare_jid, Xep.MessageArchiveManagement.NS_URI_2)); + if (server_supports_sid) { + new_message.server_id = Xep.UniqueStableStanzaIDs.get_stanza_id(message, new_message.counterpart.bare_jid); + } } else if (message.type_ == Xmpp.MessageStanza.TYPE_CHAT) { - new_message.server_id = Xep.UniqueStableStanzaIDs.get_stanza_id(message, account.bare_jid); + bool server_supports_sid = (yield disco_module.has_entity_feature(stream, account.bare_jid, Xep.UniqueStableStanzaIDs.NS_URI)) || + (yield disco_module.has_entity_feature(stream, account.bare_jid, Xep.MessageArchiveManagement.NS_URI_2)); + if (server_supports_sid) { + new_message.server_id = Xep.UniqueStableStanzaIDs.get_stanza_id(message, account.bare_jid); + } } if (mam_message_flag != null) new_message.local_time = mam_message_flag.server_time; |