Add tardis_normalize_symbol_str function for Python

Author: cjdsellers

crates/adapters/tardis/src/enums.rs

@@ -19,6 +19,8 @@ use strum::{AsRefStr, Display, EnumIter, EnumString, FromRepr};
 use ustr::Ustr;
 
 #[derive(Debug, Clone, PartialEq, Eq, Serialize, Deserialize, Display, FromRepr, EnumString)]
+#[strum(ascii_case_insensitive)]
+#[strum(serialize_all = "lowercase")]
 #[serde(rename_all = "lowercase")]
 /// The instrument type for the symbol.
 pub enum InstrumentType {

crates/adapters/tardis/src/python/mod.rs

@@ -21,7 +21,29 @@ pub mod enums;
 pub mod http;
 pub mod machine;
 
+use nautilus_core::python::to_pyvalue_err;
+use std::str::FromStr;
+
 use pyo3::prelude::*;
+use ustr::Ustr;
+
+use super::enums::{Exchange, InstrumentType};
+use crate::parse::normalize_symbol_str;
+
+#[pyfunction(name = "tardis_normalize_symbol_str")]
+#[pyo3(signature = (symbol, exchange, instrument_type, is_inverse=None))]
+pub fn py_tardis_normalize_symbol_str(
+    symbol: String,
+    exchange: String,
+    instrument_type: String,
+    is_inverse: Option<bool>,
+) -> PyResult<String> {
+    let symbol = Ustr::from(&symbol);
+    let exchange = Exchange::from_str(&exchange).map_err(to_pyvalue_err)?;
+    let instrument_type = InstrumentType::from_str(&instrument_type).map_err(to_pyvalue_err)?;
+
+    Ok(normalize_symbol_str(symbol, &exchange, &instrument_type, is_inverse).to_string())
+}
 
 /// Loaded as nautilus_pyo3.tardis
 ///
@@ -55,6 +77,7 @@ pub fn tardis(_: Python<'_>, m: &Bound<'_, PyModule>) -> PyResult<()> {
     )?)?;
     m.add_function(wrap_pyfunction!(csv::py_load_tardis_quotes, m)?)?;
     m.add_function(wrap_pyfunction!(csv::py_load_tardis_trades, m)?)?;
+    m.add_function(wrap_pyfunction!(py_tardis_normalize_symbol_str, m)?)?;
 
     Ok(())
 }

nautilus_trader/core/nautilus_pyo3.pyi

@@ -5008,7 +5008,8 @@ class DatabentoLiveClient:
 
 # Tardis
 
-def tardis_exchange_from_venue_str(venue_str: str) -> list[str]: ...
+def tardis_normalize_symbol_str(symbol: str, exchange: str, instrument_type: str, is_inverse: bool | None = None) -> str: ...
+def tardis_exchange_from_venue_str(value: str) -> list[str]: ...
 def bar_spec_to_tardis_trade_bar_string(bar_spec: BarSpecification) -> str: ...
 
 def load_tardis_deltas(filepath: str, price_precision: int | None = None, size_precision: int | None = None, instrument_id: InstrumentId | None = None, limit: int | None = None) -> list[OrderBookDelta]: ...  # noqa

tests/integration_tests/adapters/tardis/test_common.py

@@ -0,0 +1,29 @@
+# -------------------------------------------------------------------------------------------------
+#  Copyright (C) 2015-2025 Nautech Systems Pty Ltd. All rights reserved.
+#  https://nautechsystems.io
+#
+#  Licensed under the GNU Lesser General Public License Version 3.0 (the "License");
+#  You may not use this file except in compliance with the License.
+#  You may obtain a copy of the License at https://www.gnu.org/licenses/lgpl-3.0.en.html
+#
+#  Unless required by applicable law or agreed to in writing, software
+#  distributed under the License is distributed on an "AS IS" BASIS,
+#  WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+#  See the License for the specific language governing permissions and
+#  limitations under the License.
+# -------------------------------------------------------------------------------------------------
+
+from nautilus_trader.core import nautilus_pyo3
+
+
+def test_normalize_symbol_str() -> None:
+    # Arrange, Act
+    result = nautilus_pyo3.tardis_normalize_symbol_str(
+        symbol="BTCUSDT",
+        exchange="binance-futures",
+        instrument_type="perpetual",
+        is_inverse=False,
+    )
+
+    # Assert
+    assert result == "BTCUSDT-PERP"