Compare commits

...

1 Commits

Author SHA1 Message Date
Bogdan-Ștefan Neacşu 79b8b4d324 Add query message wrapper 2024-11-15 16:31:51 +02:00
3 changed files with 21 additions and 6 deletions
@@ -17,6 +17,11 @@ fn generate_random() -> u64 {
rng.next_u64() rng.next_u64()
} }
#[derive(Serialize, Deserialize, Debug, Clone)]
pub struct QueryMessage {
pub pub_key: PeerPublicKey,
}
#[derive(Clone, Debug, Serialize, Deserialize)] #[derive(Clone, Debug, Serialize, Deserialize)]
pub struct AuthenticatorRequest { pub struct AuthenticatorRequest {
pub protocol: Protocol, pub protocol: Protocol,
@@ -65,7 +70,7 @@ impl AuthenticatorRequest {
) )
} }
pub fn new_query_request(peer_public_key: PeerPublicKey, reply_to: Recipient) -> (Self, u64) { pub fn new_query_request(query_message: QueryMessage, reply_to: Recipient) -> (Self, u64) {
let request_id = generate_random(); let request_id = generate_random();
( (
Self { Self {
@@ -73,7 +78,7 @@ impl AuthenticatorRequest {
service_provider_type: ServiceProviderType::Authenticator, service_provider_type: ServiceProviderType::Authenticator,
version: VERSION, version: VERSION,
}, },
data: AuthenticatorRequestData::QueryBandwidth(peer_public_key), data: AuthenticatorRequestData::QueryBandwidth(query_message.pub_key),
reply_to, reply_to,
request_id, request_id,
}, },
@@ -20,6 +20,11 @@ fn generate_random() -> u64 {
rng.next_u64() rng.next_u64()
} }
#[derive(Serialize, Deserialize, Debug, Clone)]
pub struct QueryMessage {
pub pub_key: PeerPublicKey,
}
#[derive(Clone, Debug, Serialize, Deserialize)] #[derive(Clone, Debug, Serialize, Deserialize)]
pub struct AuthenticatorRequest { pub struct AuthenticatorRequest {
pub protocol: Protocol, pub protocol: Protocol,
@@ -68,7 +73,7 @@ impl AuthenticatorRequest {
) )
} }
pub fn new_query_request(peer_public_key: PeerPublicKey, reply_to: Recipient) -> (Self, u64) { pub fn new_query_request(query_message: QueryMessage, reply_to: Recipient) -> (Self, u64) {
let request_id = generate_random(); let request_id = generate_random();
( (
Self { Self {
@@ -76,7 +81,7 @@ impl AuthenticatorRequest {
service_provider_type: ServiceProviderType::Authenticator, service_provider_type: ServiceProviderType::Authenticator,
version: VERSION, version: VERSION,
}, },
data: AuthenticatorRequestData::QueryBandwidth(peer_public_key), data: AuthenticatorRequestData::QueryBandwidth(query_message.pub_key),
reply_to, reply_to,
request_id, request_id,
}, },
@@ -20,6 +20,11 @@ fn generate_random() -> u64 {
rng.next_u64() rng.next_u64()
} }
#[derive(Serialize, Deserialize, Debug, Clone)]
pub struct QueryMessage {
pub pub_key: PeerPublicKey,
}
#[derive(Clone, Debug, Serialize, Deserialize)] #[derive(Clone, Debug, Serialize, Deserialize)]
pub struct AuthenticatorRequest { pub struct AuthenticatorRequest {
pub protocol: Protocol, pub protocol: Protocol,
@@ -68,7 +73,7 @@ impl AuthenticatorRequest {
) )
} }
pub fn new_query_request(peer_public_key: PeerPublicKey, reply_to: Recipient) -> (Self, u64) { pub fn new_query_request(query_message: QueryMessage, reply_to: Recipient) -> (Self, u64) {
let request_id = generate_random(); let request_id = generate_random();
( (
Self { Self {
@@ -76,7 +81,7 @@ impl AuthenticatorRequest {
service_provider_type: ServiceProviderType::Authenticator, service_provider_type: ServiceProviderType::Authenticator,
version: VERSION, version: VERSION,
}, },
data: AuthenticatorRequestData::QueryBandwidth(peer_public_key), data: AuthenticatorRequestData::QueryBandwidth(query_message.pub_key),
reply_to, reply_to,
request_id, request_id,
}, },