chat

Oct 30, 2026

Changes in this version

+ const MaxPinnedMessages

+ var ErrTooManyPins = errors.New("too many pins")

+ func PinTime(t time.Time) time.Time

+ func ValidatePin(chatID *commonpb.ChatId, pin Pin) error

+ func ValidatePinChatIDs(chatIDs ...*commonpb.ChatId) error

+ func ValidatePinPosition(pos PinPosition) error

type Chat

+ OpeningIntentID *commonpb.IntentId

type GroupEdit

+ MinimumBalances *GroupMinimumBalances

+ type GroupMinimumBalances struct

+ Listener *MinimumBalance

+ Speaker *MinimumBalance

+ func RulesEditFromProto(c *Chat, rules *chatpb.Rules) (*GroupMinimumBalances, error)

+ type MessageKey struct

+ ChatID string

+ MessageID uint64

+ func MessageKeyOf(chatID *commonpb.ChatId, messageID *messagingpb.MessageId) MessageKey

type MessagingReader

+ Messages func(ctx context.Context, refs []MessageRef, reading Reading) (map[MessageKey]*messagingpb.Message, error)

type Permissions

+ CanPin bool

+ type Pin struct

+ MessageID *messagingpb.MessageId

+ PinnedAt time.Time

+ PinnedBy *commonpb.UserId

+ func (p Pin) Clone() Pin

+ func (p Pin) Position() PinPosition

+ func (p Pin) ToProto(message *messagingpb.Message) *chatpb.Pin

+ type PinPosition struct

+ MessageID *messagingpb.MessageId

+ PinnedAt time.Time

+ func (p PinPosition) Compare(o PinPosition) int

+ type PinSummary struct

+ Count uint32

+ Latest *Pin

+ Version uint64

+ func (s PinSummary) Clone() PinSummary

+ func (s PinSummary) ToProto(latestMessage *messagingpb.Message) *chatpb.PinSummary

type Server

+ func (s *Server) GetPinnedMessages(ctx context.Context, req *chatpb.GetPinnedMessagesRequest) (*chatpb.GetPinnedMessagesResponse, error)

+ func (s *Server) PinMessage(ctx context.Context, req *chatpb.PinMessageRequest) (*chatpb.PinMessageResponse, error)

+ func (s *Server) UnpinMessage(ctx context.Context, req *chatpb.UnpinMessageRequest) (*chatpb.UnpinMessageResponse, error)

type ServerOption

+ func WithMaxPinnedMessages(n int) ServerOption

type Store

+ GetDmOpeningIntentID func(ctx context.Context, chatID *commonpb.ChatId) (*commonpb.IntentId, error)

+ GetPinSummaries func(ctx context.Context, chatIDs []*commonpb.ChatId) (map[string]PinSummary, error)

+ GetPinsPage func(ctx context.Context, chatID *commonpb.ChatId, after *PinPosition, limit int) ([]Pin, error)

+ PinMessage func(ctx context.Context, chatID *commonpb.ChatId, messageID *messagingpb.MessageId, ...) (summary PinSummary, changed bool, err error)

+ UnpinMessage func(ctx context.Context, chatID *commonpb.ChatId, messageID *messagingpb.MessageId) (summary PinSummary, changed bool, err error)

+ type StoredRules struct

+ IsCreatorOnlySpeaker bool

+ IsStaffOnly bool

+ MinimumListenerBalance *MinimumBalance

+ MinimumSpeakerBalance *MinimumBalance

Oct 26, 2026

Changes in this version

+ const InviteIDSize

+ const InviteTokenSize

+ const MaxActiveInvites

+ const MaxInviteDuration

+ var ErrInviteExhausted = errors.New("invite exhausted")

+ var ErrInviteExpired = errors.New("invite expired")

+ var ErrInviteNotFound = errors.New("invite not found")

+ var ErrInviteRevoked = errors.New("invite revoked")

+ var ErrOwnInvite = errors.New("user created the invite they are joining with")

+ var ErrTooManyInvites = errors.New("too many invites")

+ func InviteTime(t time.Time) time.Time

+ func MustDeriveInviteID(token *chatpb.InviteToken) *chatpb.InviteId

+ func ValidateInviteJoin(chatID *commonpb.ChatId, userID *commonpb.UserId, inviteID *chatpb.InviteId, ...) error

+ func ValidateInvitePosition(pos InvitePosition) error

+ func ValidateNewInvite(invite Invite, keyCopy *chatpb.InviteKeyEnvelope) error

+ func VerifyInviteSignature(publicKey *commonpb.PublicKey, chatID *commonpb.ChatId, ...) bool

+ type Invite struct

+ ChatID *commonpb.ChatId

+ CreatedAt time.Time

+ CreatedBy *commonpb.UserId

+ ExpiresAt *time.Time

+ ID *chatpb.InviteId

+ MaxUses uint32

+ RevokedAt *time.Time

+ SecretEnvelope *chatpb.InviteSecretEnvelope

+ UseCount uint32

+ func (i Invite) AdmitsAt(now time.Time) error

+ func (i Invite) Clone() Invite

+ func (i Invite) IsLastUse() bool

+ func (i Invite) Position() InvitePosition

+ func (i Invite) StatusAt(now time.Time) chatpb.Invite_Status

+ func (i Invite) ToProto(now time.Time) *chatpb.Invite

+ type InviteKeyCopy struct

+ Envelope *chatpb.InviteKeyEnvelope

+ InviteID *chatpb.InviteId

+ SecretEnvelope *chatpb.InviteSecretEnvelope

+ func (c InviteKeyCopy) Clone() InviteKeyCopy

+ func (c InviteKeyCopy) Equal(other InviteKeyCopy) bool

+ func (c InviteKeyCopy) ToProto() *chatpb.GetKeyEnvelopeResponse_InviteKeyBundle

+ type InvitePosition struct

+ CreatedAt time.Time

+ InviteID *chatpb.InviteId

+ func (p InvitePosition) Compare(o InvitePosition) int

+ type JoinMethod struct

+ By *commonpb.UserId

+ Kind JoinMethodKind

+ func AdmittedBy(userID *commonpb.UserId) JoinMethod

+ func InvitedBy(userID *commonpb.UserId) JoinMethod

+ func JoinedDirectly() JoinMethod

+ type JoinMethodKind uint8

+ const JoinAdmitted

+ const JoinDirect

+ const JoinInvited

+ type JoinWithInviteResult struct

+ Changed bool

+ Invite Invite

+ LeftLobby bool

+ Roster RosterSummary

type KeyEnvelope

+ InviteCopy *InviteKeyCopy

+ func NewInviteKeyEnvelope(invite Invite, envelope *chatpb.InviteKeyEnvelope, ...) KeyEnvelope

+ func (e KeyEnvelope) IsInviteCopy() bool

type Permissions

+ CanInvite bool

type Server

+ func (s *Server) CreateInvite(ctx context.Context, req *chatpb.CreateInviteRequest) (*chatpb.CreateInviteResponse, error)

+ func (s *Server) GetChatInvites(ctx context.Context, req *chatpb.GetChatInvitesRequest) (*chatpb.GetChatInvitesResponse, error)

+ func (s *Server) GetInvite(ctx context.Context, req *chatpb.GetInviteRequest) (*chatpb.GetInviteResponse, error)

+ func (s *Server) RevokeInvite(ctx context.Context, req *chatpb.RevokeInviteRequest) (*chatpb.RevokeInviteResponse, error)

type ServerOption

+ func WithMaxActiveInvites(n int) ServerOption

type Store

+ CreateInvite func(ctx context.Context, invite Invite, keyCopy *chatpb.InviteKeyEnvelope, ...) (stored Invite, created bool, err error)

+ GetChatInvitesPage func(ctx context.Context, chatID *commonpb.ChatId, createdBy *commonpb.UserId, ...) ([]Invite, error)

+ GetInvite func(ctx context.Context, inviteID *chatpb.InviteId) (Invite, error)

+ JoinWithInvite func(ctx context.Context, chatID *commonpb.ChatId, userID *commonpb.UserId, ...) (JoinWithInviteResult, error)

+ RevokeInvite func(ctx context.Context, chatID *commonpb.ChatId, inviteID *chatpb.InviteId, ...) (invite Invite, changed bool, err error)

Oct 23, 2026

Changes in this version

+ var ErrBanned = errors.New("banned")

+ var ErrSilenceUntilOutOfRange = errors.New("silence until is out of range")

type Access

+ func (a *Access) CanDelete(ctx context.Context, chatID *commonpb.ChatId, userID *commonpb.UserId) (bool, error)

+ type BanResult struct

+ Changed bool

+ Departed bool

+ LeftLobby bool

+ Roster RosterSummary

+ State ViewerState

+ type ModerationPermissions struct

+ CanBan bool

+ CanSilence bool

+ func (m ModerationPermissions) Any() bool

type Permissions

+ Moderation ModerationPermissions

+ type RestrictedUser struct

+ State ViewerState

+ UserID *commonpb.UserId

+ func (r RestrictedUser) Position() RestrictionPosition

+ type RestrictionPosition struct

+ RestrictedAt time.Time

+ UserID *commonpb.UserId

+ func (p RestrictionPosition) Compare(o RestrictionPosition) int

type Server

+ func (s *Server) BanUser(ctx context.Context, req *chatpb.BanUserRequest) (*chatpb.BanUserResponse, error)

+ func (s *Server) GetRestrictedUsers(ctx context.Context, req *chatpb.GetRestrictedUsersRequest) (*chatpb.GetRestrictedUsersResponse, error)

+ func (s *Server) SilenceUser(ctx context.Context, req *chatpb.SilenceUserRequest) (*chatpb.SilenceUserResponse, error)

+ func (s *Server) UnbanUser(ctx context.Context, req *chatpb.UnbanUserRequest) (*chatpb.UnbanUserResponse, error)

+ func (s *Server) UnsilenceUser(ctx context.Context, req *chatpb.UnsilenceUserRequest) (*chatpb.UnsilenceUserResponse, error)

+ type Silence struct

+ Forever bool

+ Until time.Time

+ func SilenceFromProto(s *chatpb.SilenceState) Silence

+ func (s Silence) Active(now time.Time) bool

+ func (s Silence) Normalize() (Silence, error)

+ func (s Silence) ToProto() *chatpb.SilenceState

type SpeakerStanding

+ Silenced bool

type Store

+ BanUser func(ctx context.Context, chatID *commonpb.ChatId, userID *commonpb.UserId, ...) (BanResult, error)

+ ClearSilence func(ctx context.Context, chatID *commonpb.ChatId, userID *commonpb.UserId) (state ViewerState, changed bool, err error)

+ GetRestrictedUsersPage func(ctx context.Context, chatID *commonpb.ChatId, after *RestrictionPosition, ...) ([]RestrictedUser, error)

+ GetViewerStatesForUsers func(ctx context.Context, chatID *commonpb.ChatId, userIDs []*commonpb.UserId) (map[string]ViewerState, error)

+ SetSilence func(ctx context.Context, chatID *commonpb.ChatId, userID *commonpb.UserId, ...) (state ViewerState, changed bool, err error)

+ UnbanUser func(ctx context.Context, chatID *commonpb.ChatId, userID *commonpb.UserId) (state ViewerState, changed bool, err error)

type ViewerState

+ BannedAt *time.Time

+ RestrictedAt *time.Time

+ Silence *Silence

+ func (v ViewerState) ActiveSilence(now time.Time) *Silence

+ func (v ViewerState) IsBanned() bool

+ func (v ViewerState) IsRestricted() bool

Oct 16, 2026

Changes in this version

+ const DefaultSpeakerAdmissionTTL

+ const MinGroupHoldingsHolders

+ var ErrHoldingsMintMismatch = errors.New("holdings mint differs from the group's")

+ var ErrInvalidGroupHoldings = errors.New("invalid group holdings")

+ var ErrNotGovernedByRules = errors.New("chat is not governed by rules")

+ func GatedMint(c *Chat) (*commonpb.PublicKey, bool)

+ func HoldingsLess(a, b GroupHoldings) bool

+ func ValidateGroupHoldings(h GroupHoldings) error

type AccessOption

+ func WithSpeakerAdmissionTTL(ttl time.Duration) AccessOption

type Chat

+ MinimumSpeakerBalance *MinimumBalance

+ func (c *Chat) ChatRules() ChatRules

+ type ChatRules struct

+ CreatorID *commonpb.UserId

+ IsPrivate bool

+ Rules *chatpb.Rules

+ func (r ChatRules) RuleSet() (RuleSet, bool)

+ type CreationRules struct

+ IsStaffOnly bool

+ MinimumListenerBalance *MinimumBalance

+ MinimumSpeakerBalance *MinimumBalance

+ type GroupHoldings struct

+ AsOf time.Time

+ ChatID *commonpb.ChatId

+ HolderCount uint64

+ Mint *commonpb.PublicKey

+ Quarks uint64

+ func (h GroupHoldings) Clone() GroupHoldings

+ func (h GroupHoldings) Listed() bool

+ func (h GroupHoldings) ToProto() *chatpb.HoldingsSummary

+ type HoldingsRefresh struct

+ Attempts uint32

+ ChatID *commonpb.ChatId

+ DueAt time.Time

+ Mint *commonpb.PublicKey

+ type HoldingsWorker struct

+ func NewHoldingsWorker(log *zap.Logger, chats Store, balances *balance.Client, ...) *HoldingsWorker

+ func (w *HoldingsWorker) Process(runtimeCtx context.Context) (int, error)

+ func (w *HoldingsWorker) Start(ctx context.Context, interval time.Duration) error

+ type HoldingsWorkerOption func(*HoldingsWorker)

+ func WithHoldingsRefreshInterval(interval time.Duration) HoldingsWorkerOption

+ func WithHoldingsRosterPageSize(n int) HoldingsWorkerOption

+ func WithHoldingsWorkerBackoff(base, maxDelay time.Duration) HoldingsWorkerOption

+ func WithHoldingsWorkerBatchSize(n int) HoldingsWorkerOption

+ func WithHoldingsWorkerClaimLease(lease time.Duration) HoldingsWorkerOption

+ func WithHoldingsWorkerMaxConcurrency(n int) HoldingsWorkerOption

+ func WithHoldingsWorkerRefreshTimeout(timeout time.Duration) HoldingsWorkerOption

+ type Hydrator struct

+ func NewHydrator(log *zap.Logger, accounts account.Store, blocklist BlocklistReader, ...) *Hydrator

+ func (h *Hydrator) PublicGroupsMetadata(ctx context.Context, chatIDs []*commonpb.ChatId) ([]*chatpb.Metadata, error)

+ type RuleSet struct

+ func NewRuleSet(rules *chatpb.Rules, creatorID *commonpb.UserId) RuleSet

type Store

+ ClaimHoldingsRefresh func(ctx context.Context, chatID *commonpb.ChatId, asOf, until time.Time) (bool, error)

+ EnqueueHoldingsRefresh func(ctx context.Context, chatID *commonpb.ChatId, mint *commonpb.PublicKey, ...) (changed bool, err error)

+ GetDueHoldingsRefreshes func(ctx context.Context, asOf time.Time, limit int) ([]HoldingsRefresh, error)

+ GetGroupHoldings func(ctx context.Context, chatIDs []*commonpb.ChatId) (map[string]GroupHoldings, error)

+ GetTopGroupsByHoldings func(ctx context.Context, mint *commonpb.PublicKey, limit int) ([]GroupHoldings, error)

+ PutGroupHoldings func(ctx context.Context, h GroupHoldings) (changed bool, err error)

+ RescheduleHoldingsRefresh func(ctx context.Context, chatID *commonpb.ChatId, dueAt time.Time, attempts uint32) error

+ type SystemMessenger interface

+ SendUserJoined func(ctx context.Context, chatID *commonpb.ChatId, ...) error

Oct 6, 2026

Changes in this version

+ const ActivityRecordInterval

+ const ActivityRetention

+ const ActivityScoreFullWeightGap

+ const ActivityScoreHalfLife

+ const ActivityScoreMaxLead

+ const MaxDescriptionLength

+ const MaxFeaturedGroups

+ var DefaultLobbyLimits = LobbyLimits

+ var ErrAlreadyMember = errors.New("already a member")

+ var ErrInvalidDescription = errors.New("invalid description")

+ var ErrKeyEnvelopeNotFound = errors.New("key envelope not found")

+ var ErrLobbyFull = errors.New("lobby full")

+ var ErrNotInLobby = errors.New("not in lobby")

+ var ErrTooManyLobbies = errors.New("too many lobbies")

+ func EffectiveActivityScore(score, lastSentAt time.Time) time.Time

+ func NewBlobEncryptedUploadGate(access *Access) blob.EncryptedUploadGate

+ func NextActivityScore(prior, lastSentAt, sentAt time.Time) time.Time

+ func ValidateDescription(description string) error

+ func ValidateFeaturedGroups(chatIDs []*commonpb.ChatId) error

type Access

+ func (a *Access) ListenerStanding(ctx context.Context, chatID *commonpb.ChatId, userID *commonpb.UserId, ...) (ListenerStanding, error)

+ func (a *Access) ListenerStandingWithChat(ctx context.Context, c *Chat, userID *commonpb.UserId, ...) (ListenerStanding, error)

+ func (a *Access) ListenerStandingWithRules(ctx context.Context, chatID *commonpb.ChatId, rules GroupRules, ...) (ListenerStanding, error)

+ func (a *Access) PublicListenerStanding(c *Chat) ListenerStanding

+ func (a *Access) SpeakerStanding(ctx context.Context, chatID *commonpb.ChatId, userID *commonpb.UserId) (SpeakerStanding, error)

type Chat

+ CoverPictureBlobID *blobpb.BlobId

+ Description string

+ IsPrivate bool

+ ProfilePictureBlobID *blobpb.BlobId

+ type Encryption uint8

+ const EncryptionNone

+ const EncryptionOptional

+ const EncryptionRequired

+ type FeaturedGroups struct

+ ChatIDs []*commonpb.ChatId

+ Version uint64

+ func (f FeaturedGroups) Equal(chatIDs []*commonpb.ChatId) bool

type GroupEdit

+ CoverPictureBlobID *blobpb.BlobId

+ Description *string

+ ProfilePictureBlobID *blobpb.BlobId

type GroupRules

+ IsPrivate bool

+ type KeyEnvelope struct

+ Ciphertext []byte

+ Nonce []byte

+ Scheme chatpb.KeyEnvelope_Scheme

+ WrappedBy *commonpb.UserId

+ func KeyEnvelopeFromProto(pb *chatpb.KeyEnvelope, wrappedBy *commonpb.UserId) KeyEnvelope

+ func (e KeyEnvelope) Clone() KeyEnvelope

+ func (e KeyEnvelope) Equal(other KeyEnvelope) bool

+ func (e KeyEnvelope) IsWrappedBy(userID *commonpb.UserId) bool

+ func (e KeyEnvelope) ToProto() *chatpb.KeyEnvelope

+ type ListenerStanding struct

+ CanListen bool

+ CanPreview bool

+ IsMember bool

+ func (s ListenerStanding) Reading(mode messagingpb.ViewMode) Reading

+ type LobbyEntry struct

+ EnteredAt time.Time

+ UserID *commonpb.UserId

+ func (e LobbyEntry) Position() LobbyPosition

+ type LobbyLimits struct

+ LobbiesPerUser int

+ LobbySize int

+ type LobbyPosition struct

+ EnteredAt time.Time

+ UserID *commonpb.UserId

+ func (p LobbyPosition) Compare(o LobbyPosition) int

type Media

+ SetAsChatMedia func(ctx context.Context, ownerID *commonpb.UserId, chatID *commonpb.ChatId, ...) error

type ProfileReader

+ GetLimitedPublicProfilesForRow func(ctx context.Context, userIDs []*commonpb.UserId) (map[string]*profilepb.UserProfile, error)

+ GetUserIDByUsername func(ctx context.Context, username string) (userID *commonpb.UserId, ok bool, err error)

+ type RecentSender struct

+ ActivityScore time.Time

+ LastSentAt time.Time

+ UserID *commonpb.UserId

type Server

+ func (s *Server) AdmitLobbyMember(ctx context.Context, req *chatpb.AdmitLobbyMemberRequest) (*chatpb.AdmitLobbyMemberResponse, error)

+ func (s *Server) DenyLobbyMember(ctx context.Context, req *chatpb.DenyLobbyMemberRequest) (*chatpb.DenyLobbyMemberResponse, error)

+ func (s *Server) EnterLobby(ctx context.Context, req *chatpb.EnterLobbyRequest) (*chatpb.EnterLobbyResponse, error)

+ func (s *Server) GetFeaturedGroups(ctx context.Context, req *chatpb.GetFeaturedGroupsRequest) (*chatpb.GetFeaturedGroupsResponse, error)

+ func (s *Server) GetKeyEnvelope(ctx context.Context, req *chatpb.GetKeyEnvelopeRequest) (*chatpb.GetKeyEnvelopeResponse, error)

+ func (s *Server) GetLobbyMembers(ctx context.Context, req *chatpb.GetLobbyMembersRequest) (*chatpb.GetLobbyMembersResponse, error)

+ func (s *Server) GetMentionSuggestions(ctx context.Context, req *chatpb.GetMentionSuggestionsRequest) (*chatpb.GetMentionSuggestionsResponse, error)

+ func (s *Server) LeaveLobby(ctx context.Context, req *chatpb.LeaveLobbyRequest) (*chatpb.LeaveLobbyResponse, error)

+ func (s *Server) SampleChatters(ctx context.Context, req *chatpb.SampleChattersRequest) (*chatpb.SampleChattersResponse, error)

+ func (s *Server) SetFeaturedGroups(ctx context.Context, req *chatpb.SetFeaturedGroupsRequest) (*chatpb.SetFeaturedGroupsResponse, error)

+ func (s *Server) SetKeyEnvelope(ctx context.Context, req *chatpb.SetKeyEnvelopeRequest) (*chatpb.SetKeyEnvelopeResponse, error)

+ type ServerOption func(*Server)

+ func WithLobbyLimits(limits LobbyLimits) ServerOption

+ type SpeakerStanding struct

+ CanSpeak bool

+ Encryption Encryption

+ Scheme messagingpb.EncryptedContent_Scheme

type Store

+ AdmitFromLobby func(ctx context.Context, chatID *commonpb.ChatId, userID *commonpb.UserId, ...) (changed bool, roster RosterSummary, err error)

+ EnterLobby func(ctx context.Context, chatID *commonpb.ChatId, userID *commonpb.UserId, ...) (entry LobbyEntry, changed bool, err error)

+ GetActiveSenders func(ctx context.Context, chatID *commonpb.ChatId, limit int) ([]RecentSender, error)

+ GetFeaturedGroups func(ctx context.Context, userID *commonpb.UserId) (FeaturedGroups, error)

+ GetGroupChatsByID func(ctx context.Context, chatIDs []*commonpb.ChatId) (map[string]*Chat, error)

+ GetGroupMembersByID func(ctx context.Context, chatID *commonpb.ChatId, userIDs []*commonpb.UserId) (map[string]GroupMember, error)

+ GetKeyEnvelope func(ctx context.Context, chatID *commonpb.ChatId, userID *commonpb.UserId) (KeyEnvelope, error)

+ GetLastSentAt func(ctx context.Context, chatID *commonpb.ChatId, userID *commonpb.UserId) (lastSentAt time.Time, ok bool, err error)

+ GetLobbyEntries func(ctx context.Context, userID *commonpb.UserId, chatIDs []*commonpb.ChatId) (map[string]LobbyEntry, error)

+ GetLobbyPage func(ctx context.Context, chatID *commonpb.ChatId, after *LobbyPosition, limit int) ([]LobbyEntry, error)

+ GetRecentSenders func(ctx context.Context, chatID *commonpb.ChatId, limit int) ([]RecentSender, error)

+ LeaveLobby func(ctx context.Context, chatID *commonpb.ChatId, userID *commonpb.UserId) (changed bool, err error)

+ RecordSend func(ctx context.Context, chatID *commonpb.ChatId, userID *commonpb.UserId, ...) (recorded bool, err error)

+ SetFeaturedGroups func(ctx context.Context, userID *commonpb.UserId, chatIDs []*commonpb.ChatId) (featured FeaturedGroups, changed bool, err error)

+ SetKeyEnvelope func(ctx context.Context, chatID *commonpb.ChatId, userID *commonpb.UserId, ...) (KeyEnvelope, error)

Sep 30, 2026

Changes in this version

type Chat

+ IsCreatorOnlySpeaker bool

+ func (c *Chat) GroupRules() GroupRules

+ type FeedExclusions struct

+ func NewFeedExclusions(userIDs []*commonpb.UserId) FeedExclusions

+ func (e FeedExclusions) For(c *Chat) []*commonpb.UserId

+ type GroupRules struct

+ CreatorID *commonpb.UserId

+ Rules *chatpb.Rules

type RuleEvaluator

+ func (e *RuleEvaluator) RulesOf(c *Chat) *chatpb.Rules

Sep 25, 2026

Changes in this version

+ var ErrMuteUntilOutOfRange = errors.New("mute until is out of range")

+ var MaxMuteUntil = time.Date(9999, 12, 31, 23, 59, 59, 0, time.UTC)

+ func NewBlobDMMembership(store Store) blob.DMMembership

+ func SortRoster(members []GroupMember)

type Access

+ func (a *Access) IsMemberWithChat(ctx context.Context, c *Chat, userID *commonpb.UserId) (bool, error)

+ func (a *Access) PublicStanding(c *Chat) Standing

+ func (a *Access) StandingWithChat(ctx context.Context, c *Chat, userID *commonpb.UserId, ...) (Standing, error)

type Chat

+ func (c *Chat) IsCreator(userID *commonpb.UserId) bool

+ func (c *Chat) PermissionsFor(userID *commonpb.UserId, isMember bool) Permissions

+ type GroupEdit struct

+ PictureBlobID *blobpb.BlobId

+ Title *string

+ func (e GroupEdit) IsEmpty() bool

+ type GroupMember struct

+ JoinedAt time.Time

+ UserID *commonpb.UserId

+ Version uint64

+ func (m GroupMember) Position() RosterPosition

+ type MembersPage struct

+ Next *commonpb.UserId

+ Users []*commonpb.UserId

+ type Mute struct

+ Forever bool

+ Until time.Time

+ func MuteFromProto(m *chatpb.MuteState) Mute

+ func (m Mute) Active(now time.Time) bool

+ func (m Mute) Normalize() (Mute, error)

+ func (m Mute) ToProto() *chatpb.MuteState

+ type Permissions struct

+ CanEdit bool

+ func (p Permissions) ToProto() *chatpb.ViewerState_Permissions

+ type RosterPosition struct

+ JoinedAt time.Time

+ UserID *commonpb.UserId

+ func (p RosterPosition) Compare(o RosterPosition) int

type Server

+ func (s *Server) EditChat(ctx context.Context, req *chatpb.EditChatRequest) (*chatpb.EditChatResponse, error)

+ func (s *Server) GetRoster(ctx context.Context, req *chatpb.GetRosterRequest) (*chatpb.GetRosterResponse, error)

+ func (s *Server) MuteChat(ctx context.Context, req *chatpb.MuteChatRequest) (*chatpb.MuteChatResponse, error)

+ func (s *Server) UnmuteChat(ctx context.Context, req *chatpb.UnmuteChatRequest) (*chatpb.UnmuteChatResponse, error)

type Store

+ ClearMute func(ctx context.Context, chatID *commonpb.ChatId, userID *commonpb.UserId) (state ViewerState, changed bool, err error)

+ EditGroup func(ctx context.Context, chatID *commonpb.ChatId, edit GroupEdit) error

+ GetGroupMemberRecords func(ctx context.Context, userID *commonpb.UserId, chatIDs []*commonpb.ChatId) (map[string]GroupMember, error)

+ GetGroupMembersPage func(ctx context.Context, chatID *commonpb.ChatId, after *commonpb.UserId, ...) (MembersPage, error)

+ GetGroupRoster func(ctx context.Context, chatID *commonpb.ChatId) (RosterSummary, []GroupMember, error)

+ GetGroupRosterPage func(ctx context.Context, chatID *commonpb.ChatId, after *RosterPosition, limit int) ([]GroupMember, error)

+ GetMutedCount func(ctx context.Context, chatID *commonpb.ChatId) (uint64, error)

+ GetMutedUsers func(ctx context.Context, chatID *commonpb.ChatId, now time.Time, limit int) ([]*commonpb.UserId, error)

+ GetMutedUsersPage func(ctx context.Context, chatID *commonpb.ChatId, now time.Time, ...) ([]*commonpb.UserId, error)

+ GetViewerStates func(ctx context.Context, userID *commonpb.UserId, chatIDs []*commonpb.ChatId) (map[string]ViewerState, error)

+ SetMute func(ctx context.Context, chatID *commonpb.ChatId, userID *commonpb.UserId, ...) (state ViewerState, changed bool, err error)

+ type ViewerState struct

+ Mute *Mute

+ Version uint64

+ func (v ViewerState) ActiveMute(now time.Time) *Mute

+ func (v ViewerState) Clone() ViewerState

+ func (v ViewerState) ToProto(permissions Permissions) *chatpb.ViewerState

Sep 17, 2026

Changes in this version

+ const IdempotencyKeySize

+ func MustDeriveGroupChatID(creatorID *commonpb.UserId, key *chatpb.IdempotencyKey) *commonpb.ChatId

type Access

+ func (a *Access) Standing(ctx context.Context, chatID *commonpb.ChatId, userID *commonpb.UserId, ...) (Standing, error)

+ type Reading uint8

+ const ReadingDenied

+ const ReadingFull

+ const ReadingRedacted

type Standing

+ CanPreview bool

+ func (s Standing) Reading(mode messagingpb.ViewMode) Reading

Sep 16, 2026

Changes in this version

+ const DefaultListenerAdmissionTTL

+ var ErrGroupFeedTooLarge = errors.New("group feed exceeds the token window")

+ var ErrInvalidRules = errors.New("invalid chat rules")

+ type Access struct

+ func NewAccess(chats Store, rules *RuleEvaluator, opts ...AccessOption) *Access

+ func (a *Access) CanListen(ctx context.Context, chatID *commonpb.ChatId, userID *commonpb.UserId) (bool, error)

+ func (a *Access) CanListenWithRules(ctx context.Context, chatID *commonpb.ChatId, rules *chatpb.Rules, ...) (bool, error)

+ func (a *Access) CanSpeak(ctx context.Context, chatID *commonpb.ChatId, userID *commonpb.UserId) (bool, error)

+ func (a *Access) IsMember(ctx context.Context, chatID *commonpb.ChatId, userID *commonpb.UserId) (bool, error)

+ func (a *Access) Rules() *RuleEvaluator

+ func (a *Access) StandingWithRules(ctx context.Context, chatID *commonpb.ChatId, rules *chatpb.Rules, ...) (Standing, error)

+ type AccessOption func(*Access)

+ func WithListenerAdmissionTTL(ttl time.Duration) AccessOption

type Chat

+ CreatorID *commonpb.UserId

+ IsStaffOnly bool

+ MinimumListenerBalance *MinimumBalance

+ PictureBlobID *blobpb.BlobId

+ RosterSummary RosterSummary

+ func (c *Chat) Rules() *chatpb.Rules

+ type ChatEventPublisher interface

+ OnEvent func(chatID *commonpb.ChatId, e *eventpb.ChatEvent)

+ type GroupMembership struct

+ ChatID *commonpb.ChatId

+ Joined bool

+ Version uint64

+ type Media interface

+ ResolveRenditions func(ctx context.Context, ids []*blobpb.BlobId) (map[string][]*blobpb.Rendition, error)

+ SetAsChatPicture func(ctx context.Context, ownerID *commonpb.UserId, chatID *commonpb.ChatId, ...) error

+ type MinimumBalance struct

+ Currency string

+ Mints []*commonpb.PublicKey

+ NativeAmount float64

+ func RulesFromProto(rules *chatpb.Rules) (isStaffOnly bool, minimumListenerBalance *MinimumBalance, err error)

+ func (m *MinimumBalance) Clone() *MinimumBalance

+ func (m *MinimumBalance) ToProto() *chatpb.MinimumBalanceRequirement

+ type RosterSummary struct

+ MemberCount uint64

+ Version uint64

+ func (r RosterSummary) ToProto() *chatpb.RosterSummary

+ type RuleEvaluator struct

+ func NewRuleEvaluator(accounts account.Store, balances *balance.Client, chats Store) *RuleEvaluator

+ func (e *RuleEvaluator) CanListen(ctx context.Context, chatID *commonpb.ChatId, userID *commonpb.UserId) (bool, error)

+ func (e *RuleEvaluator) CanListenWithRules(ctx context.Context, rules *chatpb.Rules, userID *commonpb.UserId) (bool, error)

+ func (e *RuleEvaluator) CanSpeak(ctx context.Context, chatID *commonpb.ChatId, userID *commonpb.UserId) (bool, error)

+ func (e *RuleEvaluator) CanSpeakWithRules(ctx context.Context, rules *chatpb.Rules, userID *commonpb.UserId) (bool, error)

type Server

+ func (s *Server) GetGroupChatFeed(ctx context.Context, req *chatpb.GetGroupChatFeedRequest) (*chatpb.GetGroupChatFeedResponse, error)

+ func (s *Server) JoinChat(ctx context.Context, req *chatpb.JoinChatRequest) (*chatpb.JoinChatResponse, error)

+ func (s *Server) LeaveChat(ctx context.Context, req *chatpb.LeaveChatRequest) (*chatpb.LeaveChatResponse, error)

+ func (s *Server) StartChat(ctx context.Context, req *chatpb.StartChatRequest) (*chatpb.StartChatResponse, error)

+ type Standing struct

+ CanListen bool

+ IsMember bool

type Store

+ GetGroupChatsForUser func(ctx context.Context, userID *commonpb.UserId) ([]*Chat, error)

+ GetGroupChatsForUserByIDs func(ctx context.Context, userID *commonpb.UserId, chatIDs []*commonpb.ChatId) ([]*Chat, error)

+ GetGroupMembershipsForUser func(ctx context.Context, userID *commonpb.UserId) ([]GroupMembership, error)

+ GetGroupRosterSummaries func(ctx context.Context, chatIDs []*commonpb.ChatId) (map[string]RosterSummary, error)

+ GetGroupRosterSummary func(ctx context.Context, chatID *commonpb.ChatId) (RosterSummary, error)

+ GetGroupRules func(ctx context.Context, chatID *commonpb.ChatId) (*chatpb.Rules, error)

+ SetGroupPicture func(ctx context.Context, chatID *commonpb.ChatId, blobID *blobpb.BlobId) error

+ type UserEventPublisher interface

+ OnEvent func(userID *commonpb.UserId, e *eventpb.Event)

Sep 10, 2026

Changes in this version

type Store

+ GetGroupChatIDsForUser func(ctx context.Context, userID *commonpb.UserId) ([]*commonpb.ChatId, error)

Aug 20, 2026

Changes in this version

+ const DmChatIDSize

+ const GroupChatIDSize

+ const MaxGroupChatCreationMembers

+ var ErrNoMembers = errors.New("chat must have at least one member")

+ var ErrTooManyMembers = errors.New("too many initial members")

+ func IsGroupChatID(chatID *commonpb.ChatId) bool

+ func MustGenerateGroupChatID() *commonpb.ChatId

type Chat

+ Title string

type Store

+ AddGroupMembers func(ctx context.Context, chatID *commonpb.ChatId, userIDs []*commonpb.UserId) error

+ RemoveGroupMember func(ctx context.Context, chatID *commonpb.ChatId, userID *commonpb.UserId) error

Aug 6, 2026

Changes in this version

type ProfileReader

+ GetPublicProfiles func(ctx context.Context, userIDs []*commonpb.UserId) (map[string]*profilepb.UserProfile, error)

Jul 23, 2026

Changes in this version

+ func IsDmChatType(chatType chatpb.ChatType) bool

+ type BlocklistReader interface

+ GetBlocked func(ctx context.Context, ownerID *commonpb.UserId, candidateIDs []*commonpb.UserId) (map[string]bool, error)

Jul 21, 2026

Changes in this version

+ func DeriveDmChatType(chatID *commonpb.ChatId, members []*commonpb.UserId) chatpb.ChatType

Jul 17, 2026

Changes in this version

type ProfileReader

+ GetDisplayNames func(ctx context.Context, userIDs []*commonpb.UserId) (map[string]string, error)

+ GetProfilePictures func(ctx context.Context, userIDs []*commonpb.UserId) (map[string]*blobpb.Media, error)

Jun 30, 2026

Changes in this version

type MessagingReader

+ LatestEventSequences func(ctx context.Context, chatIDs []*commonpb.ChatId) (map[string]uint64, error)

Jun 15, 2026

Changes in this version

+ type ProfileReader interface

+ GetPhoneNumbers func(ctx context.Context, userIDs []*commonpb.UserId) (map[string]*phonepb.PhoneNumber, error)

Jun 10, 2026

Changes in this version

+ type PointerRef struct

+ ChatID *commonpb.ChatId

+ Members []*commonpb.UserId

Jun 2, 2026

Changes in this version

+ const ChatIDSize

+ var ErrChatExists = errors.New("chat already exists")

+ var ErrChatNotFound = errors.New("chat not found")

+ func MustDeriveDmChatID(a, b *commonpb.UserId) *commonpb.ChatId

+ type Chat struct

+ ID *commonpb.ChatId

+ LastActivity time.Time

+ LastMessageID *messagingpb.MessageId

+ Members []*commonpb.UserId

+ Type chatpb.Metadata_ChatType

+ func (c *Chat) Clone() *Chat

+ func (c *Chat) HasMember(userID *commonpb.UserId) bool

+ func (c *Chat) ToProto() *chatpb.Metadata

+ type DmFeedCursor struct

+ ChatID *commonpb.ChatId

+ LastActivity time.Time

+ type MessageRef struct

+ ChatID *commonpb.ChatId

+ MessageID *messagingpb.MessageId

+ type MessagingReader interface

+ LastMessages func(ctx context.Context, refs []MessageRef) (map[string]*messagingpb.Message, error)

+ Pointers func(ctx context.Context, chatIDs []*commonpb.ChatId) (map[string][]*messagingpb.Pointer, error)

+ type Server struct

+ func NewServer(log *zap.Logger, authz auth.Authorizer, chats Store, messaging MessagingReader) *Server

+ func (s *Server) GetChat(ctx context.Context, req *chatpb.GetChatRequest) (*chatpb.GetChatResponse, error)

+ func (s *Server) GetDmChatFeed(ctx context.Context, req *chatpb.GetDmChatFeedRequest) (*chatpb.GetDmChatFeedResponse, error)

+ type Store interface

+ AdvanceLastMessage func(ctx context.Context, chatID *commonpb.ChatId, messageID *messagingpb.MessageId, ...) (bool, error)

+ GetChatByID func(ctx context.Context, chatID *commonpb.ChatId) (*Chat, error)

+ GetDmFeedPage func(ctx context.Context, userID *commonpb.UserId, snapshot time.Time, ...) ([]*Chat, error)

+ GetMembers func(ctx context.Context, chatID *commonpb.ChatId) ([]*commonpb.UserId, error)

+ IsMember func(ctx context.Context, chatID *commonpb.ChatId, userID *commonpb.UserId) (bool, error)

+ PutChat func(ctx context.Context, chat *Chat) error