lewis.moe
Monorepo for Tangled
1package xrpc
2
3import (
4 "encoding/json"
5 "fmt"
6 "net/http"
7 "os"
8
9 comatproto "github.com/bluesky-social/indigo/api/atproto"
10 "github.com/bluesky-social/indigo/atproto/syntax"
11 "github.com/bluesky-social/indigo/xrpc"
12 "tangled.org/core/api/tangled"
13 "tangled.org/core/rbac"
14 xrpcerr "tangled.org/core/xrpc/errors"
15)
16
17func (x *Xrpc) DeleteRepo(w http.ResponseWriter, r *http.Request) {
18 l := x.Logger.With("handler", "DeleteRepo")
19 fail := func(e xrpcerr.XrpcError) {
20 l.Error("failed", "kind", e.Tag, "error", e.Message)
21 writeError(w, e, http.StatusBadRequest)
22 }
23
24 actorDid, ok := r.Context().Value(ActorDid).(syntax.DID)
25 if !ok {
26 fail(xrpcerr.MissingActorDidError)
27 return
28 }
29
30 var data tangled.RepoDelete_Input
31 if err := json.NewDecoder(r.Body).Decode(&data); err != nil {
32 fail(xrpcerr.GenericError(err))
33 return
34 }
35
36 did := data.Did
37 name := data.Name
38 rkey := data.Rkey
39
40 if did == "" || name == "" {
41 fail(xrpcerr.GenericError(fmt.Errorf("did and name are required")))
42 return
43 }
44
45 ident, err := x.Resolver.ResolveIdent(r.Context(), actorDid.String())
46 if err != nil || ident.Handle.IsInvalidHandle() {
47 fail(xrpcerr.GenericError(err))
48 return
49 }
50
51 xrpcc := xrpc.Client{
52 Host: ident.PDSEndpoint(),
53 }
54
55 // ensure that the record does not exists
56 _, err = comatproto.RepoGetRecord(r.Context(), &xrpcc, "", tangled.RepoNSID, actorDid.String(), rkey)
57 if err == nil {
58 fail(xrpcerr.RecordExistsError(rkey))
59 return
60 }
61
62 repoDid, err := x.Db.GetRepoDid(did, name)
63 if err != nil {
64 fail(xrpcerr.RepoNotFoundError)
65 return
66 }
67 repoPath, _, _, err := x.Db.ResolveRepoDIDOnDisk(x.Config.Repo.ScanPath, repoDid)
68 if err != nil {
69 fail(xrpcerr.RepoNotFoundError)
70 return
71 }
72
73 isDeleteAllowed, err := x.Enforcer.IsRepoDeleteAllowed(actorDid.String(), rbac.ThisServer, repoDid)
74 if err != nil {
75 fail(xrpcerr.GenericError(err))
76 return
77 }
78 if !isDeleteAllowed {
79 fail(xrpcerr.AccessControlError(actorDid.String()))
80 return
81 }
82
83 err = os.RemoveAll(repoPath)
84 if err != nil {
85 l.Error("deleting repo", "error", err.Error())
86 writeError(w, xrpcerr.GenericError(err), http.StatusInternalServerError)
87 return
88 }
89
90 err = x.Enforcer.RemoveRepo(did, rbac.ThisServer, repoDid)
91 if err != nil {
92 l.Error("failed to delete repo from enforcer", "error", err.Error())
93 writeError(w, xrpcerr.GenericError(err), http.StatusInternalServerError)
94 return
95 }
96
97 if err := x.Db.DeleteRepoKey(repoDid); err != nil {
98 l.Error("failed to delete repo key", "error", err.Error())
99 }
100
101 w.WriteHeader(http.StatusOK)
102}