feat(backend): alerting #40
Merged
+157
−3
Conversation
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
|
We'll hold this one for a while. |
|
why? |
aldy505
approved these changes
Sep 9, 2024
Comment on lines
+25
to
+87
| type TelegramProvider struct { | ||
| url string | ||
| chatID string | ||
| } | ||
|
|
||
| type TelegramProviderConfig struct { | ||
| Url string | ||
| ChatID string | ||
| } | ||
|
|
||
| func NewTelegramAlertProvider(config TelegramProviderConfig) *TelegramProvider { | ||
| return &TelegramProvider{ | ||
| url: config.Url, | ||
| } | ||
| } | ||
|
|
||
| func (t TelegramProvider) Send(ctx context.Context, msg AlertMessage) error { | ||
| if t.url == "" || t.chatID == "" { | ||
| return fmt.Errorf("can't make a telegram alert request: some config is not set") | ||
| } | ||
|
|
||
| // Perhaps we can use a template file instead. | ||
| title := "🔴 Down" | ||
| if msg.Success { | ||
| title = "✅ Up" | ||
| } | ||
| text := fmt.Sprintf(title+` | ||
|
|
||
| **MonitorID:** %s | ||
| **MonitorName:** %s | ||
| **StatusCode:** %d | ||
| **Latency:** %d | ||
| **Timestamp:** %s`, | ||
| msg.MonitorID, | ||
| msg.MonitorName, | ||
| msg.StatusCode, | ||
| msg.Latency, | ||
| msg.Timestamp.Format(time.RFC3339), | ||
| ) | ||
| payload := map[string]any{ | ||
| "chat_id": t.chatID, | ||
| "text": text, | ||
| "parse_mode": "Markdown", | ||
| } | ||
| payloadByte, _ := json.Marshal(payload) | ||
|
|
||
| req, err := http.NewRequestWithContext(ctx, http.MethodPost, t.url, bytes.NewReader(payloadByte)) | ||
| if err != nil { | ||
| return fmt.Errorf("failed to send telegram alert: %w", err) | ||
| } | ||
| defer req.Body.Close() | ||
|
|
||
| req.Header.Set("Content-Type", "application/json") | ||
|
|
||
| client := http.Client{Timeout: time.Second * 3} | ||
|
|
||
| _, err = client.Do(req) | ||
| if err != nil { | ||
| return fmt.Errorf("failed to make request: %w", err) | ||
| } | ||
|
|
||
| return nil | ||
| } |
There was a problem hiding this comment.
This block is supposed to be moved to another file
Comment on lines
+61
to
+69
| telegramChatID, ok := os.LookupEnv("TELEGRAM_CHAT_ID") | ||
| if !ok { | ||
| log.Warn().Msg("TELEGRAM_CHAT_ID is not set") | ||
| } | ||
|
|
||
| telegramUrl, ok := os.LookupEnv("TELEGRAM_URL is not set") | ||
| if !ok { | ||
| log.Warn().Msg("TELEGRAM_URL is not set") | ||
| } |
There was a problem hiding this comment.
Since we want to support other kind of alerting system, we shouldn't make this as a warn log if the value does not exists.
Comment on lines
+113
to
+118
| processor := &Processor{ | ||
| telegramAlertProvider: NewTelegramAlertProvider(TelegramProviderConfig{ | ||
| Url: telegramUrl, | ||
| ChatID: telegramChatID, | ||
| }), | ||
| } |
There was a problem hiding this comment.
Instead, this should be array of available alerter. But we'll work on refactoring that later.
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
Add this suggestion to a batch that can be applied as a single commit.
This suggestion is invalid because no changes were made to the code.
Suggestions cannot be applied while the pull request is closed.
Suggestions cannot be applied while viewing a subset of changes.
Only one suggestion per line can be applied in a batch.
Add this suggestion to a batch that can be applied as a single commit.
Applying suggestions on deleted lines is not supported.
You must change the existing code in this line in order to create a valid suggestion.
Outdated suggestions cannot be applied.
This suggestion has been applied or marked resolved.
Suggestions cannot be applied from pending reviews.
Suggestions cannot be applied on multi-line comments.
Suggestions cannot be applied while the pull request is queued to merge.
Suggestion cannot be applied right now. Please check back later.
Close #27
NOTE: The alerting feature is currently only available for the Telegram provider.
Some environment variables below need to be added:
TELEGRAM_URL(including bot token)TELEGRAM_CHAT_IDchannel or chat idThe
alert_providerfield must be added to the monitor configuration file with a value of eithertelegramordiscord. If not value is set, the defaulttelegramprovider will be use