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

License

Browse source
This commit is contained in:
Alex Emmet 2025-11-03 20:26:06 +00:00
commit 9729fb0c09
4 changed files with 27 additions and 15 deletions
Download patch file Download diff file Expand all files Collapse all files

8
src/rho/iota_connection.rs
View file

@ -254,14 +254,16 @@ impl IotaConnection {
let receiver_id = cv.get_receiver();
let sender_id = cv.get_sender();
if !self.get_user_ids().await.contains(&sender_id) {
self.send_error_response(&cv.get_id()).await;
self.send_message(CommunicationValue::new(
CommunicationType::error_invalid_user_id,
));
return;
}
if let Some(target_rho) = rho_manager::get_rho_con_for_user(receiver_id).await {
target_rho.message_to_iota(cv).await;
} else {
let error = CommunicationValue::new(CommunicationType::error)
let error = CommunicationValue::new(CommunicationType::error_no_iota)
.with_id(cv.get_id())
.with_sender(cv.get_sender());
self.send_message(error).await;
@ -311,7 +313,7 @@ impl IotaConnection {
if let Some(rho_conn) = self.get_rho_connection().await {
let updated_cv = cv.with_sender(self.get_iota_id().await);
let receiver_id = updated_cv.get_receiver();
rho_conn.message_iota_to_client(updated_cv).await;
rho_conn.message_to_client(updated_cv).await;
}
}