Start the device list updater, which will try to refresh any stale device lists.

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

StoreNewSendForDeviceMessage stores a new send-to-device event for a user's device.

List the unique eventTypeNIDs and eventStateKeyNIDs. Assumes that the list is sorted.

Update blocks until the update has been stored in the database. It blocks primarily for satisfying sytest, which assumes when /send 200 OKs that the d

Upload a bunch of session keys for a given `version`.

WithTransaction runs a block of code passing in an SQL transaction If the code returns an error or panics then the transactions is rolledback Otherwis

absPath returns the absolute path for a given relative or absolute path.

allowedToSeeEvent returns no error if the server is allowed to see this event, otherwise it returns an error response which can be sent to the client.

broadcastGeneration broadcasts that thumbnail generation completed and the error to all waiting goroutines Note: This should only be called by the own

combineDeltas combines two deltas into a single delta. Assumes that the order of operations is add(1), remove(1), add(2), remove(2). Removes duplicate

completeRegistration runs some rudimentary checks against the submitted input, then if successful creates an account and a newly associated device We

deleteSession cleans up a given session, either because the registration completed successfully, or because a given timeout (default: 5min) was reache

fetchEvent fetches the event without auth checks. Returns an error if the event cannot be found.

loadProfile lookups the profile of a given user from the database and returns it if the user is local to this server, or returns an empty profile if n

FIXME TODO: Remove all this - horrible dupe with roomserver/state. Can't use the original impl because of circular loops it should live in this packag

lookForEvent returns the event for the event ID given, by trying to query remote servers if the event ID is unknown via /event_relationships.

lookupMapPath traverses a hierarchical map structure, like the one produced by json.Unmarshal, to return the leaf value. Traversing arrays/slices is n

newUserInteractiveResponse will return a struct to be sent back to the client during registration.

obtainSavedTags gets all tags scoped to a userID and roomID from the database

refreshWallets scans the devices attached to the machine and updates the list of wallets based on the found devices.

saveTagData saves the provided tag data into the database

updatePresence sends presence updates to the SyncAPI and FederationAPI

validateAction returns issues with an Action.

validateCondition returns issues with a Condition.

validatePassword returns an error response if the password is invalid

validateUsername returns an error response if the username is invalid

wakeQueueIfNeeded will wake up the destination queue if it is not already running. If it is running but it is backing off then we will interrupt the b

Writes a message with the given message type (mt) and payload.

Implements net.Listener

these don't have contexts passed in as we want things to happen regardless of the request context

Store the room state at an event in the database

Implements net.Listener

BackwardExtremitiesForRoom returns a map of backwards extremity event ID to a list of its prev_events.

bulkSelectStateEventByID lookups a list of state events by event ID. If any of the requested events are missing from the database it returns a types.M

CalculateAndStoreStateAfterEvents finds the room state after the given events. Stores the resulting state in the database and returns a numeric ID for

Challenge returns an HTTP 401 with the supported flows for authenticating

ClaimKeys based on the 3-uple of user_id, device_id and algorithm name. Returns the keys claimed. Returns no error if a key cannot be claimed or if no

CleanSendToDeviceUpdates removes all send-to-device messages BEFORE the specified from position, preventing the send-to-device table from growing inde

ConnMaxLifetime returns maximum amount of time a connection may be reused

Create an event in this room but do not insert it. Does not modify the room in any way (depth, fwd extremities, etc) so is thread-safe.

CurrentPosition returns the current sync position

Decode addr

Delete deletes a subscription

DeleteDeviceKeys removes the device keys for a given user/device, and any accompanying cross-signing signatures relating to that device.

DeviceKeysJSON populates the KeyJSON for the given keys. If any proided `keys` have a `KeyJSON` or `StreamID` already then it will be replaced.

Enabled returns true if the given msc is enabled. Should in the form 'msc12345'.

Look up the numeric IDs for a list of string event state keys. Returns a map from string state key to numeric ID for the state key.

Look up the string event state keys for a list of numeric event state keys Returns an error if there was a problem talking to the database.