Первая попытка модификации саммари (#14)

* Куча проблем

* прикрепил аттачменты

* gitignore

* Delete .gitignore

* asdf

* fix config

* рабочий ресивер

* Vladimir EDITED

* рабочая логика(почти)

* добавил проверки на резолв, добавил очистку

* добавил бесконечный цикл для очистки

* Delete slack.tmpl

* fix old mistakes

* fix gorutine, islomal logic

* поправил горутину, логику наполнения массива ТСок, переопределение значений алертов в сторадже

* Внес небольшие правки в форматирование и поправил пару багов

* add ci

* add ci

* add ci

* почистил конфиг от лишних полей, добавил логику here

* fix merge conflicts ci

* удалил говнокод

* подумать еще над here

* ignore tempalte

* пытаюсь в блоки

* Add blocks

* fix url encode

* add mentions

* fix mentions

* дебаг на проде

* добавил каст для старых алертов

* add divider

* удалил старый код

* Первая попытка модификации саммари

* небольшая косметика

* Update summary merger

* добавил обрезку длинны саммари до 500 строк

Co-authored-by: Vladimir Buyanov <b.vladimir@clickadu.com>

Author: AlexandrClick

config/notifiers.go

@@ -396,7 +396,7 @@ func (c *SlackConfig) UnmarshalYAML(unmarshal func(interface{}) error) error {
 type SlackConfigV2 struct {
 	NotifierConfig `yaml:",inline" json:",inline"`
 
-	Token        string         `yaml:"token,omitempty" json:"token,omitempty"`
+	Token        Secret         `yaml:"token,omitempty" json:"token,omitempty"`
 	Channel      string         `yaml:"channel,omitempty" json:"channel,omitempty"`
 	Color        string         `yaml:"color,omitempty" json:"color,omitempty"`
 	Debug        bool           `yaml:"debug" json:"debug"`

notify/slackV2/blocks.go

@@ -127,12 +127,16 @@ func (n *Notifier) formatMessage(data *template.Data) slack.Blocks {
 		if val := getMapValue(data.CommonAnnotations, "summary"); len(val) > 0 {
 			block.Elements = append(block.Elements, &Element{Type: slack.MarkdownType, Text: fmt.Sprintf("*Summary:* %s", val)})
 		} else {
+			summary := make([]string, 0)
 			for _, al := range data.Alerts {
 				if val, ok := al.Annotations["summary"]; ok && len(val) > 0 {
-					block.Elements = append(block.Elements, &Element{Type: slack.MarkdownType, Text: fmt.Sprintf("*Summary:* %s", val)})
-					break
+					summary = append(summary, val)
 				}
 			}
+			summary = mergeSameMessages(summary)
+			if len(summary) > 0 {
+				block.Elements = append(block.Elements, &Element{Type: slack.MarkdownType, Text: fmt.Sprintf("*Summary:* %s", cut(strings.Join(summary, ";\n"), 500))})
+			}
 		}
 
 		if val := getMapValue(data.CommonAnnotations, "description"); len(val) > 0 {

notify/slackV2/slackV2.go

@@ -45,7 +45,7 @@ type Data struct {
 
 // New returns a new Slack notification handler.
 func New(c *config.SlackConfigV2, t *template.Template, l log.Logger) (*Notifier, error) {
-	token := c.Token
+	token := string(c.Token)
 	client := slack.New(token, slack.OptionDebug(c.Debug))
 
 	notifier := &Notifier{

notify/slackV2/utils.go

@@ -1,6 +1,11 @@
 package slackV2
 
-import "github.com/prometheus/alertmanager/template"
+import (
+	"github.com/prometheus/alertmanager/template"
+	"unicode/utf8"
+)
+
+const SummaryMessageDiffThreshold = 3
 
 func UniqStr(input []string) []string {
 	u := make([]string, 0, len(input))
@@ -22,3 +27,81 @@ func getMapValue(data template.KV, key string) string {
 		return ""
 	}
 }
+
+func levenshteinDistance(s1, s2 string) int {
+	if len(s1) == 0 {
+		return utf8.RuneCountInString(s2)
+	} else if len(s2) == 0 {
+		return utf8.RuneCountInString(s1)
+	} else if s1 == s2 {
+		return 0
+	}
+
+	min := func(values ...int) int {
+		m := values[0]
+		for _, v := range values {
+			if v < m {
+				m = v
+			}
+		}
+		return m
+	}
+	r1, r2 := []rune(s1), []rune(s2)
+	n, m := len(r1), len(r2)
+	if n > m {
+		r1, r2 = r2, r1
+		n, m = m, n
+	}
+	currentRow := make([]int, n+1)
+	previousRow := make([]int, n+1)
+	for i := range currentRow {
+		currentRow[i] = i
+	}
+	for i := 1; i <= m; i++ {
+		for j := range currentRow {
+			previousRow[j] = currentRow[j]
+			if j == 0 {
+				currentRow[j] = i
+				continue
+			} else {
+				currentRow[j] = 0
+			}
+			add, del, change := previousRow[j]+1, currentRow[j-1]+1, previousRow[j-1]
+			if r1[j-1] != r2[i-1] {
+				change++
+			}
+			currentRow[j] = min(add, del, change)
+		}
+	}
+	return currentRow[n]
+}
+
+func mergeSameMessages(arr []string) []string {
+	result := make([]string, 0)
+	if len(arr) > 0 {
+		result = append(result, arr[0])
+	}
+
+	for _, val := range arr {
+		differs := 0
+		for _, res := range result {
+			if levenshteinDistance(val, res) > SummaryMessageDiffThreshold {
+				differs++
+			}
+		}
+		if differs == len(result) {
+			result = append(result, val)
+		}
+	}
+
+	result = UniqStr(result)
+	return result
+}
+
+func cut(text string, limit int) string {
+	runes := []rune(text)
+	if len(runes) >= limit {
+		return string(runes[:limit])
+	}
+	return text
+}