Logging

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})

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,