webhook.go

package controllers

import (
	"PrometheusAlert/models"
	"bytes"
	"crypto/tls"
	"io/ioutil"
	"net/http"
	"net/url"

	"github.com/astaxie/beego"
	"github.com/astaxie/beego/logs"
)

func PostToWebhook(text, WebhookUrl, logsign string, contentType string) string {
	logs.Info(logsign, "[Webhook]", text)
	JsonMsg := bytes.NewReader([]byte(text))
	var tr *http.Transport
	if proxyUrl := beego.AppConfig.String("proxy"); proxyUrl != "" {
		proxy := func(_ *http.Request) (*url.URL, error) {
			return url.Parse(proxyUrl)
		}
		tr = &http.Transport{
			TLSClientConfig: &tls.Config{InsecureSkipVerify: true},
			Proxy:           proxy,
		}
	} else {
		tr = &http.Transport{
			TLSClientConfig: &tls.Config{InsecureSkipVerify: true},
		}
	}
	client := &http.Client{Transport: tr}
	if contentType == "" {
		contentType = "application/json"
	}
	res, err := client.Post(WebhookUrl, contentType, JsonMsg)
	if err != nil {
		logs.Error(logsign, "[Webhook]", err.Error())
	}

	result, err := ioutil.ReadAll(res.Body)
	if err != nil {
		logs.Error(logsign, "[Webhook]", err.Error())
	}
	defer res.Body.Close()
	models.AlertToCounter.WithLabelValues("webhook").Add(1)
	ChartsJson.Webhook += 1
	logs.Info(logsign, "[Webhook]", string(result))
	return string(result)
}