logger.Error("empty args")
break
}
+ seen = time.Now()
switch cmd := string(args[0]); cmd {
case vors.CmdPing:
- seen = time.Now()
peer.tx <- vors.ArgsEncode([]byte(vors.CmdPong))
+ case vors.CmdMuted:
+ peer.muted = true
+ s := vors.ArgsEncode([]byte(vors.CmdMuted), []byte{peer.sid})
+ for _, p := range room.peers {
+ if p.sid == peer.sid {
+ continue
+ }
+ go func(tx chan []byte) { tx <- s }(p.tx)
+ }
+ case vors.CmdUnmuted:
+ peer.muted = false
+ s := vors.ArgsEncode([]byte(vors.CmdUnmuted), []byte{peer.sid})
+ for _, p := range room.peers {
+ if p.sid == peer.sid {
+ continue
+ }
+ go func(tx chan []byte) { tx <- s }(p.tx)
+ }
default:
logger.Error("unknown", "cmd", cmd)
}