From cde796932fc714584d007f60c65ae65c10f85b6a Mon Sep 17 00:00:00 2001 From: Neil Alexander Date: Thu, 3 Dec 2020 10:48:50 +0000 Subject: [PATCH] Update consumers --- syncapi/consumers/roomserver.go | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/syncapi/consumers/roomserver.go b/syncapi/consumers/roomserver.go index 2bf7629de..11d75a683 100644 --- a/syncapi/consumers/roomserver.go +++ b/syncapi/consumers/roomserver.go @@ -105,6 +105,8 @@ func (s *OutputRoomEventConsumer) onMessage(msg *sarama.ConsumerMessage) error { return s.onRetireInviteEvent(context.TODO(), *output.RetireInviteEvent) case api.OutputTypeNewPeek: return s.onNewPeek(context.TODO(), *output.NewPeek) + case api.OutputTypeRetirePeek: + return s.onRetirePeek(context.TODO(), *output.RetirePeek) case api.OutputTypeRedactedEvent: return s.onRedactEvent(context.TODO(), *output.RedactedEvent) default: @@ -310,7 +312,7 @@ func (s *OutputRoomEventConsumer) onNewPeek( } func (s *OutputRoomEventConsumer) onRetirePeek( - ctx context.Context, msg api.OutputNewPeek, + ctx context.Context, msg api.OutputRetirePeek, ) error { sp, err := s.db.DeletePeek(ctx, msg.RoomID, msg.UserID, msg.DeviceID) if err != nil {