Method RemoveWebhook

backend/api/v1/project_service.go:899–943

RemoveWebhook removes a webhook from a given project.

(ctx context.Context, req *connect.Request[v1pb.RemoveWebhookRequest])

// RemoveWebhook removes a webhook from a given project.
func (s *ProjectService) RemoveWebhook(ctx context.Context, req *connect.Request[v1pb.RemoveWebhookRequest]) (*connect.Response[v1pb.Project], error) {
	projectID, webhookID, err := common.GetProjectIDWebhookID(req.Msg.Webhook.Name)
	if err != nil {
		return nil, connect.NewError(connect.CodeInvalidArgument, err)
	}

	workspaceID := common.GetWorkspaceIDFromContext(ctx)
	project, err := s.store.GetProject(ctx, &store.FindProjectMessage{
		Workspace:  workspaceID,
		ResourceID: &projectID,
	})
	if err != nil {
		return nil, connect.NewError(connect.CodeInternal, err)
	}
	if project == nil {
		return nil, connect.NewError(connect.CodeNotFound, errors.Errorf("project %q not found", webhookID))
	}
	if project.Deleted {
		return nil, connect.NewError(connect.CodeNotFound, errors.Errorf("project %q has been deleted", projectID))
	}

	webhook, err := s.store.GetProjectWebhook(ctx, &store.FindProjectWebhookMessage{
		ProjectID:  &project.ResourceID,
		ResourceID: &webhookID,
	})
	if err != nil {
		return nil, connect.NewError(connect.CodeInternal, err)
	}
	if webhook == nil {
		return nil, connect.NewError(connect.CodeNotFound, errors.Errorf("webhook %q not found", req.Msg.Webhook.Url))
	}

	if err := s.store.DeleteProjectWebhook(ctx, project.ResourceID, webhook.ResourceID); err != nil {
		return nil, connect.NewError(connect.CodeInternal, err)
	}

	project, err = s.store.GetProject(ctx, &store.FindProjectMessage{
		Workspace:  workspaceID,
		ResourceID: &projectID,
	})
	if err != nil {
		return nil, connect.NewError(connect.CodeInternal, err)
	}
	return connect.NewResponse(convertToProject(project)), nil
}

// TestWebhook tests a webhook.
func (s *ProjectService) TestWebhook(ctx context.Context, req *connect.Request[v1pb.TestWebhookRequest]) (*connect.Response[v1pb.TestWebhookResponse], error) {