http_*: Add HTTP cloning

3 files changed, 76 insertions, 2 deletions

diff --git a/http_handle_repo_info.go b/http_handle_repo_info.go
index 3935f4b..5bc0b76 100644
--- a/http_handle_repo_info.go
+++ b/http_handle_repo_info.go
@@ -2,8 +2,36 @@ package main
 
 import (
 	"net/http"
+	"github.com/go-git/go-billy/v5/osfs"
+	"github.com/go-git/go-git/v5/plumbing/format/pktline"
+	"github.com/go-git/go-git/v5/plumbing/transport"
+	"github.com/go-git/go-git/v5/plumbing/transport/server"
 )
 
-func handle_repo_info(w http.ResponseWriter, r *http.Request, params map[string]any) {
-	http.Error(w, "\x1b[1;93mHi! We do not support Git operations over HTTP yet.\x1b[0m\n\x1b[1;93mMeanwhile, please use SSH (setupless anonymous access enabled):\x1b[0m\n\x1b[1;93m"+generate_ssh_remote_url(params["group_name"].(string), params["repo_name"].(string))+"\x1b[0m", http.StatusNotImplemented)
+func handle_repo_info(w http.ResponseWriter, r *http.Request, params map[string]any) (err error) {
+	group_name, repo_name := params["group_name"].(string), params["repo_name"].(string)
+	var repo_path string
+	err = database.QueryRow(r.Context(), "SELECT r.filesystem_path FROM repos r JOIN groups g ON r.group_id = g.id WHERE g.name = $1 AND r.name = $2;", group_name, repo_name).Scan(&repo_path)
+	if err != nil {
+		return err
+	}
+	endpoint, err := transport.NewEndpoint("/")
+	if err != nil {
+		return err
+	}
+	billy_fs := osfs.New(repo_path)
+	fs_loader := server.NewFilesystemLoader(billy_fs)
+	transport := server.NewServer(fs_loader)
+	upload_pack_session, err := transport.NewUploadPackSession(endpoint, nil)
+	advertised_references, err := upload_pack_session.AdvertisedReferencesContext(r.Context())
+	if err != nil {
+		return err
+	}
+	advertised_references.Prefix = [][]byte{[]byte("# service=git-upload-pack"), pktline.Flush}
+	w.Header().Set("content-type", "application/x-git-upload-pack-advertisement")
+	err = advertised_references.Encode(w)
+	if err != nil {
+		return err
+	}
+	return nil
 }
diff --git a/http_handle_repo_upload_pack.go b/http_handle_repo_upload_pack.go
new file mode 100644
index 0000000..9b31c25
--- /dev/null
+++ b/http_handle_repo_upload_pack.go
@@ -0,0 +1,44 @@
+package main
+
+import (
+	"net/http"
+	"github.com/go-git/go-billy/v5/osfs"
+	"github.com/go-git/go-git/v5/plumbing/protocol/packp"
+	"github.com/go-git/go-git/v5/plumbing/transport"
+	"github.com/go-git/go-git/v5/plumbing/transport/server"
+)
+
+func handle_upload_pack(w http.ResponseWriter, r *http.Request, params map[string]any) (err error) {
+	group_name, repo_name := params["group_name"].(string), params["repo_name"].(string)
+	var repo_path string
+	err = database.QueryRow(r.Context(), "SELECT r.filesystem_path FROM repos r JOIN groups g ON r.group_id = g.id WHERE g.name = $1 AND r.name = $2;", group_name, repo_name).Scan(&repo_path)
+	if err != nil {
+		return err
+	}
+	endpoint, err := transport.NewEndpoint("/")
+	if err != nil {
+		return err
+	}
+	billy_fs := osfs.New(repo_path)
+	fs_loader := server.NewFilesystemLoader(billy_fs)
+	transport := server.NewServer(fs_loader)
+	upload_pack_session, err := transport.NewUploadPackSession(endpoint, nil)
+	if err != nil {
+		return err
+	}
+	w.Header().Set("Content-Type", "application/x-git-upload-pack-result")
+	reference_update_request := packp.NewUploadPackRequest()
+	err = reference_update_request.Decode(r.Body)
+	if err != nil {
+		return err
+	}
+	report_status, err := upload_pack_session.UploadPack(r.Context(), reference_update_request)
+	if err != nil {
+		return err
+	}
+	err = report_status.Encode(w)
+	if err != nil {
+		return err
+	}
+	return nil
+}
diff --git a/http_server.go b/http_server.go
index ffbb711..1a4d0a3 100644
--- a/http_server.go
+++ b/http_server.go
@@ -132,6 +132,8 @@ func (router *http_router_t) ServeHTTP(w http.ResponseWriter, r *http.Request) {
 			switch repo_feature {
 			case "info":
 				handle_repo_info(w, r, params)
+			case "git-upload-pack":
+				handle_upload_pack(w, r, params)
 			case "tree":
 				params["rest"] = strings.Join(segments[separator_index+4:], "/")
 				if len(segments) < separator_index+5 && redirect_with_slash(w, r) {