Method UpdateProjectWebhook

backend/store/project_webhook.go:174–218

UpdateProjectWebhook updates an instance of ProjectWebhook.

(ctx context.Context, projectResourceID string, webhookResourceID string, update *UpdateProjectWebhookMessage)

// UpdateProjectWebhook updates an instance of ProjectWebhook.
func (s *Store) UpdateProjectWebhook(ctx context.Context, projectResourceID string, webhookResourceID string, update *UpdateProjectWebhookMessage) (*ProjectWebhookMessage, error) {
	var payload []byte
	if update.Payload != nil {
		p, err := protojson.Marshal(update.Payload)
		if err != nil {
			return nil, errors.Wrapf(err, "failed to marshal payload")
		}
		payload = p
	}

	q := qb.Q().Space(`
		UPDATE project_webhook
		SET payload = ?
		WHERE resource_id = ?
		RETURNING resource_id, project, payload
	`, payload, webhookResourceID)

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

	projectWebhook := ProjectWebhookMessage{
		Payload: &storepb.ProjectWebhook{},
	}
	var returnedPayload []byte
	// Execute update query with RETURNING.
	if err := s.GetDB().QueryRowContext(ctx, query, args...).Scan(
		&projectWebhook.ResourceID,
		&projectWebhook.ProjectID,
		&returnedPayload,
	); err != nil {
		if err == sql.ErrNoRows {
			return nil, &common.Error{Code: common.NotFound, Err: errors.Errorf("project hook not found: %s", webhookResourceID)}
		}
		return nil, err
	}

	if err := common.ProtojsonUnmarshaler.Unmarshal(returnedPayload, projectWebhook.Payload); err != nil {
		return nil, errors.Wrapf(err, "failed to unmarshal")
	}

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

// DeleteProjectWebhook deletes an existing projectWebhook by resource ID.
func (s *Store) DeleteProjectWebhook(ctx context.Context, projectResourceID string, webhookResourceID string) error {