<feature>add dingding alter support

Author: lawlielt

action/action.go

@@ -7,6 +7,7 @@ import (
 	"encoding/json"
 	"errors"
 	"fmt"
+	"io/ioutil"
 	"net/http"
 	"strings"
 
@@ -50,6 +51,8 @@ func ToActioner(in interface{}) (Action, error) {
 		a = &HTTP{}
 	case "slack":
 		a = &Slack{}
+	case "dingding":
+		a = &DingDing{}
 	default:
 		return Action{}, fmt.Errorf("unknown action type: %q", typ)
 	}
@@ -142,3 +145,51 @@ func (s *Slack) Do(c context.Context) error {
 	resp.Body.Close()
 	return nil
 }
+
+type DingDing struct {
+	Text string `json:"text" mapstructure:"text"`
+}
+
+func (d *DingDing) Do(c context.Context) error {
+	if config.Opts.DingDingWebhook == "" {
+		return errors.New("DingDing Webhook not set in config")
+	}
+
+	if d.Text == "" {
+		return errors.New("missing required field text in DingDing")
+	}
+
+	r, err := http.NewRequest("POST", config.Opts.DingDingWebhook, bytes.NewBufferString(d.Text))
+    if err != nil {
+    	return err
+	}
+	r.Header.Set("Content-Type", "application/json;charset=utf-8")
+
+
+	resp, err := http.DefaultClient.Do(r)
+	if err != nil {
+		return err
+	}
+
+	defer resp.Body.Close()
+
+	if resp.StatusCode < 200 || resp.StatusCode > 299 {
+		return fmt.Errorf("non 2xx response code returned: %d", resp.StatusCode)
+	}
+
+	type response struct {
+		ErrCode uint `json:"errcode"`
+		ErrMsg string `json:"errmsg"`
+	}
+	var res response
+	body, err := ioutil.ReadAll(resp.Body)
+	if err != nil {
+		return err
+	}
+    err = json.Unmarshal(body, &res)
+	if res.ErrCode != 0 {
+		return fmt.Errorf("response error: %s", res.ErrMsg)
+	}
+	return nil
+
+}

cmd/esalert/main.go

@@ -1,7 +1,6 @@
 package main
 
 import (
-	"fmt"
 	"io/ioutil"
 	"os"
 	"path/filepath"
@@ -22,7 +21,7 @@ func main() {
 	}
 
 	files := make([]string, 0, 10)
-	if !fstat.IsDir() {
+	if fstat != nil && !fstat.IsDir() {
 		files = append(files, config.Opts.AlertFileDir)
 	} else {
 		fileInfos, err := ioutil.ReadDir(config.Opts.AlertFileDir)
@@ -49,7 +48,6 @@ func main() {
 			log.WithFields(kv).Fatalln("failed to read alert config")
 		}
 
-		fmt.Println(file)
 		if err := yaml.Unmarshal(b, &alerts); err != nil {
 			kv["err"] = err
 			log.WithFields(kv).Fatalln("failed to parse yaml")

config/config.go

@@ -24,6 +24,7 @@ var Opts struct {
 	SlackWebhook      string `long:"slack-webhook" description:"Slack webhook url, required if using any Slack actions"`
 	ForceRun          string `long:"force-run" description:"If set with the name of an alert, will immediately run that alert and exit. Useful for testing changes to alert definitions"`
 	LogLevel          string `long:"log-level" default:"info" description:"Adjust the log level. Valid options are: error, warn, info, debug"`
+	DingDingWebhook string `long:"dingding-webhook" description:"dingding webhook url, required if using any Dingding action"`
 }
 
 func init() {