add more nats debug

agent/agent.go

@@ -40,35 +40,37 @@ import (
 
 // Agent struct
 type Agent struct {
-	Hostname      string
+	Hostname          string
-	Arch          string
+	Arch              string
-	AgentID       string
+	AgentID           string
-	BaseURL       string
+	BaseURL           string
-	ApiURL        string
+	ApiURL            string
-	Token         string
+	Token             string
-	AgentPK       int
+	AgentPK           int
-	Cert          string
+	Cert              string
-	ProgramDir    string
+	ProgramDir        string
-	EXE           string
+	EXE               string
-	SystemDrive   string
+	SystemDrive       string
-	MeshInstaller string
+	MeshInstaller     string
-	MeshSystemEXE string
+	MeshSystemEXE     string
-	MeshSVC       string
+	MeshSVC           string
-	PyBin         string
+	PyBin             string
-	Headers       map[string]string
+	Headers           map[string]string
-	Logger        *logrus.Logger
+	Logger            *logrus.Logger
-	Version       string
+	Version           string
-	Debug         bool
+	Debug             bool
-	rClient       *resty.Client
+	rClient           *resty.Client
-	Proxy         string
+	Proxy             string
-	LogTo         string
+	LogTo             string
-	LogFile       *os.File
+	LogFile           *os.File
-	Platform      string
+	Platform          string
-	GoArch        string
+	GoArch            string
-	ServiceConfig *service.Config
+	ServiceConfig     *service.Config
-	NatsServer    string
+	NatsServer        string
-	NatsProxyPath string
+	NatsProxyPath     string
-	NatsProxyPort string
+	NatsProxyPort     string
+	NatsPingInterval  int
+	NatsWSCompression bool
 }
 
 const (
@@ -171,39 +173,50 @@ func New(logger *logrus.Logger, version string) *Agent {
 
 	// check if using nats standard tcp, otherwise use nats websockets by default
 	var natsServer string
+	var natsWsCompression bool
 	if ac.NatsStandardPort != "" {
 		natsServer = fmt.Sprintf("tls://%s:%s", ac.APIURL, ac.NatsStandardPort)
 	} else {
 		natsServer = fmt.Sprintf("wss://%s:%s", ac.APIURL, natsProxyPort)
+		natsWsCompression = true
+	}
+
+	var natsPingInterval int
+	if ac.NatsPingInterval == 0 {
+		natsPingInterval = randRange(35, 45)
+	} else {
+		natsPingInterval = ac.NatsPingInterval
 	}
 
 	return &Agent{
-		Hostname:      info.Hostname,
+		Hostname:          info.Hostname,
-		BaseURL:       ac.BaseURL,
+		BaseURL:           ac.BaseURL,
-		AgentID:       ac.AgentID,
+		AgentID:           ac.AgentID,
-		ApiURL:        ac.APIURL,
+		ApiURL:            ac.APIURL,
-		Token:         ac.Token,
+		Token:             ac.Token,
-		AgentPK:       ac.PK,
+		AgentPK:           ac.PK,
-		Cert:          ac.Cert,
+		Cert:              ac.Cert,
-		ProgramDir:    pd,
+		ProgramDir:        pd,
-		EXE:           exe,
+		EXE:               exe,
-		SystemDrive:   sd,
+		SystemDrive:       sd,
-		MeshInstaller: "meshagent.exe",
+		MeshInstaller:     "meshagent.exe",
-		MeshSystemEXE: MeshSysExe,
+		MeshSystemEXE:     MeshSysExe,
-		MeshSVC:       meshSvcName,
+		MeshSVC:           meshSvcName,
-		PyBin:         pybin,
+		PyBin:             pybin,
-		Headers:       headers,
+		Headers:           headers,
-		Logger:        logger,
+		Logger:            logger,
-		Version:       version,
+		Version:           version,
-		Debug:         logger.IsLevelEnabled(logrus.DebugLevel),
+		Debug:             logger.IsLevelEnabled(logrus.DebugLevel),
-		rClient:       restyC,
+		rClient:           restyC,
-		Proxy:         ac.Proxy,
+		Proxy:             ac.Proxy,
-		Platform:      runtime.GOOS,
+		Platform:          runtime.GOOS,
-		GoArch:        runtime.GOARCH,
+		GoArch:            runtime.GOARCH,
-		ServiceConfig: svcConf,
+		ServiceConfig:     svcConf,
-		NatsServer:    natsServer,
+		NatsServer:        natsServer,
-		NatsProxyPath: natsProxyPath,
+		NatsProxyPath:     natsProxyPath,
-		NatsProxyPort: natsProxyPort,
+		NatsProxyPort:     natsProxyPort,
+		NatsPingInterval:  natsPingInterval,
+		NatsWSCompression: natsWsCompression,
 	}
 }
 
@@ -399,14 +412,18 @@ func (a *Agent) SyncMeshNodeID() {
 }
 
 func (a *Agent) setupNatsOptions() []nats.Option {
+	reconnectWait := randRange(2, 8)
 	opts := make([]nats.Option, 0)
 	opts = append(opts, nats.Name(a.AgentID))
 	opts = append(opts, nats.UserInfo(a.AgentID, a.Token))
-	opts = append(opts, nats.ReconnectWait(time.Second*5))
+	opts = append(opts, nats.ReconnectWait(time.Duration(reconnectWait)*time.Second))
 	opts = append(opts, nats.RetryOnFailedConnect(true))
+	opts = append(opts, nats.PingInterval(time.Duration(a.NatsPingInterval)*time.Second))
+	opts = append(opts, nats.Compression(a.NatsWSCompression))
 	opts = append(opts, nats.MaxReconnects(-1))
 	opts = append(opts, nats.ReconnectBufSize(-1))
 	opts = append(opts, nats.ProxyPath(a.NatsProxyPath))
+	opts = append(opts, nats.ReconnectJitter(500*time.Millisecond, 4*time.Second))
 	opts = append(opts, nats.DisconnectErrHandler(func(nc *nats.Conn, err error) {
 		a.Logger.Errorln("NATS disconnected:", err)
 		a.Logger.Errorf("%+v\n", nc.Statistics)

agent/agent_unix.go

@@ -158,6 +158,7 @@ func NewAgentConfig() *rmm.AgentConfig {
 		NatsProxyPath:    viper.GetString("natsproxypath"),
 		NatsProxyPort:    viper.GetString("natsproxyport"),
 		NatsStandardPort: viper.GetString("natsstandardport"),
+		NatsPingInterval: viper.GetInt("natspinginterval"),
 	}
 	return ret
 }

agent/agent_windows.go

@@ -65,6 +65,8 @@ func NewAgentConfig() *rmm.AgentConfig {
 	natsProxyPath, _, _ := k.GetStringValue("NatsProxyPath")
 	natsProxyPort, _, _ := k.GetStringValue("NatsProxyPort")
 	natsStandardPort, _, _ := k.GetStringValue("NatsStandardPort")
+	natsPingInterval, _, _ := k.GetStringValue("NatsPingInterval")
+	npi, _ := strconv.Atoi(natsPingInterval)
 
 	return &rmm.AgentConfig{
 		BaseURL:          baseurl,
@@ -79,6 +81,7 @@ func NewAgentConfig() *rmm.AgentConfig {
 		NatsProxyPath:    natsProxyPath,
 		NatsProxyPort:    natsProxyPort,
 		NatsStandardPort: natsStandardPort,
+		NatsPingInterval: npi,
 	}
 }
 

agent/rpc.go

@@ -55,6 +55,8 @@ func (a *Agent) RunRPC() {
 
 	opts := a.setupNatsOptions()
 	nc, err := nats.Connect(a.NatsServer, opts...)
+	a.Logger.Debugf("%+v\n", nc)
+	a.Logger.Debugf("%+v\n", nc.Opts)
 	if err != nil {
 		a.Logger.Fatalln("RunRPC() nats.Connect()", err)
 	}

shared/types.go

@@ -45,6 +45,7 @@ type AgentConfig struct {
 	NatsProxyPath    string
 	NatsProxyPort    string
 	NatsStandardPort string
+	NatsPingInterval int
 }
 
 type RunScriptResp struct {