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
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
|
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
var loadConfigOnce sync.Once
type Server struct {
Name string
Addr string
Fallbacks []string
}
// 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 []Server
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 {
loadConfigOnce.Do(func() {
if err := LoadConfig(); err != nil {
log.Fatal(err)
}
})
configMu.RLock()
defer configMu.RUnlock()
return config
}
// AddServer dynamically configures a new Server at runtime.
// Servers added in this way are ephemeral and will be lost
// when the proxy shuts down.
// For the media to work you have to specify an alternative
// media source that is always available, even if the server
// is offline.
// WARNING: Reloading the configuration file deletes the
// servers added using this function.
func AddServer(server Server) bool {
configMu.Lock()
defer configMu.Unlock()
for _, srv := range config.Servers {
if srv.Name == server.Name {
return false
}
}
config.Servers = append(config.Servers, server)
return true
}
// RmServer deletes a Server from the Config at runtime.
// Any server can be deleted this way, not just the ones
// added using AddServer.
// WARNING: Reloading the configuration files re-adds the
// servers it contains that were deleted using this function.
func RmServer(name string) {
configMu.Lock()
defer configMu.Unlock()
for i, srv := range config.Servers {
if srv.Name == name {
config.Servers = append(config.Servers[:i], config.Servers[1+i:]...)
return
}
}
}
// 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...)
}
}
// 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
}
|
