-
-
Notifications
You must be signed in to change notification settings - Fork 610
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
- Loading branch information
1 parent
fcae7f2
commit cffa814
Showing
10 changed files
with
288 additions
and
15 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,165 @@ | ||
| // Statup | ||
| // Copyright (C) 2018. Hunter Long and the project contributors | ||
| // Written by Hunter Long <info@socialeck.com> and the project contributors | ||
| // | ||
| // https://github.com/hunterlong/statup | ||
| // | ||
| // The licenses for most software and other practical works are designed | ||
| // to take away your freedom to share and change the works. By contrast, | ||
| // the GNU General Public License is intended to guarantee your freedom to | ||
| // share and change all versions of a program--to make sure it remains free | ||
| // software for all its users. | ||
| // | ||
| // You should have received a copy of the GNU General Public License | ||
| // along with this program. If not, see <http://www.gnu.org/licenses/>. | ||
|
|
||
| package notifiers | ||
|
|
||
| import ( | ||
| "encoding/json" | ||
| "errors" | ||
| "fmt" | ||
| "github.com/hunterlong/statping/core/notifier" | ||
| "github.com/hunterlong/statping/types" | ||
| "github.com/hunterlong/statping/utils" | ||
| "net/url" | ||
| "strings" | ||
| "time" | ||
| ) | ||
|
|
||
| type telegram struct { | ||
| *notifier.Notification | ||
| } | ||
|
|
||
| var telegramNotifier = &telegram{¬ifier.Notification{ | ||
| Method: "telegram", | ||
| Title: "Telegram", | ||
| Description: "Receive notifications on your Telegram channel when a service has an issue. You must get a Telegram API token from the /botfather. Review the <a target=\"_blank\" href=\"http://techthoughts.info/how-to-create-a-telegram-bot-and-send-messages-via-api\">Telegram API Tutorial</a> to learn how to generate a new API Token.", | ||
| Author: "Hunter Long", | ||
| AuthorUrl: "https://github.com/hunterlong", | ||
| Icon: "fab fa-telegram-plane", | ||
| Delay: time.Duration(5 * time.Second), | ||
| Form: []notifier.NotificationForm{{ | ||
| Type: "text", | ||
| Title: "Telegram API Token", | ||
| Placeholder: "383810182:EEx829dtCeufeQYXG7CUdiQopqdmmxBPO7-s", | ||
| SmallText: "Enter the API Token given to you from the /botfather chat.", | ||
| DbField: "api_secret", | ||
| Required: true, | ||
| }, { | ||
| Type: "text", | ||
| Title: "Channel or User ID", | ||
| Placeholder: "789325392", | ||
| SmallText: "Insert your Telegram Channel ID or User ID here.", | ||
| DbField: "Var1", | ||
| Required: true, | ||
| }}}, | ||
| } | ||
|
|
||
| // DEFINE YOUR NOTIFICATION HERE. | ||
| func init() { | ||
| err := notifier.AddNotifier(telegramNotifier) | ||
| if err != nil { | ||
| panic(err) | ||
| } | ||
| } | ||
|
|
||
| func (u *telegram) Select() *notifier.Notification { | ||
| return u.Notification | ||
| } | ||
|
|
||
| // Send will send a HTTP Post to the Telegram API. It accepts type: string | ||
| func (u *telegram) Send(msg interface{}) error { | ||
| message := msg.(string) | ||
| apiEndpoint := fmt.Sprintf("https://api.telegram.org/bot%v/sendMessage", u.ApiSecret) | ||
|
|
||
| v := url.Values{} | ||
| v.Set("chat_id", u.Var1) | ||
| v.Set("text", message) | ||
| rb := *strings.NewReader(v.Encode()) | ||
|
|
||
| contents, _, err := utils.HttpRequest(apiEndpoint, "GET", "application/x-www-form-urlencoded", nil, &rb, time.Duration(10*time.Second)) | ||
|
|
||
| success, _ := telegramSuccess(contents) | ||
| if !success { | ||
| errorOut := telegramError(contents) | ||
| out := fmt.Sprintf("Error code %v - %v", errorOut.ErrorCode, errorOut.Description) | ||
| return errors.New(out) | ||
| } | ||
| return err | ||
| } | ||
|
|
||
| // OnFailure will trigger failing service | ||
| func (u *telegram) OnFailure(s *types.Service, f *types.Failure) { | ||
| msg := fmt.Sprintf("Your service '%v' is currently offline!", s.Name) | ||
| u.AddQueue(s.Id, msg) | ||
| u.Online = false | ||
| } | ||
|
|
||
| // OnSuccess will trigger successful service | ||
| func (u *telegram) OnSuccess(s *types.Service) { | ||
| if !u.Online { | ||
| u.ResetUniqueQueue(s.Id) | ||
| msg := fmt.Sprintf("Your service '%v' is back online!", s.Name) | ||
| u.AddQueue(s.Id, msg) | ||
| } | ||
| u.Online = true | ||
| } | ||
|
|
||
| // OnSave triggers when this notifier has been saved | ||
| func (u *telegram) OnSave() error { | ||
| utils.Log(1, fmt.Sprintf("Notification %v is receiving updated information.", u.Method)) | ||
|
|
||
| // Do updating stuff here | ||
|
|
||
| return nil | ||
| } | ||
|
|
||
| // OnTest will test the Twilio SMS messaging | ||
| func (u *telegram) OnTest() error { | ||
| msg := fmt.Sprintf("Testing the Twilio SMS Notifier on your Statup server") | ||
| return u.Send(msg) | ||
| } | ||
|
|
||
| func telegramSuccess(res []byte) (bool, telegramResponse) { | ||
| var obj telegramResponse | ||
| json.Unmarshal(res, &obj) | ||
| if obj.Ok { | ||
| return true, obj | ||
| } | ||
| return false, obj | ||
| } | ||
|
|
||
| func telegramError(res []byte) telegramErrorObj { | ||
| var obj telegramErrorObj | ||
| json.Unmarshal(res, &obj) | ||
| return obj | ||
| } | ||
|
|
||
| type telegramErrorObj struct { | ||
| Ok bool `json:"ok"` | ||
| ErrorCode int `json:"error_code"` | ||
| Description string `json:"description"` | ||
| } | ||
|
|
||
| type telegramResponse struct { | ||
| Ok bool `json:"ok"` | ||
| Result struct { | ||
| MessageID int `json:"message_id"` | ||
| From struct { | ||
| ID int `json:"id"` | ||
| IsBot bool `json:"is_bot"` | ||
| FirstName string `json:"first_name"` | ||
| Username string `json:"username"` | ||
| } `json:"from"` | ||
| Chat struct { | ||
| ID int `json:"id"` | ||
| FirstName string `json:"first_name"` | ||
| LastName string `json:"last_name"` | ||
| Username string `json:"username"` | ||
| Type string `json:"type"` | ||
| } `json:"chat"` | ||
| Date int `json:"date"` | ||
| Text string `json:"text"` | ||
| } `json:"result"` | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,108 @@ | ||
| // Statup | ||
| // Copyright (C) 2018. Hunter Long and the project contributors | ||
| // Written by Hunter Long <info@socialeck.com> and the project contributors | ||
| // | ||
| // https://github.com/hunterlong/statup | ||
| // | ||
| // The licenses for most software and other practical works are designed | ||
| // to take away your freedom to share and change the works. By contrast, | ||
| // the GNU General Public License is intended to guarantee your freedom to | ||
| // share and change all versions of a program--to make sure it remains free | ||
| // software for all its users. | ||
| // | ||
| // You should have received a copy of the GNU General Public License | ||
| // along with this program. If not, see <http://www.gnu.org/licenses/>. | ||
|
|
||
| package notifiers | ||
|
|
||
| import ( | ||
| "github.com/hunterlong/statping/core/notifier" | ||
| "github.com/stretchr/testify/assert" | ||
| "os" | ||
| "testing" | ||
| "time" | ||
| ) | ||
|
|
||
| var ( | ||
| telegramToken string | ||
| telegramChannel string | ||
| telegramMessage = "The Telegram notifier on Statping has been tested!" | ||
| ) | ||
|
|
||
| func init() { | ||
| telegramToken = os.Getenv("TELEGRAM_TOKEN") | ||
| telegramChannel = os.Getenv("TELEGRAM_CHANNEL") | ||
| telegramNotifier.ApiSecret = telegramToken | ||
| telegramNotifier.Var1 = telegramChannel | ||
| } | ||
|
|
||
| func TestTelegramNotifier(t *testing.T) { | ||
| t.Parallel() | ||
| if telegramToken == "" || telegramChannel == "" { | ||
| t.Log("Telegram notifier testing skipped, missing TELEGRAM_TOKEN and TELEGRAM_CHANNEL environment variable") | ||
| t.SkipNow() | ||
| } | ||
| currentCount = CountNotifiers() | ||
|
|
||
| t.Run("Load Telegram", func(t *testing.T) { | ||
| telegramNotifier.ApiSecret = telegramToken | ||
| telegramNotifier.Var1 = telegramChannel | ||
| telegramNotifier.Delay = time.Duration(1 * time.Second) | ||
| err := notifier.AddNotifier(telegramNotifier) | ||
| assert.Nil(t, err) | ||
| assert.Equal(t, "Hunter Long", telegramNotifier.Author) | ||
| assert.Equal(t, telegramToken, telegramNotifier.ApiSecret) | ||
| assert.Equal(t, telegramChannel, telegramNotifier.Var1) | ||
| }) | ||
|
|
||
| t.Run("Load Telegram Notifier", func(t *testing.T) { | ||
| notifier.Load() | ||
| }) | ||
|
|
||
| t.Run("Telegram Within Limits", func(t *testing.T) { | ||
| ok, err := telegramNotifier.WithinLimits() | ||
| assert.Nil(t, err) | ||
| assert.True(t, ok) | ||
| }) | ||
|
|
||
| t.Run("Telegram OnFailure", func(t *testing.T) { | ||
| telegramNotifier.OnFailure(TestService, TestFailure) | ||
| assert.Equal(t, 1, len(telegramNotifier.Queue)) | ||
| }) | ||
|
|
||
| t.Run("Telegram Check Offline", func(t *testing.T) { | ||
| assert.False(t, telegramNotifier.Online) | ||
| }) | ||
|
|
||
| t.Run("Telegram OnSuccess", func(t *testing.T) { | ||
| telegramNotifier.OnSuccess(TestService) | ||
| assert.Equal(t, 1, len(telegramNotifier.Queue)) | ||
| }) | ||
|
|
||
| t.Run("Telegram Check Back Online", func(t *testing.T) { | ||
| assert.True(t, telegramNotifier.Online) | ||
| }) | ||
|
|
||
| t.Run("Telegram OnSuccess Again", func(t *testing.T) { | ||
| telegramNotifier.OnSuccess(TestService) | ||
| assert.Equal(t, 1, len(telegramNotifier.Queue)) | ||
| }) | ||
|
|
||
| t.Run("Telegram Send", func(t *testing.T) { | ||
| err := telegramNotifier.Send(telegramMessage) | ||
| assert.Nil(t, err) | ||
| }) | ||
|
|
||
| t.Run("Telegram Test", func(t *testing.T) { | ||
| err := telegramNotifier.OnTest() | ||
| assert.Nil(t, err) | ||
| }) | ||
|
|
||
| t.Run("Telegram Queue", func(t *testing.T) { | ||
| go notifier.Queue(telegramNotifier) | ||
| time.Sleep(3 * time.Second) | ||
| assert.Equal(t, telegramToken, telegramNotifier.ApiSecret) | ||
| assert.Equal(t, 0, len(telegramNotifier.Queue)) | ||
| }) | ||
|
|
||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.
Oops, something went wrong.
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
|
|
@@ -42,8 +42,8 @@ | |
| } | ||
|
|
||
| .card-body { | ||
| font-size: 6pt; | ||
| padding: 5px 5px; | ||
| font-size: 10pt; | ||
| padding: 0px 10px; | ||
| } | ||
|
|
||
| .lg_number { | ||
|
|
||
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -1 +1 @@ | ||
| 0.79.98 | ||
| 0.79.99 |