From 75e51b5ed3b639b9cf7b16b0ddbee7e362c44ef1 Mon Sep 17 00:00:00 2001 From: fiaxh Date: Tue, 4 Apr 2017 15:47:00 +0200 Subject: MessageStorage/Processor, correctly resolve conversations (fixup 22adbd3) --- plugins/omemo/src/manager.vala | 8 ++++---- plugins/openpgp/src/manager.vala | 4 ++-- 2 files changed, 6 insertions(+), 6 deletions(-) (limited to 'plugins') diff --git a/plugins/omemo/src/manager.vala b/plugins/omemo/src/manager.vala index 67b38bc5..8f50dff9 100644 --- a/plugins/omemo/src/manager.vala +++ b/plugins/omemo/src/manager.vala @@ -65,8 +65,8 @@ public class Manager : StreamInteractionModule, Object { stream_interactor.stream_negotiated.connect(on_stream_negotiated); stream_interactor.account_added.connect(on_account_added); - stream_interactor.get_module(MessageManager.IDENTITY).pre_message_received.connect(on_pre_message_received); - stream_interactor.get_module(MessageManager.IDENTITY).pre_message_send.connect(on_pre_message_send); + stream_interactor.get_module(MessageProcessor.IDENTITY).pre_message_received.connect(on_pre_message_received); + stream_interactor.get_module(MessageProcessor.IDENTITY).pre_message_send.connect(on_pre_message_send); } private void on_pre_message_received(Entities.Message message, Xmpp.Message.Stanza message_stanza, Conversation conversation) { @@ -145,7 +145,7 @@ public class Manager : StreamInteractionModule, Object { } foreach (Entities.Message msg in send_now) { Entities.Conversation conv = stream_interactor.get_module(ConversationManager.IDENTITY).get_conversation(msg.counterpart, account); - stream_interactor.get_module(MessageManager.IDENTITY).send_xmpp_message(msg, conv, true); + stream_interactor.get_module(MessageProcessor.IDENTITY).send_xmpp_message(msg, conv, true); } } @@ -169,7 +169,7 @@ public class Manager : StreamInteractionModule, Object { } foreach (Entities.Message msg in send_now) { Entities.Conversation conv = stream_interactor.get_module(ConversationManager.IDENTITY).get_conversation(msg.counterpart, account); - stream_interactor.get_module(MessageManager.IDENTITY).send_xmpp_message(msg, conv, true); + stream_interactor.get_module(MessageProcessor.IDENTITY).send_xmpp_message(msg, conv, true); } } diff --git a/plugins/openpgp/src/manager.vala b/plugins/openpgp/src/manager.vala index a261c2cb..0a145283 100644 --- a/plugins/openpgp/src/manager.vala +++ b/plugins/openpgp/src/manager.vala @@ -26,8 +26,8 @@ namespace Dino.Plugins.OpenPgp { this.db = db; stream_interactor.account_added.connect(on_account_added); - stream_interactor.get_module(MessageManager.IDENTITY).pre_message_received.connect(on_pre_message_received); - stream_interactor.get_module(MessageManager.IDENTITY).pre_message_send.connect(on_pre_message_send); + stream_interactor.get_module(MessageProcessor.IDENTITY).pre_message_received.connect(on_pre_message_received); + stream_interactor.get_module(MessageProcessor.IDENTITY).pre_message_send.connect(on_pre_message_send); } private void on_pre_message_received(Entities.Message message, Xmpp.Message.Stanza message_stanza, Conversation conversation) { -- cgit v1.2.3-70-g09d2