10 "github.com/Sirupsen/logrus"
11 "github.com/iotbzh/xds-server/lib/common"
12 "github.com/syncthing/syncthing/lib/config"
16 type SyncThing struct {
18 client *common.HTTPClient
22 // NewSyncThing creates a new instance of Syncthing
23 func NewSyncThing(url string, apikey string, log *logrus.Logger) *SyncThing {
24 cl, err := common.HTTPNewClient(url,
25 common.HTTPClientConfig{
27 HeaderClientKeyName: "X-Syncthing-ID",
30 msg := ": " + err.Error()
31 if strings.Contains(err.Error(), "connection refused") {
32 msg = fmt.Sprintf("(url: %s)", url)
34 log.Debugf("ERROR: cannot connect to Syncthing %s", msg)
47 // IDGet returns the Syncthing ID of Syncthing instance running locally
48 func (s *SyncThing) IDGet() (string, error) {
50 if err := s.client.HTTPGet("system/status", &data); err != nil {
53 status := make(map[string]interface{})
54 json.Unmarshal(data, &status)
55 return status["myID"].(string), nil
58 // ConfigGet returns the current Syncthing configuration
59 func (s *SyncThing) ConfigGet() (config.Configuration, error) {
61 config := config.Configuration{}
62 if err := s.client.HTTPGet("system/config", &data); err != nil {
65 err := json.Unmarshal(data, &config)
69 // ConfigSet set Syncthing configuration
70 func (s *SyncThing) ConfigSet(cfg config.Configuration) error {
71 body, err := json.Marshal(cfg)
75 return s.client.HTTPPost("system/config", string(body))