oss/FrankerFaceZ
oss/FrankerFaceZ
1
0
Fork 0
mirror of https://github.com/FrankerFaceZ/FrankerFaceZ.git synced 2025-09-04 12:20:56 +00:00
Code Wiki Activity

Add publish command

Browse source
This commit is contained in:
Kane York 2015-10-28 17:24:21 -07:00
parent 43d596ad07
commit 014e7bc5e5
1 changed files with 25 additions and 0 deletions
Download patch file Download diff file Expand all files Collapse all files

25
socketserver/cmd/ffzsocketserver/console.go
View file

@ -5,6 +5,8 @@ import (
"fmt" "fmt"
"github.com/abiosoft/ishell" "github.com/abiosoft/ishell"
"runtime" "runtime"
"strings"
"github.com/gorilla/websocket"
) )
func commandLineConsole() { func commandLineConsole() {
@ -28,6 +30,28 @@ func commandLineConsole() {
return "Message sent.", nil return "Message sent.", nil
}) })
shell.Register("publish", func(args ...string) (string, error) {
if len(args) < 4 {
return "Usage: publish [room.sirstendec | _ALL] -1 reload_ff 23", nil
}
target := args[0]
line := strings.Join(args[1:], " ")
msg := server.ClientMessage{}
err := server.UnmarshalClientMessage([]byte(line), websocket.TextMessage, &msg)
if err != nil {
return "", err
}
var count int
if target == "_ALL" {
count = server.PublishToAll(msg)
} else {
count = server.PublishToChat(target, msg)
}
return fmt.Sprintf("Published to %d clients", count), nil
})
shell.Register("memstatsbysize", func(args ...string) (string, error) { shell.Register("memstatsbysize", func(args ...string) (string, error) {
runtime.GC() runtime.GC()
@ -45,3 +69,4 @@ func commandLineConsole() {
shell.Start() shell.Start()
} }