ExecutedMigrations returns a map with already executed migrations in addition to creating the migrations table, if it doesn't exist.

Failure marks a failure and starts backing off if needed. The next call to BackoffIfRequired will do the right thing after this. It will return the ti

* func (u UsersObjMapper) GetLastSeenAndStatus(appid uint32, id types.Uid) (time.Time, interface{}, error) { return adaptr.GetLastSeenAndStatus(appid

GetAccountData implements GET /user/{userId}/[rooms/{roomid}/]account_data/{type}

GetEventsInTopologicalRange retrieves all of the events on a given ordering using the given extremities and limit. If backwardsOrdering is true, the m

GetFilter looks up the filter associated with a given local user and filter ID and populates the target filter. Otherwise returns an error if no such

GetListener returns a UserStreamListener that can be used to wait for updates for a user. Must be closed. notify for anything before sincePos

GetMemberships implements GET /rooms/{roomId}/members

Query the notary for the server keys for the given server. If `optKeyIDs` is not empty, multiple server keys may be returned (between 1 - len(optKeyID

GetNotifyChannel returns a channel that is closed when there may be an update for the user. sincePos specifies from which point we want to be notified

Opens and returns a room updater, which locks the room and opens a transaction. The GetRoomUpdater must have Commit or Rollback called on it if this d

request -> timestamp is emulating gomatrixserverlib.FetchKeys: https://github.com/matrix-org/gomatrixserverlib/blob/f69539c86ea55d1e2cc76fd8e944e2d82d

GetSyncPosition returns last sync position which the UserStream was notified about

GetThumbnailPath returns the path to a thumbnail given the absolute src path and thumbnail size configuration

GetTypingUsers returns the list of users typing in a room.

GetTypingUsersIfUpdatedAfter returns all users typing in this room with updated == true if the typing sync position of the room is after the given pos

GetUsers loads subscriptions for topic plus loads user.Public

InsertEventInTopology inserts the given event in the room's topology, based on the event's depth. `pos` is the stream position of this event in the ev

IsAfter returns true if ANY position in this token is greater than `other`.

IsInterestedInRoomAlias returns a bool on whether an application service's namespace includes the given room alias

IsReferenced implements types.RoomRecentEventsUpdater

JoinedHostsFromEvents turns a list of state events into a list of joined hosts. This errors if one of the events was invalid. It should be impossible

KeyBackupVersion returns the key backup version specified. If `version` is empty, the latest `keyBackupVersionResponse` is returned. Implements GET /

LoadStateAtSnapshotForStringTuples loads the state for a list of event type and state key pairs at a snapshot. This is used when we only want to load

Login with the auth type, returning an error response on failure. Not all types support login, only m.login.password and m.login.token See https://mat

LoginFromJSONReader performs authentication given a login request body reader and some context. It returns the basic login information and a cleanup f

MSC2836EventRelationships performs an /event_relationships request to a remote server

ManualUpdate invalidates the device list for the given user and fetches the latest and tracks it. Blocks until the device list is synced or the timeou

MatchEvent returns the first matching rule. Returns nil if there was no match rule.

MaxIdleConns returns maximum idle connections to the DB

MaxOpenConns returns maximum open connections to the DB

MaxTopologicalPosition returns the highest topological position for a given room.

New is a wrapper which calls NewWithCleanupPeriod with DefaultCleanupPeriod as argument.

NotifyNewEvents wakes up all waiting goroutines, notifying that events remain in the event queue for this application service worker.

NumWaiting returns the number of goroutines waiting for waiting for updates. Used for metrics and testing.

OnIncomingStateTypeRequest is called when a client makes a rooms/{roomID}/state/{type}/{statekey} request. It will look in current state to see if the

OneTimeKeysCount returns a count of all OTKs for this device.

OwnsNamespaceCoveringUserId returns a bool on whether an application service's namespace is exclusive and includes the given user ID

Broadcasts an EDU to all servers in rooms we are joined to. Used in the yggdrasil demos.

Handle an instruction to make_join & send_join with a remote server.

PostJSONNoSpan performs a POST request with JSON on an internal HTTP API

Check whether a room alias exists within any application service namespaces

Save message

SaveAccountData implements PUT /user/{userId}/[rooms/{roomId}/]account_data/{type}

SelectMaxPositionInTopology returns the event which has the highest depth, and if there are multiple, the event with the highest stream position.