aboutsummaryrefslogtreecommitdiff
path: root/weed/notification/webhook/http_test.go
diff options
context:
space:
mode:
Diffstat (limited to 'weed/notification/webhook/http_test.go')
-rw-r--r--weed/notification/webhook/http_test.go12
1 files changed, 8 insertions, 4 deletions
diff --git a/weed/notification/webhook/http_test.go b/weed/notification/webhook/http_test.go
index 5a008d2a5..f7ef006ae 100644
--- a/weed/notification/webhook/http_test.go
+++ b/weed/notification/webhook/http_test.go
@@ -48,7 +48,7 @@ func TestHttpClientSendMessage(t *testing.T) {
},
}
- err = client.sendMessage("/test/path", message)
+ err = client.sendMessage(newWebhookMessage("/test/path", message))
if err != nil {
t.Fatalf("Failed to send message: %v", err)
}
@@ -57,6 +57,10 @@ func TestHttpClientSendMessage(t *testing.T) {
t.Errorf("Expected key '/test/path', got %v", receivedPayload["key"])
}
+ if receivedPayload["event_type"] != "create" {
+ t.Errorf("Expected event_type 'create', got %v", receivedPayload["event_type"])
+ }
+
if receivedPayload["message"] == nil {
t.Error("Expected message to be present")
}
@@ -92,7 +96,7 @@ func TestHttpClientSendMessageWithoutToken(t *testing.T) {
message := &filer_pb.EventNotification{}
- err = client.sendMessage("/test/path", message)
+ err = client.sendMessage(newWebhookMessage("/test/path", message))
if err != nil {
t.Fatalf("Failed to send message: %v", err)
}
@@ -120,7 +124,7 @@ func TestHttpClientSendMessageServerError(t *testing.T) {
message := &filer_pb.EventNotification{}
- err = client.sendMessage("/test/path", message)
+ err = client.sendMessage(newWebhookMessage("/test/path", message))
if err == nil {
t.Error("Expected error for server error response")
}
@@ -139,7 +143,7 @@ func TestHttpClientSendMessageNetworkError(t *testing.T) {
message := &filer_pb.EventNotification{}
- err = client.sendMessage("/test/path", message)
+ err = client.sendMessage(newWebhookMessage("/test/path", message))
if err == nil {
t.Error("Expected error for network failure")
}