Wala shell

Advanced PHP File Manager

Server IP: 127.0.0.1 | PHP Version: 8.3.30 | Domains Hosted: 54

Name	Size	Last Modified	Actions
📁 ..	-	2025-05-25 12:27
📄 pushover.go // Copyright 2019 Prometheus Team // Licensed under the Apache License, Version 2.0 (the "License"); // you may not use this file except in compliance with the License. // You may obtain a copy of the License at // // http://www.apache.org/licenses/LICENSE-2.0 // // Unless required by applicable law or agreed to in writing, software // distributed under the License is distributed on an "AS IS" BASIS, // WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. // See the License for the specific language governing permissions and // limitations under the License. package pushover import ( "context" "fmt" "log/slog" "net/http" "net/url" "os" "strings" "time" commoncfg "github.com/prometheus/common/config" "github.com/prometheus/alertmanager/config" "github.com/prometheus/alertmanager/notify" "github.com/prometheus/alertmanager/template" "github.com/prometheus/alertmanager/types" ) const ( // https://pushover.net/api#limits - 250 characters or runes. maxTitleLenRunes = 250 // https://pushover.net/api#limits - 1024 characters or runes. maxMessageLenRunes = 1024 // https://pushover.net/api#limits - 512 characters or runes. maxURLLenRunes = 512 ) // Notifier implements a Notifier for Pushover notifications. type Notifier struct { conf config.PushoverConfig tmpl template.Template logger slog.Logger client http.Client retrier notify.Retrier apiURL string // for tests. } // New returns a new Pushover notifier. func New(c config.PushoverConfig, t template.Template, l slog.Logger, httpOpts ...commoncfg.HTTPClientOption) (Notifier, error) { client, err := commoncfg.NewClientFromConfig(c.HTTPConfig, "pushover", httpOpts...) if err != nil { return nil, err } return &Notifier{ conf: c, tmpl: t, logger: l, client: client, retrier: &notify.Retrier{}, apiURL: "https://api.pushover.net/1/messages.json", }, nil } // Notify implements the Notifier interface. func (n Notifier) Notify(ctx context.Context, as ...types.Alert) (bool, error) { key, ok := notify.GroupKey(ctx) if !ok { return false, fmt.Errorf("group key missing") } data := notify.GetTemplateData(ctx, n.tmpl, as, n.logger) // @tjhop: should this use `group` for the keyval like most other notify implementations? n.logger.Debug("extracted group key", "incident", key) var ( err error message string ) tmpl := notify.TmplText(n.tmpl, data, &err) tmplHTML := notify.TmplHTML(n.tmpl, data, &err) var ( token string userKey string ) if n.conf.Token != "" { token = string(n.conf.Token) } else { content, err := os.ReadFile(n.conf.TokenFile) if err != nil { return false, fmt.Errorf("read token_file: %w", err) } token = string(content) } if n.conf.UserKey != "" { userKey = string(n.conf.UserKey) } else { content, err := os.ReadFile(n.conf.UserKeyFile) if err != nil { return false, fmt.Errorf("read user_key_file: %w", err) } userKey = string(content) } parameters := url.Values{} parameters.Add("token", tmpl(token)) parameters.Add("user", tmpl(userKey)) title, truncated := notify.TruncateInRunes(tmpl(n.conf.Title), maxTitleLenRunes) if truncated { n.logger.Warn("Truncated title", "incident", key, "max_runes", maxTitleLenRunes) } parameters.Add("title", title) if n.conf.HTML { parameters.Add("html", "1") message = tmplHTML(n.conf.Message) } else { message = tmpl(n.conf.Message) } message, truncated = notify.TruncateInRunes(message, maxMessageLenRunes) if truncated { n.logger.Warn("Truncated message", "incident", key, "max_runes", maxMessageLenRunes) } message = strings.TrimSpace(message) if message == "" { // Pushover rejects empty messages. message = "(no details)" } parameters.Add("message", message) supplementaryURL, truncated := notify.TruncateInRunes(tmpl(n.conf.URL), maxURLLenRunes) if truncated { n.logger.Warn("Truncated URL", "incident", key, "max_runes", maxURLLenRunes) } parameters.Add("url", supplementaryURL) parameters.Add("url_title", tmpl(n.conf.URLTitle)) parameters.Add("priority", tmpl(n.conf.Priority)) parameters.Add("retry", fmt.Sprintf("%d", int64(time.Duration(n.conf.Retry).Seconds()))) parameters.Add("expire", fmt.Sprintf("%d", int64(time.Duration(n.conf.Expire).Seconds()))) parameters.Add("device", tmpl(n.conf.Device)) parameters.Add("sound", tmpl(n.conf.Sound)) newttl := int64(time.Duration(n.conf.TTL).Seconds()) if newttl > 0 { parameters.Add("ttl", fmt.Sprintf("%d", newttl)) } if err != nil { return false, err } u, err := url.Parse(n.apiURL) if err != nil { return false, err } u.RawQuery = parameters.Encode() // Don't log the URL as it contains secret data (see #1825). n.logger.Debug("Sending message", "incident", key) resp, err := notify.PostText(ctx, n.client, u.String(), nil) if err != nil { return true, notify.RedactURL(err) } defer notify.Drain(resp) shouldRetry, err := n.retrier.Check(resp.StatusCode, resp.Body) if err != nil { return shouldRetry, notify.NewErrorWithReason(notify.GetFailureReasonFromStatusCode(resp.StatusCode), err) } return shouldRetry, err }	5.03 KB	2025-05-25 12:27
📄 pushover_test.go // Copyright 2019 Prometheus Team // Licensed under the Apache License, Version 2.0 (the "License"); // you may not use this file except in compliance with the License. // You may obtain a copy of the License at // // http://www.apache.org/licenses/LICENSE-2.0 // // Unless required by applicable law or agreed to in writing, software // distributed under the License is distributed on an "AS IS" BASIS, // WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. // See the License for the specific language governing permissions and // limitations under the License. package pushover import ( "fmt" "os" "testing" commoncfg "github.com/prometheus/common/config" "github.com/prometheus/common/promslog" "github.com/stretchr/testify/require" "github.com/prometheus/alertmanager/config" "github.com/prometheus/alertmanager/notify/test" ) func TestPushoverRetry(t testing.T) { notifier, err := New( &config.PushoverConfig{ HTTPConfig: &commoncfg.HTTPClientConfig{}, }, test.CreateTmpl(t), promslog.NewNopLogger(), ) require.NoError(t, err) for statusCode, expected := range test.RetryTests(test.DefaultRetryCodes()) { actual, _ := notifier.retrier.Check(statusCode, nil) require.Equal(t, expected, actual, fmt.Sprintf("error on status %d", statusCode)) } } func TestPushoverRedactedURL(t testing.T) { ctx, u, fn := test.GetContextWithCancelingURL() defer fn() key, token := "user_key", "token" notifier, err := New( &config.PushoverConfig{ UserKey: config.Secret(key), Token: config.Secret(token), HTTPConfig: &commoncfg.HTTPClientConfig{}, }, test.CreateTmpl(t), promslog.NewNopLogger(), ) require.NoError(t, err) notifier.apiURL = u.String() test.AssertNotifyLeaksNoSecret(ctx, t, notifier, key, token) } func TestPushoverReadingUserKeyFromFile(t testing.T) { ctx, apiURL, fn := test.GetContextWithCancelingURL() defer fn() const userKey = "user key" f, err := os.CreateTemp("", "pushover_user_key") require.NoError(t, err, "creating temp file failed") _, err = f.WriteString(userKey) require.NoError(t, err, "writing to temp file failed") notifier, err := New( &config.PushoverConfig{ UserKeyFile: f.Name(), Token: config.Secret("token"), HTTPConfig: &commoncfg.HTTPClientConfig{}, }, test.CreateTmpl(t), promslog.NewNopLogger(), ) notifier.apiURL = apiURL.String() require.NoError(t, err) test.AssertNotifyLeaksNoSecret(ctx, t, notifier, userKey) } func TestPushoverReadingTokenFromFile(t testing.T) { ctx, apiURL, fn := test.GetContextWithCancelingURL() defer fn() const token = "token" f, err := os.CreateTemp("", "pushover_token") require.NoError(t, err, "creating temp file failed") _, err = f.WriteString(token) require.NoError(t, err, "writing to temp file failed") notifier, err := New( &config.PushoverConfig{ UserKey: config.Secret("user key"), TokenFile: f.Name(), HTTPConfig: &commoncfg.HTTPClientConfig{}, }, test.CreateTmpl(t), promslog.NewNopLogger(), ) notifier.apiURL = apiURL.String() require.NoError(t, err) test.AssertNotifyLeaksNoSecret(ctx, t, notifier, token) }	3.08 KB	2025-05-25 12:27

Terminal