fix: set up tls for redis when it's enabled

log error when pubsub fail to publish peer information

internal/peer/pubsub_redis.go

@@ -166,7 +166,13 @@ func (p *RedisPubsubPeers) Start() error {
 			case <-ticker.Chan():
 				// publish our presence periodically
 				ctx, cancel := context.WithTimeout(context.Background(), p.Config.GetPeerTimeout())
-				p.PubSub.Publish(ctx, "peers", newPeerCommand(Register, myaddr).marshal())
+				err := p.PubSub.Publish(ctx, "peers", newPeerCommand(Register, myaddr).marshal())
+				if err != nil {
+					p.Logger.Error().WithFields(map[string]interface{}{
+						"error":       err,
+						"hostaddress": myaddr,
+					}).Logf("failed to publish peer address")
+				}
 				cancel()
 			case <-logTicker.Chan():
 				p.Logger.Debug().WithFields(map[string]any{
@@ -191,7 +197,14 @@ func (p *RedisPubsubPeers) stop() {
 		p.Logger.Error().Logf("failed to get public address")
 		return
 	}
-	p.PubSub.Publish(context.Background(), "peers", newPeerCommand(Unregister, myaddr).marshal())
+	err = p.PubSub.Publish(context.Background(), "peers", newPeerCommand(Unregister, myaddr).marshal())
+	if err != nil {
+		p.Logger.Error().WithFields(map[string]interface{}{
+			"error":       err,
+			"hostaddress": myaddr,
+		}).Logf("failed to publish peer address")
+	}
+
 }
 
 func (p *RedisPubsubPeers) GetPeers() ([]string, error) {

pubsub/pubsub_goredis.go

@@ -2,6 +2,7 @@ package pubsub
 
 import (
 	"context"
+	"crypto/tls"
 	"strings"
 	"sync"
 
@@ -69,6 +70,20 @@ func (ps *GoRedisPubSub) Start() error {
 		options.Username = username
 		options.Password = pw
 		options.DB = ps.Config.GetRedisDatabase()
+		useTLS := ps.Config.GetUseTLS()
+		tlsInsecure := ps.Config.GetUseTLSInsecure()
+		if useTLS {
+			tlsConfig := &tls.Config{
+				MinVersion: tls.VersionTLS12,
+			}
+
+			if tlsInsecure {
+				tlsConfig.InsecureSkipVerify = true
+			}
+
+			options.TLSConfig = tlsConfig
+		}
+
 	}
 	client := redis.NewUniversalClient(options)