SelectEventIDsInRange selects the IDs of events whose depths are within a given range in a given room's topological order. Events with `minDepth` are

Look up the state entries for a list of string event IDs Returns an error if the there is an error talking to the database Returns a types.MissingEven

cleanup old containers/volumes from a previous run

TODO: Replace when Dendrite uses Go 1.18

lookup an entry in the event map.

processRoomEvent can only be called once at a time TODO(#375): This should be rewritten to allow concurrent calls. The difficulty is in ensuring that

validateApplicationService checks if a provided application service token corresponds to one that is registered. If so, then it checks if the desired

validateTopicName expands session specific topic name to global name Returns topic: session-specific topic name the message recepient should see route

AddAllPublicRoutes attaches all public paths to the given router

AddPublicRoutes sets up and registers HTTP handlers for the SyncAPI component.

BackoffInfo returns information about the current or previous backoff. Returns the last backoffUntil time and whether the server is currently blacklis

CurrentlyActive returns the current active state.

Derive generates data that is derived from various values provided in the config file.

Lookup the event IDs for a batch of event numeric IDs. Returns an error if the retrieval went wrong.

EventPositionInTopology returns the depth and stream position of the given event.

FederationAPIHTTPClient returns FederationInternalAPI for hitting the federation API server over HTTP

Lookup the membership of a given user in a given room. Returns the numeric ID of the latest membership event sent from this user in this room, along a

GetRoomsByMembership returns a list of room IDs matching the provided membership and user ID (as state_key).

GetStateEvent returns the Matrix state event of a given type for a given room with a given state key If no event could be found, returns nil If there

GetSubs loads a list of subscriptions for the given user

KeyChanges returns a list of user IDs who have modified their keys from the offset given (exclusive) to the offset given (inclusive). A to offset of t

KeyError sets a key error field on KeyErrors

Notify sends a notification to the gateway at the given URL.

ParseUsernameParam extracts localpart from usernameParam. usernameParam can either be a user ID or just the localpart/username. If serverName is passe

Query a given amount (or less) of events prior to a given set of events.

PerformForget forgets a rooms history for a specific user

RedactEvent wipes an event in the database and sets the unsigned.redacted_because key to the redaction event

RunLimitedVariablesQuery split up a query with more variables than the used database can handle in multiple queries.

SendEvent implements: /rooms/{roomID}/send/{eventType} /rooms/{roomID}/send/{eventType}/{txnID} /rooms/{roomID}/state/{eventType}/{stateKey}

Start creates an ephemeral non-durable consumer on the roomserver input topic. It is configured to deliver us headers only because we don't actually c

request -> result is emulating gomatrixserverlib.StoreKeys: https://github.com/matrix-org/gomatrixserverlib/blob/f69539c86ea55d1e2cc76fd8e944e2d82d303

StreamEventsToEvents converts streamEvent to Event. If device is non-nil and matches the streamevent.transactionID device then the transaction ID gets

WriteEvent into the database. It is not safe to call this function from multiple goroutines, as it would create races when generating the sync stream

_fetchUserDeviceStream retrieves a stream unique to the given device. If makeIfNotExists is true, a stream will be made for this device if one doesn't

getCompletedStages returns the completed stages for a session.

getProfile gets the full profile of a user by querying the database or a remote homeserver. Returns an error when something goes wrong or specifically

injectResponseToRoomserver injects the events into the roomserver as KindOutlier, with auth chains.

isTrusted checks if a given identity server is part of the list of trusted identity servers in the configuration file. Returns an error if the server

loadStateEvents loads the matrix events for a list of state entries. Returns a list of state events in no particular order and a map from string event

AddTypingUser sets an user as typing in a room. expire is the time when the user typing should time out. if expire is nil, defaultTypingTimeout is ass

AppserviceHTTPClient returns the AppServiceInternalAPI for hitting the appservice component over HTTP.

Blacklisted returns true if the server is blacklisted and false otherwise.

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