feat: hint transports if the subscription API is enabled

dunglas · Jan 24, 2024 · 327c5a7 · 327c5a7
1 parent 9580d7b
commit 327c5a7
Showing 1 changed file with 9 additions and 6 deletions.
diff --git a/caddy/caddy.go b/caddy/caddy.go
@@ -140,14 +140,17 @@ func (m *Mercure) Provision(ctx caddy.Context) error { //nolint:funlen
 			return nil, fmt.Errorf("invalid transport url: %w", err)
 		}
 
-		if m.WriteTimeout != nil {
-			query := u.Query()
-			if !query.Has("write_timeout") {
-				query.Set("write_timeout", time.Duration(*m.WriteTimeout).String())
-				u.RawQuery = query.Encode()
-			}
+		query := u.Query()
+		if m.WriteTimeout != nil && !query.Has("write_timeout") {
+			query.Set("write_timeout", time.Duration(*m.WriteTimeout).String())
+		}
+
+		if m.Subscriptions && !query.Has("subscriptions") {
+			query.Set("subscriptions", "1")
 		}
 
+		u.RawQuery = query.Encode()
+
 		transport, err := mercure.NewTransport(u, m.logger)
 		if err != nil {
 			return nil, err //nolint:wrapcheck