Skip to content

#58 benchmark sender #61

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
WingZer0o merged 8 commits into from
Nov 23, 2025
Merged

#58 benchmark sender #61

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
8 commits
Select commit Hold shift + click to select a range
f0e5fc3
add tokio
WingZer0o Nov 22, 2025
8222cc7
adding debug
WingZer0o Nov 23, 2025
6f3a8e0
basic benchmark sender
WingZer0o Nov 23, 2025
dbf691a
adding basic http cache and benchmark sender
WingZer0o Nov 23, 2025
152edb7
version bump
WingZer0o Nov 23, 2025
ddee644
task spawn
WingZer0o Nov 23, 2025
d699c8c
bench mark sending
WingZer0o Nov 23, 2025
beeb9da
remove http test
WingZer0o Nov 23, 2025
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
249 changes: 249 additions & 0 deletions .vscode/launch.json
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -0,0 +1,249 @@
{
"version": "0.2.0",
"configurations": [
{
"name": "Debug unit tests in library 'cas_lib'",
"type": "lldb",
"request": "launch",
"cargo": {
"args": [
"test",
"--lib",
"--no-run"
]
},
"program": "${cargo:program}",
"args": [
"--nocapture"
],
"cwd": "${workspaceFolder}",
"env": {
"RUST_BACKTRACE": "1"
},
"console": "integratedTerminal"
},

// Integration tests
{
"name": "Debug integration test: asymmetric",
"type": "lldb",
"request": "launch",
"cargo": {
"args": [
"test",
"--test=asymmetric",
"--no-run"
]
},
"program": "${cargo:program}",
"args": ["--nocapture"],
"cwd": "${workspaceFolder}",
"env": { "RUST_BACKTRACE": "1" },
"console": "integratedTerminal"
},
{
"name": "Debug integration test: compression",
"type": "lldb",
"request": "launch",
"cargo": {
"args": [
"test",
"--test=compression",
"--no-run"
]
},
"program": "${cargo:program}",
"args": ["--nocapture"],
"cwd": "${workspaceFolder}",
"env": { "RUST_BACKTRACE": "1" },
"console": "integratedTerminal"
},
{
"name": "Debug integration test: digital_signatures",
"type": "lldb",
"request": "launch",
"cargo": {
"args": [
"test",
"--test=digital_signatures",
"--no-run"
]
},
"program": "${cargo:program}",
"args": ["--nocapture"],
"cwd": "${workspaceFolder}",
"env": { "RUST_BACKTRACE": "1" },
"console": "integratedTerminal"
},
{
"name": "Debug integration test: hashers",
"type": "lldb",
"request": "launch",
"cargo": {
"args": [
"test",
"--test=hashers",
"--no-run"
]
},
"program": "${cargo:program}",
"args": ["--nocapture"],
"cwd": "${workspaceFolder}",
"env": { "RUST_BACKTRACE": "1" },
"console": "integratedTerminal"
},
{
"name": "Debug integration test: http",
"type": "lldb",
"request": "launch",
"cargo": {
"args": [
"test",
"--test=http",
"--no-run"
]
},
"program": "${cargo:program}",
"args": ["--nocapture"],
"cwd": "${workspaceFolder}",
"env": { "RUST_BACKTRACE": "1" },
"console": "integratedTerminal"
},
{
"name": "Debug integration test: hybrid",
"type": "lldb",
"request": "launch",
"cargo": {
"args": [
"test",
"--test=hybrid",
"--no-run"
]
},
"program": "${cargo:program}",
"args": ["--nocapture"],
"cwd": "${workspaceFolder}",
"env": { "RUST_BACKTRACE": "1" },
"console": "integratedTerminal"
},
{
"name": "Debug integration test: key_exchange",
"type": "lldb",
"request": "launch",
"cargo": {
"args": [
"test",
"--test=key_exchange",
"--no-run"
]
},
"program": "${cargo:program}",
"args": ["--nocapture"],
"cwd": "${workspaceFolder}",
"env": { "RUST_BACKTRACE": "1" },
"console": "integratedTerminal"
},
{
"name": "Debug integration test: message",
"type": "lldb",
"request": "launch",
"cargo": {
"args": [
"test",
"--test=message",
"--no-run"
]
},
"program": "${cargo:program}",
"args": ["--nocapture"],
"cwd": "${workspaceFolder}",
"env": { "RUST_BACKTRACE": "1" },
"console": "integratedTerminal"
},
{
"name": "Debug integration test: password_hashers",
"type": "lldb",
"request": "launch",
"cargo": {
"args": [
"test",
"--test=password_hashers",
"--no-run"
]
},
"program": "${cargo:program}",
"args": ["--nocapture"],
"cwd": "${workspaceFolder}",
"env": { "RUST_BACKTRACE": "1" },
"console": "integratedTerminal"
},
{
"name": "Debug integration test: pqc",
"type": "lldb",
"request": "launch",
"cargo": {
"args": [
"test",
"--test=pqc",
"--no-run"
]
},
"program": "${cargo:program}",
"args": ["--nocapture"],
"cwd": "${workspaceFolder}",
"env": { "RUST_BACKTRACE": "1" },
"console": "integratedTerminal"
},
{
"name": "Debug integration test: signatures",
"type": "lldb",
"request": "launch",
"cargo": {
"args": [
"test",
"--test=signatures",
"--no-run"
]
},
"program": "${cargo:program}",
"args": ["--nocapture"],
"cwd": "${workspaceFolder}",
"env": { "RUST_BACKTRACE": "1" },
"console": "integratedTerminal"
},
{
"name": "Debug integration test: sponges",
"type": "lldb",
"request": "launch",
"cargo": {
"args": [
"test",
"--test=sponges",
"--no-run"
]
},
"program": "${cargo:program}",
"args": ["--nocapture"],
"cwd": "${workspaceFolder}",
"env": { "RUST_BACKTRACE": "1" },
"console": "integratedTerminal"
},
{
"name": "Debug integration test: symmetric",
"type": "lldb",
"request": "launch",
"cargo": {
"args": [
"test",
"--test=symmetric",
"--no-run"
]
},
"program": "${cargo:program}",
"args": ["--nocapture"],
"cwd": "${workspaceFolder}",
"env": { "RUST_BACKTRACE": "1" },
"console": "integratedTerminal"
}
]
}
8 changes: 7 additions & 1 deletion Cargo.toml
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -1,6 +1,6 @@
[package]
name = "cas-lib"
version = "0.2.66"
version = "0.2.67"
edition = "2021"
description = "A function wrapper layer for RustCrypto and Dalek-Cryptography. Intended to be used in FFI situations with a global heap deallactor at the top level project."
license = "Apache-2.0"
Expand Down Expand Up @@ -34,9 +34,15 @@ hkdf = "0.12.4"
chacha20poly1305 = "0.10.1"
slh-dsa = "0.0.3"
ml-kem = "0.2.1"
reqwest = { version = "0.12.24", features = ["json", "cookies", "rustls-tls"] }
serde = "1.0.228"
tokio = { version = "1.48.0", features = ["macros", "rt-multi-thread"] }
url = "2.5.7"
once_cell = "1.21.3"

[profile.dev.package.num-bigint-dig]
opt-level = 3

[build-dependencies]
napi-build = "1"

96 changes: 96 additions & 0 deletions src/http/mod.rs
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -0,0 +1,96 @@
use reqwest::{Client, cookie::Jar};
use std::sync::{Arc, Mutex};
use url::Url;

pub mod types;
use crate::http::types::{BenchmarkRequest};

static API_KEY: Mutex<String> = Mutex::new(String::new());
static BASE_URL: Mutex<String> = Mutex::new(String::new());

static TOKEN: Mutex<String> = Mutex::new(String::new());
static REFRESH_TOKEN: Mutex<String> = Mutex::new(String::new());
static BENCHMARK_SENDER_CLIENT: Mutex<Option<Client>> = Mutex::new(None);

fn create_benchmark_sender_client(token: String, refresh_token: String) -> Client {
let cookie_store = Arc::new(Jar::default());
let base_url = Url::parse(BASE_URL.lock().unwrap().as_str()).unwrap();
cookie_store.add_cookie_str(&format!("Token={}; Path=/", token), &base_url);
cookie_store.add_cookie_str(&format!("RefreshToken={}; Path=/", refresh_token), &base_url);
Client::builder()
.cookie_provider(cookie_store)
.build()
.unwrap()
}

fn determine_api_route() -> String {
let base_url = BASE_URL.lock().unwrap();
if base_url.contains("cryptographicapiservices.com") {
"api/userapi".to_string()
} else {
"api".to_string()
}
}

pub async fn set_api_key_in_cache(api_key: String) {
let mut key = API_KEY.lock().unwrap();
*key = api_key.clone();
set_tokens_in_cache(api_key).await;
}

pub fn set_base_url_in_cache(base_url: String) {
let mut url = BASE_URL.lock().unwrap();
*url = base_url
}

pub async fn set_tokens_in_cache(api_key: String) {
let client = Client::new();
let base_url = BASE_URL.lock().unwrap().clone();
let url = format!("{}/{}/APIKey/GetToken", base_url, determine_api_route());
let response_task = client
.get(url)
.header("Authorization", api_key)
.send()
.await;
let response = response_task.unwrap().json::<types::AuthResponse>().await;
match response {
Ok(auth_response) => {
{
let mut token = TOKEN.lock().unwrap();
*token = auth_response.token.clone();
}
{
let mut refresh = REFRESH_TOKEN.lock().unwrap();
*refresh = auth_response.refresh_token.clone();
}
{
let mut bench_client = BENCHMARK_SENDER_CLIENT.lock().unwrap();
*bench_client = Some(create_benchmark_sender_client(
auth_response.token,
auth_response.refresh_token,
));
}
}

Err(_) => {
*TOKEN.lock().unwrap() = String::new();
*REFRESH_TOKEN.lock().unwrap() = String::new();
}
}
}

pub async fn send_benchmark(time_in_milliseconds: i64, class_name: String, method_name: String) {
let payload = BenchmarkRequest {
class_name,
method_name,
time_in_milliseconds,
};
let base_url = BASE_URL.lock().unwrap().clone();
let client = BENCHMARK_SENDER_CLIENT.lock().unwrap().as_ref().unwrap().clone();

let response = client
.post(format!("{}/{}/Benchmark", base_url, determine_api_route()))
.json(&payload)
.send()
.await;
}
18 changes: 18 additions & 0 deletions src/http/types/mod.rs
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -0,0 +1,18 @@
use serde::Serialize;

pub mod runtime;

#[derive(Serialize)]
#[serde(rename_all = "camelCase")]
pub struct BenchmarkRequest {
pub class_name: String,
pub method_name: String,
pub time_in_milliseconds: i64
}

#[derive(serde::Deserialize)]
#[serde(rename_all = "camelCase")]
pub struct AuthResponse {
pub token: String,
pub refresh_token: String
}
Loading