sync3

Jan 22, 2024

Changes in this version

type RoomConnMetadata

+ func (r *RoomConnMetadata) SameRoomAvatar(next *RoomConnMetadata) bool

Nov 24, 2023

Changes in this version

type ConnMap

+ func (m *ConnMap) CloseConnsForUsers(userIDs []string) (closed int)

type Dispatcher

+ func (d *Dispatcher) UnregisterBulk(userIDs []string) []string

Nov 9, 2023

Changes in this version

type Conn

+ func (c *Conn) SetCancelCallback(cancel context.CancelFunc)

type ConnHandler

+ SetCancelCallback func(cancel context.CancelFunc)

type JoinedRoomsTracker

+ func (t *JoinedRoomsTracker) ReloadMembershipsForRoom(roomID string, joined, invited []string)

Oct 11, 2023

Changes in this version

type Dispatcher

+ func (d *Dispatcher) OnInvalidateRoom(ctx context.Context, roomID string)

type Receiver

+ OnInvalidateRoom func(ctx context.Context, roomID string)

type Room

+ Heroes []internal.Hero

type RoomSubscription

+ Heroes *bool

+ func (rs RoomSubscription) IncludeHeroes() bool

Aug 23, 2023

Changes in this version

type Dispatcher

+ func (d *Dispatcher) IsUserInvited(userID, roomID string) bool

type JoinedRoomsTracker

+ func (t *JoinedRoomsTracker) IsUserInvited(userID, roomID string) bool

type Request

+ func (r *Request) ListKeys() []string

type Room

+ Timestamp uint64

Aug 2, 2023

Changes in this version

+ const DeletedAvatar

+ type AvatarChange string

+ const UnchangedAvatar

+ func NewAvatarChange(avatar string) AvatarChange

+ func (a *AvatarChange) UnmarshalJSON(data []byte) error

+ func (a AvatarChange) MarshalJSON() ([]byte, error)

type ConnHandler

+ PublishEventsUpTo func(roomID string, nid int64)

type ConnMap

+ func (m *ConnMap) ClearUpdateQueues(userID, roomID string, nid int64)

+ func (m *ConnMap) UpdateMetrics()

type Room

+ AvatarChange AvatarChange

type RoomDelta

+ RoomAvatarChanged bool

Jun 19, 2023

Changes in this version

+ var SpamProtectionInterval = time.Second

type ConnID

+ CID string

+ UserID string

type ConnMap

+ func (m *ConnMap) CloseConnsForDevice(userID, deviceID string)

+ func (m *ConnMap) Conns(userID, deviceID string) []*Conn

type Dispatcher

+ func (d *Dispatcher) ReceiverForUser(userID string) Receiver

type InternalRequestLists

+ func (s *InternalRequestLists) ListKeys() []string

type Request

+ ConnID string

+ func (r *Request) Validate() error

type RequestList

+ BumpEventTypes []string

type RoomConnMetadata

+ LastInterestedEventTimestamps map[string]uint64

+ func (r *RoomConnMetadata) GetLastInterestedEventTimestamp(listKey string) uint64

Apr 27, 2023

Changes in this version

type Dispatcher

+ func (d *Dispatcher) OnNewEvent(ctx context.Context, roomID string, event json.RawMessage, pos int64)

type InternalRequestLists

+ func (s *InternalRequestLists) ListsByVisibleRoomIDs(muxedReqLists map[string]RequestList) map[string][]string

type Request

+ BumpEventTypes []string

Feb 24, 2023

Changes in this version

type Dispatcher

+ func (d *Dispatcher) OnReceipt(ctx context.Context, receipt internal.Receipt)

type InternalRequestLists

+ func (s *InternalRequestLists) ReadOnlyRoom(roomID string) *RoomConnMetadata

type Receiver

+ OnReceipt func(ctx context.Context, receipt internal.Receipt)

type Response

+ func (r *Response) RoomIDsToTimelineEventIDs() map[string][]string

type RoomDelta

+ HighlightCountChanged bool

+ NotificationCountChanged bool

type RoomFinder

+ ReadOnlyRoom func(roomID string) *RoomConnMetadata

Feb 1, 2023

Changes in this version

type RequestList

+ Deleted bool

+ func (rl *RequestList) TimelineLimitChanged(next *RequestList) bool

type RoomDelta

+ HighlightCountDecreased bool

+ NotificationCountDecreased bool

type RoomListDelta

+ ListKey string

type RoomSubscription

+ func (rs RoomSubscription) RequiredStateChanged(other RoomSubscription) bool

Jan 12, 2023

Changes in this version

type Conn

+ func (c *Conn) OnUpdate(update caches.Update)

type ConnHandler

+ OnUpdate func(update caches.Update)

Dec 16, 2022

Changes in this version

+ const DispatcherAllUsers

+ const OpDelete

+ const OpInsert

+ const OpInvalidate

+ const OpSync

+ var DefaultTimelineLimit = int64(20)

+ var DefaultTimeoutMSecs = 10 * 1000

+ var SortBy = []string

+ var SortByHighlightCount = "by_highlight_count"

+ var SortByName = "by_name"

+ var SortByNotificationCount = "by_notification_count"

+ var SortByNotificationLevel = "by_notification_level"

+ var SortByRecency = "by_recency"

+ var StateKeyLazy = "$LAZY"

+ var StateKeyMe = "$ME"

+ var Wildcard = "*"

+ type Conn struct

+ ConnID ConnID

+ func NewConn(connID ConnID, h ConnHandler) *Conn

+ func (c *Conn) Alive() bool

+ func (c *Conn) OnIncomingRequest(ctx context.Context, req *Request) (resp *Response, herr *internal.HandlerError)

+ func (c *Conn) UserID() string

+ type ConnHandler interface

+ Alive func() bool

+ Destroy func()

+ OnIncomingRequest func(ctx context.Context, cid ConnID, req *Request, isInitial bool) (*Response, error)

+ UserID func() string

+ type ConnID struct

+ DeviceID string

+ func (c *ConnID) String() string

+ type ConnMap struct

+ func NewConnMap() *ConnMap

+ func (m *ConnMap) CloseConn(connID ConnID)

+ func (m *ConnMap) Conn(cid ConnID) *Conn

+ func (m *ConnMap) CreateConn(cid ConnID, newConnHandler func() ConnHandler) (*Conn, bool)

+ func (m *ConnMap) Len() int

+ func (m *ConnMap) Teardown()

+ type Dispatcher struct

+ func NewDispatcher() *Dispatcher

+ func (d *Dispatcher) IsUserJoined(userID, roomID string) bool

+ func (d *Dispatcher) OnEphemeralEvent(roomID string, ephEvent json.RawMessage)

+ func (d *Dispatcher) OnNewEvents(roomID string, events []json.RawMessage, latestPos int64)

+ func (d *Dispatcher) OnNewInitialRoomState(roomID string, state []json.RawMessage)

+ func (d *Dispatcher) Register(userID string, r Receiver) error

+ func (d *Dispatcher) Startup(roomToJoinedUsers map[string][]string) error

+ func (d *Dispatcher) Unregister(userID string)

+ type FilteredSortableRooms struct

+ func NewFilteredSortableRooms(finder RoomFinder, roomIDs []string, filter *RequestFilters) *FilteredSortableRooms

+ func (f *FilteredSortableRooms) Add(roomID string) bool

+ type InternalRequestLists struct

+ func NewInternalRequestLists() *InternalRequestLists

+ func (s *InternalRequestLists) AssignList(index int, filters *RequestFilters, sort []string, ...) (*FilteredSortableRooms, bool)

+ func (s *InternalRequestLists) Count(index int) int

+ func (s *InternalRequestLists) DeleteList(index int)

+ func (s *InternalRequestLists) Get(listIndex int) *FilteredSortableRooms

+ func (s *InternalRequestLists) Len() int

+ func (s *InternalRequestLists) RemoveRoom(roomID string)

+ func (s *InternalRequestLists) Room(roomID string) *RoomConnMetadata

+ func (s *InternalRequestLists) SetRoom(r RoomConnMetadata) (delta RoomDelta)

+ type JoinedRoomsTracker struct

+ func NewJoinedRoomsTracker() *JoinedRoomsTracker

+ func (t *JoinedRoomsTracker) IsUserJoined(userID, roomID string) bool

+ func (t *JoinedRoomsTracker) JoinedRoomsForUser(userID string) []string

+ func (t *JoinedRoomsTracker) JoinedUsersForRoom(roomID string, filter func(userID string) bool) (matchedUserIDs []string, joinCount int)

+ func (t *JoinedRoomsTracker) NumInvitedUsersForRoom(roomID string) int

+ func (t *JoinedRoomsTracker) Startup(roomToJoinedUsers map[string][]string)

+ func (t *JoinedRoomsTracker) UserJoinedRoom(userID, roomID string) bool

+ func (t *JoinedRoomsTracker) UserLeftRoom(userID, roomID string)

+ func (t *JoinedRoomsTracker) UsersInvitedToRoom(userIDs []string, roomID string)

+ func (t *JoinedRoomsTracker) UsersJoinedRoom(userIDs []string, roomID string) bool

+ type List interface

+ Add func(roomID string) bool

+ Get func(index int) string

+ IndexOf func(roomID string) (int, bool)

+ Len func() int64

+ Remove func(roomID string) int

+ Sort func(sortBy []string) error

+ type ListOp uint8

+ var ListOpAdd ListOp = 1

+ var ListOpChange ListOp = 3

+ var ListOpDel ListOp = 2

+ type OverwriteVal bool

+ var DoNotOverwrite OverwriteVal = false

+ var Overwrite OverwriteVal = true

+ type Receiver interface

+ OnEphemeralEvent func(roomID string, ephEvent json.RawMessage)

+ OnNewEvent func(event *caches.EventData)

+ OnRegistered func(latestPos int64) error

+ type Request struct

+ Extensions extensions.Request

+ Lists []RequestList

+ RoomSubscriptions map[string]RoomSubscription

+ TxnID string

+ UnsubscribeRooms []string

+ func (r *Request) ApplyDelta(nextReq *Request) (result *Request, delta *RequestDelta)

+ func (r *Request) GetTimelineLimit(listIndex int, roomID string) int64

+ func (r *Request) Same(other *Request) bool

+ func (r *Request) SetPos(pos int64)

+ func (r *Request) SetTimeoutMSecs(timeout int)

+ func (r *Request) TimeoutMSecs() int

+ type RequestDelta struct

+ Lists []RequestListDelta

+ Subs []string

+ Unsubs []string

+ type RequestFilters struct

+ IsDM *bool

+ IsEncrypted *bool

+ IsInvite *bool

+ IsTombstoned *bool

+ NotRoomTypes []*string

+ NotTags []string

+ RoomNameFilter string

+ RoomTypes []*string

+ Spaces []string

+ Tags []string

+ func (rf *RequestFilters) Include(r *RoomConnMetadata, finder RoomFinder) bool

+ type RequestList struct

+ Filters *RequestFilters

+ Ranges SliceRanges

+ SlowGetAllRooms *bool

+ Sort []string

+ func (rl *RequestList) CalculateMoveIndexes(fromIndex, toIndex int) (fromTos [][2]int)

+ func (rl *RequestList) FiltersChanged(next *RequestList) bool

+ func (rl *RequestList) ShouldGetAllRooms() bool

+ func (rl *RequestList) SortOrderChanged(next *RequestList) bool

+ func (rl *RequestList) WriteDeleteOp(deletedIndex int) *ResponseOpSingle

+ func (rl *RequestList) WriteInsertOp(insertedIndex int, roomID string) *ResponseOpSingle

+ func (rl *RequestList) WriteSwapOp(roomID string, fromIndex, toIndex int) []ResponseOp

+ type RequestListDelta struct

+ Curr *RequestList

+ Prev *RequestList

+ type Response struct

+ Extensions extensions.Response

+ Lists []ResponseList

+ Pos string

+ Rooms map[string]Room

+ Session string

+ TxnID string

+ func (r *Response) ListOps() int

+ func (r *Response) PosInt() int64

+ func (r *Response) UnmarshalJSON(b []byte) error

+ type ResponseList struct

+ Count int

+ Ops []ResponseOp

+ type ResponseOp interface

+ IncludedRoomIDs func() []string

+ Op func() string

+ func CalculateListOps(reqList *RequestList, list List, roomID string, listOp ListOp) (ops []ResponseOp, subs []string)

+ type ResponseOpRange struct

+ Operation string

+ Range []int64

+ RoomIDs []string

+ func (r *ResponseOpRange) IncludedRoomIDs() []string

+ func (r *ResponseOpRange) Op() string

+ type ResponseOpSingle struct

+ Index *int

+ Operation string

+ RoomID string

+ func (r *ResponseOpSingle) IncludedRoomIDs() []string

+ func (r *ResponseOpSingle) Op() string

+ type Room struct

+ HighlightCount int64

+ Initial bool

+ InviteState []json.RawMessage

+ InvitedCount int

+ IsDM bool

+ JoinedCount int

+ Name string

+ NotificationCount int64

+ NumLive int

+ PrevBatch string

+ RequiredState []json.RawMessage

+ Timeline []json.RawMessage

+ type RoomConnMetadata struct

+ type RoomDelta struct

+ InviteCountChanged bool

+ JoinCountChanged bool

+ Lists []RoomListDelta

+ RoomNameChanged bool

+ type RoomFinder interface

+ Room func(roomID string) *RoomConnMetadata

+ type RoomListDelta struct

+ ListIndex int

+ Op ListOp

+ type RoomSubscription struct

+ IncludeOldRooms *RoomSubscription

+ RequiredState [][2]string

+ TimelineLimit int64

+ func (rs RoomSubscription) Combine(other RoomSubscription) RoomSubscription

+ func (rs RoomSubscription) LazyLoadMembers() bool

+ func (rs RoomSubscription) RequiredStateMap(userID string) *internal.RequiredStateMap

+ type SliceRanges [][2]int64

+ func (r SliceRanges) ClosestInDirection(i int64, towardsZero bool) (closestIndex int64)

+ func (r SliceRanges) Delta(next SliceRanges) (added SliceRanges, removed SliceRanges, same SliceRanges)

+ func (r SliceRanges) Inside(i int64) ([2]int64, bool)

+ func (r SliceRanges) SliceInto(slice Subslicer) []Subslicer

+ func (r SliceRanges) Valid() bool

+ type SortableRooms struct

+ func NewSortableRooms(finder RoomFinder, rooms []string) *SortableRooms

+ func (s *SortableRooms) Add(roomID string) bool

+ func (s *SortableRooms) Get(index int) string

+ func (s *SortableRooms) IndexOf(roomID string) (int, bool)

+ func (s *SortableRooms) Len() int64

+ func (s *SortableRooms) Remove(roomID string) int

+ func (s *SortableRooms) RoomIDs() []string

+ func (s *SortableRooms) Sort(sortBy []string) error

+ func (s *SortableRooms) Subslice(i, j int64) Subslicer

+ type Subslicer interface

+ Len func() int64

+ Subslice func(i, j int64) Subslicer