diff --git a/syncapi/consumers/roomserver.go b/syncapi/consumers/roomserver.go index a6aeee3a8..8e63ed481 100644 --- a/syncapi/consumers/roomserver.go +++ b/syncapi/consumers/roomserver.go @@ -194,6 +194,7 @@ func (s *OutputRoomEventConsumer) onNewRoomEvent( sentry.CaptureException(err) return err } + log.Infof("onNewRoomEvent -> %d: %+v", pduPos, msg) s.pduStream.Advance(pduPos) s.notifier.OnNewEvent(ev, ev.RoomID(), nil, types.StreamingToken{PDUPosition: pduPos}) diff --git a/syncapi/sync/requestpool.go b/syncapi/sync/requestpool.go index a45736106..98df35632 100644 --- a/syncapi/sync/requestpool.go +++ b/syncapi/sync/requestpool.go @@ -244,6 +244,7 @@ func (rp *RequestPool) OnIncomingSyncRequest(req *http.Request, device *userapi. ), } } + syncReq.Log.Infof("%s->%s : %+v", syncReq.Since, syncReq.Response.NextBatch, syncReq.Response) return util.JSONResponse{ Code: http.StatusOK,