Merge pull request #6 from IteraLabs/feature/kraken-market-data-snapshot

v0.0.13

Author: convergentist

atelier-data/Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name = "atelier_data"
-version = "0.0.12"
+version = "0.0.13"
 edition = "2024"
 rust-version = "1.85.0"
 description = "Data connectors with lightweighted connectivity and integrations for the atelier-rs engine"
@@ -24,73 +24,71 @@ license = "Apache-2.0"
 name = "atelier_data"
 path = "src/lib.rs"
 
-[[example]]
-name = "market_streams"
-path = "examples/bybit/market_streams.rs"
+# ── market_sync ──
 
 [[example]]
-name = "ob_snapshot_fetch_sync_store"
-path = "examples/bybit/ob_snapshot_fetch_sync_store.rs"
+name = "market_load"
+path = "examples/market_sync/market_load.rs"
 
 [[example]]
-name = "ob_snapshot_load"
-path = "examples/bybit/ob_snapshot_load.rs"
+name = "multi_sync_workers"
+path = "examples/multi_sync/multi_sync_workers.rs"
 
-[[example]]
-name = "trade_fetch_store"
-path = "examples/bybit/trade_fetch_store.rs"
+# ── per market ──
 
 [[example]]
-name = "trade_load"
-path = "examples/bybit/trade_load.rs"
+name = "bybit_markets"
+path = "examples/market_sync/bybit/bybit_markets.rs"
 
 [[example]]
-name = "market_snapshot"
-path = "examples/bybit/market_snapshot.rs"
+name = "coinbase_markets"
+path = "examples/market_sync/coinbase/coinbase_markets.rs"
 
 [[example]]
-name = "market_snapshot_event"
-path = "examples/bybit/market_snapshot_event.rs"
+name = "kraken_markets"
+path = "examples/market_sync/kraken/kraken_markets.rs"
 
-# ── market_sync ──
+# ── bybit tests ──
 
-[[example]]
-name = "bybit_markets"
-path = "examples/market_sync/bybit/bybit_markets.rs"
+[[test]]
+name = "test_bybit_orderbook_responses"
+path = "tests/sources/bybit/order_books/test_orderbook_responses.rs"
 
-[[example]]
-name = "bybit_markets_load"
-path = "examples/market_sync/bybit/bybit_markets_load.rs"
+[[test]]
+name = "test_bybit_trade_responses"
+path = "tests/sources/bybit/public_trades/test_public_trades_responses.rs"
 
-[[example]]
-name = "bybit_workers"
-path = "examples/market_sync/bybit/bybit_workers.rs"
+[[test]]
+name = "test_bybit_funding_rates_responses"
+path = "tests/sources/bybit/funding_rates/test_funding_rates_responses.rs"
 
-[[example]]
-name = "base_markets"
-path = "examples/market_sync/base/base_markets.rs"
+[[test]]
+name = "test_bybit_open_interests_responses"
+path = "tests/sources/bybit/open_interests/test_open_interests_responses.rs"
+
+[[test]]
+name = "test_bybit_liquidations_responses"
+path = "tests/sources/bybit/liquidations/test_liquidations_responses.rs"
 
 # ── coinbase tests ──
 
 [[test]]
 name = "test_coinbase_orderbook_responses"
-path = "tests/coinbase/order_books/test_orderbook_responses.rs"
+path = "tests/sources/coinbase/order_books/test_orderbook_responses.rs"
 
 [[test]]
 name = "test_coinbase_trade_responses"
-path = "tests/coinbase/public_trades/test_trade_responses.rs"
+path = "tests/sources/coinbase/public_trades/test_trade_responses.rs"
 
-[[test]]
-name = "test_coinbase_liquidations"
-path = "tests/coinbase/liquidations/test_liquidations.rs"
+# ── kraken tests ──
 
 [[test]]
-name = "test_coinbase_funding_rates"
-path = "tests/coinbase/funding_rates/test_funding_rates.rs"
+name = "test_kraken_orderbook_responses"
+path = "tests/sources/kraken/order_books/test_orderbook_responses.rs"
 
 [[test]]
-name = "test_coinbase_open_interest"
-path = "tests/coinbase/open_interests/test_open_interest.rs"
+name = "test_kraken_trade_responses"
+path = "tests/sources/kraken/public_trades/test_trade_responses.rs"
 
 # ── type tests ──
 
@@ -114,6 +112,16 @@ path = "tests/types/synchronizers/test_market_sync.rs"
 name = "test_market_aggregate"
 path = "tests/types/snapshots/test_market_aggregate.rs"
 
+# ── parquet round-trip tests ──
+
+[[test]]
+name = "test_orderbook_parquet_roundtrip"
+path = "tests/types/order_books/test_orderbook_parquet_roundtrip.rs"
+
+[[test]]
+name = "test_trades_parquet_roundtrip"
+path = "tests/types/trades/test_trades_parquet_roundtrip.rs"
+
 [dependencies]
 anyhow = { version = "1.0" }
 arrow = { version = "57.2", optional = true }
@@ -142,6 +150,9 @@ tracing-subscriber = { version = "0.3" }
 url = { version = "2.0" }
 uuid = { version = "1.0", features = ["v4"] }
 
+[dev-dependencies]
+tempfile = "3"
+
 [features]
 default = []
 parquet = ["dep:arrow", "dep:parquet"]