feat: display details for firing alerts (#2)

* feat: display details for firing alerts

* chore: fixed linting

alertmanager.go

@@ -126,7 +126,7 @@ func (g *AlertmanagerStruct) DoQuery(method string, url string, body interface{}
 		return nil, err
 	}
 
-	if resp.StatusCode >= 400 {
+	if resp.StatusCode >= http.StatusBadRequest {
 		return nil, fmt.Errorf("Could not fetch request. Status code: %d", resp.StatusCode)
 	}
 

alerts_firing.go

@@ -28,21 +28,21 @@ func HandleListFiringAlerts(c tele.Context) error {
 
 	var sb strings.Builder
 	if len(grafanaGroups) > 0 {
-		sb.WriteString("<strong>Grafana alerts</strong>\n")
+		sb.WriteString("<strong>Grafana alerts:</strong>\n")
 		for _, group := range grafanaGroups {
 			for _, rule := range group.Rules {
-				sb.WriteString(rule.Serialize(group.Name))
+				sb.WriteString(rule.SerializeFull(group.Name))
 			}
 		}
 	} else {
 		sb.WriteString("<strong>No Grafana alerts</strong>\n")
 	}
 
 	if len(prometheusGroups) > 0 {
-		sb.WriteString("<strong>Prometheus alerts</strong>\n")
+		sb.WriteString("<strong>Prometheus alerts:</strong>\n")
 		for _, group := range prometheusGroups {
 			for _, rule := range group.Rules {
-				sb.WriteString(rule.Serialize(group.Name))
+				sb.WriteString(rule.SerializeFull(group.Name))
 			}
 		}
 	} else {

alerts_list.go

@@ -25,7 +25,7 @@ func HandleListAlerts(c tele.Context) error {
 
 	var sb strings.Builder
 	if len(grafanaGroups) > 0 {
-		sb.WriteString("<strong>Grafana alerts</strong>\n")
+		sb.WriteString("<strong>Grafana alerts:</strong>\n")
 		for _, group := range grafanaGroups {
 			for _, rule := range group.Rules {
 				sb.WriteString(rule.Serialize(group.Name))
@@ -36,7 +36,7 @@ func HandleListAlerts(c tele.Context) error {
 	}
 
 	if len(prometheusGroups) > 0 {
-		sb.WriteString("<strong>Prometheus alerts</strong>\n")
+		sb.WriteString("<strong>Prometheus alerts:</strong>\n")
 		for _, group := range prometheusGroups {
 			for _, rule := range group.Rules {
 				sb.WriteString(rule.Serialize(group.Name))

grafana.go

@@ -296,7 +296,7 @@ func (g *GrafanaStruct) DoQuery(method string, url string, body interface{}) (io
 		return nil, err
 	}
 
-	if resp.StatusCode >= 400 {
+	if resp.StatusCode >= http.StatusBadRequest {
 		g.Logger.Error().
 			Str("url", url).
 			Str("method", method).

main.go

@@ -1,7 +1,6 @@
 package main
 
 import (
-	"io/ioutil"
 	"os"
 	"time"
 
@@ -33,7 +32,7 @@ func Execute(cmd *cobra.Command, args []string) {
 		log.Fatal().Msg("Cannot start without config")
 	}
 
-	yamlFile, err := ioutil.ReadFile(ConfigPath)
+	yamlFile, err := os.ReadFile(ConfigPath)
 	if err != nil {
 		log.Fatal().Err(err).Msg("Could not read config file")
 	}

types.go

@@ -98,6 +98,7 @@ type GrafanaAlertRule struct {
 type GrafanaAlert struct {
 	Labels map[string]string `json:"labels"`
 	State  string            `json:"state"`
+	Value  string            `json:"value"`
 }
 
 type RenderOptions struct {
@@ -134,6 +135,31 @@ func (alert *GrafanaAlert) Serialize() string {
 	return fmt.Sprintf("- %s <pre>%s</pre>", GetEmojiByStatus(alert.State), SerializeAlertLabels(alert.Labels))
 }
 
+func (rule *GrafanaAlertRule) SerializeFull(groupName string) string {
+	var sb strings.Builder
+
+	sb.WriteString(fmt.Sprintf(
+		"%s %s -> %s (%d):\n",
+		GetEmojiByStatus(rule.State),
+		groupName,
+		rule.Name,
+		len(rule.Alerts),
+	))
+
+	for _, alert := range rule.Alerts {
+		for key, label := range alert.Labels {
+			if key == "alertname" {
+				continue
+			}
+			sb.WriteString(fmt.Sprintf("%s = %s\n", key, label))
+		}
+		sb.WriteString(fmt.Sprintf("value = %.1f\n", StrToFloat64(alert.Value)))
+		sb.WriteString("\n")
+	}
+
+	return sb.String()
+}
+
 func (silence *Silence) Serialize() string {
 	var sb strings.Builder
 	sb.WriteString(fmt.Sprintf("ID:         <code>%s</code>\n", silence.ID))

utils.go

@@ -3,13 +3,14 @@ package main
 import (
 	"fmt"
 	"regexp"
+	"strconv"
 	"strings"
 	"time"
 
 	tele "gopkg.in/telebot.v3"
 )
 
-const MAX_MESSAGE_SIZE = 4096
+const MaxMessageSize = 4096
 
 func NormalizeString(input string) string {
 	reg := regexp.MustCompile("[^a-zA-Z0-9]+")
@@ -148,7 +149,7 @@ func BotReply(c tele.Context, msg string) error {
 	var sb strings.Builder
 
 	for _, line := range msgsByNewline {
-		if sb.Len()+len(line) > MAX_MESSAGE_SIZE {
+		if sb.Len()+len(line) > MaxMessageSize {
 			if err := c.Reply(sb.String(), tele.ModeHTML); err != nil {
 				log.Error().Err(err).Msg("Could not send Telegram message")
 				return err
@@ -280,3 +281,12 @@ func FilterFiringOrPendingAlertGroups(groups []GrafanaAlertGroup) []GrafanaAlert
 
 	return returnGroups
 }
+
+func StrToFloat64(s string) float64 {
+	f, err := strconv.ParseFloat(s, 64)
+	if err != nil {
+		panic(err)
+	}
+
+	return f
+}