anotherim/anotherim-desktop
2
0
Fork 0
Code Issues Pull requests Actions Packages Projects Releases Wiki Activity

Use ContentItems for NotificationEvents

Browse source
This commit is contained in:
fiaxh 2018-11-07 00:17:24 +01:00
parent 3af9faac82
commit f60ebc2af6
4 changed files with 51 additions and 23 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
libdino/src/application.vala
View file

@ -37,8 +37,8 @@ public interface Dino.Application : GLib.Application {
ConversationManager.start(stream_interactor, db); ConversationManager.start(stream_interactor, db);
ChatInteraction.start(stream_interactor); ChatInteraction.start(stream_interactor);
FileManager.start(stream_interactor, db); FileManager.start(stream_interactor, db);
NotificationEvents.start(stream_interactor);
ContentItemStore.start(stream_interactor, db); ContentItemStore.start(stream_interactor, db);
NotificationEvents.start(stream_interactor);
SearchProcessor.start(stream_interactor, db); SearchProcessor.start(stream_interactor, db);
create_actions(); create_actions();

42
libdino/src/service/notification_events.vala
View file

@ -9,13 +9,13 @@ public class NotificationEvents : StreamInteractionModule, Object {
public static ModuleIdentity<NotificationEvents> IDENTITY = new ModuleIdentity<NotificationEvents>("notification_events"); public static ModuleIdentity<NotificationEvents> IDENTITY = new ModuleIdentity<NotificationEvents>("notification_events");
public string id { get { return IDENTITY.id; } } public string id { get { return IDENTITY.id; } }
public signal void notify_message(Message message, Conversation conversation); public signal void notify_content_item(ContentItem content_item, Conversation conversation);
public signal void notify_subscription_request(Conversation conversation); public signal void notify_subscription_request(Conversation conversation);
public signal void notify_connection_error(Account account, ConnectionManager.ConnectionError error); public signal void notify_connection_error(Account account, ConnectionManager.ConnectionError error);
private StreamInteractor stream_interactor; private StreamInteractor stream_interactor;
private HashMap<Account, HashMap<Conversation, Entities.Message>> mam_potential_new = new HashMap<Account, HashMap<Conversation, Entities.Message>>(Account.hash_func, Account.equals_func); private HashMap<Account, HashMap<Conversation, ContentItem>> mam_potential_new = new HashMap<Account, HashMap<Conversation, ContentItem>>(Account.hash_func, Account.equals_func);
private Gee.List<Account> synced_accounts = new ArrayList<Account>(Account.equals_func); private Gee.List<Account> synced_accounts = new ArrayList<Account>(Account.equals_func);
public static void start(StreamInteractor stream_interactor) { public static void start(StreamInteractor stream_interactor) {
@ -26,16 +26,16 @@ public class NotificationEvents : StreamInteractionModule, Object {
public NotificationEvents(StreamInteractor stream_interactor) { public NotificationEvents(StreamInteractor stream_interactor) {
this.stream_interactor = stream_interactor; this.stream_interactor = stream_interactor;
stream_interactor.get_module(MessageProcessor.IDENTITY).message_received.connect(on_message_received); stream_interactor.get_module(ContentItemStore.IDENTITY).new_item.connect(on_content_item_received);
stream_interactor.get_module(PresenceManager.IDENTITY).received_subscription_request.connect(on_received_subscription_request); stream_interactor.get_module(PresenceManager.IDENTITY).received_subscription_request.connect(on_received_subscription_request);
stream_interactor.get_module(MessageProcessor.IDENTITY).history_synced.connect((account) => { stream_interactor.get_module(MessageProcessor.IDENTITY).history_synced.connect((account) => {
synced_accounts.add(account); synced_accounts.add(account);
if (!mam_potential_new.has_key(account)) return; if (!mam_potential_new.has_key(account)) return;
foreach (Conversation c in mam_potential_new[account].keys) { foreach (Conversation c in mam_potential_new[account].keys) {
Entities.Message m = mam_potential_new[account][c]; ContentItem last_mam_item = mam_potential_new[account][c];
Entities.Message last_message = stream_interactor.get_module(MessageStorage.IDENTITY).get_last_message(c); ContentItem last_item = stream_interactor.get_module(ContentItemStore.IDENTITY).get_latest(c);
if (m.equals(last_message) && !c.read_up_to.equals(m)) { if (last_mam_item == last_item /* && !c.read_up_to.equals(m) */) {
on_message_received(m, c); on_content_item_received(last_mam_item, c);
} }
} }
mam_potential_new[account].clear(); mam_potential_new[account].clear();
@ -43,27 +43,39 @@ public class NotificationEvents : StreamInteractionModule, Object {
stream_interactor.connection_manager.connection_error.connect((account, error) => notify_connection_error(account, error)); stream_interactor.connection_manager.connection_error.connect((account, error) => notify_connection_error(account, error));
} }
private void on_message_received(Entities.Message message, Conversation conversation) { private void on_content_item_received(ContentItem item, Conversation conversation) {
bool is_mam_message = Xep.MessageArchiveManagement.MessageFlag.get_flag(message.stanza) != null; if (!synced_accounts.contains(conversation.account)) {
if (!synced_accounts.contains(conversation.account) && is_mam_message) {
if (!mam_potential_new.has_key(conversation.account)) { if (!mam_potential_new.has_key(conversation.account)) {
mam_potential_new[conversation.account] = new HashMap<Conversation, Entities.Message>(Conversation.hash_func, Conversation.equals_func); mam_potential_new[conversation.account] = new HashMap<Conversation, ContentItem>(Conversation.hash_func, Conversation.equals_func);
} }
mam_potential_new[conversation.account][conversation] = message; mam_potential_new[conversation.account][conversation] = item;
return; return;
} }
if (!should_notify_message(message, conversation)) return; if (!should_notify(item, conversation)) return;
if (stream_interactor.get_module(ChatInteraction.IDENTITY).is_active_focus()) return; if (stream_interactor.get_module(ChatInteraction.IDENTITY).is_active_focus()) return;
notify_message(message, conversation); notify_content_item(item, conversation);
} }
private bool should_notify_message(Entities.Message message, Conversation conversation) { private bool should_notify(ContentItem content_item, Conversation conversation) {
Conversation.NotifySetting notify = conversation.get_notification_setting(stream_interactor); Conversation.NotifySetting notify = conversation.get_notification_setting(stream_interactor);
switch (content_item.type_) {
case MessageItem.TYPE:
Message message = (content_item as MessageItem).message;
if (message.direction == Message.DIRECTION_SENT) return false;
break;
case FileItem.TYPE:
FileTransfer file_transfer = (content_item as FileItem).file_transfer;
if (file_transfer.direction == FileTransfer.DIRECTION_SENT) return false;
break;
}
if (notify == Conversation.NotifySetting.OFF) return false; if (notify == Conversation.NotifySetting.OFF) return false;
Jid? nick = stream_interactor.get_module(MucManager.IDENTITY).get_own_jid(conversation.counterpart, conversation.account); Jid? nick = stream_interactor.get_module(MucManager.IDENTITY).get_own_jid(conversation.counterpart, conversation.account);
if (content_item.type_ == MessageItem.TYPE) {
Entities.Message message = (content_item as MessageItem).message;
if (notify == Conversation.NotifySetting.HIGHLIGHT && nick != null) { if (notify == Conversation.NotifySetting.HIGHLIGHT && nick != null) {
return Regex.match_simple("\\b" + Regex.escape_string(nick.resourcepart) + "\\b", message.body, RegexCompileFlags.CASELESS); return Regex.match_simple("\\b" + Regex.escape_string(nick.resourcepart) + "\\b", message.body, RegexCompileFlags.CASELESS);
} }
}
return true; return true;
} }

24
main/src/ui/notifications.vala
View file

@ -41,20 +41,36 @@ public class Notifications : Object {
} }
public void start() { public void start() {
stream_interactor.get_module(NotificationEvents.IDENTITY).notify_message.connect(notify_message); stream_interactor.get_module(NotificationEvents.IDENTITY).notify_content_item.connect(notify_content_item);
stream_interactor.get_module(NotificationEvents.IDENTITY).notify_subscription_request.connect(notify_subscription_request); stream_interactor.get_module(NotificationEvents.IDENTITY).notify_subscription_request.connect(notify_subscription_request);
stream_interactor.get_module(NotificationEvents.IDENTITY).notify_connection_error.connect(notify_connection_error); stream_interactor.get_module(NotificationEvents.IDENTITY).notify_connection_error.connect(notify_connection_error);
} }
private void notify_message(Entities.Message message, Conversation conversation) { private void notify_content_item(ContentItem content_item, Conversation conversation) {
if (!notifications.has_key(conversation)) { if (!notifications.has_key(conversation)) {
notifications[conversation] = new Notification(""); notifications[conversation] = new Notification("");
notifications[conversation].set_default_action_and_target_value("app.open-conversation", new Variant.int32(conversation.id)); notifications[conversation].set_default_action_and_target_value("app.open-conversation", new Variant.int32(conversation.id));
} }
string display_name = Util.get_conversation_display_name(stream_interactor, conversation); string display_name = Util.get_conversation_display_name(stream_interactor, conversation);
string text = message.body; string text = "";
switch (content_item.type_) {
case MessageItem.TYPE:
Message message = (content_item as MessageItem).message;
text = message.body;
break;
case FileItem.TYPE:
FileItem file_item = content_item as FileItem;
FileTransfer transfer = file_item.file_transfer;
if (transfer.direction == Message.DIRECTION_SENT) {
text = transfer.mime_type.has_prefix("image") ? _("Image sent") : _("File sent");
} else {
text = transfer.mime_type.has_prefix("image") ? _("Image received") : _("File received");
}
break;
}
if (stream_interactor.get_module(MucManager.IDENTITY).is_groupchat(conversation.counterpart, conversation.account)) { if (stream_interactor.get_module(MucManager.IDENTITY).is_groupchat(conversation.counterpart, conversation.account)) {
string muc_occupant = Util.get_display_name(stream_interactor, message.from, conversation.account); string muc_occupant = Util.get_display_name(stream_interactor, content_item.jid, conversation.account);
text = @"$muc_occupant: $text"; text = @"$muc_occupant: $text";
} }
notifications[conversation].set_title(display_name); notifications[conversation].set_title(display_name);

2
plugins/notification-sound/src/plugin.vala
View file

@ -9,7 +9,7 @@ public class Plugin : RootInterface, Object {
this.app = app; this.app = app;
Canberra.Context.create(out sound_context); Canberra.Context.create(out sound_context);
app.stream_interactor.get_module(NotificationEvents.IDENTITY).notify_message.connect((message, conversation) => { app.stream_interactor.get_module(NotificationEvents.IDENTITY).notify_content_item.connect((item, conversation) => {
sound_context.play(0, Canberra.PROP_EVENT_ID, "message-new-instant", Canberra.PROP_EVENT_DESCRIPTION, "New Dino message"); sound_context.play(0, Canberra.PROP_EVENT_ID, "message-new-instant", Canberra.PROP_EVENT_DESCRIPTION, "New Dino message");
}); });
} }