8 Commits

Author SHA1 Message Date
dd1d530d44 add img/ 2024-11-04 22:01:01 +00:00
f2752f5609 print usage message if not in interactive mode, and no rcon commands passed 2024-11-04 21:23:45 +00:00
05ee3f1912 reword 2024-11-04 17:46:11 +00:00
a7702c8050 add functional option WithLoginTimeout
use it to set the login timeout
2024-11-04 16:13:31 +00:00
08af9d3388 fix -p flag usage message 2024-11-04 15:30:03 +00:00
46d3e3fa4a left align example snippets 2024-11-04 15:10:12 +00:00
07ffd98e7a remove Logging highlight 2024-11-04 15:05:57 +00:00
bc373e72ae add your own implementation section 2024-11-04 15:05:13 +00:00
5 changed files with 62 additions and 21 deletions

View File

@@ -52,9 +52,21 @@ func main() {
} }
``` ```
#### `WithLoginTimeout(timeout time.Duration)`
If the server was just started or is currently performing a long operation like map rotating then it's possible to receive empty rcon responses. In which case you'll want to retry login. Use this functional option to set the max timeout for logins, it defaults to 5 seconds.
For example:
```go
rcon, err := q3rcon.New(
host, port, password,
q3rcon.WithLoginTimeout(2*time.Second))
```
#### `WithDefaultTimeout(timeout time.Duration)` #### `WithDefaultTimeout(timeout time.Duration)`
You may want to change the default timeout if some of your responses are getting mixed together (stability can depend on connection to the server). For example, on LAN I can leave the default at 20ms, when connecting remotely I normally increase this to 50ms. You may want to change the default timeout if some of your responses are getting mixed together (stability can depend on connection to the server). For example, over localhost I can leave the default at 20ms, when connecting remotely I normally increase this to 50ms.
For example: For example:
@@ -103,8 +115,17 @@ q3rcon -h=localhost -p=30000 -P="rconpassword" -i
If interactive mode is enabled, any arguments sent on the command line will be ignored. If interactive mode is enabled, any arguments sent on the command line will be ignored.
## `Logging` ## Your own implementation
The included CLI is a generic implementation, while it can be used out of the box you may find that some requests result in fragmented responses. The solution is to implement your own version, adjusting the timings with the functional options as detailed above. I could have increased the default timeouts but that would add unnecessary delay for most requests, so I decided to leave those details to the users of the package.
Since you can include the q3rcon package into your own package you can easily make your own modifications, for example, I added [colour to the terminal][status] and [reformatted some of the responses][mapname].
## Logging
Log level may be set by passing the `-l` flag with a number from 0 up to 6 where Log level may be set by passing the `-l` flag with a number from 0 up to 6 where
0 = Panic, 1 = Fatal, 2 = Error, 3 = Warning, 4 = Info, 5 = Debug, 6 = Trace 0 = Panic, 1 = Fatal, 2 = Error, 3 = Warning, 4 = Info, 5 = Debug, 6 = Trace
[status]: ./img/status.png
[mapname]: ./img/mapname.png

View File

@@ -2,6 +2,7 @@ package main
import ( import (
"bufio" "bufio"
"errors"
"flag" "flag"
"fmt" "fmt"
"io" "io"
@@ -16,6 +17,12 @@ import (
var interactive bool var interactive bool
func exit(err error) {
_, _ = fmt.Fprintf(os.Stderr, "Error: %s\n", err)
flag.Usage()
os.Exit(1)
}
func main() { func main() {
var ( var (
host string host string
@@ -28,8 +35,8 @@ func main() {
flag.StringVar(&host, "h", "localhost", "hostname of the server (shorthand)") flag.StringVar(&host, "h", "localhost", "hostname of the server (shorthand)")
flag.IntVar(&port, "port", 28960, "port of the server") flag.IntVar(&port, "port", 28960, "port of the server")
flag.IntVar(&port, "p", 28960, "port of the server (shorthand)") flag.IntVar(&port, "p", 28960, "port of the server (shorthand)")
flag.StringVar(&password, "password", "", "hostname of the server") flag.StringVar(&password, "password", "", "rcon password")
flag.StringVar(&password, "P", "", "hostname of the server (shorthand)") flag.StringVar(&password, "P", "", "rcon password (shorthand)")
flag.BoolVar(&interactive, "interactive", false, "run in interactive mode") flag.BoolVar(&interactive, "interactive", false, "run in interactive mode")
flag.BoolVar(&interactive, "i", false, "run in interactive mode") flag.BoolVar(&interactive, "i", false, "run in interactive mode")
@@ -57,6 +64,11 @@ func main() {
return return
} }
if len(flag.Args()) == 0 {
err = errors.New("no rcon commands passed")
exit(err)
}
for _, arg := range flag.Args() { for _, arg := range flag.Args() {
resp, err := rcon.Send(arg) resp, err := rcon.Send(arg)
if err != nil { if err != nil {
@@ -68,8 +80,7 @@ func main() {
} }
func connectRcon(host string, port int, password string) (*q3rcon.Rcon, error) { func connectRcon(host string, port int, password string) (*q3rcon.Rcon, error) {
rcon, err := q3rcon.New( rcon, err := q3rcon.New(host, port, password)
host, port, password)
if err != nil { if err != nil {
return nil, err return nil, err
} }

BIN
img/mapname.png Normal file

Binary file not shown.

After

Width:  |  Height:  |  Size: 5.4 KiB

BIN
img/status.png Normal file

Binary file not shown.

After

Width:  |  Height:  |  Size: 28 KiB

View File

@@ -12,13 +12,21 @@ import (
// Option is a functional option type that allows us to configure the VbanTxt. // Option is a functional option type that allows us to configure the VbanTxt.
type Option func(*Rcon) type Option func(*Rcon)
// WithLoginTimeout is a functional option to set the login timeout
func WithLoginTimeout(timeout time.Duration) Option {
return func(rcon *Rcon) {
rcon.loginTimeout = timeout
}
}
// WithDefaultTimeout is a functional option to set the default response timeout
func WithDefaultTimeout(timeout time.Duration) Option { func WithDefaultTimeout(timeout time.Duration) Option {
return func(rcon *Rcon) { return func(rcon *Rcon) {
rcon.defaultTimeout = timeout rcon.defaultTimeout = timeout
} }
} }
// WithTimeouts is a functional option to set the timeouts for responses // WithTimeouts is a functional option to set the timeouts for responses per command
func WithTimeouts(timeouts map[string]time.Duration) Option { func WithTimeouts(timeouts map[string]time.Duration) Option {
return func(rcon *Rcon) { return func(rcon *Rcon) {
rcon.timeouts = timeouts rcon.timeouts = timeouts
@@ -30,6 +38,7 @@ type Rcon struct {
request packet.Request request packet.Request
response packet.Response response packet.Response
loginTimeout time.Duration
defaultTimeout time.Duration defaultTimeout time.Duration
timeouts map[string]time.Duration timeouts map[string]time.Duration
@@ -50,6 +59,7 @@ func New(host string, port int, password string, options ...Option) (*Rcon, erro
conn: conn, conn: conn,
request: packet.NewRequest(password), request: packet.NewRequest(password),
resp: make(chan string), resp: make(chan string),
loginTimeout: 5 * time.Second,
defaultTimeout: 20 * time.Millisecond, defaultTimeout: 20 * time.Millisecond,
timeouts: make(map[string]time.Duration), timeouts: make(map[string]time.Duration),
} }
@@ -58,8 +68,7 @@ func New(host string, port int, password string, options ...Option) (*Rcon, erro
o(r) o(r)
} }
err = r.Login() if err = r.Login(); err != nil {
if err != nil {
return nil, err return nil, err
} }
@@ -67,7 +76,7 @@ func New(host string, port int, password string, options ...Option) (*Rcon, erro
} }
func (r Rcon) Login() error { func (r Rcon) Login() error {
timeout := time.After(2 * time.Second) timeout := time.After(r.loginTimeout)
for { for {
select { select {
case <-timeout: case <-timeout: