feat: add discord /missing proper command (#59)

* feat: add discord /missing proper command

* chore: fixed linting

* feat: add discord /validators command

* feat: add missing and validators cmds to /help

.golangci.yml

@@ -54,3 +54,4 @@ linters:
     - durationcheck
     - gocyclo
     - exhaustive
+    - mnd

pkg/reporters/discord/discord.go

@@ -9,6 +9,7 @@ import (
 	statePkg "main/pkg/state"
 	templatesPkg "main/pkg/templates"
 	types "main/pkg/types"
+	"main/pkg/utils"
 	"strings"
 	"sync"
 	"time"
@@ -82,6 +83,7 @@ func (reporter *Reporter) Init() {
 	reporter.Commands = map[string]*Command{
 		"params":      reporter.GetParamsCommand(),
 		"missing":     reporter.GetMissingCommand(),
+		"validators":  reporter.GetValidatorsCommand(),
 		"subscribe":   reporter.GetSubscribeCommand(),
 		"unsubscribe": reporter.GetUnsubscribeCommand(),
 		"status":      reporter.GetStatusCommand(),
@@ -199,16 +201,28 @@ func (reporter *Reporter) Send(report *types.Report) error {
 }
 
 func (reporter *Reporter) BotRespond(s *discordgo.Session, i *discordgo.InteractionCreate, text string) {
-	err := s.InteractionRespond(i.Interaction, &discordgo.InteractionResponse{
+	chunks := utils.SplitStringIntoChunks(text, 2000)
+	firstChunk, rest := chunks[0], chunks[1:]
+
+	if err := s.InteractionRespond(i.Interaction, &discordgo.InteractionResponse{
 		Type: discordgo.InteractionResponseChannelMessageWithSource,
 		Data: &discordgo.InteractionResponseData{
-			Content: text,
+			Content: firstChunk,
 		},
-	})
-
-	if err != nil {
+	}); err != nil {
 		reporter.Logger.Error().Err(err).Msg("Error sending response")
 	}
+
+	for index, chunk := range rest {
+		if _, err := s.FollowupMessageCreate(i.Interaction, false, &discordgo.WebhookParams{
+			Content: chunk,
+		}); err != nil {
+			reporter.Logger.Error().
+				Int("chunk", index).
+				Err(err).
+				Msg("Error sending followup message")
+		}
+	}
 }
 
 func (reporter *Reporter) SerializeDate(date time.Time) string {

pkg/reporters/discord/help.go

@@ -24,14 +24,7 @@ func (reporter *Reporter) GetHelpCommand() *Command {
 				return
 			}
 
-			if err = s.InteractionRespond(i.Interaction, &discordgo.InteractionResponse{
-				Type: discordgo.InteractionResponseChannelMessageWithSource,
-				Data: &discordgo.InteractionResponseData{
-					Content: template,
-				},
-			}); err != nil {
-				reporter.Logger.Error().Err(err).Msg("Error sending help")
-			}
+			reporter.BotRespond(s, i, template)
 		},
 	}
 }

pkg/reporters/discord/missing.go

@@ -66,18 +66,7 @@ func (reporter *Reporter) GetMissingCommand() *Command {
 				return
 			}
 
-			chunks := utils.SplitStringIntoChunks(template, 2000)
-
-			for _, chunk := range chunks {
-				if err = s.InteractionRespond(i.Interaction, &discordgo.InteractionResponse{
-					Type: discordgo.InteractionResponseChannelMessageWithSource,
-					Data: &discordgo.InteractionResponseData{
-						Content: chunk,
-					},
-				}); err != nil {
-					reporter.Logger.Error().Err(err).Msg("Error sending missing")
-				}
-			}
+			reporter.BotRespond(s, i, template)
 		},
 	}
 }

pkg/reporters/discord/params.go

@@ -36,14 +36,7 @@ func (reporter *Reporter) GetParamsCommand() *Command {
 				return
 			}
 
-			if err = s.InteractionRespond(i.Interaction, &discordgo.InteractionResponse{
-				Type: discordgo.InteractionResponseChannelMessageWithSource,
-				Data: &discordgo.InteractionResponseData{
-					Content: template,
-				},
-			}); err != nil {
-				reporter.Logger.Error().Err(err).Msg("Error sending params")
-			}
+			reporter.BotRespond(s, i, template)
 		},
 	}
 }

pkg/reporters/discord/validators.go

@@ -0,0 +1,67 @@
+package discord
+
+import (
+	"fmt"
+	"main/pkg/constants"
+	snapshotPkg "main/pkg/snapshot"
+	"main/pkg/utils"
+	"sort"
+
+	"github.com/bwmarrin/discordgo"
+)
+
+func (reporter *Reporter) GetValidatorsCommand() *Command {
+	return &Command{
+		Info: &discordgo.ApplicationCommand{
+			Name:        "validators",
+			Description: "Get the list of all validators and their missing blocks",
+		},
+		Handler: func(s *discordgo.Session, i *discordgo.InteractionCreate) {
+			reporter.MetricsManager.LogReporterQuery(reporter.Config.Name, constants.TelegramReporterName, "validators")
+
+			snapshot, found := reporter.SnapshotManager.GetNewerSnapshot()
+			if !found {
+				reporter.Logger.Info().
+					Msg("No older snapshot on discord validators query!")
+				reporter.BotRespond(s, i, "Error getting validators list")
+				return
+			}
+
+			validatorEntries := snapshot.Entries.ToSlice()
+			activeValidatorsEntries := utils.Filter(validatorEntries, func(v snapshotPkg.Entry) bool {
+				return v.Validator.Active()
+			})
+
+			sort.Slice(activeValidatorsEntries, func(firstIndex, secondIndex int) bool {
+				first := activeValidatorsEntries[firstIndex]
+				second := activeValidatorsEntries[secondIndex]
+
+				return first.SignatureInfo.GetNotSigned() < second.SignatureInfo.GetNotSigned()
+			})
+
+			render := missingValidatorsRender{
+				Config: reporter.Config,
+				Validators: utils.Map(activeValidatorsEntries, func(v snapshotPkg.Entry) missingValidatorsEntry {
+					link := reporter.Config.ExplorerConfig.GetValidatorLink(v.Validator)
+					group, _, _ := reporter.Config.MissedBlocksGroups.GetGroup(v.SignatureInfo.GetNotSigned())
+					link.Text = fmt.Sprintf("%s %s", group.EmojiEnd, v.Validator.Moniker)
+
+					return missingValidatorsEntry{
+						Validator:    v.Validator,
+						Link:         link,
+						NotSigned:    v.SignatureInfo.GetNotSigned(),
+						BlocksWindow: reporter.Config.BlocksWindow,
+					}
+				}),
+			}
+
+			template, err := reporter.TemplatesManager.Render("Validators", render)
+			if err != nil {
+				reporter.Logger.Error().Err(err).Msg("Error rendering missing")
+				return
+			}
+
+			reporter.BotRespond(s, i, template)
+		},
+	}
+}

templates/discord/Help.md

@@ -10,7 +10,7 @@ The bot can understand the following commands:
 - </subscribe:{{ .Commands.subscribe.Info.ID }}> [validator address] - subscribe to validator's notifications
 - </unsubscribe:{{ .Commands.unsubscribe.Info.ID }}> [validator address] - unsubscribe from validator's notifications
 - </status:{{ .Commands.status.Info.ID }}> - see the notification on validators you are subscribed to
-- /missing - see the missed blocks counter of validators missing blocks
-- /validators - see the missed blocks counter of all validators
+- </missing:{{ .Commands.missing.Info.ID }}> - see the missed blocks counter of validators missing blocks
+- </validators:{{ .Commands.validators.Info.ID }}> - see the missed blocks counter of all validators
 - </params:{{ .Commands.params.Info.ID }}> - see the app config and chain params
 - </notifiers:{{ .Commands.notifiers.Info.ID }}> - see notifiers for each validator

templates/discord/Status.md

@@ -10,4 +10,4 @@ You are subscribed to the following validators' updates on {{ .ChainConfig.GetNa
 {{- else -}}
 **{{ SerializeLink .Link }}** ({{ $render.FormatVotingPower . }}): {{ .SigningInfo.GetNotSigned }} missed blocks ({{ $render.FormatNotSignedPercent . }}%)
 {{- end -}}
-{{ end }}
+{{ end }}

templates/discord/Validators.md

@@ -0,0 +1,8 @@
+{{- if not .Validators }}
+There are no active validators on {{ .Config.GetName }}!
+{{- else }}
+**Validators' status on {{ .Config.GetName }}:**
+{{- end }}
+{{ range .Validators -}}
+**{{ SerializeLink .Link }}**: {{ .NotSigned }} missed blocks ({{ .FormatMissed }}%)
+{{ end }}