tag 추가

This commit is contained in:
2023-07-11 15:26:13 +09:00
parent 4acb81a20d
commit 74829b93ac

View File

@ -55,6 +55,7 @@ func (r *room) loop(ctx context.Context, conns *map[string]*wsconn) (normalEnd b
} }
}() }()
tag := "#" + r.name
for { for {
select { select {
case <-ctx.Done(): case <-ctx.Done():
@ -70,7 +71,7 @@ func (r *room) loop(ctx context.Context, conns *map[string]*wsconn) (normalEnd b
ds := DownstreamMessage{ ds := DownstreamMessage{
Alias: msg.Alias, Alias: msg.Alias,
Body: msg.Body, Body: msg.Body,
Tag: append(msg.Tag, r.name), Tag: append(msg.Tag, tag),
} }
bt, _ := json.Marshal(ds) bt, _ := json.Marshal(ds)