diff --git a/CMakeLists.txt b/CMakeLists.txt index 1365b6d2..66b32f4b 100644 --- a/CMakeLists.txt +++ b/CMakeLists.txt @@ -11,7 +11,7 @@ else () endif () # Prepare Plugins -set(DEFAULT_PLUGINS omemo;openpgp;http-files;ice;rtp) +set(DEFAULT_PLUGINS omemo;openpgp;http-files;ice;rtp;phone-ringer) foreach (plugin ${DEFAULT_PLUGINS}) if ("$CACHE{DINO_PLUGIN_ENABLED_${plugin}}" STREQUAL "") if (NOT DEFINED DINO_PLUGIN_ENABLED_${plugin}}) diff --git a/libdino/src/service/notification_events.vala b/libdino/src/service/notification_events.vala index 8771b5a9..f448a7ad 100644 --- a/libdino/src/service/notification_events.vala +++ b/libdino/src/service/notification_events.vala @@ -12,9 +12,7 @@ public class NotificationEvents : StreamInteractionModule, Object { public signal void notify_content_item(ContentItem content_item, Conversation conversation); private StreamInteractor stream_interactor; - private Future notifier; - private Promise notifier_promise; - private bool notifier_outstanding = true; + private Gee.List> promises = new ArrayList>(); public static void start(StreamInteractor stream_interactor) { NotificationEvents m = new NotificationEvents(stream_interactor); @@ -31,18 +29,16 @@ public class NotificationEvents : StreamInteractionModule, Object { stream_interactor.get_module(MucManager.IDENTITY).voice_request_received.connect((account, room_jid, from_jid, nick) => on_voice_request_received.begin(account, room_jid, from_jid, nick)); stream_interactor.get_module(Calls.IDENTITY).call_incoming.connect((call, state, conversation, video, multiparty) => on_call_incoming.begin(call, state, conversation, video, multiparty)); + stream_interactor.get_module(Calls.IDENTITY).call_outgoing.connect((call, state, conversation) => on_call_outgoing.begin(call)); + stream_interactor.connection_manager.connection_error.connect((account, error) => on_connection_error.begin(account, error)); stream_interactor.get_module(ChatInteraction.IDENTITY).focused_in.connect((conversation) => on_focused_in.begin(conversation)); - - notifier_promise = new Promise(); - notifier = notifier_promise.future; } public async void register_notification_provider(NotificationProvider notification_provider) { - if (notifier_outstanding || (yield notifier.wait_async()).get_priority() < notification_provider.get_priority()) { - notifier_outstanding = false; - notifier_promise.set_value(notification_provider); - } + var promise = new Promise(); + promise.set_value(notification_provider); + promises.add(promise); } private async void on_content_item_received(ContentItem item, Conversation conversation) { @@ -77,8 +73,10 @@ public class NotificationEvents : StreamInteractionModule, Object { notify_content_item(item, conversation); if (notify != Conversation.NotifySetting.OFF) { - NotificationProvider notifier = yield notifier.wait_async(); - yield notifier.notify_message(message, conversation, conversation_display_name, participant_display_name); + foreach(var promise in promises) { + NotificationProvider notifier = yield promise.future.wait_async(); + yield notifier.notify_message(message, conversation, conversation_display_name, participant_display_name); + } } break; case FileItem.TYPE: @@ -91,8 +89,10 @@ public class NotificationEvents : StreamInteractionModule, Object { notify_content_item(item, conversation); if (notify != Conversation.NotifySetting.OFF) { - NotificationProvider notifier = yield notifier.wait_async(); - yield notifier.notify_file(file_transfer, conversation, is_image, conversation_display_name, participant_display_name); + foreach(var promise in promises) { + NotificationProvider notifier = yield promise.future.wait_async(); + yield notifier.notify_file(file_transfer, conversation, is_image, conversation_display_name, participant_display_name); + } } break; case CallItem.TYPE: @@ -105,29 +105,47 @@ public class NotificationEvents : StreamInteractionModule, Object { Conversation? conversation = stream_interactor.get_module(ConversationManager.IDENTITY).get_conversation(room_jid, account, Conversation.Type.GROUPCHAT); if (conversation == null) return; - NotificationProvider notifier = yield notifier.wait_async(); - yield notifier.notify_voice_request(conversation, from_jid); + foreach(var promise in promises) { + NotificationProvider notifier = yield promise.future.wait_async(); + yield notifier.notify_voice_request(conversation, from_jid); + } } private async void on_received_subscription_request(Jid jid, Account account) { Conversation conversation = stream_interactor.get_module(ConversationManager.IDENTITY).create_conversation(jid, account, Conversation.Type.CHAT); if (stream_interactor.get_module(ChatInteraction.IDENTITY).is_active_focus(conversation)) return; - NotificationProvider notifier = yield notifier.wait_async(); - yield notifier.notify_subscription_request(conversation); + foreach(var promise in promises) { + NotificationProvider notifier = yield promise.future.wait_async(); + yield notifier.notify_subscription_request(conversation); + } } private async void on_call_incoming(Call call, CallState call_state, Conversation conversation, bool video, bool multiparty) { if (!stream_interactor.get_module(Calls.IDENTITY).can_we_do_calls(call.account)) return; string conversation_display_name = get_conversation_display_name(stream_interactor, conversation, null); - NotificationProvider notifier = yield notifier.wait_async(); - yield notifier.notify_call(call, conversation, video, multiparty, conversation_display_name); - call.notify["state"].connect(() => { - if (call.state != Call.State.RINGING) { - notifier.retract_call_notification.begin(call, conversation); - } - }); + foreach(var promise in promises) { + NotificationProvider notifier = yield promise.future.wait_async(); + yield notifier.notify_call(call, conversation, video, multiparty, conversation_display_name); + call.notify["state"].connect(() => { + if (call.state != Call.State.RINGING) { + notifier.retract_call_notification.begin(call, conversation); + } + }); + } + } + + private async void on_call_outgoing(Call call) { + foreach(var promise in promises) { + NotificationProvider notifier = yield promise.future.wait_async(); + yield notifier.notify_dialing(); + call.notify["state"].connect(() => { + if (call.state != Call.State.ESTABLISHING) { + notifier.retract_dialing.begin(); + } + }); + } } private async void on_invite_received(Account account, Jid room_jid, Jid from_jid, string? password, string? reason) { @@ -139,19 +157,26 @@ public class NotificationEvents : StreamInteractionModule, Object { Conversation direct_conversation = new Conversation(from_jid, account, Conversation.Type.CHAT); inviter_display_name = get_participant_display_name(stream_interactor, direct_conversation, from_jid); } - NotificationProvider notifier = yield notifier.wait_async(); - yield notifier.notify_muc_invite(account, room_jid, from_jid, inviter_display_name); + + foreach(var promise in promises) { + NotificationProvider notifier = yield promise.future.wait_async(); + yield notifier.notify_muc_invite(account, room_jid, from_jid, inviter_display_name); + } } private async void on_connection_error(Account account, ConnectionManager.ConnectionError error) { - NotificationProvider notifier = yield notifier.wait_async(); - yield notifier.notify_connection_error(account, error); + foreach(var promise in promises) { + NotificationProvider notifier = yield promise.future.wait_async(); + yield notifier.notify_connection_error(account, error); + } } private async void on_focused_in(Conversation conversation) { - NotificationProvider notifier = yield notifier.wait_async(); - yield notifier.retract_content_item_notifications(); - yield notifier.retract_conversation_notifications(conversation); + foreach(var promise in promises) { + NotificationProvider notifier = yield promise.future.wait_async(); + yield notifier.retract_content_item_notifications(); + yield notifier.retract_conversation_notifications(conversation); + } } } @@ -162,6 +187,8 @@ public interface NotificationProvider : Object { public abstract async void notify_file(FileTransfer file_transfer, Conversation conversation, bool is_image, string conversation_display_name, string? participant_display_name); public abstract async void notify_call(Call call, Conversation conversation, bool video, bool multiparty, string conversation_display_name); public abstract async void retract_call_notification(Call call, Conversation conversation); + public abstract async void notify_dialing(); + public abstract async void retract_dialing(); public abstract async void notify_subscription_request(Conversation conversation); public abstract async void notify_connection_error(Account account, ConnectionManager.ConnectionError error); public abstract async void notify_muc_invite(Account account, Jid room_jid, Jid from_jid, string inviter_display_name); diff --git a/main/src/ui/notifier_freedesktop.vala b/main/src/ui/notifier_freedesktop.vala index a1df5990..79b07744 100644 --- a/main/src/ui/notifier_freedesktop.vala +++ b/main/src/ui/notifier_freedesktop.vala @@ -118,7 +118,6 @@ public class Dino.Ui.FreeDesktopNotifier : NotificationProvider, Object { HashTable hash_table = new HashTable(null, null); hash_table["image-path"] = "call-start-symbolic"; - hash_table["sound-name"] = new Variant.string("phone-incoming-call"); hash_table["urgency"] = new Variant.byte(2); hash_table["desktop-entry"] = new Variant.string(Dino.Application.get_default().get_application_id()); hash_table["category"] = new Variant.string("im"); @@ -153,6 +152,9 @@ public class Dino.Ui.FreeDesktopNotifier : NotificationProvider, Object { } catch (Error e) { } } + public async void notify_dialing(){} + public async void retract_dialing(){} + public async void notify_subscription_request(Conversation conversation) { string summary = _("Subscription request"); string body = Markup.escape_text(conversation.counterpart.to_string()); diff --git a/main/src/ui/notifier_gnotifications.vala b/main/src/ui/notifier_gnotifications.vala index 4d36620d..83df1868 100644 --- a/main/src/ui/notifier_gnotifications.vala +++ b/main/src/ui/notifier_gnotifications.vala @@ -87,6 +87,9 @@ namespace Dino.Ui { GLib.Application.get_default().withdraw_notification(call.id.to_string()); } + public async void notify_dialing(){} + public async void retract_dialing(){} + public async void notify_subscription_request(Conversation conversation) { Notification notification = new Notification(_("Subscription request")); notification.set_body(conversation.counterpart.to_string()); diff --git a/plugins/phone-ringer/CMakeLists.txt b/plugins/phone-ringer/CMakeLists.txt new file mode 100644 index 00000000..58f77499 --- /dev/null +++ b/plugins/phone-ringer/CMakeLists.txt @@ -0,0 +1,28 @@ +find_packages(PHONE_RINGER_PACKAGES REQUIRED + Canberra + Gee + GLib + GModule + GObject + GDKPixbuf2 +) + +vala_precompile(PHONE_RINGER_VALA_C +SOURCES + src/plugin.vala + src/register_plugin.vala +CUSTOM_VAPIS + ${CMAKE_BINARY_DIR}/exports/xmpp-vala.vapi + ${CMAKE_BINARY_DIR}/exports/dino.vapi + ${CMAKE_BINARY_DIR}/exports/qlite.vapi +PACKAGES + ${PHONE_RINGER_PACKAGES} +) + +add_definitions(${VALA_CFLAGS}) +add_library(phone-ringer SHARED ${PHONE_RINGER_VALA_C}) +target_link_libraries(phone-ringer libdino ${PHONE_RINGER_PACKAGES}) +set_target_properties(phone-ringer PROPERTIES PREFIX "") +set_target_properties(phone-ringer PROPERTIES LIBRARY_OUTPUT_DIRECTORY ${CMAKE_BINARY_DIR}/plugins/) + +install(TARGETS phone-ringer ${PLUGIN_INSTALL}) diff --git a/plugins/phone-ringer/src/plugin.vala b/plugins/phone-ringer/src/plugin.vala new file mode 100644 index 00000000..e2e2c04d --- /dev/null +++ b/plugins/phone-ringer/src/plugin.vala @@ -0,0 +1,83 @@ +using Dino.Entities; +using Xmpp; + +namespace Dino.Plugins.PhoneRinger { + +public class Plugin : RootInterface, NotificationProvider, Object { + + private Canberra.Context sound_context; + private const int ringer_id = 0; + private const int dialer_id = 1; + private Canberra.Proplist ringer_props; + private Canberra.Proplist dialer_props; + + private void loop_ringer() { + sound_context.play_full(ringer_id, ringer_props, (c, id, code) => { + if (code != Canberra.Error.CANCELED) { + Idle.add(() => { + loop_ringer(); + return Source.REMOVE; + }); + } + }); + } + + private void loop_dialer() { + sound_context.play_full(dialer_id, dialer_props, (c, id, code) => { + if (code != Canberra.Error.CANCELED) { + Idle.add(() => { + loop_dialer(); + return Source.REMOVE; + }); + } + }); + } + + public void registered(Dino.Application app) { + + Canberra.Context.create(out sound_context); + Canberra.Proplist.create(out ringer_props); + Canberra.Proplist.create(out dialer_props); + ringer_props.sets(Canberra.PROP_EVENT_ID, "phone-incoming-call"); + ringer_props.sets(Canberra.PROP_EVENT_DESCRIPTION, "Incoming call"); + dialer_props.sets(Canberra.PROP_EVENT_ID, "phone-outgoing-calling"); + dialer_props.sets(Canberra.PROP_EVENT_DESCRIPTION, "Outgoing call"); + + NotificationEvents notification_events = app.stream_interactor.get_module(NotificationEvents.IDENTITY); + notification_events.register_notification_provider.begin(this); + } + + public void shutdown() { } + + public async void notify_call(Call call, Conversation conversation, bool video, bool multiparty, string conversation_display_name){ + loop_ringer(); + } + + public async void retract_call_notification(Call call, Conversation conversation){ + sound_context.cancel(ringer_id); + } + + public async void notify_dialing(){ + loop_dialer(); + } + + public async void retract_dialing(){ + sound_context.cancel(dialer_id); + } + + public double get_priority(){ + return 0; + } + + public async void notify_message(Message message, Conversation conversation, string conversation_display_name, string? participant_display_name){} + public async void notify_file(FileTransfer file_transfer, Conversation conversation, bool is_image, string conversation_display_name, string? participant_display_name){} + public async void notify_subscription_request(Conversation conversation){} + public async void notify_connection_error(Account account, ConnectionManager.ConnectionError error){} + public async void notify_muc_invite(Account account, Jid room_jid, Jid from_jid, string inviter_display_name){} + public async void notify_voice_request(Conversation conversation, Jid from_jid){} + public async void retract_content_item_notifications(){} + public async void retract_conversation_notifications(Conversation conversation){} + +} + +} diff --git a/plugins/phone-ringer/src/register_plugin.vala b/plugins/phone-ringer/src/register_plugin.vala new file mode 100644 index 00000000..9008ea75 --- /dev/null +++ b/plugins/phone-ringer/src/register_plugin.vala @@ -0,0 +1,3 @@ +public Type register_plugin(Module module) { + return typeof (Dino.Plugins.PhoneRinger.Plugin); +}