test

package
v0.2.12 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Dec 6, 2024 License: Apache-2.0 Imports: 42 Imported by: 0

Documentation

Index

Constants

View Source
const (
	// ServerKeyFile is the name of the file holding the matrix server private key.
	ServerKeyFile = "server_key.pem"
	// TLSCertFile is the name of the file holding the TLS certificate used for federation.
	TLSCertFile = "tls_cert.pem"
	// TLSKeyFile is the name of the file holding the TLS key used for federation.
	TLSKeyFile = "tls_key.pem"
)
View Source
const NatsImage = "nats:2.10"

Variables

View Source
var (

	// private keys that tests can use
	PrivateKeyA = ed25519.NewKeyFromSeed([]byte{
		1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12, 13, 14, 15, 16,
		17, 18, 19, 20, 21, 22, 23, 24, 25, 26, 27, 28, 29, 30, 31, 77,
	})
	PrivateKeyB = ed25519.NewKeyFromSeed([]byte{
		1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12, 13, 14, 15, 16,
		17, 18, 19, 20, 21, 22, 23, 24, 25, 26, 27, 28, 29, 30, 31, 66,
	})
)

Functions

func AssertEventIDsEqual

func AssertEventIDsEqual(t *testing.T, gotEventIDs []string, wants []*types.HeaderedEvent)

func AssertEventsEqual

func AssertEventsEqual(t *testing.T, gots, wants []*types.HeaderedEvent)

func GuestsCanJoin

func GuestsCanJoin(canJoin bool) roomModifier

func ListenAndServe

func ListenAndServe(t *testing.T, router http.Handler, withTLS bool) (apiURL string, cancel func())

ListenAndServe will listen on a random high-numbered port and attach the given router. Returns the base URL to send requests to. Call `cancel` to shutdown the server, which will block until it has closed.

func NewMatrixKey

func NewMatrixKey(matrixKeyPath string) (err error)

NewMatrixKey generates a new ed25519 matrix server key and writes it to a file.

func NewRequest

func NewRequest(t *testing.T, method, path string, opts ...HTTPRequestOpt) *http.Request

func NewTLSKey

func NewTLSKey(tlsKeyPath, tlsCertPath string, keySize int) error

NewTLSKey generates a new RSA TLS key and certificate and writes it to a file.

func NewTLSKeyWithAuthority

func NewTLSKeyWithAuthority(serverName, tlsKeyPath, tlsCertPath, authorityKeyPath, authorityCertPath string, keySize int) error

func PrepareDatabaseDSConnection added in v0.2.5

func PrepareDatabaseDSConnection(ctx context.Context) (postgresDataSource config.DataSource, close func(), err error)

PrepareDatabaseDSConnection Prepare a postgres connection string for testing. Returns the connection string to use and a close function which must be called when the test finishes. Calling this function twice will return the same database, which will have data from previous tests unless close() is called.

func PrepareDefaultDSConnections added in v0.2.5

func PrepareDefaultDSConnections(ctx context.Context) (config.DefaultOpts, func(), error)

func PrepareNatsDataSourceConnection added in v0.2.5

func PrepareNatsDataSourceConnection(ctx context.Context) (dsConnection string, close func(), err error)

PrepareNatsDataSourceConnection Prepare a nats connection string for testing. Returns the connection string to use and a close function which must be called when the test finishes. Calling this function twice will return the same connection, which will have data from previous tests unless close() is called.

func PrepareRedisDataSourceConnection added in v0.2.5

func PrepareRedisDataSourceConnection(ctx context.Context) (connStr config.DataSource, close func(), err error)

PrepareRedisDataSourceConnection Prepare a redis connection string for testing. Returns the connection string to use and a close function which must be called when the test finishes. Calling this function twice will return the same database, which will have data from previous tests unless close() is called.

func Reversed

func Reversed(in []*types.HeaderedEvent) []*types.HeaderedEvent

Reverse a list of events

func RoomHistoryVisibility

func RoomHistoryVisibility(vis gomatrixserverlib.HistoryVisibility) roomModifier

func RoomPreset

func RoomPreset(p Preset) roomModifier

func RoomVersion

func RoomVersion(ver gomatrixserverlib.RoomVersion) roomModifier

func SaveMatrixKey

func SaveMatrixKey(matrixKeyPath string, data ed25519.PrivateKey) error

func UnsortedStringSliceEqual

func UnsortedStringSliceEqual(first, second []string) bool

UnsortedStringSliceEqual returns true if the slices have same length & elements. Does not modify the given slice.

func UserIDForSender

func UserIDForSender(roomID spec.RoomID, senderID spec.SenderID) (*spec.UserID, error)

func WithAllDatabases

func WithAllDatabases(t *testing.T, testFn func(t *testing.T, db DependancyOption))

WithAllDatabases Creates subtests with each known DependancyOption

func WithAuthIDs

func WithAuthIDs(evs []string) eventModifier

func WithKeyID

func WithKeyID(keyID gomatrixserverlib.KeyID) eventModifier

func WithOrigin

func WithOrigin(origin spec.ServerName) eventModifier

func WithPrivateKey

func WithPrivateKey(pkey ed25519.PrivateKey) eventModifier

func WithStateKey

func WithStateKey(skey string) eventModifier

func WithTimestamp

func WithTimestamp(ts time.Time) eventModifier

func WithUnsigned

func WithUnsigned(unsigned interface{}) eventModifier

Types

type DependancyOption added in v0.2.6

type DependancyOption struct {
	// contains filtered or unexported fields
}

func (*DependancyOption) Cache added in v0.2.6

func (opt *DependancyOption) Cache() string

func (*DependancyOption) Database added in v0.2.6

func (opt *DependancyOption) Database() string

func (*DependancyOption) Name added in v0.2.6

func (opt *DependancyOption) Name() string

func (*DependancyOption) Queue added in v0.2.6

func (opt *DependancyOption) Queue() string

type HTTPRequestOpt

type HTTPRequestOpt func(req *http.Request)

func WithJSONBody

func WithJSONBody(t *testing.T, body interface{}) HTTPRequestOpt

func WithQueryParams

func WithQueryParams(qps map[string]string) HTTPRequestOpt

type InMemoryFederationDatabase

type InMemoryFederationDatabase struct {
	// contains filtered or unexported fields
}

func NewInMemoryFederationDatabase

func NewInMemoryFederationDatabase() *InMemoryFederationDatabase

func (*InMemoryFederationDatabase) AddInboundPeek

func (d *InMemoryFederationDatabase) AddInboundPeek(ctx context.Context, serverName spec.ServerName, roomID, peekID string, renewalInterval int64) error

func (*InMemoryFederationDatabase) AddOutboundPeek

func (d *InMemoryFederationDatabase) AddOutboundPeek(ctx context.Context, serverName spec.ServerName, roomID, peekID string, renewalInterval int64) error

func (*InMemoryFederationDatabase) AddServerToBlacklist

func (d *InMemoryFederationDatabase) AddServerToBlacklist(
	serverName spec.ServerName,
) error

func (*InMemoryFederationDatabase) AssociateEDUWithDestinations

func (d *InMemoryFederationDatabase) AssociateEDUWithDestinations(
	ctx context.Context,
	destinations map[spec.ServerName]struct{},
	dbReceipt *receipt.Receipt,
	eduType string,
	expireEDUTypes map[string]time.Duration,
) error

func (*InMemoryFederationDatabase) AssociatePDUWithDestinations

func (d *InMemoryFederationDatabase) AssociatePDUWithDestinations(
	ctx context.Context,
	destinations map[spec.ServerName]struct{},
	dbReceipt *receipt.Receipt,
) error

func (*InMemoryFederationDatabase) CleanEDUs

func (d *InMemoryFederationDatabase) CleanEDUs(
	ctx context.Context,
	serverName spec.ServerName,
	receipts []*receipt.Receipt,
) error

func (*InMemoryFederationDatabase) CleanPDUs

func (d *InMemoryFederationDatabase) CleanPDUs(
	ctx context.Context,
	serverName spec.ServerName,
	receipts []*receipt.Receipt,
) error

func (*InMemoryFederationDatabase) DeleteExpiredEDUs

func (d *InMemoryFederationDatabase) DeleteExpiredEDUs(ctx context.Context) error

func (*InMemoryFederationDatabase) FetcherName

func (d *InMemoryFederationDatabase) FetcherName() string

func (*InMemoryFederationDatabase) GetAllJoinedHosts

func (d *InMemoryFederationDatabase) GetAllJoinedHosts(ctx context.Context) ([]spec.ServerName, error)

func (*InMemoryFederationDatabase) GetInboundPeek

func (d *InMemoryFederationDatabase) GetInboundPeek(ctx context.Context, serverName spec.ServerName, roomID, peekID string) (*types.InboundPeek, error)

func (*InMemoryFederationDatabase) GetInboundPeeks

func (d *InMemoryFederationDatabase) GetInboundPeeks(ctx context.Context, roomID string) ([]types.InboundPeek, error)

func (*InMemoryFederationDatabase) GetJoinedHosts

func (d *InMemoryFederationDatabase) GetJoinedHosts(ctx context.Context, roomID string) ([]types.JoinedHost, error)

func (*InMemoryFederationDatabase) GetJoinedHostsForRooms

func (d *InMemoryFederationDatabase) GetJoinedHostsForRooms(ctx context.Context, roomIDs []string, excludeSelf, excludeBlacklisted bool) ([]spec.ServerName, error)

func (*InMemoryFederationDatabase) GetNotaryKeys

func (*InMemoryFederationDatabase) GetOutboundPeek

func (d *InMemoryFederationDatabase) GetOutboundPeek(ctx context.Context, serverName spec.ServerName, roomID, peekID string) (*types.OutboundPeek, error)

func (*InMemoryFederationDatabase) GetOutboundPeeks

func (d *InMemoryFederationDatabase) GetOutboundPeeks(ctx context.Context, roomID string) ([]types.OutboundPeek, error)

func (*InMemoryFederationDatabase) GetPendingEDUCount

func (d *InMemoryFederationDatabase) GetPendingEDUCount(
	ctx context.Context,
	serverName spec.ServerName,
) (int64, error)

func (*InMemoryFederationDatabase) GetPendingEDUServerNames

func (d *InMemoryFederationDatabase) GetPendingEDUServerNames(
	ctx context.Context,
) ([]spec.ServerName, error)

func (*InMemoryFederationDatabase) GetPendingEDUs

func (d *InMemoryFederationDatabase) GetPendingEDUs(
	ctx context.Context,
	serverName spec.ServerName,
	limit int,
) (edus map[*receipt.Receipt]*gomatrixserverlib.EDU, err error)

func (*InMemoryFederationDatabase) GetPendingPDUCount

func (d *InMemoryFederationDatabase) GetPendingPDUCount(
	ctx context.Context,
	serverName spec.ServerName,
) (int64, error)

func (*InMemoryFederationDatabase) GetPendingPDUServerNames

func (d *InMemoryFederationDatabase) GetPendingPDUServerNames(
	ctx context.Context,
) ([]spec.ServerName, error)

func (*InMemoryFederationDatabase) GetPendingPDUs

func (d *InMemoryFederationDatabase) GetPendingPDUs(
	ctx context.Context,
	serverName spec.ServerName,
	limit int,
) (pdus map[*receipt.Receipt]*rstypes.HeaderedEvent, err error)

func (*InMemoryFederationDatabase) IsServerAssumedOffline

func (d *InMemoryFederationDatabase) IsServerAssumedOffline(
	ctx context.Context,
	serverName spec.ServerName,
) (bool, error)

func (*InMemoryFederationDatabase) IsServerBlacklisted

func (d *InMemoryFederationDatabase) IsServerBlacklisted(
	serverName spec.ServerName,
) (bool, error)

func (*InMemoryFederationDatabase) P2PAddRelayServersForServer

func (d *InMemoryFederationDatabase) P2PAddRelayServersForServer(
	ctx context.Context,
	serverName spec.ServerName,
	relayServers []spec.ServerName,
) error

func (*InMemoryFederationDatabase) P2PGetRelayServersForServer

func (d *InMemoryFederationDatabase) P2PGetRelayServersForServer(
	ctx context.Context,
	serverName spec.ServerName,
) ([]spec.ServerName, error)

func (*InMemoryFederationDatabase) P2PRemoveAllRelayServersForServer

func (d *InMemoryFederationDatabase) P2PRemoveAllRelayServersForServer(ctx context.Context, serverName spec.ServerName) error

func (*InMemoryFederationDatabase) P2PRemoveRelayServersForServer

func (d *InMemoryFederationDatabase) P2PRemoveRelayServersForServer(
	ctx context.Context,
	serverName spec.ServerName,
	relayServers []spec.ServerName,
) error

func (*InMemoryFederationDatabase) PurgeRoom

func (d *InMemoryFederationDatabase) PurgeRoom(ctx context.Context, roomID string) error

func (*InMemoryFederationDatabase) RemoveAllServersAssumedOffine

func (d *InMemoryFederationDatabase) RemoveAllServersAssumedOffine(
	ctx context.Context,
) error

func (*InMemoryFederationDatabase) RemoveAllServersAssumedOffline

func (d *InMemoryFederationDatabase) RemoveAllServersAssumedOffline(ctx context.Context) error

func (*InMemoryFederationDatabase) RemoveAllServersFromBlacklist

func (d *InMemoryFederationDatabase) RemoveAllServersFromBlacklist() error

func (*InMemoryFederationDatabase) RemoveServerAssumedOffline

func (d *InMemoryFederationDatabase) RemoveServerAssumedOffline(
	ctx context.Context,
	serverName spec.ServerName,
) error

func (*InMemoryFederationDatabase) RemoveServerFromBlacklist

func (d *InMemoryFederationDatabase) RemoveServerFromBlacklist(
	serverName spec.ServerName,
) error

func (*InMemoryFederationDatabase) RenewInboundPeek

func (d *InMemoryFederationDatabase) RenewInboundPeek(ctx context.Context, serverName spec.ServerName, roomID, peekID string, renewalInterval int64) error

func (*InMemoryFederationDatabase) RenewOutboundPeek

func (d *InMemoryFederationDatabase) RenewOutboundPeek(ctx context.Context, serverName spec.ServerName, roomID, peekID string, renewalInterval int64) error

func (*InMemoryFederationDatabase) SetServerAssumedOffline

func (d *InMemoryFederationDatabase) SetServerAssumedOffline(
	ctx context.Context,
	serverName spec.ServerName,
) error

func (*InMemoryFederationDatabase) StoreJSON

func (d *InMemoryFederationDatabase) StoreJSON(
	ctx context.Context,
	js string,
) (*receipt.Receipt, error)

func (*InMemoryFederationDatabase) UpdateNotaryKeys

func (d *InMemoryFederationDatabase) UpdateNotaryKeys(ctx context.Context, serverName spec.ServerName, serverKeys gomatrixserverlib.ServerKeys) error

func (*InMemoryFederationDatabase) UpdateRoom

func (d *InMemoryFederationDatabase) UpdateRoom(ctx context.Context, roomID string, addHosts []types.JoinedHost, removeHosts []string, purgeRoomFirst bool) (joinedHosts []types.JoinedHost, err error)

type InMemoryRelayDatabase

type InMemoryRelayDatabase struct {
	// contains filtered or unexported fields
}

func NewInMemoryRelayDatabase

func NewInMemoryRelayDatabase() *InMemoryRelayDatabase

func (*InMemoryRelayDatabase) DeleteQueueEntries

func (d *InMemoryRelayDatabase) DeleteQueueEntries(
	ctx context.Context,
	txn *sql.Tx,
	serverName spec.ServerName,
	jsonNIDs []int64,
) error

func (*InMemoryRelayDatabase) DeleteQueueJSON

func (d *InMemoryRelayDatabase) DeleteQueueJSON(
	ctx context.Context,
	txn *sql.Tx,
	nids []int64,
) error

func (*InMemoryRelayDatabase) InsertQueueEntry

func (d *InMemoryRelayDatabase) InsertQueueEntry(
	ctx context.Context,
	txn *sql.Tx,
	transactionID gomatrixserverlib.TransactionID,
	serverName spec.ServerName,
	nid int64,
) error

func (*InMemoryRelayDatabase) InsertQueueJSON

func (d *InMemoryRelayDatabase) InsertQueueJSON(
	ctx context.Context,
	txn *sql.Tx,
	json string,
) (int64, error)

func (*InMemoryRelayDatabase) SelectQueueEntries

func (d *InMemoryRelayDatabase) SelectQueueEntries(
	ctx context.Context,
	txn *sql.Tx, serverName spec.ServerName,
	limit int,
) ([]int64, error)

func (*InMemoryRelayDatabase) SelectQueueEntryCount

func (d *InMemoryRelayDatabase) SelectQueueEntryCount(
	ctx context.Context,
	txn *sql.Tx,
	serverName spec.ServerName,
) (int64, error)

func (*InMemoryRelayDatabase) SelectQueueJSON

func (d *InMemoryRelayDatabase) SelectQueueJSON(
	ctx context.Context,
	txn *sql.Tx,
	jsonNIDs []int64,
) (map[int64][]byte, error)

type NopJSONVerifier

type NopJSONVerifier struct {
}

NopJSONVerifier is a JSONVerifier that verifies nothing and returns no errors.

func (*NopJSONVerifier) VerifyJSONs

type Preset

type Preset int
var (
	PresetNone               Preset = 0
	PresetPrivateChat        Preset = 1
	PresetPublicChat         Preset = 2
	PresetTrustedPrivateChat Preset = 3
)

type Room

type Room struct {
	ID      string
	Version gomatrixserverlib.RoomVersion
	// contains filtered or unexported fields
}

func NewRoom

func NewRoom(t *testing.T, creator *User, modifiers ...roomModifier) *Room

Create a new test room. Automatically creates the initial create events.

func (*Room) CreateAndInsert

func (r *Room) CreateAndInsert(t *testing.T, creator *User, eventType string, content interface{}, mods ...eventModifier) *rstypes.HeaderedEvent

func (*Room) CreateEvent

func (r *Room) CreateEvent(t *testing.T, creator *User, eventType string, content interface{}, mods ...eventModifier) *rstypes.HeaderedEvent

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.

func (*Room) CurrentState

func (r *Room) CurrentState() []*rstypes.HeaderedEvent

func (*Room) Events

func (r *Room) Events() []*rstypes.HeaderedEvent

func (*Room) ForwardExtremities

func (r *Room) ForwardExtremities() []string

func (*Room) InsertEvent

func (r *Room) InsertEvent(t *testing.T, he *rstypes.HeaderedEvent)

Add a new event to this room DAG. Not thread-safe.

func (*Room) MustGetAuthEventRefsForEvent

func (r *Room) MustGetAuthEventRefsForEvent(t *testing.T, needed gomatrixserverlib.StateNeeded) []string

type User

type User struct {
	ID          string
	Localpart   string
	AccountType api.AccountType
	// contains filtered or unexported fields
}

func NewUser

func NewUser(t *testing.T, opts ...UserOpt) *User

type UserOpt

type UserOpt func(*User)

func WithAccountType

func WithAccountType(accountType api.AccountType) UserOpt

func WithSigningServer

func WithSigningServer(srvName spec.ServerName, keyID gomatrixserverlib.KeyID, privKey ed25519.PrivateKey) UserOpt

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL