Bogdan-Ștefan Neacşu
4f46e36aa8
* Make gateway mnemonic optional * Remove unnecessary timer struct * Prepare for code reuse * Use trait for stats collector * Put trait definition in common crate * Gateway stats runner * Custom statistics url arg * Build & send stats req to url * Storage support for new stats type * Make gateway stats opt in * Test&clippy fixes * CHANGELOG update
57 lines
1.5 KiB
Rust
57 lines
1.5 KiB
Rust
// Copyright 2022 - Nym Technologies SA <contact@nymtech.net>
|
|
// SPDX-License-Identifier: Apache-2.0
|
|
|
|
use crate::error::StatsError;
|
|
use crate::StatsMessage;
|
|
|
|
pub const DEFAULT_STATISTICS_SERVICE_ADDRESS: &str = "127.0.0.1";
|
|
pub const DEFAULT_STATISTICS_SERVICE_PORT: u16 = 8090;
|
|
|
|
pub const STATISTICS_SERVICE_VERSION: &str = "/v1";
|
|
pub const STATISTICS_SERVICE_API_STATISTICS: &str = "statistic";
|
|
|
|
pub async fn build_and_send_statistics_request(
|
|
msg: StatsMessage,
|
|
url: String,
|
|
) -> Result<(), StatsError> {
|
|
reqwest::Client::new()
|
|
.post(format!(
|
|
"{}{}/{}",
|
|
url, STATISTICS_SERVICE_VERSION, STATISTICS_SERVICE_API_STATISTICS
|
|
))
|
|
.json(&msg)
|
|
.send()
|
|
.await?;
|
|
|
|
Ok(())
|
|
}
|
|
|
|
pub fn build_statistics_request_bytes(msg: StatsMessage) -> Result<Vec<u8>, StatsError> {
|
|
let json_msg = msg.to_json()?;
|
|
|
|
let req = reqwest::Request::new(
|
|
reqwest::Method::POST,
|
|
reqwest::Url::parse(&format!(
|
|
"http://{}:{}{}/{}",
|
|
DEFAULT_STATISTICS_SERVICE_ADDRESS,
|
|
DEFAULT_STATISTICS_SERVICE_PORT,
|
|
STATISTICS_SERVICE_VERSION,
|
|
STATISTICS_SERVICE_API_STATISTICS
|
|
))
|
|
.unwrap(),
|
|
);
|
|
let data = format!(
|
|
"{} {} {:?}\n\
|
|
Content-Type: application/json\n\
|
|
Content-Length: {}\n\n\
|
|
{}\n",
|
|
req.method().as_str(),
|
|
req.url().as_str(),
|
|
req.version(),
|
|
json_msg.len(),
|
|
json_msg
|
|
);
|
|
|
|
Ok(data.into_bytes())
|
|
}
|