#![allow(unused_imports)]
use async_trait::async_trait;
use derive_builder::Builder;
use reqwest;
use rust_decimal::prelude::*;
use serde::{Deserialize, Serialize};
use serde_json::{Value, json};
use std::collections::BTreeMap;
use crate::common::{
config::ConfigurationRestApi,
models::{ParamBuildError, RestApiResponse},
utils::send_request,
};
use crate::stocks::rest_api::models;
const HAS_TIME_UNIT: bool = false;
#[async_trait]
pub trait UserDataStreamsApi: Send + Sync {
async fn create_renew_listen_key(
&self,
params: CreateRenewListenKeyParams,
) -> anyhow::Result<RestApiResponse<models::CreateRenewListenKeyResponse>>;
}
#[derive(Debug, Clone)]
pub struct UserDataStreamsApiClient {
configuration: ConfigurationRestApi,
}
impl UserDataStreamsApiClient {
pub fn new(configuration: ConfigurationRestApi) -> Self {
Self { configuration }
}
}
#[derive(Clone, Debug, Builder, Deserialize, Default)]
#[builder(pattern = "owned", build_fn(error = "ParamBuildError"))]
pub struct CreateRenewListenKeyParams {
#[builder(setter(into), default)]
#[serde(rename = "recvWindow", default)]
pub recv_window: Option<i64>,
}
impl CreateRenewListenKeyParams {
#[must_use]
pub fn builder() -> CreateRenewListenKeyParamsBuilder {
CreateRenewListenKeyParamsBuilder::default()
}
}
#[async_trait]
impl UserDataStreamsApi for UserDataStreamsApiClient {
async fn create_renew_listen_key(
&self,
params: CreateRenewListenKeyParams,
) -> anyhow::Result<RestApiResponse<models::CreateRenewListenKeyResponse>> {
let CreateRenewListenKeyParams { recv_window } = params;
let mut query_params = BTreeMap::new();
let body_params = BTreeMap::new();
if let Some(rw) = recv_window {
query_params.insert("recvWindow".to_string(), json!(rw));
}
send_request::<models::CreateRenewListenKeyResponse>(
&self.configuration,
"/sapi/v1/equity/listenKey",
reqwest::Method::POST,
query_params,
body_params,
if HAS_TIME_UNIT {
self.configuration.time_unit
} else {
None
},
false,
)
.await
}
}
#[cfg(all(test, feature = "stocks"))]
mod tests {
use super::*;
use crate::TOKIO_SHARED_RT;
use crate::{errors::ConnectorError, models::DataFuture, models::RestApiRateLimit};
use async_trait::async_trait;
use std::collections::HashMap;
struct DummyRestApiResponse<T> {
inner: Box<dyn FnOnce() -> DataFuture<Result<T, ConnectorError>> + Send + Sync>,
status: u16,
headers: HashMap<String, String>,
rate_limits: Option<Vec<RestApiRateLimit>>,
}
impl<T> From<DummyRestApiResponse<T>> for RestApiResponse<T> {
fn from(dummy: DummyRestApiResponse<T>) -> Self {
Self {
data_fn: dummy.inner,
status: dummy.status,
headers: dummy.headers,
rate_limits: dummy.rate_limits,
}
}
}
struct MockUserDataStreamsApiClient {
force_error: bool,
}
#[async_trait]
impl UserDataStreamsApi for MockUserDataStreamsApiClient {
async fn create_renew_listen_key(
&self,
_params: CreateRenewListenKeyParams,
) -> anyhow::Result<RestApiResponse<models::CreateRenewListenKeyResponse>> {
if self.force_error {
return Err(ConnectorError::ConnectorClientError {
msg: "ResponseError".to_string(),
code: None,
}
.into());
}
let resp_json: Value = serde_json::from_str(
r#"{"listenKey":"pqia91ma19a5s61cv6a81va65sdf19v8a65s1cv1zuz3ee1c5xz2ef6ad7"}"#,
)
.unwrap_or_else(|_| serde_json::json!({}));
let dummy_response: models::CreateRenewListenKeyResponse =
serde_json::from_value(resp_json.clone())
.expect("should parse into models::CreateRenewListenKeyResponse");
let dummy = DummyRestApiResponse {
inner: Box::new(move || Box::pin(async move { Ok(dummy_response) })),
status: 200,
headers: HashMap::new(),
rate_limits: None,
};
Ok(dummy.into())
}
}
#[test]
fn create_renew_listen_key_required_params_success() {
TOKIO_SHARED_RT.block_on(async {
let client = MockUserDataStreamsApiClient { force_error: false };
let params = CreateRenewListenKeyParams::builder().build().unwrap();
let resp_json: Value = serde_json::from_str(
r#"{"listenKey":"pqia91ma19a5s61cv6a81va65sdf19v8a65s1cv1zuz3ee1c5xz2ef6ad7"}"#,
)
.unwrap_or_else(|_| serde_json::json!({}));
let expected_response: models::CreateRenewListenKeyResponse =
serde_json::from_value(resp_json.clone())
.expect("should parse into models::CreateRenewListenKeyResponse");
let resp = client
.create_renew_listen_key(params)
.await
.expect("Expected a response");
let data_future = resp.data();
let actual_response = data_future.await.unwrap();
assert_eq!(actual_response, expected_response);
});
}
#[test]
fn create_renew_listen_key_optional_params_success() {
TOKIO_SHARED_RT.block_on(async {
let client = MockUserDataStreamsApiClient { force_error: false };
let params = CreateRenewListenKeyParams::builder()
.recv_window(5000)
.build()
.unwrap();
let resp_json: Value = serde_json::from_str(
r#"{"listenKey":"pqia91ma19a5s61cv6a81va65sdf19v8a65s1cv1zuz3ee1c5xz2ef6ad7"}"#,
)
.unwrap_or_else(|_| serde_json::json!({}));
let expected_response: models::CreateRenewListenKeyResponse =
serde_json::from_value(resp_json.clone())
.expect("should parse into models::CreateRenewListenKeyResponse");
let resp = client
.create_renew_listen_key(params)
.await
.expect("Expected a response");
let data_future = resp.data();
let actual_response = data_future.await.unwrap();
assert_eq!(actual_response, expected_response);
});
}
#[test]
fn create_renew_listen_key_response_error() {
TOKIO_SHARED_RT.block_on(async {
let client = MockUserDataStreamsApiClient { force_error: true };
let params = CreateRenewListenKeyParams::builder().build().unwrap();
match client.create_renew_listen_key(params).await {
Ok(_) => panic!("Expected an error"),
Err(err) => {
assert_eq!(err.to_string(), "Connector client error: ResponseError");
}
}
});
}
}