add primitive reconnect backoff

internal/config/config.go

@@ -83,9 +83,10 @@ type LoggingConfig struct {
 }
 
 type SungrowConfig struct {
-	Host     string `validate:"required"`
-	Username string
-	Password string
+	Host           string `validate:"required"`
+	Username       string
+	Password       string
+	ReconnectTries uint
 }
 
 type Config struct {
@@ -142,8 +143,9 @@ func loadDefaults(v *viper.Viper) error {
 			Format: AutoLoggingFormat,
 		},
 		Sungrow: SungrowConfig{
-			Username: "user",
-			Password: "pw1111",
+			Username:       "user",
+			Password:       "pw1111",
+			ReconnectTries: 3,
 		},
 	}
 

internal/serve/serve.go

@@ -12,7 +12,13 @@ import (
 func Run(c config.Config) error {
 	logger := zerolog.New(c.Logging.Format.Writer()).With().Timestamp().Logger().Level(c.Logging.Level)
 
-	sg := redgiant.NewSungrow(c.Sungrow.Host, c.Sungrow.Username, c.Sungrow.Password, redgiant.WithLogger(logger))
+	sg := redgiant.NewSungrow(
+		c.Sungrow.Host,
+		c.Sungrow.Username,
+		c.Sungrow.Password,
+		redgiant.WithLogger(logger),
+		redgiant.WithReconnect(c.Sungrow.ReconnectTries),
+	)
 	rg := redgiant.NewRedgiant(sg, redgiant.WithLogger(logger))
 
 	if err := rg.Connect(); err != nil {

sungrow.go

@@ -174,17 +174,15 @@ func (s *Sungrow) reconnect() error {
 	s.Close()
 
 	var err error
-	if s.reconnectTries >= 1 {
-
-		for try := range s.reconnectTries {
-			s.log.Info().Uint("try", try).Msg("reconnecting")
-			if err = s.Connect(); err == nil {
-				return nil
-			}
+	for try := range s.reconnectTries {
+		s.log.Info().Uint("try", try).Msg("reconnecting")
+		if err = s.Connect(); err == nil {
+			return nil
 		}
+		// FIXME: implement proper backoff here
+		time.Sleep(time.Second * 20)
 	}
 
-	s.log.Error().Err(err).Msg("unable to reconnect")
 	return newSungrowDisconnectedError("unable to reconnect")
 }