Something went wrong. Try again.
Monorepo for Tangled
Something went wrong. Try again.
3.0 kB · 114 lines
Go
at ci
123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115package state
import ( "fmt" "io" "maps" "net/http"
"github.com/bluesky-social/indigo/atproto/identity" "github.com/go-chi/chi/v5" "tangled.org/core/appview/models")
func (s *State) InfoRefs(w http.ResponseWriter, r *http.Request) { user := r.Context().Value("resolvedId").(identity.Identity) repo := r.Context().Value("repo").(*models.Repo)
scheme := "https" if s.config.Core.Dev { scheme = "http" }
targetURL := fmt.Sprintf("%s://%s/%s/%s/info/refs?%s", scheme, repo.Knot, user.DID, repo.Name, r.URL.RawQuery) s.proxyRequest(w, r, targetURL)
}
func (s *State) UploadArchive(w http.ResponseWriter, r *http.Request) { user, ok := r.Context().Value("resolvedId").(identity.Identity) if !ok { http.Error(w, "failed to resolve user", http.StatusInternalServerError) return } repo := r.Context().Value("repo").(*models.Repo)
scheme := "https" if s.config.Core.Dev { scheme = "http" }
targetURL := fmt.Sprintf("%s://%s/%s/%s/git-upload-archive?%s", scheme, repo.Knot, user.DID, repo.Name, r.URL.RawQuery) s.proxyRequest(w, r, targetURL)}
func (s *State) UploadPack(w http.ResponseWriter, r *http.Request) { user, ok := r.Context().Value("resolvedId").(identity.Identity) if !ok { http.Error(w, "failed to resolve user", http.StatusInternalServerError) return } repo := r.Context().Value("repo").(*models.Repo)
scheme := "https" if s.config.Core.Dev { scheme = "http" }
targetURL := fmt.Sprintf("%s://%s/%s/%s/git-upload-pack?%s", scheme, repo.Knot, user.DID, repo.Name, r.URL.RawQuery) s.proxyRequest(w, r, targetURL)}
func (s *State) ReceivePack(w http.ResponseWriter, r *http.Request) { user, ok := r.Context().Value("resolvedId").(identity.Identity) if !ok { http.Error(w, "failed to resolve user", http.StatusInternalServerError) return } repo := r.Context().Value("repo").(*models.Repo)
scheme := "https" if s.config.Core.Dev { scheme = "http" }
targetURL := fmt.Sprintf("%s://%s/%s/%s/git-receive-pack?%s", scheme, repo.Knot, user.DID, repo.Name, r.URL.RawQuery) s.proxyRequest(w, r, targetURL)}
func (s *State) proxyRequest(w http.ResponseWriter, r *http.Request, targetURL string) { client := &http.Client{}
// Create new request proxyReq, err := http.NewRequest(r.Method, targetURL, r.Body) if err != nil { http.Error(w, err.Error(), http.StatusInternalServerError) return }
// Copy original headers proxyReq.Header = r.Header
repoOwnerHandle := chi.URLParam(r, "user") proxyReq.Header.Add("x-tangled-repo-owner-handle", repoOwnerHandle)
// Execute request resp, err := client.Do(proxyReq) if err != nil { http.Error(w, err.Error(), http.StatusInternalServerError) return } defer resp.Body.Close()
// Copy response headers maps.Copy(w.Header(), resp.Header)
// Set response status code w.WriteHeader(resp.StatusCode)
// Copy response body if _, err := io.Copy(w, resp.Body); err != nil { http.Error(w, err.Error(), http.StatusInternalServerError) return }}