mirror of
https://github.com/teamhanko/hanko.git
synced 2025-10-28 23:30:15 +08:00
3cafb66754
* add tests for webhooks * improve error handling when context does not contain webhook manager * add logging to worker and fix nesting error overwrite * remove enable and disable methods in favor for update method * move data in jwt from subject claim to custom `data` claim * add event in jwt to custom `evt` claim * change webhook trigger to only fire once per hook (was once per subscribed event in hook before) Closes #692
74 lines
1.5 KiB
Go
74 lines
1.5 KiB
Go
package webhooks
|
|
|
|
import (
|
|
"bytes"
|
|
"encoding/json"
|
|
"fmt"
|
|
"github.com/labstack/echo/v4"
|
|
"github.com/teamhanko/hanko/backend/webhooks/events"
|
|
"net/http"
|
|
"strings"
|
|
"time"
|
|
)
|
|
|
|
type Webhook interface {
|
|
Trigger(data JobData) error
|
|
DisableOnExpiryDate(now time.Time) error
|
|
DisableOnFailure() error
|
|
Reset() error
|
|
IsEnabled() bool
|
|
HasEvent(evt events.Event) bool
|
|
}
|
|
|
|
type Webhooks []Webhook
|
|
|
|
const (
|
|
WebhookExpireDuration = 30 * 24 * time.Hour // 30 Days
|
|
)
|
|
|
|
type BaseWebhook struct {
|
|
Logger echo.Logger
|
|
Callback string
|
|
Events events.Events
|
|
}
|
|
|
|
func (bh *BaseWebhook) HasEvent(evt events.Event) bool {
|
|
for _, event := range bh.Events {
|
|
return strings.HasPrefix(string(evt), string(event))
|
|
}
|
|
|
|
return false
|
|
}
|
|
|
|
func (bh *BaseWebhook) Trigger(data JobData) error {
|
|
// create request
|
|
dataJson, err := json.Marshal(data)
|
|
if err != nil {
|
|
bh.Logger.Error(fmt.Errorf("unable to convert JobData to json: %w", err))
|
|
return err
|
|
}
|
|
|
|
request, err := http.NewRequest(http.MethodPost, bh.Callback, bytes.NewReader(dataJson))
|
|
if err != nil {
|
|
bh.Logger.Error(fmt.Errorf("unable to create request for webhook: %w", err))
|
|
return err
|
|
}
|
|
request.Header.Set("Content-Type", "application/json")
|
|
|
|
client := http.Client{}
|
|
response, err := client.Do(request)
|
|
if err != nil {
|
|
bh.Logger.Error(fmt.Errorf("unable to execute webhook request: %w", err))
|
|
return err
|
|
}
|
|
|
|
if response.StatusCode >= http.StatusBadRequest {
|
|
err := fmt.Errorf("request failed due to status code: %d", response.StatusCode)
|
|
bh.Logger.Error(err)
|
|
|
|
return err
|
|
}
|
|
|
|
return nil
|
|
}
|