http_*: Add HTTP cloning

1 files changed, 30 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
 }