webhook

type BatchResult struct {
	URL     string
	Results []DeliveryResult
	Error   error
}

type BatchSender struct {
	// contains filtered or unexported fields
}

type ContextKey string

type DeliveryResult struct {
	// Success indicates if the delivery was successful.
	Success bool

	// StatusCode is the HTTP status code received.
	StatusCode int

	// ResponseBody is the response body (truncated if large).
	ResponseBody string

	// Duration is how long the request took.
	Duration time.Duration

	// Attempt is which attempt this was (1-based).
	Attempt int

	// Error is the error if delivery failed.
	Error error

	// Timestamp is when this attempt was made.
	Timestamp time.Time
}

type Dispatcher struct {
	// contains filtered or unexported fields
}

type Event struct {
	// ID is a unique identifier for this event.
	ID string `json:"id"`

	// Type is the event type (e.g., "order.created", "user.updated").
	Type string `json:"type"`

	// Timestamp is when the event occurred.
	Timestamp time.Time `json:"timestamp"`

	// Data is the event payload.
	Data any `json:"data"`

	// Metadata contains additional event metadata.
	Metadata map[string]string `json:"metadata,omitempty"`
}

type GitHubVerifier struct {
	// contains filtered or unexported fields
}

type Group struct {
	// contains filtered or unexported fields
}

type HMACConfig struct {
	Secret      string
	Algorithm   HashAlgorithm
	Header      string
	Prefix      string
	MaxBodySize int64
}

type HMACVerifier struct {
	// Secret is the shared secret for HMAC computation.
	Secret []byte

	// Algorithm is the hash algorithm to use.
	Algorithm HashAlgorithm

	// Header is the HTTP header containing the signature.
	Header string

	// Prefix is an optional prefix to strip from the signature (e.g., "sha256=").
	Prefix string

	// MaxBodySize is the maximum allowed request body size.
	MaxBodySize int64
}

type Handler func(ctx context.Context, event *RawEvent) error

type HandlerFunc func(w http.ResponseWriter, r *http.Request, event *RawEvent)

type HashAlgorithm string

type Payload struct {
	// Event is the webhook event.
	Event RawEvent `json:"event"`

	// DeliveryID is the unique ID for this delivery attempt.
	DeliveryID string `json:"delivery_id,omitempty"`

	// Attempt is the delivery attempt number (1-based).
	Attempt int `json:"attempt,omitempty"`
}

type RawEvent struct {
	// ID is a unique identifier for this event.
	ID string `json:"id"`

	// Type is the event type.
	Type string `json:"type"`

	// Timestamp is when the event occurred.
	Timestamp time.Time `json:"timestamp"`

	// Data is the raw JSON event payload.
	Data json.RawMessage `json:"data"`

	// Metadata contains additional event metadata.
	Metadata map[string]string `json:"metadata,omitempty"`
}

type Response struct {
	Success bool   `json:"success"`
	Message string `json:"message,omitempty"`
	Error   string `json:"error,omitempty"`
}

type Router struct {
	// contains filtered or unexported fields
}

type RouterConfig struct {
	// Verifier is used to verify incoming webhook signatures.
	// If nil, signatures are not verified.
	Verifier Verifier

	// MaxBodySize is the maximum allowed request body size.
	// Default: 10MB
	MaxBodySize int64

	// ErrorHandler is called when an error occurs.
	// If nil, a default error response is sent.
	ErrorHandler func(w http.ResponseWriter, r *http.Request, err error)

	// EventParser parses the webhook payload into an event.
	// If nil, the default JSON parser is used.
	EventParser func([]byte) (*RawEvent, error)

	// BeforeHandler is called before any event handler.
	// Can be used for logging, metrics, or additional validation.
	BeforeHandler func(ctx context.Context, event *RawEvent) error

	// AfterHandler is called after event handlers complete.
	// Can be used for logging or cleanup.
	AfterHandler func(ctx context.Context, event *RawEvent, err error)
}

type Sender struct {
	// contains filtered or unexported fields
}

type SenderConfig struct {
	// SigningSecret is the secret used to sign outgoing webhooks.
	// If empty, webhooks are sent without signatures.
	SigningSecret string

	// SignatureHeader is the header name for the signature.
	// Default: "X-Webhook-Signature"
	SignatureHeader string

	// TimestampHeader is the header name for the timestamp.
	// Default: "X-Webhook-Timestamp"
	TimestampHeader string

	// HTTPClient is the HTTP client to use.
	// If nil, a default client with reasonable timeouts is used.
	HTTPClient *http.Client

	// Timeout is the timeout for each delivery attempt.
	// Default: 30 seconds
	Timeout time.Duration

	// MaxRetries is the maximum number of retry attempts.
	// Default: 3
	MaxRetries int

	// RetryBackoff is the initial backoff duration between retries.
	// Default: 1 second
	RetryBackoff time.Duration

	// MaxBackoff is the maximum backoff duration.
	// Default: 1 minute
	MaxBackoff time.Duration

	// BackoffMultiplier is the multiplier for exponential backoff.
	// Default: 2.0
	BackoffMultiplier float64

	// Headers are additional headers to include in all requests.
	Headers map[string]string

	// UserAgent is the User-Agent header value.
	// Default: "Waffle-Webhook/1.0"
	UserAgent string

	// OnDelivery is called after each delivery attempt.
	// Can be used for logging or metrics.
	OnDelivery func(url string, result DeliveryResult)
}

type ShopifyVerifier struct {
	// contains filtered or unexported fields
}

type SlackVerifier struct {
	// contains filtered or unexported fields
}

type StripeVerifier struct {
	// contains filtered or unexported fields
}

type Subscription struct {
	// ID is a unique identifier for this subscription.
	ID string `json:"id"`

	// URL is the endpoint to deliver webhooks to.
	URL string `json:"url"`

	// Events is a list of event types to subscribe to.
	// Use "*" to subscribe to all events.
	Events []string `json:"events"`

	// Secret is the signing secret for this subscription.
	Secret string `json:"secret,omitempty"`

	// Active indicates if the subscription is active.
	Active bool `json:"active"`

	// Metadata contains additional subscription metadata.
	Metadata map[string]string `json:"metadata,omitempty"`

	// CreatedAt is when the subscription was created.
	CreatedAt time.Time `json:"created_at"`

	// UpdatedAt is when the subscription was last updated.
	UpdatedAt time.Time `json:"updated_at"`
}

type TwilioVerifier struct {
	// contains filtered or unexported fields
}

type Verifier interface {
	// Verify verifies the webhook signature from an HTTP request.
	Verify(r *http.Request) error

	// VerifyPayload verifies the webhook signature for a raw payload.
	VerifyPayload(payload []byte, signature string) error
}

type VerifyRequest struct {
	// Body is the raw request body.
	Body []byte

	// Signature is the signature from the request.
	Signature string

	// Timestamp is the timestamp from the request (if available).
	Timestamp time.Time

	// Headers contains relevant headers.
	Headers http.Header
}