Method handleListWebhookDeliveries

internal/httpapi/webhooks.go:331–366

(ctx context.Context, in *ListDeliveriesInput)

}

func (s *Server) handleListWebhookDeliveries(ctx context.Context, in *ListDeliveriesInput) (*listDeliveriesOutput, error) {
	user, err := s.requireAccountUser(ctx)
	if err != nil {
		return nil, err
	}
	if s.deps.ListDeliveries == nil {
		return nil, NewError(http.StatusNotFound, "not_found", "deliveries endpoint not configured")
	}
	// Ownership: deliveries are scoped to a webhook the caller owns.
	if wh, err := s.deps.GetWebhook(ctx, in.ID, user.ID); err != nil || wh == nil {
		return nil, NewError(http.StatusNotFound, "not_found", "webhook not found")
	}
	limit := in.Limit
	if limit <= 0 {
		limit = 50
	}
	rows, err := s.deps.ListDeliveries(ctx, in.ID, in.Status, limit)
	if err != nil {
		return nil, NewError(http.StatusInternalServerError, "internal_error", "failed to list deliveries")
	}
	items := make([]WebhookDeliveryView, 0, len(rows))
	for _, d := range rows {
		v := WebhookDeliveryView{
			ID: d.ID, EventType: d.EventType, Status: d.Status, Attempts: d.Attempts,
			LastError: d.LastError, LastStatusCode: d.LastStatusCode,
			NextRetryAt: d.NextRetryAt.UTC().Format(time.RFC3339),
			CreatedAt:   d.CreatedAt.UTC().Format(time.RFC3339),
		}
		if d.LastAttemptAt != nil {
			v.LastAttemptAt = d.LastAttemptAt.UTC().Format(time.RFC3339)
		}
		items = append(items, v)
	}
	// No cursor continuation in the store (limit only) — next_cursor null.
	return &listDeliveriesOutput{Body: NewPage(items, "")}, nil
}

// UpdateWebhookRequest mirrors the legacy PATCH body — pointer fields so
// absent != zero; url/events/filters are full-replace when present.