checkFlowCompleted checks if a registration flow complies with any allowed flow dictated by the server. Order of stages does not matter. A user may co

AddTransaction adds an entry for the (accessToken, txnID) tuple in Cache. Adds to the front txnMap.

LoadStateAtSnapshot loads the full state of a room at a particular snapshot. This is typically the state before an event or the current state of a roo

Query the server names of the joined hosts in a room. Unlike QueryJoinedHostsInRoom, this function returns a de-duplicated slice containing only the s

QuerySharedUsers returns a list of users who share at least 1 room in common with the given user.

SetCurrentPosition sets the current streaming positions. This must be called directly after NewNotifier and initialising the streams.

Success updates the server statistics with a new successful attempt, which increases the sent counter and resets the idle and failure counters. If a h

lockedFetchUserStream invokes Notifier.fetchUserStream, respecting Notifier.streamLock. A new stream is made if it doesn't exist already.

lookup an entry in the event map.

prepareWithFilters returns a prepared statement with the relevant filters included. It also includes an []interface{} list of all the relevant paramet

bulkSelectEventID returns a map from numeric event ID to string event ID.

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 i

Events lookups a list of event by their event ID. Returns a list of events matching the requested IDs found in the database. If an event is not found

FetchTransaction looks up an entry for the (accessToken, txnID) tuple in Cache. Looks in both the txnMaps. Returns (JSON response, true) if txnID is f

Look up the room ID a given alias refers to. Returns an error if there was a problem talking to the database.

NewNotifier creates a new notifier set to the given sync position. In order for this to be of any use, the Notifier needs to be told all rooms and the

OnNewEvent is called when a new event is received from the room server. Must only be called from a single goroutine, to avoid races between updates wh

PowerLevels implements gomatrixserverlib.AuthEventProvider

Query the state after a list of events in a room from the room server.

SendEDU sends an EDU event to the destinations.

SendToDeviceUpdatesForSync returns a list of send-to-device updates. It returns the relevant events within the given ranges for the supplied user ID a

needed to avoid chicken and egg scenario when setting up the interdependencies between the roomserver and other input APIs

UserAPIClient returns UserInternalAPI for hitting the userapi over HTTP.

addCompletedSessionStage records that a session has completed an auth stage also starts a timer to delete the session once done.

Broadcast a new sync position for this user.

Close implements io.Closer

GetAuthChain fetches the auth chain for the given auth events. An auth chain is the list of all events that are referenced in the auth_events section,

Lookup the membership event numeric IDs for all user that are or have been members of a given room. Only lookup events of "join" membership if joinOnl

IsInterestedInUserID returns a bool on whether an application service's namespace includes the given user ID

PerformLoginTokenDeletion ensures the token doesn't exist. Success is returned even if the token didn't exist, or was already deleted.

QueryLoginToken returns the data associated with a login token. If the token is not valid, success is returned, but res.Data == nil.

Query if we think we're still in a room.

RoomserverHTTPClient returns RoomserverInternalAPI for hitting the roomserver over HTTP.

SetUserAPI assigns a user API to query when extracting device names.

Look up the state of a room at each event for a list of string event IDs. Returns an error if there is an error talking to the database. The length of

getFSType returns the filesystem type of the underlying mounted filesystem

setUsersJoinedToRooms marks the given users as 'joined' to the given rooms, such that new events from these rooms will wake the given users /sync requ

Wait until something is Wait()ing on the user stream.

Commit the transaction

DeviceKeysForUser returns the device keys for the device IDs given. If the length of deviceIDs is 0, all devices are selected. If there are some missi

Look up the numeric IDs for a list of events. Returns an error if there was a problem talking to the database.

KeyServerHTTPClient returns KeyInternalAPI for hitting the key server over HTTP

LoadCombinedStateAfterEvents loads a snapshot of the state after each of the events and combines those snapshots together into a single list. At this

lookup an entry in the event map.

Generators of error messages

PerformLoginTokenCreation creates a new login token and associates it with the provided data.

PushGatewayHTTPClient returns a new client for interacting with (external) Push Gateways.

Query to get state and auth chain for a (potentially hypothetical) event. Takes lists of PrevEventIDs and AuthEventsIDs and uses them to calculate the

Rollback the transaction.