tensamin/iota
Watch
6
0
Fork
You've already forked iota
 0
Code Issues Pull requests 3 Projects Releases 1 Packages Wiki Activity Actions

Compare commits

base: tensamin:e18e8d1151567afe892ce6b4d430e440a54a801d
Branches Tags
tensamin:main
tensamin:renovate/zip-8.x
tensamin:renovate/rand_core-0.x
tensamin:renovate/rand-0.x
tensamin:renovate/base64-0.x
tensamin:0.1.0-dev-f252724
tensamin:1.0.0
...
compare: tensamin:4114cf6da7a71c247f86320da2f01a15d6b61814
Branches Tags
tensamin:renovate/zip-8.x
tensamin:renovate/rand_core-0.x
tensamin:renovate/rand-0.x
tensamin:renovate/base64-0.x
tensamin:main
tensamin:0.1.0-dev-f252724
tensamin:1.0.0
Author SHA1 Message Date
Alex Emmet
4114cf6da7 notifications 2026-05-17 21:48:01 +02:00
Alex Emmet
9d7438d1cb [Add] Push notifications 2026-05-17 21:35:22 +02:00
1 changed files with 12 additions and 0 deletions
Download patch file Download diff file Expand all files Collapse all files

12
omikron-connector/src/omikron_connection.rs
View file

@ -955,6 +955,12 @@ impl OmikronConnection {
MessageState::Sent,
);
// Send push notification to Omega since user is offline
let push_msg = CommunicationValue::new(CommunicationType::push_notification)
.with_receiver(receiver_id as u64)
.add_data(DataTypes::sender_id, DataValue::Number(sender_id as i64));
self.send_message(&push_msg).await;
// notify sender
self.send_message(
&CommunicationValue::new(CommunicationType::message_state)
@ -1071,6 +1077,12 @@ impl OmikronConnection {
MessageState::Sent,
);
// Send push notification to Omega since user is offline
let push_msg = CommunicationValue::new(CommunicationType::push_notification)
.with_receiver(*receiver_id)
.add_data(DataTypes::sender_id, DataValue::Number(*sender_id as i64));
self.send_message(&push_msg).await;
self.send_message(
&CommunicationValue::new(CommunicationType::message_state)
.with_id(cv.get_id())