mirrors/dendrite
1
0
Fork 0
mirror of https://github.com/matrix-org/dendrite.git synced 2025-12-16 11:23:11 -06:00
Code Issues Packages Projects Releases Wiki Activity

more logging needed

Browse source
This commit is contained in:
Neil Alexander 2020-03-10 16:18:24 +00:00
parent 70fdf9f834
commit 091e98a2d1
5 changed files with 20 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
appservice/consumers/roomserver.go
View file

@ -97,6 +97,10 @@ func (s *OutputRoomEventConsumer) onMessage(msg *sarama.ConsumerMessage) error {
// TODO: Is this trusted here?
ev, err := gomatrixserverlib.NewEventFromTrustedJSON(output.NewRoomEvent.Event, false, output.NewRoomEvent.RoomVersion)
if err != nil {
log.WithError(err).WithField("roomversion", output.NewRoomEvent.RoomVersion).Errorf(
"roomserver output log: couldn't create event from trusted JSON (%d bytes)",
len(output.NewRoomEvent.Event),
)
return err
}

4
clientapi/consumers/roomserver.go
View file

@ -87,6 +87,10 @@ func (s *OutputRoomEventConsumer) onMessage(msg *sarama.ConsumerMessage) error {
// TODO: Is this trusted here?
ev, err := gomatrixserverlib.NewEventFromTrustedJSON(output.NewRoomEvent.Event, false, output.NewRoomEvent.RoomVersion)
if err != nil {
log.WithError(err).WithField("roomversion", output.NewRoomEvent.RoomVersion).Errorf(
"roomserver output log: couldn't create event from trusted JSON (%d bytes)",
len(output.NewRoomEvent.Event),
)
return err
}

4
federationsender/consumers/roomserver.go
View file

@ -186,6 +186,10 @@ func (s *OutputRoomEventConsumer) joinedHostsAtEvent(
// TODO: Is this trusted here?
ev, err := gomatrixserverlib.NewEventFromTrustedJSON(ore.Event, false, ore.RoomVersion)
if err != nil {
log.WithError(err).WithField("roomversion", ore.RoomVersion).Errorf(
"roomserver output log: couldn't create event from trusted JSON (%d bytes)",
len(ore.Event),
)
return nil, err
}

4
publicroomsapi/consumers/roomserver.go
View file

@ -81,6 +81,10 @@ func (s *OutputRoomEventConsumer) onMessage(msg *sarama.ConsumerMessage) error {
// TODO: Is this trusted here?
ev, err := gomatrixserverlib.NewEventFromTrustedJSON(output.NewRoomEvent.Event, false, output.NewRoomEvent.RoomVersion)
if err != nil {
log.WithError(err).WithField("roomversion", output.NewRoomEvent.RoomVersion).Errorf(
"roomserver output log: couldn't create event from trusted JSON (%d bytes)",
len(output.NewRoomEvent.Event),
)
return err
}

4
syncapi/consumers/roomserver.go
View file

@ -101,6 +101,10 @@ func (s *OutputRoomEventConsumer) onNewRoomEvent(
// TODO: Is this trusted here?
ev, err := gomatrixserverlib.NewEventFromTrustedJSON(msg.Event, false, msg.RoomVersion)
if err != nil {
log.WithError(err).WithField("roomversion", msg.RoomVersion).Errorf(
"roomserver output log: couldn't create event from trusted JSON (%d bytes)",
len(msg.Event),
)
return err
}