tweak syncChannelMetadata

This commit is contained in:
Shivaram Lingamneni 2025-06-15 16:08:45 -04:00
parent 2f60990426
commit 1f546bad9c

View file

@ -80,21 +80,22 @@ func syncClientMetadata(server *Server, rb *ResponseBuffer, target *Client) {
} }
} }
func syncChannelMetadata(server *Server, rb *ResponseBuffer, target *Channel) { func syncChannelMetadata(server *Server, rb *ResponseBuffer, channel *Channel) {
batchId := rb.StartNestedBatch("metadata") batchId := rb.StartNestedBatch("metadata")
defer rb.EndNestedBatch(batchId) defer rb.EndNestedBatch(batchId)
subs := rb.session.MetadataSubscriptions() subs := rb.session.MetadataSubscriptions()
chname := channel.Name()
values := target.ListMetadata() values := channel.ListMetadata()
for k, v := range values { for k, v := range values {
if subs.Has(k) { if subs.Has(k) {
visibility := "*" visibility := "*"
rb.Add(nil, server.name, "METADATA", target.Name(), k, visibility, v) rb.Add(nil, server.name, "METADATA", chname, k, visibility, v)
} }
} }
for _, client := range target.Members() { for _, client := range channel.Members() {
values := client.ListMetadata() values := client.ListMetadata()
for k, v := range values { for k, v := range values {
if subs.Has(k) { if subs.Has(k) {