WIP: Hyper 1.0 migration - fix net.rs and rpc body conversions

- Removed incorrect AsyncRead/AsyncWrite from HyperStream
- Added body error mapping for tonic::BoxBody
- Still working on TonicServiceWrapper trait bounds
- 43 errors remaining

Author: devonshigaki

libsql-server/src/net.rs

@@ -35,39 +35,8 @@ impl<S> HyperStream<S> {
     }
 }
 
-impl<S: AsyncRead + AsyncWrite + Unpin> AsyncRead for HyperStream<S> {
-    fn poll_read(
-        self: Pin<&mut Self>,
-        cx: &mut Context<'_>,
-        buf: &mut tokio::io::ReadBuf<'_>,
-    ) -> Poll<std::io::Result<()>> {
-        // SAFETY: HyperStream is Unpin if S is Unpin
-        let this = unsafe { self.get_unchecked_mut() };
-        Pin::new(&mut this.inner).poll_read(cx, buf)
-    }
-}
-
-impl<S: AsyncRead + AsyncWrite + Unpin> AsyncWrite for HyperStream<S> {
-    fn poll_write(
-        self: Pin<&mut Self>,
-        cx: &mut Context<'_>,
-        buf: &[u8],
-    ) -> Poll<std::io::Result<usize>> {
-        let this = unsafe { self.get_unchecked_mut() };
-        Pin::new(&mut this.inner).poll_write(cx, buf)
-    }
-
-    fn poll_flush(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<std::io::Result<()>> {
-        let this = unsafe { self.get_unchecked_mut() };
-        Pin::new(&mut this.inner).poll_flush(cx)
-    }
-
-    fn poll_shutdown(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<std::io::Result<()>> {
-        let this = unsafe { self.get_unchecked_mut() };
-        Pin::new(&mut this.inner).poll_shutdown(cx)
-    }
-}
-
+// Note: HyperStream only implements hyper's Read/Write traits, not tokio's AsyncRead/AsyncWrite
+// TokioIo already bridges between tokio and hyper traits internally
 impl<S: AsyncRead + AsyncWrite + Unpin> Read for HyperStream<S> {
     fn poll_read(
         self: Pin<&mut Self>,

libsql-server/src/rpc/mod.rs

@@ -84,7 +84,9 @@ where
 
     fn call(&mut self, req: hyper::Request<hyper::body::Incoming>) -> Self::Future {
         // Convert Incoming body to tonic's BoxBody
+        // Need to map the error type from io::Error to tonic::Status
         let (parts, body) = req.into_parts();
+        let body = body.map_err(|e| tonic::Status::internal(format!("body error: {}", e)));
         let body = tonic::body::BoxBody::new(body);
         let req = hyper::Request::from_parts(parts, body);
         self.inner.call(req)