Something went wrong. Try again.
Monorepo for Tangled
Something went wrong. Try again.
2.8 kB · 111 lines
Go
123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112package xrpc
import ( "fmt" "net/http" "net/url" "strings"
"github.com/go-git/go-git/v5/plumbing"
"tangled.org/core/api/tangled" "tangled.org/core/knotserver/git" xrpcerr "tangled.org/core/xrpc/errors")
func (x *Xrpc) RepoArchive(w http.ResponseWriter, r *http.Request) { repo := r.URL.Query().Get("repo") repoPath, err := x.parseRepoParam(repo) if err != nil { writeError(w, err.(xrpcerr.XrpcError), http.StatusBadRequest) return }
ref := r.URL.Query().Get("ref") // ref can be empty (git.Open handles this)
format := r.URL.Query().Get("format") if format == "" { format = "tar.gz" // default }
prefix := r.URL.Query().Get("prefix")
if format != "tar.gz" && format != "zip" { writeError(w, xrpcerr.NewXrpcError( xrpcerr.WithTag("InvalidRequest"), xrpcerr.WithMessage("only tar.gz and zip formats are supported"), ), http.StatusBadRequest) return }
gr, err := git.Open(repoPath, ref) if err != nil { writeError(w, xrpcerr.RefNotFoundError, http.StatusNotFound) return }
repoParts := strings.Split(repo, "/") repoName := repoParts[len(repoParts)-1]
immutableLink, err := x.buildImmutableLink(repo, format, gr.Hash().String(), prefix) if err != nil { x.Logger.Error( "failed to build immutable link", "err", err.Error(), "repo", repo, "format", format, "ref", gr.Hash().String(), "prefix", prefix, ) }
safeRefFilename := strings.ReplaceAll(plumbing.ReferenceName(ref).Short(), "/", "-")
var archivePrefix string if prefix != "" { archivePrefix = prefix } else { archivePrefix = fmt.Sprintf("%s-%s", repoName, safeRefFilename) }
filename := fmt.Sprintf("%s-%s.%s", repoName, safeRefFilename, format) w.Header().Set("Content-Disposition", fmt.Sprintf("attachment; filename=\"%s\"", filename)) w.Header().Set("Content-Type", archiveContentType(format)) w.Header().Set("Link", fmt.Sprintf("<%s>; rel=\"immutable\"", immutableLink))
err = gr.WriteArchive(w, format, archivePrefix) if err != nil { // once we start writing to the body we can't report error anymore // so we are only left with logging the error x.Logger.Error("writing archive", "error", err.Error(), "format", format) return }}
func archiveContentType(format string) string { if format == "zip" { return "application/zip" } return "application/gzip"}
func (x *Xrpc) buildImmutableLink(repo string, format string, ref string, prefix string) (string, error) { scheme := "https" if x.Config.Server.Dev { scheme = "http" }
u, err := url.Parse(scheme + "://" + x.Config.Server.Hostname + "/xrpc/" + tangled.RepoArchiveNSID) if err != nil { return "", err }
params := url.Values{} params.Set("repo", repo) params.Set("format", format) params.Set("ref", ref) params.Set("prefix", prefix)
return fmt.Sprintf("%s?%s", u.String(), params.Encode()), nil}