diff --git a/userapi/consumers/clientapi.go b/userapi/consumers/clientapi.go index c220d35cb..ae362569e 100644 --- a/userapi/consumers/clientapi.go +++ b/userapi/consumers/clientapi.go @@ -81,7 +81,12 @@ func (s *OutputReceiptEventConsumer) onMessage(ctx context.Context, msgs []*nats readPos := msg.Header.Get(jetstream.EventID) evType := msg.Header.Get("type") - if readPos == "" || evType != "m.read" { + switch { + case readPos == "": + return true + case evType == "m.read": // allowed + case evType == "m.read.private": // allowed + default: return true }