diff --git a/socketserver/cmd/ffzsocketserver/console.go b/socketserver/cmd/ffzsocketserver/console.go index 93c95987..d22ba178 100644 --- a/socketserver/cmd/ffzsocketserver/console.go +++ b/socketserver/cmd/ffzsocketserver/console.go @@ -6,7 +6,8 @@ import ( "strconv" "strings" - "../../server" + "github.com/FrankerFaceZ/FrankerFaceZ/socketserver/server" + "github.com/FrankerFaceZ/FrankerFaceZ/socketserver/server/rate" "github.com/abiosoft/ishell" "github.com/gorilla/websocket" ) @@ -33,7 +34,7 @@ func commandLineConsole() { Command: "message", Arguments: args[0], } - server.PublishToAll(msg) + server.PublishToAll(msg, rate.Unlimited()) return "Message sent.", nil }) @@ -52,9 +53,9 @@ func commandLineConsole() { var count int if target == "_ALL" { - count = server.PublishToAll(msg) + count = server.PublishToAll(msg, rate.Unlimited()) } else { - count = server.PublishToChannel(target, msg) + count = server.PublishToChannel(target, msg, rate.Unlimited()) } return fmt.Sprintf("Published to %d clients", count), nil }) diff --git a/socketserver/cmd/ffzsocketserver/socketserver.go b/socketserver/cmd/ffzsocketserver/socketserver.go index 1d67bddc..312d38c5 100644 --- a/socketserver/cmd/ffzsocketserver/socketserver.go +++ b/socketserver/cmd/ffzsocketserver/socketserver.go @@ -1,4 +1,4 @@ -package main // import "bitbucket.org/stendec/frankerfacez/socketserver/cmd/ffzsocketserver" +package main // import "github.com/FrankerFaceZ/FrankerFaceZ/socketserver/cmd/ffzsocketserver" import ( "encoding/json" @@ -9,7 +9,7 @@ import ( "net/http" "os" - "../../server" + "github.com/FrankerFaceZ/FrankerFaceZ/socketserver/server" ) import _ "net/http/pprof"