notnite.com
1package state
2
3import (
4 "fmt"
5 "io"
6 "net/http"
7
8 "github.com/bluesky-social/indigo/atproto/identity"
9 "github.com/go-chi/chi/v5"
10)
11
12func (s *State) InfoRefs(w http.ResponseWriter, r *http.Request) {
13 user := r.Context().Value("resolvedId").(identity.Identity)
14 knot := r.Context().Value("knot").(string)
15 repo := chi.URLParam(r, "repo")
16
17 scheme := "https"
18 if s.config.Dev {
19 scheme = "http"
20 }
21 targetURL := fmt.Sprintf("%s://%s/%s/%s/info/refs?%s", scheme, knot, user.DID, repo, r.URL.RawQuery)
22 resp, err := http.Get(targetURL)
23 if err != nil {
24 http.Error(w, err.Error(), http.StatusInternalServerError)
25 return
26 }
27 defer resp.Body.Close()
28
29 // Copy response headers
30 for k, v := range resp.Header {
31 w.Header()[k] = v
32 }
33
34 // Set response status code
35 w.WriteHeader(resp.StatusCode)
36
37 // Copy response body
38 if _, err := io.Copy(w, resp.Body); err != nil {
39 http.Error(w, err.Error(), http.StatusInternalServerError)
40 return
41 }
42
43}
44
45func (s *State) UploadPack(w http.ResponseWriter, r *http.Request) {
46 user, ok := r.Context().Value("resolvedId").(identity.Identity)
47 if !ok {
48 http.Error(w, "failed to resolve user", http.StatusInternalServerError)
49 return
50 }
51 knot := r.Context().Value("knot").(string)
52 repo := chi.URLParam(r, "repo")
53
54 scheme := "https"
55 if s.config.Dev {
56 scheme = "http"
57 }
58 targetURL := fmt.Sprintf("%s://%s/%s/%s/git-upload-pack?%s", scheme, knot, user.DID, repo, r.URL.RawQuery)
59 client := &http.Client{}
60
61 // Create new request
62 proxyReq, err := http.NewRequest(r.Method, targetURL, r.Body)
63 if err != nil {
64 http.Error(w, err.Error(), http.StatusInternalServerError)
65 return
66 }
67
68 // Copy original headers
69 proxyReq.Header = r.Header
70
71 // Execute request
72 resp, err := client.Do(proxyReq)
73 if err != nil {
74 http.Error(w, err.Error(), http.StatusInternalServerError)
75 return
76 }
77 defer resp.Body.Close()
78
79 // Copy response headers
80 for k, v := range resp.Header {
81 w.Header()[k] = v
82 }
83
84 // Set response status code
85 w.WriteHeader(resp.StatusCode)
86
87 // Copy response body
88 if _, err := io.Copy(w, resp.Body); err != nil {
89 http.Error(w, err.Error(), http.StatusInternalServerError)
90 return
91 }
92}