Method WebhookLogs

internal/service/admin_webhooks.go:265–296

WebhookLogs returns a paginated list of webhook delivery logs, optionally filtered by webhook id. Requires super-admin auth. Logic migrated from internal/graphql/webhook_logs.go.

(ctx context.Context, meta RequestMetadata, params *model.ListWebhookLogRequest)

// filtered by webhook id. Requires super-admin auth. Logic migrated from
// internal/graphql/webhook_logs.go.
func (p *provider) WebhookLogs(ctx context.Context, meta RequestMetadata, params *model.ListWebhookLogRequest) (*model.WebhookLogs, *ResponseSideEffects, error) {
	log := p.Log.With().Str("func", "WebhookLogs").Logger()
	if err := p.requireSuperAdmin(ctx, meta); err != nil {
		return nil, nil, err
	}

	var pagination *model.Pagination
	var webhookID string
	if params != nil {
		pagination = utils.GetPagination(&model.PaginatedRequest{
			Pagination: params.Pagination,
		})
		webhookID = refs.StringValue(params.WebhookID)
	} else {
		pagination = utils.GetPagination(nil)
		webhookID = ""
	}

	webhookLogs, pagination, err := p.StorageProvider.ListWebhookLogs(ctx, pagination, webhookID)
	if err != nil {
		log.Debug().Err(err).Msg("failed ListWebhookLogs")
		return nil, nil, err
	}
	resItems := make([]*model.WebhookLog, len(webhookLogs))
	for i, webhookLog := range webhookLogs {
		resItems[i] = webhookLog.AsAPIWebhookLog()
	}
	return &model.WebhookLogs{
		Pagination:  pagination,
		WebhookLogs: resItems,
	}, nil, nil
}

// TestEndpoint sends a synthetic event payload to a webhook endpoint and returns
// the resulting HTTP status and response body. Requires super-admin auth. Logic