aboutsummaryrefslogtreecommitdiff
path: root/plugins/omemo
diff options
context:
space:
mode:
authorMarvin W <git@larma.de>2017-03-12 21:20:56 +0100
committerMarvin W <git@larma.de>2017-03-12 21:24:47 +0100
commitbd1f116b3a57b803e2be4dc92474937f1f824fe4 (patch)
tree908c8eb00b762c10cfa920ca89de9d834b50bc0a /plugins/omemo
parent13cef27d46bb8c3c6a274983fc8569752fb69b5d (diff)
downloaddino-bd1f116b3a57b803e2be4dc92474937f1f824fe4.tar.gz
dino-bd1f116b3a57b803e2be4dc92474937f1f824fe4.zip
Fix delegate copying issue
Diffstat (limited to 'plugins/omemo')
-rw-r--r--plugins/omemo/src/stream_module.vala9
1 files changed, 5 insertions, 4 deletions
diff --git a/plugins/omemo/src/stream_module.vala b/plugins/omemo/src/stream_module.vala
index 546da102..86a9225d 100644
--- a/plugins/omemo/src/stream_module.vala
+++ b/plugins/omemo/src/stream_module.vala
@@ -109,18 +109,19 @@ public class StreamModule : XmppStreamModule {
}
public override void attach(XmppStream stream) {
- if (Plugin.context == null) return;
Message.Module.require(stream);
Pubsub.Module.require(stream);
- stream.get_module(Message.Module.IDENTITY).pre_received_message.connect(on_pre_received_message);
- stream.get_module(Pubsub.Module.IDENTITY).add_filtered_notification(stream, NODE_DEVICELIST, on_devicelist, this);
+ if (Plugin.context == null) return;
+
this.store = Plugin.context.create_store();
store_created(store);
+ stream.get_module(Message.Module.IDENTITY).pre_received_message.connect(on_pre_received_message);
+ stream.get_module(Pubsub.Module.IDENTITY).add_filtered_notification(stream, NODE_DEVICELIST, (stream, jid, id, node, obj) => (obj as StreamModule).on_devicelist(stream, jid, id, node), this);
}
private void on_pre_received_message(XmppStream stream, Message.Stanza message) {
StanzaNode? encrypted = message.stanza.get_subnode("encrypted", NS_URI);
- if (encrypted == null) return;
+ if (encrypted == null || MessageFlag.get_flag(message) != null) return;
MessageFlag flag = new MessageFlag();
message.add_flag(flag);
StanzaNode? header = encrypted.get_subnode("header");