mirrors/diun
1
0
Fork 0
mirror of https://github.com/crazy-max/diun.git synced 2026-01-03 11:35:02 +01:00
Code Issues Packages Projects Releases Wiki Activity

Fix Telegram notification error (#162)

Browse Source
This commit is contained in:
CrazyMax
2020-08-28 23:43:24 +02:00
parent a82cef7065
commit 17f72c7bb9
1 changed files with 14 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

19
internal/notif/telegram/telegram.go
View File

@@ -3,6 +3,7 @@ package telegram
import (
"bytes"
"fmt"
"strings"
"text/template"
"github.com/crazy-max/diun/v4/internal/model"
@@ -45,13 +46,13 @@ func (c *Client) Send(entry model.NotifEntry) error {
}
var msgBuf bytes.Buffer
msgTpl := template.Must(template.New("email").Parse(fmt.Sprintf("Docker tag %s which you subscribed to through {{ .Entry.Provider }} provider has been {{ if (eq .Entry.Status \"new\") }}newly added{{ else }}updated{{ end }} on {{ .Meta.Hostname }}.", tagTpl)))
msgTpl := template.Must(template.New("email").Parse(fmt.Sprintf("Docker tag %s which you subscribed to through {{ .Entry.Provider }} provider has been {{ if (eq .Entry.Status \"new\") }}newly added{{ else }}updated{{ end }} on {{ .Hostname }}.", tagTpl)))
if err := msgTpl.Execute(&msgBuf, struct {
Meta model.Meta
Entry model.NotifEntry
Hostname string
Entry model.NotifEntry
}{
Meta: c.meta,
Entry: entry,
Hostname: escapeMarkdown(c.meta.Hostname),
Entry: entry,
}); err != nil {
return err
}
@@ -72,3 +73,11 @@ func (c *Client) Send(entry model.NotifEntry) error {
return nil
}
func escapeMarkdown(txt string) string {
txt = strings.ReplaceAll(txt, "_", "\\_")
txt = strings.ReplaceAll(txt, "*", "\\*")
txt = strings.ReplaceAll(txt, "[", "\\[")
txt = strings.ReplaceAll(txt, "`", "\\`")
return txt
}