fixed http clone

but do we really nedd to create a blank commit?
I dont think ngit-relay does that.
Do we need to se the default branch or is this automatic?

1 files changed, 40 insertions, 7 deletions

diff --git a/src/git/handlers.rs b/src/git/handlers.rs
index 0efc9d0..ac35d14 100644
--- a/src/git/handlers.rs
+++ b/src/git/handlers.rs
@@ -4,6 +4,7 @@
 
 use std::path::PathBuf;
 use hyper::{body::Bytes, Response, StatusCode};
+use http_body_util::Full;
 use tokio::io::{AsyncReadExt, AsyncWriteExt};
 use tracing::{debug, error, warn};
 
@@ -16,7 +17,7 @@ use super::subprocess::GitSubprocess;
 pub async fn handle_info_refs(
     repo_path: PathBuf,
     service: GitService,
-) -> Result<Response<String>, GitError> {
+) -> Result<Response<Full<Bytes>>, GitError> {
     debug!("Handling info/refs for {:?} with service {:?}", repo_path, service);
 
     // Check if repository exists
@@ -34,6 +35,8 @@ pub async fn handle_info_refs(
 
     // Read the output from git
     let mut output = Vec::new();
+    let mut stderr_output = Vec::new();
+    
     if let Some(stdout) = git.take_stdout() {
         let mut stdout = stdout;
         stdout.read_to_end(&mut output).await
@@ -42,6 +45,15 @@ pub async fn handle_info_refs(
                 GitError::IoError(e)
             })?;
     }
+    
+    if let Some(stderr) = git.take_stderr() {
+        let mut stderr = stderr;
+        stderr.read_to_end(&mut stderr_output).await
+            .map_err(|e| {
+                error!("Failed to read git stderr: {}", e);
+                GitError::IoError(e)
+            })?;
+    }
 
     // Wait for process to complete
     let status = git.wait().await
@@ -51,7 +63,8 @@ pub async fn handle_info_refs(
         })?;
 
     if !status.success() {
-        error!("Git process failed with status: {:?}", status);
+        let stderr_str = String::from_utf8_lossy(&stderr_output);
+        error!("Git process failed with status: {:?}, stderr: {}", status, stderr_str);
         return Err(GitError::GitFailed(status.code()));
     }
 
@@ -70,7 +83,7 @@ pub async fn handle_info_refs(
         .status(StatusCode::OK)
         .header("content-type", service.advertisement_content_type())
         .header("cache-control", "no-cache")
-        .body(String::from_utf8_lossy(&response_body).to_string())
+        .body(Full::new(Bytes::from(response_body)))
         .unwrap())
 }
 
@@ -78,7 +91,7 @@ pub async fn handle_info_refs(
 pub async fn handle_upload_pack(
     repo_path: PathBuf,
     request_body: Bytes,
-) -> Result<Response<String>, GitError> {
+) -> Result<Response<Full<Bytes>>, GitError> {
     debug!("Handling upload-pack for {:?}", repo_path);
 
     if !repo_path.exists() {
@@ -99,17 +112,27 @@ pub async fn handle_upload_pack(
 
     // Read response from git's stdout
     let mut output = Vec::new();
+    let mut stderr_output = Vec::new();
+    
     if let Some(stdout) = git.take_stdout() {
         let mut stdout = stdout;
         stdout.read_to_end(&mut output).await
             .map_err(GitError::IoError)?;
     }
+    
+    if let Some(stderr) = git.take_stderr() {
+        let mut stderr = stderr;
+        stderr.read_to_end(&mut stderr_output).await
+            .map_err(GitError::IoError)?;
+    }
 
     // Wait for process
     let status = git.wait().await
         .map_err(GitError::IoError)?;
 
     if !status.success() {
+        let stderr_str = String::from_utf8_lossy(&stderr_output);
+        error!("Git upload-pack failed: {}", stderr_str);
         return Err(GitError::GitFailed(status.code()));
     }
 
@@ -117,7 +140,7 @@ pub async fn handle_upload_pack(
         .status(StatusCode::OK)
         .header("content-type", GitService::UploadPack.result_content_type())
         .header("cache-control", "no-cache")
-        .body(String::from_utf8_lossy(&output).to_string())
+        .body(Full::new(Bytes::from(output)))
         .unwrap())
 }
 
@@ -127,7 +150,7 @@ pub async fn handle_upload_pack(
 pub async fn handle_receive_pack(
     repo_path: PathBuf,
     request_body: Bytes,
-) -> Result<Response<String>, GitError> {
+) -> Result<Response<Full<Bytes>>, GitError> {
     debug!("Handling receive-pack for {:?}", repo_path);
 
     if !repo_path.exists() {
@@ -151,17 +174,27 @@ pub async fn handle_receive_pack(
 
     // Read response from git's stdout
     let mut output = Vec::new();
+    let mut stderr_output = Vec::new();
+    
     if let Some(stdout) = git.take_stdout() {
         let mut stdout = stdout;
         stdout.read_to_end(&mut output).await
             .map_err(GitError::IoError)?;
     }
+    
+    if let Some(stderr) = git.take_stderr() {
+        let mut stderr = stderr;
+        stderr.read_to_end(&mut stderr_output).await
+            .map_err(GitError::IoError)?;
+    }
 
     // Wait for process
     let status = git.wait().await
         .map_err(GitError::IoError)?;
 
     if !status.success() {
+        let stderr_str = String::from_utf8_lossy(&stderr_output);
+        error!("Git receive-pack failed: {}", stderr_str);
         return Err(GitError::GitFailed(status.code()));
     }
 
@@ -169,7 +202,7 @@ pub async fn handle_receive_pack(
         .status(StatusCode::OK)
         .header("content-type", GitService::ReceivePack.result_content_type())
         .header("cache-control", "no-cache")
-        .body(String::from_utf8_lossy(&output).to_string())
+        .body(Full::new(Bytes::from(output)))
         .unwrap())
 }