diff --git a/internal/event/target/webhook.go b/internal/event/target/webhook.go index 244df29ff..e3eed5e24 100644 --- a/internal/event/target/webhook.go +++ b/internal/event/target/webhook.go @@ -119,10 +119,17 @@ func (target *WebhookTarget) IsActive() (bool, error) { } return false, err } + tokens := strings.Fields(target.args.AuthToken) + switch len(tokens) { + case 2: + req.Header.Set("Authorization", target.args.AuthToken) + case 1: + req.Header.Set("Authorization", "Bearer "+target.args.AuthToken) + } resp, err := target.httpClient.Do(req) if err != nil { - if xnet.IsNetworkOrHostDown(err, false) || errors.Is(err, context.DeadlineExceeded) { + if xnet.IsNetworkOrHostDown(err, true) { return false, errNotConnected } return false, err @@ -133,7 +140,8 @@ func (target *WebhookTarget) IsActive() (bool, error) { return true, nil } -// Save - saves the events to the store if queuestore is configured, which will be replayed when the wenhook connection is active. +// Save - saves the events to the store if queuestore is configured, +// which will be replayed when the webhook connection is active. func (target *WebhookTarget) Save(eventData event.Event) error { if target.store != nil { return target.store.Put(eventData)