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