webhook

type CreateWebhookInput struct {
	Namespace string

	ID            *string
	URL           string
	CustomHeaders map[string]string
	Disabled      bool
	Secret        *string
	RateLimit     *uint16
	Description   *string
	EventTypes    []string
	Channels      []string
	Metadata      map[string]string
}

type DeleteWebhookInput = GetWebhookInput

type EvenTypeSchemaVersion = string

type EventType struct {
	Name        string
	Description string
	GroupName   string
	// Schemas defines the list of schemas for each event type version
	Schemas    map[EvenTypeSchemaVersion]EventTypeSchema
	Deprecated bool
}

type EventTypeHandler interface {
	RegisterEventTypes(ctx context.Context, params RegisterEventTypesInputs) error
}

type EventTypeSchema = interface{}

type ExpandParams struct {
	// Payload stores whether the message payload for the webhook message should be included in the response or not.
	Payload bool
	// DeliveryStatus stores whether the delivery status for the webhook message should be included in the response or not.
	DeliveryStatus bool
}

type GetMessageInput struct {
	Namespace string

	ID      string
	EventID string

	Expand ExpandParams
}

type GetWebhookInput struct {
	Namespace string

	ID string
}

type Handler interface {
	WebhookHandler
	MessageHandler
	EventTypeHandler
}

type ListWebhooksInput struct {
	Namespace string

	IDs        []string
	EventTypes []string
	Channels   []string
}

type Message struct {
	Namespace string

	ID        string
	EventID   string
	EventType string
	Channels  []string

	Annotations models.Annotations

	// Payload stores the message payload if it was requested.
	Payload *Payload

	// DeliveryStatuses stores the message delivery status if it was requested.
	DeliveryStatuses *[]MessageDeliveryStatus
}

type MessageDeliveryStatus struct {
	NextAttempt *time.Time                            `json:"nextAttempt"`
	State       notification.EventDeliveryStatusState `json:"state"`
	ChannelID   string                                `json:"channel_id"`
	Attempts    []notification.EventDeliveryAttempt   `json:"attempts"`
}

type MessageHandler interface {
	SendMessage(ctx context.Context, params SendMessageInput) (*Message, error)
	GetMessage(ctx context.Context, params GetMessageInput) (*Message, error)
	ResendMessage(ctx context.Context, params ResendMessageInput) error
}

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

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

type Payload = map[string]any

type RegisterEventTypesInputs struct {
	EventTypes  []EventType
	AllowUpdate bool
}

type ResendMessageInput struct {
	Namespace string

	ID        string
	EventID   string
	ChannelID string
}

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

type SendMessageInput struct {
	Namespace string

	EventID   string
	EventType string
	Channels  []string
	Payload   Payload
}

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

type UpdateWebhookChannelsInput struct {
	Namespace string

	ID             string
	AddChannels    []string
	RemoveChannels []string
}

type UpdateWebhookInput struct {
	Namespace string

	ID            string
	URL           string
	CustomHeaders map[string]string
	Disabled      bool
	Secret        *string
	RateLimit     *uint16
	Description   *string
	EventTypes    []string
	Channels      []string
	Metadata      map[string]string
}

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

type Webhook struct {
	Namespace string

	ID            string
	URL           string
	Secret        string
	CustomHeaders map[string]string
	Disabled      bool
	RateLimit     *uint16
	Description   string
	EventTypes    []string
	Channels      []string
	CreatedAt     time.Time
	UpdatedAt     time.Time
}

type WebhookHandler interface {
	ListWebhooks(ctx context.Context, params ListWebhooksInput) ([]Webhook, error)
	CreateWebhook(ctx context.Context, params CreateWebhookInput) (*Webhook, error)
	UpdateWebhook(ctx context.Context, params UpdateWebhookInput) (*Webhook, error)
	UpdateWebhookChannels(ctx context.Context, params UpdateWebhookChannelsInput) (*Webhook, error)
	GetWebhook(ctx context.Context, params GetWebhookInput) (*Webhook, error)
	DeleteWebhook(ctx context.Context, params DeleteWebhookInput) error
}