Method handleTestWebhook

internal/httpapi/webhooks.go:267–304

(ctx context.Context, in *testWebhookInput)

}

func (s *Server) handleTestWebhook(ctx context.Context, in *testWebhookInput) (*testWebhookOutput, error) {
	user, err := s.requireAccountUser(ctx)
	if err != nil {
		return nil, err
	}
	if s.deps.TestWebhookInsert == nil {
		return nil, NewError(http.StatusNotFound, "not_found", "test endpoint not configured")
	}
	wh, err := s.deps.GetWebhook(ctx, in.ID, user.ID)
	if err != nil || wh == nil {
		return nil, NewError(http.StatusNotFound, "not_found", "webhook not found")
	}
	if !wh.Enabled {
		return nil, NewError(http.StatusConflict, "webhook_disabled", "webhook is disabled")
	}
	event := in.Body.Event
	if event == "" {
		event = webhookpub.EventEmailReceived
	}
	if !webhookpub.IsValidEventType(event) {
		return nil, NewError(http.StatusBadRequest, "invalid_event_type", fmt.Sprintf("unknown event type %q", event))
	}
	data := in.Body.Data
	if data == nil {
		data = map[string]any{"test": true}
	}
	envelope, err := json.Marshal(webhookpub.NewEvent(event, user.ID, data).AsEnvelope())
	if err != nil {
		return nil, NewError(http.StatusInternalServerError, "internal_error", "failed to marshal test event")
	}
	deliveryID, err := s.deps.TestWebhookInsert(ctx, wh.ID, event, envelope)
	if err != nil {
		return nil, NewError(http.StatusInternalServerError, "internal_error", "failed to schedule test delivery")
	}
	out := &testWebhookOutput{}
	out.Body.DeliveryID = deliveryID
	return out, nil
}

// WebhookDeliveryView mirrors the legacy per-delivery wire shape.
type WebhookDeliveryView struct {