nautilus_core/python/
datetime.rs1use pyo3::prelude::*;
19use pyo3_stub_gen::derive::gen_stub_pyfunction;
20
21use super::to_pyvalue_err;
22use crate::{
23 UnixNanos,
24 datetime::{
25 is_within_last_24_hours, last_weekday_nanos, micros_to_nanos, millis_to_nanos,
26 nanos_to_micros, nanos_to_millis, nanos_to_secs, secs_to_millis, secs_to_nanos,
27 unix_nanos_to_iso8601, unix_nanos_to_iso8601_millis,
28 },
29};
30
31#[pyfunction(name = "secs_to_nanos")]
37#[gen_stub_pyfunction(module = "nautilus_trader.core")]
38pub fn py_secs_to_nanos(secs: f64) -> PyResult<u64> {
39 secs_to_nanos(secs).map_err(to_pyvalue_err)
40}
41
42#[pyfunction(name = "secs_to_millis")]
48#[gen_stub_pyfunction(module = "nautilus_trader.core")]
49pub fn py_secs_to_millis(secs: f64) -> PyResult<u64> {
50 secs_to_millis(secs).map_err(to_pyvalue_err)
51}
52
53#[pyfunction(name = "millis_to_nanos")]
62#[gen_stub_pyfunction(module = "nautilus_trader.core")]
63pub fn py_millis_to_nanos(millis: f64) -> PyResult<u64> {
64 millis_to_nanos(millis).map_err(to_pyvalue_err)
65}
66
67#[pyfunction(name = "micros_to_nanos")]
76#[gen_stub_pyfunction(module = "nautilus_trader.core")]
77pub fn py_micros_to_nanos(micros: f64) -> PyResult<u64> {
78 micros_to_nanos(micros).map_err(to_pyvalue_err)
79}
80
81#[must_use]
86#[pyfunction(name = "nanos_to_secs")]
87#[gen_stub_pyfunction(module = "nautilus_trader.core")]
88pub fn py_nanos_to_secs(nanos: u64) -> f64 {
89 nanos_to_secs(nanos)
90}
91
92#[must_use]
94#[pyfunction(name = "nanos_to_millis")]
95#[gen_stub_pyfunction(module = "nautilus_trader.core")]
96pub const fn py_nanos_to_millis(nanos: u64) -> u64 {
97 nanos_to_millis(nanos)
98}
99
100#[must_use]
102#[pyfunction(name = "nanos_to_micros")]
103#[gen_stub_pyfunction(module = "nautilus_trader.core")]
104pub const fn py_nanos_to_micros(nanos: u64) -> u64 {
105 nanos_to_micros(nanos)
106}
107
108#[pyfunction(
113 name = "unix_nanos_to_iso8601",
114 signature = (timestamp_ns, nanos_precision=Some(true))
115)]
116#[gen_stub_pyfunction(module = "nautilus_trader.core")]
117pub fn py_unix_nanos_to_iso8601(
118 timestamp_ns: u64,
119 nanos_precision: Option<bool>,
120) -> PyResult<String> {
121 if timestamp_ns > i64::MAX as u64 {
122 return Err(to_pyvalue_err(
123 "timestamp_ns is out of range for conversion",
124 ));
125 }
126
127 let unix_nanos = UnixNanos::from(timestamp_ns);
128 let formatted = if nanos_precision.unwrap_or(true) {
129 unix_nanos_to_iso8601(unix_nanos)
130 } else {
131 unix_nanos_to_iso8601_millis(unix_nanos)
132 };
133
134 Ok(formatted)
135}
136
137#[pyfunction(name = "last_weekday_nanos")]
143#[gen_stub_pyfunction(module = "nautilus_trader.core")]
144pub fn py_last_weekday_nanos(year: i32, month: u32, day: u32) -> PyResult<u64> {
145 Ok(last_weekday_nanos(year, month, day)
146 .map_err(to_pyvalue_err)?
147 .as_u64())
148}
149
150#[pyfunction(name = "is_within_last_24_hours")]
156#[gen_stub_pyfunction(module = "nautilus_trader.core")]
157pub fn py_is_within_last_24_hours(timestamp_ns: u64) -> PyResult<bool> {
158 is_within_last_24_hours(UnixNanos::from(timestamp_ns)).map_err(to_pyvalue_err)
159}
160
161#[cfg(test)]
162mod tests {
163 use rstest::rstest;
164
165 use super::*;
166
167 #[rstest]
168 fn test_py_unix_nanos_to_iso8601_errors_on_out_of_range_timestamp() {
169 let result = py_unix_nanos_to_iso8601((i64::MAX as u64) + 1, Some(true));
170 assert!(result.is_err());
171 }
172
173 #[rstest]
174 fn test_py_unix_nanos_to_iso8601_formats_valid_timestamp() {
175 let output = py_unix_nanos_to_iso8601(0, Some(false)).unwrap();
176 assert_eq!(output, "1970-01-01T00:00:00.000Z");
177 }
178}