Jędrzej Stuczyński
75 lines
2.3 KiB
Rust
75 lines
2.3 KiB
Rust
// Copyright 2023 - Nym Technologies SA <contact@nymtech.net>
|
|
// SPDX-License-Identifier: Apache-2.0
|
|
|
|
use crate::error::WasmClientError;
|
|
use crate::topology::WasmNymTopology;
|
|
use js_sys::Promise;
|
|
use nym_client_core::client::replies::reply_storage::browser_backend;
|
|
use nym_client_core::config;
|
|
use nym_sphinx::addressing::clients::Recipient;
|
|
use nym_sphinx::anonymous_replies::requests::AnonymousSenderTag;
|
|
use nym_topology::NymTopology;
|
|
use nym_validator_client::NymApiClient;
|
|
use url::Url;
|
|
use wasm_bindgen::prelude::wasm_bindgen;
|
|
use wasm_bindgen_futures::future_to_promise;
|
|
use wasm_utils::PromisableResult;
|
|
|
|
// don't get too excited about the name, under the hood it's just a big fat placeholder
|
|
// with no persistence
|
|
pub(crate) fn setup_reply_surb_storage_backend(
|
|
config: config::ReplySurbs,
|
|
) -> browser_backend::Backend {
|
|
browser_backend::Backend::new(
|
|
config.minimum_reply_surb_storage_threshold,
|
|
config.maximum_reply_surb_storage_threshold,
|
|
)
|
|
}
|
|
|
|
pub(crate) fn parse_recipient(recipient: &str) -> Result<Recipient, WasmClientError> {
|
|
Recipient::try_from_base58_string(recipient).map_err(|source| {
|
|
WasmClientError::MalformedRecipient {
|
|
raw: recipient.to_string(),
|
|
source,
|
|
}
|
|
})
|
|
}
|
|
|
|
pub(crate) fn parse_sender_tag(tag: &str) -> Result<AnonymousSenderTag, WasmClientError> {
|
|
AnonymousSenderTag::try_from_base58_string(tag).map_err(|source| {
|
|
WasmClientError::MalformedSenderTag {
|
|
raw: tag.to_string(),
|
|
source,
|
|
}
|
|
})
|
|
}
|
|
|
|
pub(crate) async fn current_network_topology_async(
|
|
nym_api_url: String,
|
|
) -> Result<WasmNymTopology, WasmClientError> {
|
|
let url: Url = match nym_api_url.parse() {
|
|
Ok(url) => url,
|
|
Err(source) => {
|
|
return Err(WasmClientError::MalformedUrl {
|
|
raw: nym_api_url,
|
|
source,
|
|
})
|
|
}
|
|
};
|
|
|
|
let api_client = NymApiClient::new(url);
|
|
let mixnodes = api_client.get_cached_active_mixnodes().await?;
|
|
let gateways = api_client.get_cached_gateways().await?;
|
|
|
|
Ok(NymTopology::from_detailed(mixnodes, gateways).into())
|
|
}
|
|
|
|
#[wasm_bindgen]
|
|
pub fn current_network_topology(nym_api_url: String) -> Promise {
|
|
future_to_promise(async move {
|
|
current_network_topology_async(nym_api_url)
|
|
.await
|
|
.into_promise_result()
|
|
})
|
|
}
|