Data tracks core

Cargo.toml

@@ -6,6 +6,7 @@ members = [
     "livekit-protocol",
     "livekit-ffi",
     "livekit-uniffi",
+    "livekit-datatrack",
     "livekit-ffi-node-bindings",
     "livekit-runtime",
     "libwebrtc",
@@ -43,6 +44,7 @@ libwebrtc = { version = "0.3.24", path = "libwebrtc" }
 livekit = { version = "0.7.29", path = "livekit" }
 livekit-api = { version = "0.4.12", path = "livekit-api" }
 livekit-ffi = { version = "0.12.44", path = "livekit-ffi" }
+livekit-datatrack = { version = "0.1.0", path = "livekit-datatrack" }
 livekit-protocol = { version = "0.6.0", path = "livekit-protocol" }
 livekit-runtime = { version = "0.4.0", path = "livekit-runtime" }
 soxr-sys = { version = "0.1.1", path = "soxr-sys" }
@@ -55,7 +57,9 @@ bytes = "1.10"
 clap = "4.5"
 console-subscriber = "0.1"
 env_logger = "0.11"
+from_variants = "1.0.2"
 futures = "0.3"
+futures-core = "0.3"
 futures-util = "0.3"
 lazy_static = "1.4"
 log = "0.4"
@@ -68,6 +72,7 @@ serde = "1"
 serde_json = "1.0"
 thiserror = "1"
 tokio = "1"
+tokio-stream = "0.1"
 
 [profile.release]
 opt-level = "z"

livekit-datatrack/Cargo.toml

@@ -0,0 +1,25 @@
+[package]
+name = "livekit-datatrack"
+version = "0.1.0"
+edition = "2021"
+license = "Apache-2.0"
+repository = "https://github.com/livekit/rust-sdks"
+readme = "README.md"
+
+[dependencies]
+livekit-protocol = { workspace = true }
+livekit-runtime = { workspace = true }
+log = { workspace = true }
+thiserror = "2.0.17"  # TODO: upgrade workspace version to 2.x.x
+tokio = { workspace = true, default-features = false, features = ["sync"] }
+futures-util = { workspace = true, default-features = false, features = ["sink"] }
+futures-core = { workspace = true }
+bytes = { workspace = true }
+from_variants = { workspace = true }
+tokio-stream = { workspace = true, features = ["sync"] }
+anyhow = { workspace = true } # For internal error handling only
+rand = { workspace = true }
+
+[dev-dependencies]
+test-case = "3.3"
+fake = { version = "4.4", features = ["derive"] }

livekit-datatrack/README.md

@@ -0,0 +1,6 @@
+# LiveKit Data Track
+
+**Important**:
+This is an internal crate that powers the data tracks feature in LiveKit client SDKs (including [Rust](https://crates.io/crates/livekit) and others) and is not usable directly.
+
+To use data tracks in your application, please use the public APIs provided by the client SDKs.