2014-01-26 14:28:41 +01:00
|
|
|
package main
|
|
|
|
|
|
|
|
import (
|
2014-02-01 20:23:19 +01:00
|
|
|
"encoding/xml"
|
2014-01-26 14:28:41 +01:00
|
|
|
"io"
|
|
|
|
"reflect"
|
|
|
|
"strconv"
|
|
|
|
"strings"
|
|
|
|
)
|
|
|
|
|
2014-02-01 20:23:19 +01:00
|
|
|
type Configuration struct {
|
|
|
|
Version int `xml:"version,attr" default:"1"`
|
|
|
|
Repositories []RepositoryConfiguration `xml:"repository"`
|
|
|
|
Options OptionsConfiguration `xml:"options"`
|
|
|
|
XMLName xml.Name `xml:"configuration" json:"-"`
|
2014-01-26 14:28:41 +01:00
|
|
|
}
|
|
|
|
|
2014-02-01 20:23:19 +01:00
|
|
|
type RepositoryConfiguration struct {
|
|
|
|
Directory string `xml:"directory,attr"`
|
|
|
|
Nodes []NodeConfiguration `xml:"node"`
|
|
|
|
}
|
|
|
|
|
|
|
|
type NodeConfiguration struct {
|
|
|
|
NodeID string `xml:"id,attr"`
|
2014-02-05 22:49:26 +01:00
|
|
|
Name string `xml:"name,attr"`
|
2014-02-01 20:23:19 +01:00
|
|
|
Addresses []string `xml:"address"`
|
|
|
|
}
|
|
|
|
|
|
|
|
type OptionsConfiguration struct {
|
2014-02-05 23:17:17 +01:00
|
|
|
ListenAddress []string `xml:"listenAddress" default:":22000" ini:"listen-address"`
|
|
|
|
ReadOnly bool `xml:"readOnly" ini:"read-only"`
|
|
|
|
AllowDelete bool `xml:"allowDelete" default:"true" ini:"allow-delete"`
|
|
|
|
FollowSymlinks bool `xml:"followSymlinks" default:"true" ini:"follow-symlinks"`
|
|
|
|
GUIEnabled bool `xml:"guiEnabled" default:"true" ini:"gui-enabled"`
|
|
|
|
GUIAddress string `xml:"guiAddress" default:"127.0.0.1:8080" ini:"gui-address"`
|
|
|
|
GlobalAnnServer string `xml:"globalAnnounceServer" default:"syncthing.nym.se:22025" ini:"global-announce-server"`
|
|
|
|
GlobalAnnEnabled bool `xml:"globalAnnounceEnabled" default:"true" ini:"global-announce-enabled"`
|
|
|
|
LocalAnnEnabled bool `xml:"localAnnounceEnabled" default:"true" ini:"local-announce-enabled"`
|
|
|
|
ParallelRequests int `xml:"parallelRequests" default:"16" ini:"parallel-requests"`
|
|
|
|
MaxSendKbps int `xml:"maxSendKbps" ini:"max-send-kbps"`
|
|
|
|
RescanIntervalS int `xml:"rescanIntervalS" default:"60" ini:"rescan-interval"`
|
|
|
|
ReconnectIntervalS int `xml:"reconnectionIntervalS" default:"60" ini:"reconnection-interval"`
|
|
|
|
MaxChangeKbps int `xml:"maxChangeKbps" default:"1000" ini:"max-change-bw"`
|
2014-02-01 20:23:19 +01:00
|
|
|
}
|
|
|
|
|
|
|
|
func setDefaults(data interface{}) error {
|
2014-01-26 14:28:41 +01:00
|
|
|
s := reflect.ValueOf(data).Elem()
|
|
|
|
t := s.Type()
|
|
|
|
|
|
|
|
for i := 0; i < s.NumField(); i++ {
|
|
|
|
f := s.Field(i)
|
|
|
|
tag := t.Field(i).Tag
|
|
|
|
|
2014-02-01 20:23:19 +01:00
|
|
|
v := tag.Get("default")
|
2014-01-26 14:28:41 +01:00
|
|
|
if len(v) > 0 {
|
|
|
|
switch f.Interface().(type) {
|
|
|
|
case string:
|
|
|
|
f.SetString(v)
|
|
|
|
|
2014-02-05 23:17:17 +01:00
|
|
|
case []string:
|
|
|
|
rv := reflect.MakeSlice(reflect.TypeOf([]string{}), 1, 1)
|
|
|
|
rv.Index(0).SetString(v)
|
|
|
|
f.Set(rv)
|
|
|
|
|
2014-01-26 14:28:41 +01:00
|
|
|
case int:
|
|
|
|
i, err := strconv.ParseInt(v, 10, 64)
|
|
|
|
if err != nil {
|
|
|
|
return err
|
|
|
|
}
|
|
|
|
f.SetInt(i)
|
|
|
|
|
|
|
|
case bool:
|
|
|
|
f.SetBool(v == "true")
|
|
|
|
|
|
|
|
default:
|
|
|
|
panic(f.Type())
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
return nil
|
|
|
|
}
|
|
|
|
|
2014-02-01 20:23:19 +01:00
|
|
|
func readConfigINI(m map[string]string, data interface{}) error {
|
2014-01-26 14:28:41 +01:00
|
|
|
s := reflect.ValueOf(data).Elem()
|
|
|
|
t := s.Type()
|
|
|
|
|
|
|
|
for i := 0; i < s.NumField(); i++ {
|
|
|
|
f := s.Field(i)
|
|
|
|
tag := t.Field(i).Tag
|
|
|
|
|
2014-02-01 20:23:19 +01:00
|
|
|
name := tag.Get("ini")
|
|
|
|
if len(name) == 0 {
|
|
|
|
name = strings.ToLower(t.Field(i).Name)
|
|
|
|
}
|
|
|
|
|
|
|
|
if v, ok := m[name]; ok {
|
|
|
|
switch f.Interface().(type) {
|
|
|
|
case string:
|
|
|
|
f.SetString(v)
|
|
|
|
|
|
|
|
case int:
|
|
|
|
i, err := strconv.ParseInt(v, 10, 64)
|
|
|
|
if err == nil {
|
|
|
|
f.SetInt(i)
|
|
|
|
}
|
|
|
|
|
|
|
|
case bool:
|
|
|
|
f.SetBool(v == "true")
|
|
|
|
|
|
|
|
default:
|
|
|
|
panic(f.Type())
|
|
|
|
}
|
2014-01-26 14:28:41 +01:00
|
|
|
}
|
|
|
|
}
|
2014-02-01 20:23:19 +01:00
|
|
|
return nil
|
2014-01-26 14:28:41 +01:00
|
|
|
}
|
|
|
|
|
2014-02-01 20:23:19 +01:00
|
|
|
func writeConfigXML(wr io.Writer, cfg Configuration) error {
|
|
|
|
e := xml.NewEncoder(wr)
|
|
|
|
e.Indent("", " ")
|
|
|
|
err := e.Encode(cfg)
|
|
|
|
if err != nil {
|
|
|
|
return err
|
|
|
|
}
|
|
|
|
_, err = wr.Write([]byte("\n"))
|
|
|
|
return err
|
|
|
|
}
|
|
|
|
|
2014-02-05 23:17:17 +01:00
|
|
|
func uniqueStrings(ss []string) []string {
|
|
|
|
var m = make(map[string]bool, len(ss))
|
|
|
|
for _, s := range ss {
|
|
|
|
m[s] = true
|
|
|
|
}
|
|
|
|
|
|
|
|
var us = make([]string, 0, len(m))
|
|
|
|
for k := range m {
|
|
|
|
us = append(us, k)
|
|
|
|
}
|
|
|
|
|
|
|
|
return us
|
|
|
|
}
|
|
|
|
|
2014-02-01 20:23:19 +01:00
|
|
|
func readConfigXML(rd io.Reader) (Configuration, error) {
|
|
|
|
var cfg Configuration
|
|
|
|
|
|
|
|
setDefaults(&cfg)
|
|
|
|
setDefaults(&cfg.Options)
|
|
|
|
|
|
|
|
var err error
|
|
|
|
if rd != nil {
|
|
|
|
err = xml.NewDecoder(rd).Decode(&cfg)
|
|
|
|
}
|
|
|
|
|
2014-02-05 23:17:17 +01:00
|
|
|
cfg.Options.ListenAddress = uniqueStrings(cfg.Options.ListenAddress)
|
2014-02-01 20:23:19 +01:00
|
|
|
return cfg, err
|
2014-01-26 14:28:41 +01:00
|
|
|
}
|