From edc3552e83c5106a0e36147c333cc23f7196ec09 Mon Sep 17 00:00:00 2001 From: Runxi Yu Date: Sun, 16 Feb 2025 02:26:22 +0800 Subject: http_*: Add HTTP cloning --- http_handle_repo_info.go | 32 ++++++++++++++++++++++++++++++-- 1 file changed, 30 insertions(+), 2 deletions(-) (limited to 'http_handle_repo_info.go') 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 } -- cgit v1.2.3