[Add] Notification handling

src/data/communication.rs

@@ -35,6 +35,7 @@ pub enum DataTypes {
     denied_profiles,
     content,
     messages,
+    notifications,
     send_time,
     get_time,
     get_variant,
@@ -142,6 +143,11 @@ pub enum CommunicationType {
     message_other_iota,
     message_chunk,
     messages_get,
+
+    push_notification,
+    read_notification,
+    get_notifications,
+
     change_confirm,
     confirm_receive,
     confirm_read,

src/omega/omega_connection.rs

@@ -126,7 +126,7 @@ impl OmegaConnection {
         }
 
         loop {
-            if retry > 5 {
+            if retry > 500 {
                 log_err!(
                     0,
                     PrintType::Omega,

src/rho/client_connection.rs

@@ -361,6 +361,8 @@ impl ClientConnection {
             }
 
             if cv.is_type(CommunicationType::change_user_data)
+                || cv.is_type(CommunicationType::read_notification)
+                || cv.is_type(CommunicationType::get_notifications)
                 || cv.is_type(CommunicationType::get_user_data)
                 || cv.is_type(CommunicationType::get_iota_data)
                 || cv.is_type(CommunicationType::delete_user)

src/rho/iota_connection.rs

@@ -32,7 +32,6 @@ use x448::PublicKey;
 
 use super::{rho_connection::RhoConnection, rho_manager};
 use crate::{
-    // calls::call_manager::CallManager,
     data::communication::{CommunicationType, CommunicationValue, DataTypes},
     omega::omega_connection::OmegaConnection,
 };
@@ -434,6 +433,7 @@ impl IotaConnection {
         }
 
         if cv.is_type(CommunicationType::change_iota_data)
+            || cv.is_type(CommunicationType::push_notification)
             || cv.is_type(CommunicationType::get_user_data)
             || cv.is_type(CommunicationType::get_iota_data)
             || cv.is_type(CommunicationType::get_register)