Compatible with protoc that not enable proto3

Author: Ma233

Cargo.lock

@@ -6,6 +6,7 @@ edition = "2021"
 [dependencies]
 clap = "4.5.4"
 futures = "0.3.30"
+httparse = "1.8.0"
 litep2p = "0.5.0"
 # Do not upgrade multiaddr, see: https://github.com/paritytech/litep2p/pull/91
 multiaddr = "0.17.1"

Cargo.toml

@@ -1,4 +1,6 @@
 fn main() -> Result<(), Box<dyn std::error::Error>> {
-    tonic_build::compile_protos("proto/command_v1.proto")?;
+    tonic_build::configure()
+        .protoc_arg("--experimental_allow_proto3_optional")
+        .compile(&["proto/command_v1.proto"], &["proto"])?;
     Ok(())
 }

build.rs

@@ -12,6 +12,10 @@ pub enum Error {
     Litep2p(#[from] litep2p::Error),
     #[error("Litep2p request response error: {0:?}")]
     Litep2pRequestResponseError(litep2p::protocol::request_response::RequestResponseError),
+    #[error("Httparse error: {0}")]
+    Httparse(#[from] httparse::Error),
+    #[error("Incomplete http request")]
+    IncompleteHttpRequest,
     #[error("Unexpected response type")]
     UnexpectedResponseType,
 }

src/error.rs

@@ -212,6 +212,12 @@ impl PProxyHandle {
         &self,
         request: RequestHttpServerRequest,
     ) -> Result<RequestHttpServerResponse> {
+        let mut headers = [httparse::EMPTY_HEADER; 64];
+        let mut req = httparse::Request::new(&mut headers);
+        if req.parse(&request.data)?.is_partial() {
+            return Err(Error::IncompleteHttpRequest);
+        }
+
         let (tx, rx) = oneshot::channel();
 
         self.command_tx