This commit is contained in:
Ming Deng
2020-11-09 22:43:49 +08:00
parent fb12e1f743
commit 2a6fadb9ae
2 changed files with 52 additions and 6 deletions

View File

@@ -1,10 +1,10 @@
package logs
import (
"bytes"
"encoding/json"
"fmt"
"net/http"
"net/url"
"github.com/pkg/errors"
)
@@ -25,8 +25,8 @@ func newSLACKWriter() Logger {
}
func (s *SLACKWriter) Format(lm *LogMsg) string {
text := fmt.Sprintf("{\"text\": \"%s %s\"}", lm.When.Format("2006-01-02 15:04:05"), lm.OldStyleFormat())
return text
// text := fmt.Sprintf("{\"text\": \"%s\"}", msg)
return lm.When.Format("2006-01-02 15:04:05") + " " + lm.OldStyleFormat()
}
func (s *SLACKWriter) SetFormatter(f LogFormatter) {
@@ -55,10 +55,12 @@ func (s *SLACKWriter) WriteMsg(lm *LogMsg) error {
return nil
}
msg := s.Format(lm)
form := url.Values{}
form.Add("payload", msg)
m := make(map[string]string, 1)
m["text"] = msg
resp, err := http.PostForm(s.WebhookURL, form)
body, _ := json.Marshal(m)
// resp, err := http.PostForm(s.WebhookURL, form)
resp, err := http.Post(s.WebhookURL, "application/json", bytes.NewReader(body))
if err != nil {
return err
}