Merge pull request #19 from IteraLabs/fix/complementary-fixes-for-beta-release

complementary fixes for beta release

Author: convergentist

Cargo.toml

@@ -28,11 +28,11 @@ exclude = ["*.log", ".github", "Makefile.toml", "assets/*", "tags"]
 include = ["katex-header.html"]
 
 [workspace.dependencies]
-atelier_data = { path = "./atelier-data", version = "0.0.12" }
-atelier_engine = { path = "./atelier-data", version = "0.0.10" }
-atelier_quant = { path = "./atelier-quant", version = "0.0.10" }
-atelier_retro = { path = "./atelier-retro", version = "0.0.10" }
-atelier_rs = { path = "./atelier-rs", version = "0.0.10" }
+atelier_data = { version = "0.0.14" }
+atelier_engine = { version = "0.0.10" }
+atelier_quant = { version = "0.0.11" }
+atelier_retro = { version = "0.0.10" }
+atelier_rs = { version = "0.0.10" }
 clap = { version = "4.5", features = ["derive"] }
 criterion = { version = "0.5", features = ["html_reports"] }
 csv = { version = "1.3" }
@@ -53,7 +53,7 @@ tokio = { version = "1", features = ["full"] }
 toml = { version = "0.8" }
 
 [workspace.lints.rust]
-dead_code = "allow"
+dead_code = "forbid"
 large_enum_variant = "allow"
 too_many_arguments = "allow"
 trivial_casts = "warn"

atelier-data/Cargo.toml

@@ -1,25 +1,29 @@
 [package]
 name = "atelier_data"
-version = "0.0.13"
+version = "0.0.15"
 edition = "2024"
 rust-version = "1.85.0"
-description = "Data connectors with lightweighted connectivity and integrations for the atelier-rs engine"
-documentation = "https://docs.rs/atelier-data/"
+description = "Data Artifacts and I/O for the atelier-rs engine"
+documentation = "https://docs.rs/atelier_data/"
 readme = "README.md"
 homepage = "https://iteralabs.xyz/atelier-rs"
 repository = "https://github.com/iteralabs/atelier-rs"
 license = "Apache-2.0"
 keywords = ["crypto", "framework", "machine-learning", "math", "trading"]
 categories = ["data-structures", "development-tools", "finance", "simulation"]
-exclude = ["*.log", ".github", "Makefile.toml", "assets/*", "tags"]
-include = ["../katex-header.html", "Cargo.toml", "README.md", "src/**/*"]
+include = [
+  "Cargo.toml",
+  "README.md",
+  "examples/**/*",
+  "katex-header.html",
+  "src/**/*",
+  "tests/**/*",
+]
 publish = true
 
 [package.metadata.docs.rs]
 rustdoc-args = ["--html-in-header", "katex-header.html", "--cfg", "docsrs"]
-private-doc = true
-alll-features = true
-license = "Apache-2.0"
+features = ["parquet"]
 
 [lib]
 name = "atelier_data"
@@ -28,10 +32,12 @@ path = "src/lib.rs"
 # ── binaries ──
 
 [[bin]]
+doc = false
 name = "market_worker"
 path = "src/bin/market_worker.rs"
 
 [[bin]]
+doc = false
 name = "data_worker"
 path = "src/bin/data_worker.rs"
 
@@ -73,7 +79,7 @@ path = "examples/market_worker/run_market_worker.rs"
 name = "read_market_worker"
 path = "examples/market_worker/read_market_worker.rs"
 
-# ── market_strems ──
+# ── market_streams ──
 
 [[example]]
 name = "market_fetch"
@@ -121,6 +127,16 @@ path = "tests/sources/kraken/order_books/test_orderbook_responses.rs"
 name = "test_kraken_trade_responses"
 path = "tests/sources/kraken/public_trades/test_trade_responses.rs"
 
+# ── binance tests ──
+
+[[test]]
+name = "test_binance_orderbook_responses"
+path = "tests/sources/binance/order_books/test_orderbook_responses.rs"
+
+[[test]]
+name = "test_binance_trade_responses"
+path = "tests/sources/binance/public_trades/test_trade_responses.rs"
+
 # ── type tests ──
 
 [[test]]
@@ -165,6 +181,10 @@ path = "tests/workers/test_data_worker_markets.rs"
 name = "test_worker_gap_detector"
 path = "tests/workers/test_worker_gap_detector.rs"
 
+[[test]]
+name = "test_pipeline"
+path = "tests/workers/test_pipeline.rs"
+
 # ── parquet round-trip tests ──
 
 [[test]]
@@ -175,6 +195,8 @@ path = "tests/types/order_books/test_orderbook_parquet_roundtrip.rs"
 name = "test_trades_parquet_roundtrip"
 path = "tests/types/trades/test_trades_parquet_roundtrip.rs"
 
+# ── clients tests ──
+
 [[test]]
 name = "test_http_builder"
 path = "tests/clients/http/test_builder.rs"
@@ -191,6 +213,10 @@ path = "tests/clients/wss/test_connectivity.rs"
 name = "test_wss_decoder"
 path = "tests/clients/wss/test_decoder.rs"
 
+[[test]]
+name = "test_connection_manager"
+path = "tests/clients/connections/test_connection_manager.rs"
+
 [dependencies]
 anyhow = { version = "1.0" }
 arrow = { version = "57.2", optional = true }