Method CreateWebhook

internal/store/webhooks.go:11–37

CreateWebhook registers a new webhook for a workspace.

(workspaceID string, input models.WebhookCreate)

// CreateWebhook registers a new webhook for a workspace.
func (s *Store) CreateWebhook(workspaceID string, input models.WebhookCreate) (*models.Webhook, error) {
	id := newID()
	ts := now()

	evts := input.Events
	if evts == "" {
		evts = `["*"]`
	}

	// Encrypt the HMAC secret at rest. With no encryption key configured
	// (common on self-host) encrypt() returns the plaintext unchanged, so
	// this stays a no-op fallback rather than a hard requirement.
	encSecret, err := s.encrypt(input.Secret)
	if err != nil {
		return nil, fmt.Errorf("encrypt webhook secret: %w", err)
	}

	_, err = s.db.Exec(s.q(`
		INSERT INTO webhooks (id, workspace_id, url, secret, events, active, created_at, updated_at, failure_count)
		VALUES (?, ?, ?, ?, ?, ?, ?, ?, 0)
	`), id, workspaceID, input.URL, encSecret, evts, s.dialect.BoolToInt(true), ts, ts)
	if err != nil {
		return nil, fmt.Errorf("insert webhook: %w", err)
	}

	return s.GetWebhook(id)
}

// GetWebhook retrieves a single webhook by ID.
func (s *Store) GetWebhook(id string) (*models.Webhook, error) {