webhooks

type QueueEmptyWebhookEventParams struct {
	WorkspaceID string
	QueueType   string
	SessionID   string
	Observer    string
	Observed    string
}

type WebhookClock interface {
	Now() time.Time
}

type WebhookDeliveryAttempt struct {
	EndpointID  string
	WorkspaceID string
	EventType   WebhookEventType
	Attempt     int
	Status      WebhookDeliveryStatus
	StatusCode  int
	ErrorClass  WebhookDeliveryErrorClass
	Error       string
	Retry       bool
	NextRetryAt *time.Time
	Evidence    WebhookDeliveryEvidence
	RecordedAt  time.Time
}

type WebhookDeliveryEndpoint struct {
	ID             string
	WorkspaceID    string
	URL            string
	Disabled       bool
	DisabledReason string
}

type WebhookDeliveryErrorClass string

type WebhookDeliveryEvidence struct {
	EndpointID  string
	EndpointURL string
	WorkspaceID string
	EventType   WebhookEventType
	Status      WebhookDeliveryStatus
	StatusCode  int
	ErrorClass  WebhookDeliveryErrorClass
	Attempt     int
	NextRetryAt *time.Time
}

type WebhookDeliveryRequest struct {
	WorkspaceID string
	Event       WebhookEvent
	Attempt     int
}

type WebhookDeliveryResult struct {
	EndpointID  string
	WorkspaceID string
	EventType   WebhookEventType
	Attempt     int
	Status      WebhookDeliveryStatus
	StatusCode  int
	ErrorClass  WebhookDeliveryErrorClass
	Error       string
	Retry       bool
	NextRetryAt *time.Time
	Evidence    WebhookDeliveryEvidence
}

type WebhookDeliveryStatus string

type WebhookDeliveryStore interface {
	ListWebhookDeliveryEndpoints(ctx context.Context, workspaceID string) ([]WebhookDeliveryEndpoint, error)
	RecordWebhookDelivery(ctx context.Context, attempt WebhookDeliveryAttempt) error
	DisableWebhookDeliveryEndpoint(ctx context.Context, endpoint WebhookDeliveryEndpoint, reason string, now time.Time) error
}

type WebhookDeliveryWorker struct {
	Store       WebhookDeliveryStore
	Client      WebhookHTTPClient
	Clock       WebhookClock
	Secret      string
	MaxAttempts int
	Backoff     func(attempt int) time.Duration
}

type WebhookEndpoint struct {
	ID          string    `json:"id"`
	WorkspaceID string    `json:"workspace_id"`
	URL         string    `json:"url"`
	CreatedAt   time.Time `json:"created_at"`
}

type WebhookEndpointCreateParams struct {
	WorkspaceID string
	URL         string
	Limit       int
	Now         time.Time
}

type WebhookEndpointCreateResult struct {
	Endpoint WebhookEndpoint `json:"endpoint"`
	Created  bool            `json:"created"`
}

type WebhookEvent struct {
	Type        WebhookEventType `json:"type"`
	WorkspaceID string           `json:"workspace_id"`
	Data        map[string]any   `json:"data,omitempty"`
}

type WebhookEventType string

type WebhookHTTPClient interface {
	PostWebhook(ctx context.Context, req WebhookHTTPRequest) (WebhookHTTPResponse, error)
}

type WebhookHTTPRequest struct {
	URL     string
	Body    string
	Headers map[string]string
}

type WebhookHTTPResponse struct {
	StatusCode int
}