mirror of
https://github.com/Rain-kl/OpenFlare.git
synced 2026-09-28 05:46:36 +08:00
ryan
63a24da9ee
Result: {"status":"keep","total_issues":8,"golint_canonicalheader":0,"golint_errname":0,"golint_errorlint":1,"golint_forcetypeassert":0,"golint_gosec":0,"golint_intrange":0,"golint_modernize":3,"golint_nilnil":3,"golint_perfsprint":0,"golint_prealloc":0,"golint_recvcheck":1,"golint_usestdlibvars":0,"golint_wastedassign":0,"golint_total":8,"golint_test_testifylint":0,"golint_test_thelper":0,"golint_test_usetesting":0,"golint_test_total":0,"eslint_problems":0,"eslint_errors":0,"eslint_warnings":0,"tsc_errors":0,"measure_s":39}
117 lines
3.1 KiB
Go
117 lines
3.1 KiB
Go
// Copyright 2026 Arctel.net
|
|
// SPDX-License-Identifier: Apache-2.0
|
|
|
|
package push
|
|
|
|
import (
|
|
"context"
|
|
"encoding/json"
|
|
"net/http"
|
|
"net/http/httptest"
|
|
"testing"
|
|
|
|
"github.com/stretchr/testify/assert"
|
|
"github.com/stretchr/testify/require"
|
|
)
|
|
|
|
func TestTelegramPusher_Send(t *testing.T) {
|
|
t.Run("successful send with HTML parse mode", func(t *testing.T) {
|
|
var receivedReq telegramMessageRequest
|
|
server := httptest.NewServer(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
|
|
assert.Equal(t, "/botmy-token/sendMessage", r.URL.Path)
|
|
assert.Equal(t, http.MethodPost, r.Method)
|
|
assert.Equal(t, "application/json", r.Header.Get("Content-Type"))
|
|
|
|
err := json.NewDecoder(r.Body).Decode(&receivedReq)
|
|
assert.NoError(t, err)
|
|
|
|
w.WriteHeader(http.StatusOK)
|
|
_, _ = w.Write([]byte(`{"ok": true}`))
|
|
}))
|
|
defer server.Close()
|
|
|
|
pusher := &TelegramPusher{}
|
|
cfg := Config{
|
|
Channel: "telegram",
|
|
URL: server.URL,
|
|
Secret: "my-token",
|
|
}
|
|
body := map[string]any{
|
|
"title": "Alert",
|
|
"content": "Host down",
|
|
"level": "CRITICAL",
|
|
}
|
|
_, err := pusher.Send(context.Background(), cfg, "123456", body, "", nil)
|
|
require.NoError(t, err)
|
|
|
|
assert.Equal(t, "123456", receivedReq.ChatID)
|
|
assert.Contains(t, receivedReq.Text, "[CRITICAL] Alert")
|
|
assert.Contains(t, receivedReq.Text, "Host down")
|
|
assert.Equal(t, "HTML", receivedReq.ParseMode)
|
|
})
|
|
|
|
t.Run("fallback to plain text on HTML error", func(t *testing.T) {
|
|
var requests []*telegramMessageRequest
|
|
server := httptest.NewServer(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
|
|
var req telegramMessageRequest
|
|
err := json.NewDecoder(r.Body).Decode(&req)
|
|
assert.NoError(t, err)
|
|
requests = append(requests, &req)
|
|
|
|
if len(requests) == 1 {
|
|
w.WriteHeader(http.StatusBadRequest)
|
|
_, _ = w.Write([]byte(`{"ok": false, "error_code": 400, "description": "Bad Request: can't parse entities"}`))
|
|
} else {
|
|
w.WriteHeader(http.StatusOK)
|
|
_, _ = w.Write([]byte(`{"ok": true}`))
|
|
}
|
|
}))
|
|
defer server.Close()
|
|
|
|
pusher := &TelegramPusher{}
|
|
cfg := Config{
|
|
Channel: "telegram",
|
|
URL: server.URL,
|
|
Secret: "my-token",
|
|
}
|
|
body := map[string]any{
|
|
"title": "Alert & Info",
|
|
"content": "A < B comparison",
|
|
"level": "INFO",
|
|
}
|
|
_, err := pusher.Send(context.Background(), cfg, "123456", body, "", nil)
|
|
require.NoError(t, err)
|
|
|
|
require.Len(t, requests, 2)
|
|
assert.Equal(t, "HTML", requests[0].ParseMode)
|
|
assert.Empty(t, requests[1].ParseMode)
|
|
assert.Contains(t, requests[1].Text, "[INFO] Alert & Info")
|
|
assert.Contains(t, requests[1].Text, "A < B comparison")
|
|
})
|
|
|
|
t.Run("validation error", func(t *testing.T) {
|
|
pusher := &TelegramPusher{}
|
|
cfg := Config{
|
|
Channel: "telegram",
|
|
URL: "https://api.telegram.org",
|
|
}
|
|
err := pusher.ValidateConfig(cfg)
|
|
require.Error(t, err)
|
|
|
|
cfg = Config{
|
|
Channel: "telegram",
|
|
URL: "ftp://api.telegram.org",
|
|
Secret: "token",
|
|
}
|
|
err = pusher.ValidateConfig(cfg)
|
|
require.Error(t, err)
|
|
|
|
cfg = Config{
|
|
Channel: "telegram",
|
|
Secret: "token",
|
|
}
|
|
err = pusher.ValidateConfig(cfg)
|
|
assert.NoError(t, err)
|
|
})
|
|
}
|