internal

Documentation

Index

• Constants
• func DeviceListCatchup(ctx context.Context, keyAPI keyapi.KeyInternalAPI, ...) (newPos types.StreamPosition, hasNew bool, err error)
• func DeviceOTKCounts(ctx context.Context, keyAPI keyapi.KeyInternalAPI, userID, deviceID string, ...) error
• func TrackChangedUsers(ctx context.Context, rsAPI roomserverAPI.RoomserverInternalAPI, userID string, ...) (changed, left []string, err error)

Constants

const DeviceListLogName = "dl"

Functions

func DeviceListCatchup

func DeviceListCatchup(
	ctx context.Context, keyAPI keyapi.KeyInternalAPI, rsAPI roomserverAPI.RoomserverInternalAPI,
	userID string, res *types.Response, from, to types.StreamPosition,
) (newPos types.StreamPosition, hasNew bool, err error)

DeviceListCatchup fills in the given response for the given user ID to bring it up-to-date with device lists. hasNew=true if the response was filled in, else false if there are no new device list changes because there is nothing to catch up on. The response MUST be already filled in with join/leave information.

func DeviceOTKCounts

func DeviceOTKCounts(ctx context.Context, keyAPI keyapi.KeyInternalAPI, userID, deviceID string, res *types.Response) error

DeviceOTKCounts adds one-time key counts to the /sync response

func TrackChangedUsers

func TrackChangedUsers(
	ctx context.Context, rsAPI roomserverAPI.RoomserverInternalAPI, userID string, newlyJoinedRooms, newlyLeftRooms []string,
) (changed, left []string, err error)

TrackChangedUsers calculates the values of device_lists.changed|left in the /sync response.