webhook

type AttemptRecord struct {
	Number     int            `json:"attempt_number"`
	HTTPStatus *int           `json:"response_status,omitzero"`
	Error      *string        `json:"error,omitzero"`
	DurationMs *int           `json:"duration_ms,omitzero"`
	Response   map[string]any `json:"response,omitzero"`
	Succeeded  bool           `json:"succeeded"`
	CreatedAt  time.Time      `json:"created_at"`
}

type AttemptResult struct {
	HTTPStatus int
	Request    map[string]any
	Response   map[string]any
	Duration   time.Duration
	Err        error
	Succeeded  bool
}

type CreateParams struct {
	Name        string            `json:"name"`
	Description *string           `json:"description,omitzero"`
	Endpoint    string            `json:"endpoint"`
	Method      string            `json:"method,omitzero"`
	Headers     map[string]string `json:"headers,omitzero"`
	Enabled     *bool             `json:"enabled,omitzero"`
	EventTypes  []string          `json:"event_types,omitzero"`
}

type Delivery struct {
	ID          DeliveryID     `json:"id"`
	WebhookID   *WebhookID     `json:"webhook_id,omitzero"`
	Event       *string        `json:"event,omitzero"`
	HTTPStatus  *int           `json:"http_status,omitzero"`
	Response    map[string]any `json:"response,omitzero"`
	Attempts    int            `json:"attempts"`
	Succeeded   bool           `json:"succeeded"`
	Error       *string        `json:"error,omitzero"`
	CreatedAt   time.Time      `json:"created_at"`
	DeliveredAt *time.Time     `json:"delivered_at,omitzero"`
}

type DeliveryID = typeid.TypeID[deliveryPrefix]

type Executor = datastore.Executor

type ListParams struct {
	Enabled *bool
	Event   string
	Page
}

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

type Option func(*Module)

type OutboundDelivery struct {
	// URL is the registered endpoint.
	URL string
	// Method is the registered HTTP verb.
	Method string
	// Headers are the registered custom headers plus the signature set.
	Headers map[string]string
	// Body is the canonical JSON encoding of the event payload.
	Body []byte
}

type Page struct {
	Page  int
	Limit int
}

type PendingDelivery struct {
	ID    DeliveryID
	Event string
	Body  []byte
}

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

type Sender interface {
	Send(ctx context.Context, delivery OutboundDelivery) (status int, body []byte, err error)
}

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

type ServiceOption func(*Service)

type Store interface {
	List(ctx context.Context, params ListParams) ([]Webhook, int, error)
	Get(ctx context.Context, id WebhookID) (Webhook, error)
	Create(ctx context.Context, params CreateParams, encryptedSecret string) (Webhook, error)
	Update(ctx context.Context, id WebhookID, params UpdateParams) (Webhook, error)
	Delete(ctx context.Context, id WebhookID) error
	SetSecret(ctx context.Context, id WebhookID, encryptedSecret string) error

	// Subscribers returns the enabled endpoints for an event, with
	// their decrypted-at-the-service-layer secret still encrypted.
	Subscribers(ctx context.Context, event string) ([]Webhook, error)
	// Secret returns the stored ciphertext for one endpoint.
	Secret(ctx context.Context, id WebhookID) (string, error)

	// InsertDelivery writes the outbox record (pending delivery).
	InsertDelivery(ctx context.Context, exec Executor, delivery *Delivery, body []byte) error
	// DeliveryForSend loads the immutable body bytes and event name
	// for one attempt.
	DeliveryForSend(ctx context.Context, id DeliveryID) (PendingDelivery, error)
	// RecordAttempt appends one attempt row and folds its outcome
	// into the delivery.
	RecordAttempt(ctx context.Context, id DeliveryID, result AttemptResult) error
	// ListAttempts returns the attempt history of one delivery in
	// attempt order.
	ListAttempts(ctx context.Context, id DeliveryID) ([]AttemptRecord, error)
	ListDeliveries(ctx context.Context, params ListParams, webhookID *WebhookID) ([]Delivery, int, error)
	// PruneDeliveries deletes deliveries recorded before the cutoff.
	PruneDeliveries(ctx context.Context, before time.Time) (int64, error)
}

type UpdateParams struct {
	Name        *string           `json:"name,omitzero"`
	Description *string           `json:"description,omitzero"`
	Endpoint    *string           `json:"endpoint,omitzero"`
	Method      *string           `json:"method,omitzero"`
	Headers     map[string]string `json:"headers,omitzero"`
	Enabled     *bool             `json:"enabled,omitzero"`
	EventTypes  []string          `json:"event_types,omitzero"`
}

type Webhook struct {
	ID          WebhookID         `json:"id"`
	Name        string            `json:"name"`
	Description *string           `json:"description,omitzero"`
	Endpoint    string            `json:"endpoint"`
	Method      string            `json:"method"`
	Headers     map[string]string `json:"headers,omitzero"`
	Enabled     bool              `json:"enabled"`
	EventTypes  []string          `json:"event_types"`

	// Secret is the plaintext signing secret. It is populated on
	// create/rotate only; listings and reads never carry it.
	Secret *string `json:"secret,omitzero"`

	CreatedAt time.Time  `json:"created_at"`
	UpdatedAt *time.Time `json:"updated_at,omitzero"`
}

type WebhookDeliveryTask struct {
	// DeliveryID identifies the webhook_deliveries row to update.
	DeliveryID string `json:"delivery_id"`

	// WebhookID identifies the endpoint row.
	WebhookID string `json:"webhook_id"`
}

type WebhookID = typeid.TypeID[webhookPrefix]