feat: WASM compatibility and registry refactor

WASM refactor:
- Gate native-only code (spawn_blocking, filesystem, redb) behind
  #[cfg(not(target_arch = "wasm32"))]
- Add cross-platform spawn utilities (spawn_task, spawn_delayed) in s5_fs
- Split BlobStore imports into WASM-compatible (inline hash) and
  native-only (with outboard) variants
- Add `server` feature to s5_blobs to gate native-only components

Registry refactor:
- Extract RedbRegistry to registries/redb crate (native-only)
- Add registries/store for BlobStore-backed registry (WASM-compatible)
- Make RegistryServer generic over any RegistryApi implementation
- Add MemoryRegistry, TeeRegistry, MultiRegistry implementations
- Add Delete RPC to registry protocol
- All registry implementations now respect should_store semantics

New features:
- PinBlob RPC for pinning existing blobs without re-upload
- Blinded queries for zero-knowledge availability checks
- MultiFetcher for multi-source blob fetching with fallback
- Store testutil module for testing Store implementations

Bug fixes:
- GC now aborts on root.fs5.cbor decryption failure instead of treating
  root as empty (which could mark all blobs as GC candidates)

Author: redsolver

Cargo.lock

@@ -1,19 +1,25 @@
 [workspace]
 resolver = "3"
 members = [
-  "blob_stores/local",
-  "blob_stores/memory",
-  "blob_stores/s3",
-  "blob_stores/sia",
-  "importers/http",
-  "importers/local",
+  # Core crates
   "s5_blobs",
   "s5_cli",
   "s5_core",
   "s5_fs",
+  "s5_fuse",
   "s5_node",
   "s5_registry",
-  "s5_fuse",
+  # Blob stores
+  "blob_stores/local",
+  "blob_stores/memory",
+  "blob_stores/s3",
+  "blob_stores/sia",
+  # Registries
+  "registries/redb",
+  "registries/store",
+  # Importers
+  "importers/http",
+  "importers/local",
 ]
 
 [workspace.dependencies]
@@ -33,21 +39,25 @@ log = "0.4.28"
 minicbor = { version = "2.1.1", features = ["alloc", "derive", "half"] }
 postcard = "1.1.3"
 redb = "3.1.0"
-s5_blobs = { path = "s5_blobs", version = "1.0.0-beta.1" }
+s5_blobs = { path = "s5_blobs", version = "1.0.0-beta.1", default-features = false }
 s5_core = { path = "s5_core", version = "1.0.0-beta.1" }
 s5_fs = { path = "s5_fs", version = "1.0.0-beta.1" }
 s5_fuse = { path = "s5_fuse", version = "1.0.0-beta.1" }
 s5_importer_http = { path = "importers/http", version = "1.0.0-beta.1" }
 s5_importer_local = { path = "importers/local", version = "1.0.0-beta.1" }
 s5_node = { path = "s5_node", version = "1.0.0-beta.1" }
 s5_registry = { path = "s5_registry", version = "1.0.0-beta.1" }
+s5_registry_redb = { path = "registries/redb", version = "1.0.0-beta.1" }
+s5_registry_store = { path = "registries/store", version = "1.0.0-beta.1" }
 s5_store_local = { path = "blob_stores/local", version = "1.0.0-beta.1" }
 s5_store_memory = { path = "blob_stores/memory", version = "1.0.0-beta.1" }
 s5_store_s3 = { path = "blob_stores/s3", version = "1.0.0-beta.1" }
 s5_store_sia = { path = "blob_stores/sia", version = "1.0.0-beta.1" }
 serde = { version = "1.0.228", features = ["derive"] }
 thiserror = "2.0.17"
-tokio = { version = "1.48.0", features = ["full"] }
+# WASM-compatible tokio features: sync, macros, io-util, rt, time
+# Native crates that need more features should add them explicitly
+tokio = { version = "1.48.0", features = ["sync", "macros", "io-util", "rt", "time"] }
 tokio-util = { version = "0.7.16", features = ["io"] }
 tracing = "0.1.41"
 criterion = { version = "0.5.1", features = ["async_tokio"], default-features = false }

Cargo.toml

@@ -13,6 +13,11 @@ bytes.workspace = true
 futures.workspace = true
 s5_core.workspace = true
 serde.workspace = true
-tokio.workspace = true
+# Local store needs tokio fs (native-only crate)
+tokio = { version = "1.48.0", features = ["sync", "macros", "io-util", "rt", "fs"] }
 tokio-util.workspace = true
 walkdir = "2.5.0"
+
+[dev-dependencies]
+s5_core = { workspace = true, features = ["testutil"] }
+tempfile = "3"

blob_stores/local/Cargo.toml

@@ -204,3 +204,16 @@ impl s5_core::store::Store for LocalStore {
         Ok(Box::new(stream))
     }
 }
+
+#[cfg(test)]
+mod tests {
+    use super::*;
+    use s5_core::testutil::StoreTests;
+
+    #[tokio::test]
+    async fn test_local_store() {
+        let temp_dir = tempfile::tempdir().unwrap();
+        let store = LocalStore::new(temp_dir.path());
+        StoreTests::new(&store).run_all().await.unwrap();
+    }
+}

blob_stores/local/src/lib.rs

@@ -12,3 +12,7 @@ bytes.workspace = true
 dashmap = "6.1.0"
 futures.workspace = true
 s5_core.workspace = true
+
+[dev-dependencies]
+s5_core = { workspace = true, features = ["testutil"] }
+tokio = { workspace = true, features = ["rt-multi-thread", "macros"] }

blob_stores/memory/Cargo.toml

@@ -151,3 +151,15 @@ impl s5_core::store::Store for MemoryStore {
         Ok(vec![])
     }
 }
+
+#[cfg(test)]
+mod tests {
+    use super::*;
+    use s5_core::testutil::StoreTests;
+
+    #[tokio::test]
+    async fn test_memory_store() {
+        let store = MemoryStore::new();
+        StoreTests::new(&store).run_all().await.unwrap();
+    }
+}

blob_stores/memory/src/lib.rs

@@ -14,5 +14,9 @@ futures.workspace = true
 rust-s3 = { version = "0.37.0" }
 s5_core.workspace = true
 serde.workspace = true
-tokio.workspace = true
+# S3 store uses async io
+tokio = { version = "1.48.0", features = ["sync", "macros", "io-util", "rt"] }
 tokio-util = { workspace = true, features = ["io"] }
+
+[dev-dependencies]
+s5_core = { workspace = true, features = ["testutil"] }

blob_stores/s3/Cargo.toml

@@ -154,3 +154,27 @@ impl s5_core::store::Store for S3Store {
         Ok(Box::new(stream))
     }
 }
+
+#[cfg(test)]
+mod tests {
+    // S3 tests require a running S3-compatible server (e.g., MinIO)
+    // They are ignored by default
+    #[allow(unused_imports)]
+    use super::*;
+    #[allow(unused_imports)]
+    use s5_core::testutil::StoreTests;
+
+    #[tokio::test]
+    #[ignore = "requires S3-compatible server"]
+    async fn test_s3_store() {
+        let config = S3StoreConfig {
+            endpoint: "http://localhost:9000".to_string(),
+            region: "us-east-1".to_string(),
+            bucket_name: "test-bucket".to_string(),
+            access_key: "minioadmin".to_string(),
+            secret_key: "minioadmin".to_string(),
+        };
+        let store = S3Store::create(config);
+        StoreTests::new(&store).run_all().await.unwrap();
+    }
+}

blob_stores/s3/src/lib.rs

@@ -23,7 +23,8 @@ s5_core.workspace = true
 serde.workspace = true
 serde_json = "1.0.142"
 thiserror = "2.0.12"
-tokio.workspace = true
+# Sia store uses async io
+tokio = { version = "1.48.0", features = ["sync", "macros", "io-util", "rt"] }
 tokio-util.workspace = true
 anyhow.workspace = true
 

blob_stores/sia/Cargo.toml

@@ -15,7 +15,8 @@ reqwest = { version = "0.12.23", features = ["stream"] }
 s5_core.workspace = true
 s5_fs.workspace = true
 scraper = "0.23.1"
-tokio.workspace = true
+# HTTP importer uses tokio sync primitives
+tokio = { version = "1.48.0", features = ["sync", "macros", "rt"] }
 tracing = "0.1.41"
 tracing-subscriber = "0.3.19"
 url = "2.5.4"