Fix roomserver test

This commit is contained in:
Neil Alexander 2020-07-29 10:39:49 +01:00
parent e1d00e47de
commit 11a7073c97
No known key found for this signature in database
GPG key ID: A02A2019A2BB0944

View file

@ -94,17 +94,11 @@ func mustLoadEvents(t *testing.T, ver gomatrixserverlib.RoomVersion, events []js
} }
func mustSendEvents(t *testing.T, ver gomatrixserverlib.RoomVersion, events []json.RawMessage) (api.RoomserverInternalAPI, *dummyProducer, []gomatrixserverlib.HeaderedEvent) { func mustSendEvents(t *testing.T, ver gomatrixserverlib.RoomVersion, events []json.RawMessage) (api.RoomserverInternalAPI, *dummyProducer, []gomatrixserverlib.HeaderedEvent) {
cfg := &config.Dendrite{ cfg := &config.Dendrite{}
Global: config.Global{ cfg.Defaults()
ServerName: testOrigin, cfg.Global.ServerName = testOrigin
Kafka: config.Kafka{ cfg.Global.Kafka.UseNaffka = true
UseNaffka: true,
},
},
RoomServer: config.RoomServer{},
}
cfg.RoomServer.Database = roomserverDBFileURI cfg.RoomServer.Database = roomserverDBFileURI
cfg.Global.Kafka.Topics.OutputRoomEvent = "output_room_event"
dp := &dummyProducer{ dp := &dummyProducer{
topic: string(cfg.Global.Kafka.Topics.OutputRoomEvent), topic: string(cfg.Global.Kafka.Topics.OutputRoomEvent),
} }