kot.pink
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 // TODO: make this https for production!
18 targetURL := fmt.Sprintf("http://%s/%s/%s/info/refs?%s", knot, user.DID, repo, r.URL.RawQuery)
19 resp, err := http.Get(targetURL)
20 if err != nil {
21 http.Error(w, err.Error(), http.StatusInternalServerError)
22 return
23 }
24 defer resp.Body.Close()
25
26 // Copy response headers
27 for k, v := range resp.Header {
28 w.Header()[k] = v
29 }
30
31 // Set response status code
32 w.WriteHeader(resp.StatusCode)
33
34 // Copy response body
35 if _, err := io.Copy(w, resp.Body); err != nil {
36 http.Error(w, err.Error(), http.StatusInternalServerError)
37 return
38 }
39
40}
41
42func (s *State) UploadPack(w http.ResponseWriter, r *http.Request) {
43 user, ok := r.Context().Value("resolvedId").(identity.Identity)
44 if !ok {
45 http.Error(w, "failed to resolve user", http.StatusInternalServerError)
46 return
47 }
48 knot := r.Context().Value("knot").(string)
49 repo := chi.URLParam(r, "repo")
50 // TODO: make this https for production!
51 targetURL := fmt.Sprintf("http://%s/%s/%s/git-upload-pack?%s", knot, user.DID, repo, r.URL.RawQuery)
52 client := &http.Client{}
53
54 // Create new request
55 proxyReq, err := http.NewRequest(r.Method, targetURL, r.Body)
56 if err != nil {
57 http.Error(w, err.Error(), http.StatusInternalServerError)
58 return
59 }
60
61 // Copy original headers
62 proxyReq.Header = r.Header
63
64 // Execute request
65 resp, err := client.Do(proxyReq)
66 if err != nil {
67 http.Error(w, err.Error(), http.StatusInternalServerError)
68 return
69 }
70 defer resp.Body.Close()
71
72 // Copy response headers
73 for k, v := range resp.Header {
74 w.Header()[k] = v
75 }
76
77 // Set response status code
78 w.WriteHeader(resp.StatusCode)
79
80 // Copy response body
81 if _, err := io.Copy(w, resp.Body); err != nil {
82 http.Error(w, err.Error(), http.StatusInternalServerError)
83 return
84 }
85}