84 lines
3.6 KiB
Go
84 lines
3.6 KiB
Go
package notifiers
|
|
|
|
import (
|
|
"bytes"
|
|
"errors"
|
|
"github.com/statping/statping/types/failures"
|
|
"github.com/statping/statping/types/notifications"
|
|
"github.com/statping/statping/types/notifier"
|
|
"github.com/statping/statping/types/services"
|
|
"github.com/statping/statping/utils"
|
|
"strings"
|
|
"time"
|
|
)
|
|
|
|
var _ notifier.Notifier = (*slack)(nil)
|
|
|
|
const (
|
|
slackMethod = "slack"
|
|
failingTemplate = `{ "attachments": [ { "fallback": "Service {{.Service.Name}} - is currently failing", "text": "Your Statping service <{{.Service.Domain}}|{{.Service.Name}}> has just received a Failure notification based on your expected results. {{.Service.Name}} responded with a HTTP Status code of {{.Service.LastStatusCode}}.", "fields": [ { "title": "Expected Status Code", "value": "{{.Service.ExpectedStatus}}", "short": true }, { "title": "Received Status Code", "value": "{{.Service.LastStatusCode}}", "short": true } ,{ "title": "Error Message", "value": "{{.Failure.Issue}}", "short": false } ], "color": "#FF0000", "thumb_url": "https://statping.com", "footer": "Statping", "footer_icon": "https://img.cjx.io/statuplogo32.png" } ] }`
|
|
successTemplate = `{ "attachments": [ { "fallback": "Service {{.Service.Name}} - is now back online", "text": "Your Statping service <{{.Service.Domain}}|{{.Service.Name}}> is now back online and meets your expected responses.", "color": "#00FF00", "thumb_url": "https://statping.com", "footer": "Statping", "footer_icon": "https://img.cjx.io/statuplogo32.png" } ] }`
|
|
)
|
|
|
|
type slack struct {
|
|
*notifications.Notification
|
|
}
|
|
|
|
func (s *slack) Select() *notifications.Notification {
|
|
return s.Notification
|
|
}
|
|
|
|
var slacker = &slack{¬ifications.Notification{
|
|
Method: slackMethod,
|
|
Title: "slack",
|
|
Description: "Send notifications to your slack channel when a service is offline. Insert your Incoming webhook URL for your channel to receive notifications. Based on the <a href=\"https://api.slack.com/incoming-webhooks\">Slack API</a>.",
|
|
Author: "Hunter Long",
|
|
AuthorUrl: "https://github.com/hunterlong",
|
|
Delay: time.Duration(10 * time.Second),
|
|
Host: "https://webhooksurl.slack.com/***",
|
|
Icon: "fab fa-slack",
|
|
Limits: 60,
|
|
Form: []notifications.NotificationForm{{
|
|
Type: "text",
|
|
Title: "Incoming Webhook Url",
|
|
Placeholder: "Insert your Slack Webhook URL here.",
|
|
SmallText: "Incoming Webhook URL from <a href=\"https://api.slack.com/apps\" target=\"_blank\">Slack Apps</a>",
|
|
DbField: "Host",
|
|
Required: true,
|
|
}}},
|
|
}
|
|
|
|
// Send will send a HTTP Post to the slack webhooker API. It accepts type: string
|
|
func (s *slack) sendSlack(msg string) error {
|
|
_, resp, err := utils.HttpRequest(s.Host, "POST", "application/json", nil, strings.NewReader(msg), time.Duration(10*time.Second), true)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
defer resp.Body.Close()
|
|
return nil
|
|
}
|
|
|
|
func (s *slack) OnTest() (string, error) {
|
|
contents, resp, err := utils.HttpRequest(s.Host, "POST", "application/json", nil, bytes.NewBuffer([]byte(`{"text":"testing message"}`)), time.Duration(10*time.Second), true)
|
|
if err != nil {
|
|
return "", err
|
|
}
|
|
defer resp.Body.Close()
|
|
if string(contents) != "ok" {
|
|
return string(contents), errors.New("the slack response was incorrect, check the URL")
|
|
}
|
|
return string(contents), nil
|
|
}
|
|
|
|
// OnFailure will trigger failing service
|
|
func (s *slack) OnFailure(srv *services.Service, f *failures.Failure) error {
|
|
msg := ReplaceVars(failingTemplate, srv, f)
|
|
return s.sendSlack(msg)
|
|
}
|
|
|
|
// OnSuccess will trigger successful service
|
|
func (s *slack) OnSuccess(srv *services.Service) error {
|
|
msg := ReplaceVars(successTemplate, srv, nil)
|
|
return s.sendSlack(msg)
|
|
}
|