use std::{
fmt::{Debug, Display},
hash::Hash,
};
use nautilus_core::correctness::{FAILED, check_valid_string_ascii};
use ustr::Ustr;
#[repr(C)]
#[derive(Clone, Copy, Hash, PartialEq, Eq, PartialOrd, Ord)]
#[cfg_attr(
feature = "python",
pyo3::pyclass(module = "nautilus_trader.core.nautilus_pyo3.model", from_py_object)
)]
#[cfg_attr(
feature = "python",
pyo3_stub_gen::derive::gen_stub_pyclass(module = "nautilus_trader.model")
)]
pub struct ClientOrderId(Ustr);
impl ClientOrderId {
pub fn new_checked<T: AsRef<str>>(value: T) -> anyhow::Result<Self> {
let value = value.as_ref();
check_valid_string_ascii(value, stringify!(value))?;
Ok(Self(Ustr::from(value)))
}
pub fn new<T: AsRef<str>>(value: T) -> Self {
Self::new_checked(value).expect(FAILED)
}
#[cfg_attr(not(feature = "python"), allow(dead_code))]
pub(crate) fn set_inner(&mut self, value: &str) {
self.0 = Ustr::from(value);
}
#[must_use]
pub fn inner(&self) -> Ustr {
self.0
}
#[must_use]
pub fn as_str(&self) -> &str {
self.0.as_str()
}
#[must_use]
pub fn external() -> Self {
Self::new("EXTERNAL")
}
#[must_use]
pub fn is_external(&self) -> bool {
self.0.as_str() == "EXTERNAL"
}
}
impl Debug for ClientOrderId {
fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
write!(f, "\"{}\"", self.0)
}
}
impl Display for ClientOrderId {
fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
write!(f, "{}", self.0)
}
}
#[must_use]
pub fn optional_ustr_to_vec_client_order_ids(s: Option<Ustr>) -> Option<Vec<ClientOrderId>> {
s.map(|ustr| {
let s_str = ustr.to_string();
s_str
.split(',')
.map(ClientOrderId::new)
.collect::<Vec<ClientOrderId>>()
})
}
#[must_use]
pub fn optional_vec_client_order_ids_to_ustr(vec: Option<Vec<ClientOrderId>>) -> Option<Ustr> {
vec.map(|client_order_ids| {
let s: String = client_order_ids
.into_iter()
.map(|id| id.to_string())
.collect::<Vec<String>>()
.join(",");
Ustr::from(&s)
})
}
#[cfg(test)]
mod tests {
use rstest::rstest;
use ustr::Ustr;
use super::ClientOrderId;
use crate::identifiers::{
client_order_id::{
optional_ustr_to_vec_client_order_ids, optional_vec_client_order_ids_to_ustr,
},
stubs::*,
};
#[rstest]
fn test_string_reprs(client_order_id: ClientOrderId) {
assert_eq!(client_order_id.as_str(), "O-19700101-000000-001-001-1");
assert_eq!(format!("{client_order_id}"), "O-19700101-000000-001-001-1");
}
#[rstest]
fn test_optional_ustr_to_vec_client_order_ids() {
assert_eq!(optional_ustr_to_vec_client_order_ids(None), None);
let ustr = Ustr::from("id1,id2,id3");
let client_order_ids = optional_ustr_to_vec_client_order_ids(Some(ustr)).unwrap();
assert_eq!(client_order_ids[0].as_str(), "id1");
assert_eq!(client_order_ids[1].as_str(), "id2");
assert_eq!(client_order_ids[2].as_str(), "id3");
}
#[rstest]
fn test_optional_vec_client_order_ids_to_ustr() {
assert_eq!(optional_vec_client_order_ids_to_ustr(None), None);
let client_order_ids = vec![
ClientOrderId::from("id1"),
ClientOrderId::from("id2"),
ClientOrderId::from("id3"),
];
let ustr = optional_vec_client_order_ids_to_ustr(Some(client_order_ids)).unwrap();
assert_eq!(ustr.to_string(), "id1,id2,id3");
}
}