Monorepo for Tangled
tangled.org
1package xrpc
2
3import (
4 "encoding/json"
5 "fmt"
6 "net/http"
7
8 comatproto "github.com/bluesky-social/indigo/api/atproto"
9 "github.com/bluesky-social/indigo/atproto/syntax"
10 "github.com/bluesky-social/indigo/xrpc"
11 "tangled.org/core/api/tangled"
12 "tangled.org/core/eventstream"
13 "tangled.org/core/knotserver/git"
14 "tangled.org/core/rbac"
15 "tangled.org/core/tid"
16
17 xrpcerr "tangled.org/core/xrpc/errors"
18)
19
20func (x *Xrpc) SetDefaultBranch(w http.ResponseWriter, r *http.Request) {
21 l := x.Logger
22 fail := func(e xrpcerr.XrpcError) {
23 l.Error("failed", "kind", e.Tag, "error", e.Message)
24 writeError(w, e, http.StatusBadRequest)
25 }
26
27 actorDid, ok := r.Context().Value(ActorDid).(syntax.DID)
28 if !ok {
29 fail(xrpcerr.MissingActorDidError)
30 return
31 }
32
33 var data tangled.RepoSetDefaultBranch_Input
34 if err := json.NewDecoder(r.Body).Decode(&data); err != nil {
35 fail(xrpcerr.GenericError(err))
36 return
37 }
38
39 // unfortunately we have to resolve repo-at here
40 repoAt, err := syntax.ParseATURI(data.Repo)
41 if err != nil {
42 fail(xrpcerr.InvalidRepoError(data.Repo))
43 return
44 }
45
46 // resolve this aturi to extract the repo record
47 ident, err := x.Resolver.ResolveIdent(r.Context(), repoAt.Authority().String())
48 if err != nil || ident.Handle.IsInvalidHandle() {
49 fail(xrpcerr.GenericError(fmt.Errorf("failed to resolve handle: %w", err)))
50 return
51 }
52
53 xrpcc := xrpc.Client{Host: ident.PDSEndpoint()}
54 resp, err := comatproto.RepoGetRecord(r.Context(), &xrpcc, "", tangled.RepoNSID, repoAt.Authority().String(), repoAt.RecordKey().String())
55 if err != nil {
56 fail(xrpcerr.GenericError(err))
57 return
58 }
59
60 if _, ok := resp.Value.Val.(*tangled.Repo); !ok {
61 fail(xrpcerr.RepoNotFoundError)
62 return
63 }
64 repoDid, err := x.Db.GetRepoDid(actorDid.String(), repoAt.RecordKey().String())
65 if err != nil {
66 fail(xrpcerr.RepoNotFoundError)
67 return
68 }
69 repoPath, _, _, err := x.Db.ResolveRepoDIDOnDisk(x.Config.Repo.ScanPath, repoDid)
70 if err != nil {
71 fail(xrpcerr.RepoNotFoundError)
72 return
73 }
74
75 if ok, err := x.Enforcer.IsPushAllowed(actorDid.String(), rbac.ThisServer, repoDid); !ok || err != nil {
76 l.Error("insufficient permissions", "did", actorDid.String())
77 writeError(w, xrpcerr.AccessControlError(actorDid.String()), http.StatusUnauthorized)
78 return
79 }
80
81 gr, err := git.PlainOpen(repoPath)
82 if err != nil {
83 fail(xrpcerr.GenericError(err))
84 return
85 }
86
87 err = gr.SetDefaultBranch(data.DefaultBranch)
88 if err != nil {
89 l.Error("setting default branch", "error", err.Error())
90 writeError(w, xrpcerr.GitError(err), http.StatusInternalServerError)
91 return
92 }
93
94 ownerDid := ident.DID.String()
95 refUpdate := tangled.GitRefUpdate{
96 Repo: repoDid,
97 OwnerDid: &ownerDid,
98 CommitterDid: actorDid.String(),
99 }
100 eventJson, err := json.Marshal(refUpdate)
101 if err != nil {
102 fail(xrpcerr.GenericError(err))
103 return
104 }
105
106 if err := x.Db.InsertEvent(eventstream.Event{
107 Rkey: tid.TID(),
108 Nsid: tangled.GitRefUpdateNSID,
109 EventJson: eventJson,
110 }, x.Notifier); err != nil {
111 l.Error("failed to insert event", "error", err)
112 writeError(w, xrpcerr.GenericError(err), http.StatusInternalServerError)
113 return
114 }
115
116 w.WriteHeader(http.StatusOK)
117}