blob: d3394dda56a63036aad1ac1f990b109aca3a8418 (
plain) (
blame)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
|
package proxy
import (
"encoding/json"
"log"
"os"
"sync"
)
const (
defaultCmdPrefix = ">"
defaultSendInterval = 0.09
defaultUserLimit = 10
defaultAuthBackend = "files"
defaultTelnetAddr = "[::1]:40010"
defaultBindAddr = ":40000"
defaultListInterval = 300
)
var config Config
var configMu sync.RWMutex
// A Config contains information from the configuration file
// that affects the way the proxy works.
type Config struct {
NoPlugins bool
CmdPrefix string
RequirePasswd bool
SendInterval float32
UserLimit int
AuthBackend string
NoTelnet bool
TelnetAddr string
BindAddr string
Servers []struct {
Name string
Addr string
Fallbacks []string
}
ForceDefaultSrv bool
FallbackServers []string
CSMRF struct {
NoCSMs bool
ChatMsgs bool
ItemDefs bool
NodeDefs bool
NoLimitMapRange bool
PlayerList bool
}
MapRange uint32
DropCSMRF bool
Groups map[string][]string
UserGroups map[string]string
List struct {
Enable bool
Addr string
Interval int
Name string
Desc string
URL string
Creative bool
Dmg bool
PvP bool
Game string
FarNames bool
Mods []string
}
}
// Conf returns a copy of the Config used by the proxy.
// Any modifications will not affect the original Config.
func Conf() Config {
configMu.RLock()
defer configMu.RUnlock()
return config
}
// FallbackServers returns a slice of server names that
// a server can fall back to.
func FallbackServers(server string) []string {
configMu.RLock()
defer configMu.RUnlock()
fallbacks := make([]string, 0)
conf := Conf()
// find server
for _, srv := range conf.Servers {
if srv.Name == server {
fallbacks = append(fallbacks, srv.Fallbacks...)
break
}
}
// global fallbacks
if len(conf.FallbackServers) == 0 {
if len(conf.Servers) == 0 {
return fallbacks
}
return append(fallbacks, conf.Servers[0].Name)
} else {
return append(fallbacks, conf.FallbackServers...)
}
return fallbacks
}
// LoadConfig attempts to parse the configuration file.
// It leaves the config unchanged if there is an error
// and returns the error.
func LoadConfig() error {
configMu.Lock()
defer configMu.Unlock()
oldConf := config
config.CmdPrefix = defaultCmdPrefix
config.SendInterval = defaultSendInterval
config.UserLimit = defaultUserLimit
config.AuthBackend = defaultAuthBackend
config.TelnetAddr = defaultTelnetAddr
config.BindAddr = defaultBindAddr
config.FallbackServers = make([]string, 0)
config.Groups = make(map[string][]string)
config.UserGroups = make(map[string]string)
config.List.Interval = defaultListInterval
f, err := os.OpenFile(Path("config.json"), os.O_RDWR|os.O_CREATE, 0666)
if err != nil {
config = oldConf
return err
}
defer f.Close()
if fi, _ := f.Stat(); fi.Size() == 0 {
f.WriteString("{\n\t\n}\n")
f.Seek(0, os.SEEK_SET)
}
decoder := json.NewDecoder(f)
if err := decoder.Decode(&config); err != nil {
config = oldConf
return err
}
log.Print("load config")
return nil
}
|
