Something went wrong. Try again.
Monorepo for Tangled
Something went wrong. Try again.
2.1 kB · 75 lines
12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576package xrpc
import ( "database/sql" "encoding/json" "net/http"
"github.com/bluesky-social/indigo/atproto/syntax" "tangled.org/core/api/tangled" "tangled.org/core/knotserver/db" "tangled.org/core/rbac" xrpcerr "tangled.org/core/xrpc/errors")
func (h *Xrpc) RemoveCollaborator(w http.ResponseWriter, r *http.Request) { l := h.Logger.With("handler", "RemoveCollaborator") fail := func(e xrpcerr.XrpcError, status int) { l.Error("failed", "kind", e.Tag, "error", e.Message) writeError(w, e, status) }
actorDid, ok := r.Context().Value(ActorDid).(syntax.DID) if !ok { fail(xrpcerr.MissingActorDidError, http.StatusForbidden) return }
var data tangled.RepoRemoveCollaborator_Input if err := json.NewDecoder(r.Body).Decode(&data); err != nil { fail(xrpcerr.GenericError(err), http.StatusBadRequest) return }
t, status, xerr := h.resolveCollabTarget(actorDid, data.Repo, data.Subject) if xerr != nil { fail(*xerr, status) return } if t.ownerNoop { l.Info("subject is the repo owner, no-op", "repoDid", t.repoDid, "subject", t.subject) w.WriteHeader(http.StatusOK) return }
status, xerr = h.applyAclRevoke(r.Context(), l.With("repoDid", t.repoDid), aclRevoke{ role: "collaborator", subject: t.subject, inAcl: func() (bool, error) { return h.Enforcer.IsRepoCollaborator(t.subject.String(), rbac.ThisServer, t.repoDid.String()) }, inTable: func() (bool, error) { return db.IsCollaborator(h.Db, t.repoDid, t.subject) }, removeAcl: func() (bool, error) { if err := h.Enforcer.RemoveCollaborator(t.subject.String(), rbac.ThisServer, t.repoDid.String()); err != nil { return false, err } return true, nil }, restoreAcl: func() error { return h.Enforcer.AddCollaborator(t.subject.String(), rbac.ThisServer, t.repoDid.String()) }, deleteRow: func(tx *sql.Tx) error { return db.RemoveCollaborator(tx, t.repoDid, t.subject) }, emit: func() error { return h.Db.EmitCollaboratorUpdate(h.Notifier, db.AclOpRemove, t.subject, t.repoDid) }, }) if xerr != nil { fail(*xerr, status) return } w.WriteHeader(status)}