Add thread safety for discord posts

cmd/discord.go

@@ -27,6 +27,7 @@ const (
 type DiscordNotificationService struct {
 	webhookID    string
 	webhookToken string
+	postMutex    *sync.Mutex
 }
 
 func formattedTime(t time.Time) string {
@@ -37,6 +38,7 @@ func NewDiscordNotificationService(webhookID, webhookToken string) *DiscordNotif
 	return &DiscordNotificationService{
 		webhookID:    webhookID,
 		webhookToken: webhookToken,
+		postMutex:    &sync.Mutex{},
 	}
 }
 
@@ -167,23 +169,26 @@ func (service *DiscordNotificationService) UpdateValidatorRealtimeStatus(
 	client := service.client()
 	defer client.Close(ctx)
 	if vm.DiscordStatusMessageID != nil {
-
+		service.postMutex.Lock()
 		_, err := client.UpdateMessage(snowflake.Snowflake(*vm.DiscordStatusMessageID), discord.WebhookMessageUpdate{
 			Embeds: &[]discord.Embed{
 				getCurrentStatsEmbed(stats, vm),
 			},
 		}, rest.WithCtx(ctx))
+		service.postMutex.Unlock()
 		if err != nil {
 			fmt.Printf("Error updating discord message: %v\n", err)
 			return
 		}
 	} else {
+		service.postMutex.Lock()
 		message, err := client.CreateMessage(discord.WebhookMessageCreate{
 			Username: config.Notifications.Discord.Username,
 			Embeds: []discord.Embed{
 				getCurrentStatsEmbed(stats, vm),
 			},
 		}, rest.WithCtx(ctx))
+		service.postMutex.Unlock()
 		if err != nil {
 			fmt.Printf("Error sending discord message: %v\n", err)
 			return
@@ -228,6 +233,7 @@ func (service *DiscordNotificationService) SendValidatorAlertNotification(
 		defer cancel()
 		client := service.client()
 		defer client.Close(ctx)
+		service.postMutex.Lock()
 		_, err := client.CreateMessage(discord.WebhookMessageCreate{
 			Username: config.Notifications.Discord.Username,
 			Content:  toNotify,
@@ -239,6 +245,7 @@ func (service *DiscordNotificationService) SendValidatorAlertNotification(
 				},
 			},
 		}, rest.WithCtx(ctx))
+		service.postMutex.Unlock()
 		if err != nil {
 			fmt.Printf("Error sending discord message: %v\n", err)
 		}
@@ -257,6 +264,7 @@ func (service *DiscordNotificationService) SendValidatorAlertNotification(
 		defer cancel()
 		client := service.client()
 		defer client.Close(ctx)
+		service.postMutex.Lock()
 		_, err := client.CreateMessage(discord.WebhookMessageCreate{
 			Username: config.Notifications.Discord.Username,
 			Content:  toNotify,
@@ -268,6 +276,7 @@ func (service *DiscordNotificationService) SendValidatorAlertNotification(
 				},
 			},
 		}, rest.WithCtx(ctx))
+		service.postMutex.Unlock()
 		if err != nil {
 			fmt.Printf("Error sending discord message: %v\n", err)
 		}

cmd/validator.go

@@ -2,6 +2,7 @@ package cmd
 
 import (
 	"context"
+	"encoding/hex"
 	"fmt"
 	"reflect"
 	"sync"
@@ -34,6 +35,21 @@ func monitorValidator(
 		return
 	}
 
+	addr, err := hex.DecodeString("4658F97E7B70B55D69D26C100C1F9D7CE1B7160C")
+	if err != nil {
+		errs = append(errs, err)
+		return
+	}
+
+	bech32Encoded, err := bech32.ConvertAndEncode("penumbravalcons", addr)
+
+	if err != nil {
+		errs = append(errs, err)
+		return
+	}
+
+	fmt.Printf("Us bech32: %s\n", bech32Encoded)
+
 	valInfo, err := getSigningInfo(client, vm.Address)
 	slashingPeriod := int64(10000)
 	if err != nil {
@@ -89,7 +105,9 @@ func monitorValidator(
 				break
 			}
 			found := false
+			fmt.Printf("Us: %v\n", hexAddress)
 			for _, voter := range block.Block.LastCommit.Signatures {
+				fmt.Printf("Voter: %v\n", voter.ValidatorAddress)
 				if reflect.DeepEqual(voter.ValidatorAddress, bytes.HexBytes(hexAddress)) {
 					if block.Block.Height > stats.LastSignedBlockHeight {
 						stats.LastSignedBlockHeight = block.Block.Height
@@ -121,6 +139,7 @@ func monitorValidator(
 						break
 					}
 					for _, voter := range block.Block.LastCommit.Signatures {
+						fmt.Printf("Voter: %v\n", voter)
 						if reflect.DeepEqual(voter.ValidatorAddress, bytes.HexBytes(hexAddress)) {
 							stats.LastSignedBlockHeight = block.Block.Height
 							stats.LastSignedBlockTimestamp = block.Block.Time