-
-
Notifications
You must be signed in to change notification settings - Fork 40
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Basic notifications feature.
- Loading branch information
Showing
10 changed files
with
837 additions
and
29 deletions.
There are no files selected for viewing
Large diffs are not rendered by default.
Oops, something went wrong.
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,221 @@ | ||
| use std::time::SystemTime; | ||
|
|
||
| use matrix_sdk::{ | ||
| notification_settings::{IsEncrypted, IsOneToOne, NotificationSettings, RoomNotificationMode}, | ||
| room::Room as MatrixRoom, | ||
| ruma::{ | ||
| api::client::push::get_notifications::v3::Notification, | ||
| events::{room::message::MessageType, AnyMessageLikeEventContent, AnySyncTimelineEvent}, | ||
| MilliSecondsSinceUnixEpoch, | ||
| RoomId, | ||
| }, | ||
| Client, | ||
| }; | ||
| use unicode_segmentation::UnicodeSegmentation; | ||
|
|
||
| use crate::{ | ||
| base::{AsyncProgramStore, IambError, IambResult}, | ||
| config::ApplicationSettings, | ||
| }; | ||
|
|
||
| pub async fn register_notifications( | ||
| client: &Client, | ||
| settings: &ApplicationSettings, | ||
| store: &AsyncProgramStore, | ||
| ) { | ||
| if !settings.tunables.notifications.enabled { | ||
| return; | ||
| } | ||
| let show_message = settings.tunables.notifications.show_message; | ||
| let server_settings = client.notification_settings().await; | ||
| let Some(startup_ts) = MilliSecondsSinceUnixEpoch::from_system_time(SystemTime::now()) else { | ||
| return; | ||
| }; | ||
|
|
||
| let store = store.clone(); | ||
| client | ||
| .register_notification_handler(move |notification, room: MatrixRoom, client: Client| { | ||
| let store = store.clone(); | ||
| let server_settings = server_settings.clone(); | ||
| async move { | ||
| let mode = global_or_room_mode(&server_settings, &room).await; | ||
| if mode == RoomNotificationMode::Mute { | ||
| return; | ||
| } | ||
|
|
||
| if is_open(&store, room.room_id()).await { | ||
| return; | ||
| } | ||
|
|
||
| match parse_notification(notification, room).await { | ||
| Ok((summary, body, server_ts)) => { | ||
| if server_ts < startup_ts { | ||
| return; | ||
| } | ||
|
|
||
| let mut desktop_notification = notify_rust::Notification::new(); | ||
| desktop_notification | ||
| .summary(&summary) | ||
| .appname("iamb") | ||
| .timeout(notify_rust::Timeout::Milliseconds(3000)) | ||
| .action("default", "default"); | ||
|
|
||
| if is_missing_mention(&body, mode, &client) { | ||
| return; | ||
| } | ||
| if show_message != Some(false) { | ||
| if let Some(body) = body { | ||
| desktop_notification.body(&body); | ||
| } | ||
| } | ||
| if let Err(err) = desktop_notification.show() { | ||
| tracing::error!("Failed to send notification: {err}") | ||
| } | ||
| }, | ||
| Err(err) => { | ||
| tracing::error!("Failed to extract notification data: {err}") | ||
| }, | ||
| } | ||
| } | ||
| }) | ||
| .await; | ||
| } | ||
|
|
||
| async fn global_or_room_mode( | ||
| settings: &NotificationSettings, | ||
| room: &MatrixRoom, | ||
| ) -> RoomNotificationMode { | ||
| let room_mode = settings.get_user_defined_room_notification_mode(room.room_id()).await; | ||
| if let Some(mode) = room_mode { | ||
| return mode; | ||
| } | ||
| let is_one_to_one = match room.is_direct().await { | ||
| Ok(true) => IsOneToOne::Yes, | ||
| _ => IsOneToOne::No, | ||
| }; | ||
| let is_encrypted = match room.is_encrypted().await { | ||
| Ok(true) => IsEncrypted::Yes, | ||
| _ => IsEncrypted::No, | ||
| }; | ||
| settings | ||
| .get_default_room_notification_mode(is_encrypted, is_one_to_one) | ||
| .await | ||
| } | ||
|
|
||
| fn is_missing_mention(body: &Option<String>, mode: RoomNotificationMode, client: &Client) -> bool { | ||
| if let Some(body) = body { | ||
| if mode == RoomNotificationMode::MentionsAndKeywordsOnly { | ||
| let mentioned = match client.user_id() { | ||
| Some(user_id) => body.contains(user_id.localpart()), | ||
| _ => false, | ||
| }; | ||
| return !mentioned; | ||
| } | ||
| } | ||
| false | ||
| } | ||
|
|
||
| async fn is_open(store: &AsyncProgramStore, room_id: &RoomId) -> bool { | ||
| let mut locked = store.lock().await; | ||
| if let Some(draw_curr) = locked.application.draw_curr { | ||
| let info = locked.application.get_room_info(room_id.to_owned()); | ||
| if let Some(draw_last) = info.draw_last { | ||
| return draw_last == draw_curr; | ||
| } | ||
| } | ||
| false | ||
| } | ||
|
|
||
| pub async fn parse_notification( | ||
| notification: Notification, | ||
| room: MatrixRoom, | ||
| ) -> IambResult<(String, Option<String>, MilliSecondsSinceUnixEpoch)> { | ||
| let event = notification.event.deserialize().map_err(IambError::from)?; | ||
|
|
||
| let server_ts = event.origin_server_ts(); | ||
|
|
||
| let sender_id = event.sender(); | ||
| let sender = room.get_member_no_sync(sender_id).await.map_err(IambError::from)?; | ||
|
|
||
| let sender_name = sender | ||
| .as_ref() | ||
| .and_then(|m| m.display_name()) | ||
| .unwrap_or_else(|| sender_id.localpart()); | ||
|
|
||
| let body = event_notification_body( | ||
| &event, | ||
| sender_name, | ||
| room.is_direct().await.map_err(IambError::from)?, | ||
| ) | ||
| .map(truncate); | ||
| return Ok((sender_name.to_string(), body, server_ts)); | ||
| } | ||
|
|
||
| pub fn event_notification_body( | ||
| event: &AnySyncTimelineEvent, | ||
| sender_name: &str, | ||
| is_direct: bool, | ||
| ) -> Option<String> { | ||
| let AnySyncTimelineEvent::MessageLike(event) = event else { | ||
| return None; | ||
| }; | ||
|
|
||
| match event.original_content()? { | ||
| AnyMessageLikeEventContent::RoomMessage(message) => { | ||
| let body = match message.msgtype { | ||
| MessageType::Audio(_) => { | ||
| format!("{sender_name} sent an audio file.") | ||
| }, | ||
| MessageType::Emote(content) => { | ||
| let message = &content.body; | ||
| format!("{sender_name}: {message}") | ||
| }, | ||
| MessageType::File(_) => { | ||
| format!("{sender_name} sent a file.") | ||
| }, | ||
| MessageType::Image(_) => { | ||
| format!("{sender_name} sent an image.") | ||
| }, | ||
| MessageType::Location(_) => { | ||
| format!("{sender_name} sent their location.") | ||
| }, | ||
| MessageType::Notice(content) => { | ||
| let message = &content.body; | ||
| format!("{sender_name}: {message}") | ||
| }, | ||
| MessageType::ServerNotice(content) => { | ||
| let message = &content.body; | ||
| format!("{sender_name}: {message}") | ||
| }, | ||
| MessageType::Text(content) => { | ||
| if is_direct { | ||
| content.body | ||
| } else { | ||
| let message = &content.body; | ||
| format!("{sender_name}: {message}") | ||
| } | ||
| }, | ||
| MessageType::Video(_) => { | ||
| format!("{sender_name} sent a video.") | ||
| }, | ||
| MessageType::VerificationRequest(_) => { | ||
| format!("{sender_name} sent a verification request.") | ||
| }, | ||
| _ => unimplemented!(), | ||
| }; | ||
| Some(body) | ||
| }, | ||
| AnyMessageLikeEventContent::Sticker(_) => Some(format!("{sender_name} sent a sticker.")), | ||
| _ => None, | ||
| } | ||
| } | ||
|
|
||
| fn truncate(s: String) -> String { | ||
| static MAX_LENGTH: usize = 100; | ||
| if s.graphemes(true).count() > MAX_LENGTH { | ||
| let truncated: String = s.graphemes(true).take(MAX_LENGTH).collect(); | ||
| truncated + "..." | ||
| } else { | ||
| s | ||
| } | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters