mirror of
https://github.com/matrix-org/dendrite
synced 2024-12-14 21:53:49 +01:00
6de29c1cd2
* Fix flakey sytest 'Local device key changes get to remote servers' * Debug logs * Remove internal/test and use /test only Remove a lot of ancient code too. * Use FederationRoomserverAPI in more places * Use more interfaces in federationapi; begin adding regression test * Linting * Add regression test * Unbreak tests * ALL THE LOGS * Fix a race condition which could cause events to not be sent to servers If a new room event which rewrites state arrives, we remove all joined hosts then re-calculate them. This wasn't done in a transaction so for a brief period we would have no joined hosts. During this interim, key change events which arrive would not be sent to destination servers. This would sporadically fail on sytest. * Unbreak new tests * Linting
109 lines
2.7 KiB
Go
109 lines
2.7 KiB
Go
// Copyright 2022 The Matrix.org Foundation C.I.C.
|
|
//
|
|
// Licensed under the Apache License, Version 2.0 (the "License");
|
|
// you may not use this file except in compliance with the License.
|
|
// You may obtain a copy of the License at
|
|
//
|
|
// http://www.apache.org/licenses/LICENSE-2.0
|
|
//
|
|
// Unless required by applicable law or agreed to in writing, software
|
|
// distributed under the License is distributed on an "AS IS" BASIS,
|
|
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
|
// See the License for the specific language governing permissions and
|
|
// limitations under the License.
|
|
|
|
package test
|
|
|
|
import (
|
|
"bytes"
|
|
"crypto/ed25519"
|
|
"testing"
|
|
"time"
|
|
|
|
"github.com/matrix-org/gomatrixserverlib"
|
|
)
|
|
|
|
type eventMods struct {
|
|
originServerTS time.Time
|
|
origin gomatrixserverlib.ServerName
|
|
stateKey *string
|
|
unsigned interface{}
|
|
keyID gomatrixserverlib.KeyID
|
|
privKey ed25519.PrivateKey
|
|
}
|
|
|
|
type eventModifier func(e *eventMods)
|
|
|
|
func WithTimestamp(ts time.Time) eventModifier {
|
|
return func(e *eventMods) {
|
|
e.originServerTS = ts
|
|
}
|
|
}
|
|
|
|
func WithStateKey(skey string) eventModifier {
|
|
return func(e *eventMods) {
|
|
e.stateKey = &skey
|
|
}
|
|
}
|
|
|
|
func WithUnsigned(unsigned interface{}) eventModifier {
|
|
return func(e *eventMods) {
|
|
e.unsigned = unsigned
|
|
}
|
|
}
|
|
|
|
func WithKeyID(keyID gomatrixserverlib.KeyID) eventModifier {
|
|
return func(e *eventMods) {
|
|
e.keyID = keyID
|
|
}
|
|
}
|
|
|
|
func WithPrivateKey(pkey ed25519.PrivateKey) eventModifier {
|
|
return func(e *eventMods) {
|
|
e.privKey = pkey
|
|
}
|
|
}
|
|
|
|
func WithOrigin(origin gomatrixserverlib.ServerName) eventModifier {
|
|
return func(e *eventMods) {
|
|
e.origin = origin
|
|
}
|
|
}
|
|
|
|
// Reverse a list of events
|
|
func Reversed(in []*gomatrixserverlib.HeaderedEvent) []*gomatrixserverlib.HeaderedEvent {
|
|
out := make([]*gomatrixserverlib.HeaderedEvent, len(in))
|
|
for i := 0; i < len(in); i++ {
|
|
out[i] = in[len(in)-i-1]
|
|
}
|
|
return out
|
|
}
|
|
|
|
func AssertEventIDsEqual(t *testing.T, gotEventIDs []string, wants []*gomatrixserverlib.HeaderedEvent) {
|
|
t.Helper()
|
|
if len(gotEventIDs) != len(wants) {
|
|
t.Errorf("length mismatch: got %d events, want %d", len(gotEventIDs), len(wants))
|
|
return
|
|
}
|
|
for i := range wants {
|
|
w := wants[i].EventID()
|
|
g := gotEventIDs[i]
|
|
if w != g {
|
|
t.Errorf("event at index %d mismatch:\ngot %s\n\nwant %s", i, string(g), string(w))
|
|
}
|
|
}
|
|
}
|
|
|
|
func AssertEventsEqual(t *testing.T, gots, wants []*gomatrixserverlib.HeaderedEvent) {
|
|
t.Helper()
|
|
if len(gots) != len(wants) {
|
|
t.Fatalf("length mismatch: got %d events, want %d", len(gots), len(wants))
|
|
}
|
|
for i := range wants {
|
|
w := wants[i].JSON()
|
|
g := gots[i].JSON()
|
|
if !bytes.Equal(w, g) {
|
|
t.Errorf("event at index %d mismatch:\ngot %s\n\nwant %s", i, string(g), string(w))
|
|
}
|
|
}
|
|
}
|