diff --git a/downstream.go b/downstream.go index 1b9aae9..f0e9c61 100644 --- a/downstream.go +++ b/downstream.go @@ -2983,9 +2983,13 @@ func (dc *downstreamConn) handleMessageRegistered(ctx context.Context, msg *irc. } network.forEachDownstream(func(d *downstreamConn) { if broadcast || dc.id == d.id { + cmd := "MARKREAD" + if !dc.caps.IsEnabled("draft/read-marker") { + cmd = "READ" + } d.SendMessage(&irc.Message{ Prefix: d.prefix(), - Command: msg.Command, + Command: cmd, Params: []string{d.marshalEntity(network, entity), timestampStr}, }) }