kot.pink
1package state
2
3import (
4 "fmt"
5 "io"
6 "maps"
7 "net/http"
8
9 "github.com/bluesky-social/indigo/atproto/identity"
10 "github.com/go-chi/chi/v5"
11 "tangled.org/core/appview/models"
12)
13
14func (s *State) InfoRefs(w http.ResponseWriter, r *http.Request) {
15 user := r.Context().Value("resolvedId").(identity.Identity)
16 repo := r.Context().Value("repo").(*models.Repo)
17
18 scheme := "https"
19 if s.config.Core.Dev {
20 scheme = "http"
21 }
22
23 targetURL := fmt.Sprintf("%s://%s/%s/%s/info/refs?%s", scheme, repo.Knot, user.DID, repo.Name, r.URL.RawQuery)
24 s.proxyRequest(w, r, targetURL)
25
26}
27
28func (s *State) UploadPack(w http.ResponseWriter, r *http.Request) {
29 user, ok := r.Context().Value("resolvedId").(identity.Identity)
30 if !ok {
31 http.Error(w, "failed to resolve user", http.StatusInternalServerError)
32 return
33 }
34 repo := r.Context().Value("repo").(*models.Repo)
35
36 scheme := "https"
37 if s.config.Core.Dev {
38 scheme = "http"
39 }
40
41 targetURL := fmt.Sprintf("%s://%s/%s/%s/git-upload-pack?%s", scheme, repo.Knot, user.DID, repo.Name, r.URL.RawQuery)
42 s.proxyRequest(w, r, targetURL)
43}
44
45func (s *State) ReceivePack(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 repo := r.Context().Value("repo").(*models.Repo)
52
53 scheme := "https"
54 if s.config.Core.Dev {
55 scheme = "http"
56 }
57
58 targetURL := fmt.Sprintf("%s://%s/%s/%s/git-receive-pack?%s", scheme, repo.Knot, user.DID, repo.Name, r.URL.RawQuery)
59 s.proxyRequest(w, r, targetURL)
60}
61
62func (s *State) DownloadArchive(w http.ResponseWriter, r *http.Request) {
63 ref := chi.URLParam(r, "ref")
64
65 user, ok := r.Context().Value("resolvedId").(identity.Identity)
66 if !ok {
67 http.Error(w, "failed to resolve user", http.StatusInternalServerError)
68 return
69 }
70 repo := r.Context().Value("repo").(*models.Repo)
71
72 scheme := "https"
73 if s.config.Core.Dev {
74 scheme = "http"
75 }
76
77 targetURL := fmt.Sprintf("%s://%s/%s/%s/archive/%s", scheme, repo.Knot, user.DID, repo.Name, ref)
78 s.proxyRequest(w, r, targetURL)
79}
80
81func (s *State) proxyRequest(w http.ResponseWriter, r *http.Request, targetURL string) {
82 client := &http.Client{}
83
84 // Create new request
85 proxyReq, err := http.NewRequest(r.Method, targetURL, r.Body)
86 if err != nil {
87 http.Error(w, err.Error(), http.StatusInternalServerError)
88 return
89 }
90
91 // Copy original headers
92 proxyReq.Header = r.Header
93
94 repoOwnerHandle := chi.URLParam(r, "user")
95 proxyReq.Header.Add("x-tangled-repo-owner-handle", repoOwnerHandle)
96
97 // Execute request
98 resp, err := client.Do(proxyReq)
99 if err != nil {
100 http.Error(w, err.Error(), http.StatusInternalServerError)
101 return
102 }
103 defer resp.Body.Close()
104
105 // Copy response headers
106 maps.Copy(w.Header(), resp.Header)
107
108 // Set response status code
109 w.WriteHeader(resp.StatusCode)
110
111 // Copy response body
112 if _, err := io.Copy(w, resp.Body); err != nil {
113 http.Error(w, err.Error(), http.StatusInternalServerError)
114 return
115 }
116}