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

Update consumers

Browse source
This commit is contained in:
Neil Alexander 2020-12-03 10:48:50 +00:00
parent 4c01a34115
commit cde796932f
No known key found for this signature in database
GPG key ID: A02A2019A2BB0944
1 changed files with 3 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
syncapi/consumers/roomserver.go
View file

@ -105,6 +105,8 @@ func (s *OutputRoomEventConsumer) onMessage(msg *sarama.ConsumerMessage) error {
return s.onRetireInviteEvent(context.TODO(), *output.RetireInviteEvent) return s.onRetireInviteEvent(context.TODO(), *output.RetireInviteEvent)
case api.OutputTypeNewPeek: case api.OutputTypeNewPeek:
return s.onNewPeek(context.TODO(), *output.NewPeek) return s.onNewPeek(context.TODO(), *output.NewPeek)
case api.OutputTypeRetirePeek:
return s.onRetirePeek(context.TODO(), *output.RetirePeek)
case api.OutputTypeRedactedEvent: case api.OutputTypeRedactedEvent:
return s.onRedactEvent(context.TODO(), *output.RedactedEvent) return s.onRedactEvent(context.TODO(), *output.RedactedEvent)
default: default:
@ -310,7 +312,7 @@ func (s *OutputRoomEventConsumer) onNewPeek(
} }
func (s *OutputRoomEventConsumer) onRetirePeek( func (s *OutputRoomEventConsumer) onRetirePeek(
ctx context.Context, msg api.OutputNewPeek, ctx context.Context, msg api.OutputRetirePeek,
) error { ) error {
sp, err := s.db.DeletePeek(ctx, msg.RoomID, msg.UserID, msg.DeviceID) sp, err := s.db.DeletePeek(ctx, msg.RoomID, msg.UserID, msg.DeviceID)
if err != nil { if err != nil {