libsql-server: WAL sync protocol support

Author: penberg

Cargo.lock

@@ -37,6 +37,7 @@ itertools = "0.10.5"
 jsonwebtoken = "9"
 libsql = { path = "../libsql/", optional = true }
 libsql_replication = { path = "../libsql-replication" }
+libsql_sync = { path = "../libsql-sync" }
 libsql-wal = { path = "../libsql-wal/" }
 libsql-storage = { path = "../libsql-storage", optional = true }
 metrics = "0.21.1"

libsql-server/Cargo.toml

@@ -24,6 +24,7 @@ pub mod replica_proxy;
 pub mod replication_log;
 pub mod replication_log_proxy;
 pub mod streaming_exec;
+pub mod sync;
 
 pub async fn run_rpc_server<A: crate::net::Accept>(
     proxy_service: ProxyService,

libsql-server/src/rpc/mod.rs

@@ -0,0 +1,31 @@
+use futures::stream::BoxStream;
+use libsql_sync::sync::rpc::wal_sync_server::WalSync;
+
+pub struct SyncService {}
+
+#[tonic::async_trait]
+impl WalSync for SyncService {
+    type FetchDatabaseStream =
+        BoxStream<'static, Result<libsql_sync::sync::rpc::DatabaseChunk, tonic::Status>>;
+
+    async fn fetch_database(
+        &self,
+        _request: tonic::Request<libsql_sync::sync::rpc::FetchDatabaseRequest>,
+    ) -> Result<tonic::Response<Self::FetchDatabaseStream>, tonic::Status> {
+        unimplemented!()
+    }
+
+    async fn pull_wal(
+        &self,
+        _request: tonic::Request<libsql_sync::sync::rpc::PullWalRequest>,
+    ) -> Result<tonic::Response<libsql_sync::sync::rpc::PullWalResponse>, tonic::Status> {
+        unimplemented!()
+    }
+
+    async fn push_wal(
+        &self,
+        _request: tonic::Request<libsql_sync::sync::rpc::PushWalRequest>,
+    ) -> Result<tonic::Response<libsql_sync::sync::rpc::PushWalResponse>, tonic::Status> {
+        unimplemented!()
+    }
+}