invisi/gotenberg
1
0
Fork 0
mirror of https://github.com/gotenberg/gotenberg.git synced 2026-07-02 00:17:40 +08:00
Code Issues Packages Projects Releases Wiki Activity

test(webhook): integration smoke for async webhook traceparent continuity

Browse Source
This commit is contained in:
Julien Neuhart
2026-06-02 18:56:06 +02:00
parent 8003109012
commit f5b26c0b2c
2 changed files with 38 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files
test/integration/features/webhook.feature
+12
View File
@@ -126,3 +126,15 @@ Feature: Webhook
"timestamp": "ignore"
}
"""
Scenario: Asynchronous Trace Continuity
Given I have a default Gotenberg container
Given I have a webhook server
When I make a "POST" request to Gotenberg at the "/forms/pdfengines/flatten" endpoint with the following form data and header(s):
| files | testdata/page_1.pdf | file |
| Gotenberg-Webhook-Url | http://host.docker.internal:%d/webhook | header |
| Gotenberg-Webhook-Error-Url | http://host.docker.internal:%d/webhook/error | header |
| traceparent | 00-0af7651916cd43dd8448eb211c80319c-b7ad6b7169203331-01 | header |
Then the response status code should be 204
When I wait for the asynchronous request to the webhook
Then the webhook request header "traceparent" should carry trace id "0af7651916cd43dd8448eb211c80319c"
test/integration/scenario/scenario.go
+26
View File
@@ -602,6 +602,31 @@ func (s *scenario) theHeaderValueShouldBe(kind, name string, expected string) er
return nil
}
func (s *scenario) theWebhookRequestHeaderShouldCarryTraceID(name, expected string) error {
if s.server == nil {
return errors.New("server not initialized")
}
if s.server.req == nil {
return errors.New("no webhook request found")
}
value := s.server.req.Header.Get(name)
if value == "" {
return fmt.Errorf("expected webhook request header %q to be set, but it is empty", name)
}
// W3C traceparent format: version "-" trace-id "-" parent-id "-" trace-flags.
parts := strings.Split(value, "-")
if len(parts) != 4 {
return fmt.Errorf("expected webhook request header %q to be a valid traceparent, but got %q", name, value)
}
if parts[1] != expected {
return fmt.Errorf("expected webhook request header %q to carry trace id %q, but actual is %q", name, expected, parts[1])
}
return nil
}
func (s *scenario) theCookieValueShouldBe(kind, name, expected string) error {
var cookies []*http.Cookie
switch {
@@ -1351,6 +1376,7 @@ func InitializeScenario(ctx *godog.ScenarioContext) {
ctx.Then(`^all concurrent response status codes should be (\d+)$`, s.allConcurrentResponseStatusCodesShouldBe)
ctx.Then(`^all concurrent responses should have (\d+) PDF\(s\)$`, s.allConcurrentResponsesShouldHavePdfs)
ctx.Then(`^the (response|webhook request|file request|server request) header "([^"]*)" should be "([^"]*)"$`, s.theHeaderValueShouldBe)
ctx.Then(`^the webhook request header "([^"]*)" should carry trace id "([^"]*)"$`, s.theWebhookRequestHeaderShouldCarryTraceID)
ctx.Then(`^the (response|webhook request|file request|server request) cookie "([^"]*)" should be "([^"]*)"$`, s.theCookieValueShouldBe)
ctx.Then(`^the (response|webhook request) body should match string:$`, s.theBodyShouldMatchString)
ctx.Then(`^the (response|webhook request) body should contain string:$`, s.theBodyShouldContainString)