Method TriggerRefreshSources

admin/server/deployment.go:59–101

Deprecated: See details in api.proto.

(ctx context.Context, req *adminv1.TriggerRefreshSourcesRequest)

// Deprecated: See details in api.proto.
func (s *Server) TriggerRefreshSources(ctx context.Context, req *adminv1.TriggerRefreshSourcesRequest) (*adminv1.TriggerRefreshSourcesResponse, error) {
	observability.AddRequestAttributes(ctx,
		attribute.String("args.deployment_id", req.DeploymentId),
		attribute.StringSlice("args.sources", req.Sources),
	)

	depl, err := s.admin.DB.FindDeployment(ctx, req.DeploymentId)
	if err != nil {
		return nil, err
	}

	proj, err := s.admin.DB.FindProject(ctx, depl.ProjectID)
	if err != nil {
		return nil, err
	}

	claims := auth.GetClaims(ctx)
	if !claims.ProjectPermissions(ctx, proj.OrganizationID, depl.ProjectID).ManageProd {
		return nil, status.Error(codes.PermissionDenied, "does not have permission to manage deployment")
	}

	var names []*runtimev1.ResourceName
	for _, source := range req.Sources {
		names = append(names, &runtimev1.ResourceName{Kind: runtime.ResourceKindSource, Name: source})
	}

	rt, err := s.admin.OpenRuntimeClient(depl)
	if err != nil {
		return nil, err
	}
	defer rt.Close()

	_, err = rt.CreateTrigger(ctx, &runtimev1.CreateTriggerRequest{
		InstanceId: depl.RuntimeInstanceID,
		Resources:  names,
		All:        len(names) == 0, // Backwards compatibility
	})
	if err != nil {
		return nil, err
	}

	return &adminv1.TriggerRefreshSourcesResponse{}, nil
}

// ListDeployments returns a list of deployments for a given project.
func (s *Server) ListDeployments(ctx context.Context, req *adminv1.ListDeploymentsRequest) (*adminv1.ListDeploymentsResponse, error) {