250 lines
11 KiB
Go
250 lines
11 KiB
Go
package notifiers
|
|
|
|
import (
|
|
"crypto/tls"
|
|
"fmt"
|
|
"github.com/go-mail/mail"
|
|
"github.com/statping/statping/types/failures"
|
|
"github.com/statping/statping/types/notifications"
|
|
"github.com/statping/statping/types/notifier"
|
|
"github.com/statping/statping/types/null"
|
|
"github.com/statping/statping/types/services"
|
|
"github.com/statping/statping/utils"
|
|
"time"
|
|
)
|
|
|
|
var _ notifier.Notifier = (*emailer)(nil)
|
|
|
|
const (
|
|
mainEmailTemplate = `<!DOCTYPE html PUBLIC "-//W3C//DTD XHTML 1.0 Transitional//EN" "http://www.w3.org/TR/xhtml1/DTD/xhtml1-transitional.dtd">
|
|
<html xmlns="http://www.w3.org/1999/xhtml" xmlns="http://www.w3.org/1999/xhtml">
|
|
<head>
|
|
<meta name="viewport" content="width=device-width, initial-scale=1.0" />
|
|
<meta http-equiv="Content-Type" content="text/html; charset=UTF-8" />
|
|
<title>Statping email</title>
|
|
</head>
|
|
<body style="-webkit-text-size-adjust: none; box-sizing: border-box; color: #74787E; font-family: Arial, 'Helvetica Neue', Helvetica, sans-serif; height: 100%; line-height: 1.4; margin: 0; width: 100% !important;" bgcolor="#F2F4F6">
|
|
<style type="text/css">
|
|
body {
|
|
width: 100% !important;
|
|
height: 100%;
|
|
margin: 0;
|
|
line-height: 1.4;
|
|
background-color: #F2F4F6;
|
|
color: #74787E;
|
|
-webkit-text-size-adjust: none;
|
|
}
|
|
@media only screen and (max-width: 600px) {
|
|
.email-body_inner {
|
|
width: 100% !important;
|
|
}
|
|
.email-footer {
|
|
width: 100% !important;
|
|
}
|
|
}
|
|
|
|
@media only screen and (max-width: 500px) {
|
|
.button {
|
|
width: 100% !important;
|
|
}
|
|
}
|
|
</style>
|
|
<table class="email-wrapper" width="100%" cellpadding="0" cellspacing="0" style="box-sizing: border-box; font-family: Arial, 'Helvetica Neue', Helvetica, sans-serif; margin: 0; padding: 0; width: 100%;" bgcolor="#F2F4F6">
|
|
<tr>
|
|
<td align="center" style="box-sizing: border-box; font-family: Arial, 'Helvetica Neue', Helvetica, sans-serif; word-break: break-word;">
|
|
<table class="email-content" width="100%" cellpadding="0" cellspacing="0" style="box-sizing: border-box; font-family: Arial, 'Helvetica Neue', Helvetica, sans-serif; margin: 0; padding: 0; width: 100%;">
|
|
<tr>
|
|
<td class="email-body" width="100%" cellpadding="0" cellspacing="0" style="-premailer-cellpadding: 0; -premailer-cellspacing: 0; border-bottom-color: #EDEFF2; border-bottom-style: solid; border-bottom-width: 1px; border-top-color: #EDEFF2; border-top-style: solid; border-top-width: 1px; box-sizing: border-box; font-family: Arial, 'Helvetica Neue', Helvetica, sans-serif; margin: 0; padding: 0; width: 100%; word-break: break-word;" bgcolor="#FFFFFF">
|
|
<table class="email-body_inner" align="center" width="570" cellpadding="0" cellspacing="0" style="box-sizing: border-box; font-family: Arial, 'Helvetica Neue', Helvetica, sans-serif; margin: 0 auto; padding: 0; width: 570px;" bgcolor="#FFFFFF">
|
|
<tr>
|
|
<td class="content-cell" style="box-sizing: border-box; font-family: Arial, 'Helvetica Neue', Helvetica, sans-serif; padding: 35px; word-break: break-word;">
|
|
<h1 style="box-sizing: border-box; color: #2F3133; font-family: Arial, 'Helvetica Neue', Helvetica, sans-serif; font-size: 19px; font-weight: bold; margin-top: 0;" align="left">
|
|
{{ .Service.Name }} is {{ if .Service.Online }}Online{{else}}Offline{{end}}!
|
|
</h1>
|
|
<p style="box-sizing: border-box; color: #74787E; font-family: Arial, 'Helvetica Neue', Helvetica, sans-serif; font-size: 16px; line-height: 1.5em; margin-top: 0;" align="left">
|
|
|
|
{{ if .Service.Online }}
|
|
Your Statping service <a target="_blank" href="{{.Service.Domain}}">{{.Service.Name}}</a> is back online. This service has been triggered with a HTTP status code of '{{.Service.LastStatusCode}}' and is currently online based on your requirements. Your service was reported online at {{.Service.CreatedAt}}. </p>
|
|
{{ else }}
|
|
Your Statping service <a target="_blank" href="{{.Service.Domain}}">{{.Service.Name}}</a> has been triggered with a HTTP status code of '{{.Service.LastStatusCode}}' and is currently offline based on your requirements. This failure was created on {{.Service.CreatedAt}}. </p>
|
|
{{ end }}
|
|
|
|
{{if .Service.LastResponse }}
|
|
<h1 style="box-sizing: border-box; color: #2F3133; font-family: Arial, 'Helvetica Neue', Helvetica, sans-serif; font-size: 19px; font-weight: bold; margin-top: 0;" align="left">
|
|
Last Response</h1>
|
|
<p style="box-sizing: border-box; color: #74787E; font-family: Arial, 'Helvetica Neue', Helvetica, sans-serif; font-size: 16px; line-height: 1.5em; margin-top: 0;" align="left">
|
|
{{ .Service.LastResponse }} </p> {{end}}
|
|
<table class="body-sub" style="border-top-color: #EDEFF2; border-top-style: solid; border-top-width: 1px; box-sizing: border-box; font-family: Arial, 'Helvetica Neue', Helvetica, sans-serif; margin-top: 25px; padding-top: 25px;">
|
|
<td style="box-sizing: border-box; font-family: Arial, 'Helvetica Neue', Helvetica, sans-serif; word-break: break-word;"> <a href="/service/{{.Service.Id}}" class="button button--blue" target="_blank" style="-webkit-text-size-adjust: none; background: #3869D4; border-color: #3869d4; border-radius: 3px; border-style: solid; border-width: 10px 18px; box-shadow: 0 2px 3px rgba(0, 0, 0, 0.16); box-sizing: border-box; color: #FFF; display: inline-block; font-family: Arial, 'Helvetica Neue', Helvetica, sans-serif; text-decoration: none;">View Service</a> </td>
|
|
<td style="box-sizing: border-box; font-family: Arial, 'Helvetica Neue', Helvetica, sans-serif; word-break: break-word;"> <a href="/dashboard" class="button button--blue" target="_blank" style="-webkit-text-size-adjust: none; background: #3869D4; border-color: #3869d4; border-radius: 3px; border-style: solid; border-width: 10px 18px; box-shadow: 0 2px 3px rgba(0, 0, 0, 0.16); box-sizing: border-box; color: #FFF; display: inline-block; font-family: Arial, 'Helvetica Neue', Helvetica, sans-serif; text-decoration: none;">Statping Dashboard</a> </td>
|
|
</table>
|
|
</td>
|
|
</tr>
|
|
</table>
|
|
</td>
|
|
</tr>
|
|
</table>
|
|
</td>
|
|
</tr>
|
|
</table>
|
|
</body>
|
|
</html>`
|
|
)
|
|
|
|
var (
|
|
mailer *mail.Dialer
|
|
)
|
|
|
|
type emailer struct {
|
|
*notifications.Notification
|
|
}
|
|
|
|
func (e *emailer) Select() *notifications.Notification {
|
|
return e.Notification
|
|
}
|
|
|
|
var email = &emailer{¬ifications.Notification{
|
|
Method: "email",
|
|
Title: "email",
|
|
Description: "Send emails via SMTP when services are online or offline.",
|
|
Author: "Hunter Long",
|
|
AuthorUrl: "https://github.com/hunterlong",
|
|
Icon: "far fa-envelope",
|
|
SuccessData: "Service {{.Service.Name}} is Back Online",
|
|
FailureData: "Service {{.Service.Name}} is Offline",
|
|
DataType: "text",
|
|
Limits: 30,
|
|
Form: []notifications.NotificationForm{{
|
|
Type: "text",
|
|
Title: "SMTP Host",
|
|
Placeholder: "Insert your SMTP Host here.",
|
|
DbField: "Host",
|
|
}, {
|
|
Type: "text",
|
|
Title: "SMTP Username",
|
|
Placeholder: "Insert your SMTP Username here.",
|
|
DbField: "Username",
|
|
}, {
|
|
Type: "password",
|
|
Title: "SMTP Password",
|
|
Placeholder: "Insert your SMTP Password here.",
|
|
DbField: "Password",
|
|
}, {
|
|
Type: "number",
|
|
Title: "SMTP Port",
|
|
Placeholder: "Insert your SMTP Port here.",
|
|
DbField: "Port",
|
|
}, {
|
|
Type: "text",
|
|
Title: "Outgoing Email Address",
|
|
Placeholder: "outgoing@email.com",
|
|
DbField: "Var1",
|
|
}, {
|
|
Type: "email",
|
|
Title: "Send Alerts To",
|
|
Placeholder: "sendto@email.com",
|
|
DbField: "Var2",
|
|
}, {
|
|
Type: "text",
|
|
Title: "Disable TLS/SSL",
|
|
Placeholder: "",
|
|
SmallText: "To Disable TLS/SSL insert 'true'",
|
|
DbField: "api_key",
|
|
}}},
|
|
}
|
|
|
|
type emailOutgoing struct {
|
|
To string
|
|
Subject string
|
|
Template string
|
|
From string
|
|
Data replacer
|
|
Source string
|
|
Sent bool
|
|
}
|
|
|
|
// OnFailure will trigger failing service
|
|
func (e *emailer) OnFailure(s *services.Service, f *failures.Failure) (string, error) {
|
|
subject := fmt.Sprintf("Service %s is Offline", s.Name)
|
|
email := &emailOutgoing{
|
|
To: e.Var2,
|
|
Subject: subject,
|
|
Template: mainEmailTemplate,
|
|
Data: replacer{
|
|
Service: s,
|
|
Failure: f,
|
|
},
|
|
From: e.Var1,
|
|
}
|
|
return "email failed", e.dialSend(email)
|
|
}
|
|
|
|
// OnSuccess will trigger successful service
|
|
func (e *emailer) OnSuccess(s *services.Service) (string, error) {
|
|
subject := fmt.Sprintf("Service %s is Back Online", s.Name)
|
|
email := &emailOutgoing{
|
|
To: e.Var2,
|
|
Subject: subject,
|
|
Template: mainEmailTemplate,
|
|
Data: replacer{
|
|
Service: s,
|
|
Failure: &failures.Failure{},
|
|
},
|
|
From: e.Var1,
|
|
}
|
|
return "email sent", e.dialSend(email)
|
|
}
|
|
|
|
// OnTest triggers when this notifier has been saved
|
|
func (e *emailer) OnTest() (string, error) {
|
|
testService := services.Service{
|
|
Id: 1,
|
|
Name: "Example Service",
|
|
Domain: "https://www.youtube.com/watch?v=-u6DvRyyKGU",
|
|
ExpectedStatus: 200,
|
|
Interval: 30,
|
|
Type: "http",
|
|
Method: "GET",
|
|
Timeout: 20,
|
|
LastStatusCode: 200,
|
|
Expected: null.NewNullString("test example"),
|
|
LastResponse: "<html>this is an example response</html>",
|
|
CreatedAt: utils.Now().Add(-24 * time.Hour),
|
|
}
|
|
subject := fmt.Sprintf("Service %v is Back Online", testService.Name)
|
|
email := &emailOutgoing{
|
|
To: e.Var2,
|
|
Subject: subject,
|
|
Template: mainEmailTemplate,
|
|
Data: replacer{
|
|
Service: &testService,
|
|
Failure: &failures.Failure{},
|
|
},
|
|
From: e.Var1,
|
|
}
|
|
err := e.dialSend(email)
|
|
return subject, err
|
|
}
|
|
|
|
func (e *emailer) dialSend(email *emailOutgoing) error {
|
|
mailer = mail.NewDialer(e.Host, e.Port, e.Username, e.Password)
|
|
m := mail.NewMessage()
|
|
// if email setting TLS is Disabled
|
|
if e.ApiKey == "true" {
|
|
mailer.SSL = false
|
|
} else {
|
|
mailer.TLSConfig = &tls.Config{InsecureSkipVerify: true}
|
|
}
|
|
|
|
m.SetHeader("From", email.From)
|
|
m.SetHeader("To", email.To)
|
|
m.SetHeader("Subject", email.Subject)
|
|
m.SetBody("text/html", ReplaceTemplate(email.Template, email.Data))
|
|
|
|
if err := mailer.DialAndSend(m); err != nil {
|
|
utils.Log.Errorln(fmt.Sprintf("email '%v' sent to: %v (size: %v) %v", email.Subject, email.To, len([]byte(email.Source)), err))
|
|
return err
|
|
}
|
|
return nil
|
|
}
|