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

[Add] Push notifications

Browse source
This commit is contained in:
Alex Emmet 2026-05-17 21:35:22 +02:00
commit 9d7438d1cb
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, 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 // notify sender
self.send_message( self.send_message(
&CommunicationValue::new(CommunicationType::message_state) &CommunicationValue::new(CommunicationType::message_state)
@ -1071,6 +1077,12 @@ impl OmikronConnection {
MessageState::Sent, 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( self.send_message(
&CommunicationValue::new(CommunicationType::message_state) &CommunicationValue::new(CommunicationType::message_state)
.with_id(cv.get_id()) .with_id(cv.get_id())