sdk_common/src/models/request_prd_message.rs
2024-02-09 17:36:11 +01:00

93 lines
2.8 KiB
Rust

use rocket::FromForm;
use std::{
collections::hash_map::DefaultHasher,
hash::{Hash, Hasher},
};
use serde::{Deserialize, Serialize};
use super::{
key_encryption::KeyEncryption, message_client::MessageClient, request_prd::RequestPrd,
shared_peer::SharedPeer, shared_process::SharedProcess,
};
#[derive(
Debug, Serialize, Deserialize, Default, Clone, PartialEq, Eq, Hash, PartialOrd, Ord, FromForm,
)]
pub struct RequestPrdMessage {
pub prd: RequestPrd,
}
impl RequestPrdMessage {
pub const TYPE: &'static str = "prd_message";
pub fn new(
request_item_name: Option<String>,
request_version: i64,
request_process_hash: String,
request_pcd_reference_hash: Option<String>,
request_item_reference_hash: Option<String>,
pcd_keys_role_confidential_list_enc_by_shared_secret: String,
message_public: Option<String>,
message_confidential: Option<String>,
message_private: Option<String>,
sp_address_to: String,
sp_address_from: String,
sp_address_reply: String,
timestamp_declared: u64,
role_name_from: String,
role_name_to: String,
) -> Self {
let request_type = Self::TYPE.to_string();
let prd = RequestPrd::new(
request_item_name,
request_type,
request_version,
request_process_hash,
request_pcd_reference_hash,
request_item_reference_hash,
pcd_keys_role_confidential_list_enc_by_shared_secret,
message_public,
message_confidential,
message_private,
sp_address_to,
sp_address_from,
sp_address_reply,
timestamp_declared,
role_name_from,
role_name_to,
);
RequestPrdMessage { prd }
}
pub fn to_message(
&self,
process_public_enc_key: KeyEncryption,
message_shared_peer_list: Vec<SharedPeer>,
message_shared_process_list: Vec<SharedProcess>,
message_faucet_sp_address: String,
pow_pathern: String,
pow_difficulty: usize,
) -> MessageClient {
let mut hasher: DefaultHasher = DefaultHasher::new();
self.hash(&mut hasher);
let request_hash = hasher.finish().to_string();
let request_enc: String = process_public_enc_key
.enc_prd_message(self.clone())
.to_string();
MessageClient::new(
request_enc,
request_hash,
message_shared_peer_list,
message_shared_process_list,
message_faucet_sp_address,
pow_pathern,
pow_difficulty,
)
}
// Fonction pour afficher ou retourner les informations
pub fn display_info(&self) -> String {
format!("PRD: {:?}", self.prd)
}
}