Method CreateProjectWebhook

backend/store/project_webhook.go:41–81

CreateProjectWebhook creates an instance of ProjectWebhook.

(ctx context.Context, projectID string, create *ProjectWebhookMessage)

// CreateProjectWebhook creates an instance of ProjectWebhook.
func (s *Store) CreateProjectWebhook(ctx context.Context, projectID string, create *ProjectWebhookMessage) (*ProjectWebhookMessage, error) {
	payload := []byte("{}")
	if create.Payload != nil {
		p, err := protojson.Marshal(create.Payload)
		if err != nil {
			return nil, errors.Wrapf(err, "failed to marshal")
		}
		payload = p
	}

	projectWebhook := ProjectWebhookMessage{
		ProjectID: projectID,
		Payload:   create.Payload,
	}

	q := qb.Q().Space(`
		INSERT INTO project_webhook (
			project,
			payload
		)
		VALUES (?, ?)
		RETURNING resource_id
	`, projectID, payload)

	query, args, err := q.ToSQL()
	if err != nil {
		return nil, errors.Wrapf(err, "failed to build sql")
	}

	if err := s.GetDB().QueryRowContext(ctx, query, args...).Scan(
		&projectWebhook.ResourceID,
	); err != nil {
		if err == sql.ErrNoRows {
			return nil, common.FormatDBErrorEmptyRowWithQuery(query)
		}
		return nil, err
	}

	s.removeProjectCache(projectID)
	return &projectWebhook, nil
}

// ListProjectWebhooks lists a list of ProjectWebhook instances.
func (s *Store) ListProjectWebhooks(ctx context.Context, find *FindProjectWebhookMessage) ([]*ProjectWebhookMessage, error) {