onyx_online/q3rcon-proxy
1
0
Fork 0
mirror of https://github.com/onyx-and-iris/q3rcon-proxy.git synced 2025-10-31 04:41:48 +00:00
Code Issues Packages Projects Releases Wiki Activity

read from env var Q3RCON_STALE_SESSION_TIMEOUT

Browse Source
This commit is contained in:
onyx-and-iris 2024-10-19 21:19:33 +01:00
parent 64c1df645d
commit c42df03858
1 changed files with 12 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
cmd/q3rcon-proxy/main.go
View File

@ -5,6 +5,7 @@ import (
"os" "os"
"slices" "slices"
"strings" "strings"
"time"
log "github.com/sirupsen/logrus" log "github.com/sirupsen/logrus"
@ -30,20 +31,28 @@ func main() {
host = "0.0.0.0" host = "0.0.0.0"
} }
staleTimeout, err := getEnvInt("Q3RCON_STALE_SESSION_TIMEOUT")
if err != nil {
log.Fatalf("unable to parse Q3RCON_STALE_SESSION_TIMEOUT: %s", err.Error())
}
for _, proxy := range strings.Split(proxies, ";") { for _, proxy := range strings.Split(proxies, ";") {
go start(host, proxy) go start(host, proxy, staleTimeout)
} }
<-make(chan int) <-make(chan int)
} }
func start(host, proxy string) { func start(host, proxy string, staleTimeout int) {
port, target := func() (string, string) { port, target := func() (string, string) {
x := strings.Split(proxy, ":") x := strings.Split(proxy, ":")
return x[0], x[1] return x[0], x[1]
}() }()
c, err := udpproxy.New(fmt.Sprintf("%s:%s", host, port), fmt.Sprintf("127.0.0.1:%s", target)) c, err := udpproxy.New(
fmt.Sprintf("%s:%s", host, port),
fmt.Sprintf("127.0.0.1:%s", target),
udpproxy.WithStaleTimeout(time.Duration(staleTimeout)*time.Minute))
if err != nil { if err != nil {
log.Fatal(err) log.Fatal(err)
} }