-
Notifications
You must be signed in to change notification settings - Fork 209
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
Yarom Swisa
authored and
Yarom Swisa
committed
Dec 22, 2024
1 parent
537c7ca
commit edbfa9b
Showing
4 changed files
with
202 additions
and
1 deletion.
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,58 @@ | ||
| package monitoring | ||
|
|
||
| import ( | ||
| "bytes" | ||
| "encoding/json" | ||
| "fmt" | ||
| "net/http" | ||
|
|
||
| "github.com/lavanet/lava/v4/utils" | ||
| ) | ||
|
|
||
| type TelegramAlertingOptions struct { | ||
| TelegramBotToken string | ||
| TelegramChannelID string | ||
| } | ||
|
|
||
| const TELEGRAM_URL = "https://api.telegram.org" | ||
|
|
||
| func NewTelegramAlerting(options TelegramAlertingOptions) *TelegramAlertingOptions { | ||
| return &TelegramAlertingOptions{ | ||
| TelegramBotToken: options.TelegramBotToken, | ||
| TelegramChannelID: options.TelegramChannelID, | ||
| } | ||
| } | ||
|
|
||
| func (al *Alerting) SendTelegramAlert(alert string, attrs []utils.Attribute) error { | ||
| if al.TelegramAlerting.TelegramBotToken == "" || al.TelegramAlerting.TelegramChannelID == "" { | ||
| return fmt.Errorf("telegram configuration missing") | ||
| } | ||
|
|
||
| message := fmt.Sprintf("%s\n", alert) | ||
| for _, attr := range attrs { | ||
| message += fmt.Sprintf("%s: %v\n", attr.Key, attr.Value) | ||
| } | ||
|
|
||
| payload := map[string]string{ | ||
| "chat_id": al.TelegramAlerting.TelegramChannelID, | ||
| "text": message, | ||
| } | ||
|
|
||
| jsonData, err := json.Marshal(payload) | ||
| if err != nil { | ||
| return fmt.Errorf("failed to marshal payload: %v", err) | ||
| } | ||
|
|
||
| url := fmt.Sprintf("%s/bot%s/sendMessage", TELEGRAM_URL, al.TelegramAlerting.TelegramBotToken) | ||
| resp, err := http.Post(url, "application/json", bytes.NewBuffer(jsonData)) | ||
| if err != nil { | ||
| return fmt.Errorf("failed to send telegram alert: %v", err) | ||
| } | ||
| defer resp.Body.Close() | ||
|
|
||
| if resp.StatusCode != http.StatusOK { | ||
| return fmt.Errorf("telegram API returned non-200 status: %d", resp.StatusCode) | ||
| } | ||
|
|
||
| return nil | ||
| } |
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,134 @@ | ||
| package monitoring_test | ||
|
|
||
| import ( | ||
| "io" | ||
| "net/http" | ||
| "net/http/httptest" | ||
| "testing" | ||
|
|
||
| "github.com/lavanet/lava/v4/protocol/monitoring" | ||
| "github.com/lavanet/lava/v4/utils" | ||
| "github.com/stretchr/testify/assert" | ||
| "github.com/stretchr/testify/require" | ||
| ) | ||
|
|
||
| func TestTelegramAlerting_SendTelegramAlert(t *testing.T) { | ||
| tests := []struct { | ||
| name string | ||
| botToken string | ||
| channelID string | ||
| alert string | ||
| attrs []utils.Attribute | ||
| mockResponse string | ||
| mockStatus int | ||
| expectedError bool | ||
| checkRequest func(*testing.T, *http.Request) | ||
| }{ | ||
| { | ||
| name: "successful alert", | ||
| botToken: "test_token", | ||
| channelID: "test_channel", | ||
| alert: "Test Alert", | ||
| attrs: []utils.Attribute{ | ||
| {Key: "severity", Value: "high"}, | ||
| {Key: "service", Value: "test-service"}, | ||
| }, | ||
| mockResponse: `{"ok":true}`, | ||
| mockStatus: http.StatusOK, | ||
| expectedError: false, | ||
| checkRequest: func(t *testing.T, r *http.Request) { | ||
| // Check method and content type | ||
| assert.Equal(t, "POST", r.Method) | ||
| assert.Equal(t, "application/json", r.Header.Get("Content-Type")) | ||
|
|
||
| // Read and verify request body | ||
| body, err := io.ReadAll(r.Body) | ||
| require.NoError(t, err) | ||
|
|
||
| // Check if body contains expected content | ||
| bodyStr := string(body) | ||
| assert.Contains(t, bodyStr, "Test Alert") | ||
| assert.Contains(t, bodyStr, "severity") | ||
| assert.Contains(t, bodyStr, "high") | ||
| assert.Contains(t, bodyStr, "service") | ||
| assert.Contains(t, bodyStr, "test-service") | ||
| }, | ||
| }, | ||
| { | ||
| name: "missing configuration", | ||
| botToken: "", | ||
| channelID: "", | ||
| alert: "Test Alert", | ||
| attrs: []utils.Attribute{}, | ||
| expectedError: true, | ||
| }, | ||
| { | ||
| name: "server error", | ||
| botToken: "test_token", | ||
| channelID: "test_channel", | ||
| alert: "Test Alert", | ||
| attrs: []utils.Attribute{}, | ||
| mockResponse: `{"ok":false}`, | ||
| mockStatus: http.StatusInternalServerError, | ||
| expectedError: true, | ||
| }, | ||
| } | ||
|
|
||
| for _, tt := range tests { | ||
| t.Run(tt.name, func(t *testing.T) { | ||
| // Create test server if mockResponse is provided | ||
| var ts *httptest.Server | ||
| if tt.mockResponse != "" { | ||
| ts = httptest.NewServer(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) { | ||
| if tt.checkRequest != nil { | ||
| tt.checkRequest(t, r) | ||
| } | ||
| w.WriteHeader(tt.mockStatus) | ||
| w.Write([]byte(tt.mockResponse)) | ||
| })) | ||
| defer ts.Close() | ||
| } | ||
|
|
||
| // Initialize TelegramAlerting | ||
| options := monitoring.TelegramAlertingOptions{ | ||
| TelegramBotToken: tt.botToken, | ||
| TelegramChannelID: tt.channelID, | ||
| } | ||
| alerting := monitoring.NewTelegramAlerting(options) | ||
|
|
||
| // Send alert | ||
| al := &monitoring.Alerting{TelegramAlerting: *alerting} | ||
| err := al.SendTelegramAlert(tt.alert, tt.attrs) | ||
|
|
||
| // Check error | ||
| if tt.expectedError { | ||
| assert.Error(t, err) | ||
| } else { | ||
| assert.NoError(t, err) | ||
| } | ||
| }) | ||
| } | ||
| } | ||
|
|
||
| // Optional: Integration test (disabled by default) | ||
| func TestTelegramAlerting_Integration(t *testing.T) { | ||
| t.Skip("Integration test - run manually with valid credentials") | ||
|
|
||
| options := monitoring.TelegramAlertingOptions{ | ||
| TelegramBotToken: "YOUR_BOT_TOKEN", // Replace with actual token | ||
| TelegramChannelID: "YOUR_CHANNEL_ID", // Replace with actual channel ID | ||
| } | ||
|
|
||
| alerting := monitoring.NewTelegramAlerting(options) | ||
|
|
||
| al := &monitoring.Alerting{TelegramAlerting: *alerting} | ||
| err := al.SendTelegramAlert( | ||
| "Integration Test Alert", | ||
| []utils.Attribute{ | ||
| {Key: "test_key", Value: "test_value"}, | ||
| {Key: "timestamp", Value: "2024-03-14 12:00:00"}, | ||
| }, | ||
| ) | ||
|
|
||
| assert.NoError(t, err) | ||
| } |