1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
|
package notify
import (
"encoding/json"
"io"
"log/slog"
"net/http"
"net/http/httptest"
"os"
"testing"
)
func TestWebhookNotifier_Success(t *testing.T) {
var received Event
server := httptest.NewServer(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
body, _ := io.ReadAll(r.Body)
json.Unmarshal(body, &received)
w.WriteHeader(http.StatusOK)
}))
defer server.Close()
logger := slog.New(slog.NewTextHandler(os.Stderr, &slog.HandlerOptions{Level: slog.LevelError}))
notifier := NewWebhookNotifier(server.URL, logger)
event := Event{
TaskID: "t-1",
TaskName: "Test",
Status: "COMPLETED",
CostUSD: 0.50,
Duration: "2m30s",
}
if err := notifier.Notify(event); err != nil {
t.Fatalf("unexpected error: %v", err)
}
if received.TaskID != "t-1" {
t.Errorf("task_id: want 't-1', got %q", received.TaskID)
}
if received.CostUSD != 0.50 {
t.Errorf("cost: want 0.50, got %f", received.CostUSD)
}
}
func TestWebhookNotifier_ServerError(t *testing.T) {
server := httptest.NewServer(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
w.WriteHeader(http.StatusInternalServerError)
}))
defer server.Close()
logger := slog.New(slog.NewTextHandler(os.Stderr, &slog.HandlerOptions{Level: slog.LevelError}))
notifier := NewWebhookNotifier(server.URL, logger)
err := notifier.Notify(Event{TaskID: "t-1", Status: "COMPLETED"})
if err == nil {
t.Fatal("expected error for 500 response")
}
}
func TestMultiNotifier_FansOut(t *testing.T) {
var count int
counter := &countingNotifier{count: &count}
logger := slog.New(slog.NewTextHandler(os.Stderr, &slog.HandlerOptions{Level: slog.LevelError}))
multi := NewMultiNotifier(logger, counter, counter, counter)
multi.Notify(Event{TaskID: "t-1"})
if count != 3 {
t.Errorf("want 3 notifications, got %d", count)
}
}
func TestLogNotifier_NoError(t *testing.T) {
logger := slog.New(slog.NewTextHandler(os.Stderr, &slog.HandlerOptions{Level: slog.LevelError}))
notifier := &LogNotifier{Logger: logger}
if err := notifier.Notify(Event{TaskID: "t-1", Status: "COMPLETED"}); err != nil {
t.Errorf("unexpected error: %v", err)
}
}
type countingNotifier struct {
count *int
}
func (c *countingNotifier) Notify(_ Event) error {
*c.count++
return nil
}
|
