package tinyclient import ( "context" "encoding/json" "errors" "net/http" "net/http/httptest" "strings" "testing" "github.com/FelineStateMachine/tinyrelay/internal/policy" ) var ( roomOwner = strings.Repeat("a", 64) roomAgent = strings.Repeat("b", 64) roomGuest = strings.Repeat("c", 64) roomHello = strings.Repeat("1", 64) roomChat = strings.Repeat("2", 64) roomThread = strings.Repeat("3", 64) roomReply = strings.Repeat("4", 64) roomLike = strings.Repeat("5", 64) ) // roomsBackend answers the room browse calls for an open room and a // members-only room. Guests see the open room only. type roomsBackend struct { fakeBackend calls []string } func roomEvent(id, pubkey string, kind int, createdAt int64, content string, tags ...[]string) map[string]any { return map[string]any{"id": id, "pubkey": pubkey, "kind": kind, "created_at": createdAt, "content": content, "tags": tags, "sig": ""} } func roomRecord(id, name, access, role string) map[string]any { return map[string]any{"id": id, "name": name, "about": "Where " + name + " happens.", "picture": "", "access": access, "created_by": roomOwner, "created_at": 1757200000, "event_id": "", "members": 2, "last_message_at": 1757203600, "role": role} } func TestRoomInteractionSummariesSurvivePagination(t *testing.T) { root := RoomMessage{ID: roomThread, PubKey: roomAgent, Kind: 11, Content: "Root"} page := RoomPage{ Room: RoomSummary{ID: "general"}, Messages: []RoomMessage{root}, Root: &root, ReplyCounts: map[string]int{roomThread: 105}, ReactionCounts: map[string]map[string]int{roomThread: {"+1": 2, "wave": 1}}, } value := roomPageValueFromContract(page) items := roomItems(value, "messages") if len(items) != 1 || items[0].Replies != 105 || len(items[0].Reactions) != 2 || items[0].Reactions[0] != (reaction{Content: "+1", Count: 2}) { t.Fatalf("folded summaries missing: %#v", items) } if item := roomRoot(value); item.Replies != 105 { t.Fatalf("thread total counts only the current page: %d", item.Replies) } } func (b *roomsBackend) Query(_ context.Context, method string, params []json.RawMessage, actor string) (any, error) { b.calls = append(b.calls, method+":"+actor) q := map[string]any{} if len(params) > 0 { _ = json.Unmarshal(params[0], &q) } role := "" if actor != "" { role = "owner" } id, _ := q["id"].(string) switch method { case "browserooms": items := []any{roomRecord("general", "General", "open", role)} if actor != "" { items = append(items, roomRecord("build", "Build", "members", role)) } return map[string]any{"items": items, "next_cursor": ""}, nil case "browseroom", "browsethread": if id == "build" && actor == "" { return nil, errors.New("auth-required: this room is members-only") } if id != "general" && id != "build" { return nil, errors.New("not found: room") } default: return nil, nil } members := []any{map[string]any{"pubkey": roomOwner, "role": "owner", "added_at": 1757200000}, map[string]any{"pubkey": roomAgent, "role": "member", "added_at": 1757200100, "agent": true, "operator": roomOwner}} root := roomEvent(roomThread, roomAgent, 11, 1757203000, "Release notes draft", []string{"h", id}) reply := roomEvent(roomReply, roomOwner, 12, 1757203300, "Looks good", []string{"h", id}, []string{"e", roomThread}, []string{"p", roomAgent}) if method == "browsethread" { return map[string]any{"room": roomRecord(id, "General", "open", ""), "root": root, "replies": []any{reply}, "next_cursor": ""}, nil } messages := []any{ roomEvent(strings.Repeat("a", 64), roomAgent, 40003, 1757203650, "hello again, see https://example.com/docs. and nostr:npub1ttrypewl3au52wqux86r22yt506c077k3maj02a0jste97wrvd5sjfutc2", []string{"h", id}, []string{"e", roomHello}), roomEvent(strings.Repeat("b", 64), roomOwner, 40003, 1757203660, "not my message", []string{"h", id}, []string{"e", roomHello}), roomEvent(roomLike, roomOwner, 7, 1757203600, "+", []string{"h", id}, []string{"e", roomChat}), reply, root, roomEvent(roomChat, roomOwner, 9, 1757202000, "@agent take a look ", []string{"h", id}, []string{"p", roomAgent}, []string{"q", roomThread, "", roomAgent}), roomEvent(roomHello, roomAgent, 9, 1757201000, "hello, see https://example.com/docs. and nostr:npub1ttrypewl3au52wqux86r22yt506c077k3maj02a0jste97wrvd5sjfutc2", []string{"h", id}), } return map[string]any{"room": roomRecord(id, strings.ToUpper(id[:1])+id[1:], map[string]string{"general": "open", "build": "members"}[id], role), "members": members, "messages": messages, "next_cursor": "cursor-1"}, nil } func roomsApp(t *testing.T, actor string) (*App, *roomsBackend) { t.Helper() backend := &roomsBackend{fakeBackend: fakeBackend{policy: policy.Defaults(roomOwner)}} app, err := New(backend, Options{Actor: func(*http.Request) (string, error) { return actor, nil }}) if err != nil { t.Fatal(err) } return app, backend } func roomsPage(t *testing.T, app *App, path string) string { t.Helper() recorder := httptest.NewRecorder() app.ServeHTTP(recorder, httptest.NewRequest(http.MethodGet, path, nil)) if recorder.Code != http.StatusOK { t.Fatalf("%s: status=%d", path, recorder.Code) } body := recorder.Body.String() if strings.Contains(body, "class=") { t.Errorf("%s carries a class attribute", path) } content := body[strings.Index(body, `id="content"`):strings.Index(body, `id="aside"`)] if sections := strings.Count(content, "`, `General`, `Build`, `members only Where Build happens.`, ``, `chat`, `