Panic if we cannot keep room state updated

This commit is contained in:
Kegan Dougal 2017-03-30 14:08:24 +01:00
parent 254b207a92
commit f480c32038

View file

@ -64,7 +64,8 @@ func (s *Server) onMessage(msg *sarama.ConsumerMessage) error {
}).Info("received event from roomserver") }).Info("received event from roomserver")
if err := s.db.WriteEvent(&ev, output.AddsStateEventIDs, output.RemovesStateEventIDs); err != nil { if err := s.db.WriteEvent(&ev, output.AddsStateEventIDs, output.RemovesStateEventIDs); err != nil {
log.WithError(err).Errorf("roomserver output log: write event failure") // panic rather than continue with an inconsistent database
log.WithError(err).WithField("OutputRoomEvent", output).Panicf("roomserver output log: write event failure")
return nil return nil
} }