Add signature support, fix #41

config.example.yml

@@ -3,5 +3,7 @@
 targets:
   webhook1:
     url: https://oapi.dingtalk.com/robot/send?access_token=xxxxxxxxxxxx
+    # secret for signature
+    secret: this_is_secret
   webhook2:
     url: https://oapi.dingtalk.com/robot/send?access_token=xxxxxxxxxxxx

config/config.go

@@ -61,5 +61,6 @@ func (c *Config) UnmarshalYAML(unmarshal func(interface{}) error) error {
 }
 
 type Target struct {
-	URL string `yaml:"url"`
+	URL    string `yaml:"url"`
+	Secret string `yaml:"secret"`
 }

notifier/prometheus.go

@@ -2,12 +2,18 @@ package notifier
 
 import (
 	"bytes"
+	"crypto/hmac"
+	"crypto/sha256"
+	"encoding/base64"
 	"encoding/json"
 	"net/http"
+	"net/url"
+	"strconv"
 	"time"
 
 	"github.com/pkg/errors"
 
+	"github.com/timonwong/prometheus-webhook-dingtalk/config"
 	"github.com/timonwong/prometheus-webhook-dingtalk/models"
 	"github.com/timonwong/prometheus-webhook-dingtalk/template"
 )
@@ -33,30 +39,53 @@ func BuildDingTalkNotification(promMessage *models.WebhookMessage) (*models.Ding
 	return notification, nil
 }
 
-func SendDingTalkNotification(httpClient *http.Client, webhookURL string, notification *models.DingTalkNotification) (*models.DingTalkNotificationResponse, error) {
+func SendDingTalkNotification(httpClient *http.Client, target config.Target, notification *models.DingTalkNotification) (*models.DingTalkNotificationResponse, error) {
 	body, err := json.Marshal(&notification)
 	if err != nil {
 		return nil, errors.Wrap(err, "error encoding DingTalk request")
 	}
 
-	httpReq, err := http.NewRequest("POST", webhookURL, bytes.NewReader(body))
+	targetURL := target.URL
+	// Calculate signature when secret is provided
+	if target.Secret != "" {
+		timestamp := strconv.FormatInt(time.Now().UnixNano()/int64(time.Millisecond), 10)
+		stringToSign := []byte(timestamp + "\n" + target.Secret)
+
+		mac := hmac.New(sha256.New, []byte(target.Secret))
+		mac.Write(stringToSign) // nolint: errcheck
+		signature := base64.StdEncoding.EncodeToString(mac.Sum(nil))
+
+		u, err := url.Parse(targetURL)
+		if err != nil {
+			return nil, errors.Wrap(err, "failed to parse target url")
+		}
+
+		qs := u.Query()
+		qs.Set("timestamp", timestamp)
+		qs.Set("sign", signature)
+		u.RawQuery = qs.Encode()
+
+		targetURL = u.String()
+	}
+
+	httpReq, err := http.NewRequest("POST", targetURL, bytes.NewReader(body))
 	if err != nil {
 		return nil, errors.Wrap(err, "error building DingTalk request")
 	}
 	httpReq.Header.Set("Content-Type", "application/json")
 
-	req, err := httpClient.Do(httpReq)
+	resp, err := httpClient.Do(httpReq)
 	if err != nil {
 		return nil, errors.Wrap(err, "error sending notification to DingTalk")
 	}
-	defer req.Body.Close()
+	defer resp.Body.Close()
 
-	if req.StatusCode != 200 {
-		return nil, errors.Errorf("unacceptable response code %d", req.StatusCode)
+	if resp.StatusCode != 200 {
+		return nil, errors.Errorf("unacceptable response code %d", resp.StatusCode)
 	}
 
 	var robotResp models.DingTalkNotificationResponse
-	enc := json.NewDecoder(req.Body)
+	enc := json.NewDecoder(resp.Body)
 	if err := enc.Decode(&robotResp); err != nil {
 		return nil, errors.Wrap(err, "error decoding response from DingTalk")
 	}

webrouter/dingtalk.go

@@ -58,7 +58,7 @@ func (rs *DingTalkResource) SendNotification(w http.ResponseWriter, r *http.Requ
 		return
 	}
 
-	robotResp, err := notifier.SendDingTalkNotification(rs.HttpClient, target.URL, notification)
+	robotResp, err := notifier.SendDingTalkNotification(rs.HttpClient, target, notification)
 	if err != nil {
 		level.Error(logger).Log("msg", "Failed to send notification", "err", err)
 		http.Error(w, "Bad Request", http.StatusBadRequest)