Jędrzej Stuczyński
833114372a
* wip: changes to surb logic + stronger db typing * surb invalidation logic * chore: remove unused deps * resolving todos * a lot of additional bugfixes * 1.88 clippy * wasm fixes * wasm clippy * wallet clippy * wait for epoch end when setting up new network * split ReplyController into Sender and Receiver for easier reasoning * additional reply surbs improvements includes, but is not limited to: unconditionally reseting sender tag on restart, limiting number of surb re-requests, resetting stale surbs on load * fixed calculation of number of removed surbs * add additional calculated field to key rotation info * DBG: 'request_reply_surbs_for_queue_clearing' temp logs * fixes for silly mistakes * conditionally reduce log severity
73 lines
2.7 KiB
Rust
73 lines
2.7 KiB
Rust
use nym_sdk::mixnet::{
|
|
AnonymousSenderTag, MixnetClientBuilder, MixnetMessageSender, ReconstructedMessage,
|
|
StoragePaths,
|
|
};
|
|
use std::path::PathBuf;
|
|
use tempfile::TempDir;
|
|
|
|
#[tokio::main]
|
|
async fn main() {
|
|
nym_bin_common::logging::setup_tracing_logger();
|
|
|
|
// Specify some config options
|
|
let config_dir: PathBuf = TempDir::new().unwrap().path().to_path_buf();
|
|
let storage_paths = StoragePaths::new_from_dir(&config_dir).unwrap();
|
|
|
|
// Create the client with a storage backend, and enable it by giving it some paths. If keys
|
|
// exists at these paths, they will be loaded, otherwise they will be generated.
|
|
let client = MixnetClientBuilder::new_with_default_storage(storage_paths)
|
|
.await
|
|
.unwrap()
|
|
.build()
|
|
.unwrap();
|
|
|
|
// Now we connect to the mixnet, using keys now stored in the paths provided.
|
|
let mut client = client.connect_to_mixnet().await.unwrap();
|
|
|
|
// Be able to get our client address
|
|
let our_address = client.nym_address();
|
|
println!("\nOur client nym address is: {our_address}");
|
|
|
|
// Send a message through the mixnet to ourselves using our nym address
|
|
client
|
|
.send_plain_message(*our_address, "hello there")
|
|
.await
|
|
.unwrap();
|
|
|
|
// we're going to parse the sender_tag (AnonymousSenderTag) from the incoming message and use it to 'reply' to ourselves instead of our Nym address.
|
|
// we know there will be a sender_tag since the sdk sends SURBs along with messages by default.
|
|
println!("Waiting for message\n");
|
|
|
|
// get the actual message - discard the empty vec sent along with a potential SURB topup request
|
|
let mut message: Vec<ReconstructedMessage> = Vec::new();
|
|
while let Some(new_message) = client.wait_for_messages().await {
|
|
if new_message.is_empty() {
|
|
continue;
|
|
}
|
|
message = new_message;
|
|
break;
|
|
}
|
|
|
|
let mut parsed = String::new();
|
|
if let Some(r) = message.first() {
|
|
parsed = String::from_utf8(r.message.clone()).unwrap();
|
|
}
|
|
// parse sender_tag: we will use this to reply to sender without needing their Nym address
|
|
let return_recipient: AnonymousSenderTag = message[0].sender_tag.unwrap();
|
|
println!(
|
|
"\nReceived the following message: {parsed} \nfrom sender with surb bucket {return_recipient}"
|
|
);
|
|
|
|
// reply to self with it: note we use `send_str_reply` instead of `send_str`
|
|
println!("Replying with using SURBs");
|
|
client
|
|
.send_reply(return_recipient, "hi an0n!")
|
|
.await
|
|
.unwrap();
|
|
|
|
println!("Waiting for message (once you see it, ctrl-c to exit)\n");
|
|
client
|
|
.on_messages(|msg| println!("\nReceived: {}", String::from_utf8_lossy(&msg.message)))
|
|
.await;
|
|
}
|