mirrors/dendrite
1
0
Fork 0
mirror of https://github.com/matrix-org/dendrite.git synced 2026-01-16 18:43:10 -06:00
Code Issues Packages Projects Releases Wiki Activity

Fix tests

Browse source
This commit is contained in:
Kegan Dougal 2023-04-14 12:35:06 +01:00
parent 1fb2ee9d2d
commit 1529bc5d1f
1 changed files with 3 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

6
syncapi/storage/shared/storage_consumer_test.go
View file

@ -7,10 +7,10 @@ import (
"github.com/matrix-org/dendrite/internal/sqlutil" "github.com/matrix-org/dendrite/internal/sqlutil"
"github.com/matrix-org/dendrite/syncapi/storage" "github.com/matrix-org/dendrite/syncapi/storage"
"github.com/matrix-org/dendrite/syncapi/synctypes"
"github.com/matrix-org/dendrite/syncapi/types" "github.com/matrix-org/dendrite/syncapi/types"
"github.com/matrix-org/dendrite/test" "github.com/matrix-org/dendrite/test"
"github.com/matrix-org/dendrite/test/testrig" "github.com/matrix-org/dendrite/test/testrig"
"github.com/matrix-org/gomatrixserverlib"
) )
func newSyncDB(t *testing.T, dbType test.DBType) (storage.Database, func()) { func newSyncDB(t *testing.T, dbType test.DBType) (storage.Database, func()) {
@ -32,7 +32,7 @@ func TestFilterTable(t *testing.T) {
defer closeDB() defer closeDB()
// initially create a filter // initially create a filter
filter := &gomatrixserverlib.Filter{} filter := &synctypes.Filter{}
filterID, err := tab.PutFilter(context.Background(), "alice", filter) filterID, err := tab.PutFilter(context.Background(), "alice", filter)
if err != nil { if err != nil {
t.Fatal(err) t.Fatal(err)
@ -49,7 +49,7 @@ func TestFilterTable(t *testing.T) {
} }
// query the filter again // query the filter again
targetFilter := &gomatrixserverlib.Filter{} targetFilter := &synctypes.Filter{}
if err = tab.GetFilter(context.Background(), targetFilter, "alice", filterID); err != nil { if err = tab.GetFilter(context.Background(), targetFilter, "alice", filterID); err != nil {
t.Fatal(err) t.Fatal(err)
} }