Something went wrong. Try again.
Monorepo for Tangled
Something went wrong. Try again.
4.0 kB · 129 lines
Go
123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130package xrpc
import ( "encoding/json" "net/http" "net/http/httptest" "testing"
"tangled.org/core/api/tangled" "tangled.org/core/eventstream" "tangled.org/core/knotserver/db")
func eventsOfType(t *testing.T, x *Xrpc, nsid string) []eventstream.Event { t.Helper() all, err := x.Db.GetEvents(0, 1000) if err != nil { t.Fatalf("GetEvents: %v", err) } var out []eventstream.Event for _, e := range all { if e.Nsid == nsid { out = append(out, e) } } return out}
func decodeMemberUpdate(t *testing.T, e eventstream.Event) db.KnotMemberUpdate { t.Helper() var m db.KnotMemberUpdate if err := json.Unmarshal(e.EventJson, &m); err != nil { t.Fatalf("decode memberUpdate: %v", err) } return m}
func decodeCollaboratorUpdate(t *testing.T, e eventstream.Event) db.RepoCollaboratorUpdate { t.Helper() var c db.RepoCollaboratorUpdate if err := json.Unmarshal(e.EventJson, &c); err != nil { t.Fatalf("decode collaboratorUpdate: %v", err) } return c}
func TestAddMember_EmitsAddEvent(t *testing.T) { x, _ := newACLXrpc(t) rec := httptest.NewRecorder() x.AddMember(rec, aclRequest(t, aclOwner, tangled.KnotAddMember_Input{Subject: aclSubject})) if rec.Code != http.StatusOK { t.Fatalf("status = %d, body=%s", rec.Code, rec.Body.String()) }
evs := eventsOfType(t, x, db.KnotMemberUpdateNSID) if len(evs) != 1 { t.Fatalf("memberUpdate events = %d, want 1", len(evs)) } m := decodeMemberUpdate(t, evs[0]) if m.Op != db.AclOpAdd || m.Subject != aclSubject { t.Errorf("event = %+v, want op=add subject=%s", m, aclSubject) }}
func TestRemoveMember_EmitsRemoveEvent(t *testing.T) { x, _ := newACLXrpc(t) seedMembers(t, x, aclSubject)
rec := httptest.NewRecorder() x.RemoveMember(rec, aclRequest(t, aclOwner, tangled.KnotRemoveMember_Input{Subject: aclSubject})) if rec.Code != http.StatusOK { t.Fatalf("status = %d, body=%s", rec.Code, rec.Body.String()) }
evs := eventsOfType(t, x, db.KnotMemberUpdateNSID) if len(evs) != 2 { t.Fatalf("memberUpdate events = %d, want 2 (add then remove)", len(evs)) } last := decodeMemberUpdate(t, evs[len(evs)-1]) if last.Op != db.AclOpRemove || last.Subject != aclSubject { t.Errorf("last event = %+v, want op=remove subject=%s", last, aclSubject) }}
func TestAddMember_NoOpDoesNotEmit(t *testing.T) { x, _ := newACLXrpc(t) for range 2 { rec := httptest.NewRecorder() x.AddMember(rec, aclRequest(t, aclOwner, tangled.KnotAddMember_Input{Subject: aclSubject})) if rec.Code != http.StatusOK { t.Fatalf("status = %d, body=%s", rec.Code, rec.Body.String()) } }
if evs := eventsOfType(t, x, db.KnotMemberUpdateNSID); len(evs) != 1 { t.Errorf("memberUpdate events = %d, want 1; a duplicate grant is a no-op and must not emit", len(evs)) }}
func TestCollaborator_EmitsAddThenRemove(t *testing.T) { x, _ := newACLXrpc(t) seedRepo(t, x)
addRec := httptest.NewRecorder() x.AddCollaborator(addRec, aclRequest(t, aclOwner, tangled.RepoAddCollaborator_Input{Repo: aclRepoDid, Subject: aclSubject})) if addRec.Code != http.StatusOK { t.Fatalf("add status = %d, body=%s", addRec.Code, addRec.Body.String()) }
rmRec := httptest.NewRecorder() x.RemoveCollaborator(rmRec, aclRequest(t, aclOwner, tangled.RepoRemoveCollaborator_Input{Repo: aclRepoDid, Subject: aclSubject})) if rmRec.Code != http.StatusOK { t.Fatalf("remove status = %d, body=%s", rmRec.Code, rmRec.Body.String()) }
evs := eventsOfType(t, x, db.RepoCollaboratorUpdateNSID) if len(evs) != 2 { t.Fatalf("collaboratorUpdate events = %d, want 2 (add then remove)", len(evs)) }
add := decodeCollaboratorUpdate(t, evs[0]) if add.Op != db.AclOpAdd || add.Subject != aclSubject || add.Repo != aclRepoDid { t.Errorf("add event = %+v, want op=add subject=%s repo=%s", add, aclSubject, aclRepoDid) } rm := decodeCollaboratorUpdate(t, evs[1]) if rm.Op != db.AclOpRemove || rm.Subject != aclSubject || rm.Repo != aclRepoDid { t.Errorf("remove event = %+v, want op=remove subject=%s repo=%s", rm, aclSubject, aclRepoDid) }}