SelectRoomIDsWithAnyMembership returns a map of all memberships for the given user.

SendInputRoomEvents to the roomserver.

SendJoin implements the /send_join API The make-join send-join dance makes much more sense as a single flow so the cyclomatic complexity is high: noli

SendLeave implements the /send_leave API

SendData sends account data to the user API server

SendToDevice handles PUT /_matrix/client/r0/sendToDevice/{eventType}/{txnId} sends the device events to the syncapi & federationsender

Save a given room alias with the room ID it refers to. Returns an error if there was a problem talking to the database.

Set the state at an event. FIXME TODO: "at"

StaleDeviceLists returns a list of user IDs ending with the domains provided who have stale device lists. If no domains are given, all user IDs with s

Start consuming typing events.

StoreRemoteDeviceKeys persists the given keys. Keys with the same user ID and device ID will be replaced. An empty KeyJSON removes the key for this (u

Subscribe implements accounts.Backend, creating an async subscription to receive notifications on the addition or removal of smart card wallets.

SuccessCount returns the number of successful requests. This is usually useful in constructing transaction IDs.

UpdateChildMetadata persists the children_count and children_hash from this event if and only if the count is greater than what was previously there.

UpsertKey updates or inserts a (server_name, key_id) tuple, pointing it via NotaryID at the the response which has the longest valid_until_ts `newNota

Check whether a user ID exists within any application service namespaces

Validate validates the uploadRequest fields

ValidateRule checks the rule for errors. These follow from Sytests and the specification.

WithStreamID returns a copy of this device message with the given stream ID

_removeEmptyUserStreams iterates through the user stream map and removes any that have been empty for a certain amount of time. This is a crude way of

_wakeupUserDevice will wake up the sync stream for a specific user device. Other device streams will be left alone. nolint:unused

addChildren adds an event's children to the to walk data structure

Adds multiple events at once, each entry in the map is an eventID and set of auth events that are converted to an event and added.

addIgnoredUsersToFilter adds ignored users to the eventfilter and the syncreq itself for further use in streams.

addParams adds a registerRequest to a sessionID and starts a timer to delete that registerRequest

appendExclusiveNamespaceRegexs takes a slice of strings and a slice of namespaces and will append the regexes of only the exclusive namespaces into th

* func fromStateTuples(tuples []gomatrixserverlib.StateKeyTuple, omitTuples []gomatrixserverlib.StateKeyTuple) (result []*gomatrixserverlib.HeaderedE

authorised returns true iff the user is joined this room or the room is world_readable

backfill performs a backfill request over the federation on another homeserver in the room. See: https://matrix.org/docs/spec/server_server/latest#get

broadcastMediaMetadata broadcasts the media metadata and error response to waiting goroutines Only the owner of the activeRemoteRequestResult for this

buildMembershipEvent uses a builder for a m.room.member invite event derived from a third-party invite to auth and build the said event. Returns the s

bulkSelectEventNIDs returns a map from string event ID to numeric event ID. If an event ID is not in the database then it is omitted from the map.

bulkSelectEventNIDs returns a map from string event ID to numeric event ID. If an event ID is not in the database then it is omitted from the map.

cancel will interrupt the currently active backoff.

cancel will interrupt the currently active backoff.

File type hooks should be provided a path to a directory to store log files

checkRecaptchaEnabled creates an error response if recaptcha is not usable on homeserver.

childrenForParent returns the children events for this event ID, honouring the direction: up|down flags meaning this can actually be returning the par

From https://gist.github.com/mimoo/25fc9716e0f1353791f5908f94d6e726 Modified to strip off top-level when compressing

Check whether a tuple is in the list. Assumes that the list is sorted.

createRoom implements /createRoom nolint: gocyclo

createThumbnail checks if the thumbnail exists, and if not, generates it Thumbnail generation is only done once for each non-existing thumbnail.

createThumbnail checks if the thumbnail exists, and if not, generates it Thumbnail generation is only done once for each non-existing thumbnail.

Message received, dispatch

FederatedAuthProvider is an auth chain provider which fetches events from the server provided

fetchStateEvents converts the set of event IDs into a set of events. It will fetch any which are missing from the database. Returns a map of room ID t

findDuplicateStateKeys finds the state entries where the state key tuple appears more than once in a sorted list. Returns a sorted list of those state