feat(backend): add unlisted members, private member list, custom members header

This commit is contained in:
Sam 2023-04-01 17:20:59 +02:00
parent ba48ba0eb2
commit ef9b186e66
No known key found for this signature in database
GPG Key ID: B4EF20DDE721CAA1
14 changed files with 135 additions and 34 deletions

View File

@ -26,6 +26,7 @@ type Member struct {
Links []string Links []string
Names []FieldEntry Names []FieldEntry
Pronouns []PronounEntry Pronouns []PronounEntry
Unlisted bool
} }
const ( const (
@ -68,10 +69,15 @@ func (db *DB) UserMember(ctx context.Context, userID xid.ID, memberRef string) (
} }
// UserMembers returns all of a user's members, sorted by name. // UserMembers returns all of a user's members, sorted by name.
func (db *DB) UserMembers(ctx context.Context, userID xid.ID) (ms []Member, err error) { func (db *DB) UserMembers(ctx context.Context, userID xid.ID, showHidden bool) (ms []Member, err error) {
sql, args, err := sq.Select("*"). builder := sq.Select("*").
From("members").Where("user_id = ?", userID). From("members").Where("user_id = ?", userID).
OrderBy("name", "id").ToSql() OrderBy("name", "id")
if !showHidden {
builder = builder.Where("unlisted = ?", false)
}
sql, args, err := builder.ToSql()
if err != nil { if err != nil {
return nil, errors.Wrap(err, "building sql") return nil, errors.Wrap(err, "building sql")
} }
@ -148,6 +154,7 @@ func (db *DB) UpdateMember(
ctx context.Context, ctx context.Context,
tx pgx.Tx, id xid.ID, tx pgx.Tx, id xid.ID,
name, displayName, bio *string, name, displayName, bio *string,
unlisted *bool,
links *[]string, links *[]string,
avatar *string, avatar *string,
) (m Member, err error) { ) (m Member, err error) {
@ -190,6 +197,9 @@ func (db *DB) UpdateMember(
if links != nil { if links != nil {
builder = builder.Set("links", *links) builder = builder.Set("links", *links)
} }
if unlisted != nil {
builder = builder.Set("unlisted", *unlisted)
}
if avatar != nil { if avatar != nil {
if *avatar == "" { if *avatar == "" {

View File

@ -20,6 +20,7 @@ type User struct {
Username string Username string
DisplayName *string DisplayName *string
Bio *string Bio *string
MemberTitle *string
Avatar *string Avatar *string
Links []string Links []string
@ -37,6 +38,7 @@ type User struct {
MaxInvites int MaxInvites int
IsAdmin bool IsAdmin bool
ListPrivate bool
DeletedAt *time.Time DeletedAt *time.Time
SelfDelete *bool SelfDelete *bool
@ -317,10 +319,11 @@ func (db *DB) UpdateUser(
ctx context.Context, ctx context.Context,
tx pgx.Tx, id xid.ID, tx pgx.Tx, id xid.ID,
displayName, bio *string, displayName, bio *string,
memberTitle *string, listPrivate *bool,
links *[]string, links *[]string,
avatar *string, avatar *string,
) (u User, err error) { ) (u User, err error) {
if displayName == nil && bio == nil && links == nil && avatar == nil { if displayName == nil && bio == nil && links == nil && avatar == nil && memberTitle == nil && listPrivate == nil {
sql, args, err := sq.Select("*").From("users").Where("id = ?", id).ToSql() sql, args, err := sq.Select("*").From("users").Where("id = ?", id).ToSql()
if err != nil { if err != nil {
return u, errors.Wrap(err, "building sql") return u, errors.Wrap(err, "building sql")
@ -349,9 +352,19 @@ func (db *DB) UpdateUser(
builder = builder.Set("bio", *bio) builder = builder.Set("bio", *bio)
} }
} }
if memberTitle != nil {
if *memberTitle == "" {
builder = builder.Set("member_title", nil)
} else {
builder = builder.Set("member_title", *memberTitle)
}
}
if links != nil { if links != nil {
builder = builder.Set("links", *links) builder = builder.Set("links", *links)
} }
if listPrivate != nil {
builder = builder.Set("list_private", *listPrivate)
}
if avatar != nil { if avatar != nil {
if *avatar == "" { if *avatar == "" {
@ -492,7 +505,7 @@ func (db *DB) CleanUser(ctx context.Context, id xid.ID) error {
} }
} }
members, err := db.UserMembers(ctx, u.ID) members, err := db.UserMembers(ctx, u.ID, true)
if err != nil { if err != nil {
return errors.Wrap(err, "getting members") return errors.Wrap(err, "getting members")
} }

View File

@ -175,7 +175,7 @@ func (s *server) doExport(u db.User) {
log.Debugf("[%v] exported user avatar", u.ID) log.Debugf("[%v] exported user avatar", u.ID)
} }
members, err := s.DB.UserMembers(ctx, u.ID) members, err := s.DB.UserMembers(ctx, u.ID, true)
if err != nil { if err != nil {
log.Errorf("[%v] getting user members: %v", u.ID, err) log.Errorf("[%v] getting user members: %v", u.ID, err)
return return

View File

@ -161,7 +161,7 @@ func (s *Server) createMember(w http.ResponseWriter, r *http.Request) (err error
return errors.Wrap(err, "committing transaction") return errors.Wrap(err, "committing transaction")
} }
render.JSON(w, r, dbMemberToMember(u, m, cmr.Fields)) render.JSON(w, r, dbMemberToMember(u, m, cmr.Fields, true))
return nil return nil
} }

View File

@ -24,10 +24,12 @@ type GetMemberResponse struct {
Fields []db.Field `json:"fields"` Fields []db.Field `json:"fields"`
User PartialUser `json:"user"` User PartialUser `json:"user"`
Unlisted *bool `json:"unlisted,omitempty"`
} }
func dbMemberToMember(u db.User, m db.Member, fields []db.Field) GetMemberResponse { func dbMemberToMember(u db.User, m db.Member, fields []db.Field, isOwnMember bool) GetMemberResponse {
return GetMemberResponse{ r := GetMemberResponse{
ID: m.ID, ID: m.ID,
Name: m.Name, Name: m.Name,
DisplayName: m.DisplayName, DisplayName: m.DisplayName,
@ -46,6 +48,12 @@ func dbMemberToMember(u db.User, m db.Member, fields []db.Field) GetMemberRespon
Avatar: u.Avatar, Avatar: u.Avatar,
}, },
} }
if isOwnMember {
r.Unlisted = &m.Unlisted
}
return r
} }
type PartialUser struct { type PartialUser struct {
@ -81,12 +89,17 @@ func (s *Server) getMember(w http.ResponseWriter, r *http.Request) error {
return server.APIError{Code: server.ErrMemberNotFound} return server.APIError{Code: server.ErrMemberNotFound}
} }
isOwnMember := false
if claims, ok := server.ClaimsFromContext(ctx); ok && claims.UserID == u.ID {
isOwnMember = true
}
fields, err := s.DB.MemberFields(ctx, m.ID) fields, err := s.DB.MemberFields(ctx, m.ID)
if err != nil { if err != nil {
return err return err
} }
render.JSON(w, r, dbMemberToMember(u, m, fields)) render.JSON(w, r, dbMemberToMember(u, m, fields, isOwnMember))
return nil return nil
} }
@ -104,6 +117,11 @@ func (s *Server) getUserMember(w http.ResponseWriter, r *http.Request) error {
return server.APIError{Code: server.ErrUserNotFound} return server.APIError{Code: server.ErrUserNotFound}
} }
isOwnMember := false
if claims, ok := server.ClaimsFromContext(ctx); ok && claims.UserID == u.ID {
isOwnMember = true
}
m, err := s.DB.UserMember(ctx, u.ID, chi.URLParam(r, "memberRef")) m, err := s.DB.UserMember(ctx, u.ID, chi.URLParam(r, "memberRef"))
if err != nil { if err != nil {
return server.APIError{ return server.APIError{
@ -116,7 +134,7 @@ func (s *Server) getUserMember(w http.ResponseWriter, r *http.Request) error {
return err return err
} }
render.JSON(w, r, dbMemberToMember(u, m, fields)) render.JSON(w, r, dbMemberToMember(u, m, fields, isOwnMember))
return nil return nil
} }

View File

@ -52,7 +52,16 @@ func (s *Server) getUserMembers(w http.ResponseWriter, r *http.Request) error {
return server.APIError{Code: server.ErrUserNotFound} return server.APIError{Code: server.ErrUserNotFound}
} }
ms, err := s.DB.UserMembers(ctx, u.ID) isSelf := false
if claims, ok := server.ClaimsFromContext(ctx); ok && claims.UserID == u.ID {
isSelf = true
}
if u.ListPrivate && !isSelf {
return server.APIError{Code: server.ErrMemberListPrivate}
}
ms, err := s.DB.UserMembers(ctx, u.ID, isSelf)
if err != nil { if err != nil {
return err return err
} }
@ -65,7 +74,7 @@ func (s *Server) getMeMembers(w http.ResponseWriter, r *http.Request) error {
ctx := r.Context() ctx := r.Context()
claims, _ := server.ClaimsFromContext(ctx) claims, _ := server.ClaimsFromContext(ctx)
ms, err := s.DB.UserMembers(ctx, claims.UserID) ms, err := s.DB.UserMembers(ctx, claims.UserID, true)
if err != nil { if err != nil {
return err return err
} }

View File

@ -23,6 +23,7 @@ type PatchMemberRequest struct {
Pronouns *[]db.PronounEntry `json:"pronouns"` Pronouns *[]db.PronounEntry `json:"pronouns"`
Fields *[]db.Field `json:"fields"` Fields *[]db.Field `json:"fields"`
Avatar *string `json:"avatar"` Avatar *string `json:"avatar"`
Unlisted *bool `json:"unlisted"`
} }
func (s *Server) patchMember(w http.ResponseWriter, r *http.Request) error { func (s *Server) patchMember(w http.ResponseWriter, r *http.Request) error {
@ -62,6 +63,7 @@ func (s *Server) patchMember(w http.ResponseWriter, r *http.Request) error {
if req.DisplayName == nil && if req.DisplayName == nil &&
req.Name == nil && req.Name == nil &&
req.Bio == nil && req.Bio == nil &&
req.Unlisted == nil &&
req.Links == nil && req.Links == nil &&
req.Fields == nil && req.Fields == nil &&
req.Names == nil && req.Names == nil &&
@ -213,7 +215,7 @@ func (s *Server) patchMember(w http.ResponseWriter, r *http.Request) error {
} }
defer tx.Rollback(ctx) defer tx.Rollback(ctx)
m, err = s.DB.UpdateMember(ctx, tx, id, req.Name, req.DisplayName, req.Bio, req.Links, avatarHash) m, err = s.DB.UpdateMember(ctx, tx, id, req.Name, req.DisplayName, req.Bio, req.Unlisted, req.Links, avatarHash)
if err != nil { if err != nil {
switch errors.Cause(err) { switch errors.Cause(err) {
case db.ErrNothingToUpdate: case db.ErrNothingToUpdate:
@ -274,6 +276,6 @@ func (s *Server) patchMember(w http.ResponseWriter, r *http.Request) error {
} }
// echo the updated member back on success // echo the updated member back on success
render.JSON(w, r, dbMemberToMember(u, m, fields)) render.JSON(w, r, dbMemberToMember(u, m, fields, true))
return nil return nil
} }

View File

@ -16,6 +16,7 @@ type GetUserResponse struct {
Username string `json:"name"` Username string `json:"name"`
DisplayName *string `json:"display_name"` DisplayName *string `json:"display_name"`
Bio *string `json:"bio"` Bio *string `json:"bio"`
MemberTitle *string `json:"member_title"`
Avatar *string `json:"avatar"` Avatar *string `json:"avatar"`
Links []string `json:"links"` Links []string `json:"links"`
Names []db.FieldEntry `json:"names"` Names []db.FieldEntry `json:"names"`
@ -29,6 +30,7 @@ type GetMeResponse struct {
MaxInvites int `json:"max_invites"` MaxInvites int `json:"max_invites"`
IsAdmin bool `json:"is_admin"` IsAdmin bool `json:"is_admin"`
ListPrivate bool `json:"list_private"`
Discord *string `json:"discord"` Discord *string `json:"discord"`
DiscordUsername *string `json:"discord_username"` DiscordUsername *string `json:"discord_username"`
@ -55,6 +57,7 @@ func dbUserToResponse(u db.User, fields []db.Field, members []db.Member) GetUser
Username: u.Username, Username: u.Username,
DisplayName: u.DisplayName, DisplayName: u.DisplayName,
Bio: u.Bio, Bio: u.Bio,
MemberTitle: u.MemberTitle,
Avatar: u.Avatar, Avatar: u.Avatar,
Links: db.NotNull(u.Links), Links: db.NotNull(u.Links),
Names: db.NotNull(u.Names), Names: db.NotNull(u.Names),
@ -87,17 +90,29 @@ func (s *Server) getUser(w http.ResponseWriter, r *http.Request) error {
if id, err := xid.FromString(userRef); err == nil { if id, err := xid.FromString(userRef); err == nil {
u, err := s.DB.User(ctx, id) u, err := s.DB.User(ctx, id)
if err == nil { if err == nil {
if u.DeletedAt != nil {
return server.APIError{Code: server.ErrUserNotFound}
}
isSelf := false
if claims, ok := server.ClaimsFromContext(ctx); ok && claims.UserID == u.ID {
isSelf = true
}
fields, err := s.DB.UserFields(ctx, u.ID) fields, err := s.DB.UserFields(ctx, u.ID)
if err != nil { if err != nil {
log.Errorf("Error getting user fields: %v", err) log.Errorf("Error getting user fields: %v", err)
return err return err
} }
members, err := s.DB.UserMembers(ctx, u.ID) var members []db.Member
if !u.ListPrivate || isSelf {
members, err = s.DB.UserMembers(ctx, u.ID, isSelf)
if err != nil { if err != nil {
log.Errorf("Error getting user members: %v", err) log.Errorf("Error getting user members: %v", err)
return err return err
} }
}
render.JSON(w, r, dbUserToResponse(u, fields, members)) render.JSON(w, r, dbUserToResponse(u, fields, members))
return nil return nil
@ -123,17 +138,25 @@ func (s *Server) getUser(w http.ResponseWriter, r *http.Request) error {
return server.APIError{Code: server.ErrUserNotFound} return server.APIError{Code: server.ErrUserNotFound}
} }
isSelf := false
if claims, ok := server.ClaimsFromContext(ctx); ok && claims.UserID == u.ID {
isSelf = true
}
fields, err := s.DB.UserFields(ctx, u.ID) fields, err := s.DB.UserFields(ctx, u.ID)
if err != nil { if err != nil {
log.Errorf("Error getting user fields: %v", err) log.Errorf("Error getting user fields: %v", err)
return err return err
} }
members, err := s.DB.UserMembers(ctx, u.ID) var members []db.Member
if !u.ListPrivate || isSelf {
members, err = s.DB.UserMembers(ctx, u.ID, isSelf)
if err != nil { if err != nil {
log.Errorf("Error getting user members: %v", err) log.Errorf("Error getting user members: %v", err)
return err return err
} }
}
render.JSON(w, r, dbUserToResponse(u, fields, members)) render.JSON(w, r, dbUserToResponse(u, fields, members))
return nil return nil
@ -155,7 +178,7 @@ func (s *Server) getMeUser(w http.ResponseWriter, r *http.Request) error {
return err return err
} }
members, err := s.DB.UserMembers(ctx, u.ID) members, err := s.DB.UserMembers(ctx, u.ID, true)
if err != nil { if err != nil {
log.Errorf("Error getting user members: %v", err) log.Errorf("Error getting user members: %v", err)
return err return err
@ -165,6 +188,7 @@ func (s *Server) getMeUser(w http.ResponseWriter, r *http.Request) error {
GetUserResponse: dbUserToResponse(u, fields, members), GetUserResponse: dbUserToResponse(u, fields, members),
MaxInvites: u.MaxInvites, MaxInvites: u.MaxInvites,
IsAdmin: u.IsAdmin, IsAdmin: u.IsAdmin,
ListPrivate: u.ListPrivate,
Discord: u.Discord, Discord: u.Discord,
DiscordUsername: u.DiscordUsername, DiscordUsername: u.DiscordUsername,
Fediverse: u.Fediverse, Fediverse: u.Fediverse,

View File

@ -15,11 +15,13 @@ type PatchUserRequest struct {
Username *string `json:"username"` Username *string `json:"username"`
DisplayName *string `json:"display_name"` DisplayName *string `json:"display_name"`
Bio *string `json:"bio"` Bio *string `json:"bio"`
MemberTitle *string `json:"member_title"`
Links *[]string `json:"links"` Links *[]string `json:"links"`
Names *[]db.FieldEntry `json:"names"` Names *[]db.FieldEntry `json:"names"`
Pronouns *[]db.PronounEntry `json:"pronouns"` Pronouns *[]db.PronounEntry `json:"pronouns"`
Fields *[]db.Field `json:"fields"` Fields *[]db.Field `json:"fields"`
Avatar *string `json:"avatar"` Avatar *string `json:"avatar"`
ListPrivate *bool `json:"list_private"`
} }
// patchUser parses a PatchUserRequest and updates the user with the given ID. // patchUser parses a PatchUserRequest and updates the user with the given ID.
@ -48,6 +50,8 @@ func (s *Server) patchUser(w http.ResponseWriter, r *http.Request) error {
if req.Username == nil && if req.Username == nil &&
req.DisplayName == nil && req.DisplayName == nil &&
req.Bio == nil && req.Bio == nil &&
req.MemberTitle == nil &&
req.ListPrivate == nil &&
req.Links == nil && req.Links == nil &&
req.Fields == nil && req.Fields == nil &&
req.Names == nil && req.Names == nil &&
@ -72,6 +76,13 @@ func (s *Server) patchUser(w http.ResponseWriter, r *http.Request) error {
Details: fmt.Sprintf("Bio too long (max %d, current %d)", db.MaxUserBioLength, len(*req.Bio)), Details: fmt.Sprintf("Bio too long (max %d, current %d)", db.MaxUserBioLength, len(*req.Bio)),
} }
} }
// this is considered a name
if req.MemberTitle != nil && len(*req.MemberTitle) > db.MaxDisplayNameLength {
return server.APIError{
Code: server.ErrBadRequest,
Details: fmt.Sprintf("Member title too long (max %d, current %d)", db.MaxDisplayNameLength, len(*req.MemberTitle)),
}
}
// validate links // validate links
if req.Links != nil { if req.Links != nil {
@ -175,7 +186,7 @@ func (s *Server) patchUser(w http.ResponseWriter, r *http.Request) error {
} }
} }
u, err = s.DB.UpdateUser(ctx, tx, claims.UserID, req.DisplayName, req.Bio, req.Links, avatarHash) u, err = s.DB.UpdateUser(ctx, tx, claims.UserID, req.DisplayName, req.Bio, req.MemberTitle, req.ListPrivate, req.Links, avatarHash)
if err != nil && errors.Cause(err) != db.ErrNothingToUpdate { if err != nil && errors.Cause(err) != db.ErrNothingToUpdate {
log.Errorf("updating user: %v", err) log.Errorf("updating user: %v", err)
return err return err

View File

@ -100,6 +100,7 @@ const (
// User-related error codes // User-related error codes
ErrUserNotFound = 2001 ErrUserNotFound = 2001
ErrMemberListPrivate = 2002
// Member-related error codes // Member-related error codes
ErrMemberNotFound = 3001 ErrMemberNotFound = 3001
@ -142,6 +143,7 @@ var errCodeMessages = map[int]string{
ErrLastProvider: "This is your account's only authentication provider", ErrLastProvider: "This is your account's only authentication provider",
ErrUserNotFound: "User not found", ErrUserNotFound: "User not found",
ErrMemberListPrivate: "This user's member list is private.",
ErrMemberNotFound: "Member not found", ErrMemberNotFound: "Member not found",
ErrMemberLimitReached: "Member limit reached", ErrMemberLimitReached: "Member limit reached",
@ -181,6 +183,7 @@ var errCodeStatuses = map[int]int{
ErrLastProvider: http.StatusBadRequest, ErrLastProvider: http.StatusBadRequest,
ErrUserNotFound: http.StatusNotFound, ErrUserNotFound: http.StatusNotFound,
ErrMemberListPrivate: http.StatusForbidden,
ErrMemberNotFound: http.StatusNotFound, ErrMemberNotFound: http.StatusNotFound,
ErrMemberLimitReached: http.StatusBadRequest, ErrMemberLimitReached: http.StatusBadRequest,

View File

@ -10,6 +10,7 @@ export interface User {
bio: string | null; bio: string | null;
avatar: string | null; avatar: string | null;
links: string[]; links: string[];
member_title: string | null;
names: FieldEntry[]; names: FieldEntry[];
pronouns: Pronoun[]; pronouns: Pronoun[];
@ -24,6 +25,7 @@ export interface MeUser extends User {
fediverse: string | null; fediverse: string | null;
fediverse_username: string | null; fediverse_username: string | null;
fediverse_instance: string | null; fediverse_instance: string | null;
list_private: boolean;
} }
export interface Field { export interface Field {
@ -66,6 +68,7 @@ export interface Member extends PartialMember {
fields: Field[]; fields: Field[];
user: MemberPartialUser; user: MemberPartialUser;
unlisted?: boolean;
} }
export interface MemberPartialUser { export interface MemberPartialUser {

View File

@ -83,7 +83,7 @@ func run(c *cli.Context) error {
} }
for _, u := range users { for _, u := range users {
members, err := db.UserMembers(ctx, u.ID) members, err := db.UserMembers(ctx, u.ID, true)
if err != nil { if err != nil {
fmt.Printf("error getting members for user %v: %v\n", u.ID, err) fmt.Printf("error getting members for user %v: %v\n", u.ID, err)
continue continue

View File

@ -0,0 +1,8 @@
-- +migrate Up
-- 2023-04-01: Add a couple customization options to users and members
alter table users add column member_title text;
alter table users add column list_private boolean not null default false;
alter table members add column unlisted boolean not null default false;

View File

@ -48,7 +48,7 @@ func run(c *cli.Context) error {
return err return err
} }
_, err = pg.UpdateUser(ctx, tx, u.ID, ptr("testing"), ptr("This is a bio!"), &[]string{"https://pronouns.cc"}, nil) _, err = pg.UpdateUser(ctx, tx, u.ID, ptr("testing"), ptr("This is a bio!"), nil, ptr(false), &[]string{"https://pronouns.cc"}, nil)
if err != nil { if err != nil {
fmt.Println("error setting user info:", err) fmt.Println("error setting user info:", err)
return err return err