diff options
| author | S7evinK <2353100+S7evinK@users.noreply.github.com> | 2022-02-04 14:08:13 +0100 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2022-02-04 13:08:13 +0000 |
| commit | 9de7efa0b095f40457f0e348632c77326dcb4a42 (patch) | |
| tree | c543823b7d4ce25371b975a88bc5270c3a9d7352 /keyserver/storage/storage_test.go | |
| parent | 532f445c4e31396fc3aa4f52e0e078cd499bc39a (diff) | |
Remove sarama/saramajetstream dependencies (#2138)
* Remove dependency on saramajetstream & sarama
Signed-off-by: Till Faelligen <tfaelligen@gmail.com>
* Remove internal.ContinualConsumer from federationapi
* Remove internal.ContinualConsumer from syncapi
* Remove internal.ContinualConsumer from keyserver
* Move to new Prepare function
* Remove saramajetstream & sarama dependency
* Delete unneeded file
* Remove duplicate import
* Log error instead of silently irgnoring it
* Move `OffsetNewest` and `OffsetOldest` into keyserver types, change them to be more sane values
* Fix comments
Co-authored-by: Neil Alexander <neilalexander@users.noreply.github.com>
Diffstat (limited to 'keyserver/storage/storage_test.go')
| -rw-r--r-- | keyserver/storage/storage_test.go | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/keyserver/storage/storage_test.go b/keyserver/storage/storage_test.go index 2f8cf809..c4c99d8c 100644 --- a/keyserver/storage/storage_test.go +++ b/keyserver/storage/storage_test.go @@ -9,8 +9,8 @@ import ( "reflect" "testing" - "github.com/Shopify/sarama" "github.com/matrix-org/dendrite/keyserver/api" + "github.com/matrix-org/dendrite/keyserver/types" "github.com/matrix-org/dendrite/setup/config" ) @@ -50,7 +50,7 @@ func TestKeyChanges(t *testing.T) { MustNotError(t, err) deviceChangeIDC, err := db.StoreKeyChange(ctx, "@charlie:localhost") MustNotError(t, err) - userIDs, latest, err := db.KeyChanges(ctx, deviceChangeIDB, sarama.OffsetNewest) + userIDs, latest, err := db.KeyChanges(ctx, deviceChangeIDB, types.OffsetNewest) if err != nil { t.Fatalf("Failed to KeyChanges: %s", err) } @@ -74,7 +74,7 @@ func TestKeyChangesNoDupes(t *testing.T) { } deviceChangeID, err := db.StoreKeyChange(ctx, "@alice:localhost") MustNotError(t, err) - userIDs, latest, err := db.KeyChanges(ctx, 0, sarama.OffsetNewest) + userIDs, latest, err := db.KeyChanges(ctx, 0, types.OffsetNewest) if err != nil { t.Fatalf("Failed to KeyChanges: %s", err) } |