mirror of https://github.com/statping/statping
83 lines
2.6 KiB
Go
83 lines
2.6 KiB
Go
package notifiers
|
|
|
|
import (
|
|
"fmt"
|
|
"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"
|
|
"net/url"
|
|
"strings"
|
|
"time"
|
|
)
|
|
|
|
var _ notifier.Notifier = (*lineNotifier)(nil)
|
|
|
|
const (
|
|
lineNotifyMethod = "line_notify"
|
|
)
|
|
|
|
type lineNotifier struct {
|
|
*notifications.Notification
|
|
}
|
|
|
|
func (l *lineNotifier) Select() *notifications.Notification {
|
|
return l.Notification
|
|
}
|
|
|
|
func (l *lineNotifier) Valid(values notifications.Values) error {
|
|
return nil
|
|
}
|
|
|
|
var LineNotify = &lineNotifier{¬ifications.Notification{
|
|
Method: lineNotifyMethod,
|
|
Title: "LINE Notify",
|
|
Description: "LINE Notify will send notifications to your LINE Notify account when services are offline or online. Based on the <a href=\"https://notify-bot.line.me/doc/en/\">LINE Notify API</a>.",
|
|
Author: "Kanin Peanviriyakulkit",
|
|
AuthorUrl: "https://github.com/dogrocker",
|
|
Icon: "far fa-bell",
|
|
Limits: 60,
|
|
Form: []notifications.NotificationForm{{
|
|
Type: "text",
|
|
Title: "Access Token",
|
|
Placeholder: "Insert your Line Notify Access Token here.",
|
|
DbField: "api_secret",
|
|
}}},
|
|
}
|
|
|
|
// Send will send a HTTP Post with the Authorization to the notify-api.line.me server. It accepts type: string
|
|
func (l *lineNotifier) sendMessage(message string) (string, error) {
|
|
v := url.Values{}
|
|
v.Set("message", message)
|
|
headers := []string{fmt.Sprintf("Authorization=Bearer %v", l.ApiSecret.String)}
|
|
content, _, err := utils.HttpRequest("https://notify-api.line.me/api/notify", "POST", "application/x-www-form-urlencoded", headers, strings.NewReader(v.Encode()), time.Duration(10*time.Second), true, nil)
|
|
return string(content), err
|
|
}
|
|
|
|
// OnFailure will trigger failing service
|
|
func (l *lineNotifier) OnFailure(s services.Service, f failures.Failure) (string, error) {
|
|
msg := fmt.Sprintf("Your service '%v' is currently offline! %s", s.Name, f.Issue)
|
|
out, err := l.sendMessage(msg)
|
|
return out, err
|
|
}
|
|
|
|
// OnSuccess will trigger successful service
|
|
func (l *lineNotifier) OnSuccess(s services.Service) (string, error) {
|
|
msg := fmt.Sprintf("Service %s is online!", s.Name)
|
|
out, err := l.sendMessage(msg)
|
|
return out, err
|
|
}
|
|
|
|
// OnTest triggers when this notifier has been saved
|
|
func (l *lineNotifier) OnTest() (string, error) {
|
|
msg := fmt.Sprintf("Testing if Line Notifier is working!")
|
|
_, err := l.sendMessage(msg)
|
|
return msg, err
|
|
}
|
|
|
|
// OnSave will trigger when this notifier is saved
|
|
func (l *lineNotifier) OnSave() (string, error) {
|
|
return "", nil
|
|
}
|